Агент — это цикл: инструменты, правила, скилы и субагенты

import { execFileSync } from "node:child_process";

const tools = [{
  name: "run_tests",
  description: "Запускает PHPUnit и возвращает вывод. Вызывай после каждой правки кода.",
  input_schema: {
    type: "object",
    properties: { path: { type: "string", description: "Файл или папка с тестами, по умолчанию tests" } },
  },
}];

const handlers = {
  run_tests: ({ path = "tests" }) => {
    if (!/^tests[\w\/.-]*$/.test(path)) throw new Error("path должен быть внутри tests/");
    try { return execFileSync("vendor/bin/phpunit", [path], { encoding: "utf8" }); }
    catch (e) { return e.stdout + e.stderr; } // упавшие тесты — тоже полезный результат
  },
};

async function callModel(messages) {
  const res = await fetch("https://api.anthropic.com/v1/messages", {
    method: "POST",
    headers: { "content-type": "application/json", "x-api-key": process.env.ANTHROPIC_API_KEY, "anthropic-version": "2023-06-01" },
    body: JSON.stringify({ model: "claude-opus-5-5", max_tokens: 4096, tools, messages }),
  });
  return res.json();
}

const messages = [{ role: "user", content: "Тест PriceTest падает. Найди причину и почини." }];
for (let step = 0; step < 20; step++) {             // лимит шагов — защита от петли
  const res = await callModel(messages);
  messages.push({ role: "assistant", content: res.content });
  if (res.stop_reason !== "tool_use") {
    console.log(res.content.filter(b => b.type === "text").map(b => b.text).join("\n"));
    break;
  }
  const results = [];
  for (const block of res.content.filter(b => b.type === "tool_use")) {
    try {
      results.push({ type: "tool_result", tool_use_id: block.id, content: await handlers[block.name](block.input) });
    } catch (e) {
      results.push({ type: "tool_result", tool_use_id: block.id, content: String(e.message), is_error: true });
    }
  }
  messages.push({ role: "user", content: results });  // все результаты шага — одним сообщением
}

import { execFileSync } from "node:child_process";

type Block =
  | { type: "text"; text: string }
  | { type: "tool_use"; id: string; name: string; input: Record<string, unknown> };
interface ModelResponse { stop_reason: "end_turn" | "tool_use" | "max_tokens"; content: Block[] }
type Handler = (input: Record<string, unknown>) => string;

const handlers: Record<string, Handler> = {
  run_tests: (input) => {
    const path = typeof input.path === "string" ? input.path : "tests";
    if (!path.startsWith("tests")) throw new Error("path должен быть внутри tests/");
    return execFileSync("vendor/bin/phpunit", [path], { encoding: "utf8" });
  },
};

async function runAgent(task: string, call: (m: unknown[]) => Promise<ModelResponse>): Promise<string> {
  const messages: unknown[] = [{ role: "user", content: task }];
  for (let step = 0; step < 20; step++) {
    const res = await call(messages);
    messages.push({ role: "assistant", content: res.content });
    if (res.stop_reason !== "tool_use") {
      return res.content.flatMap(b => (b.type === "text" ? [b.text] : [])).join("\n");
    }
    const results = res.content.flatMap(b => {
      if (b.type !== "tool_use") return [];
      const handler = handlers[b.name];
      try {
        if (!handler) throw new Error(`Неизвестный инструмент ${b.name}`);
        return [{ type: "tool_result", tool_use_id: b.id, content: handler(b.input) }];
      } catch (e) {
        return [{ type: "tool_result", tool_use_id: b.id, content: String(e), is_error: true }];
      }
    });
    messages.push({ role: "user", content: results });
  }
  return "Остановлено: лимит шагов";
}

<?php
$tools = [[
    'name' => 'run_tests',
    'description' => 'Запускает PHPUnit и возвращает вывод. Вызывай после каждой правки кода.',
    'input_schema' => [
        'type' => 'object',
        'properties' => ['path' => ['type' => 'string', 'description' => 'Файл или папка с тестами']],
    ],
]];

