add sse logging

Author: SecretiveShell

mcp_bridge/mcp_server/sse.py

@@ -4,6 +4,7 @@
 from .sse_transport import SseServerTransport
 from fastapi import APIRouter, Request
 from pydantic import ValidationError
+from loguru import logger
 
 from .server import server, options
 
@@ -14,6 +15,7 @@
 
 @router.get("/", response_class=StreamingResponse)
 async def handle_sse(request: Request):
+    logger.info("new incoming SSE connection established")
     async with sse.connect_sse(request) as streams:
         try:
             await server.run(streams[0], streams[1], options)
@@ -30,5 +32,6 @@ async def handle_sse(request: Request):
 
 @router.post("/messages")
 async def handle_messages(request: Request):
+    logger.info("incoming SSE message received")
     await sse.handle_post_message(request.scope, request.receive, request._send)
     await request.close()