[Components] moaform #14132

Sources
 - New Submission (Instant)

Author: luancazarine

components/moaform/moaform.app.mjs

@@ -8,75 +8,61 @@ export default {
       type: "string",
       label: "Form ID",
       description: "The ID of the form to monitor for new submissions",
-      async options() {
-        const forms = await this.getForms();
-        return forms.map((form) => ({
-          label: form.name,
-          value: form.id,
+      async options({ page }) {
+        const { items } = await this.getForms({
+          params: {
+            page: page + 1,
+          },
+        });
+        return items.map(({
+          id: value, title: label,
+        }) => ({
+          label,
+          value,
         }));
       },
     },
-    fields: {
-      type: "string[]",
-      label: "Fields to Capture",
-      description: "Optional fields to capture from the submission",
-      optional: true,
-    },
   },
   methods: {
-    authKeys() {
-      console.log(Object.keys(this.$auth));
-    },
     _baseUrl() {
-      return "https://api.moaform.com";
+      return "https://api.moaform.com/v1";
+    },
+    _headers() {
+      return {
+        Authorization: `Bearer ${this.$auth.api_key}`,
+      };
     },
-    async _makeRequest(opts = {}) {
-      const {
-        $ = this, method = "GET", path = "/", headers, ...otherOpts
-      } = opts;
+    _makeRequest({
+      $ = this, path, ...opts
+    }) {
       return axios($, {
-        ...otherOpts,
-        method,
         url: this._baseUrl() + path,
-        headers: {
-          ...headers,
-          Authorization: `Bearer ${this.$auth.api_token}`,
-        },
+        headers: this._headers(),
+        ...opts,
       });
     },
-    async getForms(opts = {}) {
+    getForms(opts = {}) {
       return this._makeRequest({
         ...opts,
         path: "/forms",
       });
     },
-    async createWebhook(opts = {}) {
-      const {
-        formId, url, fields,
-      } = opts;
+    createWebhook({
+      formId, ...opts
+    }) {
       return this._makeRequest({
         method: "POST",
         path: `/forms/${formId}/webhooks`,
-        data: {
-          url,
-          fields,
-        },
+        ...opts,
       });
     },
-    async deleteWebhook(opts = {}) {
-      const {
-        formId, webhookId,
-      } = opts;
+    deleteWebhook({
+      formId, webhookId,
+    }) {
       return this._makeRequest({
         method: "DELETE",
         path: `/forms/${formId}/webhooks/${webhookId}`,
       });
     },
-    async getWebhooks(opts = {}) {
-      const { formId } = opts;
-      return this._makeRequest({
-        path: `/forms/${formId}/webhooks`,
-      });
-    },
   },
 };

components/moaform/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/moaform",
-  "version": "0.0.1",
+  "version": "0.1.0",
   "description": "Pipedream Moaform Components",
   "main": "moaform.app.mjs",
   "keywords": [
@@ -11,5 +11,8 @@
   "author": "Pipedream <[email protected]> (https://pipedream.com/)",
   "publishConfig": {
     "access": "public"
+  },
+  "dependencies": {
+    "@pipedream/platform": "^3.0.3"
   }
 }

components/moaform/sources/new-submission-instant/new-submission-instant.mjs

@@ -1,60 +1,71 @@
-import { axios } from "@pipedream/platform";
+import crypto from "crypto";
 import moaform from "../../moaform.app.mjs";
+import sampleEmit from "./test-event.mjs";
 
 export default {
   key: "moaform-new-submission-instant",
-  name: "New Submission Instant",
-  description: "Emit new event every time a new form submission is received. [See the documentation](https://help.moaform.com)",
+  name: "New Submission (Instant)",
+  description: "Emit new event every time a new form submission is received.",
   version: "0.0.1",
   type: "source",
   dedupe: "unique",
   props: {
     moaform,
+    http: {
+      type: "$.interface.http",
+      customResponse: true,
+    },
     db: "$.service.db",
     formId: {
       propDefinition: [
         moaform,
         "formId",
       ],
     },
-    fields: {
-      propDefinition: [
-        moaform,
-        "fields",
+    retentionDays: {
+      type: "integer",
+      label: "Retention Days",
+      description: "Resend restriction days",
+      options: [
+        1,
+        3,
+        5,
+        7,
+        10,
+        15,
+        30,
       ],
+      optional: true,
     },
-    httpSource: {
-      type: "$.interface.http",
-      label: "HTTP Source",
-      description: "HTTP source to set up webhooks",
+    secret: {
+      type: "string",
+      label: "Secret Code",
+      description: "This code is used to verify that the data received at the specified endpoint has indeed been sent from Moaform and has not been tampered with.",
+      secret: true,
+      optional: true,
     },
   },
-  hooks: {
-    async deploy() {
-      const webhooks = await this.moaform.getWebhooks({
-        formId: this.formId,
-      });
-
-      for (const webhook of webhooks) {
-        this.$emit(webhook, {
-          id: webhook.id,
-          summary: `Existing webhook: ${webhook.id}`,
-          ts: Date.now(),
-        });
-      }
+  methods: {
+    _getWebhookId() {
+      return this.db.get("webhookId");
+    },
+    _setWebhookId(id) {
+      this.db.set("webhookId", id);
     },
+  },
+  hooks: {
     async activate() {
-      const {
-        formId, fields,
-      } = this;
-      const url = this.httpSource.url;
-      const webhook = await this.moaform.createWebhook({
-        formId,
-        url,
-        fields,
+      const response = await this.moaform.createWebhook({
+        formId: this.formId,
+        data: {
+          endpoint: this.http.endpoint,
+          enabled: true,
+          secret: this.secret,
+          verify_ssl: true,
+          retention_days: this.retentionDays,
+        },
       });
-
-      this.db.set("webhookId", webhook.id);
+      this._setWebhookId(response.id);
     },
     async deactivate() {
       const webhookId = this.db.get("webhookId");
@@ -64,28 +75,33 @@ export default {
       });
     },
   },
-  async run(event) {
-    const {
-      headers, body,
-    } = event;
-    const id = headers["x-moaform-submission-id"];
-    const formId = body.formId;
-    const submissionFields = this.fields.length ?
-      this.fields.reduce((acc, field) => ({
-        ...acc,
-        [field]: body.fields[field],
-      }), {})
-      : body.fields;
+  async run({
+    bodyRaw, body, headers,
+  }) {
+
+    if (this.secret) {
+      const signature = headers["moaform-signature"];
+      const receivedSig = signature.split("sha256=")[1];
+
+      const calculatedSig = crypto
+        .createHmac("sha256", this.secret)
+        .update(bodyRaw)
+        .digest("base64");
 
-    const eventToEmit = {
-      formId,
-      ...submissionFields,
-    };
+      if (receivedSig !== calculatedSig) {
+        return this.http.respond({
+          status: 401,
+          body: "Unauthorized",
+        });
+      }
+    }
 
-    this.$emit(eventToEmit, {
-      id,
-      summary: `New submission received for form ${formId}`,
-      ts: Date.now(),
+    const ts = Date.parse(body.submitted_at);
+    this.$emit(body, {
+      id: body.event_id,
+      summary: `New submission received for form ${this.formId}`,
+      ts: ts,
     });
   },
+  sampleEmit,
 };

components/moaform/sources/new-submission-instant/test-event.mjs

@@ -0,0 +1,18 @@
+export default {
+  "event_id": "105fa72f-9e6e-4667-8ead-22b0a3ed254a",
+  "event_type": "response_completed",
+  "hidden": {},
+  "response_id": "test#123-45-67890",
+  "submitted_at": "2024-09-27T21:00:55Z",
+  "form": {
+    "id": "MG7eAk",
+    "title": "form title",
+    "report_url": "https://www.moaform.com/reports/q945EegynYD8G2xM",
+    "answer_url": "https://moaform.com/q/not-started-collecting"
+  },
+  "answers": [],
+  "thankyou": {
+    "id": "cm1l7axyf2t9x0fqrly27vdn7",
+    "url": "https://answer.moaform.com/answers/MG7eAk/thankyou/Wo2b1Z09wx5"
+  }
+}