new components

Author: michelle0927

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

@@ -3,18 +3,47 @@ import gocanvas from "../../gocanvas.app.mjs";
 export default {
   key: "gocanvas-create-dispatch",
   name: "Create Dispatch",
-  description: "Creates a dispatch item in GoCanvas.",
+  description: "Creates a dispatch item in GoCanvas. [See the documentation](https://help.gocanvas.com/hc/en-us/article_attachments/26468076609559)",
   version: "0.0.1",
   type: "action",
   props: {
     gocanvas,
-    dispatchApp: gocanvas.propDefinitions.dispatchApp,
+    form: {
+      propDefinition: [
+        gocanvas,
+        "form",
+      ],
+      description: "The name of the form you want to create a prepopulated submission for",
+    },
+    entries: {
+      type: "object",
+      label: "Entries",
+      description: `DIEntry elements consisting of label/value pairs.
+      \n Label: Either the Export Label or plain Label field attribute (caseinsensitive) as defined in the form builder.
+      \n Value: The value assigned to this Dispatch Item entry.
+      `,
+    },
   },
   async run({ $ }) {
-    const response = await this.gocanvas.createDispatchItem({
-      dispatchApp: this.dispatchApp,
+    let entriesString = "";
+    for (const [
+      key,
+      value,
+    ] of Object.entries(this.entries)) {
+      entriesString += `<DIEntry Label="${key}" Value="${value}"/>`;
+    }
+    const response = await this.gocanvas.dispatchItems({
+      $,
+      data: `
+        <?xml version="1.0" encoding="utf-8"?>
+          <List>
+            <DI FormName="${this.form}">
+              ${entriesString}
+            </DI>
+          </List>
+      `,
     });
-    $.export("$summary", `Successfully created dispatch item in ${this.dispatchApp}`);
+    $.export("$summary", `Successfully created dispatch item in ${this.form}`);
     return response;
   },
 };

components/gocanvas/actions/create-or-update-reference-data/create-or-update-reference-data.mjs

@@ -0,0 +1,66 @@
+import gocanvas from "../../gocanvas.app.mjs";
+import * as csvParse from "csv-parse";
+
+export default {
+  key: "gocanvas-create-or-update-reference-data",
+  name: "Create or Update Reference Data",
+  description: "Creates or updates GoCanvas reference data. [See the documentation](https://help.gocanvas.com/hc/en-us/article_attachments/26468076609559)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    gocanvas,
+    name: {
+      type: "string",
+      label: "Reference Data Name",
+      description: "The attribute name of the dataset to operate on. Will be created if it doesn't already exist.",
+    },
+    data: {
+      type: "string",
+      label: "Data",
+      description: `A string of comma separated values representing the data to create/update. **Include Column names**:
+      \n Example:
+      \n  Column1,Column2,Column3
+      \n  Data1Column1,Data1Column2,Data1Column3
+      \n  Data2Column1,Data2Column2,Data3Column3
+      `,
+    },
+  },
+  methods: {
+    csvToXml(data) {
+      const records = csvParse.parse(data, {
+        columns: true,
+        trim: true,
+      });
+
+      // Extract columns
+      const columns = Object.keys(records[0]);
+      let result = "<Columns>";
+      result += columns.map((col) => `<c>${col}</c>`).join("");
+      result += "</Columns>\n<Rows>\n";
+
+      // Extract rows
+      result += records
+        .map((row) => {
+          const rowValues = columns.map((col) => `<v>${row[col]}</v>`).join("");
+          return `  <r>${rowValues}</r>`;
+        })
+        .join("\n");
+
+      result += "\n</Rows>";
+      return result;
+    },
+  },
+  async run({ $ }) {
+    const response = await this.gocanvas.createUpdateReferenceData({
+      $,
+      data: `
+        <?xml version="1.0" encoding="utf-8"?>
+          <List Name="${this.name}">
+            ${await this.csvToXml(this.data)}
+          </List>
+      `,
+    });
+    $.export("$summary", "Successfully created/updated reference data");
+    return response;
+  },
+};

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

@@ -4,14 +4,23 @@ export default {
   key: "gocanvas-delete-dispatch",
   name: "Delete Dispatch",
   description: "Removes a specific dispatch from GoCanvas. [See the documentation](https://help.gocanvas.com/hc/en-us/article_attachments/26468076609559)",
-  version: "0.0.{{ts}}",
+  version: "0.0.1",
   type: "action",
   props: {
     gocanvas,
+    form: {
+      propDefinition: [
+        gocanvas,
+        "form",
+      ],
+    },
     dispatchId: {
       propDefinition: [
         gocanvas,
         "dispatchId",
+        (c) => ({
+          form: c.form,
+        }),
       ],
     },
   },
@@ -25,15 +34,8 @@ export default {
       data: `
         <?xml version="1.0" encoding="utf-8"?>
           <List>
-            <DI FormName="Daily Report" Action="Delete" OriginalDescription="${description}">
-              <DIEntry />
-              <DIListItems>
-                <DIListItem>
-                  <DIEntries>
-                    <DIEntry Label="Date" Value="${Date.now()}"/>
-                  </DIEntries>
-                </DIListItem>
-              </DIListItems>
+            <DI FormName="${this.form}" Action="Delete" OriginalDescription="${description}">
+              <DIEntry Label="Date" Value="${Date.now()}"/>
             </DI>
           </List>
       `,

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

@@ -5,12 +5,24 @@ export default {
   type: "app",
   app: "gocanvas",
   propDefinitions: {
+    form: {
+      type: "string",
+      label: "Form",
+      description: "The identifier of a form",
+      async options() {
+        const forms = await this.listForms();
+        return forms?.map((form) => form.Name[0]) || [];
+      },
+    },
     dispatchId: {
       type: "string",
       label: "Dispatch ID",
       description: "Identifier of a dispatch",
-      async options({ page }) {
+      async options({
+        page, form,
+      }) {
         const dispatches = await this.getActiveDispatches({
+          form,
           data: {
             page: page + 1,
           },
@@ -47,22 +59,46 @@ export default {
         },
       });
     },
-    async getActiveDispatches(opts = {}) {
+    async getActiveDispatches({
+      form, ...opts
+    }) {
       const response = await this._makeRequest({
         path: "/dispatch_export",
         ...opts,
       });
       const { CanvasResult: { Dispatches: dispatches } } = await new xml2js
         .Parser().parseStringPromise(response);
-      const dispatchList = [];
-      for (const dispatch of dispatches) {
-        if (!dispatch.Dispatch) {
-          continue;
-        }
-        const activeDispatches = dispatch.Dispatch.filter((d) => d.Status[0] !== "deleted");
-        dispatchList.push(...activeDispatches);
+      if (!dispatches?.length) {
+        return [];
+      }
+      return dispatches
+        .flatMap((d) => d.Dispatch || [])
+        .filter((d) => d.Status[0] !== "deleted")
+        .filter((d) => !form || d.Form[0] === form);
+    },
+    async listForms(opts = {}) {
+      const response = await this._makeRequest({
+        path: "/forms",
+        ...opts,
+      });
+      const { CanvasResult: { Forms: forms } } = await new xml2js
+        .Parser().parseStringPromise(response);
+      if (!forms?.length) {
+        return [];
+      }
+      return forms.flatMap((form) => form.Form || []);
+    },
+    async listSubmissions(opts = {}) {
+      const response = await this._makeRequest({
+        path: "/submissions",
+        ...opts,
+      });
+      const { CanvasResult: { Submissions: submissions } } = await new xml2js
+        .Parser().parseStringPromise(response);
+      if (!submissions?.length) {
+        return [];
       }
-      return dispatchList;
+      return submissions.flatMap((sub) => sub.Submission || []);
     },
     async getDispatchDescription({
       dispatchId, ...opts
@@ -80,5 +116,36 @@ export default {
         ...opts,
       });
     },
+    createUpdateReferenceData(opts = {}) {
+      return this._makeRequest({
+        method: "POST",
+        path: "/reference_datas",
+        ...opts,
+      });
+    },
+    async *paginate({
+      fn,
+      params,
+      max,
+    }) {
+      params = {
+        ...params,
+        page: 1,
+      };
+      let total, count = 0;
+      do {
+        const results = await fn({
+          params,
+        });
+        for (const item of results) {
+          yield item;
+          if (max && ++count >= max) {
+            return;
+          }
+        }
+        total = results?.length;
+        params.page++;
+      } while (total);
+    },
   },
 };

components/gocanvas/gocanvas.app.mjs

@@ -13,6 +13,8 @@
     "access": "public"
   },
   "dependencies": {
-    "@pipedream/platform": "^3.0.3"
+    "@pipedream/platform": "^3.0.3",
+    "csv-parse": "^5.5.6",
+    "xml2js": "^0.6.2"
   }
 }