moaform init

Author: luancazarine

components/moaform/moaform.app.mjs

@@ -1,11 +1,82 @@
+import { axios } from "@pipedream/platform";
+
 export default {
   type: "app",
   app: "moaform",
-  propDefinitions: {},
+  propDefinitions: {
+    formId: {
+      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,
+        }));
+      },
+    },
+    fields: {
+      type: "string[]",
+      label: "Fields to Capture",
+      description: "Optional fields to capture from the submission",
+      optional: true,
+    },
+  },
   methods: {
-    // this.$auth contains connected account data
     authKeys() {
       console.log(Object.keys(this.$auth));
     },
+    _baseUrl() {
+      return "https://api.moaform.com";
+    },
+    async _makeRequest(opts = {}) {
+      const {
+        $ = this, method = "GET", path = "/", headers, ...otherOpts
+      } = opts;
+      return axios($, {
+        ...otherOpts,
+        method,
+        url: this._baseUrl() + path,
+        headers: {
+          ...headers,
+          Authorization: `Bearer ${this.$auth.api_token}`,
+        },
+      });
+    },
+    async getForms(opts = {}) {
+      return this._makeRequest({
+        ...opts,
+        path: "/forms",
+      });
+    },
+    async createWebhook(opts = {}) {
+      const {
+        formId, url, fields,
+      } = opts;
+      return this._makeRequest({
+        method: "POST",
+        path: `/forms/${formId}/webhooks`,
+        data: {
+          url,
+          fields,
+        },
+      });
+    },
+    async deleteWebhook(opts = {}) {
+      const {
+        formId, webhookId,
+      } = opts;
+      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

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

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

@@ -0,0 +1,91 @@
+import { axios } from "@pipedream/platform";
+import moaform from "../../moaform.app.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)",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  props: {
+    moaform,
+    db: "$.service.db",
+    formId: {
+      propDefinition: [
+        moaform,
+        "formId",
+      ],
+    },
+    fields: {
+      propDefinition: [
+        moaform,
+        "fields",
+      ],
+    },
+    httpSource: {
+      type: "$.interface.http",
+      label: "HTTP Source",
+      description: "HTTP source to set up webhooks",
+    },
+  },
+  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(),
+        });
+      }
+    },
+    async activate() {
+      const {
+        formId, fields,
+      } = this;
+      const url = this.httpSource.url;
+      const webhook = await this.moaform.createWebhook({
+        formId,
+        url,
+        fields,
+      });
+
+      this.db.set("webhookId", webhook.id);
+    },
+    async deactivate() {
+      const webhookId = this.db.get("webhookId");
+      await this.moaform.deleteWebhook({
+        formId: this.formId,
+        webhookId,
+      });
+    },
+  },
+  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;
+
+    const eventToEmit = {
+      formId,
+      ...submissionFields,
+    };
+
+    this.$emit(eventToEmit, {
+      id,
+      summary: `New submission received for form ${formId}`,
+      ts: Date.now(),
+    });
+  },
+};