Merge branch 'master' into issue-17798

Author: lcaresia

components/asana/actions/list-task-stories/list-task-stories.mjs

@@ -0,0 +1,96 @@
+import common from "../common/common.mjs";
+
+export default {
+  key: "asana-list-task-stories",
+  name: "List Task Stories",
+  description: "List stories (including comments) for a task. [See the documentation](https://developers.asana.com/reference/getstoriesfortask)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    ...common.props,
+    taskId: {
+      label: "Task GID",
+      description: "The ID of the task to retrieve stories for",
+      type: "string",
+      propDefinition: [
+        common.props.asana,
+        "tasks",
+        (c) => ({
+          project: c.project,
+        }),
+      ],
+    },
+    commentsOnly: {
+      type: "boolean",
+      label: "Comments Only",
+      description: "Only return comments",
+      optional: true,
+    },
+    optFields: {
+      type: "string[]",
+      label: "Opt Fields",
+      description: "This endpoint returns a resource which excludes some properties by default. To include those optional properties, set this query parameter to a comma-separated list of the properties you wish to include. See the [documentation](https://developers.asana.com/reference/stories) for available fields.",
+      optional: true,
+    },
+    maxResults: {
+      type: "integer",
+      label: "Max Results",
+      description: "The maximum number of results to return",
+      default: 100,
+      optional: true,
+    },
+  },
+  methods: {
+    async getStoriesForTask({
+      taskId, ...opts
+    }) {
+      return this.asana._makeRequest({
+        path: `tasks/${taskId}/stories`,
+        ...opts,
+      });
+    },
+  },
+  async run({ $ }) {
+    let hasMore, count = 0;
+
+    const params = {
+      limit: this.maxResults,
+      opt_fields: this.optFields
+        ? this.optFields?.join(",")
+        : undefined,
+    };
+
+    const results = [];
+
+    do {
+      const {
+        data, next_page: next,
+      } = await this.getStoriesForTask({
+        $,
+        taskId: this.taskId,
+        params,
+      });
+
+      hasMore = next;
+      params.offset = next?.offset;
+
+      if (data.length === 0) {
+        break;
+      }
+
+      for (const story of data) {
+        if (this.commentsOnly && story.type !== "comment") {
+          continue;
+        }
+        results.push(story);
+        if (++count >= this.maxResults) {
+          hasMore = false;
+          break;
+        }
+      }
+    } while (hasMore);
+
+    $.export("$summary", `Found ${results.length} stories`);
+    return results;
+  },
+};

