Fix Gmail sync: fetch recent emails instead of unread-only, run AI on manual sync

- Remove is:unread filter — was blocking sync for users with no unread emails
- Default to last 7 days (after:YYYY/MM/DD) to limit scope without missing read emails
- Manual /sync now calls _process_user_emails (with AI) instead of _sync_user_emails
  so emails appear categorized in priority inbox immediately after sync

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: Sai Sridhar

backend/routes/emails.py

@@ -15,7 +15,7 @@
 from services.ai_processor import process_email
 from services.gmail_service import send_gmail_reply, get_email_attachments, get_attachment_data
 from services.razorpay_service import PLAN_LIMITS
-from workers.email_listener import _sync_user_emails
+from workers.email_listener import _process_user_emails
 
 logger = logging.getLogger(__name__)
 router = APIRouter(prefix="/emails", tags=["emails"])
@@ -158,7 +158,7 @@ async def sync_emails(
     current_user: Annotated[dict, Depends(get_current_user)],
 ):
     """Manually trigger a Gmail sync for the current user."""
-    background_tasks.add_task(_sync_user_emails, _current_user_id(current_user))
+    background_tasks.add_task(_process_user_emails, _current_user_id(current_user))
     return {"message": "Gmail sync started."}
 
 

backend/services/gmail_service.py

@@ -329,7 +329,7 @@ def _extract_body(payload: dict) -> str:
 
 def _build_gmail_query(filters: dict) -> tuple[str, int]:
     """Build Gmail search query and maxResults from user sync_filters."""
-    parts = ["is:unread"]
+    parts = []
 
     # Label/folder filter — default to inbox
     labels = filters.get("sync_labels") or []
@@ -353,12 +353,11 @@ def _build_gmail_query(filters: dict) -> tuple[str, int]:
     else:
         parts.append("in:inbox")
 
-    # Date range
-    days_back = filters.get("sync_days_back")
-    if days_back and isinstance(days_back, int) and days_back > 0:
-        from datetime import timedelta, timezone as _tz
-        cutoff = (datetime.now(_tz.utc) - timedelta(days=days_back)).strftime("%Y/%m/%d")
-        parts.append(f"after:{cutoff}")
+    # Date range — default 7 days if not configured
+    days_back = filters.get("sync_days_back") or 7
+    from datetime import timedelta, timezone as _tz
+    cutoff = (datetime.now(_tz.utc) - timedelta(days=int(days_back))).strftime("%Y/%m/%d")
+    parts.append(f"after:{cutoff}")
 
     # Sender allowlist (from:a OR from:b)
     allowlist = filters.get("sync_sender_allowlist") or []