DeepResearch HITL

while (true) {
  const status = await client.deepresearch.status(taskId);

  if ((status.status === "awaiting_input" || status.status === "paused") && status.interaction) {
    const { interaction_id } = status.interaction;
    await client.deepresearch.respond(taskId, interaction_id, buildResponse(status.interaction));
  } else if (["completed", "failed", "cancelled"].includes(status.status!)) {
    break;
  }

  await new Promise((r) => setTimeout(r, 5000));
}

// planning_questions - interaction.data has { questions: [{ question, context }] }
{ answers: [{ question: "What regions?", answer: "North America and EU" }] }

// plan_review - interaction.data has { plan, estimated_steps, research_areas }
{ approved: true }
{ approved: false, modifications: "Focus more on supply chain analysis" }

// source_review - interaction.data has { domains: [{ domain, ai_recommendation }], total_sources }
{ included_domains: ["sec.gov"], excluded_domains: ["example.com"] }
// Domains not listed fall back to the AI recommendation; pass [] to accept all recommendations.

// outline_review - interaction.data has { outline, sections }
{ approved: true }
{ approved: false, modifications: "Add a regulatory risks section" }

await client.deepresearch.respondPlanningQuestions(taskId, interactionId, [
  { question: "What regions?", answer: "North America and EU" },
]);
await client.deepresearch.approvePlan(taskId, interactionId, "...");     // omit string to approve
await client.deepresearch.respondSourceReview(taskId, interactionId, {
  includedDomains: ["sec.gov"], excludedDomains: ["example.com"],
});
await client.deepresearch.approveOutline(taskId, interactionId, "...");  // omit to approve

for (const entry of (await client.deepresearch.status(taskId)).hitl_history ?? []) {
  console.log(entry.type, "auto_continued:", entry.auto_continued);
}