yjxdZddlmZddlZddlmZmZmZdZdZ hdZ d#d$d Z e fd%dZ d&dZ d'dZd(dZd)d"ZdS)*uHScale-to-zero idle detection + dormant-quiesce for the gateway (Phase 0). This is the gateway-side BEHAVIOUR layer that consumes the relay scale-to-zero PRIMITIVES (gateway-gateway Phase 5: the buffered-flip, the durable per-instance buffer, the wakeUrl poke, the reconnect supervisor). It owns the *decision* to go idle and drives the relay transport's ``go_dormant()`` (D12) — it does NOT itself suspend the machine. On Fly, the now-traffic-idle machine is suspended by ``autostop:"suspend"`` and woken by autostart-on-wakeUrl (decisions.md Q3=C′). Design constraints (decisions.md): - Per-instance enable is gated SOLELY by the NAS "Labs" toggle, carried to the gateway as the ``HERMES_SCALE_TO_ZERO`` env stamp (D11/Q8=A). NOT a user config key; ``scale_to_zero.idle_timeout_minutes`` IS config.yaml (D2). - Arm only when messaging is relay-only or absent (D1/F6) AND a wakeUrl is registered (§3.4(1)) AND the flag is set. - Idle = no in-flight agent turn AND no inbound for N min AND no live background work (D2/D3/F7). - The quiesce uses ``go_dormant()`` (socket closed + supervisor preserved), NEVER the stop/restart drain or ``disconnect()`` (F12/F14). The process stays alive; Fly freezes+resumes it. - ``mark_resume_pending`` is deliberately NOT called here (D13 — suspend preserves RAM; revive only if we move to autostop:"stop" or see kills). The pure helpers (``parse_idle_timeout_seconds``, ``scale_to_zero_enabled``, ``messaging_is_relay_only_or_absent``, ``is_idle``, ``should_arm``) take plain inputs so they unit-test without a live gateway. ) annotationsN)AnyIterableOptionalHERMES_SCALE_TO_ZERO>1onyestrueenvironOptional[dict]returnboolc||n tj}t|tdtvS)zWhether the per-instance Labs toggle is on (the HERMES_SCALE_TO_ZERO stamp). D11/Q8=A: this env flag is the SOLE per-instance enable signal reaching the gateway. Absent/blank/falsey -> disabled (fail-safe default off). N)osr strgetSCALE_TO_ZERO_ENVstriplower_TRUTHY)r envs ;/home/ragecks/.hermes/hermes-agent/gateway/scale_to_zero.pyscale_to_zero_enabledr,sN (''bjC sww("-- . . 4 4 6 6 < < > >' II cfg_valuerdefault_minutesintfloatc t|}n&#ttf$rt|}YnwxYw|dkrt|}|dzS)u$Coerce ``scale_to_zero.idle_timeout_minutes`` (config.yaml, D2) to seconds. Degrades to the default on any non-numeric / non-positive value (never raises, never returns <= 0 — a zero/negative timeout would make the gateway go dormant instantly, which is never the intent). rgN@)r! TypeError ValueError)rrminutess rparse_idle_timeout_secondsr&6sg) "" z ")))(()!||(( T>s  55 platforms Iterable[Any]cjd|D}|dt|dkS)uTrue iff the only connected messaging platform is RELAY, or there is none (a Chronos-only / no-platform agent) — the F6/D1 structural precondition. A directly-connected platform (Discord/Telegram/Slack/...) holds a live socket and cannot scale to zero, so its presence disarms the feature. We compare by the platform's ``.value``/name to avoid importing the enum here (keeps this module import-light and unit-testable). c,h|]}t|S)_platform_name).0ps r z4messaging_is_relay_only_or_absent..Qs 2 2 21^A   2 2 2rrelayr)discardlen)r'namess r!messaging_is_relay_only_or_absentr4Hs9 3 2 2 2 2E MM' u::?rplatformrct|d|}t|S)Nvalue)getattrrrr)r5r7s rr,r,Vs7 Hgx 0 0E u::     # # % %%renabledrelay_only_or_absentwake_url Optional[str]c\t|ot|ot|S)uzWhether to start the idle watcher at all (D1/D11/§3.4(1)). ALL must hold: the Labs flag is on, messaging is relay-only/absent, and a wakeUrl is registered (a suspended instance with no reachable wake target is a black hole — §3.4(1)). Any unmet -> the watcher never starts (no idle timer, no dormancy), so a non-opted instance behaves exactly as today. )r)r9r:r;s r should_armr>[s) == JT"677 JDNNJrrunning_agent_countseconds_since_last_inboundidle_timeout_secondshas_live_background_workc&|dkrdS|rdS||kS)uBThe idle predicate (D2/D3/F7). Pure — composes the three conjuncts. Idle iff: no in-flight agent turn, no inbound within the timeout window, and no live background work (backgrounded delegate_task / kanban / bg terminal). Any active work keeps the gateway awake — suspending mid-flight would lose it. rFr+)r?r@rArBs ris_idlerDks-Quu %)= ==r)N)r rrr)rrrr rr!)r'r(rr)r5rrr)r9rr:rr;r<rr) r?r r@r!rAr!rBrrr)__doc__ __future__rrtypingrrrrDEFAULT_IDLE_TIMEOUT_MINUTESrrr&r4r,r>rDr+rrrIs8#""""" **********+ ! $ $ $JJJJJ,H$    &&&& K K K K >>>>>>r