Run your first harness

import { HarnessRuntime, type ExecutionDriver } from "@agentium/harness";

const driver: ExecutionDriver = {
  id: "hello",
  version: 1,
  capabilities: {
    controls: ["follow_up"],
    durable: false,
    policyCoverage: "local",
    controlledExecution: true,
  },
  async start(request, services) {
    const text = `Hello, ${String(request.input)}!`;
    services.append([
      { role: "user", content: request.input },
      { role: "assistant", content: text },
    ]);
    services.emit({ type: "text.delta", text });
    return { text };
  },
};

const runtime = new HarnessRuntime({
  driver,
  grants: { toolIds: [], modelRoles: [] },
  budgets: { maxModelCalls: 0, maxToolCalls: 0 },
});
const identity = { tenantId: "demo", userId: "developer" };
const handle = runtime.start("Agentium", { identity, sessionId: "hello" });

for await (const event of handle.events()) {
  console.log(event.sequence, event.payload.type);
}
const result = await handle.result();
console.log(result.status, result.text);
console.log(await runtime.resources.closeSession(identity, "hello"));

import { openai } from "@agentium/core";
import { agentDriver, HarnessRuntime, research } from "@agentium/harness";

const runtime = new HarnessRuntime({
  definition: research({
    text: {
      id: "project-notes",
      entries: [{ id: "scope", text: "The project studies shipping delays." }],
    },
  }),
  driver: agentDriver({
    name: "research-assistant",
    model: openai(process.env.OPENAI_MODEL ?? "gpt-6.1-sol"),
    instructions: "Answer using the supplied sources. Say when the sources do not answer the question.",
  }),
  grants: { toolIds: [], modelRoles: ["main"] },
  budgets: { maxModelCalls: 4, maxToolCalls: 0, maxTokens: 8000 },
});

const identity = { tenantId: "demo", userId: "developer" };
try {
  const result = await runtime.run("What does this project study?", {
    identity,
    sessionId: "research-1",
  });
  console.log(result.status, result.text);
  if (result.reason) console.log(result.reason.code, result.reason.message);
} finally {
  const diagnostics = await runtime.resources.closeSession(identity, "research-1");
  if (diagnostics.length) console.error(diagnostics);
}