Function analyze

python/src/api/server.py:85–115

Run the full pipeline synchronously and return the final state.

(req: AnalyzeRequest)

@app.post("/analyze", response_model=AnalyzeResponse)
async def analyze(req: AnalyzeRequest):
    """Run the full pipeline synchronously and return the final state."""
    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:
        final = await pipeline.ainvoke(initial_state)
    except Exception as exc:
        logger.exception("Pipeline failed")
        raise HTTPException(status_code=500, detail=str(exc))

    return AnalyzeResponse(
        competitor=final["competitor"],
        changes_detected=final.get("changes_detected", []),
        research_results=final.get("research_results", []),
        comparison_matrix=final.get("comparison_matrix"),
        battlecard=final.get("battlecard"),
        alerts_sent=final.get("alerts_sent", []),
        quality_score=final.get("quality_score", 0.0),
    )


@app.post("/analyze/stream")