From 4a56fea33b0edd61d79502f9efa1301224e9215b Mon Sep 17 00:00:00 2001 From: Wolfgang Hottgenroth Date: Sun, 14 Jan 2024 15:09:41 +0100 Subject: [PATCH] timestamp added --- src/locsrv/main.go | 3 +++ src/locsrv/mqtt/mqtt.go | 2 +- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/src/locsrv/main.go b/src/locsrv/main.go index bb79397..30dfbb3 100644 --- a/src/locsrv/main.go +++ b/src/locsrv/main.go @@ -2,6 +2,7 @@ package main import ( "log" + "time" "github.com/gin-gonic/gin" "net/http" "encoding/json" @@ -30,6 +31,7 @@ type locativeEvent struct { Latitude string `json:"latitude"` Longitude string `json:"longitude"` Person string `json:"person"` + Timestamp string `json:"timestamp"` } @@ -46,6 +48,7 @@ func main() { person, err := dbh.GetPersonById(event.Device) event.Person = person event.Location = event.Id + event.Timestamp = time.Now().Format("2006-01-02 15:04:05 MST") event.Id = "" if err != nil { log.Printf("Person unknown: %v", err) diff --git a/src/locsrv/mqtt/mqtt.go b/src/locsrv/mqtt/mqtt.go index 63a0618..c33b806 100644 --- a/src/locsrv/mqtt/mqtt.go +++ b/src/locsrv/mqtt/mqtt.go @@ -45,7 +45,7 @@ func (self *MqttHandle) Publish(topicPost string, message string) error { } topic := fmt.Sprintf("%s/%s", self.pubTopic, topicPost) - token := self.client.Publish(topic, 0, false, message) + token := self.client.Publish(topic, 0, true, message) token.Wait() if token.Error() != nil { return fmt.Errorf("MQTT publish failed: %v", token.Error())