feat: added liveInspector to all mqtt events

src/Events/onConnect.ts

@@ -108,8 +108,15 @@ async function onConnect(
   connection.addConnection(client.channel, client);
 
   console.debug(`Device connected [${client.device.id}]`);
-  // TODO: ADD Live Inspector support.
-  // deviceInspector(client.device.id, client.connID, '[MQTT] Device connected', `Token Ending: ${String(tokenResult.tokenObj.token).slice(-5)} Client-ID: ${packet.clientId} Will-Message: ${!!client.will}`);
+
+  let liveInpesctorContent = `Client-ID: ${packet.clientId} Will-Message: ${!!client.will}`;
+  if (configParams.connection_method === "device_token") {
+    liveInpesctorContent = `Token Ending: ${String(client.token).slice(-5)} ${liveInpesctorContent}`;
+  }
+  core.emitToLiveInspector(client.device.id, {
+    title: "Device connected",
+    content: liveInpesctorContent,
+  });
 
   client.connack({ returnCode: 0, reasonCode: 0 });
 

src/Events/onDisconnect.ts

@@ -1,3 +1,4 @@
+import { core } from "@tago-io/tcore-sdk";
 import Connection from "../Services/connections";
 import { ITagoIOClient } from "./onConnect";
 import onPublish from "./onPublish";
@@ -6,8 +7,11 @@ async function onDisconnect(connection: Connection, client: ITagoIOClient, reaso
   connection.delConnection(client.channel as string, client.connID as string);
 
   if (!client.disconnected) {
-    // TODO: Log to Device Inspector
-    // deviceInspector(client.device.id, client.connID, '[MQTT] Device disconnected', `socket event: ${reason}`);
+    core.emitToLiveInspector(client.device.id, {
+      title: "Device disconnected",
+      content: `socket event: ${reason}`,
+    });
+
     // TODO: Trigger Action for MQTT Disconnect
     // const actionObj = {
     //   id: client.device.id,
@@ -23,8 +27,10 @@ async function onDisconnect(connection: Connection, client: ITagoIOClient, reaso
     onPublish(connection, client, client.will as any).catch(() => null);
     console.log(`Device executed will message [${client.device.id}]`, JSON.stringify(client.will));
 
-    // TODO: Log to Device Inspector
-    // deviceInspector(client.device.id, client.connID, '[MQTT] Device executed will message', JSON.stringify(client.will));
+    core.emitToLiveInspector(client.device.id, {
+      title: "Device executed will message",
+      content: JSON.stringify(client.will),
+    });
   }
 
   if (reason === "disconnect") {

src/Events/onPublish.ts

@@ -75,8 +75,10 @@ async function onPublish(connection: Connection, client: ITagoIOClient, packet:
     messageId,
   });
 
-  // TODO: Log to device inspector
-  // deviceInspector(client.device.id, client.connID, '[MQTT] Device publish', JSON.stringify(scope));
+  core.emitToLiveInspector(client.device.id, {
+    title: "Device publish received",
+    content: JSON.stringify(scope),
+  });
 
   // TODO: Update Device Last Input
   // deviceProvider.updateLastTime(client.device.id, 'input');

src/Events/onSubscribe.ts

@@ -1,3 +1,4 @@
+import { core } from "@tago-io/tcore-sdk";
 import { ISubscribePacket } from "mqtt-packet";
 import { getQOSMessage } from "../Services/mqtt.qos";
 import { getRetainedMQTT } from "../Services/mqtt.retained";
@@ -39,8 +40,10 @@ async function onSubscribe(client: ITagoIOClient, packet: ISubscribePacket) {
       }
     }
 
-    // TODO: Log to device inspector
-    // deviceInspector(client.device.id, client.connID, '[MQTT] Device subscribe', `topic: ${subscription.topic}`);
+    core.emitToLiveInspector(client.device.id, {
+      title: "Device subscribed",
+      content: `topic: ${subscription.topic}`,
+    });
   }
 }
 

src/Events/onUnsubscribe.ts

@@ -1,3 +1,4 @@
+import { core } from "@tago-io/tcore-sdk";
 import { IUnsubscribePacket } from "mqtt-packet";
 import { ITagoIOClient } from "./onConnect";
 
@@ -6,10 +7,12 @@ async function onUnsubscribe(client: ITagoIOClient, packet: IUnsubscribePacket &
 
   client.suback({ granted: [packet.qos], messageId: packet.messageId });
 
-  // TODO: Log to device inspector
-  // for (const unsubscription of packet.unsubscriptions) {
-  //   deviceInspector(client.device.id, client.connID, '[MQTT] Device unsubscribe', `topic: ${unsubscription}`);
-  // }
+  for (const unsubscription of packet.unsubscriptions) {
+    core.emitToLiveInspector(client.device.id, {
+      title: "Device unsubscribe",
+      content: `topic: ${unsubscription}`,
+    });
+  }
 }
 
 export default onUnsubscribe;