diff --git a/docs/web-api/CONTRACT.md b/docs/web-api/CONTRACT.md index 5ff8627..6a16091 100644 --- a/docs/web-api/CONTRACT.md +++ b/docs/web-api/CONTRACT.md @@ -1,6 +1,6 @@ # Контракт веб-интерфейса Hermes Hub -Версия контракта: **1.2** +Версия контракта: **1.3** Дата: 2026-08-24 Этот документ — **единственный** источник истины для двух сторон: серверной (задание A15) и клиентской (A16). Обе стороны разрабатываются параллельно и до слияния друг друга не видят. @@ -79,14 +79,14 @@ readiness, agents, providers, routing, quotas, metrics, is_stale { "action": "<имя>", "data": { ... } } ``` -Имена действий берутся **ровно** из общего слоя `action_handler.py`. Их восемнадцать: +Имена действий берутся **ровно** из общего слоя `action_handler.py`. Их девятнадцать: ``` account_details add_account agent_settings assign_role auto_assign_all check_updates delete_credentials edit_route oauth open_routing refresh_account refresh_all -refresh_data save_settings set_main set_model -set_orchestrator test +refresh_data refresh_models save_settings set_main +set_model set_orchestrator test ``` Ответ: @@ -100,6 +100,9 @@ set_orchestrator test Действия `open_routing` и `account_details` в вебе — навигация, состояние держит клиент; сервер на них отвечает `ok: true` без побочных эффектов. + +**`refresh_models`** (добавлено в A23): принудительное обновление списка моделей провайдера. `data: {"provider": ""}`. Обнаружение ходит в сеть и подпроцесс — действие возвращается сразу, результат приходит следующим снапшотом. Замерено: `agy models` отвечает за десятки секунд, иногда виснет дольше двух минут; при таймауте прежний кэш не затирается. + ### `GET /api/health` `{"ok": true, "version": "<версия Hub>", "auth_flows": {...}}`. Без авторизации — нужен для проверки, что сервер поднялся. diff --git a/src/antigravity_provider/router/health_tracker.py b/src/antigravity_provider/router/health_tracker.py index c25760e..d302cc7 100644 --- a/src/antigravity_provider/router/health_tracker.py +++ b/src/antigravity_provider/router/health_tracker.py @@ -64,6 +64,9 @@ def extract_model_family(model_name: Optional[str]) -> str: return "default" +_LOCK_TIMEOUT_SEC = 5.0 + + class _FileLock: """Interprocess file lock supporting Windows (msvcrt) and Unix (fcntl).""" @@ -75,12 +78,28 @@ class _FileLock: try: self.lock_path.parent.mkdir(parents=True, exist_ok=True) self._fd = os.open(str(self.lock_path), os.O_CREAT | os.O_RDWR) - if os.name == "nt": - import msvcrt - msvcrt.locking(self._fd, msvcrt.LK_LOCK, 1) - else: - import fcntl - fcntl.flock(self._fd, fcntl.LOCK_EX) + # Ожидание ограничено по времени. Неблокирующий захват был неверен: + # при неудаче исключение проглатывалось, и запись шла БЕЗ блокировки. + # Но бесконечное ожидание не лучше: на Unix flock(LOCK_EX) висит + # вечно, и один застрявший держатель подвесил бы приложение целиком. + # Секция короткая — запись файла состояния, — поэтому пары секунд + # с запасом хватает, а дальше честный отказ. + deadline = time.time() + _LOCK_TIMEOUT_SEC + while True: + try: + if os.name == "nt": + import msvcrt + + msvcrt.locking(self._fd, msvcrt.LK_NBLCK, 1) + else: + import fcntl + + fcntl.flock(self._fd, fcntl.LOCK_EX | fcntl.LOCK_NB) + break + except OSError: + if time.time() >= deadline: + raise + time.sleep(0.05) except Exception: if self._fd is not None: try: