Update components that use $.context and/or $.flow for use with Connect

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 @@
   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,
@@ -13,7 +13,7 @@
       label: "Full Name",
       description: "The fullname of the person for which to find the email",
     },
     alert: {
       type: "alert",
       alertType: "info",
       content: "Each search needs at least the Company Domain or the Company Name to be given. The Company Domain will usually offer the best results, you can provide both if you want to optimize the results.",
@@ -51,16 +51,21 @@
     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": [

components/fireflies/actions/upload-audio/upload-audio.mjs

@@ -5,7 +5,7 @@ export default {
   key: "fireflies-upload-audio",
   name: "Upload Audio",
   description: "Creates and stores a new meeting in Fireflies, allowing it to be transcribed and shared. [See the documentation](https://docs.fireflies.ai/graphql-api/mutation/upload-audio)",
-  version: "0.0.2",
+  version: "0.0.3",
   type: "action",
   props: {
     fireflies,
@@ -28,16 +28,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.fireflies.query({

components/fireflies/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/fireflies",
-  "version": "0.1.1",
+  "version": "0.1.2",
   "description": "Pipedream Fireflies Components",
   "main": "fireflies.app.mjs",
   "keywords": [

components/helper_functions/actions/retrieve-all-rss-stories/retrieve-all-rss-stories.mjs

@@ -6,12 +6,13 @@ export default {
   key: "helper_functions-retrieve-all-rss-stories",
   name: "Retrieve all RSS Stories",
   description: "Retrieve all stories from one or more RSS feeds.",
-  version: "0.1.1",
+  version: "0.1.2",
   type: "action",
   props: {
     helper_functions,
     rss_feeds: {
-      type: "any",
+      type: "string[]",
+      label: "RSS Feeds",
       description: "The URL(s) of the RSS Feeds",
     },
   },
@@ -20,7 +21,7 @@ export default {
 
     let stories = [];
 
-    for (url of this.rss_feeds) {
+    for (const url of this.rss_feeds) {
       let feed = await parser.parseURL(url);
       console.log(feed.title);
 
@@ -31,7 +32,11 @@ export default {
     }
 
     if (!stories.length) {
-      $.flow.exit("No new stories");
+      if ($.flow) {
+        $.flow.exit("No new stories");
+      } else {
+        console.log("No new stories");
+      }
     }
 
     return stories;

components/helper_functions/actions/retrieve-new-rss-stories/retrieve-new-rss-stories.mjs

@@ -1,29 +1,31 @@
 // legacy_hash_id: a_k6iY38
 import Parser from "rss-parser";
-import get from "lodash.get";
 import helper_functions from "../../helper_functions.app.mjs";
 
 export default {
   key: "helper_functions-retrieve-new-rss-stories",
   name: "Retrieve New RSS Stories",
   description: "Gets new stories from a specified RSS feed that have not already been processed.",
-  version: "0.2.1",
+  version: "0.2.2",
   type: "action",
   props: {
     helper_functions,
-    db: "$.service.db",
+    dataStore: {
+      type: "data_store",
+    },
     rss_feeds: {
-      type: "any",
+      type: "string[]",
+      label: "RSS Feeds",
       description: "The URL(s) of the RSS Feeds",
     },
   },
   async run({ $ }) {
     let parser = new Parser();
 
-    const previouslyPostedStories = get(this, "$checkpoint", []);
+    const previouslyPostedStories = await this.dataStore.get("previouslyPostedStories") || [];
     let newStories = [];
 
-    for (url of this.rss_feeds) {
+    for (const url of this.rss_feeds) {
       let feed = await parser.parseURL(url);
       console.log(feed.title);
 
@@ -36,10 +38,14 @@
     }
 
     if (!newStories.length) {
-      $.flow.exit("No new stories");
+      if ($.flow) {
+        $.flow.exit("No new stories");
+      } else {
+        console.log("No new stories");
+      }
     }
 
-    this.db.set("$checkpoint", previouslyPostedStories.concat(newStories.map((s) => s.link)));
+    await this.dataStore.set("previouslyPostedStories", previouslyPostedStories.concat(newStories.map((s) => s.link)));
     return newStories;
   },
 };

components/heygen/actions/common/video-polling.mjs

@@ -6,12 +6,19 @@ export default {
     heygen,
   },
   async run({ $ }) {
-    const { run } = $.context;
+    const context = $.context;
+    const run = context
+      ? context.run
+      : {
+        runs: 1,
+      };
     if (run.runs === 1) {
       const videoId = await this.processVideo($);
-      $.flow.rerun(constants.DELAY, {
-        videoId,
-      });
+      if (context) {
+        $.flow.rerun(constants.DELAY, {
+          videoId,
+        });
+      }
     }
     else {
       const videoId = run.context.videoId;

components/heygen/actions/create-talking-photo/create-talking-photo.mjs

@@ -6,7 +6,7 @@ export default {
   key: "heygen-create-talking-photo",
   name: "Create Talking Photo",
   description: "Creates a talking photo from a provided image. [See the documentation](https://docs.heygen.com/reference/create-an-avatar-video-v2)",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "action",
   props: {
     ...common.props,