[Components] wati #13213

Actions
 - Add Contact
 - Send Template Message
 - Update Contact Attribute

Source
 - New Contact Created
 - New Incoming Message

Author: luancazarine

components/wati/.gitignore

@@ -1,5 +1,5 @@
+import { ConfigurationError } from "@pipedream/platform";
 import wati from "../../wati.app.mjs";
-import { axios } from "@pipedream/platform";
 
 export default {
   key: "wati-add-contact",
@@ -9,16 +9,45 @@ export default {
   type: "action",
   props: {
     wati,
-    contactDetails: {
+    whatsappNumber: {
       propDefinition: [
         wati,
-        "contactDetails",
+        "whatsappNumber",
       ],
     },
+    name: {
+      type: "string",
+      label: "Name",
+      description: "The name of the contact",
+      optional: true,
+    },
+    customParams: {
+      propDefinition: [
+        wati,
+        "customParams",
+      ],
+      optional: true,
+    },
   },
   async run({ $ }) {
-    const response = await this.wati.addContact(this.contactDetails);
-    $.export("$summary", `Successfully added contact with name: ${this.contactDetails.name}`);
+    const response = await this.wati.addContact({
+      $,
+      whatsappNumber: this.whatsappNumber,
+      data: {
+        name: this.name,
+        customParams: this.customParams && Object.entries(this.customParams).map(([
+          key,
+          value,
+        ]) => ({
+          name: key,
+          value,
+        })),
+      },
+    });
+    if (!response.result) {
+      throw new ConfigurationError(response.info);
+    }
+    $.export("$summary", `Successfully added contact with phone number: ${this.whatsappNumber}`);
     return response;
   },
 };

components/wati/actions/add-contact/add-contact.mjs

@@ -1,34 +1,63 @@
+import { ConfigurationError } from "@pipedream/platform";
 import wati from "../../wati.app.mjs";
-import { axios } from "@pipedream/platform";
 
 export default {
   key: "wati-send-template-message",
   name: "Send WhatsApp Template Message",
   description: "Enables sending of WhatsApp messages using a pre-approved template. [See the documentation](https://docs.wati.io/reference/post_api-v2-sendtemplatemessage)",
-  version: "0.0.{{ts}}",
+  version: "0.0.1",
   type: "action",
   props: {
     wati,
-    contactDetails: {
+    whatsappNumber: {
       propDefinition: [
         wati,
-        "contactDetails",
+        "whatsappNumber",
       ],
     },
-    templateDetails: {
+    customParams: {
       propDefinition: [
         wati,
-        "templateDetails",
+        "customParams",
       ],
+      label: "Parameters",
+      description: "An object with template's custom params.",
+    },
+    templateName: {
+      propDefinition: [
+        wati,
+        "templateName",
+      ],
+    },
+    broadcastName: {
+      type: "string",
+      label: "Broadcast Name",
+      description: "The name of broadcast.",
     },
   },
   async run({ $ }) {
     const response = await this.wati.sendTemplateMessage({
-      contactDetails: this.contactDetails,
-      templateDetails: this.templateDetails,
+      $,
+      params: {
+        whatsappNumber: this.whatsappNumber,
+      },
+      data: {
+        parameters: this.customParams && Object.entries(this.customParams).map(([
+          key,
+          value,
+        ]) => ({
+          name: key,
+          value,
+        })),
+        template_name: this.templateName,
+        broadcast_name: this.broadcastName,
+      },
     });
+    if (!response.result) {
+      throw new ConfigurationError(response.info);
+    }
 
-    $.export("$summary", `Successfully sent template message to ${this.contactDetails.name || this.contactDetails.number}`);
+    $.export("$summary", `Successfully sent template message to ${this.whatsappNumber}`);
     return response;
   },
 };

components/wati/actions/send-template-message/send-template-message.mjs

@@ -1,34 +1,47 @@
+import { ConfigurationError } from "@pipedream/platform";
 import wati from "../../wati.app.mjs";
-import { axios } from "@pipedream/platform";
 
 export default {
   key: "wati-update-contact-attribute",
   name: "Update Contact Attribute",
   description: "Allows updating attributes/tags related to an existing contact. [See the documentation](https://docs.wati.io/reference/post_api-v1-updatecontactattributes-whatsappnumber)",
-  version: "0.0.{{ts}}",
+  version: "0.0.1",
   type: "action",
   props: {
     wati,
-    contactDetails: {
+    whatsappNumber: {
       propDefinition: [
         wati,
-        "contactDetails",
+        "whatsappNumber",
       ],
     },
-    attributeDetails: {
+    customParams: {
       propDefinition: [
         wati,
-        "attributeDetails",
+        "customParams",
       ],
+      optional: true,
     },
   },
   async run({ $ }) {
     const response = await this.wati.updateContactAttributes({
-      contactDetails: this.contactDetails,
-      attributeDetails: this.attributeDetails,
+      $,
+      whatsappNumber: this.whatsappNumber,
+      data: {
+        customParams: this.customParams && Object.entries(this.customParams).map(([
+          key,
+          value,
+        ]) => ({
+          name: key,
+          value,
+        })),
+      },
     });
+    if (!response.result) {
+      throw new ConfigurationError(response.info);
+    }
 
-    $.export("$summary", `Successfully updated attributes for contact ${this.contactDetails.name}`);
+    $.export("$summary", `Successfully updated attributes for contact ${this.whatsappNumber}`);
     return response;
   },
 };

components/wati/actions/update-contact-attribute/update-contact-attribute.mjs

@@ -1,16 +1,18 @@
 {
   "name": "@pipedream/wati",
-  "version": "0.0.1",
+  "version": "0.1.0",
   "description": "Pipedream WATI Components",
-  "main": "dist/app/wati.app.mjs",
+  "main": "wati.app.mjs",
   "keywords": [
     "pipedream",
     "wati"
   ],
-  "files": ["dist"],
   "homepage": "https://pipedream.com/apps/wati",
   "author": "Pipedream <[email protected]> (https://pipedream.com/)",
   "publishConfig": {
     "access": "public"
+  },
+  "dependencies": {
+    "@pipedream/platform": "^3.0.3"
   }
 }

components/wati/app/wati.app.ts

@@ -0,0 +1,68 @@
+import { DEFAULT_POLLING_SOURCE_TIMER_INTERVAL } from "@pipedream/platform";
+import wati from "../../wati.app.mjs";
+
+export default {
+  props: {
+    wati,
+    db: "$.service.db",
+    timer: {
+      type: "$.interface.timer",
+      default: {
+        intervalSeconds: DEFAULT_POLLING_SOURCE_TIMER_INTERVAL,
+      },
+    },
+  },
+  methods: {
+    getOpts() {
+      return {};
+    },
+    filterItems() {
+      () => true;
+    },
+    _getLastDate() {
+      return this.db.get("lastDate") || 0;
+    },
+    _setLastDate(lastDate) {
+      this.db.set("lastDate", lastDate);
+    },
+    async emitEvent(maxResults = false) {
+      const lastDate = this._getLastDate();
+      const dateField = this.getDateField();
+
+      const response = this.wati.paginate({
+        fn: this.getFunction(),
+        ...this.getOpts(),
+        itemsField: this.getItemsField(),
+        maxResults,
+      });
+
+      let responseArray = [];
+      for await (const item of response) {
+        if (this.checkBreak(item, lastDate)) break;
+        responseArray.push(item);
+      }
+
+      responseArray = responseArray.filter(this.filterItems);
+
+      if (responseArray.length) {
+        this._setLastDate(responseArray[0][dateField]);
+      }
+
+      for (const item of responseArray.reverse()) {
+        this.$emit(item, {
+          id: item.id,
+          summary: this.getSummary(item),
+          ts: Date.parse(item[dateField]),
+        });
+      }
+    },
+  },
+  hooks: {
+    async deploy() {
+      await this.emitEvent(25);
+    },
+  },
+  async run() {
+    await this.emitEvent();
+  },
+};

components/wati/package.json

@@ -0,0 +1,33 @@
+import common from "../common/base.mjs";
+import sampleEmit from "./test-event.mjs";
+
+export default {
+  ...common,
+  key: "wati-new-contact-created",
+  name: "New Contact Created",
+  description: "Emit new event when a contact is created from an incoming WhatsApp message.",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  methods: {
+    ...common.methods,
+    getDateField() {
+      return "created";
+    },
+    getItemsField() {
+      return [
+        "result",
+      ];
+    },
+    checkBreak(item, lastDate) {
+      return Date.parse(item.created) < lastDate;
+    },
+    getFunction() {
+      return this.wati.listContacts;
+    },
+    getSummary(item) {
+      return `New contact created: ${item.wAid}`;
+    },
+  },
+  sampleEmit,
+};