Merge branch 'master' into issue-14689

Author: vunguyenhung

components/gong/actions/retrieve-transcripts-of-calls/retrieve-transcripts-of-calls.mjs

@@ -5,7 +5,7 @@ export default {
   name: "Retrieve Transcripts Of Calls",
   description: "Retrieve transcripts of calls. [See the documentation](https://us-66463.app.gong.io/settings/api/documentation#post-/v2/calls/transcript)",
   type: "action",
-  version: "0.0.2",
+  version: "0.0.3",
   props: {
     app,
     fromDateTime: {
@@ -35,6 +35,13 @@ export default {
         "callIds",
       ],
     },
+    returnSimplifiedTranscript: {
+      type: "boolean",
+      label: "Return Simplified Transcript",
+      description: "If true, returns a simplified version of the transcript with normalized speaker IDs and formatted timestamps",
+      optional: true,
+      default: false,
+    },
   },
   methods: {
     retrieveTranscriptsOfCalls(args = {}) {
@@ -43,21 +50,101 @@ export default {
         ...args,
       });
     },
+
+    millisToTimestamp(millis) {
+      const totalSeconds = Math.floor(millis / 1000);
+      const minutes = Math.floor(totalSeconds / 60);
+      const seconds = totalSeconds % 60;
+
+      return `[${minutes.toString().padStart(2, "0")}:${seconds.toString().padStart(2, "0")}]`;
+    },
+
+    simplifyTranscript(originalResponse) {
+      const simplified = {
+        ...originalResponse,
+        callTranscripts: originalResponse.callTranscripts.map((callTranscript) => {
+          // Create a map of unique speaker IDs to simplified names
+          const speakerMap = new Map();
+          let speakerCounter = 1;
+          let currentSpeaker = null;
+          let currentTopic = null;
+          let formattedTranscript = "";
+
+          // Process each sentence maintaining chronological order
+          const allSentences = [];
+          callTranscript.transcript.forEach((segment) => {
+            segment.sentences.forEach((sentence) => {
+              allSentences.push({
+                ...sentence,
+                speakerId: segment.speakerId,
+                topic: segment.topic,
+              });
+            });
+          });
+
+          // Sort by start time
+          allSentences.sort((a, b) => a.start - b.start);
+
+          // Process sentences
+          allSentences.forEach((sentence) => {
+            // Map speaker ID to simplified name
+            if (!speakerMap.has(sentence.speakerId)) {
+              speakerMap.set(sentence.speakerId, `Speaker ${speakerCounter}`);
+              speakerCounter++;
+            }
+
+            const speaker = speakerMap.get(sentence.speakerId);
+            const timestamp = this.millisToTimestamp(sentence.start);
+
+            // Handle topic changes
+            if (sentence.topic !== currentTopic) {
+              currentTopic = sentence.topic;
+              if (currentTopic) {
+                formattedTranscript += `\nTopic: ${currentTopic}\n-------------------\n\n`;
+              }
+            }
+
+            // Add speaker name only if it changes
+            if (speaker !== currentSpeaker) {
+              currentSpeaker = speaker;
+              formattedTranscript += `\n${speaker}:\n`;
+            }
+
+            // Add timestamp and text
+            formattedTranscript += `${timestamp} ${sentence.text}\n`;
+          });
+
+          return {
+            callId: callTranscript.callId,
+            formattedTranscript: formattedTranscript.trim(),
+          };
+        }),
+      };
+
+      return simplified;
+    },
   },
