Первый управляемый агент

import Anthropic from "@anthropic-ai/sdk";

const client = new Anthropic();

// Среда: облачный контейнер с доступом в сеть (нужен для клонирования репозитория)
const environment = await client.beta.environments.create({
  name: "pr-review-env",
  config: { type: "cloud", networking: { type: "unrestricted" } },
});

// Агент: модель, правила, инструменты. Создаётся ОДИН раз.
const agent = await client.beta.agents.create({
  name: "PR Reviewer",
  model: "claude-opus-5",
  system: `Ты ревьюер кода в продуктовой студии. Репозиторий примонтирован в /workspace/repo.
Проверь изменения ветки относительно main: прочитай diff, посмотри связанный код,
запусти тесты. Замечания формулируй конкретно, со ссылкой на файл и строку.
Финальный список замечаний опубликуй через инструмент post_review_comment.`,
  tools: [
    {
      type: "agent_toolset_20260401",
      default_config: { enabled: true, permission_policy: { type: "always_allow" } },
      configs: [
        { name: "write", enabled: false },
        { name: "edit", enabled: false },
      ],
    },
    {
      type: "custom",
      name: "post_review_comment",
      description: "Публикует итоговый комментарий ревью в pull request. Вызывай один раз, в конце.",
      input_schema: {
        type: "object",
        properties: {
          pr: { type: "integer", description: "Номер pull request" },
          body: { type: "string", description: "Текст комментария в Markdown" },
        },
        required: ["pr", "body"],
      },
    },
  ],
});

console.log("ENVIRONMENT_ID =", environment.id);
console.log("AGENT_ID =", agent.id, "version", agent.version);

const AGENT_ID = process.env.AGENT_ID!;
const AGENT_VERSION = Number(process.env.AGENT_VERSION);
const ENVIRONMENT_ID = process.env.ENVIRONMENT_ID!;

async function startReview(prNumber: number, branch: string) {
  const session = await client.beta.sessions.create({
    agent: { type: "agent", id: AGENT_ID, version: AGENT_VERSION },
    environment_id: ENVIRONMENT_ID,
    title: `Review PR #${prNumber}`,
    resources: [
      {
        type: "github_repository",
        url: "https://github.com/amiga-example/portal",
        mount_path: "/workspace/repo",
        authorization_token: process.env.GITHUB_TOKEN,
        branch,
      },
    ],
  });
  console.log(`Трасса: https://platform.claude.com/workspaces/default/sessions/${session.id}`);
  return session.id;
}

async function runReview(sessionId: string, prNumber: number) {
  const send = (events: any[]) =>
    client.beta.sessions.events.send(sessionId, { events });

  await Promise.all([
    consumeEvents(sessionId, send),
    send([
      {
        type: "user.message",
        content: [{ type: "text", text: `Проверь pull request #${prNumber}.` }],
      },
    ]),
  ]);
}

async function consumeEvents(
  sessionId: string,
  send: (events: any[]) => Promise<unknown>,
) {
  while (true) {
    const stream = await client.beta.sessions.events.stream(sessionId);
    const pending: Anthropic.Beta.Sessions.BetaManagedAgentsAgentCustomToolUseEvent[] = [];

    for await (const event of stream) {
      switch (event.type) {
        case "agent.message":
          for (const block of event.content) {
            if (block.type === "text") process.stdout.write(block.text);
          }
          break;
        case "agent.tool_use":
          console.log(`\n[инструмент] ${event.name}`);
          break;
        case "agent.custom_tool_use":
          pending.push(event);
          break;
        case "session.status_idle":
          break;
        case "session.status_terminated":
          return;
      }
      if (event.type === "session.status_idle") break;
    }

    if (pending.length === 0) return;

    const results = [];
    for (const call of pending) {
      results.push({
        type: "user.custom_tool_result" as const,
        custom_tool_use_id: call.id,
        content: [{ type: "text" as const, text: await runCustomTool(call) }],
      });
    }
    await send(results);
  }
}

async function runCustomTool(
  call: Anthropic.Beta.Sessions.BetaManagedAgentsAgentCustomToolUseEvent,
): Promise<string> {
  if (call.name !== "post_review_comment") return `Неизвестный инструмент ${call.name}`;
  const { pr, body } = call.input as { pr: number; body: string };

  const approved = await askHuman(`Опубликовать ревью в PR #${pr}?\n\n${body}`);
  if (!approved) return "Пользователь отклонил публикацию. Ревью не опубликовано.";

  await publishComment(pr, body);
  return "Комментарий опубликован.";
}