wss://api.cocobase.buzz/realtime

{
  "type": "auth",
  "token": "YOUR_API_KEY"
}

{
  "type": "subscribe",
  "collection": "posts",
  "filters": {
    "status": "published"
  }
}

{
  "type": "event",
  "collection": "posts",
  "event": "created",
  "document": {
    "id": "doc_abc123",
    "data": {
      "title": "New Post"
    },
    "createdAt": "2024-01-15T10:30:00Z"
  }
}

const ws = new WebSocket("wss://api.cocobase.buzz/realtime");

ws.onopen = () => {
  // Authenticate
  ws.send(JSON.stringify({
    type: "auth",
    token: "YOUR_API_KEY",
  }));

  // Subscribe to collection
  ws.send(JSON.stringify({
    type: "subscribe",
    collection: "posts",
    filters: {
      status: "published",
    },
  }));
};

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

  if (data.type === "event") {
    console.log(`${data.event}: ${data.document.id}`);

    switch (data.event) {
      case "created":
        console.log("New document:", data.document);
        break;
      case "updated":
        console.log("Updated document:", data.document);
        break;
      case "deleted":
        console.log("Deleted document:", data.document.id);
        break;
    }
  }
};

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

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

GET /realtime/sse/{collection}

curl -N "https://api.cocobase.buzz/realtime/sse/posts" \
  -H "Authorization: Bearer YOUR_API_KEY" \
  -H "Accept: text/event-stream"

const params = new URLSearchParams({
  filters: JSON.stringify({ status: "published" }),
});

const eventSource = new EventSource(
  `https://api.cocobase.buzz/realtime/sse/posts?${params}`,
  {
    headers: {
      Authorization: "Bearer YOUR_API_KEY",
    },
  }
);

eventSource.onmessage = (event) => {
  const data = JSON.parse(event.data);
  console.log(`${data.event}: ${data.document.id}`);
};

eventSource.onerror = (error) => {
  console.error("SSE error:", error);
};

// Close connection
eventSource.close();

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

// Unsubscribe from collection
ws.send(JSON.stringify({
  type: "unsubscribe",
  collection: "posts",
}));

// Close connection
ws.close();

{
  "type": "error",
  "code": "UNAUTHORIZED",
  "message": "Invalid or missing authentication token"
}

{
  "type": "error",
  "code": "INVALID_COLLECTION",
  "message": "Collection does not exist"
}