"""POST /api/assess — SSE stream of agent updates ending with a dossier."""
from typing import Optional

from fastapi import APIRouter
from fastapi.responses import StreamingResponse
from pydantic import BaseModel, Field

from app.agents.orchestrator import run_assessment

router = APIRouter()


class AssessRequest(BaseModel):
    address: str = Field(..., min_length=3, max_length=300)
    language: Optional[str] = Field(
        "en",
        description=(
            "ISO 639-1 code for the language of user-facing dossier copy. "
            "Supported: en, es, zh, vi, ht, ar, tl. Unknown codes silently "
            "fall back to en."
        ),
    )


@router.post("/api/assess")
async def assess(req: AssessRequest):
    return StreamingResponse(
        run_assessment(req.address, language=req.language or "en"),
        media_type="text/event-stream",
        headers={
            "Cache-Control": "no-cache",
            "Connection": "keep-alive",
            "X-Accel-Buffering": "no",
        },
    )