+ jHj)5 hRt^RIHt^RIt^RIt^RIHt]P!]4t .R/O]PO5t Rt RRRRR /R R R R R/RRRR R R R/R//t RRlt]!RR04tRRltRRltRRltR0RRlltRR ltR!R"ltR#R$ltR%R&ltR1R'R(lltR2R)R*lltR+R,ltR-R.ltR#)3aTurn events a local viewer (the classic CLI, TUI, Desktop) reads from the canonical stream. The classic CLI rendered every agent callback in process: the tool-generating line, the kawaii thinking text, reasoning, MoA references, hearts, and every status line the agent printed through ``_print_fn``. On the session authority the agent runs in the gateway, so each of those callbacks is projected as an execution event (generation-fenced through ``TurnRunner._publish_execution``) and only for a local viewer's turn: a messaging route never installs them, so its agent behaves exactly as before. The cached agent is shared across turns. ``wire`` installs the sinks for one turn and returns the previous values; ``restore`` puts them back when the turn's ``run_conversation`` returns. ) annotationsN)local_desktop_ui__desktop_ui_token__ moa.reference moa_indexindex moa_countcount moa.progress moa_refs_done refs_donemoa_refs_total refs_total moa.phase moa_phasephasemoa.aggregatingcV^8dQhRR/#returndict)formats"@/home/ubuntu/.hermes/hermes-agent/gateway/local_viewer_events.py __annotate__r"sc aa\Uu/uFq"\WR4bK ppSPoV3RlVnV3RlpWAnV3RlVnV3RlVn\SRR4pVe7^RIHpV!V^,PPV^,4V4\S4'g\4'd VV3RlVn \P!SV4V\ &V#uupi) zTInstall this turn's local-viewer sinks on ``agent``; returns what ``restore`` needs.Nc@<S!RR\T;'gR4/4#)ztool.generatingnamestr)rpublishs&rwire..&s 73DvsSWS]S][]F_+`rc |<S!RR\VPRR44PRV44/4R#)z agent.printtextsep c38"TFp\V4xK R#5iNr!).0as& r )wire..print_fn..)sH^Y]TUQY]sN)r"getjoin)argskwargsr#s*,rprint_fnwire..print_fn(s4 FJJuc,B(C(H(HH^Y]H^(^_`rc@<S!RR\T;'gR4/4#)zthinking.deltar'r r!)r'r#s&rr$r%,s 73CfcRVR\R\Z\oE^+_rc@<S!RR\T;'gR4/4#)reactionkindr r!)r9r#s&rr$r%-s7:DJJTV?X+Yr_approval_owner)seed_compression_countcf<\S4'dS!RR\T;'gR4/4#R#)zreasoning.deltar'r N)show_reasoningr")r'r#turns&rr$r%5s1ESTXEYEYG%DJJB'@ A c_c cr) _TURN_ATTRSgetattr_publish_executiontool_gen_callback _print_fnthinking_callbackreaction_callbackgateway.session_usager;sessionsr0r=_config_default_launchreasoning_callbackrwire_DESKTOP_UI_TOKEN)r>agentrpreviousr4ownerr;r#sf& @rrJrJ"s=HI[Tge400[HI%%G`EaO_EYE D+T 2E @uQx0044U1X>Fd577$e #3"7"7e"DH  O+JsC/tuiguicV^8dQhRR/#rrboolr)rs"rrr@s = =D =rc\VRR4pVe*V^,PPV^,4MRp\VRR4pVfVfVRJ#^RIHp\ V!4V^,4#)zThe session's ``show_reasoning`` display flag (``config.set``, ``/reasoning show|hide``); unset on an Ink or Desktop launch, its ``display.show_reasoning`` (default on), as main's TUI gateway resolved it.r:Nr=T active_policy)r@rGr0gateway.session_policyrVlaunch_shows_reasoning)r>rNliveflagrVs& rr=r=@sq D+T 2E.3.?58   q *TD 4)4 0D 4<t|4 !-/58 <rjrkrmrrregistryholder turn_agentrprecords &&& r_is_active_session_subagentr|Zs ++m,K k3 ' '{{{=>H WT640.$ GF(666tJ:- K(I  ( ( (++// < >j,FF:V_adKeKe//33I>FT!aah&@&@GATV`&a ) ( ( (sA"E$!E E! cV^8dQhRR/#rrNoner)rs"rrrmsQQDQrc\\VRR4pVe\V^,RR4MRpVe\V\4'gVPW4R#VwrVp\VPP V4RR4p\VRR4p ^RIp V eT MV P4;_uu_4VP V4V8XdVPW4RRR4R#RRR4Ve+\WV4'dVPWbV/R7R#R#R# +'giL@;i)r:N executing event_streamlock)rk execution) r@rqrrArGr0 contextlib nullcontextr|r#) r>rkrjrNrrh session_id generationstreamrrs &&& r_publish_subagentrms  D+T 2E8=8Ia+t4tI }Jy$77  4(-%I: Y''++J7 NF 664 (D!z'='='? ? ? == $ 2  # #J 8  @ ? 2 @9$TTzzRPU @ ?s /)D D+ cV^8dQhRR/#r~r)rs"rrrs 1 1 1rc .\V\4'dGVPR4'd0VR8XdR#^RIHp\ WV!WW4\ V4R74R#VR8Xd!^RIHpVPW!W#V44R#VR8wdV\9dR#^R I H p\ V4'gVR8wdV!V4'gR#VR8XdR \T;'gR 4/pM{VR 8Xd.R \T;'gR 4R \T;'gR 4/pMGVR9d*V'gVR8XdR\T;'gR 4/M/pMR \T;'gR 4/pTP\PV/4P4U U u/uF#wrVPV 4fKWV ,bK% up p 4VR8XdRR0\!V48:gR#VR8XdVPR4'gR#VPW4R#uup p i)a``subagent.*``, ``reasoning.available`` and the MoA facade events from the agent's progress callback; a classic CLI renders MoA references whatever its reasoning display (main's ``_on_tool_progress``), while other viewers get them only with reasoning shown.z subagent.z subagent.textN)_subagent_payload)r=z tool.progress)tool_progress_payloadzreasoning.available)classic_cli_turnr'r rlabelrr aggregatorr r rr)rr)rqr" startswithtui_gateway.tool_progressrrr=agent.tool_progress_relayrrA _MOA_KEYSgateway.session_cli_turnrupdater0itemsset) r>rkrpreviewr3rrrrjkeyouts &&&&& rpublish_progressrs*c""z'<'<['I'I  ( ?$,= gnT>R-T U_$C  ,A$QW,XY**z/J9 4 Z3H%HM]^bMcMc**3w}}"-.  &C OVSB5GH 7 759ZK\=\<TZZR1bdC O, NNY]]:r5R5X5X5Z45Zzz#%C$5Z45^#[,,G3w<,W[ W)=)=J0 4s H . H c V^8dQhRRRR/#)rrM dict | Nonerrr)rs"rrrs$$[$T$rcV'gR#VP\R4pVe\P!V4VP 4Fwr4\ WV4K R#r+)poprKrreleasersetattr)rLrMtokenrvalues&& rrestorersJ  LL*D 1E   '~~' U#(rcV^8dQhRR/#r~r)rs"rrrs G G Grcvaaa^RIHoVPwoopVVV3RlpVPV!4R4R#)aAgent thread, after each tool: a tool (a plugin adding goal criteria, parking the goal) can move automation state mid-turn, so viewers' cards repaint now instead of at turn end. The snapshot is read, compared and published on the gateway loop, in order with the slash commands' publishes (a snapshot read here could land after a newer one); revision-gated, so other tools publish nothing.)r#c&<"S!SSRR7R#5i)T)only_if_changedNr)rh canonical_idr#sr republish-publish_control_if_changed..republishs <>sz#session.control.update after a toolN)gateway.session_control_actionsr#r: _schedule)r> _generationrrhrr#s& @@@rpublish_control_if_changedrs0 8+/+?+?(I|[?NN9; EFrcV^8dQhRR/#r~r)rs"rrrsNNNrc\T;'gR4p\P!4VPP R/4V&VfR#^RIHpT!T\V\4'dTM/VPPR7pVe!W`PP R /4V&R#R# \d\PRTRR7RpLMi;i) aMonotonic start time of one call (``tool.complete.duration_s``) and, for a write-capable tool, the before-state of its local files: the agent fires the start callback BEFORE the tool writes, so the gateway owns the snapshot the classic CLI used to take in process.r _local_tool_startsN)capture_local_edit_snapshot)task_idz#Edit snapshot capture failed for %sTexc_info_local_edit_snapshots)r"time monotonic__dict__ setdefault agent.displayrrqrrnr Exceptionloggerdebug)r>call_id tool_namer2rrsnapshots&&&& rnote_tool_startrs gmm C>Bnn>NDMM126s;=.y*TSWBXBX$^`7;yy7K7KM EM   !8"=cB  :IPT Us=B22%CCcV^8dQhRR/#rr)rs"rrrsdrcr\T;'gR4pVPPR/4PVR4pRVe\P !4V, MR/pVfV#TPPR/4PVR4p.p ^RIHp T !Y$\V\4'dTM/WPR7V 'dR PV 4MRVR &\W$4p V eVP!V 4V# \d\PRTR R 7.p Lgi;i) z``duration_s``, ``inline_diff`` (the rendered edit diff main's CLI printed after a write, ``None`` when there is none) and, for the todo tool, the full ``todos`` snapshot.r rN duration_sr)render_edit_diff_with_delta) function_argsrr4zEdit diff preview failed for %sTr inline_diff)r"rrrrrrrrqrappendrrrr1 todo_stater) r>rrr2resultrstartedfieldsrrenderedrtodos &&&&& rcomplete_fieldsrs gmm Cmm&&';R@DDS$OGGr9rrsecondsrs&& rprompt_timeout_srsP < T " " z@+-.=)+,k7+t+r)rBrCrDrErI)r )NN)NNN)__doc__ __future__rloggingrgatewayr getLogger__name__rCALLBACK_ATTRSr?rKrrJ frozensetr_r=rHrXr|rrrrrrrrrrrrs # $   8 $1 //1 + {G['J o{