Deploy v1 — single-Docker FastAPI + Next.js + RAG + voice + faithfulness

backend/main.py

@@ -111,6 +111,34 @@ class TTSRequest(BaseModel):
     speaker: Optional[str] = None
 
 
+class PolicyEntry(BaseModel):
+    name: str
+    source_url: str = ""  # PDF URL, verified at download time
+
+
+class InsurerCoverage(BaseModel):
+    slug: str
+    name: str
+    home_url: str  # insurer's main website (manually curated, verified)
+    policy_count: int
+    sample_policies: list[PolicyEntry]
+
+
+class CoverageResponse(BaseModel):
+    total_chunks: int
+    total_policies: int
+    total_insurers: int
+    insurers: list[InsurerCoverage]
+
+
+class UploadResponse(BaseModel):
+    policy_id: str
+    policy_name: str
+    chunks_added: int
+    pages_indexed: int
+    elapsed_ms: int
+
+
 # ---------- app ----------
 
 app = FastAPI(
@@ -227,6 +255,165 @@ async def chat(req: ChatRequest):
     )
 
 
+@app.get("/api/coverage", response_model=CoverageResponse)
+async def coverage():
+    """What policies/insurers are indexed in the corpus.
+
+    Drives the UI's "what's covered" panel — sets user expectations + reduces
+    over-refusals from off-corpus queries.
+    """
+    try:
+        from rag.retrieve import get_collection
+        coll = get_collection()
+        total = coll.count()
+    except Exception:
+        total = 0
+
+    # Insurer metadata — names + home URLs are curated + verified
+    # (see eval/verified_urls.json + tools/verify_urls.py)
+    insurer_meta = {
+        "aditya-birla":  ("Aditya Birla Health Insurance", "https://www.adityabirlacapital.com/healthinsurance"),
+        "bajaj-allianz": ("Bajaj Allianz General Insurance", "https://www.bajajallianz.com/"),
+        "care-health":   ("Care Health Insurance", "https://www.careinsurance.com/"),
+        "hdfc-ergo":     ("HDFC ERGO General Insurance", "https://www.hdfcergo.com/"),
+        "icici-lombard": ("ICICI Lombard General Insurance", "https://www.icicilombard.com/"),
+        "manipalcigna":  ("ManipalCigna Health Insurance", "https://www.manipalcigna.com/"),
+        "new-india":     ("New India Assurance", "https://www.newindia.co.in/"),
+        "niva-bupa":     ("Niva Bupa Health Insurance", "https://www.nivabupa.com/"),
+        "star-health":   ("Star Health & Allied Insurance", "https://www.starhealth.in/"),
+        "tata-aig":      ("Tata AIG General Insurance", "https://www.tataaig.com/"),
+        "user-upload":   ("Your uploaded policies", ""),
+    }
+
+    # policy -> source_url (verified at download time)
+    policy_urls: dict[tuple[str, str], str] = {}
+    by_insurer: dict[str, dict] = {}
+    if total > 0:
+        try:
+            res = coll.get(limit=10000, include=["metadatas"])
+            for m in res.get("metadatas", []):
+                slug = m.get("insurer_slug", "unknown")
+                name = m.get("policy_name", "")
+                url = m.get("source_url", "")
+                if slug not in by_insurer:
+                    by_insurer[slug] = {"policies": set(), "chunks": 0}
+                by_insurer[slug]["policies"].add(name)
+                by_insurer[slug]["chunks"] += 1
+                if url and (slug, name) not in policy_urls:
+                    policy_urls[(slug, name)] = url
+        except Exception:
+            pass
+
+    insurers_out = []
+    total_policies = 0
+    for slug, info in sorted(by_insurer.items()):
+        policy_names = sorted(info["policies"])
+        total_policies += len(policy_names)
+        name, home_url = insurer_meta.get(slug, (slug, ""))
+        sample_entries = [
+            PolicyEntry(name=p, source_url=policy_urls.get((slug, p), ""))
+            for p in policy_names[:8]
+        ]
+        insurers_out.append(
+            InsurerCoverage(
+                slug=slug,
+                name=name,
+                home_url=home_url,
+                policy_count=len(policy_names),
+                sample_policies=sample_entries,
+            )
+        )
+
+    return CoverageResponse(
+        total_chunks=total,
+        total_policies=total_policies,
+        total_insurers=len(insurers_out),
+        insurers=insurers_out,
+    )
+
+
+@app.post("/api/upload-policy", response_model=UploadResponse)
+async def upload_policy(file: UploadFile = File(...)):
+    """Accept a user-uploaded PDF policy doc, chunk + embed it, add to Chroma.
+
+    Note: in v1 demo this appends to the shared corpus (single-tenant).
+    Production would isolate by session/user.
+    """
+    import re
+    import tempfile
+    import time as _time
+    from pathlib import Path as _PathLib
+
+    t0 = _time.time()
+    contents = await file.read()
+    if not contents.startswith(b"%PDF"):
+        raise HTTPException(400, "File does not look like a PDF (magic bytes wrong).")
+    if len(contents) > 25 * 1024 * 1024:
+        raise HTTPException(413, "PDF too large (>25 MB). Use a smaller file.")
+
+    # Slugify filename for policy_id
+    raw = file.filename or "user_upload.pdf"
+    stem = _PathLib(raw).stem
+    slug = re.sub(r"[^a-zA-Z0-9]+", "-", stem.lower()).strip("-")[:80] or "user-upload"
+    policy_id = f"user-upload__{slug}"
+    policy_name = stem.replace("_", " ").replace("-", " ").title()
+
+    # Save to disk so ingest can read with pdfplumber
+    user_dir = settings.CORPUS_DIR / "user-upload"
+    user_dir.mkdir(parents=True, exist_ok=True)
+    out_path = user_dir / f"{slug}.pdf"
+    out_path.write_bytes(contents)
+
+    # Ingest just this one file
+    try:
+        from rag.ingest import chunk_pages, get_chroma_collection, read_pdf_pages
+        from backend.providers.local_embeddings import LocalEmbeddings as _Emb
+
+        pages = read_pdf_pages(out_path)
+        chunks = list(chunk_pages(pages))
+        if not chunks:
+            raise HTTPException(400, "Could not extract any text from the PDF (scanned image-only?).")
+
+        embedder = _Emb()
+        texts = [c["text"] for c in chunks]
+        vectors = await embedder.embed(texts, input_type="document")
+
+        ids = [f"{policy_id}::chunk{c['chunk_idx']}" for c in chunks]
+        metadatas = [
+            {
+                "policy_id": policy_id,
+                "insurer_slug": "user-upload",
+                "policy_name": policy_name,
+                "doc_type": "user_upload",
+                "source_url": "",
+                "page_start": c["page_start"],
+                "page_end": c["page_end"],
+                "chunk_idx": c["chunk_idx"],
+                "local_path": str(out_path),
+            }
+            for c in chunks
+        ]
+        collection = get_chroma_collection()
+        # Remove any existing chunks under this policy_id (re-upload case)
+        try:
+            collection.delete(where={"policy_id": policy_id})
+        except Exception:
+            pass
+        collection.add(ids=ids, documents=texts, embeddings=vectors, metadatas=metadatas)
+    except HTTPException:
+        raise
+    except Exception as e:
+        raise HTTPException(500, f"Indexing failed: {type(e).__name__}: {e}")
+
+    return UploadResponse(
+        policy_id=policy_id,
+        policy_name=policy_name,
+        chunks_added=len(chunks),
+        pages_indexed=len(pages),
+        elapsed_ms=int((_time.time() - t0) * 1000),
+    )
+
+
 @app.post("/api/tts")
 async def tts(req: TTSRequest):
     """Standalone TTS endpoint — returns base64 WAV."""

