Reraise exception and make websocket optional

Author: calclavia

pyproject.toml

@@ -30,12 +30,12 @@ dependencies = [
     "sse-starlette>=1.6.1",
     "pydantic-settings>=2.5.2",
     "uvicorn>=0.23.1",
-    "websockets>=15.0.1",
 ]
 
 [project.optional-dependencies]
 rich = ["rich>=13.9.4"]
 cli = ["typer>=0.12.4", "python-dotenv>=1.0.0"]
+ws = ["websockets>=15.0.1"]
 
 [project.scripts]
 mcp = "mcp.cli:app [cli]"

src/mcp/client/websocket.py

@@ -56,8 +56,9 @@ async def ws_reader():
                         except ValidationError as exc:
                             # If JSON parse or model validation fails, send the exception
                             await read_stream_writer.send(exc)
-            except (anyio.ClosedResourceError, Exception):
+            except (anyio.ClosedResourceError, Exception) as e:
                 await ws.close()
+                raise e
 
         async def ws_writer():
             """
@@ -71,8 +72,9 @@ async def ws_writer():
                             by_alias=True, mode="json", exclude_none=True
                         )
                         await ws.send(json.dumps(msg_dict))
-            except (anyio.ClosedResourceError, Exception):
+            except (anyio.ClosedResourceError, Exception) as e:
                 await ws.close()
+                raise e
 
         async with anyio.create_task_group() as tg:
             # Start reader and writer tasks