Add reason support on WebSocketDisconnectEvent (#2324)

* Add `reason` support WebSocketDisconnectEvent

* cutify test

---------

Co-authored-by: Marcelo Trylesinski <[email protected]>

Author: frankie567

tests/protocols/test_websocket.py

@@ -616,20 +616,25 @@ async def websocket_session(url: str):
 
 
 async def test_client_close(ws_protocol_cls: WSProtocol, http_protocol_cls: HTTPProtocol, unused_tcp_port: int):
+    disconnect_message: WebSocketDisconnectEvent | None = None
+
     async def app(scope: Scope, receive: ASGIReceiveCallable, send: ASGISendCallable):
+        nonlocal disconnect_message
         while True:
             message = await receive()
             if message["type"] == "websocket.connect":
                 await send({"type": "websocket.accept"})
             elif message["type"] == "websocket.receive":
                 pass
             elif message["type"] == "websocket.disconnect":
+                disconnect_message = message
                 break
 
     async def websocket_session(url: str):
         async with websockets.client.connect(url) as websocket:
             await websocket.ping()
             await websocket.send("abc")
+            await websocket.close(code=1001, reason="custom reason")
 
     config = Config(
         app=app,
@@ -641,6 +646,8 @@ async def websocket_session(url: str):
     async with run_server(config):
         await websocket_session(f"ws://127.0.0.1:{unused_tcp_port}")
 
+    assert disconnect_message == {"type": "websocket.disconnect", "code": 1001, "reason": "custom reason"}
+
 
 async def test_client_connection_lost(
     ws_protocol_cls: WSProtocol, http_protocol_cls: HTTPProtocol, unused_tcp_port: int
@@ -1262,7 +1269,7 @@ async def send_text(url: str):
         await send_text(f"ws://127.0.0.1:{unused_tcp_port}")
 
     assert frames == [b"abc", b"abc", b"abc"]
-    assert disconnect_message == {"type": "websocket.disconnect", "code": 1000}
+    assert disconnect_message == {"type": "websocket.disconnect", "code": 1000, "reason": ""}
 
 
 async def test_default_server_headers(

uvicorn/_types.py

@@ -204,6 +204,7 @@ class WebSocketResponseBodyEvent(TypedDict):
 class WebSocketDisconnectEvent(TypedDict):
     type: Literal["websocket.disconnect"]
     code: int
+    reason: NotRequired[str | None]
 
 
 class WebSocketCloseEvent(TypedDict):

uvicorn/protocols/websockets/websockets_impl.py

@@ -382,7 +382,7 @@ async def asgi_receive(
             self.closed_event.set()
             if self.ws_server.closing:
                 return {"type": "websocket.disconnect", "code": 1012}
-            return {"type": "websocket.disconnect", "code": exc.code}
+            return {"type": "websocket.disconnect", "code": exc.code, "reason": exc.reason}
 
         if isinstance(data, str):
             return {"type": "websocket.receive", "text": data}

uvicorn/protocols/websockets/wsproto_impl.py

@@ -212,7 +212,7 @@ def handle_bytes(self, event: events.BytesMessage) -> None:
     def handle_close(self, event: events.CloseConnection) -> None:
         if self.conn.state == ConnectionState.REMOTE_CLOSING:
             self.transport.write(self.conn.send(event.response()))
-        self.queue.put_nowait({"type": "websocket.disconnect", "code": event.code})
+        self.queue.put_nowait({"type": "websocket.disconnect", "code": event.code, "reason": event.reason})
         self.transport.close()
 
     def handle_ping(self, event: events.Ping) -> None:
@@ -336,7 +336,7 @@ async def send(self, message: ASGISendEvent) -> None:
                     self.close_sent = True
                     code = message.get("code", 1000)
                     reason = message.get("reason", "") or ""
-                    self.queue.put_nowait({"type": "websocket.disconnect", "code": code})
+                    self.queue.put_nowait({"type": "websocket.disconnect", "code": code, "reason": reason})
                     output = self.conn.send(wsproto.events.CloseConnection(code=code, reason=reason))
                     if not self.transport.is_closing():
                         self.transport.write(output)