Merging pull request #18664

* fetch contact will all properties

* bump versions

Author: choeqq

components/hubspot/hubspot.app.mjs

@@ -1614,5 +1614,37 @@ export default {
         ...opts,
       });
     },
+    async getContactWithAllProperties({
+      contactId, ...opts
+    }) {
+      const properties = await this.getContactProperties();
+      const allPropertyNames = properties.map((prop) => prop.name);
+
+      return this.makeRequest({
+        api: API_PATH.CRMV3,
+        endpoint: `/objects/contacts/${contactId}`,
+        params: {
+          properties: allPropertyNames.join(","),
+        },
+        ...opts,
+      });
+    },
+    async batchGetContactsWithAllProperties({
+      contactIds, ...opts
+    }) {
+      const properties = await this.getContactProperties();
+      const allPropertyNames = properties.map((prop) => prop.name);
+
+      return this.batchGetObjects({
+        objectType: "contacts",
+        data: {
+          inputs: contactIds.map((id) => ({
+            id,
+          })),
+          properties: allPropertyNames,
+        },
+        ...opts,
+      });
+    },
   },
 };

components/hubspot/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/hubspot",
-  "version": "1.7.12",
+  "version": "1.7.14",
   "description": "Pipedream Hubspot Components",
   "main": "hubspot.app.mjs",
   "keywords": [

components/hubspot/sources/delete-blog-article/delete-blog-article.mjs

@@ -6,7 +6,7 @@ export default {
   key: "hubspot-delete-blog-article",
   name: "Deleted Blog Posts",
   description: "Emit new event for each deleted blog post.",
-  version: "0.0.34",
+  version: "0.0.35",
   dedupe: "unique",
   type: "source",
   methods: {

components/hubspot/sources/new-company-property-change/new-company-property-change.mjs

@@ -7,7 +7,7 @@ export default {
   key: "hubspot-new-company-property-change",
   name: "New Company Property Change",
   description: "Emit new event when a specified property is provided or updated on a company. [See the documentation](https://developers.hubspot.com/docs/api/crm/companies)",
-  version: "0.0.27",
+  version: "0.0.28",
   dedupe: "unique",
   type: "source",
   props: {

components/hubspot/sources/new-contact-added-to-list/new-contact-added-to-list.mjs

@@ -12,7 +12,7 @@ export default {
   name: "New Contact Added to List",
   description:
     "Emit new event when a contact is added to a HubSpot list. [See the documentation](https://developers.hubspot.com/docs/reference/api/crm/lists#get-%2Fcrm%2Fv3%2Flists%2F%7Blistid%7D%2Fmemberships%2Fjoin-order)",
-  version: "0.0.6",
+  version: "0.0.7",
   type: "source",
   dedupe: "unique",
   props: {
@@ -55,6 +55,14 @@ export default {
       label: "Additional contact properties to retrieve",
       optional: true,
     },
+    fetchAllProperties: {
+      type: "boolean",
+      label: "Fetch all contact properties",
+      description:
+        "When enabled, fetches all available contact properties instead of just default and selected properties. This provides complete contact data but may increase API usage.",
+      optional: true,
+      default: false,
+    },
   },
   methods: {
     ...common.methods,
@@ -95,6 +103,40 @@ export default {
     async getContactDetails(contactIds) {
       if (!contactIds.length) return {};
 
+      if (this.fetchAllProperties) {
+        const chunks = [];
+        const chunkSize = 100;
+        for (let i = 0; i < contactIds.length; i += chunkSize) {
+          chunks.push(contactIds.slice(i, i + chunkSize));
+        }
+
+        const contactMap = {};
+
+        try {
+          for (const chunk of chunks) {
+            try {
+              const { results } = await this.hubspot.batchGetContactsWithAllProperties({
+                contactIds: chunk,
+              });
+
+              results.forEach((contact) => {
+                contactMap[contact.id] = contact;
+              });
+            } catch (error) {
+              console.warn(
+                `Error fetching contact details for chunk of ${chunk.length} contacts:`,
+                error,
+              );
+            }
+          }
+
+          return contactMap;
+        } catch (error) {
+          console.warn("Error processing contact details:", error);
+          return {};
+        }
+      }
+
       const { properties = [] } = this;
       const allProperties = [
         ...DEFAULT_CONTACT_PROPERTIES,

components/hubspot/sources/new-contact-property-change/new-contact-property-change.mjs

@@ -8,7 +8,7 @@ export default {
   name: "New Contact Property Change",
   description:
     "Emit new event when a specified property is provided or updated on a contact. [See the documentation](https://developers.hubspot.com/docs/api/crm/contacts)",
-  version: "0.0.30",
+  version: "0.0.31",
   dedupe: "unique",
   type: "source",
   props: {
@@ -38,6 +38,14 @@ export default {
       optional: true,
       default: true,
     },
+    fetchAllProperties: {
+      type: "boolean",
+      label: "Fetch all contact properties",
+      description:
+        "When enabled, fetches all available contact properties instead of just the watched property. This provides complete contact data but may increase API usage.",
+      optional: true,
+      default: false,
+    },
   },
   methods: {
     ...common.methods,
@@ -111,7 +119,38 @@ export default {
       }
       return params;
     },
-    batchGetContacts(inputs) {
+    async batchGetContacts(inputs) {
+      if (this.fetchAllProperties) {
+        const { results } = await this.hubspot.batchGetContactsWithAllProperties({
+          contactIds: inputs.map((input) => input.id),
+        });
+
+        const { results: contactsWithHistory } = await this.hubspot.batchGetObjects({
+          objectType: "contacts",
+          data: {
+            properties: [
+              this.property,
+            ],
+            propertiesWithHistory: [
+              this.property,
+            ],
+            inputs,
+          },
+        });
+
+        const mergedResults = results.map((contact) => {
+          const contactWithHistory = contactsWithHistory.find((c) => c.id === contact.id);
+          return {
+            ...contact,
+            propertiesWithHistory: contactWithHistory?.propertiesWithHistory || {},
+          };
+        });
+
+        return {
+          results: mergedResults,
+        };
+      }
+
       return this.hubspot.batchGetObjects({
         objectType: "contacts",
         data: {

components/hubspot/sources/new-custom-object-property-change/new-custom-object-property-change.mjs

@@ -7,7 +7,7 @@ export default {
   name: "New Custom Object Property Change",
   description:
     "Emit new event when a specified property is provided or updated on a custom object.",
-  version: "0.0.19",
+  version: "0.0.20",
   dedupe: "unique",
   type: "source",
   props: {

components/hubspot/sources/new-deal-in-stage/new-deal-in-stage.mjs

@@ -13,7 +13,7 @@ export default {
   key: "hubspot-new-deal-in-stage",
   name: "New Deal In Stage",
   description: "Emit new event for each new deal in a stage.",
-  version: "0.1.0",
+  version: "0.1.1",
   dedupe: "unique",
   type: "source",
   props: {

components/hubspot/sources/new-deal-property-change/new-deal-property-change.mjs

@@ -7,7 +7,7 @@ export default {
   key: "hubspot-new-deal-property-change",
   name: "New Deal Property Change",
   description: "Emit new event when a specified property is provided or updated on a deal. [See the documentation](https://developers.hubspot.com/docs/api/crm/deals)",
-  version: "0.0.28",
+  version: "0.0.30",
   dedupe: "unique",
   type: "source",
   props: {

components/hubspot/sources/new-email-event/new-email-event.mjs

@@ -8,7 +8,7 @@ export default {
   key: "hubspot-new-email-event",
   name: "New Email Event",
   description: "Emit new event for each new Hubspot email event.",
-  version: "0.0.37",
+  version: "0.0.38",
   dedupe: "unique",
   type: "source",
   props: {