ws://localhost:8000/api/v1/realtime/ws?token={jwt_token}

{
  "action": "subscribe",
  "collection": "posts",
  "operations": ["create", "update", "delete"]
}

{
  "action": "unsubscribe",
  "collection": "posts"
}

{
  "action": "ping"
}

{
  "status": "subscribed",
  "collection": "posts"
}

{
  "status": "unsubscribed",
  "collection": "posts"
}

{
  "type": "pong"
}

{
  "type": "heartbeat",
  "timestamp": "2026-01-17T12:34:56.789Z"
}

{
  "type": "posts.create",
  "timestamp": "2026-01-17T12:34:56.789Z",
  "data": {
    "id": "550e8400-e29b-41d4-a716-446655440000",
    "title": "New Post",
    "created_at": "2026-01-17T12:34:56.789Z"
  }
}

const token = "your_jwt_token";
const ws = new WebSocket(`ws://localhost:8000/api/v1/realtime/ws?token=${token}`);

ws.onopen = () => {
  // Subscribe to posts collection
  ws.send(JSON.stringify({
    action: "subscribe",
    collection: "posts",
    operations: ["create", "update", "delete"]
  }));
};

ws.onmessage = (event) => {
  const message = JSON.parse(event.data);

  if (message.type === "posts.create") {
    console.log("New post created:", message.data);
  }

  if (message.type === "heartbeat") {
    console.log("Heartbeat received");
  }
};

ws.onerror = (error) => {
  console.error("WebSocket error:", error);
};

ws.onclose = () => {
  console.log("WebSocket connection closed");
};