CrossAgentMCP — A2A пул MCP

Минимальная реализация концепции A2A.md: A2A пул MCP, в котором

1. любой агент может зарегистрироваться в общем пуле,

2. любой агент может присоединиться к мультиагентной сессии,

3. агенты наблюдают за активностью друг друга, критикуют коллег после завершения, самоулучшаются и продолжают работу без вмешательства человека, пока общая цель не будет удовлетворена каждым агентом в сессии.

Архитектура

Три типа процессов:

        ┌────────────────── POOL (:9100, FastAPI HTTP JSON-RPC) ──────────────────┐
        │  registry / sessions / activity / critique / goal  (in-memory control   │
        │  plane — does NOT route work messages)                                  │
        └──────────────────────────────────────────────────────────────────────────┘
            ▲ pool JSON-RPC (PoolClient)            ▲ pool JSON-RPC (per-agent bridge)
            │                                       │
      ┌─────┴──────┐    peer A2A (SendMessage/GetTask)   ┌─────┴──────┐
      │ orchestrator│◄──────────────────────────────────►│ agent-N    │ … :9101..9103
      └────────────┘      each agent runs its own         └────────────┘
          headless            v1.0 A2A HTTP server

• Пул (crossagent/pool.py) — центральная плоскость управления: реестр, сессии, журнал активности, добавляемый только в конец для каждой сессии, нити критики и удовлетворённость каждого агента.

• Агенты — каждый представляет собой директорию (agents/<role>/) с:

  • server.py — HTTP-сервер A2A v1.0 (плоскость данных пира);

  • .mcp.json — регистрирует мост MCP stdio a2a (crossagent/a2a_bridge.py);

  • CLAUDE.md — роль + контракт на каждый ход.

• Оркестратор (crossagent/orchestrator.py) — единственный компонент, который продвигает время: регистрирует агентов, создаёт сессию, затем по кругу запускает каждого агента без головы (claude -p), передавая ему дельту активности/критики с момента его последнего хода, пока все участники не будут удовлетворены (или не сработает предохранитель по бюджету ходов / отсутствию прогресса).

Related MCP server: kitty-hive

Протокол

Соответствует A2A v1.0 (методы JSON-RPC в PascalCase, JSON в camelCase, перечисления в SCREAMING_SNAKE_CASE). См. crossagent/a2a.py.

Настройка

uv sync          # Python 3.11+ venv + deps

Использование

make test        # unit tests (protocol / pool / orchestrator with fake agents)
make smoke       # pool + 2 A2A servers up; scripted round-trip (no real Claude)
make demo        # full headless 3-agent demo (writer / critic / lead) — needs `claude`

Демонстрационная цель

demo/goal.json просит трёх агентов — писатель, критик, лидер — совместно создать demo/output/design.md (дизайн сокращателя URL), пока все трое не объявят себя удовлетворёнными.

Примечания

• Файлы .mcp.json жестко задают путь к репозиторию D:/GitRepo-AI/CrossAgentMCP (соответствует ссылке claude-a2a); обновите его, если вы переместите репозиторий.

• Серверы пула и агентов хранят состояние в памяти; они сбрасываются при перезапуске.