Add 5 new features: health score, AI search, scheduled send, newsletter view, smart compose

- GET /api/emails/health-score: inbox health score (0-100, A-F grade) with tips
- POST /api/emails/ai-search: natural language search via Claude Haiku → DB filters
- POST /api/emails/ai-draft: AI-generated email draft with user tone + signature
- POST/GET/DELETE /api/scheduled-sends: schedule emails for future delivery
- flush_scheduled_sends scheduler job every 5 min via Gmail API
- send_gmail_compose() for new (non-reply) emails
- /email/newsletters: grouped newsletter view by sender with unsubscribe
- compose.tsx: AI Draft panel + Schedule Send datetime picker
- email/index.tsx: sparkle button toggles AI natural language search mode
- Layout.tsx: Newsletters nav points to grouped view
- Responsive: newsletters page stacks vertically on mobile

Requires Supabase migration for scheduled_sends table (see routes/scheduled.py header)

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

Author: Sai Sridhar

.gitignore

@@ -182,3 +182,4 @@ Icon
 Network Trash Folder
 Temporary Items
 .apdisk
+.gstack/

backend/ai/classifier.py

@@ -18,6 +18,10 @@
 - language: ISO 639-1 language code of the email (e.g. 'en', 'es', 'fr', 'de', 'pt', 'hi', 'zh', 'ja')
 - is_phishing: boolean — true if the email shows signs of phishing or social engineering
 - phishing_indicators: array of strings listing specific suspicious elements found (empty array if none)
+- is_invoice: boolean — true if the email is an invoice, bill, receipt, or payment request
+- invoice_amount: string or null — total amount due (e.g. "$1,200.00"), null if not an invoice
+- invoice_due_date: string or null — payment due date as ISO date string, null if not found
+- invoice_vendor: string or null — name of the company sending the invoice, null if not an invoice
 
 Email Subject: {subject}
 From: {sender}
@@ -80,6 +84,10 @@ async def classify_email(subject: str, sender: str, body: str, attachments: list
         result["language"] = result.get("language", "en")
         result["is_phishing"] = bool(result.get("is_phishing", False))
         result["phishing_indicators"] = result.get("phishing_indicators", [])
+        result["is_invoice"] = bool(result.get("is_invoice", False))
+        result["invoice_amount"] = result.get("invoice_amount") or None
+        result["invoice_due_date"] = result.get("invoice_due_date") or None
+        result["invoice_vendor"] = result.get("invoice_vendor") or None
 
         return result
 

backend/config.py

@@ -62,6 +62,11 @@ class Settings(BaseSettings):
     # AI Thresholds
     URGENCY_THRESHOLD: int = 7
 
+    # VAPID keys for Web Push (generate with: python -c "from py_vapid import Vapid; v=Vapid(); v.generate_keys(); print(v.private_key); print(v.public_key)")
+    VAPID_PRIVATE_KEY: str = ""
+    VAPID_PUBLIC_KEY: str = ""
+    VAPID_EMAIL: str = "mailto:admin@mailair.company"
+
     # Environment
     ENVIRONMENT: str = "development"
 

backend/main.py

@@ -15,7 +15,7 @@
 
 from config import settings
 from limiter import limiter
-from routes import auth, emails, actions, replies, integrations, settings as settings_routes, billing, contacts, outlook, calendar, teams, webhooks as webhooks_routes, autoassign, crm_integrations, admin as admin_routes, waitlist as waitlist_routes
+from routes import auth, emails, actions, replies, integrations, settings as settings_routes, billing, contacts, outlook, calendar, teams, webhooks as webhooks_routes, autoassign, crm_integrations, admin as admin_routes, waitlist as waitlist_routes, push as push_routes, scheduled as scheduled_routes
 from workers.email_listener import start_email_listener, stop_email_listener
 
 # ---------------------------------------------------------------------------
@@ -36,7 +36,9 @@ async def lifespan(app: FastAPI):
     """Startup and shutdown hooks."""
     logger.info("Mailair backend starting up (env=%s).", settings.ENVIRONMENT)
     start_email_listener()
+
     yield
+
     logger.info("Mailair backend shutting down.")
     stop_email_listener()
 
@@ -166,6 +168,8 @@ async def generic_exception_handler(request: Request, exc: Exception):
 app.include_router(crm_integrations.router, prefix="/api")
 app.include_router(admin_routes.router, prefix="/api")
 app.include_router(waitlist_routes.router)
+app.include_router(push_routes.router, prefix="/api")
+app.include_router(scheduled_routes.router, prefix="/api")
 
 
 # ---------------------------------------------------------------------------

backend/models/email.py

@@ -14,6 +14,7 @@ class EmailCreate(EmailBase):
     user_id: str
     gmail_message_id: Optional[str] = None
     thread_id: Optional[str] = None
+    labels: List[str] = []
 
 
 class EmailResponse(EmailBase):

backend/models/user.py

@@ -28,6 +28,15 @@ class UserUpdate(BaseModel):
     vacation_mode: Optional[bool] = None
     vacation_message: Optional[str] = None
     email_signature: Optional[str] = None
+    # Email digest preferences
+    digest_enabled: Optional[bool] = None
+    digest_frequency: Optional[str] = None  # 'daily' | 'weekly'
+    # Selective Gmail sync filters
+    sync_labels: Optional[list] = None          # e.g. ["INBOX", "CATEGORY_PROMOTIONS"]
+    sync_max_emails: Optional[int] = None        # 10 / 25 / 50 / 100
+    sync_days_back: Optional[int] = None         # only fetch emails newer than N days
+    sync_sender_allowlist: Optional[list] = None # only from these domains/emails
+    sync_sender_blocklist: Optional[list] = None # never from these domains/emails
 
 
 class ReplyDraftResponse(BaseModel):

backend/requirements.txt

@@ -18,3 +18,4 @@ pydantic-settings==2.7.0
 apscheduler==3.10.4
 slowapi==0.1.9
 tenacity==9.0.0
+pywebpush==2.0.0