backend/main.py

# backend/main.py — FIXED VERSION
import asyncio
from contextlib import asynccontextmanager
from fastapi import FastAPI
from fastapi.middleware.cors import CORSMiddleware

from backend.api.sources import router as sources_router
from backend.api.upload  import router as upload_router
from backend.api.query   import router as query_router
from backend.api.history import router as history_router
from backend.api.stream  import router as stream_router
from backend.api.legal_routes import router as legal_router
from backend.api.image_routes import router as image_router
from backend.api.legal_query_routes import router as legal_query_router
from backend.api.conversations import router as conversations_router
from backend.api.evaluation   import router as eval_router
from backend.api.export       import router as export_router

from backend.database.connection import get_connection, check_and_update_schema
from backend.vectorstore import get_stats as preload_vectorstore
from backend.ingestion.embedder import get_model as preload_embedder
from backend.rag.retriever import _get_reranker as preload_reranker
from backend.core.llm_provider import llm_provider
from backend.config import GROQ_MODEL

def _load_models(app: FastAPI):
    print("[Startup] Loading ML models...")
    try:
        preload_embedder()
        preload_reranker()
             
        print("[Startup] Models ready.")
    except Exception as e:
        print(f"[Startup] Model load failed: {e}")
    finally:
        app.state.models_ready.set()

@asynccontextmanager
async def lifespan(app: FastAPI):
    app.state.models_ready = asyncio.Event()
    # Run DB migration check
    check_and_update_schema()
    asyncio.create_task(asyncio.to_thread(_load_models, app))
    yield


app = FastAPI(
    title="InteleX RAG System",
    version="2.2.0",
    lifespan=lifespan
)

app.add_middleware(
    CORSMiddleware,
    allow_origins=["*"],
    allow_credentials=True,
    allow_methods=["*"],
    allow_headers=["*"],
)

# ── Core routes (no prefix) ───────────────────────────────────────────────────
app.include_router(sources_router)
app.include_router(upload_router)
app.include_router(query_router)
app.include_router(history_router)
# app.include_router(stream_router)  # DEPRECATED: use /query-stream from query.py instead
app.include_router(conversations_router, tags=["conversations"])
app.include_router(eval_router, prefix="/eval", tags=["evaluation"])

# ── Legal routes under /legal prefix ─────────────────────────────────────────
# This fixes the 404 on /legal/legal-sources that the frontend expects
app.include_router(legal_router,       prefix="/legal", tags=["legal"])
app.include_router(legal_query_router, tags=["legal"])   # /legal-query stays at root

# ── Image routes under /images prefix ────────────────────────────────────────
app.include_router(image_router, prefix="/images", tags=["images"])

# ── Export routes ────────────────────────────────────────────────────────────
app.include_router(export_router, prefix="/export", tags=["export"])

@app.get("/health")
def health():
    from backend.config import GROQ_API_KEY, FAISS_INDEX_PATH, VECTOR_STORE_TYPE
    from backend.database.connection import get_connection
    from backend.vectorstore import get_stats
    import os
    
    db_status = False
    try:
        conn = get_connection()
        db_status = True
        conn.close()
    except Exception as e:
        print(f"[Health] DB Check failed: {e}")

    vector_stats = get_stats()

    return {
        "status": "ok",
        "vector_store": VECTOR_STORE_TYPE,
        "vector_stats": vector_stats,
        "groq_configured": bool(GROQ_API_KEY),
        "db_connected": db_status,
        "models_ready": app.state.models_ready.is_set()
    }