Вызов инструментов

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

const TOOLS: Anthropic.Tool[] = [
  {
    name: "get_diff",
    description:
      "Возвращает diff pull request по его номеру. Вызывай в начале ревью, " +
      "чтобы увидеть изменения, прежде чем читать отдельные файлы.",
    input_schema: {
      type: "object",
      properties: {
        pr: { type: "integer", description: "Номер pull request" },
      },
      required: ["pr"],
    },
  },
  {
    name: "read_file",
    description:
      "Читает файл из основной ветки репозитория. Вызывай, когда из diff " +
      "непонятен контекст: как используется изменённая функция, какие есть тесты.",
    input_schema: {
      type: "object",
      properties: {
        path: { type: "string", description: "Путь от корня репозитория" },
      },
      required: ["path"],
    },
  },
];

const client = new Anthropic();

async function runTool(name: string, input: unknown): Promise<string> {
  const args = input as Record<string, any>;
  switch (name) {
    case "get_diff":
      return await fetchDiff(args.pr);
    case "read_file":
      return await fetchFile(args.path);
    default:
      throw new Error(`Неизвестный инструмент ${name}`);
  }
}

async function review(pr: number): Promise<string> {
  const messages: Anthropic.MessageParam[] = [
    { role: "user", content: `Проверь pull request #${pr} и напиши замечания.` },
  ];

  for (let i = 0; i < 20; i++) {
    const response = await client.messages.create({
      model: "claude-opus-5",
      max_tokens: 16000,
      system: REVIEW_RULES,
      tools: TOOLS,
      messages,
    });

    if (response.stop_reason === "end_turn") {
      return response.content
        .filter((b): b is Anthropic.TextBlock => b.type === "text")
        .map((b) => b.text)
        .join("\n");
    }
    if (response.stop_reason !== "tool_use") {
      throw new Error(`stop_reason: ${response.stop_reason}`);
    }

    messages.push({ role: "assistant", content: response.content });

    const results: Anthropic.ToolResultBlockParam[] = [];
    for (const block of response.content) {
      if (block.type !== "tool_use") continue;
      try {
        results.push({
          type: "tool_result",
          tool_use_id: block.id,
          content: await runTool(block.name, block.input),
        });
      } catch (err) {
        results.push({
          type: "tool_result",
          tool_use_id: block.id,
          content: err instanceof Error ? err.message : String(err),
          is_error: true,
        });
      }
    }
    messages.push({ role: "user", content: results });
  }
  throw new Error("Слишком много итераций");
}

import Anthropic from "@anthropic-ai/sdk";
import { betaZodTool } from "@anthropic-ai/sdk/helpers/beta/zod";
import { z } from "zod";

const client = new Anthropic();

const getDiff = betaZodTool({
  name: "get_diff",
  description: "Возвращает diff pull request по номеру. Вызывай в начале ревью.",
  inputSchema: z.object({
    pr: z.number().int().describe("Номер pull request"),
  }),
  run: async ({ pr }) => fetchDiff(pr),
});

const readFile = betaZodTool({
  name: "read_file",
  description:
    "Читает файл из основной ветки. Вызывай, когда из diff непонятен контекст.",
  inputSchema: z.object({
    path: z.string().describe("Путь от корня репозитория"),
  }),
  run: async ({ path }) => fetchFile(path),
});

const finalMessage = await client.beta.messages.toolRunner({
  model: "claude-opus-5",
  max_tokens: 16000,
  system: REVIEW_RULES,
  tools: [getDiff, readFile],
  messages: [{ role: "user", content: "Проверь pull request #482." }],
});

for (const block of finalMessage.content) {
  if (block.type === "text") console.log(block.text);
}

const postComment = betaZodTool({
  name: "post_review_comment",
  description: "Оставляет комментарий к pull request. Вызывай только для финальных замечаний.",
  inputSchema: z.object({
    pr: z.number().int(),
    body: z.string().describe("Текст комментария в Markdown"),
  }),
  run: async ({ pr, body }) => {
    const ok = await askHuman(`Опубликовать в PR #${pr}?\n\n${body}`);
    if (!ok) return "Пользователь отклонил публикацию комментария.";
    await publishComment(pr, body);
    return "Комментарий опубликован.";
  },
});