Skip to content

Commit c90f089

Browse files
committed
fix: fix the remote web socket closed expection
1 parent 3864354 commit c90f089

File tree

1 file changed

+11
-3
lines changed

1 file changed

+11
-3
lines changed

veadk/toolkits/apps/reverse_mcp/server_with_reverse_mcp.py

Lines changed: 11 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -170,6 +170,10 @@ async def ws_endpoint(ws: WebSocket):
170170
logger.info(f"Fork agent for websocket {client_id}")
171171
agent = self.agent.clone()
172172

173+
logger.info(
174+
f"clone agent \n model_name={agent.model_name}\n instruction={agent.instruction}\n"
175+
)
176+
173177
# Mount MCPToolset when creating agent
174178
mcp_toolset_url = f"http://127.0.0.1:{self.port}/mcp"
175179
mcp_toolset_headers = {REVERSE_MCP_HEADER_KEY: client_id}
@@ -191,9 +195,13 @@ async def ws_endpoint(ws: WebSocket):
191195
await ws.accept()
192196
logger.info(f"Websocket {client_id} connected")
193197

194-
while True:
195-
raw = await ws.receive_text()
196-
await self.ws_session_mgr.handle_ws_message(client_id, raw)
198+
try:
199+
while True:
200+
raw = await ws.receive_text()
201+
logger.debug(f"ws.receive_text() = {raw}")
202+
await self.ws_session_mgr.handle_ws_message(client_id, raw)
203+
except Exception as e:
204+
logger.warning(f"client {client_id} web socket connection closed: {e}")
197205

198206
class CreateSessionRequest(BaseModel):
199207
state: Optional[dict[str, Any]] = None

0 commit comments

Comments
 (0)