upd msg

arteck · Oct 31, 2023 · c196b00 · c196b00
1 parent 3ba9b83
commit c196b00
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/lib/mqtt-server.js b/lib/mqtt-server.js
@@ -252,7 +252,7 @@ class MqttServer {
         const ip = this.devices[clientId]?.ip;
         if (ip) {
             // Call Adapter function onMqttAliveChange()
-            this.adapter.onMqttAlive(ip, isAlive);
+            this.adapter.onMqttAlive(ip, isAlive, msg);
             if (isAlive) {
                 this.scheduleCheckIfStillActive(clientId); // restart timer
             } else {

diff --git a/main.js b/main.js
@@ -108,7 +108,7 @@ class fullybrowserControll  extends utils.Adapter {
         }
     }
 
-    async onMqttAlive(ip, isAlive) {
+    async onMqttAlive(ip, isAlive, msg) {
         try {
             const prevIsAlive = this.fullysEnbl[ip].isAlive;
             this.fullysEnbl[ip].isAlive = isAlive;
@@ -121,6 +121,12 @@ class fullybrowserControll  extends utils.Adapter {
             if ((!calledBefore && isAlive === true) || prevIsAlive !== isAlive) {
                 // Set Device isAlive Status - we could also use setStateChanged()...
                 this.setState(this.fullysEnbl[ip].id + '.alive', { val: isAlive, ack: true });
+
+                if (isAlive) {
+                    this.log.info(`${this.fullysEnbl[ip].name} is alive (MQTT: ${msg})`);
+                } else {
+                    this.log.warn(`${this.fullysEnbl[ip].name} is not alive! (MQTT: ${msg})`);
+                }
             }
 
             this.setStateChanged('info.connection', { val: true, ack: true });