components/asana/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/asana",
-  "version": "0.7.4",
+  "version": "0.8.0",
   "description": "Pipedream Asana Components",
   "main": "asana.app.mjs",
   "keywords": [

components/assemblyai/actions/create-captions/create-captions.mjs

@@ -2,9 +2,9 @@ import assemblyai from "../../assemblyai.app.mjs";
 
 export default {
   name: "Create Captions",
-  description: "Export your completed transcripts in SRT (srt) or VTT (vtt) format, which can be used for subtitles and closed captions in videos. [See the documentation](https://www.assemblyai.com/docs/API%20reference/transcript)",
+  description: "Export your completed transcripts in SRT (srt) or VTT (vtt) format, which can be used for subtitles and closed captions in videos. [See the documentation](https://www.assemblyai.com/docs/api-reference/transcripts/get-subtitles)",
   key: "assemblyai-create-captions",
-  version: "0.0.2",
+  version: "0.0.3",
   type: "action",
   props: {
     assemblyai,

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

@@ -2,95 +2,26 @@ import assemblyai from "../../assemblyai.app.mjs";
 
 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)",
+  description: "Fetches a specific transcribed result from the AssemblyAI API. [See the documentation](https://www.assemblyai.com/docs/api-reference/transcripts/get)",
   key: "assemblyai-get-transcription",
-  version: "0.0.4",
+  version: "0.1.0",
   type: "action",
   props: {
     assemblyai,
-    url: {
-      type: "string",
-      label: "URL",
-      description: "The URL of your media file to transcribe.",
-    },
-    languageCode: {
+    transcriptId: {
       propDefinition: [
         assemblyai,
-        "languageCode",
+        "transcriptId",
       ],
     },
-    punctuate: {
-      type: "boolean",
-      label: "Punctuate",
-      description: "Enable Automatic Punctuation",
-      optional: true,
-    },
-    speakerLabels: {
-      type: "boolean",
-      label: "Speaker Labels",
-      description: "Enable Speaker diarization",
-      optional: true,
-    },
-    contentSafety: {
-      type: "boolean",
-      label: "Content Safety",
-      description: "Enable Content Moderation",
-      optional: true,
-    },
-    sentimentAnalysis: {
-      type: "boolean",
-      label: "Sentiment Analysis",
-      description: "Enable Sentiment Analysis",
-      optional: true,
-    },
-    webhookUrl: {
-      type: "string",
-      label: "Webhook URL",
-      description: "The URL we should send webhooks to when your transcript is complete",
-      optional: true,
-    },
-    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). Not available in Pipedream Connect.",
-      optional: true,
-    },
   },
   async run({ $ }) {
-    let response;
-    const context = $.context;
-    const run = context
-      ? context.run
-      : {
-        runs: 1,
-      };
-    if (run.runs === 1) {
-      let webhookUrl  = this.webhookUrl;
-      if (context && this.callbackWithRerun) {
-        ({ resume_url: webhookUrl } = $.flow.rerun(600000, null, 1));
-      }
-      response = await this.assemblyai.createTranscript({
-        data: {
-          audio_url: this.url,
-          language_code: this.languageCode,
-          punctuate: this.punctuate,
-          speaker_labels: this.speakerLabels,
-          content_safety: this.contentSafety,
-          sentiment_analysis: this.sentimentAnalysis,
-          webhook_url: webhookUrl,
-        },
-        $,
-      });
-    }
-    if (run.callback_request) {
-      response = await this.assemblyai.getTranscript({
-        transcriptId: run.callback_request.body.transcript_id,
-      });
-    }
+    const response = await this.assemblyai.getTranscript({
+      transcriptId: this.transcriptId,
+      $,
+    });
 
-    if (response?.id) {
-      $.export("$summary", `Successfully created transcription with ID ${response.id}.`);
-    }
+    $.export("$summary", `Successfully retrieved transcription for transcript with ID ${this.transcriptId}.`);
 
     return response;
   },

components/assemblyai/actions/transcribe-audio/transcribe-audio.mjs

@@ -0,0 +1,97 @@
+import assemblyai from "../../assemblyai.app.mjs";
+
+export default {
+  name: "Transcribe Audio",
+  description: "Create a transcript from a media file that is accessible via a URL. [See the documentation](https://www.assemblyai.com/docs/api-reference/transcripts/submit)",
+  key: "assemblyai-transcribe-audio",
+  version: "0.1.0",
+  type: "action",
+  props: {
+    assemblyai,
+    url: {
+      type: "string",
+      label: "URL",
+      description: "The URL of your media file to transcribe.",
+    },
+    languageCode: {
+      propDefinition: [
+        assemblyai,
+        "languageCode",
+      ],
+    },
+    punctuate: {
+      type: "boolean",
+      label: "Punctuate",
+      description: "Enable Automatic Punctuation",
+      optional: true,
+    },
+    speakerLabels: {
+      type: "boolean",
+      label: "Speaker Labels",
+      description: "Enable Speaker diarization",
+      optional: true,
+    },
+    contentSafety: {
+      type: "boolean",
+      label: "Content Safety",
+      description: "Enable Content Moderation",
+      optional: true,
+    },
+    sentimentAnalysis: {
+      type: "boolean",
+      label: "Sentiment Analysis",
+      description: "Enable Sentiment Analysis",
+      optional: true,
+    },
+    webhookUrl: {
+      type: "string",
+      label: "Webhook URL",
+      description: "The URL we should send webhooks to when your transcript is complete",
+      optional: true,
+    },
+    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). Not available in Pipedream Connect.",
+      optional: true,
+    },
+  },
+  async run({ $ }) {
+    let response;
+    const context = $.context;
+    const run = context
+      ? context.run
+      : {
+        runs: 1,
+      };
+    if (run.runs === 1) {
+      let webhookUrl  = this.webhookUrl;
+      if (context && this.callbackWithRerun) {
+        ({ resume_url: webhookUrl } = $.flow.rerun(600000, null, 1));
+      }
+      response = await this.assemblyai.createTranscript({
+        data: {
+          audio_url: this.url,
+          language_code: this.languageCode,
+          punctuate: this.punctuate,
+          speaker_labels: this.speakerLabels,
+          content_safety: this.contentSafety,
+          sentiment_analysis: this.sentimentAnalysis,
+          webhook_url: webhookUrl,
+        },
+        $,
+      });
+    }
+    if (run.callback_request) {
+      response = await this.assemblyai.getTranscript({
+        transcriptId: run.callback_request.body.transcript_id,
+      });
+    }
+
+    if (response?.id) {
+      $.export("$summary", `Successfully created transcription with ID ${response.id}.`);
+    }
+
+    return response;
+  },
+};

