All working. As planned.

Kolajik · Apr 27, 2021 · aca9d2d · aca9d2d
1 parent e2858c1
commit aca9d2d
Show file tree

Hide file tree

Showing 2 changed files with 27 additions and 33 deletions.
diff --git a/Class/subscriber.js b/Class/subscriber.js
@@ -49,39 +49,33 @@ class Subscriber {
 
   receiveMessages() {
     client.on('message', (topic, packet) => {
-
-      var data = EXI4JSON.parse(packet).wrap;
-      console.log('\n\n Data recieved: \n', data)
-      // console.log('client', client)
-      // console.log(packet)
-
-      // if XML payload, parse to json object like this
-      // var data = parser.toJson(payload, { object: true });
-      // data = data.wrap
-
-      // if json string payload, parse to json object like this
-      // const data = JSON.parse(payload)
-
-      data.topic = packet.topic
-      let exi = true;
-      let msgJSON;
-      if (exi) {
-        let stringData = JSON.stringify(data)
-        console.log('stringit baby', stringData)
-        msgJSON = JSON.parse(stringData)
-
+      console.log('packet:', packet);
+      var payload = packet.toString();
+      var exi = false;
+      var data = null;
+      if (!rooms.includes(topic))
+        return logger.debug(this.name,'- Received a message on topic', topic)
+
+      try {
+        data = JSON.parse(JSON.stringify(EXI4JSON.parse(packet)))
+        exi = true;
+      } catch (e) {
+        logger.info('Payload is not an EXI type.')
       }
-        // const msg = packet.toString()
 
-        // ------- if XML payload, parse like this
-        // var data = parser.toJson(msg, { object: true });
-        // const msgJSON = data.wrap
-
-        // ------- if JSON string payload, parse like this:
-        // const msgJSON = JSON.parse(msg);
-
-        logger.info(this.name, '- Received a message from', msgJSON.n, 'on topic', topic, 'with data:', msgJSON)
-      })
+      if (!exi) {
+        data = JSON.parse(payload)
+        // logger.debug('data:', data);
+        let formattedData = null;
+        if (data.contentType == 'application/senml+xml') {
+          formattedData = parser.toJson(data.data);
+          let dataParsed = JSON.parse(formattedData);
+          data.data = dataParsed;
+        }
+      }
+      data.topic = topic
+      logger.info(this.name, '- Received a message from', data.data.n, 'on topic', topic, 'with data:', data)
+    })
   }
 }
 

diff --git a/broker.js b/broker.js
@@ -114,7 +114,7 @@ aedes.on('publish', async function (packet, client) {
     return logger.debug('BROKER - Client pushed a message to topic', packet.topic)
 
   try {
-    data = EXI4JSON.parse(packet.payload)
+    data = JSON.parse(JSON.stringify(EXI4JSON.parse(packet.payload)))
     exi = true;
   } catch (e) {
     logger.info('Payload is not an EXI type.')
@@ -126,7 +126,7 @@ aedes.on('publish', async function (packet, client) {
     let formattedData = null;
     if (data.contentType == 'application/senml+xml') {
       formattedData = parser.toJson(data.data);
-      dataParsed = JSON.parse(formattedData);
+      let dataParsed = JSON.parse(formattedData);
       data.data = dataParsed;
     }
   }