Function handle_sse

src/codegraphcontext/api/mcp_sse.py:80–106

Entry point for the SSE connection.

(request: Request)

async def handle_sse(request: Request):
    """Entry point for the SSE connection."""
    logger.info("SSE client connected")
    sender = _SendTracker(request._send)
    try:
        async with sse.connect_sse(request.scope, request.receive, sender) as (read_stream, write_stream):
            await mcp_server.run(
                read_stream,
                write_stream,
                InitializationOptions(
                    server_name="CodeGraphContext",
                    server_version="0.1.0",
                    capabilities=ServerCapabilities(
                        tools=ToolsCapability(listChanged=False)
                    )
                )
            )
    except anyio.EndOfStream:
        logger.debug("SSE client disconnected cleanly (stream ended)")
    except Exception as exc:
        logger.debug("SSE connection closed: %s", type(exc).__name__)
    finally:
        logger.info("SSE client disconnected — handler exited, resources freed")
    if sender.response_started:
        return _AlreadySentResponse()
    # connect_sse bailed out before writing anything (e.g. rejected origin).
    return Response(status_code=500, content="SSE connection could not be established")


async def handle_messages(request: Request):