+ jHj0<Rt^RIHt^RIt^RIHt^RIHtHt]P!R4t RRlt R] ] 3/R R llt!R R 4tR#) zAutonomy-loop gateway commands: /goal, /subgoal, /heartbeat, /loop, /refine, /review. Bound onto ``GatewayRunner`` through ``GatewaySlashCommandsMixin``.) annotationsNt) MessageEvent MessageTypez gateway.runcV^8dQhRR/#)returnbool)formats"A/home/ubuntu/.hermes/hermes-agent/gateway/slash_commands_goals.py __annotate__rstcH\V!44# \dR#i;i)F)r Exception)fns&r _quiet_boolrs%BDz s  !!errorscV^8dQhRR/#)rprefixstrr )r s"r rrs((c(rcNV!V!R3# TdpRT RT 23uRp?#Rp?ii;i)z[``(result, None)`` from ``fn(*args)``, or ``(None, ": ")`` on a manager error.Nz: r )rrrargsexcs&&$* r _mgr_callrs;(4y$ (xr#'''(s $$$c]tRt^tRtRRltRRltRRltRR ltR R lt R R lt RRlt RRlt RRlt RtR#)GatewayGoalCommandsMixinzUAutonomy-loop gateway commands: /goal, /subgoal, /heartbeat, /loop, /refine, /review.c V^8dQhRRRR/#reventrr rr )r s"r r%GatewayGoalCommandsMixin.__annotate__!s!! !!rc aaaaaa"^RIHo^RIHoSP S4GRjxL wopSf \ R4#VV3RloVVVVV3RlpSP V4GRjxL pVP'dSPSVP4VP'd*SPSVPRVPR7VP#LL{5i) )dispatch_goal_command)last_user_message_from_dbNgateway.goal.unavailablec<^RIHpSPeV!SSP4RJdR#SPSP4'g \ R4#R#)r#)authorize_local_sourceNTz gateway.goal.gate_add_admin_only)gateway.session_localr(source_resume_caller_is_adminr)r(r selfs r authorize_gateEGatewayGoalCommandsMixin._handle_goal_command..authorize_gate)sN E||',B4,VZ^,^// ==;<<rc r<S!SSP4;'gRSRS!\SRR44R7#)c\V3/VB#Nr)keydefaultvaluess&&,r QGatewayGoalCommandsMixin._handle_goal_command..dispatch..7sa6Fv6Fr session_idN)r-renderlast_user_message)get_command_argsgetattr)r-r$r r%mgrsr dispatch?GatewayGoalCommandsMixin._handle_goal_command..dispatch4s=(U++-33NF";GCW[<\"] rzcommand enqueue)labelkickoff) hermes_cli.goal_commandr$hermes_cli.goalsr%_get_goal_manager_for_eventr_run_in_executor_with_context clear_pending_clear_goal_continuationsprompt_enqueue_goal_turnrAoutput) r,r _session_entryr>resultr-r$r%r=s ff @@@@r _handle_goal_command-GatewayGoalCommandsMixin._handle_goal_command!sA>$($D$DU$KK^ ;/0 0   99(CC      * *5&2F2F G ===  # #E6==@Q[a[i[i # j}};L0Ds-!C#C;C#%C!&C#<-C#*6C#!C#c$V^8dQhRRRRRR/#)rr rverbrr Noner )r s"r rr!Ds&XX|X3X4Xrc VPV4wr4V'dV'dVPWC4R#R#R# \d"p\P RY%4Rp?R#Rp?ii;i)z0goal %s: pending continuation cleanup failed: %sN)_adapter_and_key_for!_clear_goal_pending_continuationsrloggerdebug)r,r rPadapter quick_keyrs&&& r rG2GatewayGoalCommandsMixin._clear_goal_continuationsDsY X!%!:!:5!A G966yJ%w X LLKT W W Xs"<< A(A##A(c ,V^8dQhRRRRRRRRRR /#) rr rtextrr@rAr r rQr )r s"r rr!Ls4;;!;),;8;;FJ; ;rc  ^RIHpV!4;peW&nV'gRVnR#VP V4wrxV'dV'dV'd\ T\ PVPV'd VPMRV'd VPMRV'd VPMRV'*R7p VPWV4R#R#R#R# \d"p \PRY:4Rp ? R#Rp ? ii;i)aqEnqueue *text* as the next turn through the adapter FIFO (the post-turn judge's path). A kickoff keeps the triggering message id / channel prompt / bound skills; a resume continuation carries none. Best-effort: failures only logged. A local ``slash.exec`` returns the turn to the client as its ``send`` directive instead (the client submits it with its own input id). ) active_sinkNz /goal resume)r[ message_typer* message_idchannel_prompt auto_skillinherit_channel_pinzgoal %s failed: %s)gateway.session_command_sinkr]rHdisplayrSrrTEXTr*r_r`ra _enqueue_fiforrUrV) r,r r[r@rAr]sinkrWrXturnrs &&&$$ r rI+GatewayGoalCommandsMixin._enqueue_goal_turnLs =M !D .K-  ;!%!:!:5!A GI#!,!1!1 <<3:u//;B5#7#73:u//,3 ""9G<%.t ; LL-u : : ;s/"C C._watchxs0U\\5..y%,,W6yrstatuspausezgateway.heartbeat.paused)rHzgateway.heartbeat.none_setresumezgateway.heartbeat.no_resumezgateway.heartbeat.resumed)intervalrHzgateway.heartbeat.clearedeveryzevery zgateway.heartbeat.usagez$gateway.heartbeat.interval_too_small) min_secondsz!gateway.heartbeat.prompt_requiredz gateway.heartbeat.invalid_prefixrzgateway.heartbeat.set>offstopclear)hermes_cli.heartbeatrlrmrnr;striplower _get_heartbeat_manager_for_eventrr*_session_key_for_source status_linertrHruinterval_secondsr|_unregister_heartbeat_watchsplitlenrset ValueError)r,r rlrmrnrrrKrqstatehadtokensrvrHerrr=rXsff @@r _handle_heartbeat_command2GatewayGoalCommandsMixin._handle_heartbeat_commandls _^&&(..B557 $($I$I%$PP^ ;45 5BG,,,D00>TX  X Xu(??$ $ G IIKEIN1/ E sTUVrTs s H JJLE}677 H0?5KaKa;bkpkwkwx x , ,))+C00;58101 ]a@\>] ]D!$& !9??  'CK1,<%vayk&:;H"%f+/VAYrF%fQi0H6>8a.*`` copy.Nzgateway.z .unavailablez(gateway.shared.agent_running_retry_later)commandz .nothing_yet)r*rr_running_agents_cached_agent_for)r,r rPrXagents&&& r _idle_cached_agent_or_error4GatewayGoalCommandsMixin._idle_cached_agent_or_errorsCH,,,D00>TX q8D6!>?? ? ,, ,dA&PZ^$__ _&&y1 =dAl&C$DD D%%rc V^8dQhRRRR/#rr )r s"r rr!s>>,>3>rc "VP4;'gRP4pVPVR4wr4p\\ VRR4;'g.4pV'g@V'd8W0P 9d(^RIHpV!WPV4GRjxL pVeV#V'dV#V'g \R4#TPTRR\ VR \449T;'gRR 7T'd\R TR7MRp \RT R7#L \dp \R T R 7uRp ? #Rp ? ii;i5i)uHandle /refine — run the memory/skill review fork on demand, in a daemon thread against a snapshot of the cached AIAgent's conversation (live session and prompt cache untouched).r0refine_session_messagesN)refine_local_sessionzgateway.refine.emptyT skill_managevalid_tool_names)messages_snapshot review_memory review_skillsfocuszgateway.refine.start_failederrorzgateway.refine.focus_suffix)rzgateway.refine.started) focus_suffix) r;r~rlistr<rgateway.session_refinerr*r_spawn_background_reviewrr) r,r r _quick_keyrrsnapshotrlocalrtails && r _handle_refine_command/GatewayGoalCommandsMixin._handle_refine_commands+&&(..B557#'#C#CE8#T 5':DAGGRHJ:=Q=Q+Q D.t\\4HHE  L+, , ?  * *"*$,?QSVSX0YYaeamamim +  @Dq.d;)==I ?2#> > ?sfA%E(E0,EDE/ E9 E,D 2D :EE E+ D=7E8E=EEc V^8dQhRRRR/#rr )r s"r rr!s22,232rc aaa a a a "VP4;'gRP4oVPVR4wo opV'dV#\\ SRR4;'g.4o ^RIHo Ho VVV V V V 3RlpVPV4GRjxL p^R I HpT!TS4#L \dp\T4uRp?#Rp?i\dp\RTR7uRp?#Rp?ii;i5i) uHandle /review — spawn an independent reviewer subagent. The approval session-key contextvar is only bound during agent turns, so bind it explicitly here or the completion event carries no gateway route and never re-enters this chat.r0reviewrN)reset_current_session_keyset_current_session_keyc`<S!S4p^RIHpV!SSS4S!V4# S!T4i;i)r#) start_review)agent.review_enginer)tokenrrrrXrrrs r _dispatchBGatewayGoalCommandsMixin._handle_review_command.._dispatchs3+I6E 1<#E8T:)%0)%0s# -zgateway.review.start_failedr)format_dispatch_note)r;r~rrr<tools.approval_contextrrrErrrrrr) r,r rrrLrrrrrXrrrs && @@@@@@r _handle_review_command/GatewayGoalCommandsMixin._handle_review_commands&&(..B557"&"B"B5("S 5% L':DAGGRH] 1 1 ? ==iHHF =#FD11 I s8O ?2#> > ?srAC2C2*C2B/B-B/C2-B// C/: C C/C2 C/C/ C*$C/%C2*C//C2c V^8dQhRRRR/#rr )r s"r rr!s%@%@<%@C%@rc "VP4;'gRP4pVPV4GRjxL wr4Vf \R4#VP 4'g \R4#V'g$VP 4 RVP 4 2#VPR^4pV^,P4p\V4^8dV^,P4MRpVR8XdqV'g \R4#\VP4^,4p\R TPT\\3R 7wrT ;'g\R YR 7#VR 8XdY\RVP \3R 7wrV 'dV #V 'g \R4#\V ^8Xd RV R7#RV R7#\RVP"V4wrV 'dV #VP$'d \VP$P&4M^p\RWR 7#EL \d\R4u#i;i5i)zHandle /subgoal (mirror of the CLI handler): extra criteria appended to the active goal mid-loop. They modify state read at the next turn boundary, so this is safe while the agent is running.r0Nr&zgateway.subgoal.no_goal removezgateway.subgoal.usage_removezgateway.subgoal.remove_not_intz/subgoal removeryzgateway.subgoal.removed)indexr[r|z/subgoal clearzgateway.subgoal.none_to_clearzgateway.subgoal.cleared_onezgateway.subgoal.cleared_other)countz/subgoalzgateway.subgoal.added)r;r~rDrhas_goalrrender_subgoalsrrrintrrremove_subgoal IndexError RuntimeErrorclear_subgoals add_subgoalrsubgoals) r,r rr=rKrrPrestidxremovedrprevr[s && r _handle_subgoal_command0GatewayGoalCommandsMixin._handle_subgoal_commands&&(..B557$($D$DU$KK ;/0 0||~~./ /oo'(3+>+>+@*AB BD!$ay $'K!Ovay  8 788 ;$**,q/*%!3#5#5sJP\C]LGOO!5SO O 7?!"2C4F4FP\_ID 899dai2lpq qEdlpq qj#//4@  J),c#))$$%(??AL ;9:: ;s[=I H,*I +I >BI  I  H/.-I AI "AI >/I /II II c V^8dQhRRRR/#rr )r s"r rr!s&& &&rc baa"^RIHpHpHoTPR4GRjxL TPPTP4GRjxL p\TRR4;'gRpT'g \R4#T!TR 7o/pTPpTe\TR R4p R \T R 4'd T PM\T ;'gR4/pRF$p \\YR4;'gR4Yz&K& TP!4U U u/uFwrT 'gKYbK pp p T!STP#4;'gRP%4TR 7p T P'R 4;'gRpT P'R4'd)\)TT3Rl4'dT\R4, pT# \d,p\ P RT4\R4uRp?#Rp?ii;iELEL \dRpELi;iuup p i \d/pLi;i5i)uZHandle /loop — recurring in-session wakeups, via ``dispatch_loop_command`` (CLI mirror).) LoopManagerdispatch_loop_commandgoal_blocks_loop_tickzloops module unavailable: %szgateway.loop.unavailableNz loop managerr8r0zgateway.loop.no_sessionr8platformvalue)routerJcreatedc(<S!SP4#r2r)rr=sr r6?GatewayGoalCommandsMixin._handle_loop_command..4s9Ns~~9^rzgateway.loop.goal_defers_note)chat_id chat_type thread_iduser_id user_nameprofile)hermes_cli.loopsrrrrrUrVr_warm_goals_session_dbasync_session_storeget_or_create_sessionr*r<hasattrrritemsr;r~getr)r,r rrr session_entrysidrsrcrr3kvrLrJrr=s&& @@r _handle_loop_command-GatewayGoalCommandsMixin._handle_loop_commands 1 b b)).999 !"&":":"P"PQVQ]Q]"^^Mm\48>>B./ /S)  ,,C"3 B7#wx7Q7QX^^WZ[c[i[igiWjkcC!$WSr%:%@%@b!AEJd*/++-=-$!1-='sU-C-C-E-K-K,R,R,T\abH%++ ::i [1^%_%_ a78 8F E 1 LL7 =/0 0 1 :^ ! M !$> E sH/ GH/G<H/(HG?HH/+ H/6H/ A HAH H-H3H6H/.H/?H/*H/ G9 G4.G9/H/4G99H/?H HH/HH/H H,)H/+H,,H/r N)__name__ __module__ __qualname____firstlineno____doc__rMrGrIrrrrrr__static_attributes__r rr rrs>_!FX;@4ql &>62<%@N&&rr)r __future__rlogging agent.i18nrgateway.platforms.eventrr getLoggerrUrrrrrr rr rsMG#=   = )(lJ-G(XXr