Tasks API

// Fetch running tasks for a project
const response: Response = await fetch("http://localhost:3000/api/tasks?projectId=proj-8f3a&status=running");
const tasks: Task[] = await response.json();

console.log(`${tasks.length} running tasks`);
tasks.forEach((t: Task) => console.log(`  [${t.priority}] ${t.title}`));

// Create a task with attached documents
const response: Response = await fetch("http://localhost:3000/api/tasks", {
method: "POST",
headers: { "Content-Type": "application/json" },
body: JSON.stringify({
  title: "Summarize meeting notes",
  description: "Extract action items and decisions from the uploaded transcript",
  projectId: "proj-8f3a-4b2c",
  priority: 1,
  assignedAgent: "claude-code",
  agentProfile: "technical-writer",
  documentIds: ["doc-meeting-transcript-001"],
}),
});
const task: Task = await response.json();

console.log(task.id);     // "task-a7c2-..."
console.log(task.status); // "planned"

// Fetch task with usage data to check cost
const response: Response = await fetch("http://localhost:3000/api/tasks/task-9d4e-a1b2");
const task: Task & { usage?: { costMicros: number; modelId: string; totalTokens: number } } = await response.json();

if (task.usage) {
const costUSD: number = task.usage.costMicros / 1_000_000;
console.log(`Model: ${task.usage.modelId}`);
console.log(`Tokens: ${task.usage.totalTokens.toLocaleString()}`);
console.log(`Cost: $${costUSD.toFixed(4)}`);
}

// Escalate and queue a task for immediate execution
await fetch("http://localhost:3000/api/tasks/task-9d4e-a1b2", {
method: "PATCH",
headers: { "Content-Type": "application/json" },
body: JSON.stringify({ status: "queued", priority: 0 }),
});

// Permanently remove a task
await fetch("http://localhost:3000/api/tasks/task-9d4e-a1b2", { method: "DELETE" });

// Fire-and-forget execution — poll status or stream logs to track progress
const res: Response = await fetch("http://localhost:3000/api/tasks/task-9d4e-a1b2/execute", {
method: "POST",
});

if (res.status === 202) {
console.log("Agent is running — stream /logs to follow progress");
} else if (res.status === 429) {
console.log("Budget exceeded — increase budget in Settings");
}

// Resume a failed task — the agent continues where it left off
const res: Response = await fetch("http://localhost:3000/api/tasks/task-9d4e-a1b2/resume", {
method: "POST",
});

if (res.status === 400) {
const err: { error: string } = await res.json();
if (err.error.includes("Resume limit")) {
  // Re-queue for fresh execution instead
  await fetch("http://localhost:3000/api/tasks/task-9d4e-a1b2", {
    method: "PATCH",
    headers: { "Content-Type": "application/json" },
    body: JSON.stringify({ status: "queued" }),
  });
}
}

// Cancel a runaway task
await fetch("http://localhost:3000/api/tasks/task-9d4e-a1b2/cancel", { method: "POST" });

// Auto-approve file writes to the reports directory
await fetch("http://localhost:3000/api/tasks/task-9d4e-a1b2/respond", {
method: "POST",
headers: { "Content-Type": "application/json" },
body: JSON.stringify({
  notificationId: "notif-456",
  behavior: "allow",
  alwaysAllow: true,
  permissionPattern: "write:/reports/*",
}),
});

// Fetch output and render based on detected content type
const response: Response = await fetch("http://localhost:3000/api/tasks/task-9d4e-a1b2/output");
const output: { taskId: string; status: string; result: string; contentType: string } = await response.json();

switch (output.contentType) {
case "markdown": renderMarkdown(output.result); break;
case "json":     renderJSON(JSON.parse(output.result)); break;
case "code":     renderCode(output.result); break;
default:         renderPlainText(output.result);
}

// Stream agent logs in real time
const source = new EventSource("http://localhost:3000/api/tasks/task-9d4e-a1b2/logs");

source.onmessage = (event: MessageEvent) => {
const log: { eventType: string; message: string; timestamp: string } = JSON.parse(event.data);
const time: string = new Date(log.timestamp).toLocaleTimeString();
console.log(`[${time}] [${log.eventType}] ${log.message}`);
};

source.onerror = () => {
console.log("Stream ended — task may have completed");
source.close();
};

// Trace where a task came from
const response: Response = await fetch("http://localhost:3000/api/tasks/task-9d4e-a1b2/provenance");
const prov: { sourceType: string; parentId: string } = await response.json();

console.log(`Source: ${prov.sourceType}`);  // "workflow", "schedule", "manual"
console.log(`Parent: ${prov.parentId}`);

// Show workflow progress alongside current task
const response: Response = await fetch("http://localhost:3000/api/tasks/task-9d4e-a1b2/siblings");
const siblings: { id: string; title: string; status: string }[] = await response.json();

siblings.forEach((s) => {
const icon: string = s.status === "completed" ? "✓" : s.status === "running" ? "⟳" : "○";
console.log(`${icon} ${s.title} (${s.status})`);
});