Мы активно используем Coder больше месяца в продакшне — сейчас он пишет ~90% всего кода в ZvenoAI.
Асинхронный оркестратор на Python: опрашивает Yandex Tracker на задачи с тегом ai-task, запускает агентов Claude для их выполнения, координирует подзадачи эпиков по зависимостям (с автодекомпозицией), мониторит PR на ревью-комментарии, автоматически мёржит PR (с human gate и pre-merge code review), верифицирует деплой после merge, принимает алерты из Alertmanager и стримит вывод в веб-дашборд реального времени. Supervisor проактивно мониторит здоровье агентов через heartbeat и может эскалировать на человека.
Claude API недоступен напрямую из РФ, а оплата зарубежных API-сервисов затруднена. ZvenoAI решает обе проблемы:
- Единый API (
api.zveno.ai/v1) — полностью совместим с OpenAI SDK и Claude Agent SDK - Оплата в рублях — карты, СБП, безнал для юрлиц
- 200+ моделей — OpenAI, Anthropic, Google, xAI и другие через один ключ
- Автоматический failover между провайдерами
Для работы Coder достаточно получить API-ключ на zveno.ai и указать его в .env:
ANTHROPIC_API_KEY=sk-zveno-... # ключ ZvenoAIAPI ZvenoAI совместим с Anthropic SDK — никаких изменений в коде не требуется.
Жизненный цикл: опрос трекера → если задача — эпик: регистрация и координация подзадач через OrchestratorAgent → иначе: разрешение репозиториев → создание worktree → запуск агента (opus) → планирование (opus sub-agent, read-only) → если есть блокеры: запрос информации и остановка, иначе: TDD (сначала тесты, потом реализация) → push и создание PR (если нужен) → мониторинг ревью → агент правит комментарии → human gate (блокировка больших/чувствительных PR) → pre-merge code review (Sonnet sub-agent) → auto-merge → post-merge verification (проверка деплоя) → закрытие задачи в трекере. При рестарте оркестратора сессии агентов возобновляются с полным контекстом через session_id + fork_session.
Агент сам решает, когда задача завершена. PR создаётся только при наличии изменений кода — исследовательские и документационные задачи завершаются без PR.
flowchart TB
tracker["Yandex Tracker"]
github["GitHub"]
claude["Claude API"]
alertmanager["Alertmanager"]
subgraph core["Оркестратор"]
dispatcher["Dispatcher<br/>опрос задач"]
agents["Worker Agents<br/>выполнение задач"]
monitors["Мониторы<br/>PR / needs-info"]
heartbeat["HeartbeatMonitor<br/>здоровье агентов"]
supervisor["Supervisor<br/>чат + память"]
mailbox["Mailbox<br/>межагентное общение"]
epics["Epic Coordinator<br/>координация подзадач"]
gate["Human Gate<br/>блокировка больших PR"]
verifier["Post-Merge Verifier<br/>проверка деплоя"]
escalation["Escalation<br/>эскалация на человека"]
end
subgraph infra["Инфраструктура"]
eventbus["EventBus"]
storage["SQLite Storage"]
end
dashboard["Веб-дашборд<br/>React + xterm.js"]
tracker -- "задачи" --> dispatcher
dispatcher -- "запуск" --> agents
agents -- "код, PR" --> github
agents -- "SDK" --> claude
agents <-- "сообщения" --> mailbox
agents -- "результат" --> monitors
github -- "ревью, CI" --> monitors
monitors -- "промпт" --> agents
monitors -- "human gate" --> gate
gate -- "OK" --> monitors
monitors -- "auto-merge" --> github
monitors -- "после merge" --> verifier
verifier -- "hotfix task" --> tracker
tracker -- "ответы" --> monitors
epics -- "активация<br/>подзадач" --> dispatcher
heartbeat -- "алерты" --> supervisor
supervisor -- "управление" --> tracker
supervisor -- "эскалация" --> escalation --> tracker
alertmanager -- "webhook<br/>(auto-create task)" --> tracker
alertmanager -- "webhook<br/>(prompt)" --> supervisor
core --> eventbus
eventbus --> dashboard
eventbus --> storage
classDef ext fill:#4a90d9,stroke:#2c5ea0,color:#fff
classDef core_s fill:#e8a838,stroke:#b8842c,color:#000
classDef infra_s fill:#6bbf6b,stroke:#4a9a4a,color:#000
classDef dash fill:#f87171,stroke:#c25050,color:#fff
class tracker,github,claude,alertmanager ext
class dispatcher,agents,monitors,heartbeat,supervisor,mailbox,epics,gate,verifier,escalation core_s
class eventbus,storage infra_s
class dashboard dash
| Компонент | Назначение |
|---|---|
orchestrator/main.py |
Асинхронный цикл оркестратора, диспетчеризация задач, мониторинг ревью/needs-info, веб-сервер |
orchestrator/config.py |
Конфигурация из переменных окружения с полями SDK |
orchestrator/constants.py |
Общие перечисления и типы (EventType, PRState, MAX_COMPACTION_CYCLES) |
orchestrator/orchestrator_agent.py |
Обработка результатов — track_pr / retry / escalate / fail / complete, координация эпиков |
orchestrator/orchestrator_tools.py |
Реализация терминальных действий (track_pr, retry, escalate, fail, complete) |
orchestrator/epic_coordinator.py |
Хранилище состояния подзадач эпика, автодекомпозиция, управление готовностью, активация с учётом зависимостей |
orchestrator/agent_runner.py |
Обёртка над Claude Agent SDK, долгоживущие сессии для циклов ревью, захват и возобновление session_id после рестарта |
orchestrator/compaction.py |
Авто-компактификация контекста: should_compact(), summarize_output(), build_continuation_prompt() |
orchestrator/task_dispatcher.py |
Опрос Tracker, запуск агентов с контролем параллелизма через семафор, возобновление сессий после рестарта (resume + fork_session) |
orchestrator/tracker_client.py |
REST-клиент для Yandex Tracker API |
orchestrator/tracker_enums.py |
Перечисления и хелперы для сопоставления статусов Tracker |
orchestrator/tracker_types.py |
TypedDict-определения типов для ответов Tracker API |
orchestrator/tracker_tools.py |
In-process MCP-инструменты, scoped по задаче (без sidecar-процессов) |
orchestrator/heartbeat.py |
Периодический мониторинг здоровья агентов (stuck, long-running, stale review), алертинг supervisor с cooldown |
orchestrator/github_client.py |
GitHub GraphQL-клиент для ревью-тредов, CI, auto-merge (enablePullRequestAutoMerge), проверки готовности к мёржу |
orchestrator/pr_monitor.py |
Цикл мониторинга PR ревью/CI + human gate + pre-merge review + auto-merge + post-merge verification trigger |
orchestrator/pre_merge_reviewer.py |
One-shot sub-agent (Sonnet) для code review перед auto-merge: OWASP checklist, fail-close по умолчанию |
orchestrator/post_merge_verifier.py |
Верификация деплоя после merge: ожидание CI на merge SHA, K8s rollout, sub-agent проверки, авто-создание hotfix |
orchestrator/alertmanager_webhook.py |
Парсинг Alertmanager webhook, дедупликация, маппинг компонентов, авто-создание задач в Tracker |
orchestrator/adr.py |
Architecture Decision Records: создание/список/чтение markdown-файлов в docs/decisions/ |
orchestrator/escalation.py |
Эскалация supervisor → человек: тег needs-human-review + структурированный комментарий в Tracker |
orchestrator/dependency_manager.py |
Автодефер задач с неразрешёнными зависимостями (Tracker links + LLM-экстракция блокеров), рекурентная перепроверка |
orchestrator/k8s_client.py |
Kubernetes client: pod logs/status через in-cluster ServiceAccount, feature-gated (K8S_LOGS_ENABLED) |
orchestrator/metrics.py |
Prometheus-метрики (Counter, Gauge, Histogram) для VictoriaMetrics, endpoint /metrics |
orchestrator/preflight_checker.py |
Preflight-проверки задач перед запуском агента |
orchestrator/llm_utils.py |
Общие утилиты для LLM-вызовов (Haiku) |
orchestrator/needs_info_monitor.py |
Мониторинг статуса needs-info — ожидание ответов от людей |
orchestrator/agent_mailbox.py |
Межагентный почтовый ящик — маршрутизация сообщений, управление inbox, interrupt-доставка |
orchestrator/comm_tools.py |
MCP-инструменты для общения worker-агентов (list peers, send/reply/check messages) |
orchestrator/supervisor.py |
Инициализация SupervisorRunner (memory index, embedder) |
orchestrator/supervisor_chat.py |
Интерактивный стриминг-чат с supervisor-агентом |
orchestrator/supervisor_tools.py |
Supervisor MCP-инструменты — Tracker, GitHub, статистика, память, управление агентами, ADR, env config |
orchestrator/supervisor_prompt_builder.py |
Построение системного промпта для supervisor |
orchestrator/supervisor_memory.py |
SQLite + FTS5 гибридный поиск по markdown-файлам (data/memory/) |
orchestrator/prompt_builder.py |
Построение промптов задач для worker-агентов |
orchestrator/repo_resolver.py |
Клонирование/pull git-репозиториев из repos.yaml, блокировки по репо |
orchestrator/workspace.py |
Создание/очистка git worktree на задачу, блокировки по репо |
orchestrator/workspace_tools.py |
MCP-инструменты для workspace (ленивое создание worktree) |
orchestrator/recovery.py |
Персистенция состояния восстановления, классификация ошибок, отслеживание backoff |
orchestrator/proposal_manager.py |
Жизненный цикл предложений по улучшению |
orchestrator/event_bus.py |
Async pub/sub с кольцевым буфером истории на задачу |
orchestrator/stats_collector.py |
Подписчик EventBus, записывающий статистику в хранилище |
orchestrator/stats_models.py |
Модели данных для персистентной статистики (TaskRun, SupervisorRun и т.д.) |
orchestrator/storage.py |
Абстрактный Storage Protocol для бекендов персистенции |
orchestrator/sqlite_storage.py |
Реализация хранилища на SQLite |
orchestrator/_persistence.py |
Mixin для фоновой персистенции через asyncio-задачи |
orchestrator/web.py |
FastAPI REST + WebSocket + Alertmanager webhook + Prometheus /metrics, раздача React-фронтенда |
frontend/ |
React 19 + Vite + TypeScript + xterm.js терминал |
cp .env.example .env
# Заполнить: YANDEX_TRACKER_TOKEN, YANDEX_TRACKER_ORG_ID, CLAUDE_CODE_OAUTH_TOKEN или ANTHROPIC_API_KEY, GITHUB_TOKEN
docker compose up -d
# Дашборд: http://localhost:8080- Yandex Tracker — организация с очередью задач
- GitHub — токен с правами на целевые репозитории (
reposcope) - Claude API — OAuth-токен Claude Code или API-ключ (Anthropic / ZvenoAI)
- Docker — для локального деплоя через Docker Compose
- Kubernetes — для production-деплоя через Helm
cp .env.example .env
# Заполнить обязательные переменные (см. раздел Аутентификация)
docker compose up -d # запуск
docker compose logs -f # логи
docker compose up -d --build # пересборка после измененийЧто внутри:
| Volume | Путь в контейнере | Назначение |
|---|---|---|
workspace |
/workspace |
Клонированные репозитории и git worktree агентов |
stats-data |
/app/data |
SQLite БД (статистика, состояние задач, PR lifecycle) |
./prompts |
/app/prompts (ro) |
Промпты агентов — монтируются read-only для быстрой правки без пересборки |
| Docker socket | /var/run/docker.sock |
Агенты используют Docker CLI внутри worktree (make gen, docker compose up, testcontainers) |
Docker socket монтируется потому что агенты запускают команды сборки и тесты в целевых репозиториях. Если целевые проекты не используют Docker — можно убрать из
docker-compose.yaml.
Порты:
8080— веб-дашборд (REST API + WebSocket + Prometheus/metrics)
В каталоге helm/ лежит Helm chart. Пример деплоя:
helm install coder ./helm/charts/coder \
-f helm/values/dev/coder.yaml \
--set externalSecrets.enabled=trueКлючевые особенности chart'а:
- ExternalSecrets — секреты (Tracker token, GitHub token, API key) загружаются из Vault через
ExternalSecretCRD. Fallback на Kubernetes Secret еслиexternalSecrets.enabled=false. - Persistent storage — два PVC:
workspace(20Gi, для репозиториев) иstats-data(1Gi, SQLite). - RBAC —
rbac.create=trueсоздаёт Role/RoleBinding для чтения pod logs (нужно дляK8S_LOGS_ENABLED=true). - Docker-in-Docker — опциональный sidecar (
dind.enabled=true) для агентов, использующих Docker CLI внутри worktree. - HTTPRoute — опциональный Gateway API route (
route.enabled=true) для доступа к дашборду. - Recreate strategy — один реплика, Recreate (не Rolling) из-за SQLite и git worktree.
- Graceful shutdown —
terminationGracePeriodSeconds: 120для завершения активных агентов. - Reloader — аннотация
reloader.stakater.com/auto: "true"для авто-рестарта при изменении ConfigMap/Secret.
Структура values:
helm/
charts/coder/ # chart и шаблоны
values.yaml # дефолты (пустые секреты, минимальные ресурсы)
values/
dev/coder.yaml # dev-окружение (ваши значения)
prod/coder.yaml # production
Минимальные ресурсы:
| Контейнер | Requests | Limits |
|---|---|---|
| coder | 400m CPU, 4Gi RAM | 2000m CPU, 8Gi RAM |
| dind (опционально) | 400m CPU, 2Gi RAM | 2000m CPU, 4Gi RAM |
RAM зависит от
MAX_CONCURRENT_AGENTS. Каждый агент — это процесс Claude Code CLI (~500MB-1GB RAM). Для 10 параллельных агентов рекомендуется 8-16Gi.
Оркестратор передаёт учётные данные в Claude Agent SDK. Три варианта (по приоритету):
| Переменная окружения | Описание | Приоритет |
|---|---|---|
CLAUDE_CODE_OAUTH_TOKEN |
Квота подписки Claude Code | 1 (предпочтительный) |
ANTHROPIC_API_KEY |
API-ключ Anthropic или ZvenoAI | 2 |
Зарегистрируйтесь на zveno.ai, получите API-ключ и укажите в .env:
ANTHROPIC_API_KEY=sk-zveno-...Оплата в рублях, без VPN и зарубежных карт.
Claude Code CLI сохраняет OAuth-токены в системное хранилище ключей после авторизации.
Авторизация через CLI (токен сохраняется автоматически):
claude
# в REPL ввести: /login
# завершить OAuth в браузереИзвлечение существующего токена из macOS Keychain:
security find-generic-password -s "Claude Code-credentials" -w \
| python3 -c "import sys,json; print(json.load(sys.stdin)['claudeAiOauth']['accessToken'])"Формат токена: sk-ant-oat01-.... Задаётся в .env или Vault.
Если у вас есть прямой доступ к Anthropic API:
ANTHROPIC_API_KEY=sk-ant-...Все параметры через переменные окружения (см. .env.example):
| Переменная | Значение по умолчанию | Описание |
|---|---|---|
TRACKER_QUEUE |
QR |
Ключ очереди в Yandex Tracker |
TRACKER_TAG |
ai-task |
Тег, запускающий диспетчеризацию агента |
AGENT_MODEL |
claude-opus-4-6 |
Модель Claude для worker-агентов |
AGENT_MAX_BUDGET_USD |
(нет) | Лимит расходов на задачу (опционально) |
MAX_CONCURRENT_AGENTS |
2 |
Лимит параллельных агентов |
AGENT_PERMISSION_MODE |
acceptEdits |
Режим прав SDK |
REVIEW_CHECK_DELAY_SECONDS |
120 |
Интервал опроса PR-ревью |
SUPERVISOR_MODEL |
claude-opus-4-6 |
Модель для supervisor-чата |
COMPACTION_ENABLED |
true |
Включить авто-компактификацию контекста |
COMPACTION_BUFFER_TOKENS |
20000 |
Буфер до лимита контекста для срабатывания компактификации |
COMPACTION_MODEL |
claude-haiku-4-5-20251001 |
Модель для суммаризации при компактификации |
AUTO_MERGE_ENABLED |
false |
Включить авто-мёрж PR (opt-in) |
AUTO_MERGE_METHOD |
squash |
Метод мёржа (squash, merge, rebase) |
AUTO_MERGE_REQUIRE_APPROVAL |
true |
Требовать approval перед авто-мёржем |
PRE_MERGE_REVIEW_ENABLED |
false |
Включить code review sub-agent перед merge |
PRE_MERGE_REVIEW_FAIL_OPEN |
false |
При ошибке/таймауте: false = reject, true = approve |
HUMAN_GATE_MAX_DIFF_LINES |
0 |
Порог diff для блокировки auto-merge (0 = выключен) |
HUMAN_GATE_SENSITIVE_PATHS |
(пусто) | Comma-separated glob-паттерны чувствительных файлов |
POST_MERGE_VERIFICATION_ENABLED |
false |
Включить верификацию деплоя после merge |
POST_MERGE_VERIFICATION_ENVIRONMENT |
dev |
Окружение для верификации |
ALERTMANAGER_WEBHOOK_ENABLED |
false |
Включить приём алертов из Alertmanager |
ALERTMANAGER_AUTO_CREATE_TASK |
false |
Авто-создание задач из critical/error алертов |
HEARTBEAT_INTERVAL_SECONDS |
300 |
Интервал проверки здоровья агентов |
repos.yaml перечисляет git-репозитории, клонируемые в workspace:
all_repos:
- url: https://github.com/org/api.git
path: /workspace/api
description: "Go API backend"
- url: https://github.com/org/frontend.git
path: /workspace/frontend
description: "Next.js frontend"python3 -m venv .venv && source .venv/bin/activate
pip install -e ".[dev]"
pytest tests/ -vПроверка качества (Docker, синхронизировано с CI):
task quality # все проверки (Python + Frontend параллельно)
task python:quality # lint → format:check → typecheck → test
task frontend:quality # typecheck → lint → test → buildФронтенд:
cd frontend && npm install && npm run devDocker-образ содержит: Python 3.12, Node.js 22, Go 1.24, Docker CLI, docker-compose, gh CLI, Claude Code CLI. Docker-сокет монтируется для make gen, docker compose up (тестовая инфра) и testcontainers внутри worktree агентов.
flowchart LR
tracker["Yandex Tracker<br/>ai-task, non-resolved"]
dispatcher["TaskDispatcher<br/>опрос каждые 60с"]
resolver["RepoResolver<br/>компонент → репозиторий<br/>(repos.yaml)"]
workspace["WorkspaceManager<br/>git worktree<br/>ветка: ai/{key}"]
runner["AgentRunner<br/>ClaudeSDKClient"]
worker["Worker Agent<br/>(opus)"]
plan["Planning Sub-Agent<br/>(opus, read-only)"]
compaction["Compaction<br/>суммаризация через Haiku"]
orch_agent["OrchestratorAgent<br/>track_pr / retry /<br/>escalate / complete"]
tracker --> dispatcher
dispatcher --> resolver --> workspace
dispatcher --> runner --> worker
worker -- "Task tool" --> plan
plan -- "план / блокеры" --> worker
worker -. "лимит токенов" .-> compaction
compaction -. "новая сессия" .-> worker
worker -- "результат" --> orch_agent
orch_agent -- "решение" --> dispatcher
classDef ext fill:#4a90d9,stroke:#2c5ea0,color:#fff
classDef core fill:#e8a838,stroke:#b8842c,color:#000
classDef agent fill:#c084fc,stroke:#9061c2,color:#000
classDef infra fill:#6bbf6b,stroke:#4a9a4a,color:#000
class tracker ext
class dispatcher,orch_agent core
class runner,worker,plan agent
class resolver,workspace,compaction infra
flowchart LR
github["GitHub<br/>GraphQL API"]
tracker["Yandex Tracker"]
pr_mon["PRMonitor<br/>опрос каждые 120с"]
ni_mon["NeedsInfoMonitor<br/>опрос каждые 120с"]
session["Agent Session<br/>(долгоживущая)"]
recovery["RecoveryManager<br/>backoff + retry"]
gate["Human Gate"]
reviewer["Pre-merge Review<br/>(Sonnet)"]
verifier["Post-merge<br/>Verification"]
github -- "статус PR,<br/>ревью-треды, CI" --> pr_mon
pr_mon -- "промпт ревью" --> session
session -- "push fix" --> github
pr_mon -- "gate check" --> gate
gate -- "OK" --> reviewer
reviewer -- "approve" --> pr_mon
pr_mon -- "auto-merge" --> github
pr_mon -- "вмёрджен" --> verifier
verifier -. "hotfix" .-> tracker
pr_mon -- "закрытие" --> tracker
tracker -- "новые комментарии" --> ni_mon
ni_mon -- "промпт ответа" --> session
session -- "продолжение<br/>работы" --> github
recovery -. "retry / skip" .-> pr_mon
recovery -. "retry / skip" .-> ni_mon
classDef ext fill:#4a90d9,stroke:#2c5ea0,color:#fff
classDef core fill:#e8a838,stroke:#b8842c,color:#000
classDef agent fill:#c084fc,stroke:#9061c2,color:#000
classDef infra fill:#6bbf6b,stroke:#4a9a4a,color:#000
class github,tracker ext
class pr_mon,ni_mon,gate core
class session,reviewer,verifier agent
class recovery infra
flowchart LR
epic["Эпик в Tracker<br/>(тип: Epic)"]
coordinator["EpicCoordinator<br/>обнаружение подзадач<br/>автодекомпозиция<br/>граф зависимостей"]
supervisor["Supervisor Chat<br/>планирование<br/>установка зависимостей"]
children["Подзадачи<br/>awaiting_plan → executing"]
dispatcher["Dispatcher"]
epic --> coordinator
coordinator -- "EPIC_AWAITING_PLAN" --> supervisor
coordinator -- "EPIC_NEEDS_DECOMPOSITION<br/>(нет подзадач)" --> supervisor
supervisor -- "epic_create_child<br/>set_child_dependencies<br/>activate_child" --> coordinator
coordinator -- "тег ai-task<br/>на готовую подзадачу" --> children
children --> dispatcher
classDef ext fill:#4a90d9,stroke:#2c5ea0,color:#fff
classDef core fill:#e8a838,stroke:#b8842c,color:#000
classDef agent fill:#c084fc,stroke:#9061c2,color:#000
class epic ext
class coordinator,dispatcher core
class supervisor,children agent
Supervisor — один агент (Opus, bypassPermissions), работающий через три независимых канала (каждый со своей сессией и историей):
| Канал | Назначение | Триггер |
|---|---|---|
chat |
Интерактивный чат с оператором через дашборд | Оператор пишет сообщение |
tasks |
Автономные уведомления (эпики, деферы, декомпозиция, алерты) | Системные события (fire-and-forget через auto_send) |
heartbeat |
Диагностика (застрявшие агенты, долгие задачи, stale ревью) | HeartbeatMonitor каждые 5 мин |
Сессия в каждом канале — долгоживущая (не пересоздаётся на каждое сообщение), история накапливается.
Worker-агенты получают узкий набор инструментов, ограниченных контекстом своей задачи. Supervisor — глобальный доступ ко всей системе.
| Категория | Worker (4 + 5 comm) | Supervisor (~100 инструментов) |
|---|---|---|
| Tracker | Только свой issue (get, comment, checklist) | Поиск, создание, обновление любых задач |
| GitHub | Нет | PR diff, reviews, checks, mergeability |
| Статистика | Нет | Summary, costs, errors, произвольные SQL |
| Память | Нет | CRUD + гибридный поиск (BM25 + vector) |
| Эпики | Нет | Планирование зависимостей, активация/ресет детей |
| Агенты | Нет | List/abort/cancel агентов, отправка сообщений |
| Зависимости | Нет | Approve/defer задач |
| Межагентное | send/reply/check/list (свой скоуп) | view_agent_messages, get_comm_stats (read-only) |
| K8s | Нет | Pod logs/status (опционально) |
| ADR | Нет | Создание/список/чтение Architecture Decision Records |
| Env config | Нет | Чтение/запись per-env connection details (API URLs, credentials) |
| Эскалация | Нет | Тег needs-human-review + комментарий в Tracker |
| Файловая система | Workspace (свой worktree) | Bash, Write, Edit (без ограничений) |
- Supervisor → Worker:
send_message_to_task()(interrupt текущей сессии),abort_task(),cancel_task() - Worker → Supervisor: напрямую невозможно; supervisor видит всё через EventBus и
view_agent_messages
flowchart LR
user["Пользователь<br/>(дашборд)"]
events["Системные события<br/>(epic plan, defer,<br/>heartbeat, alertmanager)"]
subgraph supervisor["Supervisor Agent (Opus)"]
chat_ch["chat канал<br/>интерактивный"]
tasks_ch["tasks канал<br/>автономный"]
hb_ch["heartbeat канал<br/>диагностика"]
end
tools["~100 MCP-инструментов<br/>Tracker, GitHub, stats,<br/>memory, epic mgmt, K8s,<br/>ADR, env, escalation,<br/>Bash, Write, Edit"]
memory["SupervisorMemory<br/>SQLite + FTS5<br/>BM25 + cosine"]
files["data/memory/*.md"]
workers["Worker Agents"]
user -- "сообщение" --> chat_ch
events -- "auto_send" --> tasks_ch
events -- "алерты" --> hb_ch
chat_ch & tasks_ch & hb_ch --> tools
tools -. "поиск / запись" .-> memory --> files
tools -- "interrupt / abort" --> workers
classDef user_s fill:#f87171,stroke:#c25050,color:#fff
classDef core fill:#e8a838,stroke:#b8842c,color:#000
classDef agent fill:#c084fc,stroke:#9061c2,color:#000
classDef infra fill:#6bbf6b,stroke:#4a9a4a,color:#000
class user,events user_s
class chat_ch,tasks_ch,hb_ch core
class tools agent
class memory,files,workers infra
flowchart LR
agentA["Worker Agent A<br/>(QR-10)"]
agentB["Worker Agent B<br/>(QR-11)"]
mailbox["AgentMailbox<br/>инбоксы, статусы сообщений<br/>MAX_INBOX_SIZE = 50"]
interrupt["interrupt_with_message<br/>(доставка через прерывание)"]
agentA -- "1. list_running_agents" --> mailbox
agentA -- "2. send_message_to_agent" --> mailbox
mailbox -- "3. interrupt" --> interrupt --> agentB
agentB -- "4. reply_to_message" --> mailbox
mailbox -- "5. interrupt" --> agentA
classDef agent fill:#c084fc,stroke:#9061c2,color:#000
classDef infra fill:#6bbf6b,stroke:#4a9a4a,color:#000
class agentA,agentB agent
class mailbox,interrupt infra
flowchart LR
components["Все компоненты<br/>(dispatcher, monitors,<br/>agents, mailbox)"]
eventbus["EventBus<br/>async pub/sub<br/>кольцевой буфер (500)"]
collector["StatsCollector"]
storage["SQLite Storage"]
fastapi["FastAPI :8080"]
ws["WebSocket<br/>/ws/tasks/{key}/stream<br/>/ws/events"]
rest["REST API<br/>/api/status, /tasks, /events,<br/>/proposals, /stats, /config,<br/>/webhook/alertmanager, /metrics"]
frontend["React 19 + Vite<br/>TailwindCSS<br/>xterm.js"]
components --> eventbus
eventbus --> ws
eventbus --> collector --> storage
fastapi --- ws
fastapi --- rest
ws --> frontend
rest --> frontend
classDef core fill:#e8a838,stroke:#b8842c,color:#000
classDef infra fill:#6bbf6b,stroke:#4a9a4a,color:#000
classDef dash fill:#f87171,stroke:#c25050,color:#fff
class components core
class eventbus,collector,storage infra
class fastapi,ws,rest,frontend dash
flowchart LR
pr["PR готов к merge"]
gate["Human Gate<br/>diff > N строк?<br/>чувствительные пути?"]
block["BLOCK<br/>комментарий в PR<br/>HUMAN_GATE_TRIGGERED"]
review["Pre-merge Review<br/>Sonnet sub-agent<br/>OWASP checklist"]
reject["REJECT<br/>REQUEST_CHANGES<br/>→ worker исправляет"]
readiness["Merge Readiness<br/>CI ✓, approved,<br/>no conflicts"]
merge["Auto-merge<br/>squash/merge/rebase"]
verify["Post-merge Verification"]
ci_wait["Ожидание CI<br/>на merge SHA"]
k8s_wait["Ожидание K8s<br/>pod rollout"]
agent["Verification Agent<br/>(Sonnet)"]
pass_ev["TASK_VERIFIED"]
fail_ev["Hotfix Bug task<br/>в Tracker"]
pr --> gate
gate -- "blocked" --> block
gate -- "OK" --> review
review -- "reject" --> reject
reject -. "fix + new commit" .-> pr
review -- "approve" --> readiness
readiness --> merge
merge --> verify
verify --> ci_wait --> k8s_wait --> agent
agent -- "pass" --> pass_ev
agent -- "fail" --> fail_ev
classDef ext fill:#4a90d9,stroke:#2c5ea0,color:#fff
classDef core fill:#e8a838,stroke:#b8842c,color:#000
classDef agent_s fill:#c084fc,stroke:#9061c2,color:#000
classDef danger fill:#f87171,stroke:#c25050,color:#fff
class pr ext
class gate,readiness,merge,verify,ci_wait,k8s_wait core
class review,agent agent_s
class block,reject,fail_ev danger
class pass_ev ext
flowchart LR
am["Alertmanager"]
webhook["POST /alertmanager/webhook"]
filter["Фильтр:<br/>status = firing"]
severity{"severity<br/>critical/error?"}
dedup["Dedup: query Tracker<br/>санитизированный alertname"]
exists{"дубликат?"}
create["Создать задачу<br/>+ компонент"]
prompt["Форматировать<br/>→ Supervisor"]
skip["Пропустить"]
component["Маппинг компонента:<br/>namespace/service →<br/>Бекенд / Фронтенд / DevOps"]
am --> webhook --> filter --> severity
severity -- "да" --> dedup --> exists
exists -- "нет" --> component --> create
exists -- "да" --> skip
severity -- "нет" --> prompt
classDef ext fill:#4a90d9,stroke:#2c5ea0,color:#fff
classDef core fill:#e8a838,stroke:#b8842c,color:#000
classDef danger fill:#f87171,stroke:#c25050,color:#fff
class am ext
class webhook,filter,severity,dedup,exists,component core
class create,prompt ext
class skip danger