Real-Time Streaming

const ws = new WebSocket("ws://localhost:8000/api/v1/bi/ws");
 
ws.onopen = () => {
  ws.send(JSON.stringify({
    type: "query",
    session_id: "sess-123",
    tenant_id: "acme-corp",
    message: "Show revenue trends for 2024"
  }));
};
 
ws.onmessage = (event) => {
  const msg = JSON.parse(event.data);
  switch (msg.type) {
    case "status":      // Agent processing status
    case "sql":         // Generated SQL
    case "data":        // Query results (streaming rows)
    case "chart":       // Visualization specification
    case "insight":     // Analysis insight
    case "complete":    // Processing complete
    case "error":       // Error occurred
  }
};