Streaming

const response = await fetch(
  "https://www.chatbase.co/api/v2/agents/YOUR_AGENT_ID/chat",
  {
    method: "POST",
    headers: {
      Authorization: "Bearer YOUR_API_KEY",
      "Content-Type": "application/json",
    },
    body: JSON.stringify({
      message: "Explain quantum computing",
      stream: true,
      // conversationId: "a1b2c3d4-...", // omit to start a new conversation
      // userId: "user_abc123",          // associate a user with the conversation
    }),
  }
);

const reader = response.body.getReader();
const decoder = new TextDecoder();
let conversationId;
let userId;

while (true) {
  const { done, value } = await reader.read();
  if (done) break;

  const lines = decoder.decode(value, { stream: true }).split("\n");
  for (const line of lines) {
    if (!line.trim()) continue;
    const event = JSON.parse(line);

    switch (event.type) {
      case "message-start":
        console.log("Message ID:", event.messageId);
        break;
      case "text-delta":
        process.stdout.write(event.delta);
        break;
      case "tool-input-available":
        console.log("\nClient action requested:", event.toolName, event.input);
        // Handle client action — see Client Actions guide
        break;
      case "message-metadata":
        conversationId = event.conversationId;
        userId = event.userId;
        console.log("\nFinish reason:", event.finishReason);
        console.log("Credits used:", event.usage.credits);
        break;
      case "error":
        console.error("Stream error:", event.errorText);
        break;
    }
  }
}

import requests
import json

response = requests.post(
    "https://www.chatbase.co/api/v2/agents/YOUR_AGENT_ID/chat",
    headers={
        "Authorization": "Bearer YOUR_API_KEY",
        "Content-Type": "application/json",
    },
    json={
        "message": "Explain quantum computing",
        "stream": True,
        # "conversationId": "a1b2c3d4-...",  # omit to start a new conversation
        # "userId": "user_abc123",            # associate a user with the conversation
    },
    stream=True,
)

conversation_id = None
user_id = None

for line in response.iter_lines():
    if not line:
        continue
    event = json.loads(line)

    if event["type"] == "message-start":
        print(f"Message ID: {event['messageId']}")
    elif event["type"] == "text-delta":
        print(event["delta"], end="", flush=True)
    elif event["type"] == "tool-input-available":
        print(f"\nClient action requested: {event['toolName']}", event["input"])
        # Handle client action — see Client Actions guide
    elif event["type"] == "message-metadata":
        conversation_id = event["conversationId"]
        user_id = event["userId"]
        print(f"\nFinish reason: {event['finishReason']}")
        print(f"Credits used: {event['usage']['credits']}")
    elif event["type"] == "error":
        print(f"Stream error: {event['errorText']}")

curl -N -X POST 'https://www.chatbase.co/api/v2/agents/YOUR_AGENT_ID/chat' \
  -H 'Authorization: Bearer YOUR_API_KEY' \
  -H 'Content-Type: application/json' \
  -d '{
    "message": "Explain quantum computing",
    "stream": true,
    "conversationId": "a1b2c3d4-e5f6-4a7b-8c9d-0e1f2a3b4c5d",
    "userId": "user_abc123"
  }'