syncmate_by_assitro init

Author: luancazarine

components/syncmate_by_assitro/actions/send-bulk-messages/send-bulk-messages.mjs

@@ -0,0 +1,49 @@
+import syncmateByAssitro from "../../syncmate_by_assitro.app.mjs";
+import { axios } from "@pipedream/platform";
+
+export default {
+  key: "syncmate_by_assitro-send-bulk-messages",
+  name: "Send Bulk Messages",
+  description: "Send multiple WhatsApp messages in bulk. [See the documentation](https://assistro.co/user-guide/bulk-messaging-at-a-scheduled-time-using-syncmate-2/)",
+  version: "0.0.{{ts}}",
+  type: "action",
+  props: {
+    syncmateByAssitro,
+    numberOfMessages: {
+      propDefinition: [
+        syncmateByAssitro,
+        "numberOfMessages",
+      ],
+    },
+    number: {
+      propDefinition: [
+        syncmateByAssitro,
+        "number",
+      ],
+    },
+    message: {
+      propDefinition: [
+        syncmateByAssitro,
+        "message",
+      ],
+    },
+    media: {
+      propDefinition: [
+        syncmateByAssitro,
+        "media",
+      ],
+      optional: true,
+    },
+  },
+  async run({ $ }) {
+    const response = await this.syncmateByAssitro.sendBulkMessages({
+      numberOfMessages: this.numberOfMessages,
+      number: this.number,
+      message: this.message,
+      media: this.media,
+    });
+
+    $.export("$summary", `Successfully sent ${this.numberOfMessages} messages to ${this.number}`);
+    return response;
+  },
+};

components/syncmate_by_assitro/actions/send-message/send-message.mjs

@@ -0,0 +1,41 @@
+import syncmateByAssitro from "../../syncmate_by_assitro.app.mjs";
+import { axios } from "@pipedream/platform";
+
+export default {
+  key: "syncmate_by_assitro-send-message",
+  name: "Send WhatsApp Message",
+  description: "Send a single WhatsApp message using SyncMate by Assistro. [See the documentation](https://assistro.co/user-guide/connect-your-custom-app-with-syncmate/)",
+  version: "0.0.{{ts}}",
+  type: "action",
+  props: {
+    syncmateByAssitro,
+    number: {
+      propDefinition: [
+        syncmateByAssitro,
+        "number",
+      ],
+    },
+    message: {
+      propDefinition: [
+        syncmateByAssitro,
+        "message",
+      ],
+    },
+    media: {
+      propDefinition: [
+        syncmateByAssitro,
+        "media",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const response = await this.syncmateByAssitro.sendSingleMessage({
+      number: this.number,
+      message: this.message,
+      media: this.media,
+    });
+
+    $.export("$summary", `Successfully sent message to ${this.number}`);
+    return response;
+  },
+};

components/syncmate_by_assitro/package.json

@@ -12,4 +12,4 @@
   "publishConfig": {
     "access": "public"
   }
-}
+}

components/syncmate_by_assitro/syncmate_by_assitro.app.mjs

@@ -1,11 +1,98 @@
+import { axios } from "@pipedream/platform";
+
 export default {
   type: "app",
   app: "syncmate_by_assitro",
-  propDefinitions: {},
+  propDefinitions: {
+    number: {
+      type: "string",
+      label: "Number",
+      description: "WhatsApp number with country code",
+    },
+    message: {
+      type: "string",
+      label: "Message",
+      description: "The text message to be sent",
+    },
+    media: {
+      type: "string[]",
+      label: "Media",
+      description: "Base64 encoded media files",
+      optional: true,
+      default: [],
+    },
+    numberOfMessages: {
+      type: "integer",
+      label: "Number of Messages",
+      description: "The number of messages to send in bulk",
+    },
+  },
   methods: {
-    // this.$auth contains connected account data
     authKeys() {
       console.log(Object.keys(this.$auth));
     },
+    _baseUrl() {
+      return "https://app.assistro.co/api/v1/wapushplus";
+    },
+    async _makeRequest(opts = {}) {
+      const {
+        $ = this,
+        method = "POST",
+        path = "/",
+        headers,
+        ...otherOpts
+      } = opts;
+      return axios($, {
+        ...otherOpts,
+        method,
+        url: this._baseUrl() + path,
+        headers: {
+          "Authorization": `Bearer ${this.$auth.api_key}`,
+          "Content-Type": "application/json",
+          ...headers,
+        },
+      });
+    },
+    async sendSingleMessage({
+      number, message, media = [],
+    }) {
+      const data = {
+        msgs: [
+          {
+            number,
+            message,
+            media: media.map((m) => ({
+              media_base64: m,
+              file_name: `file_${Date.now()}`,
+            })),
+          },
+        ],
+      };
+      return this._makeRequest({
+        path: "/single/message",
+        data,
+      });
+    },
+    async sendBulkMessages({
+      numberOfMessages, number, message, media = [],
+    }) {
+      const msgs = Array.from({
+        length: numberOfMessages,
+      }, () => ({
+        number,
+        message,
+        media: media.map((m) => ({
+          media_base64: m,
+          file_name: `file_${Date.now()}`,
+        })),
+      }));
+      const data = {
+        msgs,
+      };
+      return this._makeRequest({
+        path: "/bulk/message",
+        data,
+      });
+    },
   },
-};
+};