Plan

// 1. Create the plan
const stream = sdk.agent.stream({
  agentWallet,
  message: "/plan Build a REST API with auth, routes, and tests",
  threadId: "api-build",
});

for await (const event of stream) {
  if (event.type === "plan.proposed") {
    console.log(event.markdown); // human-readable plan summary
  }
}

// 2. Run it
const runStream = sdk.agent.stream({
  agentWallet,
  message: "/plan run",
  threadId: "api-build",
});

for await (const event of runStream) {
  switch (event.type) {
    case "task.completed":
      console.log(`Done: ${event.taskId}`);
      break;
    case "task.blocked":
    case "task.failed":
      console.log(`${event.type}: ${event.taskId}`);
      break;
  }
}

type PlanState = {
  id: string;                // unique plan identifier
  threadId: string;          // thread this plan belongs to
  status: PlanStatus;        // current lifecycle state
  tasks: TaskRecord[];       // ordered list of tasks
  goal: string;              // the objective the plan achieves
  createdAt: number;         // creation timestamp (ms)
  updatedAt: number;         // last update timestamp (ms)
};

type PlanStatus =
  | "draft"              // plan created, not yet proposed
  | "proposed"           // plan submitted for review
  | "awaiting_approval"  // waiting for an approver decision
  | "running"            // execution in progress
  | "checking"           // verifying task results
  | "blocked"            // a task is blocked
  | "completed"          // all tasks finished successfully
  | "failed"             // a task failed and execution stopped
  | "cancelled";         // the plan was cancelled

type TaskRecord = {
  id: string;          // unique task identifier
  title: string;       // short human-readable label
  description: string; // what the task does
  status: TaskStatus;  // current task state
  result?: string;     // output, once the task finishes
  error?: string;      // failure reason, if status is "failed"
  order: number;       // position in the task list
};

type TaskStatus =
  | "todo"       // not started
  | "doing"      // currently executing
  | "blocked"    // waiting on a dependency or input
  | "done"       // completed successfully
  | "failed"     // could not complete
  | "cancelled"; // removed from the plan

await sdk.agent.decide({
  agentWallet,
  runId: "run-id-from-stream",
  proposalId: "proposal_...",
  version: 1,
  decision: "approved", // "approved" | "rejected" | "changes_requested"
  approver: "0xYourWallet",
  reason: "Looks good",
});