Implementing Real-Time Features

{ "type": "chat.send", "room": "general", "text": "hello", "clientId": "c1" }
{ "type": "chat.message", "id": "m42", "room": "general", "userId": "u1", "text": "hello", "ts": 1715900000 }

import * as Y from "yjs";
import { WebsocketProvider } from "y-websocket";
const doc = new Y.Doc();
const provider = new WebsocketProvider("wss://yjs.example.com", "room-42", doc);
const ytext = doc.getText("content");
ytext.observe(() => render(ytext.toString()));

document.addEventListener("pointermove", (e) => {
  throttledSend({ "type": "cursor", "x": e.clientX, "y": e.clientY });
});