Wardrik

A client for one Wardrik server.

const wardrik = new Wardrik();
const agent = wardrik.agent("support-bot");
await agent.define({ model: "anthropic:claude-sonnet-4-5" });

for await (const event of agent.stream("What's on fire?")) {
  if (event.type === "wardrik.message.delta") process.stdout.write(event.data.delta);
}

Throws a TypeError without a token.

Extends

• Operations

Constructors

Constructor

new Wardrik(options?): Wardrik;

Parameters

Parameter	Type
options?	WardrikOptions

Returns

Wardrik

Overrides

Operations.constructor

Properties

agents

readonly agents: AgentsOperations;

The agents.* operations.

Inherited from

Operations.agents

---

interrupts

readonly interrupts: InterruptsOperations;

The interrupts.* operations.

Inherited from

Operations.interrupts

---

events

readonly events: EventsOperations;

The events.* operations.

Inherited from

Operations.events

---

audit

readonly audit: AuditOperations;

The audit.* operations.

Inherited from

Operations.audit

---

deployment

readonly deployment: DeploymentOperations;

The deployment.* operations.

Inherited from

Operations.deployment

Methods

agent()

agent(id, options?): Agent;

Returns an agent, or one of its conversations. Makes no request.

const agent = wardrik.agent("support-bot");
const thread = wardrik.agent("support-bot", { conversation: "C1-1696.1234" });

Parameters

Parameter	Type
id	string
options?	AgentOptions

Returns

Agent

---

run()

run<Id>(
   id,
   input,
   options?
): Promise<Outputs[Id]>;

Runs an operation by its ID, with all its parameters in input.

await wardrik.run("agent.ask", { agent: "support-bot", content: "Hi" });

Type Parameters

Type Parameter

Id extends | "agent.read" | "agent.define" | "agent.forget" | "agent.ask" | "agent.decide" | "agent.authorization" | "agent.cancel" | "agent.events" | "agent.timeline" | "agent.runs" | "agent.approve" | "agent.deny" | "agent.definition" | "agent.spawn" | "agent.stop" | "agent.clear" | "agent.calls" | "agent.kill" | "agent.trigger_set" | "agent.trigger_remove" | "agent.move" | "agents.list" | "agents.forget" | "agents.cancel" | "interrupts.list" | "events.list" | "events.head" | "audit.list" | "deployment.reload" | "deployment.nodes"

Parameters

Parameter	Type
id	Id
input	Inputs[Id]
options?	CallOptions

Returns

Promise<Outputs[Id]>

---

listen()

listen(handlers, options?): Promise<void>;

Passes each event to the handler for its type, with the cursor after it.

await wardrik.listen(
  { "wardrik.run.completed": (event, cursor) => saveRun(event, cursor) },
  { agents: ["support-bot"], after: savedCursor },
);

• Waits for each handler before the next event.
• Each event arrives at least once. Drop repeats by event.id.
• Resolves when signal aborts. Rejects with what a handler throws.

Parameters

Parameter	Type
handlers	Handlers
options?	ListenOptions

Returns

Promise<void>

---

tool()

tool<Input>(definition): this;

Adds a tool that runs in this process. Agents whose tools include workers/* call it as workers__<name>.

wardrik.tool({
  name: "refund_order",
  description: "Refund an order in full.",
  input: z.object({ orderId: z.string() }),
  idempotent: true,
  run: ({ orderId }, { idempotencyKey }) =>
    stripe.refunds.create({ payment_intent: orderId }, { idempotencyKey }),
});

await wardrik.work();

Type Parameters

Type Parameter
Input extends StandardSchemaWithJSON

Parameters

Parameter	Type
definition	ToolDefinition<Input>

Returns

this

---

work()

work(options?): Promise<void>;

Answers calls to the tools added with tool until signal aborts. Reconnects on its own. Throws a WardrikError if the token is refused.

Parameters

Parameter	Type
options?	WorkOptions

Returns

Promise<void>