racecar_analytics create rows in subscription handlers

main.go

func SubscribeECU() {
	Client.Subscribe("ingest/ecu", 0, func(client mqtt.Client, msg mqtt.Message) {
		ecu := ECUFromBytes(msg.Payload())
		// ------ add this ------
		ecu, err := CreateECU(ecu)
		if err != nil {
			fmt.Printf("failed to create ecu: %v", err)
		}
		// ----------------------
		fmt.Printf("[MQ] Received ecu message: %v\n", ecu)
	})
}

func SubscribeBattery() {
	Client.Subscribe("ingest/battery", 0, func(client mqtt.Client, msg mqtt.Message) {
		battery := BatteryFromBytes(msg.Payload())
		// ------ add this ------
		battery, err := CreateBattery(battery)
		if err != nil {
			fmt.Printf("failed to create battery: %v", err)
		}
		// ----------------------
		fmt.Printf("[MQ] Received battery message: %v\n", battery)
	})
}