Function handle_events_stream

uncommon_route/proxy.py:3762–3794

GET /v1/events/stream — Server-Sent Events for live dashboard updates.

(request: Request)

        return JSONResponse(visible_records)

    async def handle_events_stream(request: Request) -> Response:
        """GET /v1/events/stream — Server-Sent Events for live dashboard updates."""
        denied = _admin_auth_failure(request)
        if denied is not None:
            return denied

        bus = get_bus()
        queue = await bus.subscribe()

        async def _gen() -> AsyncGenerator[bytes, None]:
            yield b": connected\n\n"
            try:
                while True:
                    if await request.is_disconnected():
                        break
                    try:
                        event = await asyncio.wait_for(queue.get(), timeout=15.0)
                        payload = json.dumps(event, default=str)
                        yield f"data: {payload}\n\n".encode("utf-8")
                    except asyncio.TimeoutError:
                        yield b": keepalive\n\n"
            finally:
                await bus.unsubscribe(queue)

        return StreamingResponse(
            _gen(),
            media_type="text/event-stream",
            headers={
                "Cache-Control": "no-cache",
                "X-Accel-Buffering": "no",
                "Connection": "keep-alive",
            },
        )

    async def handle_traces(request: Request) -> JSONResponse:
        denied = _admin_auth_failure(request)