diff --git a/pycrdt_websocket/yroom.py b/pycrdt_websocket/yroom.py index 3a8279f..4af456a 100644 --- a/pycrdt_websocket/yroom.py +++ b/pycrdt_websocket/yroom.py @@ -25,6 +25,7 @@ create_sync_message, create_update_message, handle_sync_message, + read_message, ) from .websocket import Websocket @@ -302,6 +303,8 @@ async def serve(self, websocket: Websocket): client.path, ) tg.start_soon(client.send, message) + # apply awareness update to the server's awareness + self.awareness.apply_awareness_update(read_message(message[1:])) # remove this client self.clients.remove(websocket) except Exception as exception: