Feat: manual AI processing per email — no auto-process on sync

- Sync endpoint now only fetches/stores emails, no AI processing
- Added "Process with AI" button on each EmailCard (unprocessed only)
- After processing, refreshes email list + billing usage count
- Background poll still auto-processes (for future scheduled use)

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

Author: 2 people

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 _process_user_emails
+from workers.email_listener import _sync_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(_process_user_emails, _current_user_id(current_user))
+    background_tasks.add_task(_sync_user_emails, _current_user_id(current_user))
     return {"message": "Gmail sync started."}
 
 

backend/workers/email_listener.py

@@ -36,12 +36,53 @@ async def _get_gmail_connected_users() -> list[str]:
         return []
 
 
+async def _sync_user_emails(user_id: str) -> None:
+    """
+    Fetch unread Gmail messages for one user and store new ones in Supabase.
+    Does NOT run AI processing — users trigger that manually per email.
+    """
+    try:
+        raw_emails = await fetch_new_emails(user_id=user_id)
+        if not raw_emails:
+            return
+
+        logger.info("Fetched %d emails for user_id=%s", len(raw_emails), user_id)
+
+        supabase = get_supabase()
+
+        for raw in raw_emails:
+            gmail_message_id = raw.get("gmail_message_id")
+
+            # Skip duplicates already stored
+            if gmail_message_id:
+                existing = (
+                    supabase.table("emails")
+                    .select("id")
+                    .eq("gmail_message_id", gmail_message_id)
+                    .eq("user_id", user_id)
+                    .execute()
+                )
+                if existing.data:
+                    continue
+
+            email_create = EmailCreate(
+                user_id=user_id,
+                subject=raw.get("subject", "(No Subject)"),
+                sender=raw.get("sender", ""),
+                body=raw.get("body", ""),
+                received_at=raw.get("received_at"),
+                gmail_message_id=gmail_message_id,
+                thread_id=raw.get("thread_id"),
+            )
+
+            await create_email(email_create)
+
+
 async def _process_user_emails(user_id: str) -> None:
     """
-    Fetch unread Gmail messages for one user, store new ones in Supabase,
-    then queue AI processing.
+    Fetch and store emails, then auto-run AI processing.
+    Used by the background poll (poll_all_users) — not triggered by manual sync.
     """
-    # Import here to avoid circular dependency at module load time
     from services.ai_processor import process_email as ai_process
 
     try:
@@ -56,7 +97,6 @@ async def _process_user_emails(user_id: str) -> None:
         for raw in raw_emails:
             gmail_message_id = raw.get("gmail_message_id")
 
