new sources

Author: michelle0927

components/hubspot/hubspot.app.mjs

@@ -1008,5 +1008,19 @@ export default {
         ...opts,
       });
     },
+    listNotes(opts = {}) {
+      return this.makeRequest({
+        api: API_PATH.CRMV3,
+        endpoint: "/objects/notes",
+        ...opts,
+      });
+    },
+    listTasks(opts = {}) {
+      return this.makeRequest({
+        api: API_PATH.CRMV3,
+        endpoint: "/objects/tasks",
+        ...opts,
+      });
+    },
   },
 };

components/hubspot/package.json

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

components/hubspot/sources/common/common.mjs

@@ -181,7 +181,7 @@ export default {
   },
   async run() {
     const after = this._getAfter();
-    const params = this.getParams(after);
+    const params = await this.getParams(after);
     await this.processResults(after, params);
   },
 };

components/hubspot/sources/new-note/new-note.mjs

@@ -0,0 +1,56 @@
+import common from "../common/common.mjs";
+import {
+  DEFAULT_LIMIT, OBJECT_TYPES,
+} from "../../common/constants.mjs";
+
+export default {
+  ...common,
+  key: "hubspot-new-note",
+  name: "New Note Created",
+  description: "Emit new event for each new note created. [See the documentation](https://developers.hubspot.com/docs/reference/api/crm/engagements/notes#get-%2Fcrm%2Fv3%2Fobjects%2Fnotes)",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  methods: {
+    ...common.methods,
+    getTs(note) {
+      return Date.parse(note.createdAt);
+    },
+    generateMeta(note) {
+      return {
+        id: note.id,
+        summary: `New Note: ${note.properties.hs_body_preview || note.id}`,
+        ts: this.getTs(note),
+      };
+    },
+    isRelevant(note, createdAfter) {
+      return this.getTs(note) > createdAfter;
+    },
+    async getParams() {
+      const { results: allProperties } = await this.hubspot.getProperties({
+        objectType: "notes",
+      });
+      const properties = allProperties.map(({ name }) => name);
+
+      const objectTypes = OBJECT_TYPES.map(({ value }) => value);
+      const { results: custom } = await this.hubspot.listSchemas();
+      const customObjects = custom?.map(({ name }) => name);
+      const associations = [
+        ...objectTypes,
+        ...customObjects,
+      ];
+
+      return {
+        params: {
+          limit: DEFAULT_LIMIT,
+          properties: properties.join(","),
+          associations: associations.join(","),
+        },
+      };
+    },
+    async processResults(after, params) {
+      const notes = await this.getPaginatedItems(this.hubspot.listNotes.bind(this), params);
+      await this.processEvents(notes, after);
+    },
+  },
+};

components/hubspot/sources/new-task/new-task.mjs

@@ -0,0 +1,56 @@
+import common from "../common/common.mjs";
+import {
+  DEFAULT_LIMIT, OBJECT_TYPES,
+} from "../../common/constants.mjs";
+
+export default {
+  ...common,
+  key: "hubspot-new-task",
+  name: "New Task Created",
+  description: "Emit new event for each new task created. [See the documentation](https://developers.hubspot.com/docs/reference/api/crm/engagements/tasks#get-%2Fcrm%2Fv3%2Fobjects%2Ftasks)",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  methods: {
+    ...common.methods,
+    getTs(task) {
+      return Date.parse(task.createdAt);
+    },
+    generateMeta(task) {
+      return {
+        id: task.id,
+        summary: `New Task: ${task.properties.hs_task_subject || task.id}`,
+        ts: this.getTs(task),
+      };
+    },
+    isRelevant(task, createdAfter) {
+      return this.getTs(task) > createdAfter;
+    },
+    async getParams() {
+      const { results: allProperties } = await this.hubspot.getProperties({
+        objectType: "tasks",
+      });
+      const properties = allProperties.map(({ name }) => name);
+
+      const objectTypes = OBJECT_TYPES.map(({ value }) => value);
+      const { results: custom } = await this.hubspot.listSchemas();
+      const customObjects = custom?.map(({ name }) => name);
+      const associations = [
+        ...objectTypes,
+        ...customObjects,
+      ];
+
+      return {
+        params: {
+          limit: DEFAULT_LIMIT,
+          properties: properties.join(","),
+          associations: associations.join(","),
+        },
+      };
+    },
+    async processResults(after, params) {
+      const tasks = await this.getPaginatedItems(this.hubspot.listTasks.bind(this), params);
+      await this.processEvents(tasks, after);
+    },
+  },
+};