Fixes

Author: jcortes

components/gmail_custom_oauth/gmail_custom_oauth.app.mjs

@@ -103,10 +103,10 @@ export default {
               return this.getMessagesWithRetry([
                 id,
               ], retryCount + 1);
-            } else {
-              console.error("Failed after 3 attempts.");
-              return null; // or return a default value
             }
+
+            console.error("Failed after 3 attempts.");
+            return null;
           }));
       return Promise.all(promises);
     },

components/gmail_custom_oauth/sources/common/polling.mjs

@@ -38,21 +38,21 @@ export default {
     processMessageIds() {
       throw new Error("processMessageIds not implemented");
     },
-    getQuery() {
+    constructAttachmentQuery() {
       return this.q;
     },
   },
   async run() {
     const {
       gmail,
-      getQuery,
+      constructAttachmentQuery,
       labels,
     } = this;
 
     console.log("Polling for new messages...");
 
     const { messages } = await gmail.listMessages({
-      q: getQuery(),
+      q: constructAttachmentQuery(),
       labelIds: labels,
       maxResults: constants.HISTORICAL_EVENTS,
     });

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

@@ -10,7 +10,7 @@ export default {
   dedupe: "unique",
   methods: {
     ...common.methods,
-    getQuery() {
+    constructAttachmentQuery() {
       const { q: query } = this;
       const hasAttachment = "has:attachment";
       return query?.includes(hasAttachment)