Goal

await sdk.agent.stream({
  agentWallet,
  message: "/goal Increase test coverage to 90%",
  threadId: "quality",
});

await sdk.agent.stream({
  agentWallet,
  message: "Start with the auth module — write tests for the login flow",
  threadId: "quality",
});

await sdk.agent.stream({
  agentWallet,
  message: "Now cover the user service and the API routes",
  threadId: "quality",
});

const stream = sdk.agent.stream({
  agentWallet,
  message: "/goal status",
  threadId: "quality",
});

for await (const event of stream) {
  if (event.type === "action" && event.action === "goal") {
    console.log(event.result.goal);
  }
}

// Pause while you handle something else
sdk.agent.stream({ agentWallet, message: "/goal pause", threadId: "quality" });

// Pick up later
sdk.agent.stream({ agentWallet, message: "/goal resume", threadId: "quality" });

// Mark done when satisfied
sdk.agent.stream({ agentWallet, message: "/goal complete", threadId: "quality" });

// Or remove it completely
sdk.agent.stream({ agentWallet, message: "/goal clear", threadId: "quality" });

type GoalState = {
  id: string;          // unique goal identifier
  threadId: string;    // thread this goal belongs to
  objective: string;   // the pinned objective text
  status: GoalStatus;  // current lifecycle state
  progress?: string;   // optional summary of what's been done so far
  createdAt: number;   // creation timestamp (ms)
  updatedAt: number;   // last update timestamp (ms)
};

type GoalStatus =
  | "active"    // the agent is pursuing this goal
  | "paused"    // temporarily on hold
  | "completed" // the goal was achieved
  | "cleared";  // the goal was removed