Skip to content
Snippets Groups Projects
Commit 472018ea authored by KERDREUX Jerome's avatar KERDREUX Jerome
Browse files

Cleanup

parent 99d0a362
Branches
Tags
No related merge requests found
...@@ -58,21 +58,21 @@ func (gw *Gateway) mqttPublishHander(client MQTT.Client, msg MQTT.Message) { ...@@ -58,21 +58,21 @@ func (gw *Gateway) mqttPublishHander(client MQTT.Client, msg MQTT.Message) {
} }
// Is it devices definitions ? // Is it devices definitions ?
if msg.Topic() == gw.config.topic+"/bridge/devices" { if msg.Topic() == gw.config.topic+"/bridge/devices" {
gw.jsonParseDevices(msg.Payload()) gw.jsonParseDevices(msg)
} else { } else {
dev := gw.GetZDeviceByTopic(msg.Topic()) zDev := gw.GetZDeviceByTopic(msg.Topic())
// mqttDumpMsg(msg) // mqttDumpMsg(msg)
if dev != nil { if zDev != nil {
dev.HandleMessage(msg) zDev.HandleMessage(msg)
} }
} }
} }
// jsonParseDevices parses the bridge/devices json and creates new xAAL devices // jsonParseDevices parses the bridge/devices json and creates new xAAL devices
// if they don't exist // if they don't exist
func (gw *Gateway) jsonParseDevices(jsonData []byte) { func (gw *Gateway) jsonParseDevices(msg MQTT.Message) {
var devices []Z2MDevice var devices []Z2MDevice
err := json.Unmarshal([]byte(jsonData), &devices) err := json.Unmarshal(msg.Payload(), &devices)
if err != nil { if err != nil {
slog.Error("Error decoding JSON", "err", err) slog.Error("Error decoding JSON", "err", err)
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment