Additional message debug logging (qos, dup, retain)

Author: mpatfield

CHANGELOG.md

@@ -2,11 +2,12 @@
 
 All notable changes to homebridge-dummy will be documented in this file.
 
-## 1.5.16-beta.1 ()
+## 1.5.16-beta.2 ()
 
 ### Added
 - Added `topicGetAvailable` for "Last Will and Testament" (LWT) before an accessory goes offline
     - If value does not match `valueAvailable`, then accessory will show "No Response" in HomeKit until the next successful get event
+- Packet info (qos, dup, retain) to verbose message logging
 
 ### Changed
 - Renamed "Get Availability" to "Get Active Status" in config UI to avoid confusion with the new `topicGetAvailable` (see above)

package-lock.json

@@ -4,7 +4,7 @@
   "displayName": "Homebridge Easy MQTT",
   "description": "Homebridge plugin for MQTT devices",
   "type": "module",
-  "version": "1.5.16-beta.1",
+  "version": "1.5.16-beta.2",
   "homepage": "https://github.com/mpatfield/homebridge-easy-mqtt#readme",
   "repository": {
     "type": "git",

package.json

@@ -198,7 +198,7 @@ export class MQTT {
       });
     });
 
-    this.client.on('message', (topic, message) => this.messageReceived(topic, message.toString()));
+    this.client.on('message', (_topic, _message, packet) => this.messageReceived(packet));
 
     this.client.on('close', () => this.connectionClosed());
 
@@ -319,15 +319,17 @@ export class MQTT {
     }
   }
 
-  private messageReceived(topic: string, message: string) {
+  private messageReceived(packet: mqtt.IPublishPacket) {
 
     this.reconnectCount = 0;
 
-    try {
+    const topic = packet.topic;
+    const message = packet.payload.toString().trim();
+    const meta = `(qos: ${packet.qos}, dup: ${packet.dup}, retain: ${packet.retain})`;
 
-      message = message.trim();
+    try {
 
-      this.log.ifVerbose(strings.mqttClient.receivedMessage, this.host, topic, `\n${message}`);
+      this.log.ifVerbose(strings.mqttClient.receivedMessage, this.host, topic, `${meta}\n${message}`);
 
       const listeners = this.listeners.get(topic);
       if (!listeners || listeners.length === 0) {