[ACTION] Salesforce Accounts/Opportunities Batch Create/UpdateDD

Author: jcortes

components/salesforce_rest_api/actions/common/batch-operation.mjs

@@ -0,0 +1,81 @@
+import {
+  ConfigurationError,
+  getFileStream,
+} from "@pipedream/platform";
+import app from "../../salesforce_rest_api.app.mjs";
+
+export default {
+  props: {
+    app,
+    csvFilePath: {
+      type: "string",
+      label: "CSV File Path Or URL",
+      description: "The path to the CSV file to process. Provide a path to a file in the `/tmp` directory (for example, `/tmp/data.csv`). If a URL is provided, the file will be downloaded to the `/tmp` directory. [See the documentation](https://developer.salesforce.com/docs/atlas.en-us.api_asynch.meta/api_asynch/datafiles_prepare_data.htm)",
+    },
+  },
+  methods: {
+    getObject() {
+      throw new ConfigurationError("getObject method not implemented");
+    },
+    getOperation() {
+      throw new ConfigurationError("getOperation method not implemented");
+    },
+    getSummary() {
+      throw new ConfigurationError("getSummary method not implemented");
+    },
+    async processBulkOperation({
+      object, operation, csvData, externalIdFieldName, ...args
+    } = {}) {
+      const { app } = this;
+      const job = await app.createBulkJob({
+        ...args,
+        data: {
+          object,
+          operation,
+          externalIdFieldName,
+        },
+      });
+
+      await app.uploadBulkJobData({
+        ...args,
+        jobId: job.id,
+        data: csvData,
+      });
+
+      await app.patchBulkJob({
+        ...args,
+        jobId: job.id,
+        data: {
+          state: "UploadComplete",
+        },
+      });
+
+      return app.getBulkJobInfo({
+        ...args,
+        jobId: job.id,
+      });
+    },
+  },
+  async run({ $ }) {
+    const {
+      processBulkOperation,
+      getObject,
+      getOperation,
+      getSummary,
+      csvFilePath,
+    } = this;
+
+    const csvData = await getFileStream(csvFilePath);
+
+    const result = await processBulkOperation({
+      $,
+      object: getObject(),
+      operation: getOperation(),
+      csvData,
+    });
+
+    $.export("$summary", getSummary());
+
+    return result;
+  },
+};

components/salesforce_rest_api/actions/create-accounts-batch/create-accounts-batch.mjs

@@ -0,0 +1,21 @@
+import common from "../common/batch-operation.mjs";
+
+export default {
+  ...common,
+  key: "salesforce_rest_api-create-accounts-batch",
+  name: "Create Accounts (Batch)",
+  description: "Create multiple Accounts in Salesforce using Bulk API 2.0. [See the documentation](https://developer.salesforce.com/docs/atlas.en-us.api_asynch.meta/api_asynch/datafiles_understanding_bulk2_ingest.htm)",
+  version: "0.0.1",
+  type: "action",
+  methods: {
+    getObject() {
+      return "Account";
+    },
+    getOperation() {
+      return "insert";
+    },
+    getSummary() {
+      return "Successfully created Accounts";
+    },
+  },
+};

components/salesforce_rest_api/actions/create-opportunities-batch/create-opportunities-batch.mjs

@@ -0,0 +1,21 @@
+import common from "../common/batch-operation.mjs";
+
+export default {
+  ...common,
+  key: "salesforce_rest_api-create-opportunities-batch",
+  name: "Create Opportunities (Batch)",
+  description: "Create multiple Opportunities in Salesforce using Bulk API 2.0. [See the documentation](https://developer.salesforce.com/docs/atlas.en-us.api_asynch.meta/api_asynch/datafiles_understanding_bulk2_ingest.htm)",
+  version: "0.0.1",
+  type: "action",
+  methods: {
+    getObject() {
+      return "Opportunity";
+    },
+    getOperation() {
+      return "insert";
+    },
+    getSummary() {
+      return "Successfully created Opportunities";
+    },
+  },
+};

components/salesforce_rest_api/actions/update-accounts-batch/update-accounts-batch.mjs

@@ -0,0 +1,21 @@
+import common from "../common/batch-operation.mjs";
+
+export default {
+  ...common,
+  key: "salesforce_rest_api-update-accounts-batch",
+  name: "Update Accounts (Batch)",
+  description: "Update multiple Accounts in Salesforce using Bulk API 2.0. [See the documentation](https://developer.salesforce.com/docs/atlas.en-us.api_asynch.meta/api_asynch/datafiles_understanding_bulk2_ingest.htm)",
+  version: "0.0.1",
+  type: "action",
+  methods: {
+    getObject() {
+      return "Account";
+    },
+    getOperation() {
+      return "update";
+    },
+    getSummary() {
+      return "Successfully updated Accounts";
+    },
+  },
+};

components/salesforce_rest_api/actions/update-opportunities-batch/update-opportunities-batch.mjs

@@ -0,0 +1,21 @@
+import common from "../common/batch-operation.mjs";
+
+export default {
+  ...common,
+  key: "salesforce_rest_api-update-opportunities-batch",
+  name: "Update Opportunities (Batch)",
+  description: "Update multiple Opportunities in Salesforce using Bulk API 2.0. [See the documentation](https://developer.salesforce.com/docs/atlas.en-us.api_asynch.meta/api_asynch/datafiles_understanding_bulk2_ingest.htm)",
+  version: "0.0.1",
+  type: "action",
+  methods: {
+    getObject() {
+      return "Opportunity";
+    },
+    getOperation() {
+      return "update";
+    },
+    getSummary() {
+      return "Successfully updated Opportunities";
+    },
+  },
+};

components/salesforce_rest_api/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/salesforce_rest_api",
-  "version": "1.7.0",
+  "version": "1.8.0",
   "description": "Pipedream Salesforce (REST API) Components",
   "main": "salesforce_rest_api.app.mjs",
   "keywords": [

components/salesforce_rest_api/salesforce_rest_api.app.mjs

@@ -366,5 +366,48 @@ export default {
         ...args,
       });
     },
+    createBulkJob(args = {}) {
+      return this._makeRequest({
+        ...args,
+        method: "POST",
+        url: `${this._baseApiVersionUrl()}/jobs/ingest`,
+        data: {
+          contentType: "CSV",
+          columnDelimiter: "COMMA",
+          lineEnding: "LF",
+          ...args?.data,
+        },
+      });
+    },
+    uploadBulkJobData({
+      jobId, ...args
+    } = {}) {
+      return this._makeRequest({
+        ...args,
+        method: "PUT",
+        url: `${this._baseApiVersionUrl()}/jobs/ingest/${jobId}/batches`,
+        headers: {
+          ...this._makeRequestHeaders(),
+          "Content-Type": "text/csv",
+        },
+      });
+    },
+    patchBulkJob({
+      jobId, ...args
+    } = {}) {
+      return this._makeRequest({
+        ...args,
+        method: "PATCH",
+        url: `${this._baseApiVersionUrl()}/jobs/ingest/${jobId}`,
+      });
+    },
+    getBulkJobInfo({
+      jobId, ...args
+    } = {}) {
+      return this._makeRequest({
+        ...args,
+        url: `${this._baseApiVersionUrl()}/jobs/ingest/${jobId}`,
+      });
+    },
   },
 };