Stream Task Logs

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

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

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

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

  const chunk = decoder.decode(value);
  for (const line of chunk.split("\n")) {
    if (line.startsWith("data: ")) {
      const event = JSON.parse(line.slice(6));
      console.log(event.type, event);

      if (event.type === "finish" || event.type === "error") break;
    }
  }
}

// Note: Browser EventSource doesn't support custom headers.
// Pass the API key as a query param or use a server-side proxy.
const RUN_ID = "a1b2c3d4-e5f6-7890-abcd-ef1234567890";
const url = `https://agent.blackbox.ai/api/v1/tasks/${RUN_ID}/logs/stream`;

const es = new EventSource(url);

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

  if (data.type === "text-delta") {
    process.stdout.write(data.delta);
  } else if (data.type === "finish") {
    console.log("\nDone:", data.status);
    es.close();
  } else if (data.type === "error") {
    console.error("Error:", data.errorText);
    es.close();
  }
};

es.onerror = () => es.close();

import requests
import json

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

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

for line in response.iter_lines():
    if line and line.startswith(b"data: "):
        event = json.loads(line[6:])
        print(event["type"], event)

        if event["type"] in ("finish", "error"):
            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/tasks/%s/logs/stream", 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: ") {
            var event map[string]interface{}
            json.Unmarshal([]byte(line[6:]), &event)
            fmt.Println(event["type"], event)

            if event["type"] == "finish" || event["type"] == "error" {
                break
            }
        }
    }
}

{
  "status": "queued",
  "error": null,
  "message": "No logs available to stream. Task may not have started or logs were cleared."
}

{
  "error": "Unauthorized"
}