Function analyze_stream

python/src/api/server.py:119–151

Stream pipeline events via Server-Sent Events (SSE) so the frontend can show real-time progress.

(req: AnalyzeRequest)

@app.post("/analyze/stream")
async def analyze_stream(req: AnalyzeRequest):
    """Stream pipeline events via Server-Sent Events (SSE) so the frontend
    can show real-time progress."""

    async def event_generator() -> AsyncGenerator[dict, None]:
        initial_state: PipelineState = {
            "competitor": req.competitor,
            "monitor_urls": req.urls or [],
            "previous_hashes": {},
            "changes_detected": [],
            "research_results": [],
            "comparison_matrix": {},
            "battlecard": {},
            "alerts_sent": [],
            "quality_score": 0.0,
            "reflexion_count": 0,
            "error": None,
        }

        try:
            async for event in pipeline.astream(initial_state):
                for node_name, node_output in event.items():
                    yield {
                        "event": node_name,
                        "data": json.dumps(node_output, default=str, ensure_ascii=False),
                    }
        except Exception as exc:
            yield {
                "event": "error",
                "data": json.dumps({"error": str(exc)}),
            }

    return EventSourceResponse(event_generator())


@app.get("/competitors")