updates

Author: michelle0927

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

@@ -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,
-          "reply-to": headers.find((h) => h.name.toLowerCase() === "reply-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) {
@@ -488,23 +472,12 @@ export default {
 
       console.log("Fetched message details count:", messageDetails.length);
 
-      const processedEmails = this.processEmails(messageDetails);
-
       // Store the latest historyId in the db
       const latestHistoryId = historyResponse.historyId || receivedHistoryId;
       this._setLastProcessedHistoryId(latestHistoryId);
       console.log("Updated lastProcessedHistoryId:", latestHistoryId);
 
-      for (let i = 0; i < messageDetails.length; i++) {
-        this.$emit({
-          ...messageDetails[i],
-          "parsed-headers": processedEmails[i],
-        }, {
-          id: processedEmails[i].id,
-          summary: processedEmails[i].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,
       };
     },
   },