diff --git a/README.md b/README.md index 7430e72..49e6ad3 100644 --- a/README.md +++ b/README.md @@ -4,7 +4,7 @@ выполняет команды «желаемый результат» в Jira по правилу «проверь, потом сделай», ведёт журнал на диске и возвращает хабу состояние задач. Один файл `src/agent.py`, только стандартная библиотека, Python 3.9. -Спека: `../jira-hub/openspec/changes/bridge-core/specs/agent/spec.md` (вместе с `commands/` и `hub-api/`). +Спека: `../jira-hub/openspec/specs/agent/spec.md` (вместе с `commands/` и `hub-api/`). Хаб, очередь команд и зеркало задач живут в репозитории `jira-hub`; агент с ним общается только по HTTP. ## Доставка на виртуалку @@ -70,7 +70,7 @@ nohup python3 -u agent.py > agent.log 2>&1 & Остановка: Ctrl-C или `kill `. Первый сигнал — агент доделывает текущую команду, отправляет отчёт и выходит. Повторный сигнал — немедленный выход (код 130). Остановка во время паузы перед командой безопасна: команда уже -записана в журнал как `claimed`, при следующем запуске агент запрашивает её у хаба и выполняет через проверку (без паузы). +записана в журнал как `claimed`, при следующем запуске агент запрашивает её у хаба и выполняет через проверку, выдержав паузу темпа от последней записи журнала. ## Автозапуск через launchd (опционально) @@ -140,8 +140,11 @@ python3 agent.py prune Правила работы: - **Проверь, потом сделай.** Каждый тип сначала читает текущее состояние и записывает только разницу. - **Паузы.** Хаб выдаёт команду с `pause_seconds` — агент досыпает до зазора от последнего вызова Jira. Внутри команды - с несколькими записями зазор берётся из `pacing` настроек хаба. + с несколькими записями зазор берётся из `pacing` настроек хаба. После перезапуска время последнего вызова Jira + берётся из журнала (самая поздняя запись), поэтому первая команда тоже ждёт паузу. - **Одна команда в полёте.** Агент берёт следующую команду, только когда предыдущая выполнена и отчёт подтверждён. + На этом строится довыдача: если ответ на `claim` потерян, хаб выдаст ту же команду снова при следующем `claim` + (до 3 выдач, затем `failed`). - **Отчёт до подтверждения.** Отчёт повторяется каждые 10 с, пока хаб не подтвердит. Ответы 404/409/422 хаб выдаёт, когда команда уже отменена или удалена: агент считает её закрытой и не зацикливается. - **429 и 503.** Агент ждёт `Retry-After` из ответа Jira и повторяет запрос: до 5 запросов, то есть не более 4 ожиданий; @@ -150,7 +153,7 @@ python3 agent.py prune `finished`, ждёт не меньше 30 с и повторяет команду через проверку («проверь, потом сделай») до 3 раз. Счётчики суммируются. После исчерпания — `failed` «результат неизвестен (обрыв связи с Jira), повтор безопасен». При остановке по сигналу команду подхватит восстановление. -- **Версия.** Константа `AGENT_VERSION` в `agent.py` (сейчас 2) отправляется в каждом `claim`, в каждом отчёте +- **Версия.** Константа `AGENT_VERSION` в `agent.py` (сейчас 3) отправляется в каждом `claim`, в каждом отчёте (`agent_version`) и в `/agent/state`. Если хаб назначил `min_agent_version` выше, он пишет в `agent_status.warning`: «обновите агента»; команды при этом выдаются по-прежнему. @@ -177,9 +180,9 @@ python3 agent.py prune 1. **`prune` не запускать при работающем агенте.** Блокировки нет. Запись, добавленная агентом во время `prune`, может пропасть при перезаписи файла. Сначала остановить агента. 2. **Остановка во время паузы или между claim и выполнением (R-9).** Команда остаётся `claimed` в хабе, но в журнале - есть запись `claimed`: при перезапуске агент запрашивает её у хаба и выполняет без паузы. Отмена с force и повтор - больше не нужны. Если журнал потерян, команду придётся отменить с force (`POST /commands/{id}/cancel`, - `{"force": true}`) и повторить (`POST /commands/{id}/retry`). + есть запись `claimed`: при перезапуске агент запрашивает её у хаба и выполняет с паузой темпа (время последнего + вызова Jira берётся из журнала). Отмена с force и повтор не нужны. Если журнал потерян, хаб довыдаст команду при + следующем `claim` — агент выполнит её через проверку. 3. **HTTPS хаба с корпоративным CA не поддержан.** `HubClient` работает без `ca_bundle` и `verify_ssl`: `hub_url` должен быть `http://`. Для Jira `verify_ssl` и `ca_bundle` работают. 4. **Спринт в `refresh` — только активные и будущие спринты доски.** Поле `sprint` берётся из Agile API по diff --git a/src/agent.py b/src/agent.py index a569d8d..f5a47c6 100644 --- a/src/agent.py +++ b/src/agent.py @@ -3,7 +3,7 @@ Опрашивает хаб (jira-hub) на Mac mini, выполняет команды «желаемый результат» в Jira по правилу «проверь, потом сделай», ведёт журнал на диске и возвращает хабу состояние задач. Только стандартная библиотека, -Python 3.9. Спека: jira-hub/openspec/changes/bridge-core/specs/agent/spec.md. +Python 3.9. Спека: jira-hub/openspec/specs/agent/spec.md. Связь с хабом — HTTP (`hub_url = http://…`) или общая папка (`hub_url = folder:<путь>`), если сеть закрыта VPN. python3 agent.py check # доступ к хабу и Jira, без записи @@ -26,7 +26,7 @@ import uuid from datetime import datetime, timezone from typing import Any, Dict, List, Optional -AGENT_VERSION = 2 +AGENT_VERSION = 3 HERE = os.path.dirname(os.path.abspath(__file__)) API = "/rest/api/2" AGILE = "/rest/agile/1.0" @@ -999,10 +999,11 @@ class Runner: "error": "внутренняя ошибка агента: %s: %s" % (type(e).__name__, str(e)[:300]), "jira_calls": self.jira.calls, "rate_limited": self.jira.rate_limited} - def execute(self, cmd: dict) -> None: + def execute(self, cmd: dict, journal_claimed: bool = True) -> None: cid = cmd["id"] log("#%s %s %s" % (cid, cmd["type"], json.dumps(cmd.get("params"), ensure_ascii=False)[:200])) - self.journal.claimed(cid) # сразу после claim, до паузы (R-9): остановка не теряет команду + if journal_claimed: + self.journal.claimed(cid) # сразу после claim, до паузы (R-9): остановка не теряет команду if not self.wait_pause(cmd.get("pause_seconds")): return self.journal.started(cid) # started — только после паузы @@ -1064,8 +1065,7 @@ class Runner: self.journal.acked(cid) continue log("#%s выдана до перезапуска — выполняю через проверку" % cid) - cmd["pause_seconds"] = 0 - self.execute(cmd) + self.execute(cmd, journal_claimed=False) # claimed/started для неё уже в журнале (FM-4); пауза — из хаба (M-9) def reload_settings_before(self, cmd) -> bool: """Настройки сменились: перечитать ДО выполнения. False — остановка, команда не должна выполняться diff --git a/tests/test_folder.py b/tests/test_folder.py index 8f4fd72..d9474c5 100644 --- a/tests/test_folder.py +++ b/tests/test_folder.py @@ -135,8 +135,8 @@ class FolderIntegrationTest(unittest.TestCase): def cfg(self): return jira_cfg(self.fake, hub_url="folder:" + self.root, hub_token=self.hub.token) - def test_version_is_2(self): - self.assertEqual(agent.AGENT_VERSION, 2) + def test_version_is_3(self): + self.assertEqual(agent.AGENT_VERSION, 3) def test_runner_through_folder(self): self.fake.add("AURORA-1", duedate="2026-10-20") @@ -149,7 +149,7 @@ class FolderIntegrationTest(unittest.TestCase): runner.idle_limit = 1 runner.loop() self.assertEqual(self.hub.results[cid]["status"], "done") - self.assertEqual(self.hub.results[cid]["agent_version"], 2) + self.assertEqual(self.hub.results[cid]["agent_version"], agent.AGENT_VERSION) self.assertEqual(self.fake.issues["AURORA-1"]["duedate"], "2026-10-23") self.assertIn(("acked", cid), [(r["kind"], r["command_id"]) for r in journal.records()]) diff --git a/tests/test_runner.py b/tests/test_runner.py index 610f3a9..3d192ff 100644 --- a/tests/test_runner.py +++ b/tests/test_runner.py @@ -129,9 +129,15 @@ class RunnerTest(unittest.TestCase): self.runner.loop() self.assertEqual(self.hub.results[cid]["result"], {"changed": []}) # уже так в Jira — записи нет self.assertEqual(self.journal.unfinished_started(), []) - self.assertEqual(self.sleeps, []) # пауза при восстановлении не применяется + self.assertAlmostEqual(sum(self.sleeps), 99, delta=1) # пауза из хаба, от записи started (M-9) self.assertEqual([r[0] for r in self.fake.writes()], []) + def test_recover_does_not_journal_claimed_twice(self): + cid = self.claim_in_flight("ensure_fields", {"key": "AURORA-1", "duedate": "2026-10-20"}, pause=0) + self.journal.claimed(cid) + self.runner.loop() + self.assertEqual(self.kinds(), [("claimed", cid), ("started", cid), ("finished", cid), ("acked", cid)]) + def test_recover_ensure_issue_finds_duplicate(self): self.fake.add("AURORA-7", reporter="me", summary="Новая задача") before = len(self.fake.issues) @@ -185,7 +191,7 @@ class RunnerTest(unittest.TestCase): self.assertEqual(self.hub.results[1]["status"], "done") self.assertEqual(len(self.fake.writes()), 1) self.assertEqual(self.journal.unfinished_started(), []) - self.assertEqual(self.sleeps, []) # при восстановлении пауза не применяется + self.assertAlmostEqual(sum(self.sleeps), 5, delta=1) # пауза из хаба от записи claimed (M-9) def test_stop_between_claim_and_execute_is_recorded(self): self.hub.enqueue("ensure_fields", {"key": "AURORA-1", "duedate": "2026-10-23"})