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

Fix logging

parent c46e131a
No related branches found
No related tags found
No related merge requests found
...@@ -66,7 +66,7 @@ func parseDeviceJSON(jsonData []byte) { ...@@ -66,7 +66,7 @@ func parseDeviceJSON(jsonData []byte) {
var devices []BridgeDevice var devices []BridgeDevice
err := json.Unmarshal([]byte(jsonData), &devices) err := json.Unmarshal([]byte(jsonData), &devices)
if err != nil { if err != nil {
slog.Error("Error decoding JSON: %v", slog.Any("err", err)) slog.Error("Error decoding JSON", "err", err)
} }
gw := GetGW() gw := GetGW()
...@@ -110,7 +110,7 @@ func parseDeviceJSON(jsonData []byte) { ...@@ -110,7 +110,7 @@ func parseDeviceJSON(jsonData []byte) {
} }
func updateXAALDevice(bDevice *BridgeDevice, payload map[string]interface{}) { func updateXAALDevice(bDevice *BridgeDevice, payload map[string]interface{}) {
slog.Info("Updating device :", slog.Any("name", bDevice.FriendlyName)) slog.Info("Updating device:", "name", bDevice.FriendlyName)
for _, dev := range bDevice.XAALDevice { for _, dev := range bDevice.XAALDevice {
for key, value := range payload { for key, value := range payload {
if key == "contact" && dev.DevType == "contact.basic" { if key == "contact" && dev.DevType == "contact.basic" {
...@@ -135,7 +135,7 @@ func deviceHandler(device *BridgeDevice, msg MQTT.Message) { ...@@ -135,7 +135,7 @@ func deviceHandler(device *BridgeDevice, msg MQTT.Message) {
var data map[string]interface{} var data map[string]interface{}
err := json.Unmarshal(msg.Payload(), &data) err := json.Unmarshal(msg.Payload(), &data)
if err != nil { if err != nil {
slog.Error("Error decoding JSON: %v", slog.Any("err", err)) slog.Error("Error decoding JSON", "err", err)
} else { } else {
updateXAALDevice(device, data) updateXAALDevice(device, data)
} }
...@@ -145,7 +145,7 @@ func dumpMessage(msg MQTT.Message) { ...@@ -145,7 +145,7 @@ func dumpMessage(msg MQTT.Message) {
var data map[string]interface{} var data map[string]interface{}
err := json.Unmarshal(msg.Payload(), &data) err := json.Unmarshal(msg.Payload(), &data)
if err != nil { if err != nil {
slog.Error("Error decoding JSON: %v", slog.Any("err", err)) slog.Error("Error decoding JSON %v", "err", err)
} }
keys := make([]string, 0, len(data)) keys := make([]string, 0, len(data))
...@@ -166,7 +166,7 @@ func publishHander(client MQTT.Client, msg MQTT.Message) { ...@@ -166,7 +166,7 @@ func publishHander(client MQTT.Client, msg MQTT.Message) {
return return
} }
slog.Debug("Received message on: ", slog.Any("topic", msg.Topic())) slog.Debug("Received message on", "topic", msg.Topic())
if msg.Topic() == mqttTopic+"/bridge/devices" { if msg.Topic() == mqttTopic+"/bridge/devices" {
parseDeviceJSON(msg.Payload()) parseDeviceJSON(msg.Payload())
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment