+ jHj`4Rt^RIHt^RIt^RIt^RIt^RIt^RIHtHtH t H t ^RI H t H t ^RIHt] 'd ^RIHtHt]P&!R4tRR ltR R ltR R ltRRltRtRRlt!RR4tR#)z^SessionStore explicit suspension, crash-recovery markers, pruning and shared clock/id helpers.) annotationsN)datetime timedeltatimezoneUTC) TYPE_CHECKINGOptionalnew_session_id) SessionEntry SessionSourcezgateway.sessioncV^8dQhRR/#)returnr)formats">/home/ubuntu/.hermes/hermes-agent/gateway/session_lifecycle.py __annotate__rshc,\P!4#)zReturn the current local time.)rnowrrr_nowrs <<>rc V^8dQhRRRR/#)rrrrstrr)rs"rrrs***c*rc\V^R7#))hex_lenr )rs&r_new_session_idrs #q ))rc V^8dQhRRRR/#)rdtOptional[datetime]r Optional[str]r)rs"rrrs** *M*rc6V'dVP4#R#N) isoformat)rs&r_isor%s2<<>)T)rcV^8dQhRR/#)rrr r)rs"rrr"s+rctV'gR#\P!V4# \\3dR#i;i)zG``datetime.fromisoformat`` that returns None for empty/malformed input.N)r fromisoformat TypeError ValueError)values&r _parse_isor,"s5 %%e,, z "s "77cV^8dQhRR/#)rrfloatr)rs"rrr1s<< False (same failure mode as ``_prune_stale_sessions_locked``). Lets routing self-heal a session finalized or deleted while the gateway stays alive. Store resolved from the owning profile. Used by ``get_or_create_session`` to self-heal at routing time: ``_prune_stale_sessions_locked`` only runs at startup, so a session ended in the DB while the gateway stays alive (any path that finalizes the row without clearing sessions.json) would otherwise be reused as a live routing key and silently swallow every subsequent message until the next restart (#54878 — the live-gateway variant of #52804/FM9). A hard delete is the same shape one step further: the row is GONE, not merely ended, and reusing the route makes run_agent's INSERT OR IGNORE resurrect the deleted session with its old id (#42422) — so a missing row is treated exactly like an ended one. DB errors are non-fatal — never block routing on a failed lookup. The store is resolved from the row's owning profile rather than the ambient scope: an unscoped background writer keeps its own copy of the same session, and comparing against that copy reports a live session as ended (#66887). Pass *session_key* when the owning key is known but the id may have left the routing index: after the self-heal re-homes the key, the id has no owner and would resolve to the launch store, which never holds a routed profile's rows (#118862). FN end_reason) _db_for_key_db_for_session_id get_session Exceptionr3)selfr:r;dbrows&&& r_is_session_ended_in_db-SessionLifecycleMixin._is_session_ended_in_db=su,/:T  k *t?V?VWa?b ..,Cd{??cggl34??  sA.. A=<A=c V^8dQhRRRR/#)rentryzOptional[SessionEntry]rr!r)rs"rrr=\s+Amrc \VRR4pVe+\VRR4eVPPR8wdR#VPVP4pVe\VRR4fR#^RIp^RIHp^RIH pV!V\VP44pVPR4VP8wdR#\VR ,R ,4;'gR# YdP\\\ 3dR#i;i) a=The physical target the authority's receipt names for *entry*'s local route, else None (not a local route, no receipt, or the receipt belongs to another route). Such a route moves only through the authority (compression and reset advance the receipt and the route in one transaction), and its first admitted turn reopens a stamped row (``reopen_local_session``). A row stamped ended (a viewer's ``ws_orphan_reap``) is therefore never a stale route: dropping it minted a replacement id the authority refuses (``admission_conflict``) and stranded the conversation (#140642).originNplatformlocal _read_ctx) local_receipt)RuntimeStoreErrorrouterJr:)getattrrMr+r@r;sqlite3hermes_state_localrPhermes_state_runtimerQrchat_idr3ErrorKeyErrorr)AttributeError)rDrJrLrErTrPrQreceipts&& r_local_receipt_target+SessionLifecycleMixin._local_receipt_target\s$/ >WVZ>F&//J_J_cjJj   e// 0 :[$7?4: #BFNN(;>$ >!==(I~V  s? bool`` to every entry under ``_lock``; save once if any returned True. Returns the count that did.c3H<"TFpS!V4'gK^xK R#5i)Nr).0rJris& r CSessionLifecycleMixin._update_all_entries_locked..sQ)?6%=!!)?s" "N)rf_ensure_loaded_lockedsum_entriesvaluesrh)rDrichangeds&f r_update_all_entries_locked0SessionLifecycleMixin._update_all_entries_lockeds^ZZZ  & & (Q)=)=)?QQG   Z s AA66 B c V^8dQhRRRR/#rdr)rs"rrr=sXX3X4Xrc (VPVR4#)zMark a session suspended so it auto-resets on next access (/stop). True if it existed. Used by ``/stop`` to prevent stuck sessions from being resumed after a gateway restart (#7536). c\VRR4#)r`T)setattr)es&r7SessionLifecycleMixin.suspend_session..sKQU9Vrrj)rDr;s&&rsuspend_session%SessionLifecycleMixin.suspend_sessions !!+/VWWrc$V^8dQhRRRRRR/#)rr;rrJr rNoner)rs"rrr=s"''3'|'cg'rc VP4pW5R&\V4VR&Ve \4MRpVeVP4VR&VP WRR7W2nWBnVe WbnR#R#)zPersist the active-turn pair BEFORE publishing it in memory, so a failed write can neither leak an unowned token nor drop a live one. Lock held.active_turn_tokenactive_turn_started_atN updated_atT) entry_data lock_held)to_dictr%rr$ _save_entryrrr)rDr;rJtoken started_at candidatetoucheds&&&&& r_set_turn_marker_locked-SessionLifecycleMixin._set_turn_marker_lockedsMMO ).%&.2:.> *+&2$&  '.&7&7&9Il # dK"''1$  &  rc V^8dQhRRRR/#)rr;rrr!r)rs"rrr=s  C M rc  <\P!4PpVP;_uu_4VP V4pVf RRR4R#VP WV\ P!\44RRR4V# +'giT#;i)zPersist exact ownership of the running agent turn; returns the opaque token for :meth:`clear_turn_active`. Re-marking replaces the previous token so a stale asynchronous unwind cannot clear a newer turn.N) uuiduuid4hexrfrgrrrrrDr;rrJs&& rmark_turn_active&SessionLifecycleMixin.mark_turn_activesv    ZZZ&&{3E}Z  ( (UHLLQTDU V  Z sB +B  B c$V^8dQhRRRRRR/#)rr;rrrr<r)rs"rrr=s!Src VP;_uu_4VPV4pVeVPV8wd RRR4R#VPWRR4RRR4R# +'giR#;i)zkCompare-and-swap clear an active-turn marker; ``False`` when the entry disappeared or a newer turn owns it.NFT)rfrgrrrs&&& rclear_turn_active'SessionLifecycleMixin.clear_turn_activesdZZZ&&{3E} 7 75 @Z  ( (T4 H   Z s(A$A$$ A5 c V^8dQhRRRR/#)rmax_age_secondsrnrr)rs"rrr=s3rc aaaa\4\P!4uoo^oRVVVV3RllpVPV4S#)zPromote crash-left turn markers into ``resume_pending`` (unclean startup only). Old/invalid markers are cleared without resuming; suspended sessions are never re-armed. Returns the number of newly promoted sessions.c V^8dQhRRRR/#rrJr rr<r)rs"rrESessionLifecycleMixin.recover_interrupted_turns..__annotate__s  L T rc<VP'gR#VPpVRJ;'g(S^8;'dSVP4, S8pV'gYVP'gGVP'dVP fSVnMRVnRVnSVnS^, oRVnRVnR#)FNTrestart_interrupted)rr timestampr`resume_pendinglast_resume_marked_at resume_reason)rJrmarker_is_stale epoch_nowrrpromoteds& r_promoteASessionLifecycleMixin.recover_interrupted_turns.._promotes***55J(D0!#\\ J4H4H4J(J_(\ #5???'''22:693+/E(*?E'25E/MH&*E #+/E (r)rtimerz)rDrrrrrs&f @@@rrecover_interrupted_turns/SessionLifecycleMixin.recover_interrupted_turnss<Y  . ''1rcV^8dQhRR/#rmr)rs"rrr=s99S9rc 0RRlpVPV4#)z:Clear orphan turn markers after a verified clean shutdown.c V^8dQhRRRR/#rr)rs"rrGSessionLifecycleMixin.discard_active_turn_markers..__annotate__s  L T rcfVP'gVPfR#RVnRVnR#)NFT)rrrJs&r_discardCSessionLifecycleMixin.discard_active_turn_markers.._discards/***u/K/K/S&*E #+/E (r)rz)rDrs& rdiscard_active_turn_markers1SessionLifecycleMixin.discard_active_turn_markerss  ..x88rc$V^8dQhRRRRRR/#)rr;rreasonrr<r)rs"rrr=s" 7 7s 7C 7X\ 7rc 8aRV3RllpVPW4#)zMark a session resumable after a restart interruption (keeps the session_id/transcript, unlike ``suspend_session``). True if marked.cV^8dQhRR/#rrJr r)rs"rr?SessionLifecycleMixin.mark_resume_pending..__annotate__s 1 1, 1rcj<VP'dR#RVnSVn\4VnR#)FTN)r`rrrr)rJrs&r_apply9SessionLifecycleMixin.mark_resume_pending.._applys)#'E "(E *.&E 'rr)rDr;rrs&&f rmark_resume_pending)SessionLifecycleMixin.mark_resume_pendings  1 1 !!+66rc V^8dQhRRRR/#rdr)rs"rrr=s7777rc 0RRlpVPW4#)zOClear the resume-pending flag after a successful resumed turn; True if cleared.cV^8dQhRR/#rr)rs"rr@SessionLifecycleMixin.clear_resume_pending..__annotate__s / /, /rcXVP'gR#RVnRVnRVnR#)FN)rrrrs&rr:SessionLifecycleMixin.clear_resume_pending.._applys)'''#(E "&E *.E 'rr)rDr;rs&& rclear_resume_pending*SessionLifecycleMixin.clear_resume_pendings / !!+66rc V^8dQhRRRR/#)r max_age_daysrnrr)rs"rrr=s!!c!c!rc  VeV^8:d^#\4\VR7, pVP;_uu_4VP4\ VP P 44UUu.uFSwr4VP'dKVPVPRR7'dK>VPV8gKQVNKU pppVFpVP PVR4K! V'dVP4RRR4X'd!\PR\V4V4\V4#uuppi +'giLI;i)aDrop routing entries idle (by ``updated_at``) for more than max_age_days; suspended entries and entries with active background processes are kept. Only the key -> session_id mapping is dropped (the transcript stays). ``max_age_days <= 0`` disables. Returns count.N)daysprune)contextz1SessionStore pruned %d entries older than %d days)rrrfrulistrwitemsr`_has_active_processes_safer;rpoprhloggerinfolen)rDrcutoffkeyrJ removed_keyss&& rprune_old_entries'SessionLifecycleMixin.prune_old_entriess  <1#4)66 ZZZ  & & (&*4==+>+>+@&A&A 778I8ISZ7[$$v- &A $ !!#t,$   KKKL)< 9<  Zs57E4E  E 4E E /E=EE E rr#))restart_timeout)__name__ __module__ __qualname____firstlineno____doc__rGr\rarjrzrrrrrrrrr__static_attributes__rrrr8r8:sSF@>68X'" B9 77!!rr8r)r __future__rloggingr1rrrrrrtypingrrhermes_state_idsr gateway.sessionr r getLoggerrrrr%r,r4r6r8rrrrsid" 77*+;   , - **)0%<\!\!r