updates

Author: michelle0927

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

@@ -1,10 +1,6 @@
 import { convert } from "html-to-text";
 import gmail from "../../gmail.app.mjs";
-import {
-  decodeBase64Url,
-  extractTextFromParts,
-  attachTextToParts,
-} from "./utils.mjs";
+import utils from "../../common/utils.mjs";
 
 export default {
   key: "gmail-find-email",
@@ -72,7 +68,7 @@ export default {
       }
 
       if (message.payload?.body?.data && !Array.isArray(message.payload.parts)) {
-        const decodedBody = decodeBase64Url(message.payload.body.data);
+        const decodedBody = utils.decodeBase64Url(message.payload.body.data);
         if (this.withTextPayload) {
           newPayload += convert(decodedBody);
         } else {
@@ -82,9 +78,9 @@ export default {
 
       if (Array.isArray(message.payload?.parts)) {
         if (this.withTextPayload) {
-          newPayload += extractTextFromParts(message.payload.parts);
+          newPayload += utils.extractTextFromParts(message.payload.parts);
         } else {
-          attachTextToParts(message.payload.parts);
+          utils.attachTextToParts(message.payload.parts);
         }
       }
 

components/gmail/actions/find-email/utils.mjs

@@ -1,3 +1,5 @@
+import { convert } from "html-to-text";
+
 function parseArray(arr) {
   if (!arr) {
     return undefined;
@@ -7,6 +9,46 @@ function parseArray(arr) {
     : arr;
 }
 
+function decodeBase64Url(data) {
+  const base64 = data.replace(/-/g, "+").replace(/_/g, "/");
+  return Buffer.from(base64, "base64").toString("utf-8");
+};
+
+function extractTextFromParts(parts) {
+  let text = "";
+  for (const part of parts) {
+    if (Array.isArray(part.parts)) {
+      text += extractTextFromParts(part.parts);
+    }
+    if (part.mimeType === "text/plain" && part.body?.data) {
+      text += decodeBase64Url(part.body.data);
+    }
+    else if (part.mimeType === "text/html" && part.body?.data) {
+      const html = decodeBase64Url(part.body.data);
+      text += convert(html);
+    }
+  }
+  return text;
+};
+
+function attachTextToParts(parts) {
+  for (const part of parts) {
+    if (Array.isArray(part.parts)) {
+      attachTextToParts(part.parts);
+    }
+    if (part.mimeType === "text/html" && part.body?.data) {
+      const html = decodeBase64Url(part.body.data);
+      part.body.text = convert(html);
+    }
+    else if (part.mimeType === "text/plain" && part.body?.data) {
+      part.body.text = decodeBase64Url(part.body.data);
+    }
+  }
+};
+
 export default {
   parseArray,
+  decodeBase64Url,
+  extractTextFromParts,
+  attachTextToParts,
 };

components/gmail/common/utils.mjs

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