configure client to use local database connection

main.go

@@ -15,7 +15,6 @@ import (
 
 func main() {
 	log.Init()
-
 	queue.Init()
 
 	if os.Getenv("OUTPUT_DATABSE") != "" {
@@ -27,10 +26,13 @@ func main() {
 		log.Log.Info("Starting embedded MQTT server")
 		mqttserver.Start()
 	}
-	mqttclient.Init()
-	go messageworker.Run()
-	for {
-		time.Sleep(time.Second) // reduce CPU usage by adding a short sleep here instead of a empty for loop
+
+	if os.Getenv("LOGGER_CLIENT") != "false" && os.Getenv("LOGGER_SERVER") != "true" {
+		mqttclient.Init()
+		go messageworker.RunClient()
+		for {
+			time.Sleep(time.Second) // reduce CPU usage by adding a short sleep here instead of a empty for loop
+		}
 	}
 
 }

messageworker/main.go → messageworker/client.go

@@ -2,6 +2,7 @@ package messageworker
 
 import (
 	"encoding/json"
+	"os"
 	"time"
 
 	"jonasled.dev/jonasled/ems-esp-logger/database"
@@ -12,7 +13,15 @@ import (
 	"jonasled.dev/jonasled/ems-esp-logger/types"
 )
 
-func Run() {
+func RunClient() {
+	if os.Getenv("CLIENT_USE_SERVER") != "true" {
+
+		log.Log.Info("Intialized local client with direct datbase connection")
+		runLocalDbClient()
+	}
+}
+
+func runLocalDbClient() {
 	for {
 		taskData, taskId, err := queue.MainQueue.Dequeue()
 		if err != nil {
@@ -24,14 +33,14 @@ func Run() {
 		err = json.Unmarshal([]byte(taskData), &task)
 		if err != nil {
 			log.Log.Error("Failed decoding task as JSON: ", err.Error())
-			return
+			continue
 		}
 		var instance tables.Instance
 		err = database.Db.Where("name = ?", task.Instance).First(&instance).Error
 		if err != nil {
 			log.Log.Error("Failed retreiving instance from database, pushing task back to queue: ", err.Error())
 			queue.MainQueue.Enqueue(taskData, 60)
-			return
+			continue
 		}
 
 		var jsonData map[string]interface{}
@@ -39,7 +48,7 @@ func Run() {
 		if err != nil {
 			log.Log.Error("Failed decoding boiler JSON: ", err.Error())
 			queue.MainQueue.Enqueue(taskData, 60)
-			return
+			continue
 		}
 		valuesToInsert := []tables.Value{}
 		for key, value := range jsonData {