Update new-contact-property-change.mjs

components/hubspot/package.json

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

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

@@ -6,7 +6,7 @@ export default {
   key: "hubspot-new-contact-property-change",
   name: "New Contact Property Change",
   description: "Emit new event when a specified property is provided or updated on a contact. [See the docs here](https://developers.hubspot.com/docs/api/crm/contacts)",
-  version: "0.0.4",
+  version: "0.0.5",
   dedupe: "unique",
   type: "source",
   props: {
@@ -107,22 +107,29 @@ export default {
         return;
       }
 
-      const inputs = updatedContacts.map(({ id }) => ({
-        id,
-      }));
-      // get contacts w/ `propertiesWithHistory`
-      const { results } = await this.batchGetContacts(inputs);
-
+      const batchSize = 45;
       let maxTs = after;
-      for (const result of results) {
-        if (this.isRelevant(result, after)) {
-          this.emitEvent(result);
-          const ts = this.getTs(result);
-          if (ts > maxTs) {
-            maxTs = ts;
+
+      for (let i = 0; i < updatedContacts.length; i += batchSize) {
+        const batchInputs = updatedContacts.slice(i, i + batchSize).map(({id}) => ({id}));
+
+        // get contacts w/ `propertiesWithHistory`
+        const {results} = await this.batchGetContacts(batchInputs);
+
+        maxTs = after;
+
+        for (const result of results) {
+          if (this.isRelevant(result, after)) {
+            this.emitEvent(result);
+            const ts = this.getTs(result);
+            if (ts > maxTs) {
+              maxTs = ts;
+            }
           }
         }
-      }
+
+      after = maxTs;
+    }
 
       this._setAfter(maxTs);
     },