Import Progress

curl -N "https://vas-poc.vurbo.ai/api/v1/sse/imports/550e8400-e29b-41d4-a716-446655440000/progress" \
  -H "X-API-Key: vas_aB3dE5fG7hI9jK1lM3nO5pQ7rS9tU1vW"

// 使用 fetch API（因 EventSource 不支援 Header）
async function connectSSE(importId, apiKey) {
  const response = await fetch(
    `https://vas-poc.vurbo.ai/api/v1/sse/imports/${importId}/progress`,
    {
      headers: {
        'X-API-Key': apiKey
      }
    }
  );
  const reader = response.body.getReader();
  // ... 處理 SSE 事件
}

情境一：匯入尚在處理中
┌────────────────────────────────────────────────────┐
│ 1. connected       → 連線確認                      │
│ 2. progress        → 發送目前進度                   │
│ 3. progress ×N     → 進度有變化時持續推送            │
│    heartbeat ×N    → 每 15 秒無進度變化時發送心跳     │
│ 4. completed       → 匯入成功，連線結束              │
│    或 failed       → 匯入失敗，連線結束              │
│    或 timeout      → 超過 15 分鐘，連線結束          │
└────────────────────────────────────────────────────┘

情境二：匯入已完成（終態）
┌────────────────────────────────────────────────────┐
│ 1. connected       → 連線確認                      │
│ 2. progress        → 發送最終進度                   │
│ 3. completed       → 直接發送完成事件並結束          │
│    或 failed       → 直接發送失敗事件並結束          │
└────────────────────────────────────────────────────┘

event: connected
data: {"message":"匯入進度服務已連線 (importId: 550e8400-e29b-41d4-a716-446655440000)"}

{
  "message": "匯入進度服務已連線 (importId: xxx)"
}

event: progress
data: {"import_id":"550e8400-...","status":"processing","stage":"transcribing","progress":45,"message":"轉錄中..."}

{
  "import_id": "550e8400-e29b-41d4-a716-446655440000",
  "status": "processing",
  "stage": "transcribing",
  "progress": 45,
  "message": "轉錄中..."
}

event: completed
data: {"import_id":"550e8400-...","status":"completed","task_id":"abc123-...","message":"處理完成"}

{
  "import_id": "550e8400-e29b-41d4-a716-446655440000",
  "status": "completed",
  "task_id": "abc123-e29b-41d4-a716-446655440000",
  "message": "處理完成"
}

event: failed
data: {"import_id":"550e8400-...","status":"failed","error_code":"import_invalid_format","error_message":"不支援的音檔格式"}

{
  "import_id": "550e8400-e29b-41d4-a716-446655440000",
  "status": "failed",
  "error_code": "import_invalid_format",
  "error_message": "不支援的音檔格式"
}

event: heartbeat
data: {"timestamp":1708761600}

{
  "timestamp": 1708761600
}

event: timeout
data: {"message":"連線超時"}

{
  "message": "連線超時"
}

async function trackImportProgress(importId, apiKey) {
  const response = await fetch(
    `https://vas-poc.vurbo.ai/api/v1/sse/imports/${importId}/progress`,
    {
      headers: {
        'X-API-Key': apiKey
      }
    }
  );

  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 });

    // 解析 SSE 格式：event: xxx\ndata: {...}\n\n
    const events = buffer.split('\n\n');
    buffer = events.pop(); // 保留未完成的部分

    for (const eventStr of events) {
      if (!eventStr.trim()) continue;

      const lines = eventStr.split('\n');
      let eventType = '';
      let eventData = '';

      for (const line of lines) {
        if (line.startsWith('event: ')) {
          eventType = line.slice(7);
        } else if (line.startsWith('data: ')) {
          eventData = line.slice(6);
        }
      }

      if (!eventType || !eventData) continue;

      const data = JSON.parse(eventData);

      switch (eventType) {
        case 'connected':
          console.log('已連線:', data.message);
          break;

        case 'progress':
          console.log(`[${data.stage}] ${data.progress}% - ${data.message}`);
          // 更新 UI 進度條
          updateProgressBar(data.progress, data.stage, data.message);
          break;

        case 'completed':
          console.log('匯入完成! 錄音 ID:', data.task_id);
          // 導向錄音詳情頁
          navigateToRecording(data.task_id);
          break;

        case 'failed':
          console.error('匯入失敗:', data.error_code, data.error_message);
          // 顯示錯誤訊息
          showError(data.error_message);
          break;

        case 'heartbeat':
          console.log('心跳:', new Date(data.timestamp * 1000));
          break;

        case 'timeout':
          console.warn('連線超時:', data.message);
          break;

        case 'error':
          console.error('錯誤:', data);
          break;
      }
    }
  }
}