components/assemblyai/package.json

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

components/assemblyai/sources/new-transcription-completed/new-transcription-completed.mjs

@@ -3,9 +3,9 @@ import { DEFAULT_POLLING_SOURCE_TIMER_INTERVAL } from "@pipedream/platform";
 
 export default {
   name: "New Transcription Completed",
-  description: "Emit new event when a transcribed audio file from AssemblyAI is ready. [See the documentation](https://www.assemblyai.com/docs/API%20reference/transcript)",
+  description: "Emit new event when a transcribed audio file from AssemblyAI is ready. [See the documentation](https://www.assemblyai.com/docs/api-reference/transcripts/list)",
   key: "assemblyai-new-transcription-completed",
-  version: "0.0.2",
+  version: "0.1.0",
   type: "source",
   dedupe: "unique",
   props: {
@@ -30,7 +30,7 @@ export default {
         return;
       }
       this._setLastId(transcripts[0].id);
-      transcripts.reverse().forEach((transcript) => this.emitEvent(transcript));
+      await this.emitTranscripts(transcripts);
     },
   },
   methods: {
@@ -44,6 +44,14 @@ export default {
       const meta = this.generateMeta(transcript);
       this.$emit(transcript, meta);
     },
+    async emitTranscripts(transcripts) {
+      for (const transcript of transcripts.reverse()) {
+        const data = await this.assemblyai.getTranscript({
+          transcriptId: transcript.id,
+        });
+        this.emitEvent(data);
+      }
+    },
     generateMeta(transcript) {
       return {
         id: transcript.id,
@@ -63,7 +71,9 @@ export default {
     if (!transcripts.length) {
       return;
     }
-    transcripts.forEach((transcript) => this.emitEvent(transcript));
+
     this._setLastId(transcripts[0].id);
+
+    await this.emitTranscripts(transcripts);
   },
 };

components/attio/actions/create-note/create-note.mjs

@@ -4,7 +4,7 @@ export default {
   key: "attio-create-note",
   name: "Create Note",
   description: "Creates a new note for a given record. The note will be linked to the specified record. [See the documentation](https://developers.attio.com/reference/post_v2-notes)",
-  version: "0.0.3",
+  version: "0.0.5",
   type: "action",
   props: {
     attio,

components/attio/actions/create-person/create-person.mjs

@@ -5,7 +5,7 @@ export default {
   key: "attio-create-person",
   name: "Create Person",
   description: "Creates a new person. [See the documentation](https://developers.attio.com/reference/post_v2-objects-people-records).",
-  version: "0.0.1",
+  version: "0.0.3",
   type: "action",
   props: {
     attio,