|+jV+UddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlmZddlmZddlmZmZddlmZmZmZmZddlmZddlmZddlm Z m!Z!m"Z"m#Z#m$Z$ej%e&Z'eZ(ee(ee)j*j*d z e j+,e(d d Z-d Z.e.e _/dZ0e0e _/ ddl1m2Z2e2n #e3$rYnwxYwddl4m5Z5m6Z6m7Z7iZ8e9e:e9fe;d<iZe9e:e?e:e j@ffe;d<iZAe9e:e?e:e9ffe;d<iZBe9e:e:fe;d<daCdaDe:dze;d<e jEZFe jEZGe jHZIe jEZJdaKe9dze;d<daLeMdze;d<daNe jEZO eMe jPQdpdZRn#eSeTf$rdZRYnwxYweUdeRZV eMe jPQdpdZWn#eSeTf$rdZWYnwxYweUd eWZXd!ZYeZhd"Z[eZhd#Z\ eUd$e]e jPQd%pd&Z^n#eSeTf$rd'Z^YnwxYwej_`e^d()Zaejbd*e jcZde jee _cGd+d,Zfe d-eFZgefZhGd.d/Zid0e:fd1Zjd2e:d3e:dzd0dfd4Zkd5d6d7e:d8e:d9e:d0e?ee:dzffd:Zld;e9dzd0dfd<Zmdd;e9dzd>e:d0dfd?Znd=d@d;e9dzd>e:d0dfdAZodBe:d;e9d0dfdCZpd=d@dBe:d>e:d0eqfdDZrd;e9dzd0eqfdEZsdBe:d0dfdFZtdGd@d>e:d0e?e]e]ffdHZuddIZv eMe jPQdJpdKZwn#eTeSf$reMdKZwYnwxYweUd ewZwdLZxd0eqfdMZydBe:d;e9dNeMd0eqfdOZzddPZ{ddQZ|ejbeve|dRZ}dSe]fdTZ~dUe:dzd0edzfdVZhdWZdXedzd0e:dzfdYZdZe9d0eqfd[Zd d\e:dBe:d]e9dzfd^Zd dBe:d_e:d`e:dzfdaZdbe]dce]d0e]fddZdeed0e9fdfZdge9d0e9fdhZdSe]die:d0e9fdjZdke:fdlZdmed0e?ee:e9fe9zfdnZdme9d0e9dzfdoZd dme9dpee!d0e9dzfdqZd!d;e9dse:dteMd0e9dzfduZdBe:d;e9d0dfdvZdwZdxZdye:d0e:fdzZd d{e9dzd0e:fd|Zd;e9dzd0e:fd}Zd~e:d0e:fdZd;e9dzd0e:fdZd;e9dzd0dfdZd;e9d0dfdZejd;e9fdZd;e9d~e:d0e:fdZdZe?e:dfe;d<dZd0e9fdZde9fdZd7e:d0e:fdZd d7e:d~e:dzd0efdZded0dfdZddZd"d\e:dBe:d]e9dte]d0e:f dZd dBe:dzd0dfdZd0e9fdZd0e:fdZd0e?e:e:dzffdZde9dzd0e9fdZd de9dzd0e9fdZd;e9dzd0dfdZde:fdZeZhdZd0e:fdZiddddddddddddddddddddddddddddddddZde9d0e:fdZd0e9dzfdZd0e:dzfdZd0eqfdZd0e:fdZd0ee:dzfdZdBe:d0e:fdZdBe:d0eqfdZdBe:d0eqfdZdBe:d;e9fdZddZdddBe:d;e9de:deqd0e9f dZ d#d;e9de:dzde]dzdedzde]dzd0e?e]e9ff dńZdddǜdBe:d;e9deqdeqd0df dʄZd0e9fd˄Zd0e:fd̄Zde9d0e:fd̈́Zd0e:fd΄Zd$Zd d;e9dzd0e9fdτZdke:de9d0e:fdфZdZdZd`e:d0e:fdԄZd`e:d0e:fdՄZde9d0e:fdքZdged0e:fdׄZdeMdzd0e:fdلZdZedee:d0e]dzfdڄZdke:dge:deMdzd0e:dzfd܄ZdBe:de:dke:de9fdބZdBe:de:dke:de9dge:f d߄Z d$dBe:d2e:dke:dzde:dzde9dzf dZdBe:d0e9fdZdBe:fdZd0e:fdZԐd de9dzd0e9fdZՐd de:de9dzd0e?e:e:ffdZd0e:fdZ d%dBe:d;e9de:de:d0e?eqe9dzff dZde9de]d0e]fdZd0ee:fdZdZdZde:d0e9fdZde:d0e9fdZސd&d;e9de]de]d0ee9fdZdke:dge:d0e:fdZde:de:d0e9fdZdBe:d;e9d0e9fdZ d'dBe:de:d3e:dzde9e:zdzde:dzde9dzde:dzfdZd(dBe:de:dede]fdZd0e:fd Zd Zd~e:d e:d0e:fd Zd e:dee:d0e:fdZded0e:fdZded0e:fdZdee9d0ee9fdZded0ee9fdZded0e:fdZded0e:fdZd;e9d`ed0dfdZd;e9ded0dfdZd;e9d0dfdZd;e9d0e9dzfdZedd{e9d0e9fdZedd{e9d0e9fdZed d{e9d0e9fd!Zed"d{e9d0e9fd#Zed$d{e9d0e9fd%ZdBe:d0e:fd&ZdBe:d;e9d0e:fd'Zded0e:fd(Zd;e9de:d0e:fd)Zd%dBe:d;e9d*e:d0e9fd+Zd7e:d0e?e:e9fdzfd,Zd;e9d0e9fd-Zdddd.dBe:d;e9de]dzd/eqdpe!dzd0e9f d0Zed1d{e9d0e9fd2Zed3d{e9d0e9fd4Zed5d{e9d0e9fd6Zed7d{e9d0e9fd8Zed9d{e9d0e9fd:Zed;d{e9d0e9fd<Zed=d{e9d0e9fd>Zed?d{e9d0e9fd@ZedAd{e9d0e9fdBZedCd{e9d0e9fdDZedEd{e9d0e9fdFZedGd{e9d0e9fdHZedId{e9d0e9fdJZedKd{e9d0e9fdLZedMd{e9d0e9fdNZedOd{e9d0e9fdPZedQd{e9d0e9fdRZedSd{e9d0e9fdTZedUd{e9d0e9fdVZdWZd3e:fdXZdYZdZe9d0dfd[Zd0ee9fd\Zed]d{e9d0e9fd^Zed_d{e9d0e9fd`Zedad{e9d0e9fdbZedcd{e9d0e9fddZeded{e9d0e9fdfZedgd{e9d0e9fdhZd;e9die9d0eqfdjZdie9d0e?fdkZdle j@dBe:d;e9d0dfdmZdBe:d;e9d0e j@fdnZdBe:d;e9d`ed0dfdoZedpd{e9d0e9fdqZedrd{e9d0e9fdsZdtZduZdvZdwZe?e?e e:fdfe;dx<dye:dze:d0e dzfd{Z d%d|e d}e:d0e:fd~Z d0eZe:fdZ d;e9d|e de:de:d0ef dZ edd{e9d0e9fdZedd{e9d0e9fdZdade:d0e:fdZd;e9ded0e:fdZd;e9d0efdZdke:d0e:fdZded}e:d0efdZdye:d0edzfdZde:d0e fdZd;e9de:de:dke:d0e?eeqff dZedd{e9d0e9fdZedd{e9d0e9fdZedd{e9d0e9fdZedd{e9d0e9fdZedd{e9d0e9fdZdZedd{e9d0e9fdZedd{e9d0e9fdZedd{e9d0e9fdZedd{e9d0e9fdZedd{e9d0e9fdZedd{e9d0e9fdZedd{e9d0e9fdZedd{e9d0e9fdZedd{e9d0e9fdZedd{e9d0e9fdZedd{e9d0e9fdZedd{e9d0e9fdZeZhdZeZe:e;d<gdZee?e:e:e:fe;d<eZhdZeZe:e;d<eZddhZeZe:e;d<edd{e9d0e9fdZdee:d0e:dzfd„Zedæd{e9d0e9fdĄZedŦd{e9d0e9fdƄZdke:d0e:fdDŽZedȦd{e9d0e9fdɄZdaedʦd{e9d0e9fd˄ZdZd̐Z eZhdͣZ!e jEZ"iZ#e9e:e?eMee:ffe;d<de:d0ee:fdτZ$dke:de:d0e?e]e]fdzfdфZ%edҦd{e9d0e9fdӄZd%de:de:d0e9fdՄZ&de:de:deqd0e9fdׄZ'd`e:d0ee9dzfd؄Z(ed٦d{e9d0e9fdڄZedۦd{e9d0e9fd܄Zedݦd{e9d0e9fdބZedߦd{e9d0e9fdZdBe:d;e9de:d0e:fdZ)edd{e9d0e9fdZe jEZ*da+e:e;d<d d\e:d]e9dzd0dfdZ,d0eqfdZ-d0eqfdZ.d0e9fdZ/d0e:fdZ0edd{e9d0e9fdZedd{e9d0e9fdZedd{e9d0e9fdZedd{e9d0e9fdZedd{e9d0e9fdZedd{e9d0e9fdZedd{e9d0e9fdZd0e:fdZ1d0eqfdZ2de:dteMd0eqfdZ3d0ee:fdZ4d0e:fdZ5de:de]de:d0ee:fdZ6edd{e9d0e9fdZd{e9d0e9fdZ7d0e9fdZ8edd{e9d0e9fdZedd{e9d0e9fd Zed d{e9d0e9fd Zed d{e9d0e9fd Zedd{e9d0e9fdZedd{e9d0e9fdZedd{e9d0e9fdZedd{e9d0e9fdZedd{e9d0e9fdZedd{e9d0e9fdZedd{e9d0e9fdZedd{e9d0e9fdZdS()NdatetimePath)AnyOptional)get_hermes_homeget_hermes_home_overridereset_hermes_home_overrideset_hermes_home_override)load_hermes_dotenv)is_truthy_value)StdioTransport Transportbind_transportcurrent_transportreset_transportz.env) hermes_home project_envlogsztui_gateway_crash.logcddl}d||||} tjtjtdttdd5}| dtj d d | |dddn #1swxYwYn#t$rYnwxYwt|r9t|dn|j}t#d |jd |t$jd t%j|||dS)NrTexist_okautf-8encodingu === unhandled exception · %Y-%m-%d %H:%M:%S === z[gateway-crash] : fileflush) tracebackjoinformat_exceptionosmakedirspathdirname _CRASH_LOGopenwritetimestrftime Exceptionstrstrip splitlines__name__printsysstderr__excepthook__)exc_type exc_valueexc_tbr%traceffirsts 1/usr/local/lib/hermes-agent/tui_gateway/server.py _panic_hookrA8s GGI..xFKK L LE  BGOOJ//$???? *cG 4 4 4  GGZ >Q0R0RZZZ    GGENNN                       y>>   ! ! I))++A..    9X. 9 9% 9 9 RVWWWWxF33333s7AC?AC  C CCCC C%$C%c^ddl}d||j|j|j} t jt j tdttdd5}| dtjd d |jjd | |dddn #1swxYwYn#t"$rYnwxYwt%|jr>t%|jdn |jj}t-d |jjd |jjd|t.jddS)NrrTrrrru === thread exception · ru · thread=r z[gateway-crash] thread z raised r!r")r%r&r'r:r; exc_tracebackr(r)r*r+r,r-r.r/r0threadnamer1r2r3r4r5r6r7r8)argsr%r=r> first_lines r@_thread_panic_hookrHUs GG""4=$.$BTUU  E   BGOOJ//$???? *cG 4 4 4  GG6T];N-O-O66![-666    GGENNN                       t~   $ $ & & $DN!!##..0033 ] #  b$+"2bbDMhiddenexpanded collapsed> cli.exec shell.exec slash.exec skills.managebrowser.manageplugins.managesession.branchsession.resumesession.compressHERMES_TUI_RPC_POOL_WORKERS4ztui-rpc) max_workersthread_name_prefixc:tddS)NFT)waitcancel_futures)_poolshutdownr@rxsE$GGrwc*eZdZdZdedefdZddZdS)_DropTransportzGDetached WS sink: keep sessions resumable without writing stale frames.objreturncdSNFrv)selfr{s r@r.z_DropTransport.writesurwNcdSNrv)rs r@closez_DropTransport.closestrwr|N)r5 __module__ __qualname____doc__dictboolr.rrvrwr@rzrzsPQQ$rwrzctSr) _real_stdoutrvrwr@rxrxs,rwcDeZdZdZdedefdZdZdZdedefd Zd Z d S) _SlashWorkerz3Persistent HermesCLI subprocess for slash commands. session_keymodelc Ptj|_d|_g|_t j|_tj ddd|g}|r|d|gz }d|_ tj |tj tj tj ddtjtj |_tj|jd tj|jd dS) Nr-mztui_gateway.slash_workerz --session-keyz--modelFT)stdinstdoutr8textbufsizecwdenvtargetdaemon) threadingLock_lock_seq stderr_tailqueueQueue stdout_queuer7 executable_closed subprocessPopenPIPEr(getcwdenvironcopyprocThread _drain_stdoutstart _drain_stderr)rrrargvs r@__init__z_SlashWorker.__init__s^%%  &(6;kmm N  &      ' Y& &D $ /??  !!       24@@@FFHHH 24@@@FFHHHHHrwc|jjpgD]D} |jt j|0#tj$rYAwxYw|jddSr)rrrputjsonloadsJSONDecodeError)rlines r@rz_SlashWorker._drain_stdoutsI$*  D !%%dj&6&67777'     d#####s,?AAc|jjpgD]1}|dx}r|j|gzdd|_2dS)N i)rr8rstripr)rrrs r@rz_SlashWorker._drain_stderrs_I$* E ED{{4(((t E$($4v$=stt#D  E Erwcommandr|c |jtd|j5|xjdz c_|j}|jjtj||ddz|jj  |j t}n"#tj$rtdwxYw|n| d|krb| d s#t| d d t| d d cdddStd|jr2dt%d|jddznd #1swxYwYdS)Nzslash worker exitedr)idrrTtimeoutzslash worker timed outrokerrorzslash worker failedoutputrzslash worker closed piper! i)rpoll RuntimeErrorrrrr.rdumpsr$rget_SLASH_WORKER_TIMEOUT_SrEmptyr2rrchrr&)rrridmsgs r@runz_SlashWorker.runs  9>>   '455 5 Z   IINII)C IO ! !$*CG-L-L"M"MPT"T U U U IO ! ! # # # ;A+//8O/PPCC{AAA&'?@@@A;774==C''wwt}}P&swww8M'N'NOOO3778R001188::#        &sY]Yi+q4#b'',,t?OPRPSPS?T2U2U+U+Uoqss '          s2A.G C?GCB G8A GG Gct|ddrdSd|_|j} |x| |dnL#t $r?| |dn#t $rYnwxYwYnwxYwnL#t $r? ||dn#t $rYnwxYwYnwxYw|j|j |j fD]'} | #t $rY$wxYwdS#|j|j |j fD]'} | #t $rY$wxYwwxYw)NrFTrr) getattrrrr terminaterrr1killrrr8r)rrstreams r@rz_SlashWorker.close.s 4E * *  F y yy{{"   IIaI(((( IIKKK ! ,,,,$        ! $$$$       :t{DK@  LLNNNN D  4:t{DK@  LLNNNN D s(B0 A#"B0#B,BB, B&#B,%B&&B,)B0+B,,B0/D:0 C9;*C&%C9& C30C92C33C96D:8C99D:D(( D54D5:E8E'&E8' E4 1E83E4 4E8N) r5rrrr2rrrrrrvrwr@rrs==ICIIIII<$$$EEE 336rwrr|ctd}t|tsi}t |ddpd}|dvr|ndS)Ndisplaybusy_input_moder>rsteer interruptr) _load_cfgr isinstancerr2r3lowerrraws r@_load_busy_input_moderLs|kkooi((G gt $ $ gkk+R006B 7 7 = = ? ? E E G GC88833kIrw event_type session_idcR ddlm}|||ddS#t$rYdSwxYw)z-Fire session lifecycle hooks with CLI parity.r) invoke_hooktui)rplatformN)hermes_cli.pluginsrr1)rr _invoke_hooks r@_notify_session_boundaryrTsX BBBBBB ZJGGGGGG      s  &&r)surfacerlive_session_idrc ddlm}|||td|iS#t$r&}td|Yd}~dSd}~wwxYw)Nr)try_acquire_active_sessionr)rrconfigmetadataz'Failed to claim active session slot: %sNN)hermes_cli.active_sessionsrrr1loggerwarning)rrrrexcs r@_claim_active_session_slotr^s IIIIII))";;'9     @#FFFzzzzzs"% AAAsessionc|sdS|dd}|dS |dS#t$r tddYdSwxYw)Nactive_session_leasez%Failed to release active session slotTexc_info)popreleaser1rdebug)rleases r@_release_active_session_slotrrs  KK. 5 5E }M  MMM |5t|dg}dddn #1swxYwYn#t|dg}|9|r7t |dr' ||n#t $rYnwxYw|d }t|d dp|}td ||r8 t}|| ||n#t $rYnwxYw |d } | r| dSdS#t $rYdSwxYw) z8Best-effort finalize hook + memory commit for a session. _finalizedNT _notif_stopagent history_lockhistorycommit_memory_sessionrron_session_finalize slash_worker) rrsetlisthasattrrr1rr_get_db end_sessionr) rr stop_eventrlockrrrdbworkers r@_finalize_sessionr~s[ gkk,// GL )))]++J KK E ;;~ & &D   7 77;;y"5566G 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7w{{9b1122 W8O)P)P   ' ' 0 0 0 0    D ++m,,K d33B{J2J???  B~z:666    D  ^,,   LLNNNNN        sH$B77B;>B;;D DD&F FF+G GGrcF|sdSt|| ddlm}|dx}r ||n#t$rYnwxYw |d}|&t |dr|dSdSdS#t$rYdSwxYw)aFully tear down a session: finalize, unregister, close agent + worker. Shared by ``session.close`` and the orphaned-WS-session reaper. The slash-worker subprocess is closed inside ``_finalize_session`` (the single finalize chokepoint); this still unregisters the approval notifier and closes the in-process agent. Idempotent: the ``_finalized`` guard in ``_finalize_session`` and the ``poll()`` guard in ``_SlashWorker.close`` make repeat calls harmless. Nrrunregister_gateway_notifyrrr)rtools.approvalrrr1r r)rrrkeyrs r@_teardown_sessionrs g*5555 <<<<<<++m,, ,3 + % %c * * *        G$$  !8!8  KKMMMMM          s#(A A  A ;B B B sidct5t||ur||d< ddddS dddn #1swxYwY|dS)uStore worker on session iff sid still maps to it, else close it — a concurrent teardown already popped the session and would orphan the worker. Closes the create/close race at every slash-worker spawn site.rN)_sessions_lockrMrr)rrrs r@_attach_workerrs  ==   ( (&,GN #  ( LLNNNNNs#AA  A ct5t|d}dddn #1swxYwY|dSt||dS)axSingle idempotent teardown for one session: pop it under the sessions lock, then finalize, unregister notify, close agent + slash worker via the shared ``_teardown_session`` path. Returns True iff it closed a live session. The ``_finalized`` / worker ``_closed`` guards make concurrent or repeat calls (e.g. session.close racing the WS-orphan reaper) harmless.NFrT)rrMrr)rrrs r@_close_session_by_idrs ++--T**+++++++++++++++ug*5555 4s 044c|r|drdS|drdS|dtuS)aTrue if a WS session has no live transport and no in-flight turn. After ``handle_ws`` detaches a disconnected client it points the session at ``_detached_ws_transport``. A session left on that transport (and not mid-turn) is genuinely orphaned and safe to reap. rFrunning transport)r_detached_ws_transportrs r@_ws_session_is_orphanedr$sU gkk,//u{{9u ;;{ # #'= ==rwctdkrdSdfd }tjt|}d|_|dS)a+After a grace window, reap session ``sid`` iff it's still orphaned. Called from the WS-disconnect path. The grace window lets a transient reconnect (or a ``session.resume`` that reattaches the transport) cancel the reap by re-binding a live transport. Disabled when the grace is 0. rNr|ct5tts ddddSt dddddS#1swxYwYdS)Nws_orphan_reapr)_session_resume_lockr$rMrrrsr@_reapz'_schedule_ws_orphan_reap.._reaps" C C*9==+=+=>>  C C C C C C C C !1A B B B B C C C C C C C C C C C C C C C C C Cs)AAA!$A!Tr)_WS_ORPHAN_REAP_GRACE_SrTimerrr)rr*timers` r@_schedule_ws_orphan_reapr.se!## C C C C C C O3U ; ;EEL KKMMMMMrw ws_disconnectcbt5fdtD}dddn #1swxYwYd}d}|D]`\}}|drt |||dz }1t |d<|dz } t |Q#t$rY]wxYw||fS)uOn transport disconnect, reap the sessions that opted into close_on_disconnect (sidecar/dashboard) immediately via the unified ``_close_session_by_id`` path, and re-point the rest back to stdio so later emits don't hit a dead socket. Non-flagged detached sessions are handed to the grace-windowed WS-orphan reaper (``_schedule_ws_orphan_reap``): a quick reconnect / session.resume that re-binds a live transport cancels the reap, otherwise the orphan is torn down through the same idempotent ``_teardown_session`` path. This is the single WS-disconnect teardown entry point — there is no second independent reap loop in ``handle_ws``. Returns ``(reaped, detached)`` counts for disconnect-path observability.cLg|] \}}|du||f!Sr!r).0rsr!s r@ z1_close_sessions_for_transport..,s8]]]fc1QUU;=O=OS\=\=\#q=\=\=\rwNrclose_on_disconnectrrr!)rrMitemsrrr"r.r1)r!rownedreapeddetachedrrs` r@_close_sessions_for_transportr<s: ^^]]]] (9(9]]]^^^^^^^^^^^^^^^ FH   W ;;, - -   < < < < aKFF $:GK MH (----     8 s&;?? B B*)B*ct5tt}dddn #1swxYwY|D]}t|ddS)N tui_shutdownr)rr rMr)sidsrs r@_shutdown_sessionsr@@s I==S^<<<<<==s )--HERMES_TUI_SESSION_TTL_Si`Tgr@c>|turdSt|ddduS)NTr)r"rr2s r@_transport_is_deadrCRs, ***t 9i . .$ 66rwnowc|dst|rdS|d}||sdSt|dsdSt |dpd}t |dpd}||z t ko ||z t kS)Nr F agent_readyr! last_activerY created_at)r_session_pending_kindis_setrCfloat_SESSION_TTL_S)rrrDreadyrGrHs r@_session_is_evictablerN\s{{9!6s!;!;u KK & &E u gkk+66 7 7u M229c::Kw{{<007C88J +  / WS:5E4WWrwctjt5fdtD}dddn #1swxYwY|D]}t |ddS)Nc<g|]\}}t|||Srv)rN)r4rr5rDs r@r6z'_reap_idle_sessions..ls2]]]63:OPSUVX[:\:\]3]]]rw idle_timeoutr)r/rrMr8r)victimsrrDs @r@_reap_idle_sessionsrSis )++C ^^]]]]Y__%6%6]]]^^^^^^^^^^^^^^^==S^<<<<<==s&AAAc\d}tj|ddS)Ncx tjt tn#t$rYnwxYw:r)r/sleep_REAPER_SCAN_SrSr1rvrwr@_loopz!_start_idle_reaper.._looprsP  J~ & & & #%%%%      s + 88Tr)rrr)rXs r@_start_idle_reaperrYqs;E$///5577777rwctVddlm} |adanB#t$r5}t |at d|Yd}~dSd}~wwxYwtS)Nr SessionDBuJTUI session store unavailable — continuing without state.db features: %s)_db hermes_stater\rRr1r2rr)r\rs r@r r s {****** )++CII   CI NN\   44444   Js  A*AAcodec<tpd}t||d|S)Nzstate.db unavailablezstate.db unavailable: )rR_err)rr_details r@_db_unavailable_errorrcs(  00F Trauto. profile_homect|dS ddl}t|dz }|sdSt|d5}||pi}dddn #1swxYwYt |dpidpd}|r |tvrdStj tj |}tj |r|ndS#t$rYdSwxYw) aResolve a non-launch profile's ``terminal.cwd`` from its own config.yaml. The desktop's app-global remote mode serves every profile from one backend, so the process-global ``TERMINAL_CWD`` belongs to the *launch* profile. A new session bound to another profile must take its workspace from THAT profile's config, not the stale env var (issue #40334). Returns an absolute, existing directory, or None for placeholders / missing / invalid paths. Nr config.yamlrrterminalrr)yamlrrlr- safe_loadr2rr3_CWD_PLACEHOLDERSr(r*abspath expanduserisdirr1)rrrvpr>datarresolveds r@_profile_configured_cwdrsvt    .xxzz 4 !g & & & +!>>!$$*D + + + + + + + + + + + + + + +488J''-222599?R@@FFHH c...47??27#5#5c#:#:;;7==22.dec s rwrv)rErs` r@rrs# Jrwreqc~t|tstdddS|d}|d}t|tr|st|ddS|di}|i}n&t|tst|dd S|||fS) z;Validate a JSON-RPC request enough for safe local dispatch.Niz#invalid request: expected an objectrrz2invalid request: method must be a non-empty stringriz"invalid params: expected an object)rrrarr2)rrrrs r@_normalize_requestr's c4 ID&"GHHH ''$--C WWX  F fc " "W&WC!UVVV WWXr " "F ~  % %GC!EFFF  rwct|}t|tr|S|\}}}t|}|st |dd|S|||S)Nizunknown method: )rrrrNrra)r normalizedrrrrs r@handle_requestr:sw#C((J*d##$C f  B >C!#t$r1}tddd|}Yd}~nd}~wwxYw||dSdS)Nrizhandler error: )rr1rarr.)resprrrs r@rzdispatch..run`s L%c** L L LCGGDMM63JS3J3JKK L  s A'A  Ac.Sr)r)ctxrsr@rxzdispatch..hsSWWS\\rwN) rrrrrr_LONG_HANDLERSr contextvars copy_contextrtsubmit) rr!tokenr_ridr_paramsrrrs ` @@@r@dispatchrFs  %%A 1  E',, j$ ' ' * '!+fg  ' '!#&&" &((        )))))***s%C C 7C C>@rrc|d}|'||st|ddS|d}|rt|d|ndS)NrFrzagent initialization timed out agent_error)rrrra)rrrrMerrs r@ _wait_agentrosl KK & &E G!._build..se,>T&J&JrwT)seed_credits_at_session_startron_session_resetconfig_warning session.inforrrzagent init failed: r)!rrMrr_set_session_contextr r^r\rr1 _make_agent_clear_session_contextrr_resolve_modelrrrr_wire_callbacksagent.credits_trackerr_start_notification_pollerr _session_info_probe_config_healthrrrrr2r r)currentrnotify_registered home_tokenrrtokensrr\rrrrinfocfg_warnereplacedrrrMrs r@_buildz"_start_agent_build.._builds  ) )mmC((G ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ? IIKKK F! {{>22 R )#..FJ &5lCC &666666!*4 3E3E 3R!S!S!SJJ &&&!%JJJ& /#CDDD&v....&v.... %GG  %c75'>CSCS+T+TUUsGV4444      ('JJJJ%)!((****     C  OOOOOO--e4444     d d)##4NsT]^aTb4c4cIcN=1 d d d d d d d d d d d d d d d %%7 = = = 00D+IKK88H ))1%&x((( .#t , , , , H H H%(VVGM " '3,E!,E,E F G G G G G G G G H%*:666  = =$==--W< = = = = = = = = = = = = = = = - HHHHHH--c2222 D IIKKKKK%*:666  = =$==--W< = = = = = = = = = = = = = = = - HHHHHH--c2222 D IIKKKKsu044/"I7"B54I75 CI7CI7C*I7*C;;I72 I7>HI7HA0I76L?7 J3(J.)L?.J33L?K77K;>K;L L&%L&?ON5 ON ON ON#"O# N0-O/N00Orr)r setdefaultrrrJrr)rrrrrrMs` @@r@_start_agent_buildrws^ KK & &E }   0).2B2B C CD .. <<>> W[[)>??  ........*.%&............... - C]]]]]]]]~F40006688888s+B>BBBct|dpd}|r|dfndt|ddfS)Nrrsession not found)rMrra)rrr5s r@ _sess_nowaitrsI fjj..4"55A KAt99d36I&J&JKKrwct||\}}|rd|fSt|dpd||t||fS)Nrr)rrrr)rrr5rs r@_sessrs] &# & &FAs c{vzz,//52q999 {1c"" ##rw path_partcjtj|}tjdkr|dd}t |dkrZ|ddkrN|ddkrB|dr(d |dd|ddS|S) Nnt\/r:rkrz/mnt/)r(r*rzrEreplacelenisalphar)rr`rs r@_normalize_completion_pathrsw!!),,H w$%%dC00  OOq 1 $$1 $$1 %%''%D:a=..00CC:abb>CC C Orwrc|pi}|dpt|dpdidp`tt|dp1tjdpt j} tjtj t|}tj |r|Sn#t$rYnwxYwt jS)Nrrrrd TERMINAL_CWD) rrMrror(rrr*ryrzr2r{r1)rrr~s r@_completion_cwdrs \rF 5  ==L117R < < @ @ G G  #=I1F1F#G#G H H   :>>. ) )   9;; 7??27#5#5c#hh#?#?@@ 7== " " O       9;;s?A)D** D76D7c4tjdpd}|r|dkrtjdd}|s t di}t |tr6t|dpd}n#t$rd}YnwxYw|r|dvr|St|S)aReturn the cwd that terminal_tool should use for this TUI session. ``_completion_cwd`` validates paths on the host so file completion does not point at nonsense. Non-local terminal backends are different: their cwd is inside the target environment, so an SSH path like /home/user/workspace may not exist on the local macOS host but is still the correct execution cwd. TERMINAL_ENVrlocalrrur>rrprq) r(rrr3rrrrr2r1 _session_cwd)rbackendr terminal_cfgs r@_terminal_task_cwdrsz~~n--3::<<BBDDG 7g%%jnn^R006688  ({{z2>> lD11El..u55;<<BBDDC      3222J   sA-C11 D?Drch tjdd|ddgddddtj}|jd kr|j}|r|Stjdd|d d d gddddtj}|jd kr|jnd S#t $rYd SwxYw)Ngit-Cbranchz--show-currentTg?F)capture_outputrrcheckrr rev-parsez--shortHEADr)rrDEVNULL returncoderr3r1)rrr heads r@_git_branch_for_cwdr4s D#x)9 :$       ! !]((**F  ~ D#{Iv >$    '+o&:&:t{  """B rrsAB#AB## B10B1cv|r*|drt|dStS)Nr)rr2rr#s r@rrOs;#7;;u%%#75>"""   rwc|sdS ddlm}||ddt|idS#t$rYdSwxYw)Nrregister_task_env_overridesrr)tools.terminal_toolrrr1)rrs r@_register_session_cwdrUs  CCCCCC## M "U,>w,G,G$H           s '/ ==c|d}|sdS|d}|rTddlm} |t|dz }n-#t$r t dd YdSwxYwd }nt}d }|dS ||d t|d rt|ndn,#t$rt dd YnwxYw|r( | dS#t$rYdSwxYwdS#|r& | w#t$rYwwxYwwxYw)u Idempotently persist the session's DB row on first real activity. Called from prompt.submit so a row only exists once the user actually sends a message — abandoned drafts never leave an empty "Untitled" session behind. Uses INSERT OR IGNORE under the hood, so re-calls (and the AIAgent's own lazy create) are no-ops. Only an *explicitly chosen* workspace is persisted as the session's cwd. The agent still runs in the auto-detected directory (session["cwd"]), but we don't stamp that onto the row — otherwise every session the user never picked a folder for gets grouped under whatever directory the desktop happened to launch in (e.g. "desktop"). Leaving it null groups them under "No workspace", which is the desired default. rNrrrr[rgrz)failed to open profile db for session rowTrFr explicit_cwd)sourcerrz%failed to persist desktop session row) rr^r\rr1rrr create_sessionrrr)rrrrr\rclose_dbs r@_ensure_session_db_rowrbs ++m $ $C ;;~..L ****** 4 #5#5 #BCCCBB    LLDtL T T T FF  YY z   "")0^)D)DN W%%%$     MMM A?A C$#D<$&D  D< D  D<D)) D76D7<E&EE& E"E&!E""E&c#HKd\}}|d}|rRddlm} |t|dz d}}n:#t$rt dd YnwxYwt} |V|rJ|Jtj t5| d d d d S#1swxYwYd Sd Sd S#|rH|Gtj t5| d d d w#1swxYwYwwwxYw) aUYield the SessionDB that owns this session's row (profile-aware). Mirrors :func:`_ensure_session_db_row`: a remote/profile session persists into its own profile's ``state.db`` (a fresh handle we close on exit); everything else borrows the shared ``_get_db()`` handle (left open). Yields None when the db is unavailable. r~rrrr[rgrTz%failed to open profile db for sessionrN) rr^r\rr1rrr  contextlibsuppressr)rrrrrr\s r@ _session_dbr!sLB;;~..L****** Q$9T,-?-?*-LMMMtBB Q Q Q LL@4L P P P P P QYY  $Y//                       8 $Y//                    sSA&A.-A.C!CC CD!2D D!D D!D D!cNtjtjt |}tj|st d|||d<d|d<t|t}|X | | dd|n,#t$rt ddYnwxYw d d lm}||dn#t$rYnwxYw|S) N"working directory does not exist: rTrrrzfailed to persist session cwdrr) cleanup_vm)r(r*ryrzr2r{ ValueErrorrr update_session_cwdrr1rrrr$)rrr~rr$s r@_set_session_cwdr'sGwrw11#c((;;<r}s r@rrsI  ,--%h44SSxx| JJ &%&XXZZ9!!T  1 1%**=*=)q..}Z00 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 88:: a'*** /a~~a((.B / / / / / / / / / / / / / / /D   t,,JJI                     IsA:E&<6C 2 E&? E& CE&C(E&;D E&D##E&&D#' E&4E E&EE& E!E&& E32E3cfgchddl}tdz }t|dd5}|||dddn #1swxYwYt5t j|a|a | j a n#t$rda YnwxYwddddS#1swxYwYdS)Nrrtwrr) rvrkr- safe_dumpr0rr2rSr1r.r/rTr1)r5rvr*r>s r@ _save_cfgr9sIKKK - 'D dC' * * *a sA ]3''   -JJ   JJJ  sGAA AB'.BB' BB'BB''B+.B+c6|sdSt5ttD]M}|d|kr2t |dpdccdddSN dddn #1swxYwYdS)zReverse-map session_key to the session's logical cwd. Snapshots ``_sessions`` first: concurrent RPC handlers mutate it from the thread pool, so iterating the live view risks ``RuntimeError: dictionary changed size during iteration``. rrrN)rr rMvaluesrr2)rsesss r@_cwd_for_session_keyr=s r 22))++,, 2 2Dxx &&+55488E??0b1111222222225 2222222222222222 2sA'BBBBct ddlm}||nt|}|||S#t$rgcYSwxYw)Nr)set_session_vars)rr)gateway.session_contextr?r=r1)rrr?r~s r@rrsk <<<<<< /33/CK/P/PKXFFFF  s %( 77rcT|sdS ddlm}||dS#t$rYdSwxYw)Nr)clear_session_vars)r@rBr1)rrBs r@rr"s_  >>>>>>6"""""      s  ''c`dtjd<dtjd<dtjd<dS)zARoute approvals through gateway callbacks instead of CLI input().1HERMES_GATEWAY_SESSIONHERMES_EXEC_ASKHERMES_INTERACTIVEN)r(rrvrwr@_enable_gateway_promptsrH-s/+.BJ'($'BJ !'*BJ#$$$rw,c"tjjdd}tj}t 5||ft |<||d<|t|ft|<dddn #1swxYwY t|||| |t 5t |dt |ddddn #1swxYwYnZ#t 5t |dt |ddddw#1swxYwYwxYwt 5t |dcdddS#1swxYwYdS)N request_idrr) uuiduuid4hexrEvent _prompt_lockrOrrPrrrrrQ)rrrrrevs r@_blockrS7si *,, 2A2 C   B ??b  # ).W (> %???????????????4 eS'"""     4 4 LLd # # # $ ( (d 3 3 3 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4\ 4 4 LLd # # # $ ( (d 3 3 3 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 %%||C$$%%%%%%%%%%%%%%%%%%se+A22A69A6>'C;,7C//C36C3;E7E: EE E E EFF Fct5ttD].\}\}}|||krdt|<|/ ddddS#1swxYwYdS)u|Release pending prompts with an empty answer. When *sid* is provided, only prompts owned by that session are released — critical for session.interrupt, which must not collaterally cancel clarify/sudo/secret prompts on unrelated sessions sharing the same tui_gateway process. When *sid* is None, every pending prompt is released (used during shutdown). Nr)rQr rOr8rQr)rr owner_sidrRs r@_clear_pendingrVIs $()9)9$:$:   C)R{i3.. "  sAA,,A03A0c  ddlm}m}|t|}|j|j|j|j|j|j |jpi dddS#t$ricYSwxYw)Nr)init_skin_from_configget_active_skin help_headerr)rEcolorsbranding banner_logo banner_hero tool_prefixrZ) hermes_cli.skin_enginerXrYrrEr[r\r]r^r_rr1)rXrYskins r@ resolve_skinrb\sQQQQQQQQikk***  Ik +++ M/R44]BGG     sA+A.. A=<A=ctjddptjdd}|r|St dd}t |t r7t|ddpdSt |tr|r|SdS)N HERMES_MODELrHERMES_INFERENCE_MODELrdefaultzanthropic/claude-sonnet-4)r(rrr3rrrr2)rms r@rros ~r** 8 :>>2B 7 7 egg   $$A!T7155B''-2..44666!Sawwyy & &rwc4t}tjdd}|r||fStjddptjdd}|s|dfS ddlm}tdpi}t|trHt|dpd ndpEtjd d pd }|||}|r |\}}||fSn#t$rYnwxYw|dfS) NHERMES_TUI_PROVIDERrrdrer) detect_static_provider_for_modelrproviderHERMES_INFERENCE_PROVIDERrp) rr(rrr3hermes_cli.modelsrjrrrr2rr1) rexplicit_providerexplicit_modelrjr5current_providerdetectedrkdetected_models r@_resolve_startup_runtimers~s   E '>2B 7 7 egg d{ FFFFFFkkoog&&,"c4((CGGJ''-2..4466<<>>>  z~~92>>DDFFLLNN    43NDTUU  ,'/ $Hn!8+ + ,      $;s C$F FFrowc|siS|d}i}t|tr|}nt|trm|rY t j|}t|tr|}n,#t$rt ddYnwxYwi}t|dp|dpd}t|dp+|dp|dpd}t|d pd}t|d pd}|d } t|d pd} |r||pd |pd |pd d|d<|r||d<t| tr| |d<| r| |d<|S)aReturn runtime fields persisted with a stored session. ``session.resume`` is a session-scoped operation: reopening an older chat must restore the model/provider/reasoning state that chat actually used, not whatever global model the user most recently selected in another chat. The durable session row stores the model directly, the billing provider in ``billing_provider``, and richer runtime knobs in JSON ``model_config``. model_configz+failed to parse stored session model_configTrrrrkbilling_providerbase_urlapi_modereasoning_config service_tierN)rrkrxrymodel_overrideprovider_overridereasoning_config_overrideservice_tier_override) rrrr2r3rrr1rr) rt raw_configrvparsed overridesrrkrxryrzr{s r@!_stored_session_runtime_overridesrs  ((JL*d##W! J $ $W)9)9););W WZ ++F&$'' &%  W W W LLFQUL V V V V V WI   CL$4$4W$=$=C D D J J L LE$$    . / /  77% & &     egg  <##J//5266<<>>H<##J//5266<<>>H#''(:;;|''77=2>>DDFFL   (D (D (D ' ' "# 2)1 %&"D))B1A -.:-9 )* s+B &B32B3existingc.t|pi}tt|ddpd}tt|ddpd}tt|ddpd}tt|ddpd}t|dd}t|dd}|r||d<|r||d<|r||d<n|dd|r||d<n|ddt |tr||d<n|dd|r||d<n|dd|S)Nrrrkrxryrzr{)rr2rr3rr) rrrrrkrxryrzr{s r@_runtime_model_configrs (.b ! !F w++1r 2 2 8 8 : :E75*b117R88>>@@H75*b117R88>>@@H75*b117R88>>@@Hu&8$??5.$77L  w&%z%%z :t$$$%%z :t$$$"D))-%5!"" %t,,,)!-~ >4((( Mrwc|sdS|d}t|dpd}||sdSt|ddp t }|dS ||pi}|d}i}t |tr|}nTt |tr?|r+tj |}t |tr|}t||}tt|ddpd} t|dr-| |tj || pddS| r(t|d r||| dSdSdS#t$r t d d YdSwxYw) zIPersist active session runtime so future resumes restore the same footer.Nrrrr!rvrupdate_session_metaupdate_session_modelz&failed to persist live session runtimeTr)rr2r3rr  get_sessionrrrrrr rrrr1rr) rrrrrtrexisting_configrrvrs r@_persist_live_session_runtimers  KK Egkk-006B77==??K }K}  t , , 9 B zNnn[))/RWW^,,  j$ ' ' )(OO  C ( ( )Z-=-=-?-? )Z ++F&$'' )"(,UODD GE7B//5266<<>> 2, - - 8  " "; <0H0H%-SW X X X X X  8wr#9:: 8  # #K 7 7 7 7 7 8 8 8 8 NNN = MMMMMMNs:DG(G&G+*G+key_pathct}|}|d}|ddD];}||vs(t||tsi||<||}<|||d<t |dS)Nrq)rsplitrrrr9)rvaluer5rkeysrs r@_write_config_keyrs ++CG >>#  DCRCy g  Z C0@0@$%G%G GCL#,GDH cNNNNNrw>offtopbottomc|durdSt|tr1|x}tvr|SdS)NFrr)rr2r3r_STATUSBAR_MODES)rr5s r@_coerce_statusbarr-sP e||u#sciikk&7&7&9&9!9>N N N 5rw0rrDallanybuttonbuttonsclickfalsefullnoonscrollwheeltrueyesrct|tsdSd|vr|d}n|dd}|dus|dkrdS|dus|dSt|ttfrdSt|t r?t |dSdS)uResolve display.mouse_tracking to one of ``off|wheel|buttons|all``. Boolean values keep their legacy meaning (``True`` → ``all``, ``False`` → ``off``). The ``wheel`` preset (DEC 1000+1006) is the tmux-friendly subset — wheel + click only, no hover events to trigger prompt-row clipboard probes. Legacy ``tui_mouse`` is honored only when ``mouse_tracking`` is absent. rmouse_tracking tui_mouseTFrr) rrrrrKr2_MOUSE_TRACKING_ALIASESr3rrs r@_display_mouse_trackingrIs gt $ $u7""kk*++kk+t,, e||saxxu d{{cku#U|$$u#sG&**399;;+<+<+>+>FFF 5rwcddlm}ttdpiddpd}||S)Nrparse_reasoning_effortrreasoning_effortr)hermes_constantsrr2rrr3)refforts r@_load_reasoning_configrcsp777777   ! ! 'R,,-?DDJ egg  " !& ) ))rwcttdpiddpd}|r|dvrdS|dvrdSdS)Nrr{r>rnonenormalrfstandard>rfastpriorityr)r2rrr3r)rs r@_load_service_tierrls~ Y[[__W % % + 0 0 D D JKK   #IIIt (((z 4rwcttdpiddS)Nrshow_reasoningF)rrrrvrwr@_load_show_reasoningrys6 ++1r667GOO P PPrwctjdd}|dvr|St dpidd}|durdS|d urdSt |pd}|dvr|ndS) NHERMES_TUI_TOOL_PROGRESSr>rnewrverboser tool_progressrFrT)r(rrr3rrr2)rrmodes r@_load_tool_progress_moder}s *..3R 8 8 > > @ @ F F H HC ... ;;??9 % % + 0 0% H HC e||u d{{u s|e   " " $ $ * * , ,D;;;44Frwc~dtjdddD}d}d}|s( ddlm}|d}||Sn#t $rYnwxYw dd lmn#t $rdYnwxYw|rfd |Dfd |D}|rW dd l m }|fd |Dn#t $rgYnwxYwr# fd|D}tdDrBd|D}|r2tdd|tjddS|sSt#t# ddlm}ddlm} |} t-| dt.r| dni} | D]\} } t-| t.s| | dddr#t5| _t5| n,#t $rt#t#YnwxYwfd|D}fd|D}fd|D}|z}|r2tdd|tjd|r2tdd|tjd|r|Sd} dd lm}dd!lm}||n |}t;||d"d#}|t|tjd|pdS#t $r"|td$tjdYdSwxYw)%Nc^g|]*}||+Srv)r3r4items r@r6z*_load_enabled_toolsets..s>  ::<< rwHERMES_TUI_TOOLSETSr,r)coding_selectionr)r)validate_toolsetc*g|]}| |Srvrvr4rErs r@r6z*_load_enabled_toolsets..s*HHHT1A1A$1G1GHDHHHrwcg|]}|v| Srvrv)r4rEbuilt_ins r@r6z*_load_enabled_toolsets..s#HHHt4x3G3Gd3G3G3Grw)discover_pluginsc*g|]}| |Srvrvrs r@r6z*_load_enabled_toolsets..s+VVV?O?OPT?U?UVVVVrwcg|]}|v| Srvrv)r4rE plugin_valids r@r6z*_load_enabled_toolsets..s#VVVtT=U=Ud=U=U=Urwc3K|]}|dvV dS)>*rNrvr4rEs r@ z)_load_enabled_toolsets..s'99t|#999999rwcg|]}|dv| S)>rrrvrs r@r6z*_load_enabled_toolsets..s"MMMD 4L4Lt4L4L4LrwzR[tui] HERMES_TUI_TOOLSETS=all enables every toolset; ignoring additional entries: , Tr"read_raw_config)_parse_enabled_flag mcp_serversenabled)rfcg|]}|v| Srvrv)r4rE mcp_namess r@r6z*_load_enabled_toolsets..s#FFFdDI4E4ET4E4E4Erwcg|]}|v| Srvrv)r4rE mcp_disableds r@r6z*_load_enabled_toolsets..s#HHHT4<3G3GD3G3G3Grwc$g|] }|v|v | Srvrv)r4rErrs r@r6z*_load_enabled_toolsets..s8   9$$\)A)A )A)A)Arwz4[tui] ignoring unknown HERMES_TUI_TOOLSETS entries: zf[tui] ignoring disabled MCP servers in HERMES_TUI_TOOLSETS (set enabled: true in config.yaml to use): zI[tui] no valid HERMES_TUI_TOOLSETS entries; using configured CLI toolsets load_config)_get_platform_toolscliinclude_default_mcp_serverszq[tui] no valid HERMES_TUI_TOOLSETS entries and configured CLI toolsets could not be loaded; enabling all toolsets)r(rrragent.coding_contextrr1toolsetsrrrextendrr6r&r7r8rhermes_cli.configrhermes_cli.tools_configrrrr8addr2rrsorted)explicitr5fallback_noticer selection unresolvedrignoredrrraw_cfgrrE server_cfg mcp_validdisabledunknownvalidrrrrrrrrs @@@@@r@_load_enabled_toolsetsrsJNN#8"==CCCHHH CO   = = = = = =((%888I$  %    D  -------     S $0HHHHXHHHHHHHxHHH  W "??????  """VVVVVVV  " " "!  " W ---VVVVzVVV 99999 9 9 MMMMMG I48IIg4F4FII  4 O!ee !$  ! 9 9 9 9 9 9 C C C C C C%o''Ggkk-88$?? M***  %0$5$5$7$7 0 0 j!*d33&&z~~i'F'FPTUUU0MM#d)),,,, $$SYY////  0 ! ! !I55LLL !GFFFjFFF HHHHZHHH     "    9$   [tyyQXGYGY[[Z       )99X&&))Z       L X 111111??????_cc++--  U M M M    & / $ ? ? ? ?$   & DZ     tts\ A!! A.-A.2A99 BB0C CCC+I..&JJ9AN(N<;N<c~tt|iddpdS)Ntool_progress_moder)r2rMrr)s r@_session_tool_progress_moders4 y}}S"%%))*>FFO% P PPrwc(t|dkS)Nrrr)s r@_session_verbosers &s + +y 88rwc(t|dkS)Nrrr)s r@_tool_progress_enabledr!s &s + +u 44rwc Z|d}|r& |n#t$rYnwxYw t|dt |ddt }n#t$r d|d<YdSwxYwt |||dS)Nrrrr)rrr1rrrr)rrr new_workers r@_restart_slash_workerr%s [[ ( (F   LLNNNN    D ! M " GKK(('>3C3C D D   "&3,,,,,s. ;;ABBBcddlm}t}|d}t |t si}||d<|j|d<|j|d<|jr |j|d<n| dd||dS)Nr) save_configrrfrkrx) rr rrrr new_modeltarget_providerrxr)rr r5 model_cfgs r@_persist_model_switchr;s------ ++C  I i & &!  G !+Ii"2Ij ( & * j$'''KrwFconfirm_expensive_model raw_inputrc ddlm}m}ddlm}||\}}} } |st d|d} | rMt| ddpd} t| ddpd} t| d dpd}t| d dpd}n|d }t|ddpd} t} t|d dpd}|d d}t|rt|ts|}nt|pd}d}d} dd l m }m}|}|d }||}n#t$rYnwxYw||| | ||| ||| }|jst |jpd|s_ ddlm}||j|j|jp||jp||j}n#t$rd}YnwxYw||j|jd|jdS| rq| |j|j|j|j|jt7||t9|t;d|t=| |t|t>r$|j|j|j|j|jd|d<| rtA||j|j!pdddS)Nr)parse_model_flags switch_modelresolve_runtime_providermodel value requiredrrkrrrxapi_key requested)get_compatible_custom_providersr providers) rrp current_modelcurrent_base_urlcurrent_api_key is_globalrnuser_providerscustom_providerszmodel switch failed)expensive_model_warning)rkrxr model_infoT)rrconfirm_requiredconfirm_message)r  new_providerrrxryr)rrkrxrryr|F)rrr%)"hermes_cli.model_switchrrhermes_cli.runtime_providerrr%rrr2rcallablerrrrr1success error_messagehermes_cli.model_cost_guardr#r r rxrr$rryrrrrrrwarning_message)rrrrrrr model_inputrnpersist_global_force_refreshrrprrrruntime _runtime_key user_provs custom_provsrrr5rr#rs r@_apply_model_switchr6MsHGGGGGGGDDDDDDEVEVW`EaEaBK"NN 1/000 KK E 6"5*b99?Rw339r "5*b99?R!%B77=2**T:::w{{:r::@bAA&(( w{{:r::@bAA {{9b11 L ! ! 6*\3*G*G 6*OO!,"4"55OJL RRRRRRRRkmmWW[)) 66s;;      \)#)' +!%   F >H-F1FGGG "  K K K K K K-- /<,<9/!, GG   GGG   )"?$(#*?   B &/N__     c7+++%g... nc=#@#@AAA'4   %.~ % %  !&f%%%!)/R!  s$ 2E>> F  F 3G66 HH focus_topic approx_tokensbefore_messageshistory_versionc0ddlm}|d}||f|d5t|dg}t |dd}dddn #1swxYwY|}t |dkrt |}d|fS|4t|dd pd } t|d dpd} ||| | }||d||pd \} } |d5t |dd|krt |}d|fcdddS| |d<|d z|d<dddn #1swxYwYt |}t |t | z |fS)Nrestimate_request_tokens_roughrrrr:rn_cached_system_promptrr\ system_promptr\)r8r7r) agent.model_metadatar=r rrr _get_usager_compress_context) rr7r8r9r:r=rrusage _sys_prompt_tools compressed_s r@_compress_session_historyrIsCBBBBB G E /"9 ^ $ E E"7;;y"#=#=>>O!'++.?"C"CDDO E E E E E E E E E E E E E E EG 7||a5!!%xe%.9sU#5sDAArw pending_title) rrrrNrOrPrrr1r) rrrKrLrnew_session_idold_keyrNrOrPrr yolo_was_ons ` r@ _sync_session_key_after_compressrVsW0 KK EUL$77=2Nkk-,,2G ^w66#0                % %g . . . .    D !/  11'::KK   KKK   ##N333$$W----      # #AAAA        D  000"0  0 (#'   !#w / / / / /    DD s C( A('C(( A52C(4A55C(> B C( BC(BC(B65C(6 CC(CC(CC( C$!C(#C$$C((C:9C:D D'&D'c $d&fd }tddpd|dd|dd|d|d |d |d|d|d |d d }tdd}|rt|ddp |dpd}t|ddpd}|r>||d<||d<tdtdt||z dz|d<t|ddpd|d< ddlm}m}||d||d|d|d|dtddtd d!}|j|d"<|jt|j|d#<n#t$rYnwxYwttj d$r: } | t!| |d%<n#t$rYnwxYw|S)'NcPt|dp|rt|dndS)Nrr)kfbrs r@rxz_get_usage..Ms/75!Q//WR4VGE2q4I4I4IUVrwrrsession_input_tokenssession_prompt_tokenssession_output_tokenssession_completion_tokenssession_cache_read_tokenssession_cache_write_tokenssession_reasoning_tokenssession_total_tokenssession_api_calls) rinputr cache_read cache_write reasoningprompt completiontotalcallscontext_compressorlast_prompt_tokensrrkcontext_length context_used context_maxdcontext_percentcompression_count compressions)CanonicalUsageestimate_usage_costrerrfrg) input_tokens output_tokenscache_read_tokenscache_write_tokensrkrx)rkrx cost_statuscost_usdHERMES_DEV_CREDITSdev_credits_spent_microsr)rrminroundagent.usage_pricingrvrwr amount_usdrKr1rr(rrget_credits_spent_microsr) rgrDcompctx_usedctx_maxrvrwcostspents ` r@rBrBLsWWWWWA,,2)+BCC!+-HIIa344q566Q122!+,,a344)**&''  E 5. 5 5D K4!5q99PU7^Pq$ 0!449  Y$,E. !#*E- '*1c#uX=ORU=U7V7V.W.W'X'XE# $ '.A1 E E Jn KKKKKKKK"" 'N N"7^#Ho"' "5#(#7     UJ55UJ55     ${m ? & %do 6 6E*       rz~~&:;;<< 2244E 47JJ01    D  Ls%BF F'&F'(H H  H c t|ddpd}t|ddpd}|r|dkrd|dSn#t$rYnwxYwdS)uELight credential check at session creation — returns warning or ''.rrrkno-key-requiredz$No API key configured for provider 'z'. First message will fail.)rr1)rrrks r@_probe_credentialsrs eY++1r5*b117R `c..._(___ _/      2s37 AAct|tsdSg}td|D}|sn8dd|D}|d|d|d}|d}t|trt|d dpd }|rC|d vr?t|tr*|d |d d|S)utFlag bare YAML keys (`agent:` with no value → None) that silently drop nested settings. Returns warning or ''.rc3$K|] \}}||V dSrrvr4rZvs r@rz'_probe_config_health..s&>>TQAIqIIII>>rwrc3"K|] }d|dV dS`Nrv)r4rZs r@rz'_probe_config_health..s*55aQ555555rwz"config.yaml has empty section(s): uZ. Remove the line(s) or set them to `{}` — empty sections silently drop nested settings.rr personality>rrfneutral personalitiesNzj`display.personality` is set but `agent.personalities` is empty/null; personality overlay will be skipped. ) rrrr8r&appendrr2r3r)r5warnings null_keysr display_cfg agent_cfgrs r@rrs} c4 rH>>SYY[[>>>>>I   yy55955555 = = = =   '')$$K  I+t$$ +//-<<BCCIIKKQQSS  #AAA9d++B o..6 OO7    88H   # # % %%rwcJ ddlm}|pdS#t$rYdSwxYw)Nrget_active_profile_namerf)hermes_cli.profilesrr1rs r@_current_profile_namersO??????&&((5I5 yys  ""c:|7tD]}|d|ur|}nt|}t dpidpd}|pid|}t |dd}d}t |tr<|ddur%t|ddpd}t |d dpd}d} d d l m } m } m } |pid } | rt| | nd}t| p|p | d k} n#t$rd} YnwxYwidt |dddt |ddd|d |d|dkd| didid|dt|dt|pddt|piddt ddddddddt#|t%d} d dlm}m}||d<||d<n#t$rYnwxYw d d lm}t |dgpgD]J}|d!d"}|d||pd#g|Kn#t$rYnwxYw d d$lm}||d<n#t$rYnwxYw d d%lm}||d&<n#t$rg|d&<YnwxYw t |d'dpd|d(<n#t$rYnwxYw d d)lm}d d*lm }|d+,|d<||d<n#t$rYnwxYwtC|}|r||d-<|S).NrrrrrzrFrr{r)_YOLO_MODE_FROZEN_get_approval_moderPrrrrkrrryolor\skillsrr r desktop_contractversion release_date update_behindupdate_command)rD profile_name) __version____release_date__)get_toolset_for_toolfunctionrEotherget_available_skills)get_mcp_statusrr>r@)get_update_result)recommended_update_command?rcredential_warning)"rMr;rrrrrrr2rrrrPrr1rDESKTOP_BACKEND_CONTRACTrBrrhrr model_toolsrrrhermes_cli.bannerrtools.mcp_toolrrrrr)rr candidatercfg_personalityrrzrr{rrrrPr session_yolorrrrrrErrrrwarns r@rrs"))++  I}}W%%..#/ w  C!  228b==mLLRPRO=b%%m_EEKu&8$??#T**I   + +5 8 8/33HbAAGRHH5.$77=2L D           }"))-88 EP[t33K@@AAAV[ %&&W,W:L:L:N:NRW:W ,,GE:r22 ,    *     " s %c** s;,"-- 4B++I6677 4 2  !" "#$E""-//'D* <<<<<<<<%Y/^        444444,,2  AZ=(D M $ $%9%9$%?%?%J7B O O V V            ::::::--//X      !111111,n..] !!! ]! '/F K K Qr_       777777@@@@@@ 1 1# > > >_!;!;!=!=       e $ $D *%) !" KsAE00 E?>E?;I IIA$K KKK)) K65K6:LL L $L;; MM (M55 NNrFcR ddlm}|||dpdS#t$rYdSwxYw)Nr)build_tool_previewP)max_lenr) agent.displayrr1)rErFrs r@ _tool_ctxr( sX444444!!$b999?R? rrs  &&ct|tkr |dtkr|St|}d}t tD](}|dd|}|dkrd}n|dz})|}t |t|tz }||kr;|d|}d|cxkrt|dz krnn|dz}||d}t dt|t|z }|d|d}|r d|d|d} nd|d} | |S)Nrrrz[showing verbose tail; omitted z lines / z chars] ) r_TUI_VERBOSE_TEXT_MAX_CHARScount_TUI_VERBOSE_TEXT_MAX_LINESrangerfindrfindlstrip) ridxrrH line_start next_breaktail omitted_chars omitted_lineslabels r@_cap_tui_verbose_textr< s D 000 JJt  : : : d))C E . / /jjq#&& 77E EaJ  CII(CC D DE zYYtU++ * * * *SYY] * * * * *NE <   D3t99s4yy011M%L&&t,,MK @ @ @'4 @ @ @  K-JJJ T  rwc ddlm}|t|d}n#t$rYdSwxYwt |S)Nr)redact_sensitive_textT)forcer) agent.redactrr2r1r)rrredacteds r@_redact_tui_verbose_textr` sf666666((T$??? rr  * **s # 11c tj|piddt}n!#t$rt|pi}YnwxYwt |S)NrkF)indent ensure_asciirf)rrr2r1r)rFrs r@_tool_args_textrj sajAE3OOO $*"oo #C ( ((s"AAc ddlm}||}n#t$rt|}YnwxYwt |S)Nr)_multimodal_text_summary)agent.tool_dispatch_helpersrr1r2r)rrrs r@_tool_result_textrr scHHHHHH&&v.. &kk #C ( ((s 00secondsc|dS|dkr|ddS|dkrt|dSttt|d\}}|r|d|dn|dS)Nrrz.1fr5<zm rg)rdivmodr)rminssecss r@_fmt_tool_durationr| sr||     ||..####E'NN++R00JD$!% 5d  d    d:::5rwc|}|D]/}t|tsdS||}0t|trt |ndSr)rrrr r)r{r*currs r@ _count_listr s_ C#t$$ 44ggcll!#t,, 63s888$6rw duration_sc tj|}n#t$rd}YnwxYwt|}|rd|nd}d}|dkr9t |t r$t |dd}|d|d|dkrd nd }nN|d krHt |t r3t |d pt |dd }|d |d|dkrdnd}t |t rS|dr>t|dpd }|r||S|r||ndS)N in r web_searchr}webzDid rrsearchsearches web_extractresultsz Extracted pagepagesfallback_warning) rrr1rrrrrr2r3) rErrr}dursuffixrnrs r@ _tool_summaryr sz&!!  Z ( (C (\C\\\bF D | 4 6 6 fe , , =B!BB!q&&hhjBBD   :dD#9#9  i ( ( PKfi,P,P =CCCa1ffFF'CCD$($((+=">">(dhh1228b99??AA  ('v'' ' $ .d F   $.s  && tool_call_idct|}|i ddlm}|||}|||di|<n#t $rYnwxYwt j|di|<t|rL||t||d}t|rt|}|r||d<td||dSdS)Nr)capture_local_edit_snapshotedit_snapshotstool_started_at)tool_idrEcontext args_textz tool.start) rMrrrrr1r/rrrrr) rrrErFrrsnapshotrr s r@_on_tool_startr  s)mmC  G  A A A A A A224>>H#IQ""#3R88F    D BF)++,b11,?c"" *# t,,   C  1'--I 1'0 $ lC))))) * *s-A AAc|||d}t|}d}d}|T|di|d}|di|d}|rt j|z nd} | | |d< t j||d<n#t$r||d<YnwxYwt||| } | r| |d<t|rt|} | r| |d<|dkr{ t j|} t| tr@t| d tr| d |d <n#t$rYnwxYw d d lm} g}| |||||j rd ||d<n#t$rYnwxYwt%|s|drt'd||dSdS)N)rrErFrrrrsummary result_texttodotodosr)render_edit_diff_with_delta) function_argsr print_fnr inline_diffz tool.complete)rMrrrr/rrr1rrrrrr rrrr&rr)rrrErFrrrr  started_atrr rr}rrendereds r@_on_tool_completer s&dCCGmmC  GHJ%%&6;;?? dSS''(92>>BB. s"G"G"Ga3q66"G"G"Grw)rxryreasoning_tokens api_callsr} files_readc,g|]}t|Srvr#r4r|s r@r6z%_on_tool_progress..2 s$K$K$KSVV$K$K$Krw files_writtenc,g|]}t|Srvr#r)s r@r6z%_on_tool_progress..4 s'Q'Q'Q1A'Q'Q'Qrw output_tail tool_namerr duration_secondsz subagent.tool tool_preview) rr2rr startswithrr TypeErrorr%rKr ) rrrErr_kwargsrint_keyvals r@_on_tool_progressr5 sY "# & &^### ***w*&,c'll%; C  &!%GI  #S'222[))9( F++1r22gkk,77<1==gkk,77<1==   ;;} % % A%()?%@%@GM " ;;{ # # =#&w{';#<#$>GL ! ;;z " " H"G"G7:3F"G"G"GGJ   G ++g&&C'*3xxGG$$!:.D ;;z " " . &+GJ,?&@&@ ##z*     ;;| $ $ L$K$KW\5J$K$K$KGL ! ;; ' ' R'Q'Q8P'Q'Q'QGO $ ;;} % % B%)'-*@%A%AGM "  -#&t99GK  +!'llGFO ;;x  7 #GH$5 6 6GH  ;;y ! ! 9!$WY%7!8!8GI  ;;) * * 6*/8J0K*L*LG& '  +z_44&)'llGN #!'llGFO j#w'''''s9(9(s$HH,+H,II32I3c hfdfdd fd fdfdfddfd fdfd fd dfd d S)Nc(t|||Sr)r )tc_idrErFrs r@rxz_agent_cbs..I s d: : rwc*t||||Sr)r)r8rErFrrs r@rxz_agent_cbs..L sDU dFE E rwc&t||||fi|Sr)r5)rrErrFkwargsrs r@rxz_agent_cbs..O s.ct T7Dd d 4:d d rwcHtotdd|iS)Nztool.generatingrE)rr)rErs r@rxz_agent_cbs..R s,*@*E*E+: #S64. 9 9rwc*tdd|iS)Nzthinking.deltarrrrs r@rxz_agent_cbs..T s%0@#PT~*V*VrwcTtdd|itrddiniS)Nzreasoning.deltarrT)rrr>s r@rxz_agent_cbs..U s<5   T R3CC3H3HPy$//b R, , rwcbtt||dnt|Sr)rr2)rrrs r@rxz_agent_cbs..Z s,> TDLDDc$ii4 4 rwc ptd|j|j|j|j|j|jdS)Nznotification.show)rlevelrttl_msrr)rrrBrrCrr)rrs r@rxz_agent_cbs..` s?U  (ud    & & rwc*tdd|iS)Nznotification.clearrr)rrs r@rxz_agent_cbs..l sU #s|. . rwc,td||dS)Nzclarify.request)questionchoicesrS)qcrs r@rxz_agent_cbs..o s  sq$A$A* * rwcJtddd|fd|ffDdS)Nzterminal.read.requestci|] \}}||| Srrvrs r@ z0_agent_cbs....w s T T TdaamQmmmrwrrrrH)rrrs r@rxz_agent_cbs..t sB #  T T/'51AB T T T B B B rw) tool_start_callbacktool_complete_callbacktool_progress_callbacktool_gen_callbackthinking_callbackreasoning_callbackstatus_callbacknotice_callbacknotice_clear_callbackclarify_callbackread_terminal_callbackNNNrrrvr)s`r@ _agent_cbsr[G s    # # # # # # # # # ::::VVVV             " " " "     # # # # # Y2 2 2rwc^ddlm}ddlm}|fddfd }||dS)Nr)set_sudo_password_callback)set_secret_capture_callbackc*tdidS)Nz sudo.requestxrrHr)sr@rxz!_wire_callbacks.. svnc2s'S'S'Srwc||d}|r||d<td|}|sd|ddddSdd lm}i|||dd d S) N)rienv_varrzsecret.requestTFskipped)r+ stored_as validatedrcrr)save_env_value_securer)rcr)rSrrf)rbrirplr4rfrs r@ secret_cbz"_wire_callbacks..secret_cb s7 3 3  &%BzN%sB// $"$   <;;;;; ##GS11     rwr)rr]tools.skills_toolr^)rr]r^rhs` r@rr} sy>>>>>>======SSSSTTT      *  *****rwct|tr|ddg}|dr|d|d|dr|d|ddd|DSt |S) Nr@rtonezTone: stylezStyle: rc3K|]}||V dSrrvr)s r@rz-_render_personality_prompt.. s'//qQ///////rw)rrrrr&r2)rpartss r@_render_personality_promptro s%0?B//0 99V   3 LL1%-11 2 2 2 99W   5 LL35>33 4 4 4yy//E////// u::rwc ddlm}|dpidipiS#t$r ddlm}|dpidipicYS#t$rB|p t }|dpidipicYcYSwxYwwxYw)Nr)load_cli_configrrr)rrqrr1rrr)r5rq_load_full_cfgs r@_available_personalitiesrs s* K''''''!!%%g..4"99/2NNTRTT KKK K G G G G G G"N$$((117R<<_bQQWUW W W W K K K$CGGG$$*//DDJ J J J J J K Ks.:= C:BCAC CCCrczt|pd}|}|r|dvrdSt|}||vrSt |}dd|D}d|d}|r |d|z }n|d z }t ||t||fS) Nr>rrfr)rrrc3"K|] }d|dV dSrrv)r4rs r@rz(_validate_personality.. s*661h!hhh666666rwzUnknown personality: `z`.z Available: `none`, z No personalities configured.)r2r3rrsrr&r%ro)rr5rrErnames availablebases r@_validate_personalityry s ekr   " "C 99;;D 4999v,S11M =  }%%II6666666 ////  7 9i99 9DD 6 6D +M$,?@@ @@rwc|dSt|tr|St|trdd|DSt|S)zHNormalize config prompt values from YAML before handing them to AIAgent.Nrrc3K|]F}t|#t|VGdSrr2r3rs r@rz_prompt_text.. sGRRtD @Q@QRT**RRRRRRrw)rr2r3r r&rs r@ _prompt_textr~ sx }r%{{}}%SyyRRuRRRRRR u::    rwr new_promptrc|sdS||d<|d}|r|pd|_|rd|d}nd}|d5|d d |d t|d d dz|d <dddn #1swxYwYt |}t d||d|fSdS)uApply a personality change to an existing session without resetting history. Updates the agent's ephemeral system prompt in-place so the new personality takes effect on the next turn. The cached base system prompt is left intact (ephemeral_system_prompt is appended at API-call time, not baked into the cache), which preserves prompt-cache hits. Also injects a system-role marker into the conversation history so the model knows to pivot its style from this point forward (without this, LLMs tend to continue the tone established by earlier messages in the transcript). Returns (history_reset, info) — history_reset is always False since we preserve the conversation. )FNrrNz[System: The user has changed the assistant's personality. From this point forward, adopt the following persona and respond accordingly: ]zv[System: The user has cleared the personality overlay. From this point forward, respond in your normal default style.]rruserrolecontentr:rrrF)rephemeral_system_promptrrrr)rrrrrmarkerrs r@_apply_personality_to_sessionr s`" {(GM KK E (2(:d%  . *... FR ^ $ T T I  % %v&&I&I J J J),W[[9JA-N-N)O)ORS)SG% & T T T T T T T T T T T T T T TU## nc4(((d{ ;sABBBrfcB ttjddpd}|dkr|Sn#tt f$rYnwxYw|dpi}t|dp|dp|S)NHERMES_TUI_MAX_TURNSrrr max_turns)rr(rrr1r%)r5rfenv_maxrs r@_cfg_max_turnsr s bjnn%;R@@EAFF Q;;N  z "       &BI y}}[))LSWW[-A-ALW M MMs6:A AcFtjdd}g}t}|dddD]F}|}|r.||vr*||||G|S)NHERMES_TUI_SKILLSrrr) r(rrrrrr3rr)rrseenpartrs r@_parse_tui_skills_envr s *..,b 1 1CFUUD D#&&,,S11  zz||  D$$ HHTNNN MM$    Mrwc<ddlm}|tS)aReturn the configured fallback chain for TUI-created agents. Delegates to the shared ``get_fallback_chain`` helper so the TUI path stays in parity with ``HermesCLI.__init__`` and ``gateway/run.py``: ``fallback_providers`` is the primary source of truth and keeps its order, with legacy ``fallback_model`` entries merged in afterwards (deduped on provider/model/base_url). rget_fallback_chain)hermes_cli.fallback_configrrrs r@_load_fallback_modelr s+>=====  ikk * **rwct|drt|dpgSt|drt|ddStS)zOReturn an agent's fallback chain without rehydrating deliberately empty chains._fallback_chain_fallback_modelN)r rr)rs r@_agent_fallback_modelr' s]u'((7u/006B6u'((7u/666  ! !!rwtask_idc t}idt|ddpddt|ddpddt|ddpddt|ddpddt|ddpddt|ddpddt|ddp tdt|d d t|d dp t d d d ddt|ddpddt|dddt|dddt|dddt|dddt|ddt|ddt|dd|t|ddp t t|ddp t tt|dipidtt|d S)Nrxrrkry acp_commandacp_argsrmax_iterationsenabled_toolsets quiet_modeTverbose_loggingFrproviders_allowedproviders_ignoredproviders_order provider_sortprovider_require_parametersprovider_data_collectionopenrouter_min_coding_scorerzr{request_overridesr) rrrrzr{rrrfallback_model) rrrrrrrrr r)rrr5s r@_background_agent_kwargsr0 sy ++C GE:t44< 75)T22:d  GE:t44<  GE:t44<  wumT::Bd  GE:t44<  ..B.2B2B  .b11  GE+=tDD$ ! # #  d  5  "752KT#R#R$   WU,?FF  WU,?FF! " 75*;TBB# $ >>% & &w 0%( ( ' ,%,E3Mt$T$T'.u6SUY'Z'Z#E+=tDD$ ! # #~t<<T@R@T@T!'%1Db"I"I"ORPPii/66?    rwc\t||}|ddgddd|S)Nrur#T)rr skip_memory)rupdate)rrr;s r@_ephemeral_preview_agent_kwargsrV sF %eW 5 5F MM!+V 4   Mrw max_messagesmax_tool_charsc |d5t|dgpg}dddn #1swxYwYn5#t$r(t|dgpg}YnwxYw|sgSd}tt |dz ddD]%}||ddkr|}n&t dt ||z }|t ||}g}||dD]}t|ts|d} | d vr2d | D} | d krY| jd } t| tr4t | |kr!| d|d t | dz| d <| | |S)uDistill the parent session's recent history into a context the ephemeral preview-restart agent can actually use. The restart agent has no idea what app the user was building, what server they ran, what cwd was active, or which port belongs to which project. Without this, it would take the bare URL + console logs and guess — usually starting the wrong thing. We keep the last ``max_messages`` messages from the parent session so the restart agent sees recent user prompts, assistant replies, and most importantly any terminal/tool calls. Tool result payloads are truncated so we don't blow the context window with file dumps. rrNrrrrr)r assistanttoolsystemc&i|]\}}|dk ||S)rhrvrs r@rMz,_preview_restart_history.. s(AAAA[0@0@10@0@0@rwrrz ... (truncated, original z chars)) r rr1rrrrrrr8r2r) rrrr last_user_idxrrtrimmedrrrrs r@_preview_restart_historyrb sS9 ^ $ = =7;;y"55;< > > AAAAA 6>>dhy))G'3'' CLL>,I,IO^O,ICLLIIIJY t Ns1A&< AAAAA/A:9A:c tj|}n#t$rYdSwxYwt|tsdS|dkrt |dpd}|d}|r |ddS|drd|dS|d|St |d pddd S) Nrrur exit_codeiPrzBackground process started: zterminal exited with code rr)rrr1rrr2rr3)rErr}rrs r@_preview_tool_result_previewr s&z&!! rr dD ! !r zTXXh''-2..4466HH[))  "%&&> ! 88L ! ! KJ$((<2H2HJJ J  ; ;; ; txx  &B ' ' - - / / 66s  %%parentc *iddtdtddffd dtdtdtddffd }dtdtd td tddf fd }dd tdtdzdtdzddffd }|||fddfd dS)NrrrBr|ct|pd}|rtd||ddSdS)Nrpreview.restart.progress)rrBr)r2r3r)rrBrrrs r@progressz,_preview_restart_callbacks..progress sZ7=b!!''))  j ,f'TYcg6h6h i i i i i j jrwrrErFctj|<t||}d||rd|nddS)NzRunning r!r)r/r)rrErFrrrs r@ tool_startz._preview_restart_callbacks..tool_start sU#'9;; < d##=D=";*s***==>>>>>rwrrc tj|tjz }t|||pd||rdt|nd}t ||}||rd|ndzdS)Nz Finished rrr)r/rrrr) rrErrrr rrrs r@ tool_completez1_preview_restart_callbacks..tool_complete sY[[:>>, #L#LL fj99O>O>O{EPMOvVhisVtVtOvOvOvKM>O>O-dF;;V;MMMM<=====rwrrc|rt|dS|r&|ddd|dSdS)Nrqrr!)r2r)rrErr2rs r@rz1_preview_restart_callbacks..tool_progress sq  @ HS\\ " " " " "  @ H **344>>>> ? ? ? ? ? @ @rwc d|S)Nz Preparing rv)rErs r@rxz,_preview_restart_callbacks.. s((3F3F3F*G*Grwc"||n|Srrv)rrrs r@rxz,_preview_restart_callbacks.. s88DDTDDZ^3_3_rw)rOrPrQrRrU)rrr)r2r)rrrrrrrs`` @@r@_preview_restart_callbacksr sa#%Jjj#jcjtjjjjjjj ??C?t???????? >C>s>4>>QU>>>>>>> @@#@S4Z@t@jn@@@@@@ *"/"/GGGG_____   rwc\t|d} t||d|d|d}t|n#t|wxYw||d<g|d<i|d<d|d<d |d <t |d <t |d <i|d <|d5g|d<t |dddz|d<dddn #1swxYwYt||}td||t|||S)Nrr|)rr|rattached_imagesrr image_counterFr rrrrrr:rr) rrrrrrrrrr)rrr new_agentrs r@_reset_session_agentr s !'-"8 9 9F '  M "}- #;;'788     v&&&&v&&&& GG!#G  "G  GOGI 4 6 6G $<$>$>G !!#G   PP %(5F)J)J%K%Ka%O!"PPPPPPPPPPPPPPP G , ,D .#t$$$#w''' Ks2AA*5/C00C47C4rr|r}r~rc ddlm}ddlm}  ddlm} | n#t $rYnwxYw ddlm} | n#t $rYnwxYwt} | dpi} t| dd} t}|ruddl m }|||p| \}}}|r%td d ||r3d d | |fD} t#|t$r| drt'| dpd}| dp|pd}| d}| d}| d}| ||pd}|r||d<|r||d<|r||d<n=t)\}}t#|t&r|r|}|r|}| ||pd}|d/id|dt+| dd| dd| dd| dd| dd| dd| dd| dddddd||n t-d ||n t/d!t1d"d#d$|p|d%||n t3d&| pdd't5t6j d(d)t5t6j d*d+t5t6j d,d-t5t6j d,d.t;t=|S)0NrAIAgentr)wait_for_mcp_discoveryrr@r)build_preloaded_skills_promptrzUnknown skill(s): r c3K|]}||V dSrrv)r4rs r@rz_make_agent..# s;((4(((((((rwrrkrxrry)r target_modelrZrrrrFcredential_poolrTrFrzr{rrrrrrcheckpoints_enabledHERMES_TUI_CHECKPOINTSpass_session_idHERMES_TUI_PASS_SESSION_IDskip_context_filesHERMES_IGNORE_RULESrrrv) run_agentrr)rhermes_cli.mcp_startuprr1tui_gateway.entryrrr~ragent.skill_commandsrr%r&r3rrr2rsrrrrr rr(rrr[)rrrrr|r}r~rrrrr5rr@startup_skillsr skills_prompt_loaded_skillsmissing_skillsrrequested_provideroverride_base_urloverride_api_keyoverride_api_moder2s r@rr sg"!!!!!DDDDDD AAAAAA          <<<<<<          ++C  &BI !C!CDDM*,,N FFFFFF8U8U %#9 9 9 5 ~~  OM$))N2K2KMMNN N  "KK(("/!?(((egg  .$'' N,>,>w,G,G N&&w//5266+// ;;X?PXTX*..z::)--i88*..z::**($     4"3GJ   2!1GI   4"3GJ $<$>$>!! nc * * #~ #"E  3!2 **($    7% % % e% %c2...% Z(((% Z((( %   I&&& %  Z((( % KK ***% V$$$%  $5666% 4% % $)4 & %'))'% .%0 " !#%%1% 401115% 67% 8$9% :",!7::WYY;% <!. 5=% >,BJNN;S,T,TUUU?% @( 7S(T(TUUUA% B+2:>>:O+P+PQQQC% D$BJNN3H$I$IJJJE% F,--- S//I% % %s ,,A A Arrcolsc tj}t5id|d|d|dtjddddd|d |d d d gd ddt d|dddt dt diidtptdt<dddn #1swxYwYt}|| |}|rT| dr?t5tvr|dtd<dddn #1swxYwYnU | |tdn,#t$rtddYnwxYwt#t t%tt'|t)|dt+n #t$rdtd<YnwxYw ddlm}m} ||fd| n#t$rYnwxYw fd|_n#t$rYnwxYwt5t5tvr)t7ttd<dddn #1swxYwYt9d|t;dt=|t idS)Nrrrrr:r inflight_turnrHrGr Frrrrrrrr)rr|r!z%failed to persist resumed session cwdTrrrc&td|Srrrs r@rxz_init_session.. s%8JCQU2V2VrwcBtd|dt|iS)Nzreview.summaryr)rr2)r_sids r@rxz_init_session.. s$U dVS\\$:F F rwrrr)r/rrrrrrrrrMr rrr&r1rrrrrrrrrrbackground_review_callbackrrrrr) rrrrrrDrrtrrs ` r@ _init_sessionrn s )++C    U 3  w  IN,,  q  T   #  3  u  r  Q  ?$$  D  D  244 !":"<"> U 7 7)##,/JIcN5) 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 U%%c9S>%+@AAAA U U U Dt TTTTT U)C.))).  cN geWn6F6FGG H H    ...)- #~&&&. TTTTTTTT%V%V%V%VWWW  """"       @C, , , ((      C \\ )  ,FsIVYN,[,[IcN= )\\\\\\\\\\\\\\\/555 .#}UIMM#r4J4JKKLLLLLsB B44B8;B8 D..D25D2;'E##&F  F *AG00H  H !H33 I?I I II53J44J8;J8ctjddtjjddS)N %Y%m%d_%H%M%SrH)rrDr0rMrNrOrvrwr@_new_session_keyr s<lnn%%o66 O O9I"1"9M O OOrwcJ||djt|S)Nr)_checkpoint_mgrr)rrs r@_with_checkpointsr s$ 2gg. W0E0E F FFrwrefc* ||}t|dz }n#t$r|cYSwxYwd|cxkrt|krnn||d|Stdt|d)Nrrhashz!Invalid checkpoint number. Use 1-rq)list_checkpointsrr%rr)mgrrr checkpointsrs r@_resolve_checkpoint_hashr s**3// #hhl  C""""#k"""""""3##FC000 L[9I9ILLL M MMs '* 99 user_text image_pathsc Hddl}ddl}ddlm}d}g}|D]}t |}|s&d|d} |||t||} | dr| d d nd} | | rd | d | nd | #t$r| d | YwxYw|pd } d |} | r | r| d| n| S| pdS)zMPre-analyze attached images via vision and prepend descriptions to user text.rN)vision_analyze_toolzDescribe everything visible in this image in thorough detail. Include any text, code, data, objects, people, layout, colors, and any other notable visual information.z9[You can examine it with vision_analyze using image_url: r) image_url user_promptr+analysisrz[The user attached an image: z] z2[The user attached an image but analysis failed.] rzWhat do you see in this image?) asynciortools.vision_toolsr rrlrrr2rrr1r&)rrr_jsonr rirnr*r|hintrdescrprefixs r@_enrich_with_attached_imagesr s!!!!!!!!666666 4 EWW JJxxzz  O1OOO W  //#a&&fUUUVVA-.EE),<,<F155R((($D LLR@@@$@@@Q4QQ      W W W LLUtUU V V V V V W ?D [[  F 9(,8&$$d$$$&8  333sBC"C76C7rc|dSt|tr|St|ttfrt|St|trTg}|D]:}t |}|r||;d|St|tr| d}|dvr9t| dp| dpdS|dvrdS|d vrd S|rd |d Sd|vr$t| dpdSd St|SNrrr>r input_text output_textrr>imager  input_image[image]>audio input_audio[audio][r[structured content] rr2rrKr _content_display_textr3rr&rrrrnrrrs r@r#r# r'3'C<((7||'4    # #D(..4466D # T"""yy'4  &{{6"" 8 8 8w{{6**Jgkk).D.DJKK K 8 8 89 + + +9  t;;;  W  w{{6**0b11 1%% w<<rwc|dSt|tr|St|ttfrt|St|trg}|D]}t|tr||.t|t sD|d}t|tr|||d}|dvrQ|dp|dpd}|r"|t||dvr|d}d}t|t r-|d }t|tr|}nt|tr|}|r|d |n|d |d vr|d |r|d|dd|St|t r|d}|dvr9t|dp|dpdS|dvrt|d}d}t|t r-|d }t|tr|}nt|tr|}|pdS|d vrdS|rd|dSd|vr$t|dpdSdSt|S)uRender ``message['content']`` as a plain string for transport. Provider-side, ``content`` may be a string (most common), a list of multimodal parts (e.g. ``[{"type": "text", "text": "..."}, {"type": "image_url", "image_url": {...}}]``), or a single structured dict. Calling ``.strip()`` on a list raises ``'list' object has no attribute 'strip'`` and breaks session resume entirely. Image parts (``image_url``) are preserved by appending the underlying URL (data: or http:) into the text. The desktop renderer pulls these back out via ``extractEmbeddedImages`` so the user sees the image instead of the URL — and it stops the resume payload from disagreeing with the cached message (which would otherwise cause the inline image to flash, then disappear when the resume payload overwrites the cache). Other structured dict shapes (audio, unknown types) fall back to a bracketed placeholder so resume doesn't drop the message entirely. Nrrr>rrrr>rr rr urlrz [image]>rrz [audio]z [rrrr r!) rr2rrKr rrrr&) rchunksrrrrr r'rs r@_coerce_message_textr) s&r'3'C<((7||'4  %" -" -D$$$  d###dD)) 88F##D$$$  d###88F##D<<<HHV$$A(;(;Ar*MM#a&&)))<<< HH[11 i..$ ) e 4 4I!)S11(' 3//$#C/MM*s**----MM+.../// k*** - mDmmm,,,wwv'4  &{{6"" 8 8 8w{{6**Jgkk).D.DJKK K 8 8 8 K00IC)T** %MM%00 i--$#CIs++ #) # + + +9  t;;;  W  w{{6**0b11 1%% w<<rwc ^g}i}|D]$}t|ts|d}|dvr3t|d}|dkr|dr|dD]}|di}|dd}|rj|d rU t j|d d } n#tjtf$ri} YnwxYw|d | f||<|s)|d kr|d d}|r||nd} | r| dndp|dpd } | r| dndpi} | d | t| | d|s||d} |dkr6dD]3} | |vr-|| || | | <4| | &|S)Nr>rrrrrr tool_callsrrrrE argumentsz{}rrrr-r)rrEr)rr)rhreasoning_contentreasoning_detailscodex_reasoning_items) rrrr)rrrr1r3rr)rmessagestool_call_argsrgr content_texttcrr8rFtc_inforErrs r@_history_to_messagesr5k sHN ((!T""  uuV}} > > > +AEE),<,<== ;  155#6#6  o ? ?VVJ++tR((?RVVF^^?"#z"&&d*C*CDD 0)<"""!"-/Z,>N5)%%''  6>>EE."--E38Bn((///dG")3GAJJtTk8J8JTfD")3GAJJt:D OO)D$:O:OPP    !!##  \22 ;   * * !88c 6 uuSzzCH Os(C..D D c~t|tsgSg}|D]}t|ts|d}|dvr2|d}||d}t|tr|s|||d|S)Nr)rrrrrr)rr rrr2r3r)rrrrrs r@_coerce_seed_historyr7 s eT " " G;;$%%  xx 6 6 6 ((9%% ?hhv&&G'3'' w}}  99:::: Nrwc|dSt|tr|St|ttfrt|St|trTg}|D]:}t |}|r||;d|St|tr| d}|dvr9t| dp| dpdS|dvrdS|d vrd S|rd |d Sd|vr$t| dpdSd St|Srr"r$s r@r#r# r%rwcDt|Sr)r#r3r}s r@_inflight_textr: s  ' ' - - / //rwc\tj}d|d|t|d|d<dS)NrT)rr streaming updated_atrr)r/r:)rrrDs r@_start_inflight_turnr> s; )++Ct$$   GOrwdeltac|dnt|}|sdS|d}t|tsdddd}|dpd||d<d|d<t j|d<||d<dS)NrrTrr<rrr<r=)r2rrrr/)rr?rturns r@_append_inflight_deltarC s22CJJD  ;; ' 'D dD ! !@dB??88K006B>>>DDD#GOrwcd|d<dS)Nrrvr#s r@_clear_inflight_turnrE s#GOrwcn|d}t|tsdSt|dpd}t|dpd}t |d}|s|s|sdS|||dS)Nrrrrr<rA)rrrr2r3r)rrBrrr<s r@_inflight_snapshotrG s ;; ' 'D dD ! !t txx%2 & & , , . .DDHH[))/R00ITXXk**++I  )t  rwzsession.createc\tjjddt}t |dd}t |d}t|dpd}t|dpd} t|oXtj tj tj |}n#t$rd}YnwxYwt!|}t#|d pdpd} t%| } t'j} t+j} t-| \} }|t/|d |St05id dd dd| dgdt3|ddd| d|d| did|d|dt'jddddd|ddd| |pd| t| ndd|t7dt9it;pt<d t><tAt>dddn #1swxYwYd#fd }t'j!d|}d |_"|#tI||tK|tM|tOiit>dtQt>dd tRtUd!d"S)$NrKrrr0titlerrFrdrrrrFrr7rrHrrrrr:rrrrG) rRrrr rrrrrr!r|cdt}|t|dSdSr)rMrr)rrs r@_deferred_buildz_.._deferred_buildNs8--$$   sG , , , , ,  rwg?T)rr\rrr lazyrr)rstored_session_id message_countr0rr)+rMrNrOrrrr7r2r3rr(r*r{ryrzr1rrHrorrPr/rrarrrrrrrrMrr,rrrrr5rrrr)rrrrrrIraw_cwdr resolved_cwdrdrrrMrDr limit_messagerM build_timerrs @r@rHrHs6 *,, 2A2 C   C vzz&"%% & &D"6::j#9#9::G  7##)r * * 0 0 2 2E &**U##)r**0022GG}}drwrwGYGYZaGbGb7c7c)d)d  "6**L zz)$$*1133;tG ))L O  E )++C5c3OOOE= C}--- .. T 4  5  r  "?6::>SUZ3[3[#\#\  #E   D  #  b  L  w  IN,,  q  Q  < T! " 3# $#]d1=1IC ---t244 ":"<"<!*,,@0@5   #8 in---;...............R------ /$88KK  !$ \\,W55')) ~e,-inU.CDD$< 5 7 7       s&"A(E EECK((K,/K,z session.listct}|t|dS tdht|ddpd}t |dzd}fd|d|Dd|}t|d d |DiS#t$r(}t|dt|cYd}~Sd}~wwxYw) Nir_rlimitrkcg|]A}|dpdv?|BS)rr)rr3r)r4r5denys r@r6z_..sU   h%2,,..4466dBB BBBrwrrWsessionsc g|]z}|d|dpd|dpd|dpd|dpd|dpdd{S) rrIrrrrrPr)rrIrrrPrr3r4r5s r@r6z_..s    g!"w!52#$55#3#3#9r&'eeL&9&9&>Q)*)?)?)D1"#%%//"7R    rw) r rc frozensetrrrlist_sessions_richrr1rar2)rrrrW fetch_limitrowsrrZs @r@rHrHls= B z$St4444&'&""FJJw,,344%!)S))     **$k*JJ    5&     "       '''Cs1vv&&&&&&&&'sBB33 C%=C C% C%zsession.most_recentc t}|t|ddiS tdh}|dd}|D]}|dpd}||vrBt||d|d pd|d pd |dpdd cSt|ddiS#t$r/t d t|ddicYSwxYw)aeReturn the most recent human-facing session id, or ``None``. Mirrors ``session.list``'s deny-list behaviour (drops ``tool`` sub-agent rows). Used by TUI auto-resume when ``display.tui_auto_resume_recent`` is on; the field is also handy for any CLI tooling that wants "latest session" without paginating the full list. Contract: a ``{"session_id": null}`` result means "no eligible session found right now". Errors are also folded into that null-result shape (and logged) so callers don't have to special- case JSON-RPC error envelopes for what is a normal "no answer". NrrrXr[rrrrIrr)rrIrrzsession.most_recent failed) r rr_r`rr3rr1r exception)rrrrZrbrtsrcs r@rHrHsr B z3t,---.&"" $$D$<<  C778$$*113399;;Cd{{"%''$-- WWW--3"%'',"7"7"<1!ggh//52    3t,--- ...56663t,-----.sCD 8D 6EEric$ |dd}|st|ddS t|dd}n#ttf$rd}YnwxYw|dpdpd}t |}|dd lm}||d z }nt}|t|d S| |}|s1| |}|r |d}nt|ddSt5t|} | M| \} } t| | |dt!pt"} || d<t%|| cdddS dddn #1swxYwYt'jjdd} t-|| \} }|t|d|St/|t1t3|nd} ||||}||d}|dt9dt;|t;|z }t=|}t?|} tA|}tC| |f||d|}tE|n#tE|wxYwnS#tF$rF}| | $t|d d|cYd}~|tK|SSd}~wwxYw |tK|n#|tK|wwxYwt5t|} | tM|dr|'n#tF$rYnwxYw| | $| \}}t|||dt!pt"} || d<t%|| cdddS tQ| ||||| tRvrj|d|dtR| d<|tR| d<|t3|tR| d<| tR| d<nM#tF$r@}| | $t|d d|cYd}~cdddSd}~wwxYwtR| pi} dddn #1swxYwYt%|| |t;||tU|| dd |tW| d!ptYj,d"d# S)$Nrrsession_id requiredrrrdrr[rgrrVrrTrtouchr!resumedrKrJrKinclude_ancestors)rrzresume failed: rrr|display_history_prefixrrrFrHidle) rrmrPr0rinflightr rrr)-rrarr1r%r3ror^r\r rcrget_session_by_titler(_find_live_session_by_key_live_session_payloadrrrrMrNrOrrHr r2reopen_sessionget_messages_as_conversationrrr5rrrrr1rr r rrrMrrKr/)rrrrrdrrr\rfoundliverrrrrSrrdisplay_historyrqr0rstored_runtime_overridesrr other_sid other_sessions r@rHrHsY ZZ b ) )F 6C45556::fb))** z "zz)$$*1133;tG ))L****** Y|j8 9 9 9 YY z$St4444 NN6 " "E 8''//  84[FFT#677 7  % %(00  LC++--A1A G"(GI sG$$ % % % % % % % %  % % % % % % % % % % % % % % %$ *,, 2A2 C5fcRRRE= C}---7C7O \!2!2333UY!3 &!!!11&9999 d:  "1 9c!S))CLL899 9" (88%f-- + (I'O'O $"  + E #6 * * * * "6 * * * * * 666   MMOOOC4445555555  ! &z 2 2 2 2 " 6 +  ! &z 2 2 2  ! &z 2 2 2 2 " &+&+(00   5'**"KKMMM      '+ $I}++--A1A G"(GI sG$$'&+&+&+&+&+&+&+&+( : #vugD A A A Ai+//0@AAM7O(8IcN#3429> #56 : : :  T#8Q#8#899 9 9 9 9 9K&+&+&+&+&+&+&+&+D :--$$*M&+&+&+&+&+&+&+&+&+&+&+&+&+&+&+N   ]] !%11! L 9 9 HTY[[II   s#AA%$A%*AFFFBK1, K K1K--K10M1 M;)L<$M%M<MMM+5T$N-,T- N:7T9N::AT!BR)(T) S33)S.S3T.S33TT"%T"zsession.cwd.setc|t||\}}|r|S|drt|ddSt|ddpd}|st|ddS t ||}n5#t $r(}t|dt|cYd}~Sd}~wwxYw|d }|t||n|t|d d }td |d d|t||S)Nr  session busyrr cwd requiredrT)rr rNrr) rrrar2r3r'r%rrrr) rrrrrrrrrs r@rHrH_s_,,LGS  {{9/C~... fjj##)r * * 0 0 2 2C /C~...'w,, '''Cs1vv&&&&&&&&' KK E,1,== ( ( (%c**DDD  .&**\266=== sD>>s B C $CC C cttD]R\}\}}||krt|dif\}}t |dcSdS)Nz input.requestz.requestr)r rOr8rPrr2 removesuffix)rrrU_evr_payloads r@rIrIws~!%hnn&6&6!7!733 i    266s_b.sK    C{{<(( 311   rwr\) r2rrr rMr8r1rar)rrr rrbrs @r@rHrHs)&**1228b99GL  / /IOO--..H / / / / / / / / / / / / / / / LLLCJqJJKKKKKKKKL$    $   D sZ& ' ''s@A-'A! A-!A%%A-(A%)A-- B7B BBzsession.activatec t|dpd}td|i|\}}|r|S|Jt|t ||dt pt S)zAttach the frontend to an already-live TUI session. This intentionally does not close the previously focused session; it merely returns enough state for Ink to redraw around another live session id. rrNT)rlr!)r2rrrrvrr)rrrrrs r@rHrHs fjj&&," - -Cs 3S99LGS         '))=-=      rwzsession.deletec|dd}|st|ddSt}|t|dS t5t t }dddn #1swxYwYn+#t$r}t|dd|cYd}~Sd}~wwxYwd |D}||vrt|d d Std z } | || }n+#t$r}t|dd|cYd}~Sd}~wwxYw|st|ddSt|d|iS)uDelete a stored session and its on-disk transcript files. Used by the TUI resume picker (``d`` key) so users can prune old sessions without dropping to the CLI. Refuses to delete a session that is currently active in this gateway process — those rows are still being written to and removing them out from under the live agent corrupts message ordering and trips FK constraints when the next message append flushes. rrrgrhNrrVrcbh|],}|d|d-S)rr3r^s r@ z_..Ks5 M M Mqm8L8L MaeeM"" M M Mrwzcannot delete an active sessionr\) sessions_dirzdelete failed: rjrdeleted) rrar rcrr rMr;r1r delete_sessionr) rrrrr ractiverrs r@rHrH.sZZ b ) )F 6C4555 B z$St4444L  0 0I,,..//H 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 LLLCJqJJKKKKKKKKL M MH M M MF C@AAA"$$z1L6##F#FF 666C444555555556 4C2333 sY' ( ((s` B'B: BB  B B B B:B5/B:5B:0D D0D+%D0+D0z session.titlect||\}}|r|St}|t|dS|d}d|vr|dpd} ||pd}|rq|||rd|d<|}nZ||}|pidpd} | |krd|d<|}n |s|}n|rd|d<n#t$r|}YnwxYwt|||dS|ddpd} | st|dd S ||| rd|d<t|d | d S||}|r-d|d<t|d |dp| d S| |d<t|d | d S#t$r(} t|d t| cYd} ~ Sd} ~ wt$r(} t|dt| cYd} ~ Sd} ~ wwxYw)NrVrrIrRr)rIriztitle requiredF)pendingrITi) rr rcrrset_session_titlerr3r1rrar%r2) rrrrrrfallbackresolved_title existing_rowexisting_titlerIrs r@rHrHXs,,LGS  B z$St4444 - Cf;;//52 &11#66<"N 0''X66 2/3GO,%-NN#%>>##6#6L'3'9r&>&>w&G&G&M2%T%T%V%VN%11370)1+2)1 0+/( & & &%NNN & '"     ZZ $ $ * 1 1 3 3E 1C/000'  U + + @'+GO $s>>?? ?~~c**  '+GO $$*..w77@5 $) 3D599::: '''Cs1vv&&&&&&&& '''Cs1vv&&&&&&&&'sPBC// C>=C>-GAGG H>&H H> H>H93H>9H>zhandoff.requestc nt||\}}|r|S|drt|ddS|ddpd}|st|ddS dd lm}m}n+#t$r}t|d d |cYd }~Sd }~wwxYw ||}n,#ttf$rt|d d|dcYSwxYw |} n+#t$r}t|d d |cYd }~Sd }~wwxYw| j |} | r| j st|dd|dS| |} | r| jst|dd|dSt|t!|5} | t#|dcd d d S|d} | | s!| | d| d d| | |}nA#t$r4}t|dt+|cYd }~cd d d Sd }~wwxYw d d d n #1swxYwY|st|ddSt-|d| || jdS)aQueue a handoff of this session to a messaging platform. Desktop parity with the CLI ``/handoff`` command: we only write ``handoff_state='pending'`` onto the persisted session row. The actual transfer is performed by the separate ``hermes gateway`` process, whose ``_handoff_watcher`` claims the row, re-binds the session to the platform's home channel, and forges a synthetic turn. The desktop then polls ``handoff.state`` for the terminal result. r ruLsession busy — wait for the current turn to finish, then retry the handoffrrrzplatform requiredr)Platformload_gateway_configzcould not load gateway config: Nizunknown platform ''iz platform 'z*' is not configured/enabled in the gatewayizno home channel configured for u8 — set one with /sethome on the destination chat firstrrVrzhandoff-rKiuNsession is already in flight for handoff — wait for it to settle, then retryT)queuedrr home_name)rrrar3rgateway.configrrr1r%KeyError platformsrget_home_channelchat_idrr!rcrrrequest_handoffr2rrE)rrrr platform_namerrrr gw_configpcfgrnrrrs r@rHrHsF ,,LGS  {{9    Z   ZZ B//52<<>>DDFFM 4C2333 F@@@@@@@@@ FFFCDDDEEEEEEEEFF8M**  !FFFCDMDDDEEEEEFF'')) FFFCDDDEEEEEEEEF   " "8 , ,D  t|    R R R R    % %h / /D  t|    5m 5 5 5   7### W   + :(4888 + + + + + + + +m$ +>>#&& @$$S*>S!W*>*>???##C77BB + + +T3q66** * * * * * + + + + + + + + +  + + + + + + + + + + + + + + +     \    %     sB B?!B:4B?:B? C&C87C8< D D/D*$D/*D/;I?I?$A H10I?1 I/;I*I/I?*I//I??JJz handoff.statect||\}}|r|St|5}|t|dcdddS||d}dddn #1swxYwY|pi}t ||dpd|dpd|dpdd S) zPoll the handoff state for a session. Returns ``{state, platform, error}`` where ``state`` is one of ``pending|running|completed|failed`` (or empty when no handoff record exists). Desktop polls this after ``handoff.request``. NrrVrstaterrr)rrr)rr!rcget_handoff_staterr)rrrrrrecords r@rHrHsA ,,LGS  W  > :(4888>>>>>>>>%%gm&<==>>>>>>>>>>>>>>> \rF  ZZ((.B :..4"ZZ((.B    sA.A..A25A2z handoff.failc>t||\}}|r|St|dpddd}t |5}|t |dcdddS|d}||pi}|dpd }|d vr5|||t|d d d cdddS dddn #1swxYwYt|d|d S)zMark an in-flight handoff as failed so the user can retry. Desktop calls this when its bounded poll times out. Only pending/running rows are changed so a late success from the gateway watcher is not clobbered. rzhandoff failedNrrVrrr>rr Tfailed)rrF) rr2rr3r!rcr fail_handoffr) rrrrreasonrrrrs r@rHrH s ,,LGS  G$$8(8 9 9 ? ? A A$3$ GF W  A :(4888AAAAAAAAm$%%c**0b 7##)r * * * OOC ( ( (sth??@@AAAAAAAA + AAAAAAAAAAAAAAA suu55 6 66s%DA"DDDz session.usagect||\}}|r|S|d}|t|nddddd} ddlm}|}|r||d<n#t $rYnwxYwt ||S)Nrr)rlrerrk)nous_credits_lines credits_lines)rrrBagent.account_usagerr1r)rrrrrrDrcreditss r@rHrH"s,,LGS  KK E   51A > >  ::::::$$&&  -%,E/ "      sE??sA A+*A+zsession.statusc t||\}}|r|Sddlm}|dp|dpd}|d}i}t }|r-|r+ ||pi}n#t $ri}YnwxYwd$dtdzdtfd } | |d } | } d D]8} || r!| || | } n9|t|ni} t|d dpd }t|ddpd}ddd|d|g}|dpd }|r| d|| d|d|dd| dd| ddt| dpddd|drd nd!gt|d"d#|iS)%Nrdisplay_hermes_homerrrrrr|c|r2 tjt|S#t$rYnwxYw|ptjSr)r fromtimestamprKr1rD)rrs r@_dtz_.._dtNsW   -eEll;;;    )8<>>)s % 22r)r=last_updated_atlast_activity_atrkrr (unknown)zHermes TUI Statusz Session ID: zPath: rIzTitle: zModel:  ()z Created: z%Y-%m-%d %H:%MzLast Activity: zTokens: rkrzAgent Running: r YesNorrr)rrrrr rr1rrBrr3rrr0rrr&)rrrrrrrrrrcreatedupdatedfieldrDrkrlinesrIs r@rHrH<s,,LGS  444444 ++m $ $ F <(@(@ FBC KK E D B c >>#&&,"DD   DDD **X_*****c$((<(())GGF 88E?? c$((5//733G E "'!2Ju   Euj$//<9H E7D ) ) 8[E s($$&&((  E XXg   $" + + - -E ( &u&&''' LL *e * *x * * * <(()9:: < < Bg../?@@ B B 7s599W--233 7 7 7 Iw{{9'='=Gee4 I I   sXtyy//0 1 11s4B BBzsession.historycxt||\}}|r|St|dg}t}|D|dr/ ||dd}n#t $rYnwxYwt |t|t|dS)NrrTrn)rr0) rr rr rxr1rrr5)rrrrrrs r@rHrHus,,LGS  7;;y"--..G B ~'++m44~ 55 &$6GG    D   \\,W55    s!A?? B  B z session.undoct||\}}|r|S|drt|ddSd}|d5|dg}|rU|ddd vr8||d z }|r|ddd v8|r8|ddd kr||d z }|r)t |d dd z|d <dddn #1swxYwYt |d |iS)Nr r9session busy — /interrupt the current turn before /undorrrrr>rrrrr:removed)rrrarrr)rrrrrrs r@rHrHs%%LGS  {{9  R   G  T T++i,, '"+//&115JJJ KKMMM qLG '"+//&115JJJ  wr{v..&88 KKMMM qLG  T),W[[9JA-N-N)O)ORS)SG% & T T T T T T T T T T T T T T T sY( ) ))sCD''D+.D+rjct||\}}|r|S|drt|ddS|dd}t|ddpd} ddlm}dd lm}|d 5t|d g}t|d d} dddn #1swxYwYt|} |d } t| ddpd} t| ddpd} | r||| | nd}| dkr&|rd|dnd}t|dd| d|dd|d t||||| \}}|d 5t|d g}dddn #1swxYwYt|}t| ddp| }t| ddp| }|r||||nd}|d }t|||||||}t!||}t#d||t%|d|| |||||||d t|dS#t|dwxYw#t&$r(}t|dt|cYd}~Sd}~wwxYw) Nr ru=session busy — /interrupt the current turn before /compressrrr7r)summarize_manual_compressionr<rrr:rr>r\r?rnz , focus: "" compressingu⠋ compressing z messages (~rz tok)…)r8r9r:rrG) rrr9after_messages before_tokens after_tokensr rDrr0rMi)rrrar2r3!agent.manual_compression_feedbackrrAr=r rrrrrIrVrrrr1)rrrrrr7rr=r9r: before_count_agentrErFr focus_suffixrrDr0 after_count_sys_prompt_after _tools_afterrrr rrs r@rHrHss%%LGS  {{9  V    **\2 & &Cfjj339r::@@BBKR'RRRRRRFFFFFF ^ $ E E"7;;y"#=#=>>O!'++.?"C"CDDO E E E E E E E E E E E E E E E?++ !f&=rBBHb $//74   ) ){&      1  :EM6 66662L =<=="<==+7===   4 )6+ / / NGU( < < Ir : :;; < < < < < < < < < < < < < < <h--K 7<<K  #67D99CVL --"3&  G$E ,S' : : :22=,G!00D .#t , , ,*&'3&1%2$0&" (  & 3 ( ( ( (N3 ( ( ( ( '''Cs1vv&&&&&&&&'s J" AC3' J"3C77J":C7;A>J":J $G = J G  J G B+J <J" JJ"" K,K KKz session.savec t||\}}|r|S|d}tdz dz } |ddn.#t$r!}t |dd|d|cYd}~Sd}~wwxYwt jd }|d |d z }|d 5t| d g} dddn #1swxYwYt|ddp| dpd} t|dd} t| t r| } nY| d} t| ttfr&t j|  nd} t!|dd5}t#jt|dd| | t|ddpd| d|dddddn #1swxYwYt'|dt)|iS#t$r(}t |dt)|cYd}~Sd}~wwxYw)Nrr\savedTparentsriz failed to create save directory r!rhermes_conversation_.jsonrrrrr session_startrHr7rrrr>)rrrr@r0rkF)rrr#)rr mkdirr1rarrDr0r rrr isoformatrrKrr-rdumprr2)rrrrr saved_dirr timestampr*r0r agent_startrrHr>s r@rHrHs=%%LGS  G E !!J.8ITt4444 TTTCR)RRqRRSSSSSSSST ''88I >i>>> >D  44 Ir2233444444444444444 d33Ww{{=7Q7QWUWJ%$77K+x(( #--// [[.. *sEl33 H ": . . 8 8 : : :  ' $g . . . ! I$UGR88",%2%,U4KR%P%P%VTV ( "                   3T+,,, '''Cs1vv&&&&&&&&'sqA A8A3-A83A82$C""C&)C&*H1.UsCCC499CCCrwriu*nothing to branch — send a message firstrKrJrKrErr get_next_title_in_lineagez (branch)r_branched_from)rrrvparent_session_idrrrr)rrrzbranch failed: )rrrrprrizagent init failed on branch: )rrIr)rr rcrrarrMrNrOrrr rrrrappend_messagerr1rrrrrr rMr)rrrrrrTrnew_keynew_sidrrS branch_namerIrrrrrs r@rHrHKs%%LGS  B z$St4444m$G  DDCC Ir(B(BCCCDDDDDDDDDDDDDDD MCKLLL  Gjllrr"G5gwWWWE= C}---**VR((K!6  EE**733?xG2:;;+,,W555***    "" +G4%W%%    C   "WWVV,, **      We,,,, 666   MMOOOC444555555556D%g.. +WEEEE "6 * * * * "6 * * * * WeT']]VR9P9P     i  9>Ig 5 6 DDD   MMOOOCBqBBCCCCCCCCD s7UgNN O OOsh !A66A:=A:CG H!)H HHJ.)I ;J. IAJ.. K,8)K'!K,'K,zsession.interruptcRt||\}}|r|St|ddr|dt|dd ddlm}||ddd n#t$rYnwxYwt|d d iS) Nrrrrrresolve_gateway_approvalrrZT resolve_allr interrupted) rr rrVrrrr1r)rrrrrs r@rHrHs%%LGS  ww--%""$$$ 6::lB//000 ;;;;;;  !7TRRRRR      sX}- . ..s,B BBzdelegation.statuscddlm}m}m}m}t |||||dS)Nr)is_spawn_pausedlist_active_subagents_get_max_concurrent_children_get_max_spawn_depth)rpausedmax_spawn_depthmax_concurrent_children)tools.delegate_toolrrrrr)rrrrrrs r@rHrHs  ++--%o''3355'C'C'E'E     rwzdelegation.pausecddlm}t|dd}t |d||iS)Nr)set_spawn_pausedrT)rrrrr)rrrrs r@rHrHsP444444 &**Xt,, - -F sX//778 9 99rwzsubagent.interruptcddlm}t|dpd}|st |ddS||}t |||dS)Nr)interrupt_subagentrrzsubagent_id required)ryr)rr r2rr3rar)rrr rrs r@rHrHs666666fjj//5266<<>>K 7C5666  K ( (B sb== > >>rwcZddlm}|dz }|dd|S)Nr)r z spawn-treesTr)rr r)r roots r@_spawn_trees_rootr$sA000000 ?  } ,DJJtdJ+++ Krwcdd|Dpd}t|z }|dd|S)Nrc3NK|] }|s|dvr|ndV!dS)z-_rHN)isalnumr4rJs r@rz*_spawn_tree_session_dir..s;KK1QYY[[6AII3KKKKKKrwrTr)r&r$r)rsafeds r@_spawn_tree_session_dirr+sW KK KKKKKXy  d"AGGD4G((( Hrwz _index.jsonlentryc6 |tz dd5}|tj|ddzddddS#1swxYwYdS#t $r&}t d|Yd}~dSd}~wwxYw)NrrrFrrz"spawn_tree index append failed: %s)_SPAWN_TREE_INDEXr-r.rrOSErrorrr) session_dirr,r>rs r@_append_spawn_tree_indexr2s @-- 3 3C' 3 J J Ba GGDJu5999D@ A A A B B B B B B B B B B B B B B B B B B @@@  93?????????@s:A(-A A(AA("A#A(( B2BBc|tz }|sgSg} |dd5}|D]V}|}|s |t j|B#t j$rYSwxYw dddn #1swxYwYn#t$rgcYSwxYw|S)Nrrr) r/rlr-r3rrrrr0)r1 index_pathoutr>rs r@_read_spawn_tree_indexr6s700J      C  __S7_ 3 3 q  zz||JJtz$//0000+H                    JsXB.B"'B?B"BB"BB" B."B&&B.)B&*B.. B=<B=zspawn_tree.savec t|dpd}|dpg}t|tr|st |ddSddlm}|d}|d ptj}t|d pd}|jt| d }|d } t|pd } | | z } ||rt|ndt|||d} | tj| ddn+#t$r} t |dd| cYd} ~ Sd} ~ wwxYwt!| t| || d| d |t#|dt%|t| |dS)Nrrr]r!zsubagents list requiredrrr finished_atrz %Y%m%dT%H%M%Srrf)rrr8rr]Fr.rrrizspawn_tree.save failed: )r*rrr8rr)r*r)r2rr3rr rarr/utcfromtimestamprKr0r+ write_textrrr0r2rr)rrrr]rrr8rtsfnamer*r*rrs r@rHrHs4VZZ --344::<.Es%999qahhjj9999rwrfc3K|]>}|dxt:|V?dS)r*N)rrrl)r4rr|s r@rz_..NscAEE&MM'9q?CAww~~?O?Orwz*.jsonrrr]r8rrr)r*rr8rrrc0|dpdS)Nr8rr3)rs r@rxz_..lsquu]338qrwT)rreverseentries)r2rr3rrr$iterdirr+r6rglobrEr/r.rr read_textr1rr/rr rr0sortr)rrrrWr?r#rootsrEr*indexedr.rr]r|s @r@rHrH=sVZZ --344::<>))++T""""  HHHCFFFGGGGGGGGHA*X///AABB T) *AAAC?#??@@@@@@@@A sG  s<12B$$C5CCC(DD4D/)D4/D4z session.steerc|dpd}|st|ddSt||\}}|r|S|d}|t |dst|dd S ||}n+#t $r}t|d d |cYd}~Sd}~wwxYwt||rd nd |dS)uGInject a user message into the next tool result without interrupting. Mirrors AIAgent.steer(). Safe to call while a turn is running — the text lands on the last tool result of the next tool batch and the model sees it on its next iteration. No interrupt, no new user turn, no role alternation violation. rrztext is requiredrNrizagent does not support steerrizsteer failed: rrejected)rr)rr3rarr rr1r)rrrrrracceptedrs r@rHrHs JJv   $" + + - -D 3C1222,,LGS  KK E }GE733}C=>>>7;;t$$ 777C555666666667 s8CxxTRR S SSs B## C -CC C zterminal.resizect||\}}|r|St|dd|d<t|d|diS)Nrr)rrrr)rrrrs r@rHrHsZ,,LGS  &**VR0011GFO sVWV_- . ..rwz prompt.submitc4 |dd|ddc |d}t|\ }|r|Stx}| d< d5 drtdd cdddS|E t |}n4#t t f$r td d cYcdddSwxYw d g}d t|D}|t|krtddcdddS|d||}| d <t dddz d<tx} S | d|n5#t$r(} td| tjYd} ~ nd} ~ wwxYwd d<tj d<t! dddn #1swxYwYt# t% d fd } t'j| dt-ddiS)Nrrrtruncate_before_user_ordinalr!rr rrz/truncate_before_user_ordinal must be an integerrcJg|] \}}|ddk|!S)rrr3)r4irgs r@r6z_..s1XXX$!Qf QW@W@WA@W@W@Wrwz3target user message is no longer in session historyr:rrrz6[tui_gateway] prompt.submit: replace_messages failed: r#TrGr|c 2t}|rqtdd|diddid5dd<tdddn #1swxYwYdSt dS)Nrragent initialization failedrFr )rrrrE_run_prompt_submit)rrrrrs r@run_after_agent_readyz _..run_after_agent_readys'3''   swww3377!#@     ( . .%* "$W--- . . . . . . . . . . . . . . . F3Wd33333sA88A<?A<rrr<r)rrrrarr1r% enumeraterr replace_messagesr1r6r7r8r/r>rrrrrr)rrtruncate_user_ordinalrrordinalr user_indices truncatedrrr`rrrs` @@@r@rHrHs <,,fjj.D.DIC"JJ'EFF,,LGS    -    ,, ;;y ! ! 3T>22,,,,,,,, ! , Z344z* Z Z ZC'XYYYY,,,,,,,,  Zkk)R00GXX)G*<*<XXXL#l++++C'\]],,,,,,,, 7,w"7 78I!*GI ),W[[9JA-N-N)O)ORS)SG% &ii,k'' (> JJJJ kkkXSVXX_b_ijjjjjjjjjk! !% Wd+++-,,,,,,,,,,,,,,,27###sG$$$444444444$1$???EEGGG sX{+ , ,,sn;&H-.H-2CH-"C3$H-2C33AH-AH-$GH- G3 G.)H-.G33.H--H14H1evtct|dpdsdStdpdkrdS t5tt}dddn #1swxYwYn#t $rYdSwxYwtfd|DS)uATrue if ``evt`` is owned by a *different* live session. Background-process events carry the ``session_key`` of the session that started the process. Since all desktop sessions share one process-wide completion queue, each poller must skip events it doesn't own so a background job's completion surfaces in the session that launched it — not whichever poller happened to dequeue first. Orphaned events (owner gone) and global/system events (empty ``session_key``) return False so the current poller still handles them rather than losing them. rrFNc3pK|]0}|uo't|dpdkV1dS)rrN)r2r)r4r5evt_keyrs r@rz8_notification_event_belongs_elsewhere..s_  GS}!5!5!;<<Grw)r2rrr rMr;r1r)rrgr rjs` @r@%_notification_event_belongs_elsewhererks7#''-((.B//G u#gkk-006B7777u  0 0I,,..//H 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 uu   s6B'B BBBBB B*)B*c |dd}|dd}|dkrm|||dd|dd|dd|d d |d dfS|d s|d krC|||dd|dd|d d fS||fS)aReturn the UI-emission identity for a process notification event. Completion events are terminal notifications for a background process, so they remain one-shot per process session. Watch-match events are not terminal: a single background process can legitimately match the same or different patterns many times, so include event-specific content to avoid suppressing later distinct matches from the same process. rrjrr watch_matchrpatternr suppressedr message_idwatch_overflow_watch_disabledr)rr0)rgevt_typeevt_sids r@_notification_event_dedup_keyru swwv|,,HgglB''G=    GGIr " " GGIr " " GGHb ! ! GGL! $ $ GGL" % %  ,-- =M1M1M   GGIr " " GGIr " " GGL! $ $    X rwr c ddlm}m}t}|sV|ds@ |jd}n#t$rYTwxYwt||r/|j |tj d|dd}|d d kr| |r||}|st|} | |vr)td |d |d || |d5|dr(|j | dddld|d<dddn #1swxYwYdt!tj dz} td|t#| |||no#t$rb} t%dt'| jd| t*j|d5d|d<dddn #1swxYwYYd} ~ nd} ~ wwxYw|s|d@g} |js |j}n#t$rYnwxYwt||r| |l|dd}|d d kr| |r||}|st|} | |vr)td |d |d || |d5|dr'|j | dddnd|d<dddn #1swxYwYdt!tj dz} td|t#| |||no#t$rb} t%dt'| jd| t*j|d5d|d<dddn #1swxYwYYd} ~ nd} ~ wwxYw|j| D]}|j |dS)aPoll completion_queue and dispatch notifications autonomously. Runs in a daemon thread started by _init_session(). Emits a status.update (kind=process) for user visibility, then chains an agent turn via _run_prompt_submit if the session is idle. NOTE: The completion_queue is global (one per process). If multiple TUI sessions coexist, whichever poller wakes first grabs the event, even if the process was started by a different session. This matches CLI/gateway behavior (single session per process). r)process_registryformat_process_notificationrrrg?rrrrjrprocessrrr NT __notif__r message.startz3[tui_gateway] notification poller dispatch failed: r!r\F)tools.process_registryrwrxrrJrcompletion_queuer1rkrr/rVis_completion_consumedrurrrr_r6rr5r7r8empty get_nowaitr) r rrrwrx_emittedrg_evt_sidr _dedup_keyrrdeferreds r@_notification_poller_loopr)sUTTTTTTTuuH!!2+'++l*C*C2+ "3777DDCC    H  1# > >   - 1 1# 6 6 6 JsOOO 77<,, 776??l * */?/V/VW_/`/` * **3//   3377 X % % /3D(I(I J J J LL $ $ $ ^ $ & &{{9%%  155c::: & & & & & & &"&GI   & & & & & & & & & & & & & & & 4#dikkD01133 + /3 ' ' ' sC$ 7 7 7 7 + + + /99%//),//Z     ( + +%* " + + + + + + + + + + + + + + +  +W!!2+'++l*C*C2+nH/5577%+ "3>>@@CC    E  0# > >  OOC 77<,, 776??l * */?/V/VW_/`/` * **3//  2377 X % % /3D(I(I J J J LL $ $ $ ^ $ & &{{9%%  155c::: & & & & & & &"&GI   & & & & & & & & & & & & & & & 4#dikkD01133 + /3 ' ' ' sC$ 7 7 7 7 + + + /99%//),//Z     ( + +%* " + + + + + + + + + + + + + + +  +=/5577%+P33)--c222233sA A,+A,1FFFF"G)) I3;I.I4 II II IIJ99 KK1OOOO"P** R4;R/R5 RR RR RRctj}tjt|||fd}||S)z;Start the background notification poller for a TUI session.TrrFr)rrPrrr)rrstoprs r@rrsJ ?  D(C !   A GGIII Krwcd5tdtddtdggd<tdtst dddn #1swxYwYdt dfd }tj|d  dS) Nrrr:rrrrr{c >d}g}d}d} ddlm}m}|Dd}tDd}Dd}|rt |}t EtD}tDDdd}t|>F} t| trud| vrpddl m } dd lm} | t!?d d p t#t!?d d pd t!?d d pd t!?dd pd t!?dd} | | ||| } | jrt'dEdd| jpdi | ||n#t,$rYnwxYw|t/|t1|Dd5dDd<t3jDd<t5Ddddn #1swxYwYt'dEt7?DdS| j} | }BrS ddlm}m}ddl m!}m"}ddl#m$}|}||||}t!?dd dkrd }n7#t,$r*}tKd!|tLj'"d }Yd}~nd}~wwxYw|d#kr || B\}}|r,tKd$tQ|d%tLj'"tSd&|Dr|}ntU| B}nU#t,$r8}tKd'|tLj'"tU| B}Yd}~nd}~wwxYwtU| B}DE>fd(}tW@|d)} d*tYj-?j.j/vr Dd|d*<n#t`tbf$rYnwxYw?j.|fi|}d}d}t|tdrt|d+tVrDd5tgDd,d}|Akr|d+Dd-<Ad.zDd,<n$tKd/Ad0|d1tLj'"d2}dddn #1swxYwYtiEDdd34|d5d }|d6rd6n|drdnd7} |sW|drB|d8s|d9rd:|d}|d;}!t|!tr(|!5r|!5}nt|}d7} |tm?| d<}"|r||"d=<|r||"d><to||}#|#r|#|"d?<Dd5t5Ddddn #1swxYwYt'd@E|"| d7krt|trq|5r\ ddAl8m9}$Ddpd }%|%r tudBpi}&tg|&dCdDpdD}'n#t,$rdD}'YnwxYw|$|%|'E}(|(;rt|(<|d3F})|)dpd }*|*rt'dGEdH|*dI|)dJr|)dKpd }+|+r|+}nJ#t,$r=},tKdLt{|,j>dM|,tLj'"Yd},~,nd},~,wwxYwDdN}-|-r| d7krt}.|.rwDdpE}/ |.@|/|-rdDdN<nC#tb$r+}0dDdN<tBdO|/|0Yd}0~0nd}0~0wt,$rYnwxYw| d7krt|tr|5rtFtrpF5r\ ddPlCmD}1|1tDdpEF|Dd-gn#t,$rYnwxYw| d7krt|tr|5rtr ddQlFmG}2|}3tjI|2|3fd3RJnW#t$rtLdSYn1t,$r%}4tLdT|4Yd}4~4nd}4~4wwxYwn@#t,$r2}4ddlM}5|5N}6 tjPtjQRtd3UttdVdWX5}7|7UdYt3jVdZd[Ed\|7U|6dddn #1swxYwYn#t,$rYnwxYwtKd]t{|4j>dM|4tLj'd3^t'dEdt|4iYd}4~4nd}4~4wwxYw | ||n#t,$rYnwxYw|t/|t1|Dd5dDd<t3jDd<t5Ddddn #1swxYwYt'dEt7?Dn# | ||n#t,$rYnwxYw|t/|t1|Dd5dDd<t3jDd<t5Ddddn #1swxYwYt'dEt7?DwxYw|rۉDd5Ddr ddddSd3Dd<dddn #1swxYwY t'd_EtCED|no#t,$rb}8tKd`t{|8j>dM|8tLj'"Dd5dDd<dddn #1swxYwYYd}8~8nd}8~8wwxYw ddalXmY}9|9ZD]\}:};Dd5Ddr)|9j[\|: ddddSd3Dd<dddn #1swxYwY t'd_EtCED|;#t,$rb}dM|<tLj'"Dd5dDd<dddn #1swxYwYYd}<~}=tKdct{|=j>dM|=tLj'"Yd}=~=dSd}=~=wwxYw)dNr)reset_current_session_keyset_current_session_keyrrrrr@)preprocess_context_references)get_model_context_lengthrrrxrrk_config_context_length)rxrrkconfig_context_length)r allowed_rootrorrrzContext injection refused.rFr rGr)decide_image_input_modebuild_native_content_parts)_read_main_model_read_main_providerrrycodex_app_serverrzA[tui_gateway] image_routing decision failed, defaulting to text: r\nativez.[tui_gateway] native image attachment skipped z unreadable path(s)c3HK|]}|ddkVdS)rr Nr3r)s r@rz2_run_prompt_submit..run..s1LLquuV}} ;LLLLLLrwz:[tui_gateway] native attach failed, falling back to text: cd5t|dddn #1swxYwYd|i}r|x}||d<td|dS)Nrrrz message.delta)rCfeedr)r?rrrrstreamers r@_streamz0_run_prompt_submit..run.._stream*s^,;;*7E:::;;;;;;;;;;;;;;;!5/,hmmE&:&:!: G*+GJ'osG44444s '++)conversation_historystream_callbackrr0r:rrz@[tui_gateway] prompt.submit: history_version mismatch (expected=z current=u1) — agent output NOT written to session historyuhHistory changed during this turn — the response above is visible but was not saved to session history.TrJfinal_responsercompleterpartialzError: last_reasoning)rrDrrhrrzmessage.complete GoalManagergoalsrrdefault_max_turns)user_initiatedrrrshould_continuecontinuation_promptz-[tui_gateway] goal continuation hook failed: r!rRz)Dropping pending title for session %s: %s)maybe_auto_title speak_textrz/voice TTS skipped: hermes_cli.voice unavailablezvoice TTS dispatch failed: %srrrru" === turn-dispatcher exception · ru · sid=r z[gateway-turn] r"r{z1[tui_gateway] goal continuation dispatch failed: rwz7[tui_gateway] completion notification dispatch failed: z-[tui_gateway] completion queue drain failed: )]rrrrrr rrrrJrr2agent.context_referencesrrArrrblockedrr&rr1r rr/rErragent.image_routingrragent.auxiliary_clientrrrrr6r7r8rrrr inspect signaturerun_conversation parametersr1r%rrrVr3rBrLhermes_cli.goalsrr is_activeevaluate_after_turnrr5r rrragent.title_generatorr_voice_tts_enabledhermes_cli.voicerrrr ImportErrorrr% format_excr(r)r*r+r,r-r.r0r_r|rwdrain_notificationsr}r)Gapproval_tokensession_tokensr goal_followuprr_profile_home_strrrrirrctx_lenr run_messagerrrr_tui_load_config_cfg_mode_img_exc_parts_skippedr run_kwargsrr status_notecurrent_versionrrlrrrrsid_key goals_cfggoal_max_turnsgoal_mgrdecision verdict_msg cont_prompt _goal_excrO_pdb _session_keyrrrspokenrr%r=r> _cont_excrw_evtsynth_n_exc _drain_excrrrr:imagesrrrrsG @r@rz_run_prompt_submit..runsH  Z F         54W]5KLLN1'-2HIIN ' N ; ;   I56GHH  C w''C !' * * *;;vr**D+D11HF&#&& %3&==RRRRRRIIIIII22E7B//C>3C3C$UJ;;Ar#E9b99?R$UJ;;Ar*17++ 43!$#*  ; %tyy'>'>(<;t !---n===    %*:666 "> 2 2 2( . .%* ")- &$W--- . . . . . . . . . . . . . . . .#}UG'D'D E E E E EK  &K1 O#RQQQQQ++--D33++--((**E uj"559KKK & ###f\dff Z#EEEEEE #H$$S+E+E"",,($! sQTU]Q^Q^ s s s%(ZLLVLLLLLW*0KK*Fvv*V*VK$SSScYacc!$'C66&R&R S#?vv"N"NK 5 5 5 5 5 5 5)-W #*J  1%2H I I TTT,3M,BJy)z*    +U+KFF:FFF!NK&$''< $fjj44d;; 0*-gkk:KQ.O.O*P*P*o==17 1CGI.9H19LG$566"!O-<!O!OGV!O!O!O&)Z !H()>1eRVjj!1266zz-00HMM$*JJw$7$7GZ:G!4!4:JJx((:,2JJy,A,A::FJJw$7$799CZZ 011b#&&0288::0%'XXZZN&kk#"Z->->&QQG 6'5 $ 1%0 "%c400H /&. #( . .$W--- . . . . . . . . . . . . . . . $c7 3 3 3## 3(<(<###<<<<<<%kk-88>BG@0(1 (@(@(FBI-0{B1O1O1USU-V-VNN(000-/NNN0#.;'..<$$$$--//@'/'C'C #/3(D((H+3,,y*A*A*GRK*" %$3$'-3[$I$I!"!"!" (||,=>>@.6ll;P.Q.Q.WUW #.!@4?M C ??3CC7@CC Z{{?33H Fj00yy#*;;}#=#=#DL 11,II<7;GO4%480 G(#% *$$sC((%IIKK%tS))%JJLL % FFFFFF$$  M229c Ir22 !D*$$sC((%IIKK%'((% G;;;;;; F$) $egggg"VVVNN#TUUUUU GGGNN#BAFFFFFFFFG 5 5 5    ((**E  BGOOJ77$GGGG*cG<<<#GGS=)<==SSGJSSSGGENNN ###############      9$q''"299a99 RV     '3CFF 3 4 4 4 4 4 4 4 4# 5& !---n===    %*:666 "> 2 2 2( . .%* ")- &$W--- . . . . . . . . . . . . . . . .#}UG'D'D E E E E !---n===    %*:666 "> 2 2 2( . .%* ")- &$W--- . . . . . . . . . . . . . . . .#}UG'D'D E E E E  /( * *;;y))  * * * * * * * * &* "  * * * * * * * * * * * * * * * /os+++"3WmDDDD / / /?I/??3<?? ^,//).GI&///////////////  /  ? ? ? ? ? ?/CCEE 3 3 e^,..{{9--(9==dCCC.........*.GI& ............... 3/3///&sC%@@@@ 333=<<0==4:== Z !033-2 *333333333333333 3 3 3"    = ##,==0:==Z           sFh F F*)F*+H  HH8 hAJh K$ K h K hA)Mh N .M?:h?N,h1+OhO1.h0O11Ah A"R:. h:R>>hR>EhX7+ h7X;;h>X;?Ah^&A[/.^/ [>;^=[>>B^h _!3_h_Ah&ah b !a2-h2 b?hbAhA d)(h) d63h5d66Ah72f*)h*$g>h g>g94h9g>>ho, ml;'Ak6Ak: kk k k kl; kl;kAl;6o,;mo, m mm +ooo,r. o<;r< p rp  +r4+q+ r+q/ /r2q/ 3#r#ssss$"t u3;u. u u.u" "u.%u" &u..u37'z1w. zw." z.w2 2z5w2 6z:"xz z ';z"y4( z4y8 8z;y8 <z?zz  z {3{{Tr) r rrrrr>rrrr) rrrrrrrr:rs ```` @@@@r@r_r_s|  00wy)**gkk*;Q??@@gkk"3R8899%'!"'++o66== 0 $ / / / 000000000000000 G E /3VVVVVVVVVVVVp C---3355555sBB66B:=B:zclipboard.pastec t||\}}|r|S ddlm}m}n+#t$r}t |dd|cYd}~Sd}~wwxYw|dddz|d<tdz }|dd |d tj d d |dd z }||s=td|ddz |d<|rdnd} t|d| dS|dgt!|t|dt!|t#|ddt%|S)Nr)has_clipboard_imagesave_clipboard_imagezclipboard unavailable: rrrTrclip_rrH.pngz)Clipboard has image but extraction failedzNo image found in clipboardF)attachedrr)rr*r)rhermes_cli.clipboardrrr1rarrkrrrDr0rrrrr2rr) rrrrrrrimg_dirimg_pathrs r@rHrHPs%%LGS  >RRRRRRRRR >>>C<<<========> '{{?A>>BGOX%G MM$M... [(,..))/:: [ [W_=U [ [ [ \  ) )=#&q'/*BQ*F#G#G #"$$ / 7 7. 3Us;;<<< ("--44S]]CCC  MM!2344  (##    s" A AA A z image.attachc Vt||\}}|r|St|ddpd}|st |ddS ddlm}m}m}m }||} | r| d} | d} n/||\} } || } | t |dd | S| j |vrt |dd | j S| d gt| t|d t| t!|d | | p d | j ddt#| S#t$$r(} t |dt| cYd} ~ Sd} ~ wwxYw)Nr*rrMr)_IMAGE_EXTENSIONS_detect_file_drop_resolve_attachment_path_split_path_input remainderrzimage not found: zunsupported image: rT[User attached image: r)rr*rrrr)rr2rr3rarrrrrrrrErrrrrr1)rrrrrrrrrdropped image_pathr path_tokenrs r@rHrHxs1%%LGS  fjj$$* + + 1 1 3 3C 0C/// '            $#C((  I J ,II$5$5c$:$: !J 11*==J!C'G:'G'GHHH   " " $ $,= = =T#J#J#JKK K,b1188ZIII  JW%6788&!P%Pjo%P%P%P    j))      '''Cs1vv&&&&&&&&'s,#AE6<3E60BE66 F(F#F(#F(ii r))sPNG  r)s.jpg)sGIF87a.gif)sGIF89ar)sBM.bmp _IMAGE_MAGICr mime_prefixcNddl}ddl}|}|d||d||j}|r|d}|dd|} ||d S#t$rYdSwxYw) zDecode a base64 (optionally data-URL-wrapped) payload. Accepts ``data:...;base64,`` plus embedded whitespace. Returns the decoded bytes, or ``None`` when the input isn't valid base64. rNz^data:z[a-zA-Z0-9.+-]*;base64,(.*)$r\s+rTvalidate) base64rer3matchescapeDOTALLgroupsub b64decoder1)rr_base64_recleanedrgs r@_decode_attach_base64r s iikkG G#**[))GGG   A  ''!**ggfb'**G  4 888 tts?B B$#B$ img_bytesfilenamec|r*t|j}|r|S|dd}|dr|dddkrdStD]\}}||r|cSdS) zResolve an image extension from a filename hint, else magic bytes. Falls back to ``.png``. WebP needs the RIFF/WEBP container check, handled before the generic table. NrsRIFFrK sWEBP.webpr)rrrr0r)r rrrsigexts r@_sniff_image_extrs h&,,..  M SbS>D wD2J'$9$9w S ??3   JJJ  6rwcp ddlm}t|S#t$rthdcYSwxYw)Nrr>.jpegrrrrr)rrr_r1rs r@_allowed_image_extensionsrscM))))))*+++ MMMKKKLLLLLMs 55rrc|dddz|d<tdz }|ddtjd}||d|d|d|z } ||n+#t$rtd|ddz |d<wxYw| d g t||S) a#Write image bytes into the gateway's images dir and queue them. Mirrors what ``image.attach`` does for a local path: appends to ``session["attached_images"]`` so the next ``prompt.submit`` picks it up via the existing native-image-attach pipeline. Returns the written path. rrrrTrrrHr) rrkrrrDr0 write_bytesr1rrrr2)rr rrrr;rs r@_queue_attached_imagers '{{?A>>BGOX%G MM$M...   1 1BFIIRII'/*BICIIIHY'''' #&q'/*BQ*F#G#G   ("--44S]]CCC Os :B(B8zimage.attach_bytesc t||\}}|r|St|dp|dpd}|st |ddSt |d}|t |d d S|st |d d St |tkr/td z}t |d dt |d|dSt|ddpd}t|ddpd}|r| dsd|z}t||p|rd|nd} | tvrt |dd| S t||| d} n+#t$r} t |dd| cYd} ~ Sd} ~ wwxYwt|dt| t |ddd| jdt |dt!| S) uAttach an image to the session from base64 bytes (remote-client path). A desktop app or web dashboard running on a DIFFERENT machine than the gateway can't hand us a local path — that file only exists on the client's disk. So it uploads the raw image bytes (base64) and we write them into the gateway's own images dir. The response shape mirrors ``image.attach`` so the client treats both identically. Params: content_base64 / data (str, required): base64 image bytes. Accepts a ``data:image/...;base64,`` prefix and embedded whitespace. ``data`` is an accepted alias for older desktop builds. filename / ext (str, optional): extension hint. Without it, magic bytes identify PNG/JPEG/GIF/WebP/BMP, falling back to ``.png``. content_base64r}rrzcontent_base64 requiredzimage/rNrdata is not valid base64zimage is emptyr[zimage too large ( bytes; cap is  MB)rrrqxrzunsupported image extension: uploadrrzwrite failed: Trrr)rr*rrrbytes)rr2rr3rar r_ATTACH_BYTES_MAX_BYTESrr0rrrr1rrEr) rrrrraw_b64r mbrext_hintrrrs r@rHrHs"%%LGS  &**-..J&**V2D2DJKKQQSSG :C8999%g8DDDIC9::: 1C/000 9~~/// $ 5CZ3y>>ZZRTZZZ[[[6::j"--344H6::eR((.B//5577==??H"++C00"> 9h&VX3U>x>>>SU W WC +----CDsDDEEE5()SRRR 555C333444444445  MM!2344=X]===^^   (##    s<G G8G3-G83G8z pdf.attachc| ddl}ddl}ddl}t||\}}|r|S|dt |ddSt |ddpd}t |dp|d pd}|s|st |d d S| d 5} t| } |rt|d} | t |ddcdddS| st |ddcdddSt| tkr;tdz} t |ddt| d| dcdddS| dddkrt |ddcdddS| dz } | | t |ddpd}n4 ddlm}||}n#t"$rd}YnwxYw|!t|s t |dd |cdddSt|jd!kr2t |dd"t|jcdddSt|jtkr+tdz} t |dd#| d$cdddSt|} | j} t1|d%pd&}|d'}|t1|nd}n4#t2t4f$r t |d d(cYcdddSwxYw|d&krt |d d)cdddS| |t6zd&z }||krt |d d*cdddS||z d&zt6kr&t |d+d,t6d-cdddS| d.z }dd/d0d1d2t |d3t |t | t |g } |j|d4d4d5|j6}n-#|j$r t |dd7cYcdddSwxYw|jdkro|j p|j!pd"d8d}t |dd9d:#|zcdddStI| %d;}|st |dd<cdddSg}|D]}|j&'d=d&d>} t1|}n"#t4$r|t|z}YnwxYwtQ||)d?d@| }|*t ||dAtW|tY|d4|t||t|dBdC|dDt|dEdFcdddS#1swxYwYdS)GaAttach a PDF by rendering each page to PNG and queuing the pages. Anthropic's vision pipeline accepts images, not PDFs, so this runs ``pdftoppm`` (poppler-utils) at 150 DPI per page and queues each rendered page as an attached image. Accepts either a host ``path`` (local mode) or base64 ``content_base64`` (remote upload). Caps at 50 MB / 25 pages per call. Requires ``pdftoppm`` on $PATH (``apt install poppler-utils``); returns 5028 if missing. rNpdftoppmz7pdftoppm not installed (poppler-utils package required)r*rrr}rzpath or content_base64 required pdf_attach_r%zapplication/pdfrrrzdecoded PDF is emptyr r[zPDF too large (r!r"s%PDF-z0payload is not a PDF (missing %PDF- magic bytes)z input.pdfrz uploaded.pdf)rrzPDF not found: z.pdfz not a PDF: zPDF too large; cap is z MB first_pager last_pagez%first_page/last_page must be integerszfirst_page must be >= 1zlast_page must be >= first_pagezpage range exceeds cap of z pages per attach callrz-pngz-r150z-fz-lTr`)r rrrzpdftoppm timed out (>120s)zpdftoppm failed: z | z page-*.pngz)pdftoppm produced no pages (corrupt PDF?)-rrpdf_p)r*rrz[User attached PDF: rz page(s))])rrpages_attachedrrr)-shutilrtempfilerwhichrar2rr3TemporaryDirectoryrr r_PDF_ATTACH_MAX_BYTESrrrr1is_filerrrEr.st_sizerr1r%_PDF_ATTACH_MAX_PAGESrrTimeoutExpiredrr8rr4r&rrGstemrr read_bytesrrr)rrr8rr9rrrPr(tdtd_path pdf_bytesr)pdf_path display_namerr~r0last_page_paramr1 out_prefixrresrrattached_pagesrepage_numpage_intdsts r@rHrH9s MMMOOO%%LGS   ||J'CXYYY6::fb))/R006688H&**-..J&**V2D2DJKKQQSSG BGBC@AAA  $ $M $ : :W br((  )-gCTUUUI C'ABB W W W W W W W W  ?C'=>>W W W W W W W W 9~~ 555*{;C'`Y'`'`XZ'`'`'`aaW W W W W W W W !}((C'YZZW W W W W W W W ,H   + + +vzz*b99K^LLLL 88888833H==    tH~~'='='?'?C'C'C'CDD1W W W W W W W W 2H~~$**,,66C'JT(^^5H'J'JKK5W W W W W W W W 6H~~""$$,/DDD*{;C'G'G'G'GHH;W W W W W W W W <H~~H#=L LVZZ 55:;;J$jj55O0?0KO,,,QUII:& L L LT#JKK K KMW W W W W W W W J L >>T#<==SW W W W W W W W T  "%::Q>I z ! !T#DEE[W W W W W W W W \ z !A %(= = =T#m@U#m#m#mnn_W W W W W W W W bv% e #j//4Y MM3z??   A *.dsZdZlmmmCC( A A AT#?@@ @ @uW W W W W W W W r A >Q  J2#*299;;FFHHMDT#6D9I9I#IJJ{W W W W W W W W ~',,|4455 PT#NOOCW W W W W W W W F \ \Cx~~c1--b1H <x== < < <%N(;(;; <'1A1A6RdZbRdRdeeeC  ! !3s88X"Z"ZUXIYIY"Z [ [ [ [  ("%n"5"5'W%6788^|^^s>?R?R^^^      [W W W W W W W W W W W W W W W W W W s76Z1:Z1AZ1,Z1AZ1H+*Z1+ H:7Z19H::9Z1AZ1A Z16Z1 A NZ1"O <Z1 O  Z11%Z1#*Z1AZ1 R;:Z1;S%Z1$S%%A0Z1"4Z1#'Z1 WZ1W:7Z19W::B*Z11Z58Z5cddl}t|da|rt|s|Sd|vrd|dSd|vrd|dSd|vrd|dS|S)zQuote a context-ref value when it contains whitespace or bracket chars. Mirrors the desktop ``formatRefValue`` so the staged ``@file:`` ref round-trips through ``agent.context_references`` cleanly. rNz[\s()\[\]{}<>"'`]rrr)r _ATTACHMENT_REF_NEEDS_QUOTING_REcompiler)rr s r@_format_ref_valuerRs (/+.;;7O+P+P( 8??FF  %5||| %5||| %5||| Lrwrcjtt|} ||}t |t jdS#t$r$t |cYSwxYw)zKWorkspace-relative path for an attachment, or the absolute path if outside.r) rrrjrOr2rr(sepr%)rr workspacerels r@_attachment_ref_pathrWs\'**++3355I%nn**9553xx,,, %%%6>>##$$$$$%sAB+B21B2ctt|dz dz }|dd|S)Nz.hermeszdesktop-attachmentsTr)rrrjr)rr#s r@_desktop_attachment_dirrYsI  W%% & & . . 0 09 >  .,D (^^ "FG4 ; ;' ;6 ; ;;$$&& "! !1  rwc(|sdS ddlm}m}m}n#t$rYdSwxYw||}|r't |dS||\}}||}|!t |ndS)z> ! ! # # #Es  data_urlclddl}ddl}ddl}|pd}|d||j|jz}|r|d}|dd|} | |dS#t|j f$r}td |d}~wwxYw) u,Decode a ``data:;base64,`` payload to bytes. Unlike ``_decode_attach_base64`` (image-mime-specific), this accepts any media type — text/csv, application/pdf, etc. — so non-image file uploads round-trip. Also tolerates a bare base64 string with no data-URL prefix. rNrz-^data:[^;,]*(?:;[^;,=]+=[^;,]+)*;base64,(.*)$rrTrzinvalid data_url payload) rbinasciirr3rrIrrrr%Error)rdr  _binasciir r rgrs r@_decode_attachment_data_urlrjs    ~2$$&&G BGSZZ]Z_M_``A''!**ggfb'**G>  4 888   (>>>344#=>s6B B3B..B3rPc\tt|}t|}|E |||dfS#t $r|}|j}YnVwxYw|st dt|}t|p"tt|pdj}t|}t|t|} | || dfS)uMake a desktop file attachment available to the remote gateway agent. Three cases: 1. The path resolves to a file already INSIDE the session workspace — use it as-is (no copy, ``uploaded=False``). 2. The path resolves to a gateway-visible file OUTSIDE the workspace — copy it into ``.hermes/desktop-attachments/`` so the ``@file:`` ref resolves. 3. The path doesn't exist on the gateway (the common remote case: it's a path on the CLIENT's disk) — decode the uploaded ``data_url`` bytes and write them into ``.hermes/desktop-attachments/``. Returns ``(stored_path, uploaded)``. NFz2file not found on gateway and no data_url providedrT)rrrjrcrOr%rBrErjr\r2rYr`r) rrPrdrErUr~rr upload_dirrs r@_stage_session_file_attachmentrms0(\'**++3355I/99H %   + + +U? " % % %))++G}HHH % SQRR R-h77,T-ST#hn":M:M5N5N5STT(11J $Z1J81T1T U UF w >>  T !!sA%BBz file.attachc t||\}}|r|St|ddpd}t|ddpd}t|ddpd}|s|st |ddS t ||||\}}t ||} t|d|jt|| d t| |d S#t$r(} t |d t| cYd } ~ Sd } ~ wwxYw) aBStage a non-image file attachment into the session workspace. The image/PDF path renders to vision tiles; this one keeps the file as a readable artifact and returns a workspace-relative ``@file:`` ref so the agent's file tools (and ``agent.context_references``) can read it. Solves the remote-gateway case where the desktop passes a path that only exists on the CLIENT's disk: the client uploads ``data_url`` bytes and we materialize the file on the gateway. Params: session_id (str, required) path (str): client/host path of the file (used for naming + local-mode gateway-visible resolution). data_url (str): ``data:;base64,`` upload of the file bytes, required when the path isn't visible to the gateway. name (str, optional): preferred filename. r*rrdrErzpath or data_url required)rPrdrET@file:)rrEr*ref_pathref_textuploadedr-N) rr2rr3rarmrWrrErRr1) rrrrrrdrE stored_pathrrrprs r@rHrH?s&%%LGS  fjj$$* + + 1 1 3 3C6::j"--344::< cH4! ! !  X(==  #(K(($B%6x%@%@BB$       '''Cs1vv&&&&&&&&'sAD22 E$<EE$E$z image.detachct||\}}|r|St|ddpdst |ddS|dg}t |}fd|D|d<t|t |d|kt |ddS)Nr*rrrMrc g|] }|k| Srvrv)r4r*rs r@r6z_..xs!I!I!I4TS[[$[[[rw)r;r)rr2rr3rarrr)rrrrrbeforers @r@rHrHns%%LGS  fjj$$* + + 1 1 3 3C 0C///    12 6 6F [[F!I!I!I!I6!I!I!IG   G$56776A!2344    rwzinput.detect_dropc t||\}}|r|S ddlm}t|ddpd}||}|st |ddiS|d}|d}|d r|d gt||p d |jd } t |d d t|t|d | dt|Sd|d |rd|ndz} t |d dt||j| dS#t$r(} t|dt| cYd} ~ Sd} ~ wwxYw)Nr)rrrmatchedFr*ris_imagerrrT)rxryr*rrz[User attached file: r)rxryr*rErr) rrrr2rrrrrErrr1ra) rrrrrrr drop_pathrrrs r@rHrHs,,LGS  ''))))))&**VR((.B//##C(( 0sY.// /FO K( :     0" 5 5 < .runsp-g<;P;PQQQ 3 ) ) ) ) ) )W*77+;WEE!  %&&fd33) #3S[[AAA [[         %#]q]];;          #> 2 2 2 2 2 "> 2 2 2 2s0BB21C12 C<CC1CC11DTrr) rrrarMrNrOrrrr)rrrrrrrrs @@@@r@rHrHs%%LGS  ::fb))6::lB+G+GLD& 0C///*DJLL$RaR(**G33333333@C---33555 sY( ) ))rwzpreview.restartcb t||\ }|r|St|dpd}t|dpd}t|dpd}|st |ddSdt jjdd |d dt  t }d d d dd |d|pdd|rd|nd|rdnd|rdndddddddddddddddfD |r.s> 8 = rwz8The desktop preview pane cannot load a local server URL.z Preview URL: zCurrent working directory: rzPreview console: uCThe conversation history above is from the user's main session — including the commands you (the assistant) previously ran to start servers, edit files, or check ports. Use it to figure out exactly which server should be running at this Preview URL. The user did not start a brand new task; recover what they had working.zPRestart exactly the app intended for the Preview URL, not Hermes Desktop itself.zcThe Preview URL and port are the target. Preserve that target unless you conclude it is impossible.zIf the prior conversation shows a specific command that bound this URL/port, prefer re-running THAT exact command (in the same cwd) over guessing a new one.zFirst inspect what process, if any, owns the Preview URL port. If a stale server exists, inspect its cwd and prefer that cwd over the Hermes/Desktop process cwd.zThe Current working directory is only a hint. Do not assume it is the preview app root when the port owner or files indicate another root.zIf the console shows a module-script MIME error for src/main.tsx or similar, a static server is serving source files. Do not restart python -m http.server or any dumb static server for that app.zFor module-script MIME failures, inspect package.json/vite config in the candidate app root and start the real dev server/bundler (for example npm/pnpm/yarn dev) so module transforms happen.zBefore declaring success, verify the Preview URL responds with the intended app, not Hermes Desktop. If it serves Hermes/Desktop UI or another unrelated app, stop that process and report failure.z8Do not modify files. Do not ask the user unless blocked.z@Prefer existing project scripts or commands when they are clear.z:If a stale process owns the needed port, handle it safely.zOStart long-running servers detached/in the background, then return immediately.zLDo not run a foreground dev server command that blocks this background task.zaKeep the final response short: what command/server was started, or why it could not be restarted.cLt pt } ddlm}ddlm} r| d i rdt dnd}td  d |d |dit d  t  pd }t|tr#| dt|nt|}td |d n.#t$r!}td d|d Yd}~nd}~wwxYw ddlm}| n#t$rYnwxYwt#|dS# ddlm}| n#t$rYnwxYwt#|wxYw)Nrrrrrz (with z$ parent-session messages of context)rrzStarting hidden restart agentrr)rrrrzpreview.restart.completer)clear_task_env_overridesrv)rrrrrrrrrrrrrrr2r1rr)rrr history_noterrrrrparent_history preview_cwdrirrs r@rz_..runs.gK<` 2 2 2 2 2  HHHHHH((1111     "> 2 2 2 2sfC)D E/ D8D3.E/3D88E/<E EE/F#1FF# F F#FF#Trr)rr2rr3rarMrNrOrrr&r(r*ryrzr{r1rrrr)rrrr'rr has_historyrrrrrirrs @@@@@@r@rHrHs%%LGS  fjj%2 & & , , . .C fjj%2 & & , , . .C&**Y''-2..4466G /C~.../)"1"-//G ZZ b ) )F-g66N~&&K YY G  !C ! ! >#*< > > .5 = * * * *2 !BBrVV ^ q k p Y Q M R F N H ] Z o5 FFBEMbgoobg&8&8&=&=>>>2  rw}}[99 K  03030303030303030303dC---33555 sY( ) ))s7A#G G*)G*cx|dd}t5t|}|s!t|dd|dcdddS|\}}||dt|<|dddn #1swxYwYt |ddiS)NrLrrz no pending z requestrr)rrQrOrarQrr)rrrrr,rHrRs r@_respondrSs <$$A  Q @T#>#>#>#>??2jjb))    sXt$ % %%s1B7BB#&B#zclarify.respondc$t||dS)Nanswerrrrs r@rHrH_s C * **rwzterminal.read.respondc$t||dS)Nrrrs r@rHrHds C ( ((rwz sudo.respondc$t||dS)Npasswordrrs r@rHrHjs C , ,,rwzsecret.respondc$t||dS)Nrrrs r@rHrHos C ) ))rwzapproval.respondc @t||\}}|r|S ddlm}t|d||d|dd|dd iS#t $r(}t |d t|cYd}~Sd}~wwxYw) Nrrr~rchoicerZrFri)rrrrrr1rar2)rrrrrrs r@rHrHts%%LGS  ';;;;;; 44M*JJx00 & 5% 8 8     '''Cs1vv&&&&&&&&'sAA++ B5BBBz config.setc )2|dd|dd}}t|dd}|dkr |st|ddS|r|drt|d d S|d `|dd}t||t ||}|r|S|d t|d d St |dd||t |dd}n6t dd di|t |dd}t|||d|d|dd|dddS#t$r(}t|dt|cYd}~Sd}~wwxYw|dkrt|pd 2|r|d nd} | t| dddk} ntdk} 2dvrt||| rdnddS2dvr| rdnd} n"2dvrd} n2dvrd} nt|dd|Sd} | dkrXd d!lm} | t| ddn t!}|st|dd"S| |} | t|dd#St#d$| | | dkrdnd| _t't| d%ipi}|dd|d&d| dkr|| || _t/|t1d'|ddt3| |t||| dS|d(krt|pd 22d)vrt||t5dS2d*vrt|dd+|St#d,2t||2dS|d-krgd.}|r"|d/t7n t7}|rR|d0krLt| } | |vrt|dd1|SnD ||}n#t:$rd2}YnwxYw||d3zt=|z} t#d4| |r'| |d/<|d } | | d-k| _t||| dS|d5krt|d6pd7 } d d8l m!}m"}m#}t|pd 2d9t d:t f2fd; }|dnd}tM|t&si}||d?d@dAk}||}t#dB|rdAnd@|rdCndD} tOt(D];\}}|d } | t1d'|t3| ||+st|ddx2St#dy|+|+tTj+dz<t|dy|+|+t|+d{S|d|vrd tK}|d}kr6|d~kr|ddd} n||d<|} t]|n|dkr|dd},tt|pd|\}-}.t#d|-t#d|.t|pd} t|,||.|-\}/}0n8t#d|||} |dkrt1ddt|| d}1|dkr |/|1d<|0|0|1d<t||1S#t$r(}t|dt|cYd}~Sd}~wwxYwt|dd|S)NrrrrrrRrr ruDsession busy — /interrupt the current turn before switching modelsrrr^rFrrr%r&)rrrr%r&rr{r>rr)rr>rtoggle>rr>rrzunknown fast mode: r)resolve_fast_mode_overridesz3fast mode is not available without a selected modelz)fast mode is not available for this modelzagent.service_tierrspeedrbusy>rr>rrrzunknown busy mode: zdisplay.busy_input_moder)rrrrrcyclezunknown verbose mode: rkrzdisplay.tool_progressrscoper)rNrOrPrr|c"dvrdSdvrdS| S)N>rDrrrT>rrrrFrv)rrs r@_resolve_togglez_.._resolve_toggle=s-4444555 5"{"rwglobal)_normalize_approval_mode approvalsrmanualrzapprovals.moderDr)rrrrHERMES_YOLO_MODErhr>rshowrsectionsTrr`r[r>rhider_rzunknown reasoning value: zagent.reasoning_effort details_modezunknown details_mode: z details_mode.rqzunknown section: thinking_mode>rrarfzunknown thinking_mode: zdisplay.thinking_modezdisplay.details_moderracompact tui_compactrzunknown compact value: zdisplay.tui_compact statusbar tui_statusbarrzunknown statusbar value: zdisplay.tui_statusbarmouserzunknown mouse value: zdisplay.mouse_tracking indicatorzunknown indicator: z; pick one of |zdisplay.tui_status_indicator>rworkdir terminal.cwdrr#rr)rrrr >rarirriclear custom_promptrzdisplay.personalityzagent.system_promptrzdisplay.raz skin.changed history_resetrunknown config key: )CrrMrarrr6rrr1r2r3rrrrmrrrr{rrrrrrrrrindexr%rrrrNrOrPrrrr r8rr(rrrr9rz _DETAIL_MODES_DETAIL_SECTION_NAMESr0rr_rrrrr,r&r*ryrzr{rryrrb)3rrrrrrinit_errrrr current_fastnvrrrcurrent_overridesrrrrrNrOrPrrr5apprrenablerr<rargrrrsection sections_cfg allowed_tmcfg0d0cur_bnv_brrpnamerrrrrs3 @r@rHrHsE2&& 7B(?(?CmmFJJ|R8899G g~~6 + ?C'=>>>' ;;y))^ ;;w''/!'L"!=!=J&z7;;;*7C88H('{{7++3#C/LMMM,JJ|R00,0 #???BB(()?@@@B G,,$& <44%eW55 *"*..9K*L*LMM(1158BJ12BBJNN#5t<<<BsC"yIIJJ J + + +T3q66** * * * * * * + k7 + ? ? ? ? ? ?ekr""((**0022Cn$$kk*4SWWY5G5G*N*NVCGGI&&&TV "'++j"9"94@@GKK +++ -1()'1$&. #!(I#504G,-3f = =>>>o%%kk*4SWWY5G5G*N*NVCGGI&&&TV "'++j"9"94@@GKK +++ -2()'/$&. #!(I#605G,-3f = =>>>++C00F~C'J5'J'JKKK 6 < < < 7;;w//;4: 1-g666"JJ|R00!''"2G<< sC#6677 7 + + +T3q66** * * * * * * + n "   # # % % + + - - ] " "T#CE#C#CDD Dkk(237793E3Et(L(LT#'')$$$RT'1'++j2I2I4'P'P XGKK # # #VX #%, # #G "HW  &  I#3b11222 ~~o&&3 ))C##A& / / /T#@w#@#@AA Akk(237793E3Et(L(LT#'')$$$RT'1'++j2I2I4'P'P XGKK # # #VX "   # # % % + + - - 7   Wd + + +".GJ $C N cNNNsC"5566 6 ] " "T#CE#C#CDD D " W*  I#3b11222 o "   # # % % + + - -AAABB Z  T#DU#D#DEE E12666 "",,JJK   3b11222 i%+2$$&&,,..{{$.txx /B/BD$I$I QTXXi rRVVM51122 . 9DD D[[DD E\\DDT#DU#D#DEE E/6663d.EddFFGGG k%+2$$&&,,..++//),,"7D11 9WWr#BFF?E$B$BCC . !U**BB D[[BB $ $ $BBT#Fu#F#FGG G126663b11222 g~~ ]rrE 99;;AACCkk(237793E3Et(L(LT#'')$$$RT)'22 . !U**BB + + +(-BBT#B5#B#BCC C2B7773b11222 k]rrE 99;;AACC ' ' 'XcXX388DU;V;VXX  8#>>>3c22333 000%+2$$&& 3T>22 2goobg005566w}}S!! OT#M#M#MNN N.#...%( >" "SH[\_H`H` a a    /// +++ChG##GGOT222BB+0C(B# %% **\266$9#ekr:J:JC$P$P!z!"7???!"7DDD&))&CWj%''# tt""2S"2"2E:::&==."lnn===,,Dm##(5_%##'DLsD>> ! + + +T3q66** * * * * * * + T7#77 8 88s$G7'GAG.%GCG H'H H HU U-,U-'E.b)Db)) c3ccc&Dm+.C m+; m+Bm++ n5nnnM7D-AR%R% ASR/ASS ASSASz config.getc b|dd}|dkr ddlm}m}t }|dd}t ||t|dkr||dnd|d S#t$r(}t|d t|cYd}~Sd}~wwxYw|d kr3dd l m }t |tt|d S|dkrtdpi} t|ddp| ddpd} t!| rd| ini} t || t#| dS|dkrt |dtiS|dkr2t |dtddiS|dkrGt |dtdpiddiS|dkrtdpidd} t| } t |d| t&vr| nt(iS|dkrHt |dtdpidpdiS|dkrt} t| dpid d!pd!}t+| dpid"d#rd$nd%}t |||d&S|d'krt |dt,|d(dx}r*t/|dd)dd*krd'nt1d*krd'nd+iS|d,krt |dt3iS|d-krt5hd.}ttdpid-d/pd/} | |vr| nd/}t |d|iS|d0krt5hd1}t} t| dpid0dpd} | |vr| }nht| dpid-d/pd/}|d2krdnd/}t |d|iS|d3krZt+tdpid4d#}t |d|rd5nd6iS|d7krmtd}t7|t8r|d8d9nd9} t |dt;| iS|d:kr@td}t |dt=|iS|d;krltd|S)?Nrrrkr)list_available_providersnormalize_providerrrr)rrkrirdr)rnrprojectrur)rr rrrirrarrrfrtui_status_indicatorrrrhrrmediumrFrr)rrrrr{rrrr>r_r`rarar>rrarfr`rrrrrrrrr4rtrRr)"rrmrrrrrrr1rar2rrrkrr3rrrr,_INDICATOR_DEFAULTrrMrrrr_rrrrrlr.r/)rrrrrrrnrr cfg_terminalrrnormr5rrr allowed_dmrrdmrcfg_paths r@rHrHfs **UB  C j + V V V V V V V V"$$EKKQ''E"8;E Q**58444I!9!9!;!;     + + +T3q66** * * * * * * + i8888883\!2!2?R?R?T?TUUVVV i {{z228b &**UB''L<+;+;E2+F+FL"MMSSUUc9ucllr::3/B3/G/GHHIII f}}39;;/000 h39;;???B#G#GHIII f}} 'IKKOOI66<"AA&)TTU    k {{y))/R445KRPP3xx~~%%''  d&777dd=O P    m  y{{y117R<<]KKUv V    kkk WWW   # ( ();X F F R(   SWWY''-2223CUKKLL FF  3&W==>>> f}} #,==L"1M1M#N#NNV G 4 4ndKK!""F%7$8$8J$F$F&&H      f}}3"7"9"9:;;; nBBBCC ++1r66~{SS  UWW UWW :%%SS;3" &&& oAAABB kk ##)r..CCIr J J UWW UWW *  BBWWY''-222>;OO#" ++B3" &&& i 9;;??9--388NN O O3""7$$%8999 k++//),,3=gt3L3L WGKK / / /RW 3"3C"8"89::: g~~++//),,3"9'"B"BCDDD g~~-/ *g8??;L;LSx}}77RST  * * *sWaL)) ) ) ) * T7#77 8 88s0A+B B<B71B<7B<<>];;^^z setup.statusc ddlm}t|dt|iS#t$r(}t |dt |cYd}~Sd}~wwxYw)Nr_has_any_provider_configuredprovider_configured)hermes_cli.mainrrrr1rar2)rrrrs r@rHrHs'@@@@@@3.5Q5Q5S5S0T0TUVVV '''Cs1vv&&&&&&&&'s,/ A!AA!A!zsetup.runtime_checkc  ddlm}ddlm}ddlm}|d}t |}|dpd}t|dpd }|s3|d kr-|d vr)t|d ||d |ddS|d} t| rd n"t| pd  } t| p0| dvp,|| p!t |d} | s@t|d ||d |dd|ddSt|d|d|d |ddS#t$r*} t|d t| dcYd} ~ Sd} ~ wwxYw)aStrict provider check: does the configured/default model actually resolve to a usable runtime? Unlike setup.status (which returns True if ANY provider auth state is discoverable, including indirect fallbacks like ``gh auth token`` for Copilot), this runs the same resolve_runtime_provider() call the agent uses on session creation. It returns ok=False with the auth error message when the user's configured model cannot actually be served, so UIs can surface onboarding before the user submits a doomed prompt. rr)has_usable_secretrNrrkrrbedrock>iam-roleaws-sdk-default-chainFrz!No Hermes provider is configured.)rrkrrrr>aws-sdkrrz No usable credentials found for rqT)rrkrr)rr) r)rhermes_cli.authrrrrrr2rr*r3r1) rrrrrr2rrkrr api_key_text credential_okrs r@rHrHs78HHHHHH555555@@@@@@**T:::"#?#?#A#ABB;;z**8jW[[**0b11" x9'<'<L B B  ($[[11$@    ++i((%g..NrrC 24F4F4L4L4N4N W   ,== ,  .. ,GKK **++   ($[[11%kk(33KKKK     #KK 33 W--!++h//       8883us1vv66777777778s,B$G'C G2A G G4 G/)G4/G4z process.stopc ddlm}t|d|iS#t$r(}t |dt |cYd}~Sd}~wwxYw)Nrrkilledi)r|rwrkill_allr1rar2)rrrwrs r@rHrHAs';;;;;;3#3#<#<#>#>?@@@ '''Cs1vv&&&&&&&&'s), AAAAz reload.mcpct|dd} t|dd}|s ddlm}|}t |t r|dnd}d}t |t r#t|d d}n#t$rd}YnwxYw|rt|d d d Sdd l m }m } || |r|d} ddl m } | td} | | _| r d| Dn t!| _n2#t$r%} t$d| Yd} ~ nd} ~ wwxYwt)d|ddt+| |t|ddrF ddlm}|ddn2#t$r%} t$d| Yd} ~ nd} ~ wwxYwt|ddiS#t$r(}t1|dt3|cYd}~Sd}~wwxYw)NrrconfirmFrrrTmcp_reload_confirmr%u⚠️ /reload-mcp invalidates the prompt cache (next message re-sends full input tokens). Reply `/reload-mcp now` to proceed, or `/reload-mcp always` to proceed and silence this prompt permanently.)rr)shutdown_mcp_serversdiscover_mcp_toolsr)get_tool_definitionsrrc*h|]}|ddS)rrErvr$s r@rz_..s!===qQz]6*===rwz:Failed to refresh cached agent tools after /reload-mcp: %sralways)save_config_valuezapprovals.mcp_reload_confirmz.Failed to persist mcp_reload_confirm=false: %srreloaded)rMrrrrrrr1rrrrrrrr\rvalid_tool_namesrrrrrrrar2)rrr user_confirm _load_configr _approvals_confirm_requiredrrrrnew_defs_excr9rs r@rHrHKs\mmFJJ|R8899GT'FJJy%8899   )IIIIII#|~~6@t6L6LVTXXk222RV $(!j$//Y(,Z^^>>>>> 8%@@@@ W W WOQUVVVVVVVV W3:./// '''Cs1vv&&&&&&&&'s%IA6C I CICI4&IAE#"I# F-F I FAI,G?>I? H. H)$I)H..I I5 I0*I50I5z reload.envc ddlm}|}t|dt|iS#t$r(}t |dt |cYd}~Sd}~wwxYw)uRe-read ``~/.hermes/.env`` into the gateway process via ``hermes_cli.config.reload_env``, matching classic CLI's ``/reload`` handler. Newly added API keys take effect on the next agent call without restarting the TUI. The credential pool / provider routing for any *already-constructed* agent does not auto-rebuild — that's the same behaviour as classic CLI's ``/reload``. Users who want a brand-new credential resolution should follow with ``/new``. r) reload_envrrN)rrrrr1rar2)rrrrrs r@rHrHs'000000 3CJJ/000 '''Cs1vv&&&&&&&&'s.1 A#AA#A#>set-homerZapprovesethomecommands _TUI_HIDDEN))/compactToggle compact display modeTUI)/logsShow recent gateway log linesr)/mouse;Set mouse tracking preset [on|off|toggle|wheel|buttons|all]r)z /sessionsz Switch between live TUI sessionsr _TUI_EXTRA>rIrplanundorretryr_PENDING_INPUT_COMMANDSr snap_WORKER_BLOCKED_COMMANDSzcommands.catalogc R ddlm}m}m}g}i}g}i}g} |D]} | jt vs| jrd| j} | || <| jD]} | |d| <|| } | | | g| j }||vrg||<| ||| | | gtD]X\}} }| || g||vrg||<| ||| || gYd} t dipi}t|trR|rOd}||vrg||<| |t!|D] \}}t|tsd|}|||<| dd}|dkrd | d d}n$|d krd | d d}n|pd}t%| dp|}|ddt'|dkrdndz}| ||g|| ||gn#t($r}|sd|}Yd}~nd}~wwxYwd} ddlm}t!|D]d\}}t%| dd}| ||ddt'|dkrdndzg|dz }en#t($r}d|}Yd}~nd}~wwxYw| D] }| |||d!d|D}t/|||||||dS#t($r(}t1|dt%|cYd}~Sd}~wwxYw)uGRegistry-backed slash metadata for the TUI — categorized, no aliases.r)COMMAND_REGISTRY SUBCOMMANDS_build_descriptionrrquick_commandsz User commandsrexeczexec: raliasu alias → rz quick command descriptionNr`rz&quick_commands discovery unavailable: )scan_skill_commandsSkillrzskill discovery unavailable: )rEpairsc*i|]\}}||ddSrrvrs r@rMz_..4s&77741aq!AAA$777rw)rrcanon categories skill_countr)hermes_cli.commandsrrrrEr gateway_onlyraliasesrcategoryr rrrrrr8r2rr1rrrra) rrrrr all_pairsrrcat_map cat_ordercmdrJrrcatrErqcmdsbucketqnameqcrqtype default_descqdescrr rrZrr*rs r@rHrHsR]'          &( "!# .0! # + +Cx;&&#*:&CHA E!'')) [ + +)*g!ggmmoo&&%%c**D   aY ' ' ',C'!!!   %%% CL  D * * * *) . .OD$   dD\ * * *'!!!   %%% CL  t - - - - GKKOO$4b99?RE%&& 95 9(((&(GFO$$V,,,!' !6!699IE2%b$//! %e++C),E#))++&FF62..E'Gy"0E0E'G'G '))'JBFF8R4H4H'J'J ','? } 5 5 EFFE!$3$KCJJ4D4D55"ME$$c5\222FO**C<8888 G G G GF1FF G  : @ @ @ @ @ @!"5"5"7"7"="="?"?@@ ! !48899  !QttWQ#2%N!OPPPq  ! : : :9a99GGGGGG : D DC   sWS\BB C C C C77;#4#4#6#6777 "(*"       '''Cs1vv&&&&&&&&'suD:O4=F K O4 K%K O4 K%%O4+BN?O4 N NO4NAO44 P&>P!P&!P&rcF|sdS|d}|dkrdS|dkrdS|dkr3t|dkr |dd krd S|d kr3t|dkr |dd krd SdS)zKReturn user hint if this argv must not run headless in the gateway process.u^bare `hermes` is interactive — use `/hermes chat -q …` or run `hermes` in another terminalrsetupu?`hermes setup` needs a full terminal — run it outside the TUIgatewayu?`hermes gateway` is long-running — run it in another terminalr\rbrowseu_`hermes sessions browse` is interactive — use /resume here, or run browse in another terminalreditz5`hermes config edit` needs $EDITOR in a real terminalN)rr)ra0s r@_cli_exec_blockedr8Ds poo aB W}}PP YPP ZCIIMMd1gmmoo.I.Ipp X~~#d))a--DGMMOOv,E,EFF 4rwrbc |dg}t|trtd|Dst |ddSt |}|rt |d|dddS tjtj d d g|ddtt|d d d tjtjtj}|jpd|jpdg}dd|Dpd}t |d|j|dddS#tj$rt |ddcYSt0$r(}t |dt3|cYd}~Sd}~wwxYw)zXRun `python -m hermes_cli.main` with argv; capture stdout/stderr (non-interactive only).rc3@K|]}t|tVdSr)rr2)r4r#s r@rz_..Xs,,N,NAZ3-?-?,N,N,N,N,N,Nrwzargv must be list[str]Trr)rrr_rrzhermes_cli.mainriX)r rrrrrrc3K|]}||V dSrrvr)s r@rz_..hs'..aA.......rw (no output)FNi)rr_rrzcli.exec: timeout)rrr rrar8rrrr7rrrr(rrrrrr8r&r3rr@r1r2)rrrrrrnr5rs r@rHrHTs ::fb ! !D dD ! !9,N,N,N,N,N)N)N9C7888 T " "D S3D$bQQRRR' N ^T#4 |cYd}~Sd}~wwxYw|dpd}|st|d#d?S t d@pi}t7|dAdBpdB}n#t$$rdB}YnwxYw|||C}| }| r|dDkr%t|d|!dS|dEkr7|"dFG} | dHn dI| j#}!t|d|!dS|dJkrE|$} | t|ddKdSt|ddL| j#dMdS|dNvr?|%}"|&t|d|"rdOndPdS |'|} n+#tP$r}t|ddQ|cYd}~Sd}~wwxYwdR| j)dS| j#dT}#t|d |#| j#dUS|dVkr|st|d#dWS|d%rt|d&dXStU}$|$tW|dYZS|dd}%|%st|d#d[Sd*}&|pd }'|'rU t7|',d}&n,#tPtZf$rt|dd\|'d]cYSwxYw|&d*krd*}& |$.|%t_|&d^_}(n+#t$$r})t|dYd`|)cYd})~)Sd})~)wwxYw|(st|ddaSta|&d*z t/|(d*z }*|(|*db}+ |$1|%|+} nQ#tP$r})t|ddc|)cYd})~)Sd})~)wt$$r})t|dYdc|)cYd})~)Sd})~)wwxYw |$2|%},n#t$$rg},YnwxYw|d25t3|,|d(<t7|d3dd*z|d3<dddn #1swxYwY|d6}|tg|ddd}-|-+ |-4|%dded fn#t$$rYnwxYwt9|dgr& |5n#t$$rYnwxYwt9|dhr& t/|,|_6n#t$$rYnwxYw| dipi}.|.d.pd}/t1|/t2r+dj|/D}0d dk|0D}/t1|/t"sd}/| dld}1|*d*z}2|2d*krdmndn}3do|2d/|3dp|1dq}#t|dr|/|#dsS|dtvrI|r.|,d*ud nd}4|4dvvrt|ddwdSt|ddx|S)yNrErrrrrrrrTrN)shellr rrrrr!rr[z$quick command failed with exit code )rrrr)rrget_plugin_command_handlerresolve_plugin_command_resultplugin)rbuild_skill_invocation_messagerrskill)rrrE>rIrrXzusage: /queue send)rrrrzno active session to retryr ru:session busy — /interrupt the current turn before /retryrz!no previous user message to retryrrrrrrc3K|]H}t|tr1|ddk0|ddVIdS)rrrNrrrr)s r@rz_..sea&&,-55==F+B+Bfb!!+B+B+B+Brwzlast user message is emptyrr:rzusage: /steer ru7⏩ Steer queued — arrives after the next tool call: rz...rzno active sessionrzgoals unavailable: zno session keyrrrrrpausez user-paused)rz No goal set.u⏸ Goal paused: resumezNo goal to resume.u▶ Goal resumed: uT Send any message to continue, or wait — I'll take the next step on the next turn.>donerru✓ Goal cleared.zNo active goal.zinvalid goal: u⊙ Goal set (z-turn budget): u I'll keep working until the goal is done, you pause/clear it, or the budget is exhausted. Controls: /goal status · /goal pause · /goal resume · /goal clear)rnoticerr zno active session to undorrrVzno session key for undozundo: invalid count u — use /undo or /undo NrrWzundo: failed to load history: zno user messages to undorzundo: _memory_managerF)r resetrewound_invalidate_system_prompt_last_flushed_db_idxtarget_messagecg|]F}t|tr/|ddk0|ddGS)rrrrPr)s r@r6z_..sW&'a&&+,55==F+B+Bfb!!+B+B+Brwc3K|]}||V dSrrvr$s r@rz_..s'#:#:!#:A#:#:#:#:#:#:rw rewound_countrBturnsu ↶ Undid rz7 message(s)). Edit and resubmit, or send a new message.prefill)rrrU>rr maxsplit>rewindrestorez/snapshot restore is blocked in the TUI because it changes config/state on disk while the live agent has cached settings. Run it in the classic CLI, then restart the TUI.z"not a quick/plugin/skill command: )7rrrErMrrrrrr8r3rrarrrIrJr2r1rrrLrrrr r&rr rrrr status_linerRrrShas_goalrrr%rr rcr IndexErrorlist_recent_user_messagesrrrewind_to_messagerxron_session_switchrZr[)5rrrErr~rr+r.rrrIrJhandlerrrrLcmdsrrrrrZrrrTrrrrrrrrr5hadrUrrrarg_strrecentsr target_idx target_idrmm target_msg target_textrnr_ turns_undone turn_word subcommands5 r@rHrHs 62&&--c22FJJub4I4I#DT""H4mmFJJ|R8899G KKOO,b 1 1E u}} 4[ 66&>>V # #y"%%# ( AR88844b:8>r#eggete F |q  SSQ\SS sVv>>?? ? 66&>>W $ $sWx8L8LMMNN N          -,T22  M22773<<@@FsXV\r9J9JKKLL L M               #"$$$jj $;;00SG"S'++mR"@"@"@QSC  '#& $S fd ; ;       ~ =T#;<< <3C88999 w AT#?@@ @ ;;y ! ! TW ++i,, HT#FGG G s7||a'R00  Aqz~~f%%// ! 0  T#FGG G-(,,Y;; gt $ $ hh G  AT#?@@ @^ $ T T!(-!8GI ),W[[9JA-N-N)O)ORS)SG% & T T T T T T T T T T T T T T T3G<<=== w =T#;<< <(/9 G$$$T  WUG,,   ;;s++$*'K`cdgegdg`h'Ksvwzs{s{AtAtAjojoGI'K'K    3C88999 v~~ 8T#677 7 @ 4 4 4 4 4 4 4 @ @ @T#>#>#>?? ? ? ? ? ? ? @++m,,2 5T#344 4 ! 006BIIMM+r::@bAAII   III kW JJJ !!##yy{{ Kex//sVs7H7HIIJJ J G  II]I33E$)M..7W5:7W7WCsVs;;<< < H  JJLLE}3;O P PQQQ"nUZnnn    - - -,,..C IIKKK"58O11>O  ;GGCLLEE ; ; ;T#9C#9#9:: : : : : : : ; SU_ S SUZ S S S  v%* E E    v~~  @T#>?? ? ;;y ! ! TV YY :(4888 8kk-44  >T#<== = 9"##%%  d d *++ + d d dC'bg'b'b'bccccc d q55A I22;c!Rjj2QQGG I I IT#GA#G#GHH H H H H H H I ?T#=>> >QG q 011 J'-  1))+yAAFF 1 1 1Tccc$d;; f ef  f +f>f f  f## f21f2=.hg.git.svn.next.venv.cache .mypy_cache .ruff_cache .pytest_cachedistvenvbuildr __pycache__ node_modules _fuzzy_cachec tj}t5t|}|r(||dz t kr|dcdddSdddn #1swxYwYg} t jdd|ddgdd d t j }|j dkr8|j d d  }t jdd|dddddgdd d t j }|j dkr|j d d  dD]}|stjtj|||tjd}|drw||t-|t.krnn#t0t jf$rYnwxYw|s tj|d D]\} } } d| D| dd<tj| |} | D]^} | dkr| n| d| }||tjdt-|t.krn_t-|t.krnn#t0$rYnwxYwt5||ft|<dddn #1swxYwY|S)anReturn file paths relative to ``root``. Uses ``git ls-files`` from the repo top (resolved via ``rev-parse --show-toplevel``) so the listing covers tracked + untracked files anywhere in the repo, then converts each path back to be relative to ``root``. Files outside ``root`` (parent directories of cwd, sibling subtrees) are excluded so the picker stays scoped to what's reachable from the gateway's cwd. Falls back to a bounded ``os.walk(root)`` when ``root`` isn't inside a git repo. Result cached per-root for ``_FUZZY_CACHE_TTL_S`` so rapid keystrokes don't respawn git processes. rrNrrr z--show-toplevelT@F)r rr rrrzls-filesz-zz--cachedz--othersz--exclude-standardrz../) followlinkscNg|]"}|tv |d |#S)rq)_FUZZY_FALLBACK_EXCLUDESr0)r4r*s r@r6z$_list_repo_files..Ts? 888cARAR8888rwrq)r/ monotonic_fuzzy_cache_lockrr_FUZZY_CACHE_TTL_Srrrrrdecoder3rr(r*relpathr&rrTr0rr_FUZZY_CACHE_MAX_FILESr0r@walk)r#rDcachedfiles top_resultr list_resultr|rVdirpathdirnames filenamesrel_dirr>s r@_list_repo_filesrs .  C !!$''  cF1Io(:::!9 E) ^ D$ -> ?$      A % %#**7I>>DDFFC$.(  $ (K %**$+227IFFLLTRR  A! '//"',,sA*>*>EEMMC ~~e,,! LL%%%5zz%;;;< Z. /       02%0P0P0P  ,9% '//'488"A&#~~!!g3C3C3C3CCLLRVS!9!9:::5zz%;;;<u::!777E8    D  **!5\ T*************** LsI8A,,A03A0:E,G''H?HC K KK' LLLqueryc |sdt|fS|}|}||krdt|fS||rdt|fSg}d}|D][}|dvs0|r<|r:|ds |r|||dvr|nd}V||z }\|r|||D]<}||rdt|fcS=||vrdt|fSd}|D]9}|||kr+|dz }|t|krdt|fcS:d S) uRank ``name`` against ``query``; lower is better. Returns None to reject. Tiers (kind): 0 — exact basename 1 — basename prefix (e.g. `app` → `appChrome.tsx`) 2 — word-boundary / camelCase hit (e.g. `chrome` → `appChrome.tsx`) 3 — substring anywhere in basename 4 — subsequence match (every query char appears in order) Secondary key is `len(name)` so shorter names win ties. rrrrz-_.rrkrnN)rrr0isupperr) rErnlqlrnbufchr|rZs r@_fuzzy_basename_rankrjs 3t99~ B B Rxx3t99~ }}R3t99~ E C ;;2::<<;C;B8I8I; " S!!!%""RCC 2ICC  S "" 7799   # # "s4yy> ! ! ! " Rxx3t99~ A&& A;; FACGG||3t99~%%% 4rwz complete.pathc v |dd}|st|dgiSg} t|}|d}|r |ddn|}|r4|s2ddddd d d dd d d dd d ddddddddddg}t|d|iS|r |dvr|d}}n;|r1|dr|d\}} } | }nd}|r|n|}|r8|r5t |dkrd|vr |dkrg} t|D]w} tj | } | dr|dsLt| |}|_| || | fx| d|pd}| ddD]B\} } } | d|d| | tj | dCt|d|iS|rt|nd}|dks|sd\}}nZ|dr|d}}n@tj |pd}tj |}tj |r|ntj ||}tj |st|dgiS|dk}|}t+tj|D]}|r(||s-|r |t.vr9|r|s|drStj ||}tj |}|r||krtj ||tjd} |rdnd}|r |r d|d| |}n|r|rdnd}d|d| |}n||drDd tj |tj dz|z}n#|d!r d!| z|z}n| |z}| |||z|rd"nddt |dkrnn5#t8$r(}t;|d#t=|cYd}~Sd}~wwxYwt|d|iS)$Nwordrr8rrz@diffzgit diffrrrz@stagedz staged diffroz attach filez@folder:z attach folderz@url:z fetch urlz@git:zgit log>r#folder)zfile:zfolder:rrkrrrqcJ|dt|d|dfS)Nrr)r)rs r@rxz_..sqtS1YY!&=rwrr#rN)rqr~z~/z./dirr)rrrr0 partitionrr3rr(r*basenamerrrIr+rendswithisabsr&r{rrlistdirrrrrTrzr1rar2)rrrr8r# is_contextr prefix_tagrrHrrankedrVrranktagr` search_dirrwant_dir match_lowerr,rrArrrrs r@rHrHs@ ::fb ! !D '3" &&&Ex'v&&__S)) &0QRRD  .e . WjII"y-PP!h NN# OTT WkJJ WiHH EsWe,-- -  7%#555$)2 JJ  7E,,-ABB 7"'//#"6"6 J4IIJ!+6I  . .IOO%%&&!++9$$h&&=?F'-- 5 57++C00&&s++I4H4H4M4M+Hi@@< tS(34444 KK==K > > >&C$*3B3K   3 /C##+ " 4 4sWe,-- -T!T&!T&rc|||dS)Nrrv)rrs r@_details_completion_itemr% seT : ::rwneeds_leading_spacec0t|rd|n||S)Nr)r)rrrs r@_details_root_completion_itemr) s+ $*5 E    rwc|dsdS|}|rAd|dsdS|t dd}|dr |dd}||ddd}|rt dkr2r0gfd|Dt dd  fd DSt dkr3s1dg|d}fd |DSt dkrZrXdvr.D s@.--?)?rwrcycle global modec4g|]}t|d S)section overrider)r4rrs r@r6z(_details_completions..M sA./5G1Grwcg|];}|r$|kt||vrdn |dkrdnd.X s    ##F++  1:V0C0C %!H,,'&09W0D0D,,-   1D0C0Crwcfg|]-}t|dd.S)set r)rr)r4rrns r@r6z(_details_completions..g sJ)/HeAhnn6F6F/H/HIIrwrXclear overriderkcg|]l}|rU|kt||dkrdddnddmS)rXrrrr)r0rr)r4rrnrs r@r6z(_details_completions..p s    ##F++  1:V0C0C %!G++9U1X^^--88882a 0 022   1D0C0Crw)rr0r3rrrrr) rstrippedrmodes candidatesrrnrrs @@@@r@_details_completionsr2 s ::<< " ": . .tzz||H --hnn.>.>.D.D.F.Fq.IJJt J!! "D sABBx JJLLEs++=H /E  CJJ!OO(:O "   *,2D.D    (   $ 5zzQ1q!!1u1g11       (     5zzQ-%(..2B2Bh2N2N ! %W.RuQx~~7G7G.R.R.R S S    5zzQ1eAhnn6F6F(6R6Rq!!      /u.g..     Irwzcomplete.slashc |dd}|dst|dgiS ddlm}ddlm}ddlmdd l m dd l m |fd  fd  }||t|}fd||dDdd}|}ddddddddddddddddg} | D]M d|r0t! fd|Ds| Nt%|} | . s,>,>,@,@rwcSrrvrsr@rxz_.. s+<+<+>+>rw)skill_commands_providerskill_bundles_providercg|]@}|j|jr|jn|j|jr|jnddAS)rr)rr display_meta)r4rJrs r@r6z_.. sq     89yL==333af9:O an555R      rwrNrrrrzControl agent detail visibilityrrr r c3<K|]}|ddkVdS)rNrv)r4rextras r@rz_.. sI@@26V f -@@@@@@rwrr)r8 replace_fromr!)rr0rr"rprompt_toolkit.documentrprompt_toolkit.formatted_textrrragent.skill_bundlesrrget_completionsrrrrrr1rar2)rrrrr completerdocr8 text_lowerextras details_itemsrrrrrs @@@@r@rHrH s ::fb ! !D ??3  '3" &&&F'======444444??????;;;;;;999999))$@$@$@$@#>#>#>#>   htSYY''     ..sD99     2# ZZ\\ #%5   #%9    "7   !#U  ! , $ $EV}'' 33 $C@@@@:?@@@== $ U###,T22  $*;>$;;DJJsOOa$7$7CPTII  C4KKTZZ__q-@-@UV W W    '''Cs1vv&&&&&&&&'s%D:F->.F-- G7GGGz model.optionsc  ddlm}m}t|dd}|r|dnd}||rt |ddnd|rt |ddndp t|rt |ddnd }||d d d d d d }t||S#t$r(}t|d t|cYd}~Sd}~wwxYw)Nrbuild_models_payloadload_picker_contextrrrrkrrxrprrTr>)include_unconfigured picker_hintscanonical_orderpricing capabilities max_models) hermes_cli.inventoryrrrMrwith_overridesrrrr1rar2) rrrrrrrrrs r@rHrH sZ#'RRRRRRRR-- < < <==(/9 G$$$T "!##22?DLWUJ;;;"05=,,,2R.BRBR?DLWUJ;;;" 3  '& !%    3   '''Cs1vv&&&&&&&&'sCC D $DD D zmodel.save_keyc  ddlm}ddlm}m}ddlm}m}|dpd |dpd }r|st|dd S|rt|d d S|}|st|d d S|j dkr!t|d|j d|j dS|j st|dd|j S|j d} || |ddl} || j| <t |dd} | r| dnd} || rt%| ddnd| rt%| ddndp t'| rt%| ddnd} || dd}t)fd|dDd}||j dgddd }d|d!<t+|d|iS#t,$r(}t|d"t/|cYd}~Sd}~wwxYw)#aSave an API key for a provider, then return its refreshed model list. Params: slug: provider slug (e.g. "deepseek", "xai") api_key: the key value to save Returns the provider dict with models populated (same shape as model.options entries) on success. r)PROVIDER_REGISTRY) is_managedsave_env_valuerslugrrrzslug and api_key are requiredrgu-managed install — credentials are read-onlyrRzunknown provider: r;z uses u) auth — run `hermes model` to configurerXzno env var defined for NrrrkrrxrTr>)rrc34K|]}|dk|VdS)r Nrv)r4r|r s r@rz_..5!s1 B B1& T0A0AQ0A0A0A0A B BrwrF)r rE is_currentmodels total_models authenticatedr )rr rr r r rrrr3ra auth_typerEapi_key_env_varsr(rrMr rrnextrr1r2)rrr r r rrrpconfigrbr(rrrr provider_datarr s @r@rHrH sKD'555555@@@@@@@@RRRRRRRR 6""(b//11::i((.B5577 D7 DT#BCC C :<< TT#RSS S#''-- @T#>#>#>?? ?   ) )<33w'8333  ' MT#KW\#K#KLL L*1-w((( % 7 -- < < <==(/9 G$$$T!!##22?DLWUJ;;;"05=,,,2R.BRBR?DLWUJ;;;" 3  '& dr    B B B B , B B BD     # !!% M*. o&3]3444 '''Cs1vv&&&&&&&&'s=AH>*H>+H>2H>D+H>> I0I+%I0+I0zmodel.disconnectc ddlm}m}ddlm}|dpd}|st|ddS||}d}d}|r|jr|jD]} || rd }||}|s|st|d d |S|r|j n|} t||| d d S#t$r(} t|d t| cYd} ~ Sd} ~ wwxYw)zRemove credentials for a provider. Params: slug: provider slug (e.g. "deepseek", "xai") Returns success status and the provider's slug. r)r clear_provider_auth)remove_env_valuer rrzslug is requiredFTzno credentials found for )r rE disconnectedN) rr r rr rr3rar rErr1r2) rrr r r r r cleared_env cleared_authrR provider_namers r@rHrHI!s"'JJJJJJJJ666666 6""(b//11 7T#566 6#''--    'w/ '. ' '##B'''"&K+*400  G< GT#Et#E#EFF F(/9 T  % $      '''Cs1vv&&&&&&&&'s+A C AC(C C9C4.C94C9rc|ddd}|sdS|dt|dkr|dnd|d}}}hd}||vr|drd |S |d kr+|r)|r't |||}|d dS|d kr7|r5|r3t |t\} } t||| | nG|d krY|rWt} t| dpidd} | pd|_ d|_ n|dkrB|r@t||t||td|t||n|dkrM|rK|} | dvrd|_n | dvrd|_td|t||nM|dkr'|r%t%|dr|n |dkrddlm} | n#t.$r}d|cYd}~Sd}~wwxYwdS)z?Apply side effects that must also hit the gateway's live agent.rNrrrr>rricompressrr u=session busy — /interrupt the current turn before running /rrrrir@r rr>rrr>rrz reload-mcpreload_mcp_toolsrrzlive session sync failed: )rrrr3rr6ryrrr~rr>rIrVrrrr{r r r|rwrr1)rrrrnrErr_MUTATES_WHILE_RUNNINGrrrr5rrwrs r@_mirror_slash_side_effectsr z!s NN3   % %dA . .E r a ZZ!^^q    G#DLKK %%%'++i*@*@%UtUUU0 7??s?u?(gs;;F::i,, , ] " "s "u " 5c9;; G G E: )#w E J J J J X  % ++C%swww'7'7'=2&B&B?TV&W&WXXJ,6,>$E )*.E ' ' Z  E  %gs 3 3 3 ,S' : : : .#}UG'D'D E E E E V^^^99;;D~%%%/""***%)" .#}UG'D'D E E E E \ ! !e !?Q0R0R !  " " $ $ $ $ V^^ ? ? ? ? ? ?  % % ' ' ' 000/A////////0 2s%0IFI I,I'!I,'I,rdc t||\}}|r|S|dd}|st|ddS|dr|dn|}|d}|r|dnd}t|dkr|dnd}|tvrt|d d |S|tvrG|r.|ddnd} | d vrt|d d S dd l m } d|} | | vrt|d d| Sn#t$rYnwxYwd} d} |r) ddlm}m} ||} n#t$rd} d} YnwxYw| rd| rb | | |}t#|dt%|pdiS#t$r}t#|dd|icYd}~Sd}~wwxYw|d}|s t'|dt)|ddt+}t-|dd||n+#t$r}t|dd|cYd}~Sd}~wwxYw ||}t1|dd||}d|pdi}|r||d<t#||S#t$rS} |n#t$rYnwxYwd|d<t|dt%|cYd}~Sd}~wwxYw)NrrrX empty commandrrrbrr[z1pending-input command: use command.dispatch for />rdrezVsnapshot restore mutates live config/state; use command.dispatch for /snapshot restorerz(skill command: use command.dispatch for rHrr>zPlugin command error: rrrrrrQzslash worker start failed: r)rrr3rar0rrrrrrrrr1rrIrJrr2rrrrrr r)rrrrr) _cmd_text _cmd_parts _cmd_base_cmd_argrxr_cmd_keyplugin_handlerrJrIrrrrrrs r@rHrH!s%%LGS  **Y # # ) ) + +C 0C/// $'>>##6#6? 3CI!,,J",4A";;==I #J! 3 3z!}}H+++ V9VV   ,,,>FNX^^Q^//288:::B . . .h   ;;;;;;"y?? ))++ + +TPhPP  ,      N$(! 1 1         87 BBNN 1 1 1!N,0 ) ) ) 1F7F F22>>(3K3KLLFsXs6+B]'C'CDEE E F F FsX'C'C'CDEE E E E E E E F[[ ( (F F F! & G,,g~7G7GHHF 6::lB77& I I I I F F FT#D#D#DEE E E E E E E F 'C,VZZ b-I-I7TWXXV4}5  )!(GI 3   '''  LLNNNN    D "&Cs1vv&&&&&&&& 's>*E** E76E7FF&%F&.4G## H -HH H 'A)J J9J4.J94J9=AL M1L43M,4 M>M,M%M,&M1,M1_voice_event_sidctt5t}dddn #1swxYwYt|||dS)a4Emit a voice event toward the session that most recently turned the mode on. Voice is process-global (one microphone), so there's only ever one sid to target; the TUI handler treats an empty sid as "active session". Kept separate from _emit to make the lack of per-call sid argument explicit.N)_voice_sid_lockr) r)rrrs r@ _voice_emitr, "s|  %gs   cntjdddkS)aCurrent voice-mode flag (runtime-only, CLI parity). cli.py initialises ``_voice_mode = False`` at startup and only flips it via ``/voice on``; it never reads a persisted enable bit from config.yaml. We match that: no config lookup, env var only. This avoids the TUI auto-starting in REC the next time the user opens it just because they happened to enable voice in a prior session. HERMES_VOICErrDr(rrr3rvrwr@_voice_mode_enabledr0 "s+ :>>." - - 3 3 5 5 <>,b 1 1 7 7 9 9S @@rwct}t|tr|dnd}t|tr|niS)u*Shape-safe accessor for the ``voice:`` block in config.yaml. ``_load_cfg()`` returns raw ``yaml.safe_load()`` output, so both the root AND ``voice`` may be any YAML scalar / list / None. A hand-edit like ``voice: true`` or a malformed top-level config that parses to a scalar would otherwise break ``.get("…")`` and take every ``voice.*`` branch down with it (Copilot round-3..7 review on #19835). Coerce through ``isinstance`` at every level so malformed config falls back to an empty dict instead of crashing /voice. voiceN)rrrr)r5 voice_cfgs r@_voice_cfg_dictr6 /"sK ++C$.sD$9$9C   tI"9d33 ;99;rwctd}t|tr|rt|ndS)z@Current ``voice.record_key`` value, documented default on error. record_keyzctrl+b)r6 rrr2)r8 s r@_voice_record_keyr9 @"s? ""&&|44J(S99 Vj V3z???hVrwz voice.togglec|dd}|dkrtttd} ddlm}|}t |d|d<t |d|d<t |d|d<|d pd |d <n2#t$r%}t d |Yd }~nd }~wwxYwt||S|d vr|dk}|rdndtj d<|s^ ddl m}|n=#t$rYn1t$r%}t d|Yd }~nd }~wwxYwdtj d<t||ttdS|dkratst!|ddSt } | rdndtj d<t|dt| dSt!|dd|S)u3CLI parity for the ``/voice`` slash command. Subcommands: * ``status`` — report mode + TTS flags (default when action is unknown). * ``on`` / ``off`` — flip voice *mode* (the umbrella bit). Turning it off also tears down any active continuous recording loop. Does NOT start recording on its own; recording is driven by ``voice.record`` (Ctrl+B) after mode is on, matching cli.py's enable/Ctrl+B split. * ``tts`` — toggle speech-output of agent replies. Requires mode on (mirrors CLI's _toggle_voice_tts guard). actionr)rr8 ttsr)check_voice_requirementsrwaudio_available stt_availabledetailsrz2voice.toggle status: requirements probe failed: %sN>rrrrDrr. stop_continuousz3voice: stop_continuous failed during toggle off: %sr2 r< z"enable voice mode first: /voice onTiunknown voice action: )rr0 r9 rtools.voice_moder= rr1rrrr(rrrB rra) rrr; rr= reqsrrrB new_values r@rHrHG"sZZ( + +F +,,+--%''   T A A A A A A++--D#'(=(=#>#>GK )-dhh7H.I.I)J)JG% &'+DHH_,E,E'F'FGO $!%)!4!4!:GI   T T T NNOQR S S S S S S S S T 3    D.-4%" 1 Y<<<<<<!!!!    Y Y YTVWXXXXXXXX Y.1BJ) * "/11)++     "$$ IT#GHH H*,,, 09)Bs %&  /11       Ttst|ddSt5|dptad d d n #1swxYwYd d lm}t}|d }|d }t|ttfrt|ts|nd}t|ttfrt|ts|nd}|ddd||d} | durt|ddiSt|ddiSt5|dptad d d n #1swxYwYd dlm } | dt|ddiS#t$rt|ddcYSt$r(} t|dt!| cYd } ~ Sd } ~ wwxYw)aVAD-bounded push-to-talk capture, CLI-parity. ``start`` begins one VAD-bounded capture and emits ``voice.transcript`` after silence stops the recorder. ``stop`` forces transcription of the active buffer, matching classic CLI push-to-talk. The voice wrapper retains no-speech counts across single-shot starts, so three consecutive silent captures emit ``voice.transcript`` with ``no_speech_limit=True``. r; r>rrr2rD ru+voice mode is off — enable with /voice onrNr)start_continuoussilence_thresholdsilence_durationrXg@c&tdd|iS)Nvoice.transcriptrr, rs r@rxz_.."s 4FQR (T(Trwc&tdd|iS)Nz voice.statusrrN )r5s r@rxz_.."sK! $M$Mrwc&tdddiS)NrM no_speech_limitTrN rvrwr@rxz_.."s &):D(A))rwF) on_transcript on_statuson_silent_limitrJ rK auto_restartrr recordingrA T)force_transcribestoppedu9voice module not available — install audio dependencies)rrar0 r+ r) rrI r6 rrrKrrrB rr1r2) rrr; rI r5 thresholddurationsafe_threshold safe_durationstartedrB rs r@rHrH"sYZZ' * *F &&&C@@@AAA;' W  &(( VC'TUUU  P P#)::l#;#;#O?O  P P P P P P P P P P P P P P P : 9 9 9 9 9())I! &9::I }}%788Hi#u66"9d33  he 55>HSW>X>X  '&TTMM!!#1!."   G%36 2333sX{344 4 L L%zz,77K;K  L L L L L L L L L L L L L L L 544444....39-...     R      '''Cs1vv&&&&&&&&'s~%GGB: GB  G B CG#G5G<F% G%F))G,F)-&GH"1 H":HH"H"z voice.ttsc||dd}|st|ddS ddlm}t j||fdt|d d iS#t$rt|d d cYSt$r(}t|d t|cYd}~Sd}~wwxYw) Nrrir}rrTrrspeakingzvoice module not available) rrarrrrrrrr1r2)rrrrrs r@rHrH"s ::fb ! !D 0C///'////// $FFFLLNNN3:./// ===C;<<<<< '''Cs1vv&&&&&&&&'s$AA--B; B;B60B;6B;z insights.getc |dd}t}|t|dS tj|dzz fd|dD}t ||t |td |Dd S#t$r(}t|dt|cYd}~Sd}~wwxYw) NdaysrNr?rViQcJg|]}|dpdk| S)rrr3)r4r5cutoffs r@r6z_..#s?   l##(qV33 333rwrrVc3BK|]}|ddVdS)rPrNr3r^s r@rz_..#s0HHaoq 9 9HHHHHHrw)rd r\r0) rr rcr/r`rrsumr1rar2)rrrd rrbrrf s @r@rHrH#s ::fb ! !D B z$St4444'te|+    ***55     IIHH4HHHHH      '''Cs1vv&&&&&&&&'sA2B-- C7CCCz rollback.listct|\}}|r|S fd}t||S#t$r(}tdt |cYd}~Sd}~wwxYw)Nc|jstdgdStdd||DdS)NF)rrTcg|]D}|dd|dd|dddES)rrrr)rrrr3r(s r@r6z!_..go..2#sd$$$  %&EE&"$5$5)*{B)?)?'(uuY';';$$$rw)rrr)rrrs r@goz _..go+#st; G3E" E EFFF#$$ "%!5!5c!:!: $$$     rwr!)rrr1rar2)rrrrrl rs` r@rHrH$#s%%LGS  '     $!"--- '''Cs1vv&&&&&&&&'s/ A!AA!A!zrollback.restorect||\}|r|S|dd|ddst|ddSs&drt|ddS fd }t|t |S#t $r(}t|d t |cYd}~Sd}~wwxYw) Nrr file_pathrC hash requiredr ruIsession busy — /interrupt the current turn before full rollback.restorec~t||}|||pd}|drsd}d5dg}|rU|dddvr8||d z }|r|dddv8|r8|ddd kr||d z }|r)t d dd zd <dddn #1swxYwY||d <|S) N)rn r+rrrrr>rrrrr:history_removed)rrerrr) rrr~rrrrn rrs r@rl z _..goX#s/S&AAH[[h):Kt[LLFzz)$$ 4Y 4^,  %kk)R88G!%gbkoof&=&=AV&V&V 1 "%gbkoof&=&=AV&V&V%72;??6#:#:f#D#D 1  ,=q A ABBQF 12               -4()MsCD--D14D1r)rrrarrr1r2)rrrrl rrn rrs @@@r@rHrHB#s(%%LGS  ZZ # #F ;++I 0C///  Y//    W   '       (3)'266777 '''Cs1vv&&&&&&&&'s$B(( C2CCCz rollback.diffc t||\}}|r|S|dd st|ddS t| fd}|dddd}|dd|d }t ||d d }|r||d <t ||S#t $r(}t|d t|cYd}~Sd}~wwxYw)NrrrC ro cN||t||Sr)diffr)rrrs r@rxz_..|#s"SXXc+CCf+U+UVVrwrt r!r.)r.rt rrri)rrrarrKrr1r2) rrrrrrrrrrs @r@rHrHq#s1%%LGS  ZZ # #F 0C/// '   V V V V  eeFB&55,,c::sGKK$;$;<<  +"*GJ 3   '''Cs1vv&&&&&&&&'sBC C:C5/C:5C:ctjdd}|r|S ddlm}|}t |tr|dini}t |tr7t|ddpdSn#t$rYnwxYwdS)u6Return the configured browser CDP override without network I/O. ``/browser status`` must be fast — calling ``tools.browser_tool._get_cdp_override`` would invoke ``_resolve_cdp_override``, which performs an HTTP probe to ``.../json/version`` for discovery-style URLs. That probe has a multi-second timeout and would block the TUI on a slow or unreachable host even though status only needs to report whether an override is set. Mirrors the env/config precedence of ``_get_cdp_override`` (env var first, then ``browser.cdp_url`` from config.yaml) without the websocket-resolution step, so the answer reflects user intent even when the configured host is not currently reachable. The actual WS normalization happens in ``browser_navigate`` on the next tool call. BROWSER_CDP_URLrrrbrowsercdp_url) r(rrr3rrrrr2r1)env_urlrr5 browser_cfgs r@_resolve_browser_cdp_urlr{ #s$jnn.3399;;G 555555o0:30E0EMcggi,,,2 k4 ( ( E{y"55;<<BBDD D E      2sBC CCc |jpd}n#t$rYdSwxYw|jdv}|jdvo|jdvo|dko|S)uMatch the discovery-style local default; never the concrete WS form. A user-supplied ``ws://127.0.0.1:9222/devtools/browser/`` is a real, connectable endpoint — collapsing it to bare ``http://...:9222`` would strip the path and break the connect. rF>rr/json /json/version>wshttp> 127.0.0.1 localhost$)portr%r*schemehostname)rr discovery_paths r@_is_default_local_cdpr #s{{ b uu[$GGN '  O9 9  DL   s r'cddl} |j||5}dt|ddcxkodknccdddS#1swxYwYdS#t$rYdSwxYw)NrrrXrrIF)urllib.requestrequesturlopenrr1)r'rurllibrs r@_http_okr #s ^ # #C # 9 9 =T'$#66<<<<<<<< = = = = = = = = = = = = = = = = = = uus4AA AAAAA A)(A)cddd|j|j}|d|jd}|d|dgS)Nr https)r wss://rr~ r} )rr netlocr)rr r#s r@ _probe_urlsr #s`7 + + / / v} M MF ( ( ( ( / / 4 4D " " "tNNN 33rwc|jdr|S|ddddS)N/devtools/browser/r)r*rrfragment)r*r0geturl_replace)rs r@_normalize_cdp_urlr #sQ {233}} ??2R"? E E L L N NNrwr rcXddlm}|||}|rd|gndd|dg}d|dg|d S) Nr)manual_chrome_debug_commandzSStart a Chromium-family browser with remote debugging, then retry /browser connect:zNNo supported Chromium-family browser executable was found in this environment.zLInstall one or start a Chromium-family browser with --remote-debugging-port=z, then retry /browser connect.z Browser CDP is not reachable at rqujBrowser not connected — start a Chromium-family browser with remote debugging and retry /browser connect)hermes_cli.browser_connectr )r'r rr rrs r@_failure_messagesr #sFFFFFF))$77G  ^`ghh ] [_      23111    u rwrfc|dd}|dkr.t}t|t||dS|dkrt |S|dkrt |dd|St ||S)Nr; r connectedr' disconnectconnectrzunknown action: )rr{ rr_browser_disconnectra_browser_connect)rrr; r's r@rHrH#s ZZ( + +F &((3d3ii<<=== "3''' C:&::;;; C ( ((rwc Fddl}ddlm}ddlm}ddlm}|d}|;t|ts&t|ddt|j S|pd p|}|d pd|}gd d d td tddffd} |d|vr|nd|} | jdvrt|dd|S| jst|dd|S | jp | jdvrdnd} n$#t$$rt|dd|cYSwxYwt'| r|}||} | jpd} | jdvr| jdrlddl} | | j| fd5 dddn #1swxYwYnH#t0$r!} t|dd|d | cYd} ~ Sd} ~ wwxYwt3| }t5d!|D}|st'| rdd"lm}| d#|| |rCt9d$D]3}t;jd%t5d&|Drd'}n4|r| d(| npt?|| |d)dD]}| |d* tA|d+|d,S|st|dd|St'| r| d-| tC| }||tDj#d.<|n5#tH$r(} t|dt| cYd} ~ Sd} ~ wwxYwd'|d/}r|d0<tA||S)1Nr)DEFAULT_BROWSER_CDP_URLcleanup_all_browsers)urlparser'rz"browser url must be a string, got rrr)rBrrBr|cb|rtd||ddSdS)Nzbrowser.progress)rrB)rr)rrBr0rs r@announcez"_browser_connect..announce$sM     Q $cw+O+O P P P P P Q Qrwr zhttp://>r r r r zunsupported browser url: zmissing host in browser url: >r r irzinvalid port in browser url: r >r r r rrzcould not reach browser CDP at r!c38K|]}t|dVdS)rrNr r)s r@rz#_browser_connect..:$s/>>!Xa--->>>>>>rw)try_launch_chrome_debuguWChromium-family browser isn't running with remote debugging — attempting to launch...rrc38K|]}t|dVdS)g?rNr r)s r@rz#_browser_connect..F$s/HHAx3777HHHHHHrwTz7Chromium-family browser launched and listening on port rrF)r r'r0z5Chromium-family browser is already listening on port rv r r0)%rr r tools.browser_toolr urllib.parser rrr2rarr5r3rr r r r%r r*r0socketcreate_connectionr0r rr rr/rVr rr r(rr1)rrrr r r raw_urlr'rr rr r rprobesrr rHrrrr0rs @@r@r r #sOOOBBBBBB777777%%%%%%jjG:gs#;#; TDMM>v>>>>>B Y/77 YNNNNNNm+*488""2YY"" 3HHHHHHH"!%B!E"H]W[]]^^^^ 1#tV D DQRR H66 W555555(SS YC'N'N'NOOO&v.. YWQUWWXXX'// (2 $% '''Cs1vv&&&&&&&&'04J!G!GG'&  sG  sD,,E  E 6'MG<G > G GGGGM H!G=7H8M=HC)M,MAM NM?9N?Ncdd}|tjdd|t|ddiS)Nr|cJ ddlm}|dS#t$rYdSwxYw)Nrr )r r r1r s r@reapz!_browser_disconnect..reapl$sP  ? ? ? ? ? ? " " " " "    DD s  ""rv r Fr)r(rrr)rr s r@r r i$sZ DFFFJNN$d+++DFFF s[%( ) ))rwz plugins.listc ddlm}t|dd|jDiS#t $r(}t |dt|cYd}~Sd}~wwxYw)Nr)get_plugin_managerpluginsc \g|])\}}|t|ddt|ddd*S)r?rT)rErrrY)r4rrZs r@r6z_..$sV 1 !"#*1i#=#=#*1i#>#>rwr)rr r_pluginsr8r1rar2)rrr rs r@rHrHz$s'999999  !3 2 4 4 = C C E E      '''Cs1vv&&&&&&&&'sAA A5 A0*A50A5z config.showc L t}t}tjddp|dd}t |dkr d|ddnd}tjddp|d d}d d |gd |pd gd |ggdddt t|dgdd|dgpdgdt |ddggdddtj gdt tdz ggdg}t|d|iS#t$r(}t|dt |cYd}~Sd}~wwxYw)NHERMES_API_KEYrrrnz****z (not set)HERMES_BASE_URLrxModelzBase URLz (default)zAPI Key)rIrbAgentz Max TurnsrToolsetsrrrVerboserF Environmentz Working Dirz Config FilertrrQ)rrr(rrrr2rr&rrkrr1ra) rrr5rrmaskedrxrrs r@rHrH$s"'kk  *..!1266P#'')R:P:P*-g,,*:*:& &&& :>>"3R88SCGGJPR">?3773Er+J+J!K!K!TuUCGGIu$=$= > >?  '"BIKK0"C }(D$E$EF  # 23X./// '''Cs1vv&&&&&&&&'sE.E11 F#;FF#F#z tools.listc f ddlm}m}t|dd}|r&t t |ddgpgnt tpg}g}t| D]C}||}|s| ||d|d|r||vnd |d d Dt|d |iS#t$r(} t|d t| cYd} ~ Sd} ~ wwxYw)Nrget_all_toolsetsget_toolset_inforrrrrr!Tresolved_tools)rErr!rr\rr rr r rMrrrrrrrrr1rar2 rrr r rrr8rErrs r@rHrH$s'????????-- < < <== 5C(*> D0D+%D0+D0z tools.showc\ ddlm}m}t|dd}|rt |dddn t }||d}i}t|d D]}|d d } t|d d dpd dd} d| vr | d| ddz} | || pdg | | dt|dt|Dt|dS#t $r(} t#|dt| cYd} ~ Sd} ~ wwxYw)Nr)rrrrrrTrc|ddS)NrrErvrO s r@rxz_..$s* f0ErwrrrErrz. rrrErcg|] \}}||d S))rEr\rv)r4rErbs r@r6z_..$s4"d"D11rw)rrkr )rrrrMrrrrr2rrrrrr8rr1ra) rrrrrrr\rrrErrs r@rHrH$s #'JJJJJJJJ-- < < <== *GGG$&8$ ? ? ?'))  %$g$OOO5&E&EFFF  D #F+DtJ'++M2>>D"EEKKDQQRSTDt||2djj..223    4 4T : : Gi L L S S #'     &,X^^-=-=&>&>U       '''Cs1vv&&&&&&&&'sE6E99 F+F& F+&F+ztools.configurec Xt|ddpd}d|dgpgD}|dvrt |dd|S|st |dd S d d lm}m}d d lm }m }m }m } m } |} d |D| zd|D} d|D} fd| Dfd| D} | r|| d| || r || | |n t|| t|dd}|r$t!|dd|nd}t#| |dd}fd|D}t%||||t#t'|dS#t($r(}t |dt|cYd}~Sd}~wwxYw)Nr; rcg|]D}t|#t|ESrvr|rs r@r6z_..%sM"s4yyGXGX D rwrv>rdisablerzunknown tools action: r[znames requiredr)rr )CONFIGURABLE_TOOLSETS_apply_mcp_change_apply_toolset_changer_get_plugin_toolset_keysch|]\}}}| Srvrv)r4ts_keyrHs r@rz_..%s+   #vq!F   rwcg|]}d|v| Srrvrs r@r6z_..%sGGGDs$4rwcg|]}d|v| Sr rvrs r@r6z_..%s???3$;;t;;;rwcg|]}|v| Srvrvr4rEvalid_toolsetss r@r6z_..%s#RRRDt>7Q7Q47Q7Q7Qrwcg|]}|v| Srvrvr s r@r6z_..%s#VVVDt~?U?U4?U?U?UrwrrFrc`g|]*}|vr$d|vs|dddv(|+S)rrr)r)r4rEmissing_serversrs r@r6z_..-%sW   7""DDJJsA$6$6q$9$P$P %Q$P$Prw)changedrrr rXrr )r2rr3rrarrr rr r r rr rrMrrrrr1)rrr; targetsrr r r r rr r5toolset_targets mcp_targetsrrrr rr rr s @@@r@rHrH$s9 Hb))/R 0 0 6 6 8 8 > > @ @F&,jj"&=&=&CG***C@@@AAA 1C/0007'>>>>>>>>              kmm  '<   $ $ & &'HGGGGG????? RRRRORRRVVVVOVVV  G ! !#uov F F F.j%sX '( o#$Y<#4"#H+"#$4"5 rwr )r|rw list_sessionsrr1rar2)rrrwprocsrs r@rHrHa%s';;;;;; ..00 #     '''Cs1vv&&&&&&&&'s58 A*A%A*%A*z cron.managecz|dd|dd}} ddlm}|dkr,t|t j|dS|dkrWt|t j|d ||d d|d d S|d vr-t|t j|||St |dd|S#t$r(}t |dt|cYd}~Sd}~wwxYw)Nr; r rErr)cronjob)r; rcreatescheduleri)r; rEr ri>rRremoverS)r; job_idrzunknown cron action: i) rtools.cronjob_toolsr rrrrar1r2)rrr; jidr rs r@rHrHy%sq**Xv.. 620F0FCF'////// V  sDJwwf'='='=>>?? ? U?? G' !'J!;!;%zz(B77     2 2 2sDJwwfS'I'I'IJJKK KC?v??@@@ '''Cs1vv&&&&&&&&'s07D&AD0D4D D:D5/D:5D:rec |dd|dd}} |dkr ddlm}t|d|iS|dkrHdd lm}m}m}||||d d pg}t|d d|DiS|dkr.%s1   KL FF   rwinstall) do_installceZdZdZdS) _.._QcdSrrv)rrrZs r@r6z_.._Q.print%sDrwN)r5rrr6rvrwr@_Qr %s#rwr T) skip_confirmconsole) installedrEr5) browse_skillsrr page_size)rr r) inspect_skillrrzunknown skills action: i)rrrrtools.skills_hubr r r hermes_cli.skills_hubr r risdigitr rar1r2)rrr; rrr r r rr r r pgr rs r@rHrH%sJJx00&**Wb2I2IEF5' V   > > > > > >sX';';'='=>?? ? X            ((66"'     PS     Y   8 8 8 8 8 8         Ju4 > > > >s$>>?? ? X   ; ; ; ; ; ;VZZ**/a00#mmoo4E 1 ]]c&**[RT:U:U6V6VWWW  Y   ; ; ; ; ; ;sV]]5%9%9%?R@AA ACAAABBB '''Cs1vv&&&&&&&&'s>%F3A F3"AF3$BF36(F3F33 G%=G G% G%z skills.reloadc ddlm}|}|dpg}|dpg}t|dpd}dg}|s|s|d|r4|d|d |D|r4|d |d |D||d t |d ||dS#t$r(}t|dt|cYd}~Sd}~wwxYw)Nr) reload_skillsaddedrrkzReloading skills...zNo new skills detected.z Added skills:c3HK|]}d|ddVdSz - rErNr3rs r@rz_..%s9II46 4 466IIIIIIrwzRemoved skills:c3HK|]}d|ddVdSr r3rs r@rz_..%s9KK46 4 466KKKKKKrwz skill(s) availabler)rrrZ ) rr rrrrrr&r1rar2) rrr rr rrkrrs r@rHrH%s'666666 7##)r**Y''-2FJJw'',1--&' 4W 4 LL2 3 3 3  J LL ) ) ) LLII5III I I I  L LL* + + + LLKK7KKK K K K 2223333499U#3#3vFFGGG '''Cs1vv&&&&&&&&'sD'D** E4EEErgc  |dd} ddlm m m m fd}|dkrG|}t d|D}t|||t||z dS|dkrdd lm }|d pd st|d d St|d}||}|ds&t|d|dpdStfd|Dd} t|dt|d| dSt|dd|S#t$r(} t|dt| cYd} ~ Sd} ~ wwxYw)u=List installed plugins with activation state, or toggle one on/off. Backs the TUI Plugins Hub. Uses the same disk-discovery + enable/disable primitives as ``hermes plugins`` / the dashboard, so the three surfaces agree on what's installed and what's enabled. Actions: - ``list`` → {"plugins": [{name, version, description, source, status}], "user_count": N, "bundled_count": M} - ``toggle`` → flip ``name`` based on ``enable`` (bool). Returns the refreshed row plus {"ok", "unchanged"}. r; r r)_discover_all_plugins_get_disabled_set_get_enabled_set_plugin_statusc  } }g}t D]B\}}}}}}||t|pd|pd| ||||dC|S)Nrr)rErrrr)rrr2) rrr5rErrr_dirrr r r r s r@_rowsz_.._rows%s&&((G((**HC:@%%'';;  6gtVT3 $#&w}"#5#5'+zr"("0.wc"R"R"R Jrwc32K|]}|ddkdVdS)rbundledrNrvr s r@rz_..&s0II1( y0H0HQ0H0H0H0HIIrw)r user_count bundled_countr)"dashboard_set_agent_plugin_enabledrErr2z plugins.toggle requires a 'name'r)rrrb rz toggle failedc34K|]}|dk|VdS)rENrv)r4rrEs r@rz_..'&s1@@aai4.?.?.?.?.?.?@@rwNT unchanged)rr' rErKrzunknown plugins action: )rhermes_cli.plugins_cmdr r r r rh rrr% r3rarr r1r2)rrr; r rbr# r% rrrtrr r r r rEs @@@@@r@rHrH%s{ZZ& ) )F='                    $ V  577DIIIIIIIJ#",%(YY%;  X   Q Q Q Q Q QJJv&&,"3355D KC'IJJJ&**X..//F77fMMMF::d## OCvzz'':':'MoNNN@@@@5577@@@$GGC!%fjj&=&=!>!> !  CB&BBCCC '''Cs1vv&&&&&&&&'s9A F>AFA)F1AF F G(G G Grcc |dd}|st|ddS ddlm}m}||\}}|rt|dd|d S||\}}} |rt|dd | d Sn!#t $rt|d d cYSwxYw t j|d d d dtj t j } t|| j dd| j dd| jdS#t j$rt|ddcYSt $r(} t|dt#| cYd} ~ Sd} ~ wwxYw)NrrrXr" r)detect_dangerous_commanddetect_hardline_commandr zblocked (hardline): z'. Use the agent for dangerous commands.z blocked: rz=shell.exec unavailable: approval safety module not importableTrN)rGr rrrri`i0)rr8r_izcommand timed out (30s)i)rrarr* r+ rrrr(rrrrr8rr@r1r2) rrr)r* r+ is_hardline hardline_desc is_dangerousrHrrrs r@rHrH7&s **Y # #C 0C///`TTTTTTTT%<%rCrErGrHrIrrrrrurrvr$r+r/r2r6rkrurrr_r'r<r?rr&r rrrrPrRrWrYr\r`rcrjrmrrr rrr8rEr}rrrrrrrrrrr r+ r) r, r0 rr6 r9 r{ r r r r r r r rvrwr@rG s8        544444!!!!!!  8 $ $  $$x..*?*F*OW\\,0G H H 4444:*  777777   D QPPPPPPPPP 4T ? "$sH} """35$sE#y.// 05558:$sE#t)$445:::$sCx.  3:y~ IN    ""y~  D4K EDL  %y~''U2:>>*FGGO4PPNNINNN#c>22!!E :;;Ct I!!! !#c#899F ===>>       33rz~~;<<C D D I--!  .  GGHHH z Z ">"6"6 EE ())ddddddddNJsJJJJ  #*         3d ? ( M$+ M$ M M M M4 4 td{4 4 d4 4 4 4 nBM   td{ 3 QU    @dt9D   c #      >TD[ >T > > > >#$>%4"""!" 38_""""J====%U2:>>*DEEQRRNN:%%%U8__NNN%S.))7T7777 Xs XT X X$ X X X X==== 8 8 8 8"### $>>>>>K3:K$+KKKK()(($+#*8@D@T@@@@*HHH3HHHHH3cDjM#MsMsMMMM d t    ;T;d;;;;RCRcRdRRRRCE#sD.$9D$@&      &&$&8I#6&$+&&&&R111C1%14$;1111s9Cs9$s94s9s9s9s9lLLL $$$ # #    D4K3(!t !!!!!0SS6$+#  4$;  4     2D2T2222j 6d<&N5c?MMM4> 4     c c      c d d     4 D    ++++%%#%C%$%%s%%%%$  d d    &d& ' ' ' ' ' %S4Z"8    F84$;848888v4$;$BN4$;N4NNNNB     955566c 5 5   i  y  Y U E % 5 % g E W  5!(Tc4*t **** C$J    QdQQQQ G# G G G GLS D 0LLLL^QSQSQQQQ9#9$9999555555-s-T----,.%* {{{ { {{ " {  {{{{@# $#'"& 2121 21t21:21D[ 21 4Z 21  39 21212121r!%!% III I I I  I  IIIIX33333l     &d&s&&&&Bsee$+eeeeePCt $ !!!!!!H+3+3++++)$)3)))))f)))))6 666667V7C7C$J7777//S/edl/sTz////8**3*c*****6,-3,-c,-,-D,-RU,-,-,-,-d N(N( N(N( *N(4Z N( $; N(N(N(N(b3C3D3333l+++++< K K$+ K K K K KAAA4$;A%S/AAAA(3BD++ ++),+;>+ 4 ++++\NNsNsNNNN tCy     + + +"""#S#T####L C D    88d8#8TW8cghlcm8888v7s7C7C7777,sSTDcDTF"(,$(-1(,vv v vd v 3J% v Tz v $d{v:vvvvrMMMMsMMMMdMM#MMMMMMMM`P#PPPPGGGNsNNNNNN"4C"4d3i"4C"4"4"4"4J33MMMM4EPSX\*949D9999x r 4r Dr r r r j$( SS,%$%%%%%%Td %C%C%%%% $ # $    F#F$+FFFF">#>%>>>>,&" &"&" &"  &"  4: &"&"&"&"R +'4+'D+'+'+'+'\4D&+'4+'D+'+'+'+'\**4**D********Zm*4m*Dm*m*m*m*f & & &+4+D++++  )4)D)))! ) -4-D----*4*D****'4'D''''0 U94U9DU9U9U9U9p E94E9DE9E9E9E9P'4'D''''A84A8DA8A8A8A8N'4'D'''' V'4V'DV'V'V'V'r '4'D''''((i Ys^ * * * DsC}% &   +4) + +3   ,59j&5I+J+J)C.JJJ_'4_'D_'_'_'_'D DI #*      '4'D'''':'4'D''''&AH4AHDAHAHAHAHL 4D8$9&#IN$$35 d3eT#Y.//0555W3W49WWWWt4s4345c?T3I4444n@&4@&D@&@&@&@&F;;C;s;D;;;; 04 KsKtDzD'8KKKK\K'4K'DK'K'K'K'\$'4$'D$'$'$'$'NN'4N'DN'N'N'N'b*'4*'D*'*'*'*'`3C3$333333l X'4X'DX'X'X'X'|!).""#sTD[D =T = = = =ADAAAA <<<<<"W3WWWW]>4]>D]>]>]>]>@I'4I'DI'I'I'I'X  '4 'D ' ' ' '$'4'D''''6'4'D'''':+'4+'D+'+'+'+'\'4'D''''2#BT*#$4494444 O#OOOO3c349& )4 )D ) ) ) ) g$g4ggggT*****"'4'D''''* #'4#'D#'#'#'#'L '4'D''''< $'4$'D$'$'$'$'NA'4A'DA'A'A'A'H'4'D'''': '4'D''''. '4'D''''47'47'D7'7'7'7't'4'D''''0K'4K'DK'K'K'K'\ #'4#'D#'#'#'#'#'#'sZ&C77C?>C?%H H  H %I I I:/J** J65J6%O**O?>O?