+ lHjN@a0t$Rt^RIHt^RIt^RIt^RIt^RIt^RIt^RI H t H t ] !4t ] Pt ] Pt]P !]4tRRRR?RR@R RAR RB/tR ]R &]!0RCm4t]!]4],tR RltRRltRRltRRltRRltRRltRtRtRt Rt!RRlt"]!0RDm4t#]PH!4t%RR lt&R!R"R#R"/R$R%llt'] !R&4]R'R(l44t(] !R)4]R*R+l44t(R,R-lt)R.R/lt*R0R1lt+R2R3lt,R4R5lt-R6R7lt.R8R9lt/R:R;lt0R#)EaStructured Desktop controls for persisted goal, loop, and heartbeat state. ``session.control.read`` is a stable, allowlisted view of one live session. ``session.control`` accepts a closed set of intent-level actions: goal and loop actions use their existing TUI command handlers, while controls without a TUI command use the public manager API. A successful action emits one matching ``session.control.update`` event. ) annotationsN)HandlerRegistry bind_modulez goal.pausez goal.resumez goal.clearz goal.unwaitz loop.pausez loop.resumez loop.stopzdict[str, tuple[str, str]]_ACTION_COMMAND_MAPcV^8dQhRR/#return dict | None)formats"H/home/ubuntu/.hermes/hermes-agent/tui_gateway/methods_session_control.py __annotate__r1s""+"c(VeVPR8XdR#RVPRVPRVPRVPRVPP 4R\ VP4R VPUu.uFApR VPR VPR VPR VPRVP/NKC up/pVP'dVPVR&VP'dVPVR&VP 'dVP VR&VP"'dVP"VR&VP$'dVP$VR&\'V4;p'dW2R&V#uupi)z3Return only stable, frontend-safe GoalState fields.Nclearedtitlestatus turns_used max_turnscontractsubgoalsgatescommandtimeout_seconds max_retriesattemptslast_exit_code created_at updated_at paused_reason last_verdict last_reason wait_barrier)rgoalrrrto_dictlistrrrrrrrr last_turn_atr r!r"_extract_wait_barrier)stategatesnapshotbarriers& r _safe_goal_snapshotr-1so } 1%,,e&&U__ENN**,D(   $ 4<<!4#7#7t//DMM $"5"5  $  H$ !&!1!1 !&!3!3 $)$7$7! #(#5#5  "'"3"3'..w.#* O/  sAFcV^8dQhRR/#rr )r s"r rrVs  K rcBVP;'gRpVP'd7\P!4VP8dRRRVPRV/#VPeRRRVPRV/#VPeRR RVPRV/#R#) zGExpose absolute barriers; countdown presentation belongs to the client.typeuntiluntil_atreasonNsessiontargetpid)waiting_reason waiting_untiltimewaiting_on_sessionwaiting_on_pid)r)r4s& r r(r(Vs  ! ! ' 'RF tyy{U-@-@@U-@-@(FSS + 8U-E-ExQWXX 'x)=)=xPP rc V^8dQhRRRR/#)rdeferred_by_goalboolr r r )r s"r rrbsD[rcVeVPR8XdR#RVPRVPRVPRVPRVPRVP R VP R VPR VPR VPR VPRVPRVPRV/pVP'dVPVR&VP'dVPVR&V#)z?Return allowlisted persisted LoopState fields, never its route.Nrpromptrmodeinterval_seconds current_delaytimesr2 max_ticks ticks_firedr last_fired_at next_due_atawaiting_responser>r last_stop_reason)rrArBrCrDrEr2rFrGrrHrIrJr rK)r)r>r+s&$ r _safe_loop_snapshotrLbs } 1%,,%,, E22,,U__u((e&&,,u((U44,H  $)$7$7! ','='=#$ OrcV^8dQhRR/#rr )r s"r rr}s  { rc VeVPR8XdR#RVPRVPRVPRVPRVPRVP /#) zDReturn only the persisted HeartbeatState fields the Desktop renders.NrrArrCrrH fire_count)rrArCrrHrO)r)s&r _safe_heartbeat_snapshotrP}s] } 1%,,%,,E22e&&,,e&&  rc V^8dQhRRRR/#)r session_keystrr dictr )r s"r rrs34rc|\V4p\V4p\V4p\VRJ;'dFVPR8H;'d/VRJ;'d#VPR8H;'d \ V44p\ V4p\W$R7p\V4pRVRVRVR\WVV4R\WV4/#) zISerialize persisted session-control state once, without wall-clock churn.Nactive)r>r$loop heartbeatrevisionr) _load_goal_state_load_loop_state_load_heartbeat_stater?r_goal_blocks_loop_tickr-rLrP_snapshot_revision_snapshot_updated_at)rR goal_state loop_stateheartbeat_stater>r$rWrXs& r _snapshot_controlrcs!+.J!+.J+K8O$ 0 0    ) 0 0 d " 0 0    ) 0 0 #; /  z *D z MD(9IY&t9=*:?S  rcV^8dQhRR/#)rr rSr )r s"r rrs A A ArcVf VfVfR#\P!RVRVRV/RR RR7p\P!VP R44P 4#) zHHash canonical visible state so equal reads always have equal revisions.r0r$rWrXFT) ensure_ascii separators sort_keyszutf-8),:)jsondumpshashlibsha256encode hexdigest)r$rWrX canonicals&&& r r^r^s_ | ): vt[)< I >>)**73 4 > > @@rcaa.pVR3VR3VR33F(wopSfK VPVV3RlV44K* V'd \V4#^#)zGUse only persisted timestamps; reads never manufacture a new timestamp.c3V<"TFp\SV^4;o'gKSxK R#5i)N)getattr).0fieldr)values& r '_snapshot_updated_at..s(_WUTY[\E]<]E<]ees) ))rr')rrH)extendmax)r`rarb candidatesfieldsr)rxs&&& @@r r_r_sbJ 34 45 9: v     __ _ )3z?/a/rc^RIHpV!V4#)rt) load_goal)hermes_cli.goalsr)rRrs& r rZrZ* [ !!rc^RIHpV!V4#)rt) load_loop)hermes_cli.loopsr)rRrs& r r[r[rrc^RIHpV!V4#)rt)load_heartbeat)hermes_cli.heartbeatr)rRrs& r r\r\s3 + &&rc V^8dQhRRRR/#)rrRrSr r?r )r s"r rrs....rc^RIHpV!V4#)rt)goal_blocks_loop_tick)rr)rRrs& r r]r]s6  --rc V^8dQhRRRR/#)rr5rTr zthreading.Lockr )r s"r rrs4NrcVPR4pVf?\;_uu_4VPR\P!44pRRR4V#V# +'giT#;i)control_publish_lockN)get_PUBLISH_LOCK_GUARD setdefault threadingLock)r5locks& r _session_publish_lockrsR ;;- .D | %%&NOD! K4K! Ks &A A' only_if_presentFonly_if_changedc ,V^8dQhRRRRRRRRRR /#) rsidrSr5r rr?rr Noner )r s"r rrs9YY3YYZ^Y7;YHLYrc bV'd-\VPR4;'gR4;p'gR#\V4;_uu_4\V4;_uu_4\ V4pRRR4V'dXR,'d'V'd*XR,VPRR48Xd RRR4R#XR,VR&\ RVRV/4RRR4R# +'giL};i +'giR#;i \ d\PRTR R 7R#i;i) uBest-effort ``session.control.update`` for one live session. Also called after the post-turn hooks, because the goal judge and loop tick evaluation mutate persisted state AFTER ``message.complete`` — a client refresh keyed on that event reads the pre-judge turn count. ``only_if_present`` keeps the post-turn event stream of a session with no automation state byte-identical to today's; ``only_if_changed`` (every tool completion) also skips a snapshot equal to the last one published.rRr0NrYcontrol_revisionzsession.control.updatecontrolz,session.control.update publish failed for %sTexc_info) rSrr_session_profile_runtime_scoperc_emit Exceptionloggerdebug)rr5rrrRrs&&$$ r !_publish_session_control_snapshotrs #gkk-.H.N.NB*OO;O Y "7 + +/88+K89 (;(;# (;w{{K]_a?b(b , + +2**=G& ' *C)W1E F, +88, + + Y CSSW XYseD C3 C +C3;C3 C3C31D;C3D C0 +C33 D >DD#D.-D.zsession.control.readc V^8dQhRRRR/#rparamsrTr r )r s"r rrs F F4 FD FrcR\W4wr#V'dV#\VPR4;'gR4pV'g\VRR4#\ VR\ V4/4# \ d3p\PRTRR7\TR R T 24uR p?#R p?ii;i) z>Return the current stable control snapshot for a live session.rRr0session has no stored keyrzsession.control.read failed: %sTrzsession.control.read failed: N) _sess_nowaitrSr_err_okrcrrr)ridrr5errrRexcs&& r _rs ,LG  gkk-066B7K C:;;F3$5k$BCDD F 6d KC!>seDEEFsA)) B&4'B!B&!B&zsession.controlc V^8dQhRRRR/#rr )r s"r rrs1Y1Y41YD1Yrc VPR4p\V\4'dVP4;p'g\ VRR4#VP R4'd\ VRR4#V\ 9d\ VRRV 24#RV9d.VR,p\V\4'g\ VRR4#M/p\WV4wrVV'dV#\W4wrxV'dV#\VPR 4;'gR 4p V 'g\ VR R 4#V\9d7\V,wr\YPR 4;'gR WR7p M \WV4p RV 9dV #\#V 4pT\9d&\+TPR 4;'gR T4\-TRTR\/T 4/4# \\\3d!p \ TR\!Y=44uRp ? #Rp ? ii;i \$d3p \&P)RY=RR7\ TRRT 24uRp ? #Rp ? ii;i)zIRun one allowlisted control action and emit its exact resulting snapshot.actionzaction is requiredz goal.gatez4gate actions are not allowed through session.controlzunknown action: argszargs must be an objectrRr0rr session_id)rnameargNerrorz,session.control snapshot after %s failed: %sTrrz!session.control snapshot failed: rdispatch)r isinstancerSstripr startswith_VALID_ACTIONSrT_validate_action_argsrr_dispatch_command_execute_manager_action RuntimeError ValueError IndexError_manager_error_messagercrrrrr_dispatch_envelope)rr raw_actionrr validatedvalidation_errorr5rrRrr action_resultrrs&& r rrs,H%J j# & &9I9I9K/Kv/KC344 %%CUVV ^#C!1&:;; f~$%%T#;< <&"7T"JI,LG  gkk-066B7K C:;;D ( (+F3ID-cjj>V>\>\Z\cgqM3KSM-J#K0(()&**\*B*H*Hb'R sY5G 5VW XX! *j 1DC5fBCCD J CV[_ `C!B3%HIIJsC+AG, G HH -HH H  I 'II I c V^8dQhRRRR/#)rrrSrrTr )r s"r rrFss$rclVR8XdUVPR4p\V\4'dVP4;p'gR\ VRR43#RV/R3#VR8XdPVPR4p\ V4\ JdR\ VRR43#V^8dR\ VRR 43#RV/R3#/R3#) zGValidate the only actions with input before any manager is constructed. subgoal.addtextNrzsubgoal text is requiredsubgoal.removeindexz subgoal index must be an integerzsubgoal index must be >= 1)rrrSrrr1int)rrrrrs&&& r rrFs xx$$$TZZ\-AT-Ac4)CDD D~t## !!! ;c !c4)KLL L 19c4)EFF F%% t8Orc(V^8dQhRRRRRRRR/#)rrrSrrr rTr )r s"r rrWs( : :# :S :s :t :rc \PR4pVf\VRR4#V!VRVRVRV/4# \d4p\P RY#TR R 7\TRR T 24uRp?#Rp?ii;i) z?Delegate a fixed intent to the existing TUI command dispatcher.zcommand.dispatchNrzcommand.dispatch unavailablerrrz!command.dispatch %s %s failed: %sTrzdispatch failed: )_methodsrrrrr)rrrrhandlerrs&$$$ r rrWsll-.GC=>>:s\:vtUCPQQ : 8$SSW XC!23%899:s7 A5(A0*A50A5c(V^8dQhRRRRRRRR/#rrRrSrrrTr r )r s"r rrcs(:::c::$:rc^VPR4'd \WV4#\W4#)z?Use manager APIs for controls that have no TUI command handler.zsubgoal.)r_execute_subgoal_action_execute_heartbeat_action)rRrrs&&&r rrcs+ $$&{DAA $[ 99rc(V^8dQhRRRRRRRR/#rr )r s"r rrjs( : : :c : :$ :rcz^RIHpV!VR7pVR8XdDVPVR,4pRRRRR \VPP 4 R V 2//#VR 8Xd)VR ,pVP V4pRRRRR V R V 2//#VP4pV'dRT RV^8wdRMR R2MRpRRRRV//#)rt) GoalManagerrrrresultr1execoutputu✓ Added subgoal : rru✓ Removed subgoal u ✓ Cleared z subgoalsr0.zNo subgoals to clear.)rr add_subgoallenr)rremove_subgoalclear_subgoals) rRrrrmanagerrrcountrs &&& r rrjs,[1G ""4<06687I#gmmNdNdJeIffhimhn5opqq !!W %%e,6687KE7RTUYTZ5[\]]  " " $EKP|E7(%1*3"*EQ GVmF vvx8 99rc$V^8dQhRRRRRR/#)rrRrSrr rTr )r s"r rrzs!::3:::rc^RIHpHpV!VR7pVR8Xd+VP4pV'dRVP 2MRpMvVR8Xd>VP 4pV'd#RV!VP 4 RVP 2MR pM2VR 8XdVP4'dR MRpM\R R RV 24#RRRRV//#)rt)HeartbeatManagerformat_intervalrheartbeat.pauseu⏸ Heartbeat paused: zNo heartbeat set.heartbeat.resumeu▶ Heartbeat resumed (every z): zNo heartbeat to resume.heartbeat.clearu✓ Heartbeat cleared.Nrzunknown heartbeat action: rr1rr) rrrpauserAresumerCclearr)rRrrrrr)rs&& r rrzsF+6G "" RRRRRR/pVPW4 RV 2#)rz/subgoalrz/subgoal remove subgoal.clearz/subgoal clearrr)rrprefixess&& r rrs7z+)H ll6* +2cU 33rc V^8dQhRRRR/#)rresponserTr r )r s"r rrs   $ rc VPR4;'g/pRVPR4RVPR4RVPR4RVPR4RVPR4/#)zQKeep the command result's user-visible envelope without adding model-facing data.rr1rnoticemessagedisplayr)rrs& r rrsh \\( # ) )rF 6"&**X&&**X&6::i(6::i(  rcV^8dQhRR/#)rr rr )r s"r rrs000rc2\\4VRR7R#)z8Rebind this module's handlers onto the server namespace.)skipN)r)rglobals)servers&r registerrs 6/r)r$r)r$r)r$r)r$unwait)rWr)rWr)rWstop>rrrrrr>r$rWsubgoalrX)1__conditional_annotations____doc__ __future__rrmrkloggingrr: method_ctxrr _registrymethodprofile_scoped_profile_scoped getLogger__name__rr__annotations__ frozenset_MANAGER_ACTIONSrr-r(rLrPrcr^r_rZr[r\r]_SESSION_CONTROL_SLASHESrrrrrrrrrrrrr)r s@r rs#  4     **   8 $#%#%#%!3/./2BB"J 6 0 A 0" " ' .%%MN nn&YafY>CY, F  F1Y1Yh" :: : :(4 0r