[ACTION] Salesforce Accounts/Opportunities Batch Create/UpdateDD

Author: jcortes

components/salesforce_rest_api/actions/add-contact-to-campaign/add-contact-to-campaign.mjs

@@ -5,7 +5,7 @@ export default {
   key: "salesforce_rest_api-add-contact-to-campaign",
   name: "Add Contact to Campaign",
   description: "Adds an existing contact to an existing campaign. [See the documentation](https://developer.salesforce.com/docs/atlas.en-us.228.0.object_reference.meta/object_reference/sforce_api_objects_campaignmember.htm)",
-  version: "0.1.0",
+  version: "0.1.1",
   type: "action",
   props: {
     salesforce,

components/salesforce_rest_api/actions/add-lead-to-campaign/add-lead-to-campaign.mjs

@@ -5,7 +5,7 @@ export default {
   key: "salesforce_rest_api-add-lead-to-campaign",
   name: "Add Lead to Campaign",
   description: "Adds an existing lead to an existing campaign. [See the documentation](https://developer.salesforce.com/docs/atlas.en-us.228.0.object_reference.meta/object_reference/sforce_api_objects_campaignmember.htm)",
-  version: "0.1.0",
+  version: "0.1.1",
   type: "action",
   props: {
     salesforce,

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/convert-soap-xml-to-json/convert-soap-xml-to-json.mjs

@@ -5,7 +5,7 @@ export default {
   key: "salesforce_rest_api-convert-soap-xml-to-json",
   name: "Convert SOAP XML Object to JSON",
   description: "Converts a SOAP XML Object received from Salesforce to JSON",
-  version: "0.0.6",
+  version: "0.0.7",
   type: "action",
   props: {
     salesforce_rest_api,

components/salesforce_rest_api/actions/create-account/create-account.mjs

@@ -8,7 +8,7 @@ export default {
   key: "salesforce_rest_api-create-account",
   name: "Create Account",
   description: `Creates a Salesforce account. [See the documentation](${docsLink})`,
-  version: "0.3.1",
+  version: "0.3.2",
   type: "action",
   methods: {
     ...common.methods,

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-attachment/create-attachment.mjs

@@ -18,7 +18,7 @@ export default {
   key: "salesforce_rest_api-create-attachment",
   name: "Create Attachment",
   description: `Creates an Attachment on a parent object. [See the documentation](${docsLink})`,
-  version: "0.5.1",
+  version: "0.5.2",
   type: "action",
   props,
   async run({ $ }) {

components/salesforce_rest_api/actions/create-campaign/create-campaign.mjs

@@ -8,7 +8,7 @@ export default {
   key: "salesforce_rest_api-create-campaign",
   name: "Create Campaign",
   description: `Creates a marketing campaign. [See the documentation](${docsLink})`,
-  version: "0.3.1",
+  version: "0.3.2",
   type: "action",
   methods: {
     ...common.methods,

components/salesforce_rest_api/actions/create-case/create-case.mjs

@@ -8,7 +8,7 @@ export default {
   key: "salesforce_rest_api-create-case",
   name: "Create Case",
   description: `Creates a Case, which represents a customer issue or problem. [See the documentation](${docsLink})`,
-  version: "0.3.1",
+  version: "0.3.2",
   type: "action",
   methods: {
     ...common.methods,

components/salesforce_rest_api/actions/create-casecomment/create-casecomment.mjs

@@ -17,7 +17,7 @@ export default {
   key: "salesforce_rest_api-create-casecomment",
   name: "Create Case Comment",
   description: `Creates a Case Comment on a selected Case. [See the documentation](${docsLink})`,
-  version: "0.3.1",
+  version: "0.3.2",
   type: "action",
   props,
   async run({ $ }) {