fix(websocket): ASGI websocket must pass thru bytes as is

fix #2644
sanic-org · Jan 8, 2023 · d2a0d7a · d2a0d7a
1 parent 4ad8168
commit d2a0d7a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/sanic/server/websockets/connection.py b/sanic/server/websockets/connection.py
@@ -45,15 +45,15 @@ async def send(self, data: Union[str, bytes], *args, **kwargs) -> None:
 
         await self._send(message)
 
-    async def recv(self, *args, **kwargs) -> Optional[str]:
+    async def recv(self, *args, **kwargs) -> Optional[Union[str, bytes]]:
         message = await self._receive()
 
         if message["type"] == "websocket.receive":
             try:
                 return message["text"]
             except KeyError:
                 try:
-                    return message["bytes"].decode()
+                    return message["bytes"]
                 except KeyError:
                     raise InvalidUsage("Bad ASGI message received")
         elif message["type"] == "websocket.disconnect":