From abc0ad082515ddb00c5efe46e9ddf64ceb97ecb4 Mon Sep 17 00:00:00 2001 From: Wolfgang Hottgenroth Date: Mon, 11 Nov 2024 17:19:04 +0100 Subject: [PATCH] some more attributes --- src/udi/handlers/z2m/z2m.go | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/src/udi/handlers/z2m/z2m.go b/src/udi/handlers/z2m/z2m.go index a9dc3c5..1f45891 100644 --- a/src/udi/handlers/z2m/z2m.go +++ b/src/udi/handlers/z2m/z2m.go @@ -19,7 +19,7 @@ type Z2MHandler struct { dbh *database.DatabaseHandle } -func parse(T any, payload string, variables *map[string]database.VariableType, attributes *map[string]interface{}) error { +func parse(T any, payload string, variables *map[string]database.VariableType) error { observationType := reflect.TypeOf(T) observation := reflect.New(observationType).Interface() @@ -44,7 +44,6 @@ func parse(T any, payload string, variables *map[string]database.VariableType, a } } - (*attributes)["Status"] = "ok" return nil } @@ -90,12 +89,15 @@ func (self *Z2MHandler) Handle(message handler.MessageT) { measurement.Attributes = make(map[string]interface{}) err3 := parse(T, message.Payload, - &(measurement.Values), - &(measurement.Attributes)) + &(measurement.Values)) if err3 != nil { self.Lost("Model parser failed", err3, message) return } + + measurement.Attributes["Status"] = "ok" + measurement.Attributes["DeviceId"] = deviceId + measurement.Attributes["DeviceModel"] = device.DeviceType.ModelIdentifier log.Printf("Prepared measurement item: %s", measurement) self.dbh.StoreMeasurement(&measurement) self.S()