From f371cd4bb123821c184a3b272fdf4bb04ceb6b6d Mon Sep 17 00:00:00 2001
From: Arjun <6592213+arkml@users.noreply.github.com>
Date: Wed, 13 May 2026 14:05:52 +0530
Subject: [PATCH] ignore spam and trash emails

---
 apps/x/packages/core/src/knowledge/sync_gmail.ts | 14 +++++++++++++-
 1 file changed, 13 insertions(+), 1 deletion(-)

diff --git a/apps/x/packages/core/src/knowledge/sync_gmail.ts b/apps/x/packages/core/src/knowledge/sync_gmail.ts
index c8f696eb..e87c36b7 100644
--- a/apps/x/packages/core/src/knowledge/sync_gmail.ts
+++ b/apps/x/packages/core/src/knowledge/sync_gmail.ts
@@ -164,6 +164,16 @@ async function processThread(auth: OAuth2Client, threadId: string, syncDir: stri
 
         if (!messages || messages.length === 0) return null;
 
+        // Skip threads in SPAM or TRASH (Gmail labels them at the message level).
+        const isExcluded = messages.some(m => {
+            const labels = m.labelIds ?? [];
+            return labels.includes('SPAM') || labels.includes('TRASH');
+        });
+        if (isExcluded) {
+            console.log(`Skipping thread ${threadId} (SPAM/TRASH)`);
+            return null;
+        }
+
         // Subject from first message
         const firstHeader = messages[0].payload?.headers;
         const subject = firstHeader?.find(h => h.name === 'Subject')?.value || '(No Subject)';
@@ -279,7 +289,7 @@ async function fullSync(auth: OAuth2Client, syncDir: string, attachmentsDir: str
         do {
             const res = await gmail.users.threads.list({
                 userId: 'me',
-                q: `after:${dateQuery}`,
+                q: `after:${dateQuery} -in:spam -in:trash`,
                 pageToken
             });
 
@@ -393,6 +403,8 @@ async function partialSync(auth: OAuth2Client, startHistoryId: string, syncDir:
         for (const record of changes) {
             if (record.messagesAdded) {
                 for (const item of record.messagesAdded) {
+                    const labels = item.message?.labelIds ?? [];
+                    if (labels.includes('SPAM') || labels.includes('TRASH')) continue;
                     if (item.message?.threadId) {
                         threadIds.add(item.message.threadId);
                     }