backend/orchestrator.py

@@ -26,7 +26,19 @@ from rag.retrieve import RetrievedChunk, format_for_llm_context, retrieve
 
 # ---------- intent classification (v1: keyword heuristics) ----------
 
-COMPARISON_KEYWORDS = ("compare", "comparison", "vs", "versus", "between", "better")
+# Fact-find triggers: conversational openers where the user is seeking advice,
+# not asking a specific factual question about a known policy. These should
+# bypass retrieval+faithfulness entirely and start the discovery flow.
+FACT_FIND_TRIGGERS = (
+    "looking for", "i want", "i need", "help me find", "advice",
+    "first time", "new health insurance", "buy health insurance",
+    "should i get", "shopping for", "thinking about getting",
+    "want to buy", "best policy for me", "what do you recommend",
+    "i don't have", "no policy", "no insurance",
+    "hi", "hello", "hey", "namaste",
+)
+
+COMPARISON_KEYWORDS = ("compare", "comparison", "vs", "versus", "between policy", "which is better")
 RECOMMEND_KEYWORDS = ("recommend", "should i", "which one", "best for", "suit me")
 INDIC_KEYWORDS = (
     # Devanagari letters
@@ -37,7 +49,10 @@ INDIC_KEYWORDS = (
 
 
 def classify_intent(query: str) -> str:
-    q = query.lower()
+    q = query.lower().strip()
+    # Greeting / advice-seeking openers → fact-find flow
+    if any(kw in q for kw in FACT_FIND_TRIGGERS) and len(q.split()) < 25:
+        return "fact_find"
     if any(kw in q for kw in COMPARISON_KEYWORDS):
         return "comparison"
     if any(kw in q for kw in RECOMMEND_KEYWORDS):
@@ -108,6 +123,36 @@ async def handle_turn(
     intent = classify_intent(user_text)
     language = detect_language(user_text)
 
+    # 1a. Fact-find branch — conversational openers / advice-seeking queries
+    # bypass retrieval + faithfulness; we ask the next discovery question.
+    if intent == "fact_find":
+        from backend.needs_finder import Profile, next_question
+        profile = Profile()
+        if user_profile:
+            for k, v in user_profile.items():
+                if hasattr(profile, k):
+                    setattr(profile, k, v)
+        q = next_question(profile, language=language)
+        if q is not None:
+            opener_en = "Happy to help. " if "hi" not in user_text.lower()[:3] else "Hi! "
+            opener_hi = "मदद के लिए तैयार हूँ। "
+            reply = (opener_hi + q.prompt_hi) if language == "indic" else (opener_en + q.prompt_en)
+        else:
+            reply = ("Great — sounds like you've thought through your needs. "
+                     "Want to ask about a specific policy, or have me compare a few for your profile?")
+        return TurnResult(
+            reply_text=reply,
+            citations=[],
+            retrieved_chunk_ids=[],
+            brain_used="needs_finder::fact_find",
+            intent=intent,
+            language=language,
+            latency_ms=int((time.time() - t0) * 1000),
+            raw_reply=reply,
+            faithfulness_passed=True,
+            blocked=False,
+        )
+
     # 2. Retrieve
     chunks: list[RetrievedChunk] = await retrieve(
         query=user_text,

eval/verified_urls.json

@@ -0,0 +1,432 @@
+{
+  "verified_at": "2026-05-12T23:00:21Z",
+  "insurer_summary": {
+    "total": 10,
+    "ok": 7
+  },
+  "policy_summary": {
+    "total": 30,
+    "ok": 30
+  },
+  "insurers": {
+    "icici-lombard": {
+      "url": "https://www.icicilombard.com/",
+      "ok": false,
+      "status": 403,
+      "method": "GET-range",
+      "final_url": "https://www.icicilombard.com/",
+      "content_type": "text/html",
+      "name": "ICICI Lombard General Insurance"
+    },
+    "bajaj-allianz": {
+      "url": "https://www.bajajallianz.com/",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://www.bajajgeneralinsurance.com/",
+      "content_type": "text/html;charset=utf-8",
+      "name": "Bajaj Allianz General Insurance"
+    },
+    "niva-bupa": {
+      "url": "https://www.nivabupa.com/",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://www.nivabupa.com/",
+      "content_type": "text/html; charset=utf-8",
+      "name": "Niva Bupa Health Insurance"
+    },
+    "care-health": {
+      "url": "https://www.careinsurance.com/",
+      "ok": false,
+      "status": 403,
+      "method": "GET-range",
+      "final_url": "https://www.careinsurance.com/",
+      "content_type": "text/html;charset=utf-8",
+      "name": "Care Health Insurance"
+    },
+    "hdfc-ergo": {
+      "url": "https://www.hdfcergo.com/",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://www.hdfcergo.com/",
+      "content_type": "text/html; charset=utf-8",
+      "name": "HDFC ERGO General Insurance"
+    },
+    "aditya-birla": {
+      "url": "https://www.adityabirlacapital.com/healthinsurance",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://www.adityabirlacapital.com/healthinsurance/",
+      "content_type": "text/html; charset=UTF-8",
+      "name": "Aditya Birla Health Insurance"
+    },
+    "tata-aig": {
+      "url": "https://www.tataaig.com/",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://www.tataaig.com/",
+      "content_type": "text/html; charset=utf-8",
+      "name": "Tata AIG General Insurance"
+    },
+    "manipalcigna": {
+      "url": "https://www.manipalcigna.com/",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://www.manipalcigna.com/",
+      "content_type": "text/html; charset=utf-8",
+      "name": "ManipalCigna Health Insurance"
+    },
+    "new-india": {
+      "url": "https://www.newindia.co.in/",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://www.newindia.co.in/",
+      "content_type": "text/html; charset=utf-8",
+      "name": "New India Assurance"
+    },
+    "star-health": {
+      "url": "https://www.starhealth.in/",
+      "ok": false,
+      "error": "ReadTimeout: HTTPSConnectionPool(host='www.starhealth.in', port=443): Read timed out. (read timeout=12.0)",
+      "name": "Star Health & Allied Insurance"
+    }
+  },
+  "policy_urls": [
+    {
+      "url": "https://www.hdfcergo.com/documents/downloads/HEHI/Presales-Set-2/OR-Brochure-Revision-V2.pdf",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://www.hdfcergo.com/documents/downloads/HEHI/Presales-Set-2/OR-Brochure-Revision-V2.pdf",
+      "content_type": "application/pdf",
+      "policy_name": "Optima Restore",
+      "insurer_slug": "hdfc-ergo",
+      "doc_type": "brochure"
+    },
+    {
+      "url": "https://www.hdfcergo.com/docs/default-source/downloads/policy-wordings/health/optima-secure-revision-pw.pdf",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://www.hdfcergo.com/docs/default-source/downloads/policy-wordings/health/optima-secure-revision-pw.pdf",
+      "content_type": "application/pdf",
+      "policy_name": "my:Optima Secure",
+      "insurer_slug": "hdfc-ergo",
+      "doc_type": "wordings"
+    },
+    {
+      "url": "https://www.hdfcergo.com/docs/default-source/downloads/policy-wordings/others/optima-enhance-policy-wording.pdf",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://www.hdfcergo.com/docs/default-source/downloads/policy-wordings/others/optima-enhance-policy-wording.pdf",
+      "content_type": "application/pdf",
+      "policy_name": "Optima Enhance",
+      "insurer_slug": "hdfc-ergo",
+      "doc_type": "wordings"
+    },
+    {
+      "url": "https://www.hdfcergo.com/docs/default-source/downloads/policy-wordings/health/my-optima-secure_old_pws.pdf",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://www.hdfcergo.com/docs/default-source/downloads/policy-wordings/health/my-optima-secure_old_pws.pdf",
+      "content_type": "application/pdf",
+      "policy_name": "my:Optima Secure (older variant)",
+      "insurer_slug": "hdfc-ergo",
+      "doc_type": "wordings"
+    },
+    {
+      "url": "https://www.hdfcergo.com/docs/default-source/downloads/policy-wordings/others/policy-wordings---prime---hrc.pdf",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://www.hdfcergo.com/docs/default-source/downloads/policy-wordings/others/policy-wordings---prime---hrc.pdf",
+      "content_type": "application/pdf",
+      "policy_name": "my:health Medisure Prime",
+      "insurer_slug": "hdfc-ergo",
+      "doc_type": "wordings"
+    },
+    {
+      "url": "https://www.hdfcergo.com/docs/default-source/downloads/policy-wordings/health/optima-plus-policy-wordings.pdf",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://www.hdfcergo.com/docs/default-source/downloads/policy-wordings/health/optima-plus-policy-wordings.pdf",
+      "content_type": "application/pdf",
+      "policy_name": "Optima Plus",
+      "insurer_slug": "hdfc-ergo",
+      "doc_type": "wordings"
+    },
+    {
+      "url": "https://www.hdfcergo.com/docs/default-source/downloads/prospectus/health/my_sampoorna_suraksha.pdf",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://www.hdfcergo.com/docs/default-source/downloads/prospectus/health/my_sampoorna_suraksha.pdf",
+      "content_type": "application/pdf",
+      "policy_name": "my:health Sampoorna Suraksha",
+      "insurer_slug": "hdfc-ergo",
+      "doc_type": "brochure"
+    },
+    {
+      "url": "https://www.hdfcergo.com/docs/default-source/downloads/policy-wordings/health/energy-combined-pw-cis.pdf",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://www.hdfcergo.com/docs/default-source/downloads/policy-wordings/health/energy-combined-pw-cis.pdf",
+      "content_type": "application/pdf",
+      "policy_name": "Energy (Diabetes/Hypertension)",
+      "insurer_slug": "hdfc-ergo",
+      "doc_type": "wordings"
+    },
+    {
+      "url": "https://www.hdfcergo.com/docs/default-source/downloads/policy-wordings/health/group-health-insurance---pw.pdf",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://www.hdfcergo.com/docs/default-source/downloads/policy-wordings/health/group-health-insurance---pw.pdf",
+      "content_type": "application/pdf",
+      "policy_name": "Group Health Insurance",
+      "insurer_slug": "hdfc-ergo",
+      "doc_type": "wordings"
+    },
+    {
+      "url": "https://www.hdfcergo.com/docs/default-source/downloads/prospectus/health/myhealth-suraksha---prospectus.pdf",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://www.hdfcergo.com/docs/default-source/downloads/prospectus/health/myhealth-suraksha---prospectus.pdf",
+      "content_type": "application/pdf",
+      "policy_name": "my:health Suraksha",
+      "insurer_slug": "hdfc-ergo",
+      "doc_type": "brochure"
+    },
+    {
+      "url": "https://www.hdfcergo.com/docs/default-source/downloads/brochures/myhealth-women-suraksha-with-premium-table.pdf",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://www.hdfcergo.com/docs/default-source/downloads/brochures/myhealth-women-suraksha-with-premium-table.pdf",
+      "content_type": "application/pdf",
+      "policy_name": "my:health Women Suraksha",
+      "insurer_slug": "hdfc-ergo",
+      "doc_type": "brochure"
+    },
+    {
+      "url": "https://www.hdfcergo.com/docs/default-source/downloads/policy-wordings/health/total-health-plan--oct-2021.pdf",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://www.hdfcergo.com/docs/default-source/downloads/policy-wordings/health/total-health-plan--oct-2021.pdf",
+      "content_type": "application/pdf",
+      "policy_name": "Total Health Plan",
+      "insurer_slug": "hdfc-ergo",
+      "doc_type": "wordings"
+    },
+    {
+      "url": "https://transactions.nivabupa.com/pages/doc/brochure/Health_Companion_V2022_Br.pdf?v=1.1",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://transactions.nivabupa.com/pages/doc/brochure/Health_Companion_V2022_Br.pdf?v=1.1",
+      "content_type": "application/pdf",
+      "policy_name": "Health Companion V2022",
+      "insurer_slug": "niva-bupa",
+      "doc_type": "brochure"
+    },
+    {
+      "url": "https://transactions.nivabupa.com/pages/doc/policy_wording/ReAssure-2.0-Policy-Wording.pdf",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://transactions.nivabupa.com/pages/doc/policy_wording/ReAssure-2.0-Policy-Wording.pdf",
+      "content_type": "application/pdf",
+      "policy_name": "ReAssure 2.0",
+      "insurer_slug": "niva-bupa",
+      "doc_type": "wordings"
+    },
+    {
+      "url": "https://transactions.nivabupa.com/pages/doc/policy_wording/Rise_Policy_Wordings.pdf",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://transactions.nivabupa.com/pages/doc/policy_wording/Rise_Policy_Wordings.pdf",
+      "content_type": "application/pdf",
+      "policy_name": "RISE",
+      "insurer_slug": "niva-bupa",
+      "doc_type": "wordings"
+    },
+    {
+      "url": "https://transactions.nivabupa.com/pages/doc/policy_wording/ReAssure30_Policy_Wordings.pdf",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://transactions.nivabupa.com/pages/doc/policy_wording/ReAssure30_Policy_Wordings.pdf",
+      "content_type": "application/pdf",
+      "policy_name": "ReAssure 3.0",
+      "insurer_slug": "niva-bupa",
+      "doc_type": "wordings"
+    },
+    {
+      "url": "https://transactions.nivabupa.com/pages/doc/policy_wording/Aspire_Policy_Wordings.pdf?v=1.3",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://transactions.nivabupa.com/pages/doc/policy_wording/Aspire_Policy_Wordings.pdf?v=1.3",
+      "content_type": "application/pdf",
+      "policy_name": "Aspire",
+      "insurer_slug": "niva-bupa",
+      "doc_type": "wordings"
+    },
+    {
+      "url": "https://www.nivabupa.com/content/dam/nivabupa/PDF/health-companion-policy-wording.pdf",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://www.nivabupa.com/content/dam/nivabupa/PDF/health-companion-policy-wording.pdf",
+      "content_type": "application/pdf",
+      "policy_name": "Health Companion",
+      "insurer_slug": "niva-bupa",
+      "doc_type": "wordings"
+    },
+    {
+      "url": "https://cms.careinsurance.com/cms/public/uploads/download_center/care-supreme---policy-terms-and-conditions.pdf",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://cms.careinsurance.com/cms/public/uploads/download_center/care-supreme---policy-terms-and-conditions.pdf",
+      "content_type": "application/pdf",
+      "policy_name": "Care Supreme",
+      "insurer_slug": "care-health",
+      "doc_type": "wordings"
+    },
+    {
+      "url": "https://transactions.nivabupa.com/pages/doc/policy_wording/Healthplus_Policy_Wordings.pdf?v=1.2",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://transactions.nivabupa.com/pages/doc/policy_wording/Healthplus_Policy_Wordings.pdf?v=1.2",
+      "content_type": "application/pdf",
+      "policy_name": "Health Plus (Top-up)",
+      "insurer_slug": "niva-bupa",
+      "doc_type": "wordings"
+    },
+    {
+      "url": "https://cms.careinsurance.com/cms/public/uploads/download_center/supreme-enhance---policy-terms-and-conditions.pdf",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://cms.careinsurance.com/cms/public/uploads/download_center/supreme-enhance---policy-terms-and-conditions.pdf",
+      "content_type": "application/pdf",
+      "policy_name": "Care Supreme Enhance",
+      "insurer_slug": "care-health",
+      "doc_type": "wordings"
+    },
+    {
+      "url": "https://cms.careinsurance.com/cms/public/uploads/download_center/supreme-enhance---brochure.pdf",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://cms.careinsurance.com/cms/public/uploads/download_center/supreme-enhance---brochure.pdf",
+      "content_type": "application/pdf",
+      "policy_name": "Supreme Enhance",
+      "insurer_slug": "care-health",
+      "doc_type": "brochure"
+    },
+    {
+      "url": "https://cms.careinsurance.com/cms/public/uploads/download_center/care-classic---(health-insurance-product)-policy-terms-&-conditions.pdf",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://cms.careinsurance.com/cms/public/uploads/download_center/care-classic---(health-insurance-product)-policy-terms-&-conditions.pdf",
+      "content_type": "application/pdf",
+      "policy_name": "Care Classic",
+      "insurer_slug": "care-health",
+      "doc_type": "wordings"
+    },
+    {
+      "url": "https://www.nivabupa.com/content/dam/nivabupa/PDF/health-premia/Health%20Premia%20Policy%20Wording.pdf",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://transactions.nivabupa.com/pages/doc/policy_wording/Health-Premia-Policy-Wording.pdf?v=1.0",
+      "content_type": "application/pdf",
+      "policy_name": "Health Premia",
+      "insurer_slug": "niva-bupa",
+      "doc_type": "wordings"
+    },
+    {
+      "url": "https://www.nivabupa.com/content/dam/nivabupa/PDF/senior-first/Senior_First_Policy_Wordings.pdf",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://www.nivabupa.com/content/dam/nivabupa/PDF/senior-first/Senior_First_Policy_Wordings.pdf",
+      "content_type": "application/pdf",
+      "policy_name": "Senior First",
+      "insurer_slug": "niva-bupa",
+      "doc_type": "wordings"
+    },
+    {
+      "url": "https://www.nivabupa.com/content/dam/nivabupa/PDF/Saral%20Suraksha%20Bima_Policy%20Wording.pdf",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://www.nivabupa.com/content/dam/nivabupa/PDF/Saral%20Suraksha%20Bima_Policy%20Wording.pdf",
+      "content_type": "application/pdf",
+      "policy_name": "Saral Suraksha Bima",
+      "insurer_slug": "niva-bupa",
+      "doc_type": "wordings"
+    },
+    {
+      "url": "https://cms.careinsurance.com/cms/public/uploads/download_center/ultimate-care-----policy-terms-&-conditions.pdf",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://cms.careinsurance.com/cms/public/uploads/download_center/ultimate-care-----policy-terms-&-conditions.pdf",
+      "content_type": "application/pdf",
+      "policy_name": "Ultimate Care",
+      "insurer_slug": "care-health",
+      "doc_type": "wordings"
+    },
+    {
+      "url": "https://cms.careinsurance.com/cms/public/uploads/download_center/care-senior-brochure.pdf",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://cms.careinsurance.com/cms/public/uploads/download_center/care-senior-brochure.pdf",
+      "content_type": "application/pdf",
+      "policy_name": "Care Senior",
+      "insurer_slug": "care-health",
+      "doc_type": "brochure"
+    },
+    {
+      "url": "https://cms.careinsurance.com/cms/public/uploads/download_center/care-advantage-(health-insurance-product)---brochure.pdf",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://cms.careinsurance.com/cms/public/uploads/download_center/care-advantage-(health-insurance-product)---brochure.pdf",
+      "content_type": "application/pdf",
+      "policy_name": "Care Advantage",
+      "insurer_slug": "care-health",
+      "doc_type": "brochure"
+    },
+    {
+      "url": "https://cms.careinsurance.com/cms/public/uploads/download_center/care-advantage-with-add-on-protect-plus-&-care-shield-brochure.pdf",
+      "ok": true,
+      "status": 200,
+      "method": "HEAD",
+      "final_url": "https://cms.careinsurance.com/cms/public/uploads/download_center/care-advantage-with-add-on-protect-plus-&-care-shield-brochure.pdf",
+      "content_type": "application/pdf",
+      "policy_name": "Care Advantage + add-ons (Protect Plus + Care Shield)",
+      "insurer_slug": "care-health",
+      "doc_type": "brochure"
+    }
+  ]
+}

frontend/src/app/page.tsx

@@ -5,9 +5,12 @@ import {
   audioBlobURLFromBase64,
   Citation,
   ChatMessage,
+  CoverageResponse,
+  getCoverage,
   getHealth,
   postChat,
   postTranscribe,
+  uploadPolicy,
 } from "@/lib/api";
 
 type DisplayMessage = ChatMessage & {
@@ -16,13 +19,14 @@ type DisplayMessage = ChatMessage & {
   audioUrl?: string;
   brain?: string;
   latencyMs?: number;
+  blocked?: boolean;
 };
 
 const SUGGESTED_QUESTIONS = [
+  "I'm looking for a new health insurance policy.",
   "What is the waiting period for pre-existing diseases?",
-  "Does HDFC ERGO Optima Secure cover ayurveda?",
-  "Compare maternity coverage across Star and Niva Bupa",
-  "What's the room rent cap on Care Health policies?",
+  "Does HDFC ERGO Optima Secure cover AYUSH?",
+  "What's the room rent cap on Care Supreme?",
 ];
 
 export default function Page() {
@@ -33,16 +37,23 @@ export default function Page() {
   const [returnAudio, setReturnAudio] = useState(true);
   const [ttsLang, setTtsLang] = useState<"en-IN" | "hi-IN">("en-IN");
   const [health, setHealth] = useState<{ status: string; missing: string[] } | null>(null);
+  const [coverage, setCoverage] = useState<CoverageResponse | null>(null);
+  const [showCoverage, setShowCoverage] = useState(false);
   const [sessionId, setSessionId] = useState<string | undefined>();
+  const [uploadStatus, setUploadStatus] = useState<string | null>(null);
 
   const mediaRecorderRef = useRef<MediaRecorder | null>(null);
   const audioChunksRef = useRef<Blob[]>([]);
+  const fileInputRef = useRef<HTMLInputElement>(null);
   const scrollRef = useRef<HTMLDivElement>(null);
 
   useEffect(() => {
     getHealth()
       .then((h) => setHealth({ status: h.status, missing: h.missing_keys }))
       .catch(() => setHealth({ status: "unreachable", missing: [] }));
+    getCoverage()
+      .then(setCoverage)
+      .catch(() => setCoverage(null));
   }, []);
 
   useEffect(() => {
@@ -50,15 +61,10 @@ export default function Page() {
   }, [messages]);
 
   function pushUser(text: string) {
-    const id = `u_${Date.now()}`;
-    setMessages((m) => [...m, { id, role: "user", content: text }]);
-    return id;
+    setMessages((m) => [...m, { id: `u_${Date.now()}`, role: "user", content: text }]);
   }
-
   function pushAssistant(content: string, extras: Partial<DisplayMessage> = {}) {
-    const id = `a_${Date.now()}`;
-    setMessages((m) => [...m, { id, role: "assistant", content, ...extras }]);
-    return id;
+    setMessages((m) => [...m, { id: `a_${Date.now()}`, role: "assistant", content, ...extras }]);
   }
 
   async function send(text: string) {
@@ -66,7 +72,6 @@ export default function Page() {
     setBusy(true);
     setInput("");
     pushUser(text);
-
     try {
       const history: ChatMessage[] = messages.map((m) => ({ role: m.role, content: m.content }));
       const res = await postChat({
@@ -83,14 +88,14 @@ export default function Page() {
         audioUrl,
         brain: res.brain_used,
         latencyMs: res.latency_ms,
+        blocked: res.blocked,
       });
       if (audioUrl) {
         const audio = new Audio(audioUrl);
         audio.play().catch(() => {});
       }
     } catch (e: unknown) {
-      const msg = e instanceof Error ? e.message : String(e);
-      pushAssistant(`Sorry — backend error: ${msg}`);
+      pushAssistant(`Sorry — backend error: ${e instanceof Error ? e.message : String(e)}`);
     } finally {
       setBusy(false);
     }
@@ -100,39 +105,24 @@ export default function Page() {
     try {
       const stream = await navigator.mediaDevices.getUserMedia({ audio: true });
       const mime = MediaRecorder.isTypeSupported("audio/webm") ? "audio/webm" : "";
-      const recorder = mime
-        ? new MediaRecorder(stream, { mimeType: mime })
-        : new MediaRecorder(stream);
+      const recorder = mime ? new MediaRecorder(stream, { mimeType: mime }) : new MediaRecorder(stream);
       mediaRecorderRef.current = recorder;
       audioChunksRef.current = [];
-
-      recorder.ondataavailable = (ev) => {
-        if (ev.data.size > 0) audioChunksRef.current.push(ev.data);
-      };
-
+      recorder.ondataavailable = (ev) => { if (ev.data.size > 0) audioChunksRef.current.push(ev.data); };
       recorder.onstop = async () => {
         stream.getTracks().forEach((t) => t.stop());
-        const blob = new Blob(audioChunksRef.current, {
-          type: recorder.mimeType || "audio/webm",
-        });
+        const blob = new Blob(audioChunksRef.current, { type: recorder.mimeType || "audio/webm" });
         setRecording(false);
         if (blob.size < 1000) return;
         setBusy(true);
         try {
           const { text } = await postTranscribe(blob, ttsLang);
-          if (text && text.trim()) {
-            await send(text);
-          } else {
-            pushAssistant("Sorry, I couldn't hear that clearly. Please try again.");
-          }
+          if (text && text.trim()) await send(text);
+          else pushAssistant("Sorry, I couldn't hear that clearly. Please try again.");
         } catch (e: unknown) {
-          const msg = e instanceof Error ? e.message : String(e);
-          pushAssistant(`Sorry — transcribe error: ${msg}`);
-        } finally {
-          setBusy(false);
-        }
+          pushAssistant(`Sorry — transcribe error: ${e instanceof Error ? e.message : String(e)}`);
+        } finally { setBusy(false); }
       };
-
       recorder.start();
       setRecording(true);
     } catch (e) {
@@ -140,78 +130,102 @@ export default function Page() {
       pushAssistant(`Sorry — mic permission denied or unavailable.`);
     }
   }
+  function stopRecording() { mediaRecorderRef.current?.stop(); }
 
-  function stopRecording() {
-    mediaRecorderRef.current?.stop();
+  async function handleFile(ev: React.ChangeEvent<HTMLInputElement>) {
+    const f = ev.target.files?.[0];
+    if (!f) return;
+    setUploadStatus(`Indexing ${f.name}…`);
+    try {
+      const r = await uploadPolicy(f);
+      setUploadStatus(`✓ Indexed "${r.policy_name}" — ${r.chunks_added} chunks from ${r.pages_indexed} pages (${(r.elapsed_ms / 1000).toFixed(1)}s). Ask me about it.`);
+      // Refresh coverage so the uploaded doc shows up
+      getCoverage().then(setCoverage).catch(() => {});
+    } catch (e: unknown) {
+      setUploadStatus(`✗ Upload failed: ${e instanceof Error ? e.message : String(e)}`);
+    } finally {
+      if (fileInputRef.current) fileInputRef.current.value = "";
+      setTimeout(() => setUploadStatus(null), 8000);
+    }
   }
 
   return (
     <div className="min-h-screen flex flex-col bg-[var(--background)] text-[var(--foreground)]">
-      {/* Header */}
       <header className="border-b border-[var(--border)] bg-[var(--card)]">
         <div className="max-w-6xl mx-auto px-4 sm:px-6 py-4 flex items-center justify-between">
           <div className="flex items-center gap-3">
-            <div className="w-9 h-9 rounded-lg bg-[var(--primary)] text-[var(--primary-foreground)] flex items-center justify-center font-bold text-sm">
-              IA
-            </div>
+            <div className="w-9 h-9 rounded-lg bg-[var(--primary)] text-[var(--primary-foreground)] flex items-center justify-center font-bold text-sm">IA</div>
             <div>
-              <h1 className="font-semibold text-base sm:text-lg leading-tight">
-                Insurance Sales Portfolio Expert
-              </h1>
-              <p className="text-xs text-[var(--muted-foreground)]">
-                Voice-first AI advisor • Indian health insurance • Sarvam AI
-              </p>
+              <h1 className="font-semibold text-base sm:text-lg leading-tight">Insurance Sales Portfolio Expert</h1>
+              <p className="text-xs text-[var(--muted-foreground)]">Voice-first AI advisor · Indian health insurance · Sarvam AI</p>
             </div>
           </div>
           <div className="flex items-center gap-3">
+            {coverage && (
+              <button
+                onClick={() => setShowCoverage(!showCoverage)}
+                className="text-xs px-3 py-1.5 rounded-lg border border-[var(--border)] hover:border-[var(--primary)] transition"
+              >
+                {coverage.total_policies} policies · {coverage.total_insurers} insurers
+              </button>
+            )}
             <HealthBadge health={health} />
           </div>
         </div>
+        {showCoverage && coverage && <CoveragePanel coverage={coverage} onClose={() => setShowCoverage(false)} />}
       </header>
 
-      {/* Main */}
       <main className="flex-1 max-w-6xl w-full mx-auto px-4 sm:px-6 py-4 sm:py-6 flex flex-col">
         {messages.length === 0 ? (
-          <EmptyState onSuggest={(q) => send(q)} />
+          <EmptyState onSuggest={(q) => send(q)} coverage={coverage} />
         ) : (
-          <div
-            ref={scrollRef}
-            className="flex-1 overflow-y-auto scrollbar-thin space-y-4 mb-4 pr-1"
-          >
-            {messages.map((m) => (
-              <Message key={m.id} m={m} />
-            ))}
+          <div ref={scrollRef} className="flex-1 overflow-y-auto scrollbar-thin space-y-4 mb-4 pr-1">
+            {messages.map((m) => <Message key={m.id} m={m} />)}
             {busy && <ThinkingDots />}
           </div>
         )}
 
-        {/* Input bar */}
+        {uploadStatus && (
+          <div className="mb-3 text-xs px-3 py-2 rounded-lg bg-[var(--accent)] border border-[var(--border)] text-[var(--foreground)]">
+            {uploadStatus}
+          </div>
+        )}
+
         <div className="border border-[var(--border)] rounded-2xl bg-[var(--card)] p-3 shadow-sm">
           <div className="flex items-end gap-2">
             <textarea
               value={input}
               onChange={(e) => setInput(e.target.value)}
-              onKeyDown={(e) => {
-                if (e.key === "Enter" && !e.shiftKey) {
-                  e.preventDefault();
-                  send(input);
-                }
-              }}
+              onKeyDown={(e) => { if (e.key === "Enter" && !e.shiftKey) { e.preventDefault(); send(input); } }}
               placeholder="Ask about coverage, waiting periods, exclusions, or compare policies…"
               rows={1}
               className="flex-1 resize-none bg-transparent outline-none text-sm sm:text-base px-2 py-2 min-h-[40px] max-h-32"
               disabled={busy}
             />
+            <input
+              ref={fileInputRef}
+              type="file"
+              accept="application/pdf"
+              onChange={handleFile}
+              className="hidden"
+            />
+            <button
+              type="button"
+              onClick={() => fileInputRef.current?.click()}
+              disabled={busy || !!uploadStatus}
+              title="Upload your own policy PDF"
+              className="shrink-0 w-11 h-11 rounded-xl flex items-center justify-center bg-[var(--muted)] hover:bg-[var(--border)] disabled:opacity-40 transition"
+            >
+              <UploadIcon />
+            </button>
             <button
               type="button"
               onClick={recording ? stopRecording : startRecording}
               disabled={busy && !recording}
               className={`shrink-0 w-11 h-11 rounded-xl flex items-center justify-center transition-all ${
-                recording
-                  ? "bg-[var(--error)] text-white animate-record-pulse"
-                  : "bg-[var(--muted)] hover:bg-[var(--border)] text-[var(--foreground)]"
+                recording ? "bg-[var(--error)] text-white animate-record-pulse" : "bg-[var(--muted)] hover:bg-[var(--border)]"
               } disabled:opacity-40`}
-              title={recording ? "Stop recording" : "Click to record (push-to-talk)"}
+              title={recording ? "Stop recording" : "Voice input"}
             >
               {recording ? <StopIcon /> : <MicIcon />}
             </button>
@@ -224,72 +238,100 @@ export default function Page() {
               Send
             </button>
           </div>
-
-          {/* Settings row */}
           <div className="flex items-center justify-between gap-3 mt-2 pt-2 px-2 text-xs text-[var(--muted-foreground)]">
             <div className="flex items-center gap-3">
               <label className="flex items-center gap-1.5 cursor-pointer">
-                <input
-                  type="checkbox"
-                  checked={returnAudio}
-                  onChange={(e) => setReturnAudio(e.target.checked)}
-                  className="w-3.5 h-3.5 accent-[var(--primary)]"
-                />
-                Voice reply
+                <input type="checkbox" checked={returnAudio} onChange={(e) => setReturnAudio(e.target.checked)} className="w-3.5 h-3.5 accent-[var(--primary)]" /> Voice reply
               </label>
               <label className="flex items-center gap-1.5">
                 Lang:
-                <select
-                  value={ttsLang}
-                  onChange={(e) => setTtsLang(e.target.value as "en-IN" | "hi-IN")}
-                  className="bg-transparent border border-[var(--border)] rounded px-1.5 py-0.5"
-                >
+                <select value={ttsLang} onChange={(e) => setTtsLang(e.target.value as "en-IN" | "hi-IN")} className="bg-transparent border border-[var(--border)] rounded px-1.5 py-0.5">
                   <option value="en-IN">English</option>
                   <option value="hi-IN">हिन्दी</option>
                 </select>
               </label>
             </div>
-            <div className="hidden sm:block">Enter to send · Shift+Enter for newline</div>
+            <div className="hidden sm:block">Enter to send · 📎 to upload your own PDF</div>
           </div>
         </div>
       </main>
 
       <footer className="border-t border-[var(--border)] py-3 px-6 text-center text-xs text-[var(--muted-foreground)]">
-        Sarvam-M · Sarvam Saarika STT · Sarvam Bulbul TTS · Voyage embeddings · Llama-3.3-70B grader · DeepSeek-V3 fallback brain. Advisory only — verify with the insurer before purchase.
+        Sarvam-M · Sarvam Saarika STT · Sarvam Bulbul TTS · Voyage-prepared embeddings · Llama-3.3-70B grader · DeepSeek-V3 fallback brain. Advisory only — verify with the insurer before purchase.
       </footer>
     </div>
   );
 }
 
+function CoveragePanel({ coverage, onClose }: { coverage: CoverageResponse; onClose: () => void }) {
+  return (
+    <div className="border-t border-[var(--border)] bg-[var(--muted)]">
+      <div className="max-w-6xl mx-auto px-4 sm:px-6 py-4">
+        <div className="flex items-baseline justify-between mb-3">
+          <h2 className="text-sm font-semibold">What this bot can answer questions about</h2>
+          <button onClick={onClose} className="text-xs text-[var(--muted-foreground)] hover:underline">close</button>
+        </div>
+        <p className="text-xs text-[var(--muted-foreground)] mb-3">
+          {coverage.total_policies} policies · {coverage.total_chunks.toLocaleString()} indexed text chunks · {coverage.total_insurers} insurers. Click any insurer to open their site; click a policy to open its PDF.
+        </p>
+        <div className="grid grid-cols-1 sm:grid-cols-2 lg:grid-cols-3 gap-3">
+          {coverage.insurers.map((ins) => (
+            <div key={ins.slug} className="bg-[var(--card)] border border-[var(--border)] rounded-xl p-3 text-xs">
+              <a
+                href={ins.home_url || "#"}
+                target="_blank"
+                rel="noopener"
+                className="font-semibold text-[var(--foreground)] hover:text-[var(--primary)] block mb-1.5"
+              >
+                {ins.name} <span className="opacity-50 font-normal">· {ins.policy_count}</span>
+              </a>
+              <ul className="space-y-0.5">
+                {ins.sample_policies.map((p, i) => (
+                  <li key={i} className="text-[var(--muted-foreground)]">
+                    {p.source_url ? (
+                      <a href={p.source_url} target="_blank" rel="noopener" className="hover:text-[var(--primary)] hover:underline">
+                        {p.name}
+                      </a>
+                    ) : (
+                      <span>{p.name}</span>
+                    )}
+                  </li>
+                ))}
+              </ul>
+            </div>
+          ))}
+        </div>
+      </div>
+    </div>
+  );
+}
+
 function HealthBadge({ health }: { health: { status: string; missing: string[] } | null }) {
   if (!health) return <span className="text-xs text-[var(--muted-foreground)]">checking…</span>;
   const ok = health.status === "ok";
   return (
     <div className="flex items-center gap-1.5 text-xs">
-      <span
-        className={`w-2 h-2 rounded-full ${
-          ok ? "bg-emerald-500" : health.status === "unreachable" ? "bg-red-500" : "bg-amber-500"
-        }`}
-      />
+      <span className={`w-2 h-2 rounded-full ${ok ? "bg-emerald-500" : health.status === "unreachable" ? "bg-red-500" : "bg-amber-500"}`} />
       <span className="text-[var(--muted-foreground)]">
-        {ok ? "all systems healthy" : health.status === "unreachable" ? "backend unreachable" : `degraded (${health.missing.join(", ")})`}
+        {ok ? "healthy" : health.status === "unreachable" ? "backend unreachable" : `degraded`}
       </span>
     </div>
   );
 }
 
-function EmptyState({ onSuggest }: { onSuggest: (q: string) => void }) {
+function EmptyState({ onSuggest, coverage }: { onSuggest: (q: string) => void; coverage: CoverageResponse | null }) {
   return (
     <div className="flex-1 flex flex-col items-center justify-center text-center px-4">
-      <div className="w-16 h-16 rounded-2xl bg-[var(--primary)] text-[var(--primary-foreground)] flex items-center justify-center text-2xl font-bold mb-6">
-        IA
-      </div>
-      <h2 className="text-xl sm:text-2xl font-semibold mb-2">
-        Hi, I&apos;m your AI insurance advisor.
-      </h2>
-      <p className="text-sm text-[var(--muted-foreground)] max-w-md mb-6">
-        Ask me about Indian health insurance policies — coverage, waiting periods, exclusions, side-by-side comparisons. Speak or type, English or हिन्दी. Every fact comes with a citation.
+      <div className="w-16 h-16 rounded-2xl bg-[var(--primary)] text-[var(--primary-foreground)] flex items-center justify-center text-2xl font-bold mb-6">IA</div>
+      <h2 className="text-xl sm:text-2xl font-semibold mb-2">Hi, I&apos;m your AI insurance advisor.</h2>
+      <p className="text-sm text-[var(--muted-foreground)] max-w-md mb-3">
+        Ask me about Indian health insurance — coverage, waiting periods, exclusions, side-by-side comparisons. Speak or type, English or हिन्दी. Every fact comes with a citation.
       </p>
+      {coverage && (
+        <p className="text-xs text-[var(--muted-foreground)] mb-6">
+          Currently covering <span className="font-semibold text-[var(--foreground)]">{coverage.total_policies} policies</span> from <span className="font-semibold text-[var(--foreground)]">{coverage.total_insurers} insurers</span>. Have a different PDF? <span className="font-semibold">Click the 📎 icon to upload.</span>
+        </p>
+      )}
       <div className="grid grid-cols-1 sm:grid-cols-2 gap-2 w-full max-w-2xl">
         {SUGGESTED_QUESTIONS.map((q, i) => (
           <button
@@ -309,35 +351,16 @@ function Message({ m }: { m: DisplayMessage }) {
   const isUser = m.role === "user";
   return (
     <div className={`flex animate-fade-up ${isUser ? "justify-end" : "justify-start"}`}>
-      <div
-        className={`max-w-[85%] sm:max-w-[75%] rounded-2xl px-4 py-3 ${
-          isUser
-            ? "bg-[var(--primary)] text-[var(--primary-foreground)]"
-            : "bg-[var(--card)] border border-[var(--border)]"
-        }`}
-      >
+      <div className={`max-w-[85%] sm:max-w-[75%] rounded-2xl px-4 py-3 ${
+        isUser ? "bg-[var(--primary)] text-[var(--primary-foreground)]" : "bg-[var(--card)] border border-[var(--border)]"
+      } ${m.blocked ? "ring-1 ring-amber-300" : ""}`}>
         <div className="text-sm sm:text-base whitespace-pre-wrap leading-relaxed">{m.content}</div>
-        {m.audioUrl && (
-          <audio
-            controls
-            src={m.audioUrl}
-            className="mt-2 w-full max-w-xs"
-            style={{ height: 32 }}
-          />
-        )}
+        {m.audioUrl && <audio controls src={m.audioUrl} className="mt-2 w-full max-w-xs" style={{ height: 32 }} />}
         {m.citations && m.citations.length > 0 && (
           <div className="mt-3 pt-3 border-t border-[var(--border)] space-y-1.5">
-            <div className="text-[10px] uppercase tracking-wide text-[var(--muted-foreground)] font-semibold">
-              Sources
-            </div>
+            <div className="text-[10px] uppercase tracking-wide text-[var(--muted-foreground)] font-semibold">Sources</div>
             {m.citations.slice(0, 5).map((c, i) => (
-              <a
-                key={i}
-                href={c.source_url || "#"}
-                target="_blank"
-                rel="noopener"
-                className="block text-xs text-[var(--muted-foreground)] hover:text-[var(--primary)] transition"
-              >
+              <a key={i} href={c.source_url || "#"} target="_blank" rel="noopener" className="block text-xs text-[var(--muted-foreground)] hover:text-[var(--primary)] transition">
                 <span className="font-medium">{c.policy_name}</span>
                 <span className="opacity-60"> · {c.insurer_slug} · p.{c.page_start}</span>
                 <span className="opacity-50"> · score {c.score.toFixed(2)}</span>
@@ -345,11 +368,7 @@ function Message({ m }: { m: DisplayMessage }) {
             ))}
           </div>
         )}
-        {m.brain && (
-          <div className="mt-2 text-[10px] text-[var(--muted-foreground)] opacity-60">
-            {m.brain} · {m.latencyMs}ms
-          </div>
-        )}
+        {m.brain && (<div className="mt-2 text-[10px] text-[var(--muted-foreground)] opacity-60">{m.brain} · {m.latencyMs}ms</div>)}
       </div>
     </div>
   );
@@ -361,14 +380,7 @@ function ThinkingDots() {
       <div className="bg-[var(--card)] border border-[var(--border)] rounded-2xl px-4 py-3">
         <div className="flex gap-1.5">
           {[0, 1, 2].map((i) => (
-            <span
-              key={i}
-              className="w-2 h-2 rounded-full bg-[var(--muted-foreground)] opacity-50"
-              style={{
-                animation: "fade-up 1.2s ease-in-out infinite",
-                animationDelay: `${i * 0.2}s`,
-              }}
-            />
+            <span key={i} className="w-2 h-2 rounded-full bg-[var(--muted-foreground)] opacity-50" style={{ animation: "fade-up 1.2s ease-in-out infinite", animationDelay: `${i * 0.2}s` }} />
           ))}
         </div>
       </div>
@@ -377,20 +389,22 @@ function ThinkingDots() {
 }
 
 function MicIcon() {
-  return (
-    <svg width="20" height="20" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="2">
-      <path d="M12 1a3 3 0 0 0-3 3v8a3 3 0 0 0 6 0V4a3 3 0 0 0-3-3z" />
-      <path d="M19 10v2a7 7 0 0 1-14 0v-2" />
-      <line x1="12" y1="19" x2="12" y2="23" />
-      <line x1="8" y1="23" x2="16" y2="23" />
-    </svg>
-  );
+  return (<svg width="20" height="20" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="2">
+    <path d="M12 1a3 3 0 0 0-3 3v8a3 3 0 0 0 6 0V4a3 3 0 0 0-3-3z" />
+    <path d="M19 10v2a7 7 0 0 1-14 0v-2" />
+    <line x1="12" y1="19" x2="12" y2="23" />
+    <line x1="8" y1="23" x2="16" y2="23" />
+  </svg>);
 }
 
 function StopIcon() {
-  return (
-    <svg width="18" height="18" viewBox="0 0 24 24" fill="currentColor">
-      <rect x="6" y="6" width="12" height="12" rx="2" />
-    </svg>
-  );
+  return (<svg width="18" height="18" viewBox="0 0 24 24" fill="currentColor"><rect x="6" y="6" width="12" height="12" rx="2" /></svg>);
+}
+
+function UploadIcon() {
+  return (<svg width="20" height="20" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="2">
+    <path d="M21 15v4a2 2 0 0 1-2 2H5a2 2 0 0 1-2-2v-4" />
+    <polyline points="17 8 12 3 7 8" />
+    <line x1="12" y1="3" x2="12" y2="15" />
+  </svg>);
 }

frontend/src/lib/api.ts

@@ -26,6 +26,9 @@ export type ChatResponse = {
   latency_ms: number;
   session_id: string;
   audio_base64?: string | null;
+  faithfulness_passed?: boolean;
+  faithfulness_reasons?: string[];
+  blocked?: boolean;
 };
 
 export type ChatMessage = {
@@ -100,6 +103,54 @@ export async function getHealth(): Promise<{
   return resp.json();
 }
 
+export type PolicyEntry = {
+  name: string;
+  source_url: string;
+};
+
+export type CoverageInsurer = {
+  slug: string;
+  name: string;
+  home_url: string;
+  policy_count: number;
+  sample_policies: PolicyEntry[];
+};
+
+export type CoverageResponse = {
+  total_chunks: number;
+  total_policies: number;
+  total_insurers: number;
+  insurers: CoverageInsurer[];
+};
+
+export async function getCoverage(): Promise<CoverageResponse> {
+  const resp = await fetch(`${BACKEND_URL}/api/coverage`);
+  if (!resp.ok) throw new Error(`coverage failed: ${resp.status}`);
+  return resp.json();
+}
+
+export type UploadResponse = {
+  policy_id: string;
+  policy_name: string;
+  chunks_added: number;
+  pages_indexed: number;
+  elapsed_ms: number;
+};
+
+export async function uploadPolicy(file: File): Promise<UploadResponse> {
+  const fd = new FormData();
+  fd.append("file", file);
+  const resp = await fetch(`${BACKEND_URL}/api/upload-policy`, {
+    method: "POST",
+    body: fd,
+  });
+  if (!resp.ok) {
+    const t = await resp.text();
+    throw new Error(`upload failed: ${resp.status} ${t}`);
+  }
+  return resp.json();
+}
+
 // Decode a base64 string to a playable audio Blob URL.
 export function audioBlobURLFromBase64(b64: string, mime = "audio/wav"): string {
   const bin = atob(b64);

rag/vectors/chroma.sqlite3

@@ -1,3 +1,3 @@
 version https://git-lfs.github.com/spec/v1
-oid sha256:046dda5d699f5975831d6ee8ab1e0864c4bbd73096302ad271610140233e86ee
+oid sha256:5baf3213403a2991d2c6ed70cc36d7295966a213cef4b445a48088a6106f7b91
 size 72695808

tools/verify_urls.py

@@ -0,0 +1,135 @@
+"""Verify every URL we expose to users is real (200) and reachable.
+
+Two sets of URLs:
+  1. Insurer home URLs (10) — curated from corpus discovery agent's report
+  2. Policy PDF URLs — from rag/corpus/_manifest.json (already verified at
+     download time, but URLs can rot, so we re-check)
+
+Outputs:
+  - eval/verified_urls.json — per-URL status, last_checked timestamp
+  - prints summary table
+
+Run:
+  python tools/verify_urls.py
+"""
+
+from __future__ import annotations
+
+import json
+import time
+from concurrent.futures import ThreadPoolExecutor, as_completed
+from pathlib import Path
+
+import requests
+
+ROOT = Path(__file__).resolve().parent.parent
+MANIFEST = ROOT / "rag" / "corpus" / "_manifest.json"
+OUTPUT = ROOT / "eval" / "verified_urls.json"
+
+HEADERS = {
+    "User-Agent": (
+        "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) "
+        "AppleWebKit/537.36 (KHTML, like Gecko) Chrome/124.0 Safari/537.36"
+    ),
+    "Accept": "*/*",
+}
+
+# Insurer home URLs — curated, public, primary domains.
+INSURER_HOME_URLS = {
+    "star-health": ("Star Health & Allied Insurance", "https://www.starhealth.in/"),
+    "hdfc-ergo": ("HDFC ERGO General Insurance", "https://www.hdfcergo.com/"),
+    "niva-bupa": ("Niva Bupa Health Insurance", "https://www.nivabupa.com/"),
+    "care-health": ("Care Health Insurance", "https://www.careinsurance.com/"),
+    "icici-lombard": ("ICICI Lombard General Insurance", "https://www.icicilombard.com/"),
+    "bajaj-allianz": ("Bajaj Allianz General Insurance", "https://www.bajajallianz.com/"),
+    "new-india": ("New India Assurance", "https://www.newindia.co.in/"),
+    "aditya-birla": ("Aditya Birla Health Insurance", "https://www.adityabirlacapital.com/healthinsurance"),
+    "tata-aig": ("Tata AIG General Insurance", "https://www.tataaig.com/"),
+    "manipalcigna": ("ManipalCigna Health Insurance", "https://www.manipalcigna.com/"),
+}
+
+
+def check_url(url: str, timeout: float = 12.0) -> dict:
+    """Do a HEAD then fall back to GET (some sites reject HEAD)."""
+    try:
+        r = requests.head(url, headers=HEADERS, timeout=timeout, allow_redirects=True)
+        if r.status_code in (200, 301, 302, 303):
+            return {
+                "url": url, "ok": True, "status": r.status_code,
+                "method": "HEAD", "final_url": r.url,
+                "content_type": r.headers.get("Content-Type", ""),
+            }
+        # Try GET on a Range to avoid downloading full content
+        r2 = requests.get(
+            url, headers={**HEADERS, "Range": "bytes=0-2047"},
+            timeout=timeout, allow_redirects=True, stream=True,
+        )
+        ok = r2.status_code in (200, 206, 301, 302, 303)
+        return {
+            "url": url, "ok": ok, "status": r2.status_code,
+            "method": "GET-range", "final_url": r2.url,
+            "content_type": r2.headers.get("Content-Type", ""),
+        }
+    except Exception as e:
+        return {"url": url, "ok": False, "error": f"{type(e).__name__}: {e}"}
+
+
+def main():
+    OUTPUT.parent.mkdir(parents=True, exist_ok=True)
+
+    # 1) Insurer home URLs
+    print("=== Verifying insurer home URLs ===")
+    insurer_results: dict[str, dict] = {}
+    with ThreadPoolExecutor(max_workers=6) as ex:
+        futures = {
+            ex.submit(check_url, url): slug
+            for slug, (_, url) in INSURER_HOME_URLS.items()
+        }
+        for f in as_completed(futures):
+            slug = futures[f]
+            result = f.result()
+            name, url = INSURER_HOME_URLS[slug]
+            insurer_results[slug] = {**result, "name": name}
+            ok_tag = "OK" if result["ok"] else f"FAIL {result.get('error') or result.get('status')}"
+            print(f"  {slug:>15s}: {ok_tag:<25s} {url}")
+
+    # 2) Policy PDF URLs
+    print("\n=== Verifying policy PDF URLs (sample) ===")
+    policy_results: list[dict] = []
+    if MANIFEST.exists():
+        manifest = json.loads(MANIFEST.read_text())
+        ok_results = [r for r in manifest.get("results", []) if r.get("ok")]
+        # Verify up to 30 policy URLs (avoid hammering CDNs)
+        sample = ok_results[:30]
+        with ThreadPoolExecutor(max_workers=6) as ex:
+            futures = {ex.submit(check_url, r["url"]): r for r in sample}
+            for f in as_completed(futures):
+                src = futures[f]
+                result = f.result()
+                result.update({
+                    "policy_name": src.get("policy_name"),
+                    "insurer_slug": src.get("insurer_slug"),
+                    "doc_type": src.get("doc_type"),
+                })
+                policy_results.append(result)
+                ok_tag = "OK" if result["ok"] else f"FAIL {result.get('error') or result.get('status')}"
+                print(f"  {src['insurer_slug']:>15s} | {src['policy_name'][:40]:<40s} | {ok_tag}")
+
+    insurer_ok = sum(1 for r in insurer_results.values() if r["ok"])
+    policy_ok = sum(1 for r in policy_results if r["ok"])
+
+    payload = {
+        "verified_at": time.strftime("%Y-%m-%dT%H:%M:%SZ", time.gmtime()),
+        "insurer_summary": {"total": len(insurer_results), "ok": insurer_ok},
+        "policy_summary": {"total": len(policy_results), "ok": policy_ok},
+        "insurers": insurer_results,
+        "policy_urls": policy_results,
+    }
+    OUTPUT.write_text(json.dumps(payload, indent=2))
+    print(f"\nWrote {OUTPUT.relative_to(ROOT)}")
+    print(f"Insurer URLs: {insurer_ok}/{len(insurer_results)} OK")
+    print(f"Policy URLs:  {policy_ok}/{len(policy_results)} OK")
+
+
+if __name__ == "__main__":
+    main()