message type routing for WS

Author: Archmonger

src/reactpy/asgi/middleware.py

@@ -173,8 +173,15 @@ async def __call__(
                 break
 
             elif event["type"] == "websocket.receive" and event["text"]:
-                queue_put_func = recv_queue.put(orjson.loads(event["text"]))
-                await queue_put_func
+                msg = orjson.loads(event["text"])
+                msg_type = msg.get("type")
+                if msg_type == "layout-event":
+                    queue_put_func = recv_queue.put(msg)
+                    await queue_put_func
+                else:
+                    await asyncio.to_thread(
+                        _logger.warning, f"Unknown message type: {msg_type}"
+                    )
 
     async def run_dispatcher(
         self,

tests/test_asgi/test_standalone.py

@@ -2,13 +2,13 @@
 from collections.abc import MutableMapping
 
 import pytest
+from asgi_tools import ResponseText
 from asgiref.testing import ApplicationCommunicator
 from requests import request
 
 import reactpy
 from reactpy import html
 from reactpy.asgi.standalone import ReactPy
-from reactpy.asgi.utils import http_response
 from reactpy.testing import BackendFixture, DisplayFixture, poll
 from reactpy.testing.common import REACTPY_TESTS_DEFAULT_TIMEOUT
 from reactpy.types import Connection, Location
@@ -180,7 +180,8 @@ async def custom_http_app(scope, receive, send) -> None:
             raise ValueError("Custom HTTP app received a non-HTTP scope")
 
         rendered.current = True
-        await http_response(send=send, method=scope["method"], message="Hello World")
+        response = ResponseText("Hello World")
+        await response(scope, receive, send)
 
     scope = {
         "type": "http",