`gjdZddlmZddlZddlmZmZmZdZdZ hdZ dddZ e f dd Z dd Z dd Z dd Z dd Zy)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>1onyestruec||ntj}t|jtdj j tvS)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). )osenvironstrgetSCALE_TO_ZERO_ENVstriplower_TRUTHY)renvs H/root/.hermes/venv/lib/python3.12/site-packages/gateway/scale_to_zero.pyscale_to_zero_enabledr,sB ('bjjC sww("- . 4 4 6 < < >' IIc t|}|dkr t|}|dzS#ttf$rt|}Y1wxYw)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@)float TypeError ValueError) cfg_valuedefault_minutesminutess rparse_idle_timeout_secondsr"6sN) "!|( T> z ")()s "??cz|Dchc] }t|}}|jdt|dk(Scc}w)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). relayr)_platform_namediscardlen) platformspnamess r!messaging_is_relay_only_or_absentr+Hs;)2 21^A  2E 2 MM' u:? 3s8cjt|d|}t|jjS)Nvalue)getattrrrr)platformr-s rr%r%Vs, Hgx 0E u:    # # %%rcLt|xrt|xr t|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. )bool)enabledrelay_only_or_absentwake_urls r should_armr5[s" = JT"67 JDNJrc|dkDry|ry||k\S)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. rF)running_agent_countseconds_since_last_inboundidle_timeout_secondshas_live_background_works ris_idler<ks!Q %)= ==r)N)rzOptional[dict]returnr1)rrr intr=r)r(z Iterable[Any]r=r1)r/rr=r)r2r1r3r1r4z Optional[str]r=r1) r8r>r9rr:rr;r1r=r1)__doc__ __future__rrtypingrrrrDEFAULT_IDLE_TIMEOUT_MINUTESrrr"r+r%r5r<r7rrrCs8# **+ ! $J,H%( $ & K  K K K  K >>!&> > # >  >r