[FEATURE] Hubspot - New form submission improvement

Author: jcortes

components/hubspot/common/constants.mjs

@@ -22,6 +22,7 @@ const API_PATH = {
   AUTOMATION: "/automation/v2",
   DEAL: "/deals/v1",
   BUSINESS_UNITS: "/business-units/v3",
+  MARKETINGV3: "/marketing/v3",
 };
 
 /** Association categories for association types, as defined by the [Hubspot API

components/hubspot/hubspot.app.mjs

@@ -712,6 +712,15 @@ export default {
         ...opts,
       });
     },
+    getFormDefinition({
+      formId, ...opts
+    } = {}) {
+      return this.makeRequest({
+        api: API_PATH.MARKETINGV3,
+        endpoint: `/forms/${formId}`,
+        ...opts,
+      });
+    },
     getForms(opts = {}) {
       return this.makeRequest({
         api: API_PATH.FORMS,

components/hubspot/package.json

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

components/hubspot/sources/new-form-submission/new-form-submission.mjs

@@ -6,7 +6,7 @@ export default {
   key: "hubspot-new-form-submission",
   name: "New Form Submission",
   description: "Emit new event for each new submission of a form.",
-  version: "0.0.24",
+  version: "0.0.25",
   dedupe: "unique",
   type: "source",
   props: {
@@ -21,6 +21,40 @@ export default {
   },
   methods: {
     ...common.methods,
+    async paginate(params, resourceFn, resultType = null, after = null) {
+      let results = null;
+      let maxTs = after || 0;
+      while (!results || params.after) {
+        results = await resourceFn(params);
+        if (results.paging) {
+          params.after = results.paging.next.after;
+        } else {
+          delete params.after;
+        }
+        if (resultType) {
+          results = results[resultType];
+        }
+
+        for (const result of results) {
+          if (await this.isRelevant(result, after)) {
+            const form = await this.hubspot.getFormDefinition({
+              formId: params.formId,
+            });
+            this.emitEvent({
+              form,
+              ...result,
+            });
+            const ts = this.getTs(result);
+            if (ts > maxTs) {
+              maxTs = ts;
+              this._setAfter(ts);
+            }
+          } else {
+            return;
+          }
+        }
+      }
+    },
     getTs(result) {
       return result.submittedAt;
     },

components/hubspot/sources/new-form-submission/test-event.mjs

@@ -7,5 +7,6 @@ export default {
       "objectTypeId": "0-1"
     }
   ],
-  "pageUrl": "https://share.hsforms.com/13MJGKokMSAmW69lIF_JiKg43od5"
+  "pageUrl": "https://share.hsforms.com/13MJGKokMSAmW69lIF_JiKg43od5",
+  "form": { "id": "4442beda-998a-4825-bba1-2eaa3c1f0038", "name": "Test form (March 20, 2025 5:24:26 PM EDT)", "createdAt": "2025-03-20T21:24:26.911Z", "updatedAt": "2025-03-20T21:28:40.822Z", "archived": false, "fieldGroups": [{ "groupType": "default_group", "richTextType": "text", "fields": [{ "objectTypeId": "0-1", "name": "firstname", "label": "First Name", "required": false, "hidden": false, "fieldType": "single_line_text" }, { "objectTypeId": "0-1", "name": "lastname", "label": "Last Name", "required": false, "hidden": false, "fieldType": "single_line_text" }, { "objectTypeId": "0-1", "name": "email", "label": "Email", "required": true, "hidden": false, "validation": { "blockedEmailDomains": [], "useDefaultBlockList": false }, "fieldType": "email" }] }], "configuration": { "language": "en", "cloneable": true, "postSubmitAction": { "type": "thank_you", "value": "" }, "editable": true, "archivable": true, "recaptchaEnabled": false, "notifyContactOwner": false, "notifyRecipients": ["78708658"], "createNewContactForNewEmail": false, "prePopulateKnownValues": true, "allowLinkToResetKnownValues": false, "lifecycleStages": [] }, "displayOptions": { "renderRawHtml": false, "theme": "default_style", "submitButtonText": "", "style": { "fontFamily": "arial, helvetica, sans-serif", "backgroundWidth": "100%", "labelTextColor": "#33475b", "labelTextSize": "11px", "helpTextColor": "#7C98B6", "helpTextSize": "11px", "legalConsentTextColor": "#33475b", "legalConsentTextSize": "14px", "submitColor": "#ff7a59", "submitAlignment": "left", "submitFontColor": "#ffffff", "submitSize": "12px" }, "cssClass": null }, "legalConsentOptions": { "type": "none" }, "formType": "hubspot" }
 }