|
1 | | -import { convert } from "html-to-text"; |
2 | | -import gmail from "../../gmail.app.mjs"; |
3 | 1 | import utils from "../../common/utils.mjs"; |
| 2 | +import gmail from "../../gmail.app.mjs"; |
4 | 3 |
|
5 | 4 | export default { |
6 | 5 | key: "gmail-find-email", |
7 | 6 | name: "Find Email", |
8 | 7 | description: "Find an email using Google's Search Engine. [See the docs](https://developers.google.com/gmail/api/reference/rest/v1/users.messages/list)", |
9 | | - version: "0.1.4", |
| 8 | + version: "0.1.5", |
10 | 9 | type: "action", |
11 | 10 | props: { |
12 | 11 | gmail, |
@@ -56,11 +55,9 @@ export default { |
56 | 55 | }); |
57 | 56 | const messageIds = messages.map(({ id }) => id); |
58 | 57 | const messagesToEmit = []; |
59 | | - for await (const message of this.gmail.getAllMessages(messageIds)) { |
| 58 | + for await (let message of this.gmail.getAllMessages(messageIds)) { |
60 | 59 | messagesToEmit.push(message); |
61 | 60 |
|
62 | | - let newPayload = ""; |
63 | | - |
64 | 61 | const messageIdHeader = message.payload?.headers?.find( |
65 | 62 | (h) => h.name.toLowerCase() === "message-id", |
66 | 63 | ); |
@@ -93,17 +90,9 @@ export default { |
93 | 90 | message.subject = subjectHeader.value; |
94 | 91 | } |
95 | 92 |
|
96 | | - if (this.withTextPayload) { |
97 | | - if (message.payload?.body?.data && !Array.isArray(message.payload.parts)) { |
98 | | - const decodedBody = utils.decodeBase64Url(message.payload.body.data); |
99 | | - newPayload += convert(decodedBody); |
100 | | - } |
101 | | - |
102 | | - if (Array.isArray(message.payload?.parts)) { |
103 | | - newPayload += utils.extractTextFromParts(message.payload.parts); |
104 | | - } |
105 | | - |
106 | | - message.payload = newPayload; |
| 93 | + const parsedMessage = utils.validateTextPayload(message, this.withTextPayload); |
| 94 | + if (parsedMessage) { |
| 95 | + message = parsedMessage; |
107 | 96 | } else { |
108 | 97 | if (message.payload?.body?.data && !Array.isArray(message.payload.parts)) { |
109 | 98 | message.payload.body.text = utils.decodeBase64Url(message.payload.body.data); |
|
0 commit comments