タスクライフサイクル

{
  "status": "completed",           // Always present: what state we're in
  "message": "Found 5 products",   // Always present: human explanation
  "context_id": "ctx-123",         // Session continuity
  "context": {                     // Application-level context echoed back
    "ui": "buyer_dashboard"
  },
  "products": [...]                // Task-specific fields at top level
}

function handleAdcpResponse(response) {
  switch (response.status) {
    case 'completed':
      // 成功 - データ処理（タスクフィールドはトップレベル）
      showSuccess(response.message);
      return processData(response);

    case 'input-required':
      // 追加情報が必要 - ユーザーに確認
      const userInput = await promptUser(response.message);
      return sendFollowUp(response.context_id, userInput);

    case 'working':
      // 進行中 - 進捗表示して待機
      showProgress(response.message);
      return pollForUpdates(response.context_id);

    case 'failed':
      // エラー - メッセージを表示し丁寧に処理
      showError(response.message);
      return handleError(response.errors);

    case 'auth-required':
      // 認証が必要
      const credentials = await getAuth();
      return retryWithAuth(credentials);

    default:
      // 想定外のステータス
      console.warn('Unknown status:', response.status);
      showMessage(response.message);
  }
}

{
  "status": "input-required",
  "message": "I need more information about your campaign. What's your budget and target audience?",
  "context_id": "ctx-123",
  "products": [],
  "suggestions": ["budget", "audience", "timing"]
}

if (response.status === 'input-required') {
  // message から必要項目を抽出
  const missingInfo = extractRequirements(response.message);

  // 必要項目に応じて質問
  const answers = await promptForInfo(missingInfo);

  // 同じ context_id で追送
  return sendMessage(response.context_id, answers);
}

{
  "status": "input-required",
  "message": "Media buy exceeds auto-approval limit ($100K). Please approve to proceed with campaign creation.",
  "context_id": "ctx-123",
  "approval_required": true,
  "amount": 150000,
  "reason": "exceeds_limit"
}

if (response.status === 'input-required' && response.approval_required) {
  // 承認 UI を表示
  const approved = await showApprovalDialog(response.message, response);

  // 承認結果を送信
  const decision = approved ? "Approved" : "Rejected";
  return sendMessage(response.context_id, decision);
}

{
  "status": "working",
  "message": "Creating media buy. Validating inventory availability...",
  "context_id": "ctx-123",
  "task_id": "task-456",
  "progress": 25,
  "step": "inventory_validation"
}

submitted → working → completed
    ↓          ↓         ↑
input-required → → → → →
    ↓
  failed

const POLLING_INTERVALS = {
  working: 5000,      // 5 seconds - should complete within 120s
  submitted: 60000,   // 1 minute - long-running operations
  'input-required': null  // Don't poll - wait for user input
};

async function pollForUpdates(taskId, currentStatus) {
  const interval = POLLING_INTERVALS[currentStatus];
  if (!interval) return;

  await sleep(interval);

  const response = await adcp.call('tasks/get', {
    task_id: taskId,
    include_result: true
  });

  if (['completed', 'failed', 'canceled'].includes(response.status)) {
    return response;
  }

  return pollForUpdates(taskId, response.status);
}

const TIMEOUTS = {
  sync: 30_000,        // 30 seconds for immediate operations
  interactive: 300_000, // 5 minutes for human input
  working: 120_000,    // 2 minutes for working tasks
  submitted: 86_400_000 // 24 hours for submitted tasks
};

function setTimeoutForStatus(status) {
  switch (status) {
    case 'working': return TIMEOUTS.working;
    case 'submitted': return TIMEOUTS.submitted;
    case 'input-required': return TIMEOUTS.interactive;
    default: return TIMEOUTS.sync;
  }
}

// 保留中のオペレーションを取得
const pending = await session.call('tasks/list', {
  filters: {
    statuses: ["submitted", "working", "input-required"]
  }
});

// ローカル状態と突き合わせ
const missingTasks = pending.tasks.filter(task =>
  !localState.hasTask(task.task_id)
);

// 未追跡タスクの監視を再開
for (const task of missingTasks) {
  startPolling(task.task_id);
}