-  run({ $: step }) {
+
+  async run({ $: step }) {
     const {
-      // eslint-disable-next-line no-unused-vars
-      app,
       retrieveTranscriptsOfCalls,
+      returnSimplifiedTranscript,
+      simplifyTranscript,
       ...filter
     } = this;
 
-    return retrieveTranscriptsOfCalls({
+    const response = await retrieveTranscriptsOfCalls({
       step,
       data: {
         filter,
       },
       summary: (response) => `Successfully retrieved transcripts of calls with request ID \`${response.requestId}\`.`,
     });
+
+    if (returnSimplifiedTranscript) {
+      return simplifyTranscript(response);
+    }
+
+    return response;
   },
 };

components/gong/package.json

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

docs-v2/pages/troubleshooting.mdx

@@ -82,6 +82,12 @@ https://pipedream.com/sources/dc_abc123
 
 Your source's ID is the value that starts with `dc_`. In this example: `dc_abc123`.
 
+## Why is my trigger paused?
+
+Pipedream automatically disables sources with a 100% error rate in the past 5 days for accounts on the Free plan.
+
+To troubleshoot, you can look at the errors in the [source](/sources/) logs, and may need to reconnect your account and re-enable the source for it to run again. If the issue persists, please reach out in [the community](https://pipedream.com/support).
+
 ## Warnings
 
 Pipedream displays warnings below steps in certain conditions. These warnings do not stop the execution of your workflow, but can signal an issue you should be aware of.

packages/sdk/CHANGELOG.md

@@ -1,6 +1,14 @@
 <!-- markdownlint-disable MD024 -->
 # Changelog
 
+## [1.0.6] - 2024-11-20
+
+### Changed
+
+- Use client Connect tokens to make api calls directly from the client.
+- Deprecated the `environments` property on `createFrontendClient` since it is now
+  stored in the token
+
 ## [1.0.5] - 2024-11-18
 
 ### Changed

packages/sdk/package-lock.json

@@ -1,17 +1,27 @@
 {
   "name": "@pipedream/sdk",
-  "version": "1.0.5",
+  "version": "1.0.6",
   "description": "Pipedream SDK",
-  "main": "dist/server/index.js",
-  "module": "dist/server/index.js",
-  "types": "dist/server/index.d.ts",
-  "browser": "./dist/browser/index.js",
+  "main": "dist/server/server/index.js",
+  "module": "dist/server/server/index.js",
+  "types": "dist/server/server/index.d.ts",
+  "browser": "./dist/browser/browser/index.js",
   "exports": {
     ".": {
-      "browser": "./dist/browser/index.js",
-      "import": "./dist/server/index.js",
-      "require": "./dist/server/index.js",
-      "default": "./dist/server/index.js"
+      "browser": "./dist/browser/browser/index.js",
+      "import": "./dist/server/server/index.js",
+      "require": "./dist/server/server/index.js",
+      "default": "./dist/server/server/index.js"
+    },
+    "./server": {
+      "import": "./dist/server/server/index.js",
+      "require": "./dist/server/server/index.js",
+      "types": "./dist/server/server/index.d.ts"
+    },
+    "./browser": {
+      "import": "./dist/browser/browser/index.js",
+      "require": "./dist/browser/browser/index.js",
+      "types": "./dist/browser/browser/index.d.ts"
     }
   },
   "engines": {
@@ -25,28 +35,35 @@
     "access": "public"
   },
   "scripts": {
+    "lint": "eslint --fix --ext .ts src",
     "prepublish": "rm -rf dist && npm run build",
     "build": "npm run build:node && npm run build:browser",
     "build:node": "tsc -p tsconfig.node.json",
     "build:browser": "tsc -p tsconfig.browser.json",
     "test": "jest",
-    "watch": "nodemon --watch src --ext ts --exec 'npm run build'"
+    "watch": "nodemon --watch src --ext ts --exec 'npm run build'",
+    "cli": "node dist/server/server/cli.js"
   },
   "files": [
     "dist"
   ],
   "devDependencies": {
     "@types/fetch-mock": "^7.3.8",
     "@types/jest": "^29.5.13",
-    "@types/node": "^20.14.9",
+    "@types/node": "^20.17.6",
+    "@types/rails__actioncable": "^6.1.11",
     "@types/simple-oauth2": "^5.0.7",
+    "@types/ws": "^8.5.13",
     "jest": "^29.7.0",
     "jest-fetch-mock": "^3.0.3",
     "nodemon": "^3.1.7",
     "ts-jest": "^29.2.5",
     "typescript": "^5.5.2"
   },
   "dependencies": {
-    "simple-oauth2": "^5.1.0"
+    "@rails/actioncable": "^8.0.0",
+    "commander": "^12.1.0",
+    "simple-oauth2": "^5.1.0",
+    "ws": "^8.18.0"
   }
 }