-            # Skip duplicates already stored
             if gmail_message_id:
                 existing = (
                     supabase.table("emails")
@@ -80,7 +120,6 @@ async def _process_user_emails(user_id: str) -> None:
 
             stored = await create_email(email_create)
             if stored:
-                # Run AI pipeline asynchronously — don't block the listener
                 asyncio.create_task(ai_process(stored))
 
     except Exception as exc:

frontend/components/EmailCard.tsx

@@ -1,7 +1,7 @@
 import { useState } from 'react';
 import { useRouter } from 'next/router';
 import { formatDistanceToNow } from 'date-fns';
-import { ChevronRight, CheckSquare, Paperclip, X, Star, AlarmClock } from 'lucide-react';
+import { ChevronRight, CheckSquare, Paperclip, X, Star, AlarmClock, Zap, Loader2 } from 'lucide-react';
 import clsx from 'clsx';
 import toast from 'react-hot-toast';
 import type { Email } from '@/lib/types';
@@ -14,6 +14,7 @@ interface EmailCardProps {
   email: Email;
   className?: string;
   onDismiss?: (id: string) => void;
+  onProcessed?: () => void;
   selected?: boolean;
   onToggleSelect?: () => void;
 }
@@ -35,9 +36,10 @@ function getGradient(name: string) {
   return AVATAR_GRADIENTS[code];
 }
 
-export default function EmailCard({ email, className, onDismiss, selected, onToggleSelect }: EmailCardProps) {
+export default function EmailCard({ email, className, onDismiss, onProcessed, selected, onToggleSelect }: EmailCardProps) {
   const router = useRouter();
   const [dismissing, setDismissing] = useState(false);
+  const [processing, setProcessing] = useState(false);
   const [starred, setStarred] = useState(email.is_starred);
   const [snoozeOpen, setSnoozeOpen] = useState(false);
 
@@ -71,6 +73,21 @@ export default function EmailCard({ email, className, onDismiss, selected, onTog
     }
   };
 
+  const handleProcess = async (e: React.MouseEvent) => {
+    e.stopPropagation();
+    setProcessing(true);
+    try {
+      await emailsApi.processEmail(email.id);
+      toast.success('Processing with AI…');
+      onProcessed?.();
+    } catch (err: unknown) {
+      const msg = (err as { response?: { data?: { detail?: string } } })?.response?.data?.detail;
+      toast.error(msg || 'Failed to process email');
+    } finally {
+      setProcessing(false);
+    }
+  };
+
   const handleSnoozeClick = (e: React.MouseEvent) => {
     e.stopPropagation();
     setSnoozeOpen(true);
@@ -181,6 +198,17 @@ export default function EmailCard({ email, className, onDismiss, selected, onTog
 
           {/* Badges row */}
           <div className="mt-2 flex items-center gap-1.5 sm:gap-2 flex-wrap">
+            {/* Process with AI button — only shown for unprocessed emails */}
+            {!email.processed && !email.ai_analysis && (
+              <button
+                onClick={handleProcess}
+                disabled={processing}
+                className="inline-flex items-center gap-1 rounded-full bg-primary-50 dark:bg-primary-900/30 px-2 py-0.5 text-xs font-medium text-primary-700 dark:text-primary-300 border border-primary-200 dark:border-primary-700 hover:bg-primary-100 dark:hover:bg-primary-900/50 transition-colors"
+              >
+                {processing ? <Loader2 className="h-3 w-3 animate-spin" /> : <Zap className="h-3 w-3" />}
+                {processing ? 'Processing…' : 'Process with AI'}
+              </button>
+            )}
             {analysis?.category && (
               <CategoryBadge category={analysis.category} size="sm" />
             )}

frontend/lib/types.ts

@@ -42,6 +42,7 @@ export interface Email {
   is_starred: boolean;
   snooze_until?: string | null;
   labels: string[];
+  processed?: boolean;
   ai_analysis?: AIAnalysis;
   action_count?: number;
   created_at: string;

frontend/pages/email/index.tsx

@@ -16,7 +16,7 @@ import { ErrorCard } from '@/components/ErrorBoundary';
 import CategoryBadge from '@/components/CategoryBadge';
 import BatchActionBar from '@/components/BatchActionBar';
 import BulkSummaryModal from '@/components/BulkSummaryModal';
-import { useEmails } from '@/lib/hooks';
+import { useEmails, useBillingStatus } from '@/lib/hooks';
 import { emailsApi } from '@/lib/api';
 import { loadRules, applyRules } from '@/lib/rules';
 import type { EmailCategory, PriorityLevel, Email } from '@/lib/types';
@@ -74,6 +74,7 @@ export default function EmailListPage() {
     setPage(1);
   }, [router.query.category, router.query.priority_level]);
 
+  const { mutate: refreshBilling } = useBillingStatus();
   const { data, isLoading, error, mutate } = useEmails({
     category,
     priority_level: priorityLevel,
@@ -376,6 +377,7 @@ export default function EmailListPage() {
                   <EmailCard
                     email={email}
                     onDismiss={() => mutate()}
+                    onProcessed={() => { mutate(); refreshBilling(); }}
                     selected={selectionMode ? selectedIds.has(email.id) : undefined}
                     onToggleSelect={selectionMode ? () => toggleSelect(email.id) : undefined}
                   />