support client-mqtt lib interoperability

Author: fabik111

arduino-cloud.js

@@ -17,7 +17,7 @@ module.exports = function (RED) {
           this.propertyVariableName = config.variableName;
           this.arduinoClient = await connectionManager.getClientMqtt(connectionConfig, RED);
           if (this.arduinoClient && this.arduinoClient.connection.connected) {
-            await this.arduinoClient.onPropertyValue(this.thing, this.propertyVariableName, config.id,(msg) => {
+            await this.arduinoClient.onPropertyValue(this.thing, this.propertyVariableName,(msg) => {
               this.send(
                 {
                   topic: this.propertyName,
@@ -30,7 +30,7 @@ module.exports = function (RED) {
                 this.status({ fill: "grey", shape: "dot", text: s });
               else
                 this.status({});
-            });
+            },config.id);
           }else{
             this.status({ fill: "red", shape: "ring", text: "Connection Error" });
           }

arduino-iot-client-mqtt/arduino-iot-client-mqtt.js

@@ -564,13 +564,19 @@ class ArduinoClientMqtt {
     return arrayBufferToBase64(cborEncoded);
   };
 
-  onPropertyValue(thingId, name,nodeId, cb) {
+  onPropertyValue(thingId, name, cb,nodeId) {
     if (!name) {
       throw new Error('Invalid property name');
     }
     if (typeof cb !== 'function') {
       throw new Error('Invalid callback');
     }
+    var node;
+    if(!nodeId){
+      node=1
+    }else{
+      node=nodeId;
+    }
     const propOutputTopic = `/a/t/${thingId}/e/o`;
 
     this.subscribedTopics[thingId] = {
@@ -582,7 +588,7 @@ class ArduinoClientMqtt {
       this.propertyCallback[propOutputTopic] = {};
       this.propertyCallback[propOutputTopic][name] = [];
       this.propertyCallback[propOutputTopic][name].push({
-        nodeId: nodeId,
+        nodeId: node,
         callback:cb
       });
 
@@ -592,12 +598,12 @@ class ArduinoClientMqtt {
     if (this.propertyCallback[propOutputTopic] && !this.propertyCallback[propOutputTopic][name]) {
       this.propertyCallback[propOutputTopic][name] = [];
       this.propertyCallback[propOutputTopic][name].push({
-        nodeId: nodeId,
+        nodeId: node,
         callback:cb
       });
     }else if(this.propertyCallback[propOutputTopic] && this.propertyCallback[propOutputTopic][name]){
       this.propertyCallback[propOutputTopic][name].push({
-        nodeId: nodeId,
+        nodeId: node,
         callback:cb
       });
     }
@@ -609,11 +615,17 @@ class ArduinoClientMqtt {
     if (!name) {
       throw new Error('Invalid property name');
     }
+    var node;
+    if(!nodeId){
+      node=1
+    }else{
+      node=nodeId;
+    }
     const propOutputTopic = `/a/t/${thingId}/e/o`;
     var pos=-1;
     for(var i=0; i<this.propertyCallback[propOutputTopic][name].length; i++){
       var cbObject=this.propertyCallback[propOutputTopic][name][i];
-      if(cbObject.nodeId===nodeId){
+      if(cbObject.nodeId===node){
         pos=i;
         break;
       }