updates

Author: michelle0927

components/tuya/sources/new-device-activated/new-device-activated.mjs

@@ -0,0 +1,88 @@
+import tuya from "../../tuya.app.mjs";
+import { DEFAULT_POLLING_SOURCE_TIMER_INTERVAL } from "@pipedream/platform";
+import sampleEmit from "./test-event.mjs";
+
+export default {
+  key: "tuya-new-device-parameter-updated",
+  name: "New Device Parameter Updated",
+  description: "Emit new event when the specified device parameter is updated. [See the documentation](https://developer.tuya.com/en/docs/cloud/device-management?id=K9g6rfntdz78a#title-10-Get%20a%20list%20of%20devices%20under%20a%20specified%20user)",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  props: {
+    tuya,
+    db: "$.service.db",
+    timer: {
+      type: "$.interface.timer",
+      default: {
+        intervalSeconds: DEFAULT_POLLING_SOURCE_TIMER_INTERVAL,
+      },
+    },
+    userId: {
+      propDefinition: [
+        tuya,
+        "userId",
+      ],
+    },
+    deviceParameter: {
+      type: "string",
+      label: "Device Parameter",
+      description: "The device parameter to watch for updates. E.g. `switch_1`",
+    },
+    homeId: {
+      propDefinition: [
+        tuya,
+        "homeId",
+        (c) => ({
+          userId: c.userId,
+        }),
+      ],
+      optional: true,
+    },
+  },
+  methods: {
+    _getPreviousValues() {
+      return this.db.get("previousValues") || {};
+    },
+    _setPreviousValues(previousValues) {
+      this.db.set("previousValues", previousValues);
+    },
+    getCurrentValue(device) {
+      const { status } = device;
+      const relevantStatus = status.find(({ code }) => code === this.deviceParameter);
+      return relevantStatus?.value;
+    },
+    generateMeta(item) {
+      const ts = Date.now();
+      return {
+        id: `${item.id}${ts}`,
+        summary: `Device Updated with ID: ${item.id}`,
+        ts,
+      };
+    },
+  },
+  async run() {
+    const previousValues = this._getPreviousValues();
+    const newValues = {};
+
+    const { result: devices } = this.homeId
+      ? await this.tuya.listHomeDevices({
+        homeId: this.homeId,
+      })
+      : await this.tuya.listUserDevices({
+        userId: this.userId,
+      });
+
+    for (const device of devices) {
+      const currentValue = this.getCurrentValue(device);
+      if (previousValues[device.id] !== currentValue) {
+        const meta = this.generateMeta(device);
+        this.$emit(device, meta);
+      }
+      newValues[device.id] = currentValue;
+    }
+
+    this._setPreviousValues(newValues);
+  },
+  sampleEmit,
+};

components/tuya/sources/new-device-parameter-updated/new-device-parameter-updated.mjs

@@ -0,0 +1,77 @@
+export default {
+    "active_time": 1748632139,
+    "biz_type": 18,
+    "category": "cz",
+    "create_time": 1748632139,
+    "icon": "smart/icon/bay1599677305883cNM4/03aaf2fd77d712895eb7b8408a374ebe.png",
+    "id": "vdevo174863213925233",
+    "ip": "47.225.143.157",
+    "lat": "",
+    "local_key": ".'0k9<h@|2j7!OK9",
+    "lon": "",
+    "model": "TS-441",
+    "name": "Tramontina  Plug-vdevo",
+    "online": true,
+    "owner_id": "250587566",
+    "product_id": "mjzxchzvqmxps3lf",
+    "product_name": "Plugue Tramontina",
+    "status": [
+      {
+        "code": "switch_1",
+        "value": false
+      },
+      {
+        "code": "countdown_1",
+        "value": 0
+      },
+      {
+        "code": "add_ele",
+        "value": 0
+      },
+      {
+        "code": "cur_current",
+        "value": 0
+      },
+      {
+        "code": "cur_power",
+        "value": 0
+      },
+      {
+        "code": "cur_voltage",
+        "value": 0
+      },
+      {
+        "code": "relay_status",
+        "value": "power_off"
+      },
+      {
+        "code": "overcharge_switch",
+        "value": false
+      },
+      {
+        "code": "light_mode",
+        "value": "relay"
+      },
+      {
+        "code": "child_lock",
+        "value": false
+      },
+      {
+        "code": "cycle_time",
+        "value": ""
+      },
+      {
+        "code": "random_time",
+        "value": ""
+      },
+      {
+        "code": "switch_inching",
+        "value": ""
+      }
+    ],
+    "sub": false,
+    "time_zone": "",
+    "uid": "az1748632127862aWriL",
+    "update_time": 1748632139,
+    "uuid": "vdevo174863213925233"
+  }

components/tuya/sources/new-device-parameter-updated/test-event.mjs

@@ -8,16 +8,7 @@ export default {
     userId: {
       type: "string",
       label: "User ID",
-      description: "The identifier of a user",
-      async options() {
-        const { result: { list } } = await this.listUsers();
-        return list?.map(({
-          user_id: value, user_name: label,
-        }) => ({
-          label,
-          value,
-        })) || [];
-      },
+      description: "The unique identifier of a user. E.g. `az1748632127862aWriL`",
     },
     homeId: {
       type: "string",
@@ -60,7 +51,7 @@ export default {
     instructionCode: {
       type: "string",
       label: "Instruction Code",
-      description: "The code of the command to use",
+      description: "The code of the command to use. E.g. `switch_1`",
       async options({ deviceId }) {
         const { result } = await this.listDeviceFunctions({
           deviceId,
@@ -96,9 +87,7 @@ export default {
         console.log(response);
         throw new ConfigurationError(`${response.msg}`);
       }
-    },
-    listUsers() {
-      return this._getClient().user.users({});
+      return response;
     },
     listHomes({ userId }) {
       return this._makeRequest({