+ jHj0aR-t:0tRt^RIt^RIHt^RIHt^RIHtH t ] !4t ]^kRs ]^kRRlt ];QJd.RR.4FNK 5M !RR.44;twttttttttttttttttt t!t"]!R ] R 7t#]!R ] R 7t$]!R ] R 7t%]!R ] R 7t&]!R] R 7t'.]O]%N]&N]'NUu/uFqPPVbK upt)RRlt*RRlt+]R/RRll4t,]RRl4t-RRlt.RRlt/RRRRRRRRRRRRRRRRRRR] RR3RRllt0RR lt1R!R"lt2R0R#R$llt3]4!0R1m4t5R%R&lt6R'R(lt7R)R*lt8R+R,lt9R#uupi)2aISession-scoped context variables for the Hermes gateway. Replaces the old ``os.environ``-based ``HERMES_SESSION_*`` state with task-local ``ContextVar``s (inherited by ``run_in_executor`` threads), so concurrently handled messages no longer clobber each other's routing ids. ``get_session_env`` is a drop-in for ``os.getenv``. N)contextmanager) ContextVar)AnyIteratorFc$V^8dQhR\/#returnbool)formats"r(s" 8t*T6 * *8s HERMES_SESSION_ASYNC_DELIVERYrHERMES_SESSION_HISTORY_DELIVERY!HERMES_CRON_AUTO_DELIVER_PLATFORM HERMES_CRON_AUTO_DELIVER_CHAT_ID"HERMES_CRON_AUTO_DELIVER_THREAD_IDc4V^8dQhR\R\RR/#)rfuncargsr N)strr)r s"r rrHs!  s 3 4 rcV^RIHp\W 4!V!R# \dR#i;i)zVBest-effort call of ``agent.runtime_cwd.``; import/runtime failures are ignored.) runtime_cwdN)agentr%getattr Exception)r!r"r%s&* r _runtime_cwdr)Hs) % "D)    s  ((c(V^8dQhR\RR/#)r session_idr Nr#)r s"r rrQs 1 1s 1t 1rc\PV4^RIHpV!4'dR#V\ P R&R# \dL"i;i)zSynchronize ``HERMES_SESSION_ID`` across ContextVar and ``os.environ`` (tools read it with an os.environ fallback). Delegated subagent children (built in the parent process) get ONLY the task-local write, or they would clobber the parent's id.)is_delegated_child_contextNHERMES_SESSION_ID) _SESSION_IDsetagent.delegation_contextr.r(osenviron)r+r.s& r set_current_session_idr5QsNOOJ G % ' '  ('1BJJ"#    sA AAcLV^8dQhR\R,R\R,/#)rr+Nr r#r)r s"r rr`s" " "#* " "rc#"\P4pVe\PV4Rx\PV4R# \PT4i;i5i)zBind a task-local session id and restore the prior value on exit; never touches ``os.environ``. ``session_id=None`` is a pure save/restore boundary.N)r0getr1)r+previouss& r scoped_current_session_idr;_sE H #" ! !s.A&A A& A##A&c>V^8dQhR\R\R,/#)r session_keyr Nr7)r s"r rrms""C"HTN"rc#"\PV4pRx\PV4R# \PT4i;i5i)zBind only the route key of the session a call works for (a hook fired for it outside its turn) and restore the prior value on exit; never touches ``os.environ``.N) _SESSION_KEYr1reset)r=tokens& r scoped_session_keyrBls;   [ )E" 5! 5!sA4AA  Ac$V^8dQhR\/#rr,)r s"r rrws,,3,rcF\P4pV\JdR#T#)zThe route key bound in THIS context, ``""`` when none is: no ``os.environ`` fallback, so a thread that inherited no context never borrows another session's key.)r?r9r)values r bound_session_keyrGws#    E&2+e+rcXV^8dQhR\R\R,R\R,/#)rsourcemetadataNr )rdict)r s"r rr~s.DD#DDDrcRUu/uF%p\WR4;p'gKV\V4bK' ppV'd/T;'g/CVC#T#uupi)zKKeep inbound route anchors for durable deliveries after the source is gone.N)scope_idparent_chat_id)r'r#)rIrJkeyrFanchorss&& r source_route_metadatarQ~s^*H9*H3#F6656sCJ*HG9.5 *x~~2 *' *C8C9s A A rETc.:V^8dQhR\R\R\R\R\R\R\R\R \R \R \R \R \R\R\R\R\R\R\R\R\R\R,R\/#)rplatformrIchat_id chat_type chat_name thread_iduser_id user_id_alt user_namerMr=r+ message_idprofilebrowser_control_principal browser_control_transport_familycwdasync_delivery ui_session_id cron_sessionrNsession_history_deliveryNr )r#r rlist)r s"r rrs #36HK$'7:NQ$';>QT $' IL  '*  69  PT    ,/  JM "Dj rcdRsWW#WEWgWWVWWVV3p\\V4UUu.uFwppVPV4NK pppVP \ P\ V444TP \PVf\MT44\RV4V#uuppi)uSet all session context variables and return reset tokens. Call ``clear_session_vars(tokens)`` in a ``finally``; not nestable, clearing resets every var to ``""`` rather than restoring prior values (tokens are accepted only for API compat). ``session_history_delivery`` declares whether the bound chat id is one the client can address again: ``"1"`` (audited producers — explicit session-id header, native API sessions, /v1/runs) or ``""`` / omitted (default-deny, #98619). ``None`` leaves the var at ``_UNSET`` ("never declared"), which ``session_history_delivery_supported()`` treats as NOT capable — an omitted declaration cannot grant wake authority.Tset_session_cwd) rzip _SESSION_VARSr1append_SESSION_ASYNC_DELIVERYr _SESSION_HISTORY_DELIVERYrr))rSrIrTrUrVrWrXrYrZrMr=r+r[r\r]r^r_r`rarbrNrcvaluesvarrFtokenss&&&&&&&&&&&&&&&&&&&&&& r set_session_varsros& $'iG[mZ!\SaF 03=&/I J/Iecggen/IF J MM)--d>.BCD MM+//:R:Z`xyz"C( M KsB,c(V^8dQhR\RR/#)rrnr N)rd)r s"r rrs & &t & &rc\FpVPR4K \P\4\P\4\ R4R#)uMark session context variables as explicitly cleared (``""``, not ``_UNSET``), so ``get_session_env`` returns empty instead of stale ``os.environ`` values. Async-delivery goes back to ``_UNSET``: a cleared context is default-supported, not opted-out. Wake capability goes back to ``_UNSET`` too — but for the opposite reason: a cleared context has declared nothing, and an undeclared capability FAILS CLOSED (#98619).rEclear_session_cwdN)rhr1rjrrkr))rnrms& r clear_session_varsrss>   '!!&)$%rcV^8dQhRR/#rr Nr)r s"r rrs & &D &rc\P4FpVP\4K \P\4\ P\4\ R4R#)aReset every session var to ``_UNSET`` ("never bound here") for THIS context. Call at the top of a fresh task *before* it binds: ``create_task`` snapshots the context, so B's task inherits A's already-set vars and a subprocess spawned before B binds would read A's identity. ``_SESSION_ASYNC_DELIVERY`` and ``_SESSION_HISTORY_DELIVERY`` (outside ``_VAR_MAP``) are reset explicitly too.rrN)_VAR_MAPrlr1rrjrkr))rms r reset_session_varsrxsE   !'!!&)$%rc<V^8dQhR\R\R\/#)rrrr r,)r s"r rrs!$$#$$S$rc\PV4pVeVP4;p\JdV#\P!W4#)zRead a session var by legacy ``HERMES_SESSION_*`` name; drop-in for os.getenv. The ContextVar wins if ever set here (even to ``""``); else ``os.environ``; else *default*.)rwr9rr3getenv)rrrmrFs&& r get_session_envr|s= ,,t C SWWY.Ev= 99T ##rc$V^8dQhR\/#rr )r s"r rrsZZdZrc\P!R4;'g \RR4pV\RR43pRV4p\;QJdRV4F 'gK R# R#!RV44#) zWhether this turn is delivered over a human messaging channel (checks ``HERMES_PLATFORM``, then the session platform, then the session source).HERMES_PLATFORMHERMES_SESSION_PLATFORMrEHERMES_SESSION_SOURCEc3"TF6p\T;'gR4P4P4xK8 R#5i)rEN)r#striplower)rvs& r r/session_is_messaging_surface..s/ ;Fqc!''rl  "((**Fs A+Ac3F"TFq;'d V\9xK R#5iN)NON_MESSAGING_SESSION_SURFACES)ridents& r rrs!YRXDD&DDDRXs !!TF)r3r{r|any)rSidentss r session_is_messaging_surfacerskyy*+]]?XZ\/]H(?D EF ;F ;F 3YRXY33Y3Y3YRXY YYrcV^8dQhRR/#rur)r s"r rrs''4'rc0\PR4R#)a7Declare that this session cannot receive an async background completion. Unlike ``set_session_vars(async_delivery=False)`` this does NOT latch ``_session_context_engaged`` (flipping the subprocess env bridge), which a one-shot CLI must not do as a side effect. See NousResearch/hermes-agent#53027 and #63142. FN)rjr1rrr declare_stateless_channelrs&rc$V^8dQhR\/#rr )r s"r rrs 4 4$ 4rc^RIHp\PP R4'gV!4'dR#\ P 4pV\ JdR#\V4#)aWhether the current session can deliver a background completion later. False for stateless channels (:func:`declare_stateless_channel`), Kanban workers (``HERMES_KANBAN_TASK``: one-shot subprocesses whose parent disappears after the turn) and registered worker processes: a managed worker exits at its turn boundary, so detached work it scheduled would be lost (recovered ``unknown``) and its completion queue has no reader.)is_worker_processHERMES_KANBAN_TASKFT)agent.runtime_session_storerr3r4r9rjrr )rrFs r async_delivery_supportedrsJ > zz~~*++/@/B/B # ' ' )EF?43U 3rc$V^8dQhR\/#rr )r s"r rrs22D2rc0\P4R8H#)zWhether this request declares a server-history consumer for detached results. Fail closed on omitted bindings; never borrow authority from the environment.1)rkr9rrr "session_history_delivery_supportedrs % ( ( *c 11rchV^8dQh/^\9d \;R&^\9d \;R&#)rrr)__conditional_annotations__rr )r s"r rrs0"'&$&#r)rrHERMES_SESSION_CHAT_IDHERMES_SESSION_CHAT_TYPEHERMES_SESSION_CHAT_NAMEHERMES_SESSION_THREAD_IDHERMES_SESSION_USER_IDHERMES_SESSION_USER_ID_ALTHERMES_SESSION_USER_NAMEHERMES_SESSION_SCOPE_IDHERMES_SESSION_KEYr/HERMES_UI_SESSION_IDHERMES_SESSION_MESSAGE_IDHERMES_SESSION_PROFILE HERMES_BROWSER_CONTROL_PRINCIPAL'HERMES_BROWSER_CONTROL_TRANSPORT_FAMILYHERMES_CRON_SESSIONHERMES_SESSION_PARENT_CHAT_IDr)rE> rEclituitoolcodexlocalkanbandesktopgatewaywebhook api_servermsgraph_webhook);r__doc__r3 contextlibr contextvarsrtypingrrobjectrrrtuplerh_SESSION_PLATFORM_SESSION_SOURCE_SESSION_CHAT_ID_SESSION_CHAT_TYPE_SESSION_CHAT_NAME_SESSION_THREAD_ID_SESSION_USER_ID_SESSION_USER_ID_ALT_SESSION_USER_NAME_SESSION_SCOPE_IDr?r0_SESSION_UI_SESSION_ID_SESSION_MESSAGE_ID_SESSION_PROFILE_BROWSER_CONTROL_PRINCIPAL!_BROWSER_CONTROL_TRANSPORT_FAMILY _CRON_SESSION_SESSION_PARENT_CHAT_IDrjrk_CRON_AUTO_DELIVER_PLATFORM_CRON_AUTO_DELIVER_CHAT_ID_CRON_AUTO_DELIVER_THREAD_IDrrwr)r5r;rBrGrQrorsrxr| frozensetrrrrrr)rmrs0@r rs %" h"'&$& E 8 EE 8   (8:L*,<>R)</1A A=Ri%%DfU''HRXY))LV\]'(JTZ[)*NX^_&&/&1K& & &cHHcM&    1 " """,Dbb"RTVVXb,.2VZr+/@ & &$"+," Z' 42_ s4E