File size: 1,026 Bytes
577ea9f f9386fc 577ea9f f9386fc 577ea9f f9386fc 577ea9f | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 | """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",
},
)
|