[ACTION] Lusha: Prospecting APIs #14992

Actions
 - Contact Search
 - Company Search
 - Contact Enrich
 - Company Enrich

Author: luancazarine

components/lusha/actions/company-enrich/company-enrich.mjs

@@ -1,33 +1,37 @@
 import lusha from "../../lusha.app.mjs";
-import { axios } from "@pipedream/platform";
 
 export default {
   key: "lusha-company-enrich",
   name: "Enrich Companies",
-  description: "Enriches company information based on provided company IDs. [See the documentation]()",
-  version: "0.0.{{ts}}",
+  description: "Enriches company information based on provided company IDs. [See the documentation](https://www.lusha.com/docs/#company-enrich)",
+  version: "0.0.1",
   type: "action",
   props: {
     lusha,
-    enrichCompanyRequestId: {
+    requestId: {
       propDefinition: [
         lusha,
-        "enrichCompanyRequestId",
+        "requestId",
       ],
+      label: "Company Request ID",
+      description: "The request ID generated from the company search response.",
     },
-    enrichCompanyIds: {
+    companiesIds: {
       propDefinition: [
         lusha,
-        "enrichCompanyIds",
+        "companiesIds",
       ],
     },
   },
   async run({ $ }) {
     const response = await this.lusha.enrichCompanies({
-      enrichCompanyRequestId: this.enrichCompanyRequestId,
-      enrichCompanyIds: this.enrichCompanyIds,
+      $,
+      params: {
+        requestId: this.requestId,
+        companiesIds: this.companiesIds,
+      },
     });
-    $.export("$summary", `Successfully enriched ${this.enrichCompanyIds.length} companies`);
+    $.export("$summary", `Successfully enriched ${this.companiesIds.length} companies`);
     return response;
   },
 };

components/lusha/actions/company-search/company-search.mjs

@@ -1,72 +1,102 @@
+import { parseObject } from "../../common/utils.mjs";
 import lusha from "../../lusha.app.mjs";
-import { axios } from "@pipedream/platform";
 
 export default {
   key: "lusha-company-search",
   name: "Search Companies",
-  description: "Search for companies using various filters. [See the documentation](https://www.lusha.com/docs/)",
-  version: "0.0.{{ts}}",
+  description: "Search for companies using various filters. [See the documentation](https://www.lusha.com/docs/#contactcompany-search)",
+  version: "0.0.1",
   type: "action",
   props: {
     lusha,
-    searchCompanyNames: {
+    names: {
       propDefinition: [
         lusha,
-        "searchCompanyNames",
+        "companyNames",
       ],
+      optional: true,
     },
-    searchCompanyDomains: {
+    domains: {
       propDefinition: [
         lusha,
-        "searchCompanyDomains",
+        "domains",
       ],
+      optional: true,
     },
-    searchCompanyLocations: {
+    locations: {
       propDefinition: [
         lusha,
-        "searchCompanyLocations",
+        "locations",
       ],
+      optional: true,
     },
-    searchCompanySizes: {
+    sizes: {
       propDefinition: [
         lusha,
-        "searchCompanySizes",
+        "sizes",
       ],
+      optional: true,
     },
-    searchCompanyRevenues: {
+    revenues: {
       propDefinition: [
         lusha,
-        "searchCompanyRevenues",
+        "revenues",
       ],
+      optional: true,
     },
-    searchCompanySicCodes: {
+    sicCodes: {
       propDefinition: [
         lusha,
-        "searchCompanySicCodes",
+        "sicCodes",
       ],
+      optional: true,
     },
-    searchCompanyNaicsCodes: {
+    naicsCodes: {
       propDefinition: [
         lusha,
-        "searchCompanyNaicsCodes",
+        "naicsCodes",
       ],
+      optional: true,
+    },
+    limit: {
+      type: "string",
+      label: "Limit",
+      description: "The maximum number of results to return. **This feature is used to avoid timeouts due to very long returns.**",
     },
   },
   async run({ $ }) {
     try {
-      const response = await this.lusha.searchCompanies({
-        searchCompanyNames: this.searchCompanyNames,
-        searchCompanyDomains: this.searchCompanyDomains,
-        searchCompanyLocations: this.searchCompanyLocations,
-        searchCompanySizes: this.searchCompanySizes,
-        searchCompanyRevenues: this.searchCompanyRevenues,
-        searchCompanySicCodes: this.searchCompanySicCodes,
-        searchCompanyNaicsCodes: this.searchCompanyNaicsCodes,
+      const include = {};
+
+      if (this.names) include.names = parseObject(this.names);
+      if (this.domains) include.domains = parseObject(this.domains);
+      if (this.locations) include.locations = parseObject(this.locations);
+      if (this.sizes) include.sizes = parseObject(this.sizes);
+      if (this.revenues) include.revenues = parseObject(this.revenues);
+      if (this.sicCodes) include.sicCodes = parseObject(this.sicCodes);
+      if (this.naicsCodes) include.naicsCodes = parseObject(this.naicsCodes);
+
+      const response = this.lusha.paginate({
+        $,
+        maxResults: this.limit,
+        fn: this.lusha.searchCompanies,
+        data: {
+          filters: {
+            companies: {
+              include,
+            },
+          },
+        },
       });
 
-      const totalResults = response.totalResults;
-      $.export("$summary", `Successfully retrieved ${totalResults} companies`);
-      return response;
+      const responseArray = [];
+
+      for await (const item of response) {
+        responseArray.push(item);
+      }
+
+      $.export("$summary", `Successfully retrieved ${responseArray.length} companies`);
+      return responseArray;
     } catch (error) {
       $.export("$summary", "Failed to search companies");
       throw error;

components/lusha/actions/contact-enrich/contact-enrich.mjs

@@ -3,33 +3,35 @@ import lusha from "../../lusha.app.mjs";
 export default {
   key: "lusha-contact-enrich",
   name: "Enrich Contacts",
-  description: "Enriches contacts based on provided IDs. [See the documentation](https://www.lusha.com/docs/)",
-  version: "0.0.{{ts}}",
+  description: "Enriches contacts based on provided IDs. [See the documentation](https://www.lusha.com/docs/#contact-enrich)",
+  version: "0.0.1",
   type: "action",
   props: {
-    lusha: {
-      type: "app",
-      app: "lusha",
-    },
-    enrichContactRequestId: {
+    lusha,
+    requestId: {
       propDefinition: [
-        "lusha",
-        "enrichContactRequestId",
+        lusha,
+        "requestId",
       ],
+      label: "Company Request ID",
+      description: "The request ID generated from the company search response.",
     },
-    enrichContactIds: {
+    contactIds: {
       propDefinition: [
-        "lusha",
-        "enrichContactIds",
+        lusha,
+        "contactIds",
       ],
     },
   },
   async run({ $ }) {
     const response = await this.lusha.enrichContacts({
-      enrichContactRequestId: this.enrichContactRequestId,
-      enrichContactIds: this.enrichContactIds,
+      $,
+      params: {
+        requestId: this.requestId,
+        contactIds: this.contactIds,
+      },
     });
-    $.export("$summary", `Successfully enriched ${this.enrichContactIds.length} contacts`);
+    $.export("$summary", `Successfully enriched ${this.contactIds.length} contacts`);
     return response;
   },
 };

components/lusha/actions/contact-search/contact-search.mjs

@@ -1,107 +1,98 @@
+import { parseObject } from "../../common/utils.mjs";
 import lusha from "../../lusha.app.mjs";
-import { axios } from "@pipedream/platform";
 
 export default {
   key: "lusha-contact-search",
   name: "Search Contacts",
-  description: "Search for contacts using various filters. [See the documentation](https://www.lusha.com/docs/)",
-  version: "0.0.{{ts}}",
+  description: "Search for contacts using various filters. [See the documentation](https://www.lusha.com/docs/#contactcompany-search)",
+  version: "0.0.1",
   type: "action",
   props: {
     lusha,
-    searchContactNames: {
+    names: {
       propDefinition: [
         lusha,
-        "searchContactNames",
+        "contactNames",
       ],
+      label: "Contact Names",
+      description: "Names of contacts to search.",
     },
-    searchContactJobTitles: {
+    jobTitles: {
       propDefinition: [
         lusha,
-        "searchContactJobTitles",
+        "jobTitles",
       ],
     },
-    searchContactJobTitlesExactMatch: {
+    jobTitlesExactMatch: {
       propDefinition: [
         lusha,
-        "searchContactJobTitlesExactMatch",
+        "jobTitlesExactMatch",
       ],
     },
-    searchContactCountries: {
+    countries: {
       propDefinition: [
         lusha,
-        "searchContactCountries",
+        "countries",
       ],
     },
-    searchContactSeniority: {
+    seniority: {
       propDefinition: [
         lusha,
-        "searchContactSeniority",
+        "seniority",
       ],
     },
-    searchContactDepartments: {
+    departments: {
       propDefinition: [
         lusha,
-        "searchContactDepartments",
+        "departments",
       ],
     },
-    searchContactExistingDataPoints: {
+    existingDataPoints: {
       propDefinition: [
         lusha,
-        "searchContactExistingDataPoints",
+        "existingDataPoints",
       ],
     },
-    searchContactLocation: {
+    location: {
       propDefinition: [
         lusha,
-        "searchContactLocation",
+        "location",
       ],
     },
   },
   async run({ $ }) {
-    const args = {};
+    const include = {};
 
-    if (this.searchContactNames && this.searchContactNames.length > 0) {
-      args.searchContactNames = this.searchContactNames;
-    }
-
-    if (this.searchContactJobTitles && this.searchContactJobTitles.length > 0) {
-      args.searchContactJobTitles = this.searchContactJobTitles;
-    }
-
-    if (
-      this.searchContactJobTitlesExactMatch &&
-      this.searchContactJobTitlesExactMatch.length > 0
-    ) {
-      args.searchContactJobTitlesExactMatch = this.searchContactJobTitlesExactMatch;
-    }
-
-    if (this.searchContactCountries && this.searchContactCountries.length > 0) {
-      args.searchContactCountries = this.searchContactCountries;
-    }
-
-    if (this.searchContactSeniority && this.searchContactSeniority.length > 0) {
-      args.searchContactSeniority = this.searchContactSeniority;
-    }
+    if (this.names) include.names = parseObject(this.names);
+    if (this.jobTitles) include.jobTitles = parseObject(this.jobTitles);
+    if (this.jobTitlesExactMatch)
+      include.jobTitlesExactMatch = parseObject(this.jobTitlesExactMatch);
+    if (this.countries) include.countries = parseObject(this.countries);
+    if (this.seniority) include.seniority = parseObject(this.seniority);
+    if (this.departments) include.departments = parseObject(this.departments);
+    if (this.existingDataPoints) include.existingDataPoints = parseObject(this.existingDataPoints);
+    if (this.location) include.location = parseObject(this.location);
 
-    if (this.searchContactDepartments && this.searchContactDepartments.length > 0) {
-      args.searchContactDepartments = this.searchContactDepartments;
-    }
+    const response = this.lusha.paginate({
+      $,
+      maxResults: this.limit,
+      fn: this.lusha.searchContacts,
+      data: {
+        filters: {
+          contacts: {
+            include,
+          },
+        },
+      },
+    });
 
-    if (
-      this.searchContactExistingDataPoints &&
-      this.searchContactExistingDataPoints.length > 0
-    ) {
-      args.searchContactExistingDataPoints = this.searchContactExistingDataPoints;
-    }
+    const responseArray = [];
 
-    if (this.searchContactLocation && this.searchContactLocation.length > 0) {
-      args.searchContactLocation = this.searchContactLocation;
+    for await (const item of response) {
+      responseArray.push(item);
     }
 
-    const response = await this.lusha.searchContacts(args);
-
-    $.export("$summary", `Found ${response.totalResults} contacts`);
+    $.export("$summary", `Found ${responseArray.length} contacts`);
     return response;
   },
 };