get-transcripts & updated get-call

Author: michelle0927

components/twilio/actions/get-call/get-call.mjs

@@ -5,7 +5,7 @@ export default {
   key: "twilio-get-call",
   name: "Get Call",
   description: "Return call resource of an individual call. [See the documentation](https://www.twilio.com/docs/voice/api/call-resource#fetch-a-call-resource)",
-  version: "0.1.3",
+  version: "0.1.4",
   type: "action",
   props: {
     twilio,
@@ -16,9 +16,60 @@ export default {
       ],
       optional: false,
     },
+    includeTranscripts: {
+      type: "boolean",
+      label: "Include Transcripts",
+      description: "Set to `true` to include recording transcript(s) if available",
+      optional: true,
+    },
+  },
+  methods: {
+    async getTranscripts(callSid) {
+      const transcripts = [];
+      const recordings = await this.twilio.listRecordings({
+        callSid,
+      });
+      for (const recording of recordings) {
+        const recordingTranscripts = await this.getRecordingTranscripts(recording.sid);
+        if (recordingTranscripts?.length) {
+          transcripts.push(...recordingTranscripts);
+        }
+      }
+      return transcripts;
+    },
+    async getRecordingTranscripts(sourceSid) {
+      const transcripts = await this.twilio.listTranscripts({
+        sourceSid,
+      });
+      const results = [];
+      for (const transcript of transcripts) {
+        const {
+          sentences, transcript: fullTranscript,
+        } = await this.twilio.getSentences(transcript.sid);
+        results.push({
+          ...transcript,
+          _version: undefined,
+          sentences,
+          transcript: fullTranscript,
+        });
+      }
+      return results;
+    },
   },
   async run({ $ }) {
-    const resp = await this.twilio.getCall(this.sid);
+    let resp = await this.twilio.getCall(this.sid);
+
+    if (this.includeTranscripts) {
+      const transcripts = await this.getTranscripts(this.sid);
+      if (transcripts?.length) {
+        resp = {
+          ...resp,
+          _version: undefined,
+          transcripts,
+        };
+      }
+    }
+
     $.export("$summary", `Successfully fetched the call, "${callToString(resp)}"`);
     return resp;
   },

components/twilio/actions/get-transcripts/get-transcripts.mjs

@@ -0,0 +1,40 @@
+import twilio from "../../twilio.app.mjs";
+
+export default {
+  key: "twilio-get-transcripts",
+  name: "Get Transcripts",
+  description: "Retrieves full transcripts for the specified transcript SIDs. [See the documentation](https://www.twilio.com/docs/voice/intelligence/api/transcript-sentence-resource#get-transcript-sentences)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    twilio,
+    transcriptSids: {
+      propDefinition: [
+        twilio,
+        "transcriptSids",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const transcripts = [];
+    for (const sid of this.transcriptSids) {
+      transcripts.push(await this.twilio.getTranscript(sid));
+    }
+    const results = [];
+    for (const transcript of transcripts) {
+      const {
+        sentences, transcript: fullTranscript,
+      } = await this.twilio.getSentences(transcript.sid);
+      results.push({
+        ...transcript,
+        _version: undefined,
+        sentences,
+        transcript: fullTranscript,
+      });
+    }
+    $.export("$summary", `Successfully fetched ${results.length} transcript${results.length === 1
+      ? ""
+      : "s"}`);
+    return results;
+  },
+};

components/twilio/common/utils.mjs

@@ -136,6 +136,7 @@ function recordingToString(recording) {
 }
 
 export {
+  formatTimeElapsed,
   timeBetween,
   omitEmptyStringValues,
   callToString,

components/twilio/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/twilio",
-  "version": "0.5.0",
+  "version": "0.6.0",
   "description": "Pipedream Twilio Components",
   "main": "twilio.app.mjs",
   "keywords": [

components/twilio/twilio.app.mjs

@@ -1,5 +1,6 @@
 import twilio from "twilio";
 import {
+  formatTimeElapsed,
   callToString,
   messageToString,
   recordingToString,
@@ -177,6 +178,22 @@ export default {
         })) || [];
       },
     },
+    transcriptSids: {
+      type: "string[]",
+      label: "Transcript SIDs",
+      description: "The unique SID identifiers of the Transcripts to retrieve",
+      async options({ page }) {
+        const transcripts = await this.listTranscripts({
+          page,
+        });
+        return transcripts?.map(({
+          sid: value, dateCreated, duration,
+        }) => ({
+          value,
+          label: `${dateCreated} for ${formatTimeElapsed(duration)}`,
+        })) || [];
+      },
+    },
   },
   methods: {
     validateRequest({
@@ -259,6 +276,10 @@ export default {
       const client = this.getClient();
       return client.intelligence.v2.transcripts(transcriptId).sentences.list(params);
     },
+    getTranscript(transcriptId) {
+      const client = this.getClient();
+      return client.intelligence.v2.transcripts(transcriptId).fetch();
+    },
     async getSentences(transcriptId) {
       const sentences = await this.listTranscriptSentences(transcriptId, {
         limit: 1000,
@@ -394,7 +415,6 @@ export default {
       const client = this.getClient();
       return client.recordings(sid).transcriptions.list(params);
     },
-
     /**
      * Send a verification code via sms
      *
@@ -409,7 +429,6 @@ export default {
         channel: "sms",
       });
     },
-
     /**
      * List all services
      *
@@ -419,7 +438,6 @@ export default {
       const client = this.getClient();
       return client.verify.v2.services.list();
     },
-
     /**
      * Check whether the verification token is valid
      *