FIX: Publish data to Cloud including Device ID

Get Device ID in the output node constructor and use it for publishing data

Author: d-beamon

arduino-iot-cloud.js

@@ -82,9 +82,26 @@ module.exports = function (RED) {
               this.thing = config.thing;
               this.propertyId = config.property;
               this.propertyName = config.name;
+
+              //console.log("Node Constructor: ", config.name);
+              try {
+                const opts = {}
+                if (this.organization) {
+                  opts.xOrganization = this.organization;
+                }
+                ret = await this.arduinoRestClient.getThing(this.thing, opts);
+                this.device_id = ret.device_id;
+                //console.log("  Thing info: ", JSON.stringify(ret));
+                //console.log("  Device ID: ", this.device_id);
+              } catch (error) {
+                // Handle API call error
+                console.error('Error making API call:', error.message);
+              }
+
+              
               this.on('input', async function (msg) {
                 try {
-                  await this.arduinoRestClient.setProperty(this.thing, this.propertyId, msg.payload);
+                  await this.arduinoRestClient.setProperty(this.thing, this.propertyId, msg.payload, this.device_id);
                   var s;
                   if (typeof msg.payload !== "object") {
                     s = getStatus(msg.payload);

utils/arduino-iot-cloud-api-wrapper.js

@@ -40,9 +40,10 @@ class ArduinoClientHttp {
   updateToken(token) {
     this.token = token;
   }
-  setProperty(thing_id, property_id, value) {
+  setProperty(thing_id, property_id, value, device_id = undefined) {
     const body = JSON.stringify({
-      value: value
+      value: value,
+      device_id : device_id
     });
     oauth2.accessToken = this.token;
     return apiProperties.propertiesV2Publish(thing_id, property_id, body);
@@ -51,6 +52,11 @@ class ArduinoClientHttp {
     oauth2.accessToken = this.token;
     return apiThings.thingsV2List(opts);
   }
+  getThing(thingId, opts) {
+    oauth2.accessToken = this.token;
+    opts.showDeleted = false;
+    return apiThings.thingsV2Show(thingId, opts);
+  }
   getProperties(thingId, opts) {
     oauth2.accessToken = this.token;
     opts.showProperties = true;