mqttagent

commit 6ef78bc4a7696438c5c5f81647f46c369d3445ca
parent 4a6d8700ace0489414803628db3f7f604a5b12fa
Author: Natasha Kerensikova <natgh@instinctive.eu>
Date:   Mon,  2 Jun 2025 18:31:20 +0000

Close error are checked in mqttagent-full
Diffstat:
M
cmd/mqttagent-full/main.go
 | 
20
+++++++++++++-------

1 file changed, 13 insertions(+), 7 deletions(-)
diff --git a/cmd/mqttagent-full/main.go b/cmd/mqttagent-full/main.go
@@ -91,21 +91,27 @@ type sqlogger struct {
 	insertSent     *sql.Stmt
 }
 
+func logErr(context string, err error) {
+	if err != nil {
+		log.Println(context, err)
+	}
+}
+
 func (logger *sqlogger) Close() {
 	if logger == nil {
 		return
 	}
 
 	if logger.insertReceived != nil {
-		logger.insertReceived.Close()
+		logErr("Close insertReceived:", logger.insertReceived.Close())
 	}
 
 	if logger.insertSent != nil {
-		logger.insertSent.Close()
+		logErr("Close insertSend:", logger.insertSent.Close())
 	}
 
 	if logger.db != nil {
-		logger.db.Close()
+		logErr("Close DB:", logger.db.Close())
 	}
 }
 
@@ -164,7 +170,7 @@ func connect(connectionString string) (*sqlogger, error) {
 			" NEW.message); END;",
 	} {
 		if _, err = db.Exec(cmd); err != nil {
-			db.Close()
+			logErr("Close DB:", db.Close())
 			return nil, err
 		}
 	}
@@ -172,15 +178,15 @@ func connect(connectionString string) (*sqlogger, error) {
 	s1, err := db.Prepare("INSERT INTO receivedf(timestamp,topic,message)" +
 		" VALUES (?,?,?);")
 	if err != nil {
-		db.Close()
+		logErr("Close DB:", db.Close())
 		return nil, err
 	}
 
 	s2, err := db.Prepare("INSERT INTO sentf(timestamp,topic,message)" +
 		" VALUES (?,?,?);")
 	if err != nil {
-		s1.Close()
-		db.Close()
+		logErr("Close insertReceived:", s1.Close())
+		logErr("Close DB:", db.Close())
 		return nil, err
 	}