feat(pipedrive): add new deals trigger

packages/backend/src/apps/pipedrive/auth/refresh-token.ts

@@ -24,6 +24,7 @@ const refreshToken = async ($: IGlobalVariable) => {
 
   await $.auth.set({
     accessToken: response.data.access_token,
+    refreshToken: response.data.refresh_token,
     tokenType: response.data.token_type,
     expiresIn: response.data.expires_in,
   });

packages/backend/src/apps/pipedrive/index.ts

@@ -1,6 +1,7 @@
 import defineApp from '../../helpers/define-app';
 import addAuthHeader from './common/add-auth-header';
 import auth from './auth';
+import triggers from './triggers';
 
 export default defineApp({
   name: 'Pipedrive',
@@ -13,4 +14,5 @@ export default defineApp({
   supportsConnections: true,
   beforeRequest: [addAuthHeader],
   auth,
+  triggers,
 });

packages/backend/src/apps/pipedrive/triggers/index.ts

@@ -0,0 +1,3 @@
+import newDeals from './new-deals';
+
+export default [newDeals];

packages/backend/src/apps/pipedrive/triggers/new-deals/index.ts

@@ -0,0 +1,56 @@
+import defineTrigger from '../../../../helpers/define-trigger';
+
+type Payload = {
+  start: number;
+  limit: number;
+  sort: string;
+};
+
+type ResponseData = {
+  data: {
+    id: number;
+  }[];
+  additional_data: {
+    pagination: {
+      next_start: number;
+    };
+  };
+};
+
+export default defineTrigger({
+  name: 'New deals',
+  key: 'newDeals',
+  pollInterval: 15,
+  description: 'Triggers when a new deal is created.',
+  arguments: [],
+
+  async run($) {
+    const params: Payload = {
+      start: 0,
+      limit: 100,
+      sort: 'add_time DESC',
+    };
+
+    do {
+      const { data } = await $.http.get<ResponseData>(
+        `${$.auth.data.apiDomain}/api/v1/deals`,
+        { params }
+      );
+
+      if (!data.data.length) {
+        return;
+      }
+
+      params.start = data.additional_data?.pagination?.next_start;
+
+      for (const deal of data.data) {
+        $.pushTriggerItem({
+          raw: deal,
+          meta: {
+            internalId: deal.id.toString(),
+          },
+        });
+      }
+    } while (params.start);
+  },
+});