Get Stream Task Logs

event: <event_type>
data: <json_data>

function createLogViewer(taskId, apiKey) {
  const API_URL = `https://cloud.blackbox.ai/api/tasks/${taskId}/stream`;
  const eventSource = new EventSource(API_URL, {
    headers: { 'Authorization': `Bearer ${apiKey}` }
  });

  const logContainer = document.getElementById('logs');
  const statusElement = document.getElementById('status');

  eventSource.addEventListener('log', (event) => {
    const { index, log } = JSON.parse(event.data);
    
    const logElement = document.createElement('div');
    logElement.className = `log-entry log-${log.type}`;
    logElement.innerHTML = `
      <span class="log-index">[${index}]</span>
      <span class="log-timestamp">${new Date(log.timestamp).toLocaleTimeString()}</span>
      <span class="log-message">${log.message}</span>
    `;
    
    logContainer.appendChild(logElement);
    logContainer.scrollTop = logContainer.scrollHeight; // Auto-scroll
  });

  eventSource.addEventListener('status', (event) => {
    const { status } = JSON.parse(event.data);
    statusElement.textContent = status.toUpperCase();
    statusElement.className = `status status-${status}`;
  });

  eventSource.addEventListener('complete', (event) => {
    const { status, totalLogs } = JSON.parse(event.data);
    console.log(`Task ${status}! Received ${totalLogs} logs`);
    eventSource.close();
  });

  return eventSource;
}

class TaskLogStreamer {
  constructor(taskId, apiKey) {
    this.taskId = taskId;
    this.apiKey = apiKey;
    this.lastLogIndex = -1;
    this.eventSource = null;
  }

  connect() {
    const fromIndex = this.lastLogIndex + 1;
    const url = `https://cloud.blackbox.ai/api/tasks/${this.taskId}/stream?fromIndex=${fromIndex}`;
    
    this.eventSource = new EventSource(url, {
      headers: { 'Authorization': `Bearer ${this.apiKey}` }
    });

    this.eventSource.addEventListener('log', (event) => {
      const { index, log } = JSON.parse(event.data);
      this.lastLogIndex = index;
      this.onLog(log, index);
    });

    this.eventSource.addEventListener('complete', (event) => {
      this.onComplete(JSON.parse(event.data));
      this.disconnect();
    });

    this.eventSource.onerror = (error) => {
      console.error('Connection lost, reconnecting...');
      this.disconnect();
      setTimeout(() => this.connect(), 2000); // Reconnect after 2s
    };
  }

  disconnect() {
    if (this.eventSource) {
      this.eventSource.close();
      this.eventSource = null;
    }
  }

  onLog(log, index) {
    console.log(`[${index}]`, log.message);
  }

  onComplete(data) {
    console.log('Stream complete:', data);
  }
}

// Usage
const streamer = new TaskLogStreamer('9qQe2F8Z_nXx9-eJA0BD6', 'bb_YOUR_API_KEY');
streamer.connect();