Merge branch 'master' into 17945-trusted-shops

Author: luancazarine

components/google_my_business/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/google_my_business",
-  "version": "0.2.1",
+  "version": "0.2.2",
   "description": "Pipedream Google My Business Components",
   "main": "dist/app/google_my_business.app.mjs",
   "keywords": [

components/google_my_business/sources/common.ts

@@ -53,6 +53,7 @@ export default {
       const currentRun: number = Date.now();
       const lastRun: Date = this.getLastRun();
       const items: EntityWithCreateTime[] = await this.getItems();
+      console.log("Number of reviews: ", items.length);
       this.setLastRun(currentRun);
 
       const filteredItems = (lastRun

components/google_my_business/sources/new-post-created/new-post-created.ts

@@ -10,7 +10,7 @@ export default defineSource({
   key: "google_my_business-new-post-created",
   name: "New Post Created",
   description: `Emit new event for each new local post on a location [See the documentation](${DOCS_LINK})`,
-  version: "0.0.5",
+  version: "0.0.6",
   type: "source",
   dedupe: "unique",
   methods: {

components/google_my_business/sources/new-review-created-multiple-locations/new-review-created-multiple-locations.ts

@@ -13,7 +13,7 @@ export default defineSource({
   key: "google_my_business-new-review-created-multiple-locations",
   name: "New Review Created (Multiple Locations)",
   description: `Emit new event for each new review on any of the selected locations [See the documentation](${DOCS_LINK})`,
-  version: "0.0.2",
+  version: "0.0.3",
   type: "source",
   dedupe: "unique",
   props: {

components/google_my_business/sources/new-review-created/new-review-created.ts

@@ -10,7 +10,7 @@ export default defineSource({
   key: "google_my_business-new-review-created",
   name: "New Review Created",
   description: `Emit new event for each new review on a location [See the documentation](${DOCS_LINK})`,
-  version: "0.0.5",
+  version: "0.0.6",
   type: "source",
   dedupe: "unique",
   methods: {

components/hubspot/sources/common/common.mjs

@@ -140,19 +140,22 @@ export default {
         }
       }
     },
-    async getPaginatedItems(resourceFn, params) {
+    async getPaginatedItems(resourceFn, params, after = null) {
       const items = [];
+      const maxPages = 10;
+      let page = 0;
       do {
         const {
           results, paging,
         } = await resourceFn(params);
         items.push(...results);
         if (paging) {
           params.after = paging.next.after;
+          page++;
         } else {
           delete params.after;
         }
-      } while (params.after);
+      } while (params.after && after && page < maxPages);
       return items;
     },
     emitEvent(result) {

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.32",
+  version: "0.0.33",
   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.25",
+  version: "0.0.26",
   dedupe: "unique",
   type: "source",
   props: {
@@ -46,7 +46,7 @@ export default {
       return !updatedAfter || this.getTs(company) > updatedAfter;
     },
     getParams(after) {
-      return {
+      const params = {
         object: "companies",
         data: {
           limit: DEFAULT_LIMIT,
@@ -66,16 +66,19 @@ export default {
                   propertyName: this.property,
                   operator: "HAS_PROPERTY",
                 },
-                {
-                  propertyName: "hs_lastmodifieddate",
-                  operator: "GTE",
-                  value: after,
-                },
               ],
             },
           ],
         },
       };
+      if (after) {
+        params.data.filterGroups[0].filters.push({
+          propertyName: "hs_lastmodifieddate",
+          operator: "GTE",
+          value: after,
+        });
+      }
+      return params;
     },
     batchGetCompanies(inputs) {
       return this.hubspot.batchGetObjects({
@@ -104,6 +107,7 @@ export default {
       const updatedCompanies = await this.getPaginatedItems(
         this.hubspot.searchCRM,
         params,
+        after,
       );
 
       if (!updatedCompanies.length) {

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.4",
+  version: "0.0.5",
   type: "source",
   dedupe: "unique",
   props: {

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

@@ -7,7 +7,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 documentation](https://developers.hubspot.com/docs/api/crm/contacts)",
-  version: "0.0.27",
+  version: "0.0.28",
   dedupe: "unique",
   type: "source",
   props: {
@@ -106,6 +106,7 @@ export default {
       const updatedContacts = await this.getPaginatedItems(
         this.hubspot.searchCRM,
         params,
+        after,
       );
 
       if (!updatedContacts.length) {