TypeScript SDK

export {};

const apiKey = process.env.THREETONE_API_KEY;
if (!apiKey?.trim()) {
  throw new Error("Set THREETONE_API_KEY in your server environment.");
}

function parseAgentPage(value: unknown) {
  if (
    typeof value !== "object" || value === null ||
    !("agents" in value) || !Array.isArray(value.agents) ||
    !("has_more" in value) || typeof value.has_more !== "boolean"
  ) {
    throw new Error("Invalid agents response.");
  }
  const nextCursor = "next_cursor" in value ? value.next_cursor : null;
  if (nextCursor !== null && typeof nextCursor !== "string") {
    throw new Error("Invalid cursor.");
  }
  if (value.has_more && !nextCursor) {
    throw new Error("Missing next cursor.");
  }
  const agents = value.agents.map((agent: unknown) => {
    if (
      typeof agent !== "object" || agent === null ||
      !("agent_id" in agent) || typeof agent.agent_id !== "string" ||
      !("name" in agent) || typeof agent.name !== "string"
    ) {
      throw new Error("Invalid agent entry.");
    }
    return { agent_id: agent.agent_id, name: agent.name };
  });
  return { agents, has_more: value.has_more, next_cursor: nextCursor };
}

async function listAgents(apiKey: string, cursor?: string) {
  const url = new URL("https://api.threetone.in/v1/convai/agents");
  url.searchParams.set("page_size", "20");
  if (cursor !== undefined) url.searchParams.set("cursor", cursor);

  let response: Response;
  try {
    response = await fetch(url, {
      headers: { "x-api-key": apiKey },
      signal: AbortSignal.timeout(30_000),
      redirect: "error",
    });
  } catch {
    throw new Error(
      "GET /v1/convai/agents failed before a usable response arrived.",
    );
  }

  const requestId = JSON.stringify(
    (response.headers.get("X-Request-Id") ?? "unavailable").slice(0, 128),
  );
  const context =
    `GET /v1/convai/agents status=${response.status} request_id=${requestId}`;
  if (response.status !== 200) throw new Error(context);

  try {
    const value: unknown = await response.json();
    return parseAgentPage(value);
  } catch {
    throw new Error(`Unreadable or invalid agents response; ${context}`);
  }
}

try {
  const page = await listAgents(apiKey);
  for (const agent of page.agents) {
    console.log(agent.agent_id, agent.name);
  }
  console.log("More agents available:", page.has_more);
} catch (error) {
  console.error(error instanceof Error ? error.message : "Agent read failed.");
  process.exitCode = 1;
}