mqtt stuff

src/locsrv/main.go

@@ -2,13 +2,10 @@ package main
 
 import (
   "log"
-  "os"
-  "fmt"
   "github.com/gin-gonic/gin"
-  MQTT "github.com/eclipse/paho.mqtt.golang"
-  "github.com/google/uuid"
   "net/http"
   "locsrv/database"
+  "locsrv/mqtt"
 )
 
 /*
@@ -39,19 +36,7 @@ func main() {
 
   ch := make(chan locativeEvent)
   dbh := database.New()
-
-  mqttOpts := MQTT.NewClientOptions().
-    AddBroker(os.Getenv("MQTT_BROKER")).
-    SetClientID(fmt.Sprintf("locsrv-%s", uuid.New())).
-    SetConnectRetry(true)
-  mqttClient := MQTT.NewClient(mqttOpts)
-  if token := mqttClient.Connect(); token.Wait() && token.Error() != nil {
-    log.Fatalf("Unable to connect to broker, error %v", token.Error())
-  }
-  mqttTopic := os.Getenv("MQTT_TOPIC")
-  if mqttTopic != "" {
-    log.Fatalf("No topic set")
-  }
+  mqtt := mqtt.New()
 
   go func() {
     for {
@@ -63,6 +48,7 @@ func main() {
           log.Printf("Person unknown: %v", err)
         } 
         log.Printf("Trigger: %s, Device: %s, Location: %s, Person: %s, Latitude: %s, Longitude: %s", event.Trigger, event.Device, event.Location, event.Person, event.Latitude, event.Longitude)
+        mqtt.Publish("bla")
       }
     }
   }()