pycrdt-websocket

import asyncio from pycrdt import YDoc, YText from pycrdt.websocket import WebSocketServer, YDocRoom async def server_main(): # Initialize a Y-CRDT document for the server ydoc = YDoc() with ydoc.transaction(): text = ydoc.get_text('my_text') text += 'Hello from server!' # Create a WebSocket server that manages rooms server = WebSocketServer(ydoc, 'ws://127.0.0.1:1234') print("Server starting on ws://127.0.0.1:1234") await server.start() await asyncio.sleep(5) # Keep server running for a bit await server.stop() print("Server stopped") async def client_main(): await asyncio.sleep(1) # Give server a moment to start print("Client connecting...") # Connect to the server with a YDocRoom client_ydoc = YDoc() room = YDocRoom(client_ydoc, 'ws://127.0.0.1:1234') await room.connect() # Access the shared text shared_text = client_ydoc.get_text('my_text') print(f"Client received: '{shared_text}'") with client_ydoc.transaction(): shared_text.append(' And client!') print(f"Client sent: '{shared_text}'") await asyncio.sleep(1) # Allow changes to propagate await room.disconnect() print("Client disconnected") async def main(): server_task = asyncio.create_task(server_main()) client_task = asyncio.create_task(client_main()) await asyncio.gather(server_task, client_task) if __name__ == '__main__': asyncio.run(main())