From c659a89ec3d0cf92e48712def2cb712c47038928 Mon Sep 17 00:00:00 2001
From: Wolfgang Hottgenroth <wolfgang.hottgenroth@icloud.com>
Date: Sun, 1 Dec 2024 16:04:59 +0100
Subject: [PATCH] compiles

---
 .gitignore                           |  6 +++---
 src/ma/archiver/archiver.go          | 11 +++++------
 src/ma/counter/counter.go            | 21 ---------------------
 src/ma/database/abstract_database.go |  2 +-
 src/ma/database/database.go          |  2 +-
 src/ma/mqtt/mqtt.go                  | 21 ++++++++++-----------
 6 files changed, 20 insertions(+), 43 deletions(-)

diff --git a/.gitignore b/.gitignore
index bd0cd5f..b029c45 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1,6 +1,6 @@
-src/udi/udi
-src/udi/main
-src/udi/migrate_schema
+src/ma/ma
+src/ma/main
+src/ma/migrate_schema
 tmp/
 ENVDB
 ENVDB.cluster
diff --git a/src/ma/archiver/archiver.go b/src/ma/archiver/archiver.go
index e402257..078a963 100644
--- a/src/ma/archiver/archiver.go
+++ b/src/ma/archiver/archiver.go
@@ -2,11 +2,11 @@ package archiver
 
 import "log"
 import "time"
-import "os"
-import "fmt"
-import "net/url"
+//import "os"
+//import "fmt"
+//import "net/url"
 import "ma/mqtt"
-import "ma/config"
+//import "ma/config"
 import "ma/counter"
 import "ma/database"
 
@@ -20,13 +20,12 @@ func InputArchiver() {
     select {
     case mqttMessage := <- mqtt.InputChannel:
       message := database.Message { time.Now(), mqttMessage.Topic, string(mqttMessage.Payload) }
-      archiverChannel <- message
       handleMessage(message)
     }
   }
 }
 
-func handleMessage(message database.MessageT) {
+func handleMessage(message database.Message) {
   log.Printf("Archiving %", message)
   counter.S("Stored")
 }
diff --git a/src/ma/counter/counter.go b/src/ma/counter/counter.go
index a898b13..cd3b429 100644
--- a/src/ma/counter/counter.go
+++ b/src/ma/counter/counter.go
@@ -45,32 +45,11 @@ func F(id string) {
   }
 }
 
-func SH(id string) {
-  if _, ok := stats.Handled[id]; ok {
-    tuple := stats.Handled[id]
-    tuple.Successful += 1
-    stats.Handled[id] = tuple
-  } else {
-    stats.Handled[id] = statsTuple_t { Successful:1, Failed:0, }
-  }
-}
-
-func FH(id string) {
-  if _, ok := stats.Handled[id]; ok {
-    tuple := stats.Handled[id]
-    tuple.Failed += 1
-    stats.Handled[id] = tuple
-  } else {
-    stats.Handled[id] = statsTuple_t { Successful:0, Failed:1, }
-  }
-}
-
 func InitCounter() {
   stats = stats_t {
     Received: statsTuple_t {Successful:0,Failed:0,},
     Stored: statsTuple_t {Successful:0,Failed:0,},
     Skipped: statsTuple_t {Successful:0,Failed:0,},
-    Handled: make(map[string]statsTuple_t),
   }
 
   go func() { 
diff --git a/src/ma/database/abstract_database.go b/src/ma/database/abstract_database.go
index fec2d7d..055065c 100644
--- a/src/ma/database/abstract_database.go
+++ b/src/ma/database/abstract_database.go
@@ -1,7 +1,7 @@
 package database
 
 import "time"
-import "gorm.io/gorm"
+// import "gorm.io/gorm"
 
 
 type Message struct {
diff --git a/src/ma/database/database.go b/src/ma/database/database.go
index 323c665..307fb50 100644
--- a/src/ma/database/database.go
+++ b/src/ma/database/database.go
@@ -4,7 +4,7 @@ package database
 import (
   "log"
   //"time"
-  "fmt"
+  //"fmt"
   "ma/counter"
   "gorm.io/driver/postgres"
   "gorm.io/gorm"
diff --git a/src/ma/mqtt/mqtt.go b/src/ma/mqtt/mqtt.go
index 70a55cc..8108811 100644
--- a/src/ma/mqtt/mqtt.go
+++ b/src/ma/mqtt/mqtt.go
@@ -6,8 +6,8 @@ import "fmt"
 import MQTT "github.com/eclipse/paho.mqtt.golang"
 import "github.com/google/uuid"
 import "crypto/tls"
-import "udi/config"
-import "udi/counter"
+import "ma/config"
+import "ma/counter"
 
 type Message struct {
   Topic string
@@ -21,22 +21,21 @@ var mqttClient MQTT.Client
 
 func onMessageReceived(client MQTT.Client, message MQTT.Message) {
   // log.Printf("Message received, topic: %s, payload: %s\n", message.Topic(), message.Payload())
-  for _, i := range config.Config.ExcludeTopics {
-    if i == message.Topic {
-      counter.S("Skipped")
-      return
-    }
-  }
-
   m := Message { 
     Topic: message.Topic(), 
     Payload: message.Payload(),
   }
+  for _, i := range config.Config.ExcludeTopics {
+    if i == m.Topic {
+      counter.S("Skipped")
+      log.Println("Message skipped")
+      return
+    }
+  }
   select {
   case InputChannel <- m:
     counter.S("Received")
-    {}
-    //log.Println("Message sent to channel")
+    log.Println("Message sent to channel")
   default:
     log.Println("Channel full, message lost")
     counter.F("Received")