mqttagent

commit 2e521db0447700b8c8461537505b4c2278c37d9e
parent bb5483ca29463ae1d1d23160bcb0b15010c28ec4
Author: Natasha Kerensikova <natgh@instinctive.eu>
Date:   Fri, 10 Jan 2025 19:48:52 +0000

Error checks are cleaner
Diffstat:
M
mqttagent.go
 | 
12
++++++++----

1 file changed, 8 insertions(+), 4 deletions(-)
diff --git a/mqttagent.go b/mqttagent.go
@@ -79,7 +79,9 @@ func Run(agent MqttAgent, main_script string) {
 
 		if key, _ := subTbl.Next(lua.LNil); key == lua.LNil {
 			client := L.RawGetInt(cnx, keyClient).(*lua.LUserData).Value.(*mqtt.Client)
-			client.Disconnect(nil)
+			if err := client.Disconnect(nil); err != nil {
+				log.Println(err)
+			}
 			L.RawSetInt(stateCnxTable(L), msg.ClientId, lua.LNil)
 		}
 
@@ -98,7 +100,9 @@ func cleanupClients(L *lua.LState) {
 	L.ForEach(cnxTbl, func(key, value lua.LValue) {
 		cnx := value.(*lua.LTable)
 		client := L.RawGetInt(cnx, keyClient).(*lua.LUserData).Value.(*mqtt.Client)
-		client.Disconnect(nil)
+		if err := client.Disconnect(nil); err != nil {
+			log.Println(err)
+		}
 	})
 }
 
@@ -148,7 +152,7 @@ func match(actual, filter string) bool {
 	return matchSliced(strings.Split(actual, "/"), strings.Split(filter, "/"))
 }
 
-func mqttRead(client *mqtt.Client, toLua chan MqttMessage, id int) error {
+func mqttRead(client *mqtt.Client, toLua chan MqttMessage, id int) {
 	var big *mqtt.BigMessage
 
 	for {
@@ -167,7 +171,7 @@ func mqttRead(client *mqtt.Client, toLua chan MqttMessage, id int) error {
 			}
 		default:
 			log.Println(err)
-			return err
+			return
 		}
 	}
 }