Spaces:
Sleeping
Sleeping
Update server.py
Browse files
server.py
CHANGED
|
@@ -107,7 +107,7 @@ async def handle_post(request: Request):
|
|
| 107 |
response_data = json.dumps(response)
|
| 108 |
try:
|
| 109 |
await sse_writer.send({"event": "message", "data": response_data})
|
| 110 |
-
logger.info(f"
|
| 111 |
except Exception as e:
|
| 112 |
logger.error(f"Failed to send SSE response for session {session_id}: {str(e)}")
|
| 113 |
return Response(status_code=202)
|
|
@@ -117,8 +117,11 @@ async def handle_post(request: Request):
|
|
| 117 |
logger.error(f"No write_stream or SSE writer found for session_id: {session_id}")
|
| 118 |
return Response(status_code=202)
|
| 119 |
|
| 120 |
-
|
| 121 |
-
|
|
|
|
|
|
|
|
|
|
| 122 |
return Response(status_code=202)
|
| 123 |
except Exception as e:
|
| 124 |
logger.error(f"Error handling POST message: {str(e)}")
|
|
|
|
| 107 |
response_data = json.dumps(response)
|
| 108 |
try:
|
| 109 |
await sse_writer.send({"event": "message", "data": response_data})
|
| 110 |
+
logger.info(f"Successfully sent tools/list response for session {session_id} via SSE")
|
| 111 |
except Exception as e:
|
| 112 |
logger.error(f"Failed to send SSE response for session {session_id}: {str(e)}")
|
| 113 |
return Response(status_code=202)
|
|
|
|
| 117 |
logger.error(f"No write_stream or SSE writer found for session_id: {session_id}")
|
| 118 |
return Response(status_code=202)
|
| 119 |
|
| 120 |
+
try:
|
| 121 |
+
await transport.handle_post_message(request.scope, request.receive, request._send)
|
| 122 |
+
logger.info(f"Handled post message for session {session_id} via transport")
|
| 123 |
+
except Exception as e:
|
| 124 |
+
logger.error(f"Failed to handle post message via transport for session {session_id}: {str(e)}")
|
| 125 |
return Response(status_code=202)
|
| 126 |
except Exception as e:
|
| 127 |
logger.error(f"Error handling POST message: {str(e)}")
|