Product

import { HoronAgentClient } from "./vendor/horon-agent-sdk";

// Your application implements this lookup. Honor the signal so a cancel stops the work.
async function lookupTicket(id: string, options: { signal: AbortSignal }) {
  const response = await fetch("https://tickets.example.com/api/tickets/" + id, { signal: options.signal });
  return (await response.json()) as { id: string; title: string };
}

// A private instance: its own sessions and sockets, stopped by close().
const client = await HoronAgentClient.launch({ workingDir: process.cwd() });

const session = await client.createSession({
  workingDir: process.cwd(),
  tools: {
    enabled: ["read"],
    custom: [
      {
        name: "lookup_ticket",
        description: "Look up a ticket in the application's ticket store",
        parameters: {
          type: "object",
          properties: { id: { type: "string" } },
          required: ["id"],
          additionalProperties: false,
        },
        execute: async (input, { signal }) => {
          const ticket = await lookupTicket(String(input.id), { signal });
          return JSON.stringify(ticket);
        },
      },
    ],
  },
});

// Ask for JSON against a schema; the SDK validates the answer and retries corrections.
const result = await client.runStructured<{ summary: string; count: number }>(
  session.session_id,
  "Summarize the open tickets for this repository",
  {
    schema: {
      type: "object",
      additionalProperties: false,
      required: ["summary", "count"],
      properties: {
        summary: { type: "string" },
        count: { type: "integer", minimum: 0 },
      },
    },
  },
);

console.log(result.data.summary, result.data.count);
await client.close();