$handlers = [
    'run_tests' => function (array $input): string {
        $path = $input['path'] ?? 'tests';
        if (!preg_match('~^tests[\w/.-]*$~', $path)) {
            throw new InvalidArgumentException('path должен быть внутри tests/');
        }
        // escapeshellarg: модель не допишет в команду ничего своего
        return (string) shell_exec('vendor/bin/phpunit ' . escapeshellarg($path) . ' 2>&1');
    },
];

function callModel(array $messages, array $tools): array {
    $ch = curl_init('https://api.anthropic.com/v1/messages');
    curl_setopt_array($ch, [
        CURLOPT_POST => true,
        CURLOPT_RETURNTRANSFER => true,
        CURLOPT_HTTPHEADER => ['content-type: application/json', 'x-api-key: ' . getenv('ANTHROPIC_API_KEY'), 'anthropic-version: 2023-06-01'],
        CURLOPT_POSTFIELDS => json_encode(['model' => 'claude-opus-5-5', 'max_tokens' => 4096, 'tools' => $tools, 'messages' => $messages]),
    ]);
    return json_decode(curl_exec($ch), true, flags: JSON_THROW_ON_ERROR);
}

$messages = [['role' => 'user', 'content' => 'Тест PriceTest падает. Найди причину и почини.']];
for ($step = 0; $step < 20; $step++) {
    $res = callModel($messages, $tools);
    $messages[] = ['role' => 'assistant', 'content' => $res['content']];
    if ($res['stop_reason'] !== 'tool_use') {
        break;
    }
    $results = [];
    foreach ($res['content'] as $block) {
        if ($block['type'] !== 'tool_use') continue;
        try {
            $out = ($handlers[$block['name']] ?? throw new RuntimeException('Неизвестный инструмент'))($block['input']);
            $results[] = ['type' => 'tool_result', 'tool_use_id' => $block['id'], 'content' => $out];
        } catch (Throwable $e) {
            $results[] = ['type' => 'tool_result', 'tool_use_id' => $block['id'], 'content' => $e->getMessage(), 'is_error' => true];
        }
    }
    $messages[] = ['role' => 'user', 'content' => $results];
}

import os
import re
import subprocess
import requests

TOOLS = [{
    "name": "run_tests",
    "description": "Запускает pytest и возвращает вывод. Вызывай после каждой правки кода.",
    "input_schema": {
        "type": "object",
        "properties": {"path": {"type": "string", "description": "Файл или папка с тестами"}},
    },
}]

def run_tests(path: str = "tests") -> str:
    if not re.fullmatch(r"tests[\w/.-]*", path):
        raise ValueError("path должен быть внутри tests/")
    # список аргументов, без shell=True
    proc = subprocess.run(["pytest", path, "-q"], capture_output=True, text=True)
    return proc.stdout + proc.stderr

HANDLERS = {"run_tests": run_tests}

def call_model(messages):
    res = requests.post(
        "https://api.anthropic.com/v1/messages",
        headers={"content-type": "application/json", "x-api-key": os.environ["ANTHROPIC_API_KEY"], "anthropic-version": "2023-06-01"},
        json={"model": "claude-opus-5-5", "max_tokens": 4096, "tools": TOOLS, "messages": messages},
        timeout=120,
    )
    res.raise_for_status()
    return res.json()

messages = [{"role": "user", "content": "Тест test_price падает. Найди причину и почини."}]
for step in range(20):
    res = call_model(messages)
    messages.append({"role": "assistant", "content": res["content"]})
    if res["stop_reason"] != "tool_use":
        break
    results = []
    for block in res["content"]:
        if block["type"] != "tool_use":
            continue
        try:
            out = HANDLERS[block["name"]](**block["input"])
            results.append({"type": "tool_result", "tool_use_id": block["id"], "content": out})
        except Exception as e:
            results.append({"type": "tool_result", "tool_use_id": block["id"], "content": str(e), "is_error": True})
    messages.append({"role": "user", "content": results})