Skip to content
Open
Show file tree
Hide file tree
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 4 additions & 4 deletions components/gong/package.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@pipedream/gong",
"version": "0.3.1",
"version": "0.3.2",
"description": "Pipedream Gong Components",
"main": "gong.app.mjs",
"keywords": [
Expand All @@ -9,10 +9,10 @@
],
"homepage": "https://pipedream.com/apps/gong",
"author": "Pipedream <[email protected]> (https://pipedream.com/)",
"dependencies": {
"@pipedream/platform": "^3.0.3"
},
"publishConfig": {
"access": "public"
},
"dependencies": {
"@pipedream/platform": "^3.1.0"
}
}
19 changes: 17 additions & 2 deletions components/gong/sources/common/polling.mjs
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand All @@ -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(),
Expand Down
10 changes: 5 additions & 5 deletions components/gong/sources/new-call/new-call.mjs
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand All @@ -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(),
},
};
},
Expand Down
Loading
Loading