+ lHje Rt^RIHt^RIHt^RIHtHtHtH t ^RI H t H t H t HtHtHtHt^RIHt^RIHt!RR]4t!R R ]4t!R R ]4t!R R]4t!RR]4t!RR] 4t!RR]4t!RR]4t!RR] 4t!RR]4t]!R]]RR7!RR] 4t !R R!]4t!]!R"] ]!R#R7!R$R%]4t"!R&R']4t#]!R(]"]#R)R7!R*R+]4t$!R,R-]4t%]!R.]$]%R/R7!R0R1] 4t&!R2R3]4t'!R4R5]4t(]!R6]&](R7R7!R8R9] 4t)!R:R;]4t*]!R<])]*R=R7!R>R?] 4t+!R@RA]4t,!RBRC]4t-]!RD]+]-RER7!RFRG]4t.!RHRI]4t/]!RJ].]/RKR7!RLRM]4t0!RNRO]4t1]!RP]0]1RQR7!RRRS]4t2!RTRU]4t3]!RV]2]3RWR7!RXRY]4t4!RZR[]4t5]!R\]4]5R]R7!R^R_] 4t6!R`Ra]4t7]!Rb]6]7RcR7!RdRe]4t8!RfRg]4t9]!Rh]8]9RiR7!RjRk]4t:!RlRm]4t;]!Rn]:];RoR7!RpRq]4t<!RrRs]4t=]!Rt]<]=RuR7!RvRw]4t>!RxRy]4t?]!Rz]>]?R{R7!R|R}] 4t@!R~R]4tA!RR]4tB]!R]A]BRR7!RR]4tC!RR]4tD]!R]C]DRR7!RR]4tE!RR]4tF]!R]E]FRR7!RR]4tG!RR]4tH]!R]G]HRR7!RR]4tI!RR]4tJ]!R]I]JRR7!RR]4tK!RR]4tL!RR]4tM!RR]4tN]!R]K]NRR7!RR] 4tO!RR]4tP!RR]4tQ]!R]P]QRR7!RR]4tR!RR] 4tS!RR]4tT]!R]R]TRR7!RR] 4tU!RR]4tV!RR]4tW]!R]V]WRR7]!R]V]WRR7!RR] 4tX!RR]4tY]!R]X]YRR7!RR] 4tZ!RR] 4t[!RR]4t\]!R]Z]\RR7!RR] 4t]!RR]4t^]!R]]]^RR7!RR]4t_!RR]4t`]!R]_]`RR7!RR]4ta!RR]4tb]!R]a]bRR7!RR] 4tc!RR]4td]!R]c]dRR7!RR] 4te!RR]4tf]!R]e]fRR7R#)a'Session lifecycle contracts (``tui_gateway/methods_session.py``): create / resume / activate / close, the live-session snapshot those share, history + compression + undo, mid-turn corrections, listing/browsing stored rows, spawn-tree snapshots, event replay and the stateless one-shot LLM call. ) annotations)Field) JsonValueParamsResultWireEnum) OpenModelPendingApproval ProfileParamsSessionLiveInfo SessionParamsTranscriptMessageUsage)ConnectionRequestPayload)methodc:]tRt^t$RtR]R&R]R&R]R&RtR#) OpenRequestEntryuOne unanswered server→client request (``server_requests.Request.snapshot``); the reconnecting client re-delivers it to its request handlers.stridrzdict[str, JsonValue]paramsN__name__ __module__ __qualname____firstlineno____doc____annotations____static_attributes__rC/home/ubuntu/.hermes/hermes-agent/tui_gateway/contracts/sessions.pyrrs6 G K  rrc]tRt^t$RtRtR]R&RtR]R&RtR]R&R t R ]R &R t R ]R &R t R]R&R t R]R&R t R ]R&R tR ]R&R tR]R&R tR ]R&RtR #) InflightTurnz``session_auto_continue._inflight_snapshot``: the live (or retained failed) turn a reconnecting client rebuilds its bubbles from.r assistantFbool streaminguserN str | None display_kinddict[str, JsonValue] | Nonedisplay_metadatalist[str] | None correctionszlist[int] | Nonecorrection_offsetserrorstatus bool | None recoverable error_surfacer)rrrrrr$rr&r'r)r+r-r.r/r0r2r3rrrr r"r"s|)IsItD#N#L*#4818$(K!(+/(/E:FJ#K#15M.5rr"c"]tRt^.t$R]R&RtR#) QueuedPromptrr'rNrrrrrrrrr r5r5. Irr5c0]tRt^2t$RtR]R&R]R&RtR#) TodoStatezI``tool_progress._normalize_todo_state``: the authoritative todo snapshot.list[dict[str, JsonValue]]todosintrevisionrNrrrr r9r92sS %%Mrr9c0]tRt^9t$RtR]R&R]R&RtR#) AutoContinuezKA crash-interrupted turn was scheduled to continue right after this resume.r<attemptfloatinterrupted_atrNrrrr r?r?9sU Lrr?c.]tRt^@tRtRtRtRtRtRt Rt R#) LiveSessionStatusidlestartingwaitingworkingr&resumingrN) rrrrrErFrGrHr&rIrrrr rDrD@s DHGGIHrrDc$]tRt^It$RtR]R&R]R&R]R&R]R &R tR ]R &R tR ]R &R tR ]R&R t R]R&R t R]R&R t R]R&R t R]R&R t R]R&R tR ]R&R tR]R&R tR]R&R tR]R&R tR]R&R tR]R &R tR!]R"&R tR#]R$&R%tR #)&LiveSessionSnapshotzUnion of ``server._live_session_payload``, ``methods_session._resume_response`` and the live-unpersisted resume path; keys only some paths produce are optional.r session_idr< message_countlist[TranscriptMessage]messagesr infoNr(stored_session_idresumed session_keyr1messages_omitted hydratingrunning float | Noneturn_started_at started_atr0zInflightTurn | NoneinflightzQueuedPrompt | NonequeuedzPendingApproval | Nonepending_approvalzlist[OpenRequestEntry] | None open_requestszConnectionRequestPayload | Nonepending_connectionzTodoState | None todo_statezAutoContinue | None auto_continuer)rrrrrrrQrRrSrTrUrVrXrYr0rZr[r\r]r^r_r`rrrr rKrKIsPO%% $(z(GZ"K"$(k(!I{!G[$(O\(#J #FJ$(H!("&F &/3,337M07;?7>#'J ')-M&-rrKcz]tRt^ht$Rt]P RR/,tR]R&RtR]R&Rt R]R &Rt R]R &R t R#) SeedMessageu<One create-time transcript row (``session_history._coerce_seed_history``); ``text`` is the legacy alias of ``content``; only ``display_kind: "hidden"`` is accepted from the wire. Clients forward stored rows verbatim (``_row_id``, ``timestamp``, …) and the coercer drops what it does not use, so the row stays open.extraallowrroleNr(contenttextr)r) rrrrrr model_configrrfrgr)rrrr rbrbhsA' &&'7);;L IGZD*#L*#rrbc]tRt^vt$RtR]R&RtR]R&RtR]R&RtR]R&Rt R ]R &Rt R]R &Rt R]R &Rt R]R &Rt R]R&RtR]R&RtR]R&RtR]R&RtR]R&RtR]R&RtR]R&RtR]R&RtR]R&RtR#)SessionCreateParamsN int | Nonecolsr(sourcecwdr1 cwd_explicitzlist[SeedMessage] | NonerOparent_session_idtitlemodelproviderreasoning_effortfast service_tierFr%close_on_disconnecthidden room_plumbingfollow_profile_configidempotency_keyr)rrrrrlrrmrnrorOrprqrrrsrtrurvrwrxryrzr{rrrr rjrjvsD*FJC!%L+$)-H&-$(z(E:E:Hj#'j'D+#L*# %%FDM4"'4'#'OZ&rrjcJ]tRt^t$R]R&R]R&R]R&R]R&R]R &R tR #) SessionCreateResultrrLrQr<rMrNrOr rPrNr6rrr r}r}sO%% rr}zsession.createzgMint a live session (agent builds after the reply); a DB row appears on the first prompt unless seeded.)rresultdoccl]tRt^t$]!^R7tR]R&RtR]R&RtR]R&Rt R]R &Rt R]R &R t R#) SessionBranchStoredParams) min_lengthrrpNrkrlr(rmrnr{r) rrrrrrprrlrmrnr{rrrr rrs<"a0s0D*FJC#'OZ&rrcJ]tRt^t$R]R&R]R&R]R&R]R&R]R &R tR #) SessionBranchStoredResultrrLrQr<rMr%rTr rPrNr6rrr rrsO rrzsession.branch_storedzWhole-session branch of a stored parent: the owning backend reads and copies the transcript, which never crosses the wire (a separate method so an older gateway fails loudly, not with an empty branch).c]tRt^t$RtRtR]R&RtR]R&RtR]R &Rt R]R &Rt R]R &Rt R]R &Rt R]R &Rt R]R&RtR#)SessionResumeParamszb``session_id`` is the STORED id (or an exact title); the reply's ``session_id`` is the runtime id.Nrkrlr(rmFr%lazy defer_history omit_messages eager_buildrwT inline_imagesr)rrrrrrlrrmrrrrrwrrrrr rrsXlD*FJD$M4M4K %%M4rrc]tRt^tRtR#)SessionResumeResultrNrrrrrrrr rrrrzsession.resumez_Attach to a stored session: reuse it if live here, else lazy / deferred / cold / eager rebuild.c4]tRt^t$RtR]R&RtR]R&RtR#)SessionActivateParamsNrkrlFr%rr)rrrrrlrrrrrr rrsD*M4rrc]tRt^tRtR#)SessionActivateResultrNrrrr rrrrrzsession.activatezQAttach the frontend to a live session without closing the previously focused one.cB]tRt^t$RtR]R&RtR]R&RtR]R&R tR#) SessionListParamsNr(rqrklimitFr%include_hiddenr) rrrrrqrrrrrrr rrs E:E: ND rrc]tRt^t$RtR]R&RtR]R&RtR]R&RtR]R &^t R ]R &^t R ]R &Rt R]R&Rt R]R&] !RRR7tR]R&RtR#)SessionListRowz``methods_session._session_row_summary``; ``resolved_id`` only on a title lookup that followed a compression lineage to its tip.rrNr( resolved_idr#rqpreviewrArYr<rMrklive_message_countrm_lineage_root_id)defaultaliaslineage_root_idr)rrrrrrrrqrrYrMrrmrrrrrr rrsh' G"K"E3OGSJM3%) )FC#(]tRtRt$R]R&RtR]R&RtR]R&R tR#) SessionTitleResulti:rrqNr(rSr1pendingr)rrrrrrSrrrrr rr:s J"K"G[rrz session.titlezPRead or set a live session's title; a title set before the row exists is queued.c>]tRtRt$RtR]R&R]R&RtR]R &R tR#) SessionSetHiddenParamsiDzJ``session_id`` is a live runtime id first, else a stored id / key / title.rrLr%rxNr(profiler)rrrrrrrrrrr rrDsTO LGZrrc,]tRtRt$R]R&R]R&RtR#)SessionSetHiddenResultiLr%rxrrSrNr6rrr rrLs Lrrzsession.set_hiddenz`Set/clear hidden (out of the default list, still resumable by its owner) on a session + lineage.cT]tRtRt$RtRtR]R&RtR]R&RtR]R &Rt R]R &R t R#) SessionArchiveParamsiUzi``session_id`` (or its ``session_key`` alias) is a live runtime id first, else a stored id / key / title.Nr(rLrSTr%archivedrr) rrrrrrLrrSrrrrrr rrUs-s!J !"K"HdGZrrc,]tRtRt$R]R&R]R&RtR#)SessionArchiveResulti^r%rrrSrNr6rrr rr^s Nrrzsession.archivez[Set/clear archived (soft-hide, messages kept) on a session + lineage; Desktop PATCH parity.c,]tRtRt$R]R&R]R&RtR#)SessionWorkspaceMoveParamsigrrSrnrNr6rrr rrgs  Hrrc>]tRtRt$R]R&RtR]R&RtR]R&RtR#) SessionWorkspaceMoveResultilrrnNr(branch git_repo_rootr)rrrrrrrrrrr rrls HFJ $M:$rrzsession.workspace.movezXRe-home a stored session's workspace; git identity is replaced and a live agent follows.c"]tRtRt$R]R&RtR#)SessionCwdSetParamsivrrnrNr6rrr rrvs Hrrc]tRtRtRtRtR#)SessionCwdSetResultizzIThe refreshed ``session.info`` view (full agent view, or the lazy shape).rNrrrr rrzsSrrzsession.cwd.setz0Change a live, idle session's working directory.c]tRtRtRtR#)SessionCloseParamsirNrrrr rrrrrc>]tRtRt$R]R&]!]R7tR]R&RtR#) SessionCloseResultir%closeddefault_factoryz list[str]rOrN) rrrrrrlistrOrrrr rrs L5Hi5rrz session.closez:Tear down a live session (its stored row stays resumable).cB]tRtRt$RtR]R&RtR]R&RtR]R&RtR#) SessionBranchParamsiNr(namerkcountr{r) rrrrrrrr{rrrr rrs"D*E:#'OZ&rrc^]tRtRt$R]R&R]R&R]R&R]R&R]R&R ]R &R ]R &R tR#)SessionBranchResultirrLrQrqparentr<rMrNrOr rPrNr6rrr rrs)O J K%% rrzsession.branchzTFork a live session into a new stored child that shares the parent's history so far.c4]tRtRt$RtR]R&RtR]R&RtR#)SessionBranchWholeParamsiNr(rr{r)rrrrrrr{rrrr rrsD*"&OZ&rrc^]tRtRt$R]R&R]R&R]R&R]R&R]R&R ]R &R ]R &R tR#)SessionBranchWholeResultirrLrQrqrr<rMr%rTr rPrNr6rrr rrs)O J K rrzsession.branch_wholezOsession.branch of the whole history without echoing the copied transcript back.c]tRtRtRtRtRtR#) UndoIntentiretryundorN)rrrrRETRYUNDOrrrr rrs E Drrc&]tRtRt$RtR]R&RtR#)SessionUndoParamsiNzUndoIntent | Noneintentr)rrrrrrrrrr rrs $F $rrc"]tRtRt$R]R&RtR#)SessionUndoResultir<removedrNr6rrr rrrrrz session.undozGDrop the last user turn (and everything after it) from an idle session.c]tRtRtRtR#)SessionSaveParamsirNrrrr rrrrrcT]tRtRt$RtRtR]R&]PRR/,tRt R#) SessionSaveResultizGUnder turn isolation the compute host's result passes through verbatim.Nr(filercrdr) rrrrrrrrrhrrrr rrs$QD*&&'7);;Lrrz session.savezBExport the transcript to ~/.hermes/sessions/saved (classic /save).c]tRtRtRtR#)SessionStatusParamsirNrrrr rrrrrc"]tRtRt$R]R&RtR#)SessionStatusResultiroutputrNr6rrr rrs Krrzsession.statusz&Rendered /status text for the session.c]tRtRtRtR#)SessionHistoryParamsirNrrrr rrrrrc,]tRtRt$R]R&R]R&RtR#)SessionHistoryResultir<rrNrOrNr6rrr rrs J%%rrzsession.historyzFThe durable display transcript (ancestors included, row ids attached).c]tRtRtRtR#)SessionUsageParamsirNrrrr rrrrrc4]tRtRt$RtR]R&RtR]R&RtR#)SessionUsageResultiNr, credits_linesr1credits_usage_windowr)rrrrrrrrrrr rrs&*M#*(,+,rrz session.usagezUToken / context / cost counters for the session (+ Nous credit lines when available).c]tRtRtRtR#)SessionContextBreakdownParamsirNrrrr rrrrrc@]tRtRt$R]R&R]R&R]R&R]R&RtR #) ContextCategoryircolorrlabelr<tokensrNr6rrr rrs J G J KrrcX]tRtRt$RtR]R&R]R&R]R&R]R&R ]R &R]R &R tR #)ContextFileSourceizDOne row of ``agent.context_file_sources.list_context_file_sources``.rr pathr<chars est_tokensr%loadedr0rNrrrr r r s#N J I JO L Krr cz]tRtRt$RtR]R&R]R&R]R&R]R&R]R &R ]R &R ]R &R ]R&.tR]R&RtR#)SessionContextBreakdownResultiz``agent.context_breakdown.compute_session_context_breakdown`` (empty categories before the agent builds) plus the per-file context manifest (empty until the agent exists).zlist[ContextCategory] categoriesr< context_maxcontext_percent context_usedestimated_totalr%context_estimatedrcontext_sourcerrzlist[ContextFileSource] context_filesrN)rrrrrrrrrrr rrsDJ&% J-/M*/rrzsession.context_breakdownz5Cursor-style split of the context window by category.c~]tRtRt$RtRtR]R&RtR]R&RtR]R &Rt R]R &R t R ]R &R t R ]R&Rt R]R&Rt R#)CompressionSummaryi0zC``agent.manual_compression_feedback.summarize_manual_compression``.Fr%noopabortedNr1refused_would_grow fallback_usedr#rheadline token_liner(noter)rrrrrrrrr r!r"r#r$rrrr rr0sLMD$GT&* *!%M;%HcJD*rrc&]tRtRt$RtR]R&RtR#)SessionCompressParamsi<Nr( focus_topicr)rrrrr'rrrrr r&r&<s "K"rr&c]tRtRt$RtRtR]R&RtR]R&RtR]R&Rt R]R &Rt R]R &Rt R]R &Rt R ]R &Rt R]R&RtR]R&RtR]R&RtR]R&RtR]R&RtR]R&RtR]R&RtR]R&]P,RR/,tRtR#)SessionCompressResulti@zIn-process: the before/after summary + replacement transcript. Compute host: its result passes through (hence open) with ``turn_isolation``; a lock held elsewhere answers ``compressed: false``.Nr(r0rkrbefore_messagesafter_messages before_tokens after_tokenszCompressionSummary | Nonesummaryz Usage | NoneusagezSessionLiveInfo | NonerPzlist[TranscriptMessage] | NonerOr1 compressed lock_heldmessageturn_isolationr*host_ackrcrdr)rrrrrr0rrr*r+r,r-r.r/rPrOr0r1r2r3r4rrhrrrr r)r)@sjFJGZ"&OZ&!%NJ% $M:$#L*#)-G &-E<#'D '/3H,3"J "!I{!GZ"&NK&,0H)0&&'7);;Lrr)zsession.compresszCManual /compress of an idle session, optionally focused on a topic.c&]tRtRt$RtR]R&RtR#)SessionInterruptParamsi]Nr(expected_hosted_task_idr)rrrrr7rrrrr r6r6]s *.Z.rr6c]tRtRtRtRtRtR#)InterruptStatusia interruptednot_interruptedrN)rrrrr:r;rrrr r9r9as K'Orr9c>]tRtRt$R]R&RtR]R&RtR]R&RtR#) SessionInterruptResultifr9r0Nr1r:r3r)rrrrrr:r3rrrr r=r=fs #K#"&NK&rr=zsession.interruptzMStop the running turn (and streaming TTS); retires the crash-recovery marker.c"]tRtRtRtRtRtRtR#)CorrectionStatusipr[ redirectedrejectedrN)rrrrr[r@rArrrr r?r?ps FJHrr?c"]tRtRt$R]R&RtR#)SessionCorrectionParamsivrrgrNr6rrr rCrCvr7rrCc,]tRtRt$R]R&R]R&RtR#)SessionCorrectionResultizr?r0rrgrNr6rrr rErEzs  IrrEz session.steerzDInject text into the next tool result without interrupting the turn.zsession.redirectzVRedirect the active turn (queued for the next turn while the agent is still building).cZ]tRtRt$R]R&RtR]R&RtR]R&RtR]R &RtR]R &R t R#) SpawnTreeSaveParamsir: subagentsNr(rLrWrY finished_atr r) rrrrrrLrYrIr rrrr rGrGs0))!J !#J # $K$E:rrGc,]tRtRt$R]R&R]R&RtR#)SpawnTreeSaveResultirrrLrNr6rrr rKrKs IOrrKzspawn_tree.savezPPersist a finished delegation tree snapshot under the session's spawn-trees dir.cB]tRtRt$RtR]R&RtR]R&RtR]R &R tR#) SpawnTreeListParamsiNr(rLFr% cross_sessionrkrr) rrrrrLrrNrrrrr rMrMs !J !M4E:rrMcl]tRtRt$RtR]R&RtR]R&RtR]R &RtR]R &R t R]R &^t R ]R&Rt R#)SpawnTreeEntryizFIndex row (``server._append_spawn_tree_index``) or a legacy file scan.rrNr(rLrWrYrIr#r r<rr) rrrrrrrLrYrIr rrrrr rPrPs:P I!J !#J # $K$E3OE3NrrPc"]tRtRt$R]R&RtR#)SpawnTreeListResultizlist[SpawnTreeEntry]entriesrNr6rrr rRrRs !!rrRzspawn_tree.listz)Saved spawn-tree snapshots, newest first.c"]tRtRt$R]R&RtR#)SpawnTreeLoadParamsirrrNr6rrr rUrUr7rrUc]tRtRt$RtRtR]R&RtR]R&RtR]R&Rt R]R &] !] R 7t R ]R &] PR R/,tRtR#)SpawnTreeLoadResultizUThe snapshot file as written by ``spawn_tree.save`` (open: the file is the contract).Nr(rLrWrYrIr rr:rHrcrdr)rrrrrrLrrYrIr rrrHrrhrrrr rWrWsR_!J !#J # $K$E:,1$,GI)G&&'7);;LrrWzspawn_tree.loadzMRead one saved spawn-tree snapshot (path must be under the spawn-trees root).c&]tRtRt$RtR]R&RtR#)TerminalResizeParamsiNrkrlr)rrrrrlrrrrr rYrYs D*rrYc"]tRtRt$R]R&RtR#)TerminalResizeResultir<rlrNr6rrr r[r[r7rr[zterminal.resizez;Record the client's column width for server-side rendering.c4]tRtRt$RtR]R&RtR]R&RtR#)SessionEventsSinceParamsiNrk last_seenr( replay_epochr)rrrrr^rr_rrrr r]r]s Iz  $L*#rr]cT]tRtRt$R]R&R]R&R]R&R]R&R ]R &R ]R &R tR#)SessionEventsSinceResultir:eventsr< latest_seqr% truncatedrrepochzlist[OpenRequestEntry]r]rNr6rrr raras" &&OO J J))rrazsession.events.sincezSReplay events after a seq watermark on WS reconnect; truncated means refetch state.c]tRtRtRtR#)SessionEventsStatsParamsirNrrrr rgrgrrrgcX]tRtRt$RtR]R&R]R&R]R&R]R&R]R&R]R &R tR #) SessionEventsStatsResultiz``event_replay.replay_stats``.r<rrbbytesmax_per_sessionmax_bytes_per_sessionmax_bytes_processrNrrrr riris&(M K Jrrizsession.events.statsz.Replay-buffer occupancy telemetry (ops/debug).c]tRtRt$RtRtR]R&RtR]R&RtR]R&Rt R]R &Rt R]R &Rt R ]R &Rt R ]R&Rt R]R&RtR#)LlmOneshotParamsiz\Needs a ``template`` or ``instructions`` / ``input``; a live ``session_id`` lends its model.Nr(template instructionsinputr* variablestaskrW temperaturerk max_tokensrLr)rrrrrrprrqrrrsrtrurvrLrrrr rorosVfHj#L*#E:-1I*1D* $K$!J !!J !rroc"]tRtRt$R]R&RtR#)LlmOneshotResulti rrgrNr6rrr rxrx r7rrxz llm.oneshotzWStateless one-shot LLM completion (titles, ideas) on the session's or the task backend.N)gr __future__rpydanticrbaserrrrcommonrr r r r r rconnectors_operationrregistryrrr"r5r9r?rDrKrbrjr}rrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr rrr&r)r6r9r=r?rCrErGrKrMrPrRrUrWrYr[r]rargrirorxrrr rs #55: !v!666"66.&.> $& $'-'0& 3R hj  %% (BKe eg - T/T!4=P =?  66 1:L GI'-'& 3G_ \^ % % ~/8I TV  <<~/8I OQ - & 3R SU  -- 1:L bd M f 0F 0"+HQn BD  #M#R HJ$}$*v*&>G_ `b } v&>G_ ;= "} "v}-6F dfr