Merge branch '18109-microsoft-outlook' of https://github.com/PipedreamHQ/pipedream into 18109-microsoft-outlook

Author: luancazarine

components/devin/devin.app.mjs

@@ -0,0 +1,11 @@
+export default {
+  type: "app",
+  app: "devin",
+  propDefinitions: {},
+  methods: {
+    // this.$auth contains connected account data
+    authKeys() {
+      console.log(Object.keys(this.$auth));
+    },
+  },
+};

components/devin/package.json

@@ -0,0 +1,15 @@
+{
+  "name": "@pipedream/devin",
+  "version": "0.0.1",
+  "description": "Pipedream Devin Components",
+  "main": "devin.app.mjs",
+  "keywords": [
+    "pipedream",
+    "devin"
+  ],
+  "homepage": "https://pipedream.com/apps/devin",
+  "author": "Pipedream <[email protected]> (https://pipedream.com/)",
+  "publishConfig": {
+    "access": "public"
+  }
+}

components/hubspot/package.json

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

components/hubspot/sources/new-or-updated-contact/new-or-updated-contact.mjs

@@ -10,7 +10,7 @@ export default {
   key: "hubspot-new-or-updated-contact",
   name: "New or Updated Contact",
   description: "Emit new event for each new or updated contact in Hubspot.",
-  version: "0.0.14",
+  version: "0.0.15",
   dedupe: "unique",
   type: "source",
   props: {
@@ -96,16 +96,21 @@ export default {
       }
       return true;
     },
-    getParams() {
+    getParams(after) {
       const { properties = [] } = this;
-      return {
+      const dateProperty = this.newOnly
+        ? "createdate"
+        : "lastmodifieddate";
+      const isFirstRun = !this.db.get("after");
+
+      const params = {
         data: {
-          limit: DEFAULT_LIMIT,
+          limit: isFirstRun
+            ? 100
+            : DEFAULT_LIMIT,
           sorts: [
             {
-              propertyName: this.newOnly
-                ? "createdate"
-                : "lastmodifieddate",
+              propertyName: dateProperty,
               direction: "DESCENDING",
             },
           ],
@@ -116,6 +121,22 @@ export default {
         },
         object: "contacts",
       };
+
+      if (after) {
+        params.data.filterGroups = [
+          {
+            filters: [
+              {
+                propertyName: dateProperty,
+                operator: "GT",
+                value: after,
+              },
+            ],
+          },
+        ];
+      }
+
+      return params;
     },
     async processResults(after, params) {
       await this.searchCRM(params, after);

components/microsoft_outlook/actions/find-email/find-email.mjs

@@ -44,7 +44,6 @@ export default {
       args: {
         $,
         params: {
-          "$search": this.search,
           "$filter": this.filter,
           "$orderby": this.orderBy,
         },

components/microsoft_outlook/sources/common/common-new-email.mjs

@@ -54,5 +54,22 @@ export default {
       const draftsFolderId = this.db.get("draftsFolderId");
       return item.parentFolderId !== sentItemFolderId && item.parentFolderId !== draftsFolderId;
     },
+    async getMessageAttachments(message) {
+      const { value: attachments } = await this.microsoftOutlook.listAttachments({
+        messageId: message.id,
+      });
+      if (!attachments?.length) {
+        return [];
+      }
+      return attachments.map((attachment) => ({
+        ...attachment,
+        messageId: message.id,
+        messageSubject: message.subject,
+        messageSender: message.sender,
+        messageReceivedDateTime: message.receivedDateTime,
+        parentFolderId: message.parentFolderId,
+        contentBytes: undefined,
+      }));
+    },
   },
 };

components/microsoft_outlook/sources/new-attachment-received/new-attachment-received.mjs

@@ -36,23 +36,6 @@ export default {
       }
       return attachments;
     },
-    async getMessageAttachments(message) {
-      const { value: attachments } = await this.microsoftOutlook.listAttachments({
-        messageId: message.id,
-      });
-      if (!attachments?.length) {
-        return [];
-      }
-      return attachments.map((attachment) => ({
-        ...attachment,
-        messageId: message.id,
-        messageSubject: message.subject,
-        messageSender: message.sender,
-        messageReceivedDateTime: message.receivedDateTime,
-        parentFolderId: message.parentFolderId,
-        contentBytes: undefined,
-      }));
-    },
     emitEvent(item) {
       if (this.isRelevant(item)) {
         this.$emit(item, this.generateMeta(item));

components/microsoft_outlook/sources/new-email/new-email.mjs

@@ -7,7 +7,7 @@ export default {
   key: "microsoft_outlook-new-email",
   name: "New Email Event (Instant)",
   description: "Emit new event when an email is received in specified folders.",
-  version: "0.0.21",
+  version: "0.1.0",
   type: "source",
   dedupe: "unique",
   methods: {
@@ -66,6 +66,10 @@ export default {
               resource: folder,
               messageId: resourceId,
             });
+            if (item.hasAttachments) {
+              const attachments = await this.getMessageAttachments(item);
+              item.attachments = attachments;
+            }
             this.emitEvent(item);
           } catch {
             console.log(`Could not fetch message with ID: ${resourceId}`);

components/notion/actions/append-block/append-block.mjs

@@ -7,7 +7,7 @@ export default {
   name: "Append Block to Parent",
   description:
     "Append new and/or existing blocks to the specified parent. [See the documentation](https://developers.notion.com/reference/patch-block-children)",
-  version: "0.3.6",
+  version: "0.3.7",
   type: "action",
   props: {
     notion,

components/notion/actions/complete-file-upload/complete-file-upload.mjs

@@ -6,7 +6,7 @@ export default {
   key: "notion-complete-file-upload",
   name: "Complete File Upload",
   description: "Use this action to finalize a `mode=multi_part` file upload after all of the parts have been sent successfully. [See the documentation](https://developers.notion.com/reference/complete-a-file-upload)",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "action",
   props: {
     notion,