Agent SSE Stream

const API_KEY = "YOUR_API_KEY";
const RUN_ID = "a1b2c3d4-e5f6-7890-abcd-ef1234567890";

const response = await fetch(
  `https://agent.blackbox.ai/api/v1/agent/stream?runId=${RUN_ID}`,
  { headers: { Authorization: `Bearer ${API_KEY}` } }
);

const reader = response.body.getReader();
const decoder = new TextDecoder();
let buffer = "";

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

  buffer += decoder.decode(value, { stream: true });
  const lines = buffer.split("\n");
  buffer = lines.pop() ?? "";

  for (const line of lines) {
    if (!line.startsWith("data: ")) continue;
    const event = JSON.parse(line.slice(6));

    switch (event.type) {
      case "resume":
        console.log("Connected to stream");
        break;
      case "text-delta":
        process.stdout.write(event.delta);
        break;
      case "tool-call-start":
        console.log(`\nTool: ${event.toolName}`);
        break;
      case "finish":
        console.log(`\nDone: ${event.status}`);
        return;
      case "error":
        console.error(`Error: ${event.errorText}`);
        return;
    }
  }
}

import requests
import json

API_KEY = "YOUR_API_KEY"
RUN_ID = "a1b2c3d4-e5f6-7890-abcd-ef1234567890"

response = requests.get(
    "https://agent.blackbox.ai/api/v1/agent/stream",
    headers={"Authorization": f"Bearer {API_KEY}"},
    params={"runId": RUN_ID},
    stream=True,
)

for line in response.iter_lines():
    if not line or not line.startswith(b"data: "):
        continue

    event = json.loads(line[6:])

    if event["type"] == "text-delta":
        print(event["delta"], end="", flush=True)
    elif event["type"] == "tool-call-start":
        print(f"\n[Tool: {event['toolName']}]")
    elif event["type"] in ("finish", "error"):
        print(f"\nStream ended: {event}")
        break

package main

import (
    "bufio"
    "encoding/json"
    "fmt"
    "net/http"
    "strings"
)

func main() {
    apiKey := "YOUR_API_KEY"
    runId := "a1b2c3d4-e5f6-7890-abcd-ef1234567890"
    url := fmt.Sprintf(
        "https://agent.blackbox.ai/api/v1/agent/stream?runId=%s", runId,
    )

    req, _ := http.NewRequest("GET", url, nil)
    req.Header.Set("Authorization", "Bearer "+apiKey)

    client := &http.Client{}
    resp, _ := client.Do(req)
    defer resp.Body.Close()

    scanner := bufio.NewScanner(resp.Body)
    for scanner.Scan() {
        line := scanner.Text()
        if !strings.HasPrefix(line, "data: ") {
            continue
        }

        var event map[string]interface{}
        json.Unmarshal([]byte(line[6:]), &event)

        switch event["type"] {
        case "text-delta":
            fmt.Print(event["delta"])
        case "finish":
            fmt.Printf("\nDone: %s\n", event["status"])
            return
        case "error":
            fmt.Printf("\nError: %s\n", event["errorText"])
            return
        }
    }
}

{
  "status": "not_found",
  "error": null
}

{
  "error": "runId query parameter is required"
}