[Components] opnform #15639

Sources
 - New Submission (Instant)

Author: luancazarine

components/opnform/opnform.app.mjs

@@ -3,21 +3,30 @@ import { axios } from "@pipedream/platform";
 export default {
   type: "app",
   app: "opnform",
-  version: "0.0.{{ts}}",
   propDefinitions: {
     workspaceId: {
       type: "string",
       label: "Workspace ID",
       description: "The ID of the workspace containing the forms.",
+      async options() {
+        const worspaces = await this.listWorkspaces();
+        return worspaces.map(({
+          id: value, name: label,
+        }) => ({
+          label,
+          value,
+        }));
+      },
     },
     formId: {
       type: "string",
       label: "Form",
       description: "Select the form to monitor for new submissions.",
-      async options() {
-        const { workspaceId } = this;
+      async options({ workspaceId }) {
         const forms = await this.listForms({
-          workspaceId,
+          params: {
+            workspace_id: workspaceId,
+          },
         });
         return forms.map((form) => ({
           label: form.name,
@@ -27,76 +36,48 @@ export default {
     },
   },
   methods: {
-    authKeys() {
-      console.log(Object.keys(this.$auth));
-    },
     _baseUrl() {
       return "https://api.opnform.com/external/zapier";
     },
-    async _makeRequest(opts = {}) {
-      const {
-        $ = this, method = "GET", path = "/", headers, params, data, ...otherOpts
-      } = opts;
+    _headers() {
+      return {
+        Authorization: `Bearer ${this.$auth.api_key}`,
+      };
+    },
+    _makeRequest({
+      $ = this, path, ...opts
+    }) {
       return axios($, {
-        method,
         url: this._baseUrl() + path,
-        headers: {
-          ...headers,
-          Authorization: `Bearer ${this.$auth.api_key}`,
-        },
-        params,
-        data,
-        ...otherOpts,
+        headers: this._headers(),
+        ...opts,
       });
     },
-    async listForms({
-      workspaceId, ...opts
-    } = {}) {
-      if (!workspaceId) {
-        throw new Error("workspaceId is required to list forms.");
-      }
+    listForms(opts = {}) {
       return this._makeRequest({
-        method: "GET",
         path: "/forms",
-        params: {
-          workspace_id: workspaceId,
-        },
         ...opts,
       });
     },
-    async createWebhook({
-      hookUrl, formId, ...opts
-    } = {}) {
+    listWorkspaces(opts = {}) {
+      return this._makeRequest({
+        path: "/workspaces",
+        ...opts,
+      });
+    },
+    createWebhook(opts = {}) {
       return this._makeRequest({
         method: "POST",
         path: "/webhook",
-        data: {
-          hookUrl,
-          form_id: formId,
-        },
         ...opts,
       });
     },
-    async paginate(fn, ...opts) {
-      let results = [];
-      let response;
-      let hasMore = true;
-      let page = 1;
-
-      while (hasMore) {
-        response = await fn({
-          page,
-          ...opts,
-        });
-        if (Array.isArray(response) && response.length > 0) {
-          results = results.concat(response);
-          page += 1;
-        } else {
-          hasMore = false;
-        }
-      }
-
-      return results;
+    deleteWebhook(opts = {}) {
+      return this._makeRequest({
+        method: "DELETE",
+        path: "/webhook",
+        ...opts,
+      });
     },
   },
 };

components/opnform/package.json

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

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

@@ -1,92 +1,58 @@
-import { axios } from "@pipedream/platform";
 import opnform from "../../opnform.app.mjs";
+import sampleEmit from "./test-event.mjs";
 
 export default {
   key: "opnform-new-submission-instant",
   name: "New Submission Instant",
-  description: "Emit a new event when a form receives a submission. [See the documentation]()",
-  version: "0.0.{{ts}}",
+  description: "Emit new event when a form receives a submission.",
+  version: "0.0.1",
   type: "source",
   dedupe: "unique",
   props: {
-    opnform: {
-      type: "app",
-      app: "opnform",
-    },
+    opnform,
+    http: "$.interface.http",
+    db: "$.service.db",
     workspaceId: {
       propDefinition: [
-        "opnform",
+        opnform,
         "workspaceId",
       ],
     },
     formId: {
       propDefinition: [
-        "opnform",
+        opnform,
         "formId",
+        ({ workspaceId }) => ({
+          workspaceId,
+        }),
       ],
     },
-    http: {
-      type: "$.interface.http",
-      customResponse: true,
-    },
-    db: "$.service.db",
   },
   hooks: {
     async activate() {
-      const hookUrl = this.http.endpoint;
-      const webhook = await this.opnform.createWebhook({
-        hookUrl,
-        formId: this.formId,
+      await this.opnform.createWebhook({
+        data: {
+          hookUrl: this.http.endpoint,
+          form_id: this.formId,
+        },
       });
-      await this.db.set("webhookId", webhook.id);
     },
     async deactivate() {
-      const webhookId = await this.db.get("webhookId");
-      if (webhookId) {
-        await this.opnform._makeRequest({
-          method: "DELETE",
-          path: `/webhook/${webhookId}`,
-        });
-        await this.db.delete("webhookId");
-      }
-    },
-    async deploy() {
-      const submissions = await this.opnform.paginate(
-        this.opnform._makeRequest.bind(this.opnform),
-        {
-          method: "GET",
-          path: `/forms/${this.formId}/submissions`,
-          params: {
-            limit: 50,
-          },
+      await this.opnform.deleteWebhook({
+        data: {
+          hookUrl: this.http.endpoint,
+          form_id: this.formId,
         },
-      );
-
-      submissions.reverse().forEach((submission) => {
-        this.$emit(
-          submission,
-          {
-            id: submission.id || Date.now().toString(),
-            summary: `New submission for form ${submission.formName}`,
-            ts: submission.createdAt
-              ? Date.parse(submission.createdAt)
-              : Date.now(),
-          },
-        );
       });
     },
   },
-  async run(event) {
-    const submission = event.body;
-    const id = submission.id || Date.now().toString();
-    const summary = `New submission for form ${submission.formName}`;
-    const ts = submission.createdAt
-      ? Date.parse(submission.createdAt)
-      : Date.now();
-    this.$emit(submission, {
-      id,
-      summary,
+  async run({ body }) {
+    const ts = Date.now();
+    this.$emit(body, {
+      id: `${body.form_slug}-${ts}`,
+      summary: `New submission for "${body.form_title}"`,
       ts,
     });
   },
+  sampleEmit,
 };

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

@@ -0,0 +1,24 @@
+export default  {
+  "form_title": "My Form",
+  "form_slug": "my-form-dtewbq",
+  "submission": {
+    "Name": "User Name",
+    "Email": "[email protected]",
+    "Message": "User Message"
+  },
+  "data": {
+    "3cc8fbba-1234-1234-979d-0e81d8f6845c": {
+      "value": "USer Name",
+      "name": "Name"
+    },
+    "9a1778ff-1234-1234-a62c-197dae1ed3c0": {
+      "value": "[email protected]",
+      "name": "Email"
+    },
+    "ddd28630-1234-1234-bbe5-4f58c485d470": {
+      "value": "USer Message",
+      "name": "Message"
+    }
+  },
+  "message": "Please do not use the `submission` field. It is deprecated and will be removed in the future."
+}