remove get messages function that uses promise all

Author: andrewjschuang

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

@@ -55,9 +55,10 @@ export default {
       maxResults: this.maxResults,
     });
     const messageIds = messages.map(({ id }) => id);
-    let messagesToEmit = await this.gmail.getMessages(messageIds);
+    const messagesToEmit = [];
+    for await (const message of this.gmail.getAllMessages(messageIds)) {
+      messagesToEmit.push(message);
 
-    for await (const message of messagesToEmit) {
       let newPayload = "";
 
       const messageIdHeader = message.payload?.headers?.find(

components/gmail/gmail.app.mjs

@@ -410,12 +410,6 @@ export default {
       const { value: subject } = message.payload.headers.find(({ name }) => name === "Subject");
       return subject;
     },
-    async getMessages(ids = []) {
-      const promises = ids.map((id) => this.getMessage({
-        id,
-      }));
-      return Promise.all(promises);
-    },
     async *getAllMessages(ids = []) {
       for (const id of ids) {
         const message = await this.getMessage({

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

@@ -60,9 +60,13 @@ export default {
         index === self.findIndex((m) => m.id === message.id));
 
       const messageIds = uniqueMessages.map(({ id }) => id);
-      const messagesWithHistoryId = await this.gmail.getMessages(messageIds);
+      const messages = [];
+      for await (const message of this.gmail.getAllMessages(messageIds)) {
+        messages.push(message);
+      }
+
       const sortedMessages =
-        Array.from(messagesWithHistoryId)
+        Array.from(messages)
           .sort((a, b) => (Number(b.historyId) - Number(a.historyId)));
 
       const { historyId } = await this.gmail.getMessage({

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

@@ -57,7 +57,10 @@ export default {
       }
     },
     async processHistoricalEvents(messageIds) {
-      let messages = await this.gmail.getMessages(messageIds);
+      let messages = [];
+      for await (const message of this.gmail.getAllMessages(messageIds)) {
+        messages.push(message);
+      }
       messages = messages.sort((a, b) => (a.internalDate - b.internalDate));
       this.setLastDate(messages[messages.length - 1].internalDate);
       messages.forEach((message) => this.emitEvent(message));