Gmail - Improve New Email Received event shape

components/gmail/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/gmail",
-  "version": "0.1.5",
+  "version": "0.1.6",
   "description": "Pipedream Gmail Components",
   "main": "gmail.app.mjs",
   "keywords": [

components/gmail/sources/common/base.mjs

@@ -44,7 +44,25 @@ export default {
           decodedContent: Buffer.from(firstPart.body.data, "base64").toString(),
         };
     },
+    processEmail(msg) {
+      // Process and structure the email data
+      const headers = msg.payload.headers;
+      return {
+        "id": msg.id,
+        "threadId": msg.threadId,
+        "subject": headers.find((h) => h.name.toLowerCase() === "subject")?.value,
+        "from": headers.find((h) => h.name.toLowerCase() === "from")?.value,
+        "to": headers.find((h) => h.name.toLowerCase() === "to")?.value,
+        "reply-to": headers.find((h) => h.name.toLowerCase() === "reply-to")?.value,
+        "date": headers.find((h) => h.name.toLowerCase() === "date")?.value,
+        "snippet": msg.snippet,
+      };
+    },
     emitEvent(message) {
+      message = {
+        ...message,
+        parsedHeaders: this.processEmail(message),
+      };
       const meta = this.generateMeta(message);
       this.$emit(this.decodeContent(message), meta);
     },

components/gmail/sources/common/polling-history.mjs

@@ -6,9 +6,6 @@ export default {
   hooks: {
     ...common.hooks,
     async deploy() {
-      if (this.triggerType === "webhook") {
-        return;
-      }
       const historyId = await this.getHistoryId();
       if (!historyId) {
         return;

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

@@ -6,7 +6,7 @@ export default {
   key: "gmail-new-attachment-received",
   name: "New Attachment Received",
   description: "Emit new event for each attachment in a message received. This source is capped at 100 max new messages per run.",
-  version: "0.0.3",
+  version: "0.0.4",
   type: "source",
   dedupe: "unique",
   props: {
@@ -51,7 +51,7 @@ export default {
       return {
         id: `${message.id}${attachment.partId}`,
         summary: `New Attachment: ${attachment.filename}`,
-        ts: message.internalDate,
+        ts: +message.internalDate,
       };
     },
     emitEvent(message) {

components/gmail/sources/new-email-matching-search/new-email-matching-search.mjs

@@ -6,7 +6,7 @@ export default {
   key: "gmail-new-email-matching-search",
   name: "New Email Matching Search",
   description: "Emit new event when an email matching the search criteria is received. This source is capped at 100 max new messages per run.",
-  version: "0.0.2",
+  version: "0.0.3",
   type: "source",
   dedupe: "unique",
   props: {
@@ -39,7 +39,7 @@ export default {
       return {
         id: message.id,
         summary: `New email: ${subject}`,
-        ts: message.internalDate,
+        ts: +message.internalDate,
       };
     },
   },

components/gmail/sources/new-email-received/new-email-received.mjs

@@ -15,7 +15,7 @@ export default {
   name: "New Email Received",
   description: "Emit new event when a new email is received.",
   type: "source",
-  version: "0.1.2",
+  version: "0.1.3",
   dedupe: "unique",
   props: {
     gmail,
@@ -361,22 +361,6 @@ export default {
       }
       return topic;
     },
-    processEmails(messageDetails) {
-      // Process and structure the email data
-      return messageDetails.map((msg) => {
-        const headers = msg.payload.headers;
-        return {
-          id: msg.id,
-          threadId: msg.threadId,
-          subject: headers.find((h) => h.name.toLowerCase() === "subject")
-            ?.value,
-          from: headers.find((h) => h.name.toLowerCase() === "from")?.value,
-          to: headers.find((h) => h.name.toLowerCase() === "to")?.value,
-          date: headers.find((h) => h.name.toLowerCase() === "date")?.value,
-          snippet: msg.snippet,
-        };
-      });
-    },
     getHistoryTypes() {
       return [
         "messageAdded",
@@ -386,7 +370,7 @@ export default {
       return {
         id: message.id,
         summary: message.snippet,
-        ts: message.internalDate,
+        ts: +message.internalDate,
       };
     },
     filterHistory(history) {
@@ -482,29 +466,18 @@ export default {
       const newMessageIds = newMessages?.map(({ id }) => id) || [];
       const messageDetails = await this.gmail.getMessages(newMessageIds);
 
-      console.log("Fetched message details count:", messageDetails.length);
+      if (!messageDetails?.length) {
+        return;
+      }
 
-      const processedEmails = this.processEmails(messageDetails);
+      console.log("Fetched message details count:", messageDetails.length);
 
       // Store the latest historyId in the db
       const latestHistoryId = historyResponse.historyId || receivedHistoryId;
       this._setLastProcessedHistoryId(latestHistoryId);
       console.log("Updated lastProcessedHistoryId:", latestHistoryId);
 
-      if (processedEmails?.length) {
-        this.$emit(
-          {
-            newEmailsCount: processedEmails.length,
-            emails: processedEmails,
-            lastProcessedHistoryId: latestHistoryId,
-          },
-          {
-            id: processedEmails[0].id,
-            summary: processedEmails[0].subject,
-            ts: Date.now(),
-          },
-        );
-      }
+      messageDetails.forEach((message) => this.emitEvent(message));
     }
   },
 };

components/gmail/sources/new-labeled-email/new-labeled-email.mjs

@@ -8,7 +8,7 @@ export default {
   name: "New Labeled Email",
   description: "Emit new event when a new email is labeled.",
   type: "source",
-  version: "0.0.3",
+  version: "0.0.4",
   dedupe: "unique",
   props: {
     ...common.props,
@@ -32,7 +32,7 @@ export default {
       return {
         id: `${message.id}-${this.label}`,
         summary: `A new message with ID: ${message.id} was labeled with "${this.label}"`,
-        ts: Date.now(),
+        ts: +message.internalDate,
       };
     },
     filterHistory(history) {

components/gmail/sources/new-sent-email/new-sent-email.mjs

@@ -6,7 +6,7 @@ export default {
   key: "gmail-new-sent-email",
   name: "New Sent Email",
   description: "Emit new event for each new email sent. (Maximum of 100 events emited per execution)",
-  version: "0.0.3",
+  version: "0.0.4",
   type: "source",
   dedupe: "unique",
   props: {
@@ -30,7 +30,7 @@ export default {
       return {
         id: message.id,
         summary: message.snippet,
-        ts: new Date(message.internalDate),
+        ts: +message.internalDate,
       };
     },
   },