init

Author: michelle0927

components/gocanvas/actions/create-dispatch/create-dispatch.mjs

@@ -0,0 +1,20 @@
+import gocanvas from "../../gocanvas.app.mjs";
+
+export default {
+  key: "gocanvas-create-dispatch",
+  name: "Create Dispatch",
+  description: "Creates a dispatch item in GoCanvas.",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    gocanvas,
+    dispatchApp: gocanvas.propDefinitions.dispatchApp,
+  },
+  async run({ $ }) {
+    const response = await this.gocanvas.createDispatchItem({
+      dispatchApp: this.dispatchApp,
+    });
+    $.export("$summary", `Successfully created dispatch item in ${this.dispatchApp}`);
+    return response;
+  },
+};

components/gocanvas/actions/delete-dispatch/delete-dispatch.mjs

@@ -0,0 +1,20 @@
+import gocanvas from "../../gocanvas.app.mjs";
+
+export default {
+  key: "gocanvas-delete-dispatch",
+  name: "Delete Dispatch",
+  description: "Removes a specific dispatch from GoCanvas. The 'description' of the dispatch to be deleted is a required prop.",
+  version: "0.0.{{ts}}",
+  type: "action",
+  props: {
+    gocanvas,
+    dispatchDescription: gocanvas.propDefinitions.dispatchDescription,
+  },
+  async run({ $ }) {
+    const response = await this.gocanvas.removeDispatch({
+      dispatchDescription: this.dispatchDescription,
+    });
+    $.export("$summary", `Successfully deleted dispatch with description: ${this.dispatchDescription}`);
+    return response;
+  },
+};

components/gocanvas/actions/sync-reference-data/sync-reference-data.mjs

@@ -0,0 +1,25 @@
+import gocanvas from "../../gocanvas.app.mjs";
+
+export default {
+  key: "gocanvas-sync-reference-data",
+  name: "Sync Reference Data",
+  description: "Synchronizes GoCanvas reference data file with Google Sheets. [See the documentation](https://www.gocanvas.com/content/faq/post/how-to-use-reference-data-in-your-mobile-business-apps/)",
+  version: "0.0.{{ts}}",
+  type: "action",
+  props: {
+    gocanvas,
+    referenceDataFile: {
+      propDefinition: [
+        gocanvas,
+        "referenceDataFile",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const response = await this.gocanvas.syncReferenceDataFile({
+      referenceDataFile: this.referenceDataFile,
+    });
+    $.export("$summary", `Successfully synced reference data file ${this.referenceDataFile}`);
+    return response;
+  },
+};

components/gocanvas/gocanvas.app.mjs

@@ -1,11 +1,89 @@
+import { axios } from "@pipedream/platform";
+
 export default {
   type: "app",
   app: "gocanvas",
-  propDefinitions: {},
+  propDefinitions: {
+    applicationId: {
+      type: "string",
+      label: "Application ID",
+      description: "The ID of the GoCanvas application",
+    },
+    submissionId: {
+      type: "string",
+      label: "Submission ID",
+      description: "The ID of the submission to get dynamic fields",
+      optional: true,
+    },
+    dispatchApp: {
+      type: "string",
+      label: "Dispatch App",
+      description: "The name of a dispatch-enabled GoCanvas app",
+    },
+    dispatchDescription: {
+      type: "string",
+      label: "Dispatch Description",
+      description: "The 'description' of the dispatch to be deleted",
+    },
+    referenceDataFile: {
+      type: "string",
+      label: "Reference Data File",
+      description: "The name of the GoCanvas reference data file to be synced",
+    },
+  },
   methods: {
-    // this.$auth contains connected account data
     authKeys() {
       console.log(Object.keys(this.$auth));
     },
+    _baseUrl() {
+      return "https://api.gocanvas.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.oauth_access_token}`,
+        },
+      });
+    },
+    async emitNewEvent(opts = {}) {
+      return this._makeRequest({
+        path: `/submissions/${opts.submissionId}`,
+        ...opts,
+      });
+    },
+    async createDispatchItem(opts = {}) {
+      return this._makeRequest({
+        method: "POST",
+        path: "/dispatches",
+        data: {
+          app_name: opts.dispatchApp,
+        },
+        ...opts,
+      });
+    },
+    async removeDispatch(opts = {}) {
+      return this._makeRequest({
+        method: "DELETE",
+        path: "/dispatches",
+        params: {
+          description: opts.dispatchDescription,
+        },
+        ...opts,
+      });
+    },
+    async syncReferenceDataFile(opts = {}) {
+      return this._makeRequest({
+        method: "PUT",
+        path: `/reference_data_files/${opts.referenceDataFile}`,
+        ...opts,
+      });
+    },
   },
 };

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

@@ -0,0 +1,60 @@
+import gocanvas from "../../gocanvas.app.mjs";
+
+export default {
+  key: "gocanvas-new-submission-instant",
+  name: "New Submission Instant",
+  description: "Emit new event when a new submission is uploaded to the specified GoCanvas application.",
+  version: "0.0.{{ts}}",
+  type: "source",
+  dedupe: "unique",
+  props: {
+    gocanvas,
+    db: "$.service.db",
+    applicationId: {
+      propDefinition: [
+        gocanvas,
+        "applicationId",
+      ],
+    },
+    submissionId: {
+      propDefinition: [
+        gocanvas,
+        "submissionId",
+        (c) => ({
+          applicationId: c.applicationId,
+        }),
+      ],
+      optional: true,
+    },
+  },
+  methods: {
+    generateMeta(data) {
+      const {
+        id, created_at,
+      } = data;
+      return {
+        id,
+        summary: `New Submission: ${id}`,
+        ts: Date.parse(created_at),
+      };
+    },
+  },
+  async run(event) {
+    const { body } = event;
+    if (!body.submission || !body.submission.id) {
+      console.log("Ignoring event without submission id");
+      return;
+    }
+    const applicationId = this.applicationId;
+    const submissionId = this.submissionId || body.submission.id;
+    if (applicationId !== body.submission.application_id) {
+      console.log("Ignoring submission from another application");
+      return;
+    }
+    const data = await this.gocanvas.emitNewEvent({
+      submissionId,
+    });
+    const meta = this.generateMeta(data);
+    this.$emit(data, meta);
+  },
+};