Update components that use $.context and/or $.flow for use with Connect (#17346)

* updates

* pnpm-lock.yaml

* update

* versions

* pnpm-lock.yaml

* pnpm-lock.yaml

* add app prop

* updates

* pnpm-lock.yaml

* remove debug

* version

* updates

* replace $checkpoint with dataStore

* versions

* pnpm-lock.yaml

---------

Co-authored-by: Guilherme Falcão <[email protected]>

Author: michelle0927

components/assemblyai/actions/get-transcription/get-transcription.mjs

@@ -4,7 +4,7 @@ export default {
   name: "Get Transcription",
   description: "Fetches a specific transcribed result from the AssemblyAI API. [See the documentation](https://www.assemblyai.com/docs/API%20reference/transcript)",
   key: "assemblyai-get-transcription",
-  version: "0.0.2",
+  version: "0.0.3",
   type: "action",
   props: {
     assemblyai,
@@ -52,16 +52,21 @@ export default {
     callbackWithRerun: {
       type: "boolean",
       label: "Callback With Rerun",
-      description: "Use the `$.flow.rerun` Node.js helper to rerun the step when the transcription is completed. Overrides the `webhookUrl` prop. This will increase execution time and credit usage as a result. [See the documentation(https://pipedream.com/docs/code/nodejs/rerun/#flow-rerun)",
+      description: "Use the `$.flow.rerun` Node.js helper to rerun the step when the transcription is completed. Overrides the `webhookUrl` prop. This will increase execution time and credit usage as a result. [See the documentation(https://pipedream.com/docs/code/nodejs/rerun/#flow-rerun). Not available in Pipedream Connect.",
       optional: true,
     },
   },
   async run({ $ }) {
     let response;
-    const { run } = $.context;
+    const context = $.context;
+    const run = context
+      ? context.run
+      : {
+        runs: 1,
+      };
     if (run.runs === 1) {
       let webhookUrl  = this.webhookUrl;
-      if (this.callbackWithRerun) {
+      if (context && this.callbackWithRerun) {
         ({ resume_url: webhookUrl } = $.flow.rerun(600000, null, 1));
       }
       response = await this.assemblyai.createTranscript({

components/assemblyai/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/assemblyai",
-  "version": "0.2.0",
+  "version": "0.2.1",
   "description": "Pipedream AssemblyAI Components",
   "main": "assemblyai.app.mjs",
   "keywords": [

components/contactout/actions/verify-email-bulk/verify-email-bulk.mjs

@@ -5,7 +5,7 @@ export default {
   key: "contactout-verify-email-bulk",
   name: "Verify Email Bulk",
   description: "Verify the deliverability for a batch of up to 1000 email addresses in bulk. [See the documentation](https://api.contactout.com/#bulk).",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "action",
   props: {
     app,
@@ -26,7 +26,7 @@ export default {
     waitForCompletion: {
       type: "boolean",
       label: "Wait for Completion",
-      description: "If set to `true`, the action will wait and poll until the bulk verification job is `DONE`. If set to `false`, it will return immediately after creating the job.",
+      description: "If set to `true`, the action will wait and poll until the bulk verification job is `DONE`. If set to `false`, it will return immediately after creating the job. Not available in Pipedream Connect.",
       default: false,
       optional: true,
     },
@@ -41,7 +41,12 @@ export default {
 
     const MAX_RETRIES = 15;
     const DELAY = 1000 * 15; // 15 seconds
-    const { run } = $.context;
+    const context = $.context;
+    const run = context
+      ? context.run
+      : {
+        runs: 1,
+      };
 
     // First run: Create the bulk verification job
     if (run.runs === 1) {
@@ -56,7 +61,7 @@ export default {
       $.export("$summary", `Successfully queued bulk email verification with job ID \`${response.job_id}\`.`);
 
       // If user doesn't want to wait, return immediately
-      if (!waitForCompletion) {
+      if (!waitForCompletion || !context) {
         return response;
       }
 

components/contactout/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/contactout",
-  "version": "0.1.0",
+  "version": "0.1.1",
   "description": "Pipedream ContactOut Components",
   "main": "contactout.app.mjs",
   "keywords": [

components/ecwid/actions/update-order-status/update-order-status.mjs

@@ -2,7 +2,7 @@ import { FULFILMENT_STATUS_LIST } from "../../commons/commons.mjs";
 import ecwid from "../../ecwid.app.mjs";
 export default {
   name: "Ecwid Update Order Status",
-  version: "0.0.5",
+  version: "0.0.6",
   key: "ecwid-update-order-status",
   description: "Update the Status of an Ecwid Order. Makes use of the [Update Order API](https://api-docs.ecwid.com/reference/update-order).",
   props: {
@@ -44,7 +44,11 @@ export default {
         console.error("Error Updating Order Status of " + this.orderId + " to " + this.fulfilmentStatus);
         update = "ERROR";
         $.export("$summary", "Error Updating Order Status of " + this.orderId + " to " + this.fulfilmentStatus);
-        return $.flow.exit("Error Updating Order Status of " + this.orderId + " to " + this.fulfilmentStatus);
+        if ($.flow) {
+          return $.flow.exit("Error Updating Order Status of " + this.orderId + " to " + this.fulfilmentStatus);
+        } else {
+          throw new Error("Error Updating Order Status of " + this.orderId + " to " + this.fulfilmentStatus);
+        }
       }
     } else {
       $.export("$summary", "No updates done to order " + this.orderId);

components/ecwid/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/ecwid",
-  "version": "0.0.11",
+  "version": "0.0.12",
   "description": "Pipedream Ecwid Components",
   "main": "ecwid.app.mjs",
   "keywords": [

components/enrow/actions/find-single-email/find-single-email.mjs

@@ -4,7 +4,7 @@ export default {
   key: "enrow-find-single-email",
   name: "Find Single Email",
   description: "Executes a single email search using Enrow email finder. [See the documentation](https://enrow.readme.io/reference/find-single-email)",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "action",
   props: {
     enrow,
@@ -51,16 +51,21 @@ export default {
     callbackWithRerun: {
       type: "boolean",
       label: "Callback With Rerun",
-      description: "Use the `$.flow.rerun` Node.js helper to rerun the step when the search is completed. Overrides the `webhookUrl` prop. This will increase execution time and credit usage as a result. [See the documentation(https://pipedream.com/docs/code/nodejs/rerun/#flow-rerun)",
+      description: "Use the `$.flow.rerun` Node.js helper to rerun the step when the search is completed. Overrides the `webhookUrl` prop. This will increase execution time and credit usage as a result. [See the documentation(https://pipedream.com/docs/code/nodejs/rerun/#flow-rerun). Not available in Pipedream Connect.",
       optional: true,
     },
   },
   async run({ $ }) {
     let response;
-    const { run } = $.context;
+    const context = $.context;
+    const run = context
+      ? context.run
+      : {
+        runs: 1,
+      };
     if (run.runs === 1) {
       let webhook  = this.webhookUrl;
-      if (this.callbackWithRerun) {
+      if (context && this.callbackWithRerun) {
         ({ resume_url: webhook } = $.flow.rerun(600000, null, 1));
       }
       response = await this.enrow.executeSearch({

components/enrow/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/enrow",
-  "version": "0.1.0",
+  "version": "0.1.1",
   "description": "Pipedream Enrow Components",
   "main": "enrow.app.mjs",
   "keywords": [

components/fal_ai/actions/add-request-to-queue/add-request-to-queue.mjs

@@ -4,7 +4,7 @@ export default {
   key: "fal_ai-add-request-to-queue",
   name: "Add Request to Queue",
   description: "Adds a request to the queue for asynchronous processing, including specifying a webhook URL for receiving updates. [See the documentation](https://fal.ai/docs/model-endpoints/queue#queue-endpoints).",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "action",
   props: {
     app,
@@ -38,7 +38,7 @@ export default {
         reRunTimeoutInSecs: {
           type: "integer",
           label: "Rerun Timeout",
-          description: "The time in seconds to wait before rerunning the step to retrieve the request response. Eg. `30`. [See the documentation](https://pipedream.com/docs/code/nodejs/rerun/#flowrerun).",
+          description: "The time in seconds to wait before rerunning the step to retrieve the request response. Eg. `30`. [See the documentation](https://pipedream.com/docs/code/nodejs/rerun/#flowrerun). Not for use in Pipedream Connect.",
           optional: true,
           min: 10,
         },
@@ -65,14 +65,17 @@ export default {
     },
   },
   async run({ $ }) {
+    const context = $.context;
     const {
-      context: {
-        run: {
-          runs,
-          callback_request: callbackRequest,
-        },
+      run: {
+        runs, callback_request: callbackRequest,
+      },
+    } = context || {
+      run: {
+        runs: 1,
+        callback_request: undefined,
       },
-    } = $;
+    };
 
     const {
       app,
@@ -100,7 +103,11 @@ export default {
 
     if (runs === 1) {
       const timeout = 1000 * (reRunTimeoutInSecs || 10);
-      const { resume_url: resumeUrl } = $.flow.rerun(timeout, null, 1);
+      const { resume_url: resumeUrl } = context
+        ? $.flow.rerun(timeout, null, 1)
+        : {
+          resume_url: undefined,
+        };
 
       return addToQueue({
         $,

components/fal_ai/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/fal_ai",
-  "version": "0.1.0",
+  "version": "0.1.1",
   "description": "Pipedream fal.ai Components",
   "main": "fal_ai.app.mjs",
   "keywords": [