New Components - tuya

components/tuya/actions/list-devices/list-devices.mjs

@@ -0,0 +1,43 @@
+import tuya from "../../tuya.app.mjs";
+
+export default {
+  key: "tuya-list-devices",
+  name: "List Devices",
+  description: "Get a list of devices associated with a home. [See the documentation](https://developer.tuya.com/en/docs/cloud/d7ee73aadb?id=Kawfjer0wkt2a)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    tuya,
+    userId: {
+      propDefinition: [
+        tuya,
+        "userId",
+      ],
+    },
+    homeId: {
+      propDefinition: [
+        tuya,
+        "homeId",
+        (c) => ({
+          userId: c.userId,
+        }),
+      ],
+      optional: true,
+    },
+  },
+  async run({ $ }) {
+    const response = this.homeId
+      ? await this.tuya.listHomeDevices({
+        homeId: this.homeId,
+      })
+      : await this.tuya.listUserDevices({
+        userId: this.userId,
+      });
+    if (response?.result?.length) {
+      $.export("$summary", `Found ${response.result.length} device${response.result.length === 1
+        ? ""
+        : "s"}`);
+    }
+    return response;
+  },
+};

components/tuya/actions/list-homes/list-homes.mjs

@@ -0,0 +1,29 @@
+import tuya from "../../tuya.app.mjs";
+
+export default {
+  key: "tuya-list-homes",
+  name: "List Homes",
+  description: "Based on the user ID, query the list of homes where the specified user belongs. [See the documentation](https://developer.tuya.com/en/docs/cloud/f5dd40ed14?id=Kawfjh9hpov1n)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    tuya,
+    userId: {
+      propDefinition: [
+        tuya,
+        "userId",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const response = await this.tuya.listHomes({
+      userId: this.userId,
+    });
+    if (response?.result?.length) {
+      $.export("$summary", `Found ${response.result.length} home${response.result.length === 1
+        ? ""
+        : "s"}`);
+    }
+    return response;
+  },
+};

components/tuya/actions/send-instructions-to-device/send-instructions-to-device.mjs

@@ -0,0 +1,69 @@
+import tuya from "../../tuya.app.mjs";
+
+export default {
+  key: "tuya-send-instructions-to-device",
+  name: "Send Instructions to Device",
+  description: "Send an instruction to the specified device. [See the documentation](https://developer.tuya.com/en/docs/cloud/device-control?id=K95zu01ksols7#title-35-Send%20instructions%20to%20the%20device)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    tuya,
+    userId: {
+      propDefinition: [
+        tuya,
+        "userId",
+      ],
+    },
+    homeId: {
+      propDefinition: [
+        tuya,
+        "homeId",
+        (c) => ({
+          userId: c.userId,
+        }),
+      ],
+      optional: true,
+    },
+    deviceId: {
+      propDefinition: [
+        tuya,
+        "deviceId",
+        (c) => ({
+          userId: c.userId,
+          homeId: c.homeId,
+        }),
+      ],
+    },
+    instructionCode: {
+      propDefinition: [
+        tuya,
+        "instructionCode",
+        (c) => ({
+          deviceId: c.deviceId,
+        }),
+      ],
+    },
+    value: {
+      type: "string",
+      label: "Value",
+      description: "The value to set",
+    },
+  },
+  async run({ $ }) {
+    const response = await this.tuya.sendInstructionsToDevice({
+      deviceId: this.deviceId,
+      data: {
+        commands: [
+          {
+            code: this.instructionCode,
+            value: this.value,
+          },
+        ],
+      },
+    });
+    if (response.success) {
+      $.export("$summary", "Successfully sent instructions to device");
+    }
+    return response;
+  },
+};

components/tuya/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/tuya",
-  "version": "0.0.1",
+  "version": "0.1.0",
   "description": "Pipedream Tuya Components",
   "main": "tuya.app.mjs",
   "keywords": [
@@ -11,5 +11,9 @@
   "author": "Pipedream <support@pipedream.com> (https://pipedream.com/)",
   "publishConfig": {
     "access": "public"
+  },
+  "dependencies": {
+    "@pipedream/platform": "^3.0.3",
+    "@tuya/tuya-connector-nodejs": "^2.1.2"
   }
-}
+}

components/tuya/sources/new-device-parameter-updated/new-device-parameter-updated.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/test-event.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"
+  }