Gong "New Call" trigger update pagination

components/babelfy/babelfy.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/bitrated/bitrated.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/crypto_apis_by_alternative/crypto_apis_by_alternative.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/embedapi/embedapi.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/financial_modeling_prep/financial_modeling_prep.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/gong/actions/add-new-call/add-new-call.mjs

@@ -8,7 +8,7 @@ export default {
   name: "Add New Call",
   description: "Add a new call. [See the documentation](https://us-66463.app.gong.io/settings/api/documentation#post-/v2/calls)",
   type: "action",
-  version: "0.0.4",
+  version: "0.0.5",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,

components/gong/actions/get-extensive-data/get-extensive-data.mjs

@@ -7,7 +7,7 @@ export default {
   key: "gong-get-extensive-data",
   name: "Get Extensive Data",
   description: "Lists detailed call data. [See the documentation](https://gong.app.gong.io/settings/api/documentation#post-/v2/calls/extensive)",
-  version: "0.0.4",
+  version: "0.0.5",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,

components/gong/actions/list-calls/list-calls.mjs

@@ -5,7 +5,7 @@ export default {
   name: "List calls",
   description: "List calls. [See the documentation](https://us-66463.app.gong.io/settings/api/documentation#get-/v2/calls)",
   type: "action",
-  version: "0.0.5",
+  version: "0.0.6",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,

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.5",
+  version: "0.0.6",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,

components/gong/gong.app.mjs

@@ -152,16 +152,25 @@ export default {
     }) {
       let cursor;
       let resourcesCount = 0;
+      let response;
 
       while (true) {
-        const response =
+        try {
+          response =
           await resourceFn({
             ...resourceFnArgs,
             params: {
               ...resourceFnArgs?.params,
               cursor,
             },
           });
+        } catch (error) {
+          if (error.response.status === 404) {
+            console.log("No more resources");
+            return;
+          }
+          throw error;
+        }
 
         const nextResources = resourceName && response[resourceName] || response;
 

components/gong/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/gong",
-  "version": "0.3.1",
+  "version": "0.3.2",
   "description": "Pipedream Gong Components",
   "main": "gong.app.mjs",
   "keywords": [
@@ -9,10 +9,10 @@
   ],
   "homepage": "https://pipedream.com/apps/gong",
   "author": "Pipedream <[email protected]> (https://pipedream.com/)",
-  "dependencies": {
-    "@pipedream/platform": "^3.1.1"
-  },
   "publishConfig": {
     "access": "public"
+  },
+  "dependencies": {
+    "@pipedream/platform": "^3.1.1"
   }
 }

components/gong/sources/common/polling.mjs

@@ -39,8 +39,12 @@ export default {
       const meta = this.generateMeta(resource);
       this.$emit(resource, meta);
     },
-    async processResources(resources) {
-      const descendingResources = Array.from(resources).reverse();
+    async processResources(resources, max) {
+      let descendingResources = Array.from(resources).reverse();
+
+      if (max) {
+        descendingResources = descendingResources.slice(0, max);
+      }
 
       const [
         lastResource,
@@ -53,6 +57,17 @@ export default {
       descendingResources.forEach(this.processEvent);
     },
   },
+  hooks: {
+    async deploy() {
+      const resources = await this.app.paginate({
+        resourceFn: this.getResourceFn(),
+        resourceFnArgs: this.getResourceFnArgs(),
+        resourceName: this.getResourceName(),
+      });
+
+      this.processResources(resources, 25);
+    },
+  },
   async run() {
     const resources = await this.app.paginate({
       resourceFn: this.getResourceFn(),

components/gong/sources/new-call/new-call.mjs

@@ -4,9 +4,9 @@ export default {
   ...common,
   key: "gong-new-call",
   name: "New Call",
-  description: "Triggers when a new call is added. [See the documentation](https://us-66463.app.gong.io/settings/api/documentation#get-/v2/calls)",
+  description: "Emit new event when a new call is added. [See the documentation](https://us-66463.app.gong.io/settings/api/documentation#get-/v2/calls)",
   type: "source",
-  version: "0.0.3",
+  version: "0.0.4",
   dedupe: "unique",
   methods: {
     ...common.methods,
@@ -17,11 +17,11 @@ export default {
       return this.app.listCalls;
     },
     getResourceFnArgs() {
-      const threeMonthsAgo = new Date();
-      threeMonthsAgo.setMonth(threeMonthsAgo.getMonth() - 3);
+      const oneDayAgo = new Date();
+      oneDayAgo.setDate(oneDayAgo.getDate() - 1);
       return {
         params: {
-          fromDateTime: this.getLastCreatedAt() || threeMonthsAgo.toISOString(),
+          fromDateTime: this.getLastCreatedAt() || oneDayAgo.toISOString(),
         },
       };
     },

components/ideta/ideta.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/intelitruth/intelitruth.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/jooble/jooble.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/live_score_api/live_score_api.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/loginradius/loginradius.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/mallabe/mallabe.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/marcom_robot/marcom_robot.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/meetgeek/meetgeek.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/microsoft_azure_monitor/microsoft_azure_monitor.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/mymemory/mymemory.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/nele_ai/nele_ai.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/octave/octave.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/olostep/olostep.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/opencti/opencti.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/orq_ai/orq_ai.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/progress_agentic_rag/progress_agentic_rag.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/stock_news_api/stock_news_api.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/stocknewsapi/stocknewsapi.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/webspellchecker/webspellchecker.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/yext_sandbox/yext_sandbox.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};