epjXdZddlmZddlZddlmZmZmZdd ZddZ ddZ ddddZ dS)ubGateway session stall notification policy (#72016 item 2). Consumes the shared activity observation contract from ``agent.session_activity`` / ``AIAgent.get_activity_summary()`` (#72039) as the **single progress source**. This module owns only the notify-once policy for "pending inbound + stale progress"; it does not invent a parallel progress clock from turn-start or inbound event timestamps. Boundaries (keep separate): - ``gateway/shutdown_watchdog.py`` — process / event-loop liveness - ``gateway/delivery_ledger.py`` — outbound delivery obligations - Pending inbound here is a stall *policy gate* (queued follow-up exists), not an outbound obligation and not a progress timestamp. Notification / timeout / kill / retry policy stay in their own components; the shared contract remains observation-only (timestamp + bounded description + provenance). ) annotationsN)AnyMappingOptionaltimeout_secondsfloat idle_secondsOptional[float]has_pending_inboundboolalready_notifiedreturnc6|dkrdS|sdS|rdS|dS||kS)zAReturn True when a stall warning should be sent for this session.rF)rr r r s ;/home/thesage/.hermes/hermes-agent/gateway/session_stall.py&should_emit_session_stall_notificationrsD!u uuu ? **c.|sdS|dkrdS|dS||kS)zEReturn True when a prior stall notice may be cleared (episode ended).TrNFr)rr r s r'should_clear_session_stall_notificationr.s7 t!tu / ))rstrcNtdt|dz}d|dS)zEUser-facing stall warning (ASCII minutes; matches issue #72016 copy).<u4⚠️ Agent session appears stalled (last activity z min ago). Try /new to reset.)maxint)r minss r!format_session_stall_notificationr?s9 q#lb()) * *D t   r)nowactivityOptional[Mapping[str, Any]]rc2|sdS|d}|H t|}tj|r |dkrdS|Sn#tt f$rd}YnwxYw|d}||d}|dS t|}n#tt f$rYdSwxYwtj|sdS|&ddl}t|}nt|}||z }|dkrdS|S)u^Idle seconds from a shared activity snapshot only (#72039 contract). Prefers ``seconds_since_activity`` when present and finite; otherwise derives from ``last_activity_at`` / ``last_activity_ts``. Returns ``None`` when there is no usable progress timestamp — callers must not fall back to turn-start or pending-inbound clocks. Nseconds_since_activityrglast_activity_atlast_activity_ts)getrmathisfinite TypeError ValueErrortime)rrelapsedidletswhen_timeclocks r*resolve_session_idle_seconds_from_activityr1Hsd tll344G >>D}T"" !883  :&   DDD  ( ) )B z \\, - - ztRyy z "tt =  t {ejjll##c  4r5s(#""""" ))))))))))++++&****" 11111111r