[BUG] Apollo.io triggers are not logging anything (#15991)

jcortes · web-flow · commit 9b702901f6f0 · 2025-03-21T11:26:46.000-05:00
diff --git a/components/apollo_io/actions/add-contacts-to-sequence/add-contacts-to-sequence.mjs b/components/apollo_io/actions/add-contacts-to-sequence/add-contacts-to-sequence.mjs
@@ -5,7 +5,7 @@ export default {
   name: "Add Contacts to Sequence",
   description: "Adds one or more contacts to a sequence in Apollo.io. [See the documentation](https://apolloio.github.io/apollo-api-docs/?shell#add-contacts-to-sequence)",
   type: "action",
-  version: "0.0.4",
+  version: "0.0.5",
   props: {
     app,
     sequenceId: {
diff --git a/components/apollo_io/actions/create-account/create-account.mjs b/components/apollo_io/actions/create-account/create-account.mjs
@@ -5,7 +5,7 @@ export default {
   name: "Create Account",
   description: "Creates a new account in Apollo.io. [See the documentation](https://apolloio.github.io/apollo-api-docs/?shell#create-an-account)",
   type: "action",
-  version: "0.0.4",
+  version: "0.0.5",
   props: {
     app,
     name: {
diff --git a/components/apollo_io/actions/create-contact/create-contact.mjs b/components/apollo_io/actions/create-contact/create-contact.mjs
@@ -5,7 +5,7 @@ export default {
   name: "Create Contact",
   description: "Creates a new contact in Apollo.io. [See the documentation](https://apolloio.github.io/apollo-api-docs/?shell#create-a-contact)",
   type: "action",
-  version: "0.0.5",
+  version: "0.0.6",
   props: {
     app,
     email: {
diff --git a/components/apollo_io/actions/create-opportunity/create-opportunity.mjs b/components/apollo_io/actions/create-opportunity/create-opportunity.mjs
@@ -5,7 +5,7 @@ export default {
   name: "Create Opportunity",
   description: "Creates a new opportunity in Apollo.io. [See the documentation](https://apolloio.github.io/apollo-api-docs/?shell#create-opportunity)",
   type: "action",
-  version: "0.0.3",
+  version: "0.0.4",
   props: {
     app,
     ownerId: {
diff --git a/components/apollo_io/actions/create-update-contact/create-update-contact.mjs b/components/apollo_io/actions/create-update-contact/create-update-contact.mjs
@@ -6,7 +6,7 @@ export default {
   name: "Create Or Update Contact",
   description: "Creates or updates a specific contact. If the contact email already exists, it's updated. Otherwise, a new contact is created. [See the documentation](https://apolloio.github.io/apollo-api-docs/?shell#create-a-contact)",
   type: "action",
-  version: "0.0.2",
+  version: "0.0.3",
   props: {
     app,
     email: {
@@ -88,7 +88,7 @@ export default {
       direct_phone: this.phone,
     });
 
-    const { contacts } = await this.app.listContacts({
+    const { contacts } = await this.app.searchContacts({
       params: {
         q_keywords: this.email,
       },
diff --git a/components/apollo_io/actions/get-opportunity/get-opportunity.mjs b/components/apollo_io/actions/get-opportunity/get-opportunity.mjs
@@ -5,7 +5,7 @@ export default {
   name: "Get Opportunity",
   description: "Gets a specific opportunity in Apollo.io. [See the documentation](https://apolloio.github.io/apollo-api-docs/?shell#view-opportunity)",
   type: "action",
-  version: "0.0.3",
+  version: "0.0.4",
   props: {
     app,
     opportunityId: {
diff --git a/components/apollo_io/actions/people-enrichment/people-enrichment.mjs b/components/apollo_io/actions/people-enrichment/people-enrichment.mjs
@@ -5,7 +5,7 @@ export default {
   name: "People Enrichment",
   description: "Enriches a person's information, the more information you pass in, the more likely we can find a match. [See the documentation](https://apolloio.github.io/apollo-api-docs/?shell#people-enrichment)",
   type: "action",
-  version: "0.0.6",
+  version: "0.0.7",
   props: {
     app,
     firstName: {
diff --git a/components/apollo_io/actions/search-accounts/search-accounts.mjs b/components/apollo_io/actions/search-accounts/search-accounts.mjs
@@ -6,7 +6,7 @@ export default {
   name: "Search For Accounts",
   description: "Search for accounts in Apollo.io. [See the documentation](https://apolloio.github.io/apollo-api-docs/?shell#search-for-accounts)",
   type: "action",
-  version: "0.0.3",
+  version: "0.0.4",
   props: {
     app,
     search: {
diff --git a/components/apollo_io/actions/search-contacts/search-contacts.mjs b/components/apollo_io/actions/search-contacts/search-contacts.mjs
@@ -6,7 +6,7 @@ export default {
   name: "Search For Contacts",
   description: "Search for contacts in Apollo.io. [See the documentation](https://apolloio.github.io/apollo-api-docs/?shell#search-for-contacts)",
   type: "action",
-  version: "0.0.3",
+  version: "0.0.4",
   props: {
     app,
     search: {
diff --git a/components/apollo_io/actions/search-sequences/search-sequences.mjs b/components/apollo_io/actions/search-sequences/search-sequences.mjs
@@ -6,7 +6,7 @@ export default {
   name: "Search For Sequences",
   description: "Search for sequences in Apollo.io. [See the documentation](https://apolloio.github.io/apollo-api-docs/?shell#search-for-sequences)",
   type: "action",
-  version: "0.0.3",
+  version: "0.0.4",
   props: {
     app,
     search: {
diff --git a/components/apollo_io/actions/update-account-stage/update-account-stage.mjs b/components/apollo_io/actions/update-account-stage/update-account-stage.mjs
@@ -5,7 +5,7 @@ export default {
   name: "Update Account Stage",
   description: "Updates the stage of one or more accounts in Apollo.io. [See the documentation](https://apolloio.github.io/apollo-api-docs/?shell#update-account-stage)",
   type: "action",
-  version: "0.0.4",
+  version: "0.0.5",
   props: {
     app,
     accountIds: {
diff --git a/components/apollo_io/actions/update-account/update-account.mjs b/components/apollo_io/actions/update-account/update-account.mjs
@@ -6,7 +6,7 @@ export default {
   name: "Update Account",
   description: "Updates an existing account in Apollo.io. [See the documentation](https://apolloio.github.io/apollo-api-docs/?shell#update-an-account)",
   type: "action",
-  version: "0.0.4",
+  version: "0.0.5",
   props: {
     app,
     accountId: {
diff --git a/components/apollo_io/actions/update-contact-stage/update-contact-stage.mjs b/components/apollo_io/actions/update-contact-stage/update-contact-stage.mjs
@@ -5,7 +5,7 @@ export default {
   name: "Update Contact Stage",
   description: "Updates the stage of one or more contacts in Apollo.io. [See the documentation](https://apolloio.github.io/apollo-api-docs/?shell#update-contact-stage)",
   type: "action",
-  version: "0.0.4",
+  version: "0.0.5",
   props: {
     app,
     contactIds: {
diff --git a/components/apollo_io/actions/update-contact/update-contact.mjs b/components/apollo_io/actions/update-contact/update-contact.mjs
@@ -6,7 +6,7 @@ export default {
   name: "Update Contact",
   description: "Updates an existing contact in Apollo.io. [See the documentation](https://apolloio.github.io/apollo-api-docs/?shell#update-a-contact)",
   type: "action",
-  version: "0.0.5",
+  version: "0.0.6",
   props: {
     app,
     contactId: {
diff --git a/components/apollo_io/actions/update-opportunity/update-opportunity.mjs b/components/apollo_io/actions/update-opportunity/update-opportunity.mjs
@@ -5,7 +5,7 @@ export default {
   name: "Update Opportunity",
   description: "Updates a new opportunity in Apollo.io. [See the documentation](https://apolloio.github.io/apollo-api-docs/?shell#update-opportunity)",
   type: "action",
-  version: "0.0.3",
+  version: "0.0.4",
   props: {
     app,
     opportunityId: {
diff --git a/components/apollo_io/apollo_io.app.mjs b/components/apollo_io/apollo_io.app.mjs
@@ -1,5 +1,6 @@
 import { axios } from "@pipedream/platform";
 import constants from "./common/constants.mjs";
+import utils from "./common/utils.mjs";
 
 export default {
   type: "app",
@@ -10,7 +11,7 @@ export default {
       label: "Account ID",
       description: "Identifier of the account for this contact",
       async options({ page }) {
-        const { accounts } = await this.listAccounts({
+        const { accounts } = await this.searchAccounts({
           params: {
             page: page + 1,
           },
@@ -28,7 +29,7 @@ export default {
       label: "Contact ID",
       description: "Identifier of the contact to update",
       async options({ page }) {
-        const { contacts } = await this.listContacts({
+        const { contacts } = await this.searchContacts({
           params: {
             page: page + 1,
           },
@@ -243,15 +244,15 @@ export default {
         ...args,
       });
     },
-    listAccounts(args = {}) {
+    put(args = {}) {
       return this.makeRequest({
-        path: "/accounts/search",
+        method: "put",
         ...args,
       });
     },
-    listContacts(args = {}) {
+    patch(args = {}) {
       return this.makeRequest({
-        path: "/contacts/search",
+        method: "patch",
         ...args,
       });
     },
@@ -268,7 +269,7 @@ export default {
       });
     },
     listSequences(args = {}) {
-      return this.makeRequest({
+      return this.post({
         path: "/emailer_campaigns/search",
         ...args,
       });
@@ -298,47 +299,41 @@ export default {
       });
     },
     createContact(args = {}) {
-      return this.makeRequest({
-        method: "POST",
+      return this.post({
         path: "/contacts",
         ...args,
       });
     },
     updateContact({
       contactId, ...args
     }) {
-      return this.makeRequest({
-        method: "PUT",
+      return this.put({
         path: `/contacts/${contactId}`,
         ...args,
       });
     },
     updateContactStage(args = {}) {
-      return this.makeRequest({
-        method: "POST",
+      return this.post({
         path: "/contacts/update_stages",
         ...args,
       });
     },
     createAccount(args = {}) {
-      return this.makeRequest({
-        method: "POST",
+      return this.post({
         path: "/accounts",
         ...args,
       });
     },
     createOpportunity(args = {}) {
-      return this.makeRequest({
-        method: "POST",
+      return this.post({
         path: "/opportunities",
         ...args,
       });
     },
     updateOpportunity({
       opportunityId, ...args
     }) {
-      return this.makeRequest({
-        method: "PATCH",
+      return this.patch({
         path: `/opportunities/${opportunityId}`,
         ...args,
       });
@@ -354,36 +349,33 @@ export default {
     updateAccount({
       accountId, ...args
     }) {
-      return this.makeRequest({
-        method: "PUT",
+      return this.put({
         path: `/accounts/${accountId}`,
         ...args,
       });
     },
     updateAccountStage(args = {}) {
-      return this.makeRequest({
-        method: "POST",
+      return this.post({
         path: "/accounts/bulk_update",
         ...args,
       });
     },
     addContactsToSequence({
       sequenceId, ...args
     }) {
-      return this.makeRequest({
-        method: "POST",
+      return this.post({
         path: `/emailer_campaigns/${sequenceId}/add_contact_ids`,
         ...args,
       });
     },
     searchAccounts(args = {}) {
-      return this.makeRequest({
+      return this.post({
         path: "/accounts/search",
         ...args,
       });
     },
     searchContacts(args = {}) {
-      return this.makeRequest({
+      return this.post({
         path: "/contacts/search",
         ...args,
       });
@@ -394,7 +386,7 @@ export default {
         ...args,
       });
     },
-    async *getResourcesStream({
+    async *getIterations({
       resourceFn,
       resourceFnArgs,
       resourceName,
@@ -409,6 +401,7 @@ export default {
             ...resourceFnArgs,
             params: {
               ...resourceFnArgs.params,
+              per_page: constants.DEFAULT_LIMIT,
               page,
             },
           });
@@ -429,8 +422,16 @@ export default {
           }
         }
 
+        if (nextResources.length < constants.DEFAULT_LIMIT) {
+          console.log("No next page");
+          return;
+        }
+
         page += 1;
       }
     },
+    paginate(args = {}) {
+      return utils.iterate(this.getIterations(args));
+    },
   },
 };
diff --git a/components/apollo_io/common/constants.mjs b/components/apollo_io/common/constants.mjs
@@ -1,9 +1,11 @@
 const BASE_URL = "https://api.apollo.io";
-const VERSION_PATH = "/v1";
+const VERSION_PATH = "/api/v1";
+const DEFAULT_LIMIT = 100;
 const DEFAULT_MAX = 600;
 
 export default {
   BASE_URL,
   VERSION_PATH,
+  DEFAULT_LIMIT,
   DEFAULT_MAX,
 };
diff --git a/components/apollo_io/common/utils.mjs b/components/apollo_io/common/utils.mjs
@@ -1,9 +1,9 @@
-async function streamIterator(stream) {
-  const resources = [];
-  for await (const resource of stream) {
-    resources.push(resource);
+async function iterate(iterations) {
+  const items = [];
+  for await (const item of iterations) {
+    items.push(item);
   }
-  return resources;
+  return items;
 }
 
 function cleanObject(o) {
@@ -16,6 +16,6 @@ function cleanObject(o) {
 }
 
 export default {
-  streamIterator,
+  iterate,
   cleanObject,
 };
diff --git a/components/apollo_io/package.json b/components/apollo_io/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/apollo_io",
-  "version": "0.5.0",
+  "version": "0.5.1",
   "description": "Pipedream Apollo.io Components",
   "main": "apollo_io.app.mjs",
   "keywords": [
diff --git a/components/apollo_io/sources/account-created/account-created.mjs b/components/apollo_io/sources/account-created/account-created.mjs
@@ -3,10 +3,10 @@ import common from "../common/polling.mjs";
 export default {
   ...common,
   key: "apollo_io-account-created",
-  name: "Account Created",
-  description: "Triggers when an account is created. [See the documentation](https://apolloio.github.io/apollo-api-docs/?shell#search-for-accounts)",
+  name: "New Account Created",
+  description: "Emit new event when an account is created. [See the documentation](https://apolloio.github.io/apollo-api-docs/?shell#search-for-accounts)",
   type: "source",
-  version: "0.0.4",
+  version: "0.0.5",
   dedupe: "unique",
   props: {
     ...common.props,
@@ -27,10 +27,11 @@ export default {
       return "accounts";
     },
     getResourceFn() {
-      return this.app.listAccounts;
+      return this.app.searchAccounts;
     },
     getResourceFnArgs() {
       return {
+        debug: true,
         params: {
           account_stage_ids: this.accountStageIds,
           sort_by_field: "account_created_at",
diff --git a/components/apollo_io/sources/account-updated/account-updated.mjs b/components/apollo_io/sources/account-updated/account-updated.mjs
diff --git a/components/apollo_io/sources/common/polling.mjs b/components/apollo_io/sources/common/polling.mjs
diff --git a/components/apollo_io/sources/contact-created/contact-created.mjs b/components/apollo_io/sources/contact-created/contact-created.mjs
diff --git a/components/apollo_io/sources/contact-updated/contact-updated.mjs b/components/apollo_io/sources/contact-updated/contact-updated.mjs
diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml
