`gjWdZddlmZddlZddlmZmZddlZddlZddlZddl Z ddl Z ddl m Z m Z ddlmZddlmZddlmZmZmZdd lmZmZddlZdd lmZmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEdd lFmGZGmHZHmIZIdd lJmKZKmLZLmMZMmNZNmOZOdd lPmQZQddlRmSZSddlTmUZUmVZVmWZWddlXmYZYmZZZddl[m\Z\m]Z]e je_Z` ddlambZceddZedZfdZgdZhhdZid+d,dZjd-dZkd-dZld.dZmd/dZnd0d Zod1d!Zpdddd" d2d#Zqd3d$Zrd4d%Zs d5d&Ztd6d'Zu d7d(ZvGd)d*ejZxy#ed$rdZcYwxYw)8uHACP agent server — exposes Hermes Agent via the Agent Client Protocol.) annotationsN)datetimetimezone) defaultdictdeque)ThreadPoolExecutor)Path)AnyDequeOptional)unquoteurlparse)+AgentCapabilitiesAgentMessageChunkAgentThoughtChunkAuthenticateResponseAvailableCommandAvailableCommandsUpdateBlobResourceContentsClientCapabilitiesEmbeddedResourceContentBlockForkSessionResponseImageContentBlockAudioContentBlockImplementationInitializeResponseListSessionsResponseLoadSessionResponse McpServerHttp McpServerSseMcpServerStdio ModelInfoNewSessionResponsePromptCapabilitiesPromptResponseResumeSessionResponseSetSessionConfigOptionResponseSetSessionModelResponseSetSessionModeResponseResourceContentBlockSessionCapabilitiesSessionForkCapabilitiesSessionInfoUpdateSessionListCapabilities SessionModeSessionModeStateSessionModelStateSessionResumeCapabilities SessionInfoTextContentBlockTextResourceContentsUnstructuredCommandInputUsage UsageUpdateUserMessageChunk)TERMINAL_SETUP_AUTH_METHOD_IDbuild_auth_methodsdetect_provider)#_build_plan_update_from_todo_resultmake_message_cb make_step_cbmake_thinking_cbmake_tool_progress_cb)make_approval_callback)session_provenance_meta)SessionManager SessionState_expand_acp_enabled_toolsets)build_tool_completebuild_tool_start) reset_hermes_interactive_contextset_hermes_interactive_context) __version__z0.0.0z acp-agent) max_workersthread_name_prefix2i)ztext/>application/sqlapplication/xmlapplication/jsonapplication/tomlapplication/yamlapplication/x-yamlapplication/javascriptapplication/typescriptc|xsdj}|xsdj}|r|r ||k7r|d|dS|r|S|r|St|}|jr |jn|}t t |j xs|xsdS)z2Human-readable attachment name for prompt context. ()resource)striprschemepathr r name)urir`titleraw_name raw_titleparsed candidates E/root/.hermes/venv/lib/python3.12/site-packages/acp_adapter/server.py_resource_display_namerhns !!#H"##%IX)x"7Bxj** c]F%}} #I  " # ( ( =C =:=c|xsdjdddjj}|sy|jtxs|t vS)NrY;rF)splitr]lower startswith_TEXT_RESOURCE_MIME_PREFIXES_TEXT_RESOURCE_MIME_TYPES mime_typemimes rg_is_text_resourceru}sP O " "3 *1 - 3 3 5 ; ; =D  ??7 8 ]DD]<]]ric|xsdjdddjj}|jdS)NrYrkrlrzimage/)rmr]rnrorrs rg_is_image_resourcerws> O " "3 *1 - 3 3 5 ; ; =D ??8 $$rich|jj}ddddddddj|S)N image/pngz image/jpegz image/gifz image/webpz image/bmpz image/svg+xml)z.pngz.jpgz.jpegz.gifz.webpz.bmpz.svg)suffixrnget)r_rzs rg_guess_image_mime_from_pathr|s> [[   F  c&kricVd|dtj|jdS)Ndata:;base64,ascii)base64 b64encodedecode)datarss rg_image_data_urlrs, 9+Xf&6&6t&<&C&CG&L%M NNric|xsdj}|syt|}|jr|jdk7ry|jdk(r5|jr|jdvryt |j xsd}n t |}t |dk\rk|ddk(rc|dd k(r[|d jrH|d j}|ddjd jd d}td |z |z St |dk\rc|d d k(r[|djrH|dj}|ddjd jd d}td |z |z St|S)a#Convert local file URIs/paths from ACP clients into a readable Path. Zed may send POSIX file URIs from Linux/WSL workspaces or Windows-ish paths when launched through wsl.exe. Translate the common Windows drive form to /mnt//... so Hermes running in WSL can read it. rYNfile>rY localhostr/:rlz/\\z/mnt) r]rr^netlocr r_lenisalpharnlstripreplacer )rarawre path_textdriverests rg_path_from_file_urirsn 9"   C  c]F }}&0 }} ==V]]2CCFKK-2. CL  9~y|s2y|s7JyYZ|OcOcOe! ""$}##E*224=F|e#d** 9~y|s2y|7K7K7M! ""$}##E*224=F|e#d**  ?ricd|vr t|sydD]} |j|cS|jddS#t$rY6wxYw)zHDecode resource bytes if they are probably text; return None for binary.N)z utf-8-sigutf-8zlatin-1rrerrors)rurUnicodeDecodeError)rrsencodings rg_decode_text_bytesrs`$0;5 ;;x( ( ;;wy; 11"   s> A  A )r`rbnotecTt|||}d|d}|r |d|dz }|d|d|S)Nr`rbz[Attached file: ]rZr[ URI: z )rh)rabodyr`rbrdisplayheaders rg_format_resource_textrsL%St5AGy *F BtfA,XWSEdV ,,ric tt|ddxsdj}|sgStt|ddxsdjxsd}tt|ddxsdjxsd}tt|ddxsdjxsd}t|}|dt |||d d gSt |r|n t |}|rt |r |jj}|tkDrdt |||d |d td  d gS|jd5}|j} dddt|||} dd| d|d ddt! |idgS |jj}t#|t} |jd5}|j| } dddt% |} | dt |||d|d|xsdd  d gSd}|tkDr dtd|d}dt |||| |d gS#1swYxYw#t$r9} tjd|ddt |||d| d  d gcYd} ~ Sd} ~ wwxYw#1swYxYw#t$r9} tjd |ddt |||d!| d  d gcYd} ~ Sd} ~ wwxYw)"arConvert an ACP resource_link block to OpenAI content parts. Returns a list of {"type": "text", ...} and/or {"type": "image_url", ...} parts. Image resources produce an image_url part with a small text header so the model knows which attachment it is. Non-image resources return a single text part with the inlined file body (or a binary-omit note). rarYr`NrbrstextzM[Resource link only; Hermes cannot read non-file ACP resource URIs directly.])rar`rbrtyperz[Image too large to inline: bytes, cap=rrbz"ACP image resource read failed: %sTexc_infoz [Could not read attached image: r[Attached image: z] URI: image_urlurlrrz[Binary file omitted: bytes, mime=unknownz truncated to  of z bytes)rar`rbrrzACP resource read failed: %sz[Could not read attached file: )strgetattrr]rrrwr|statst_size_MAX_ACP_RESOURCE_BYTESopenreadOSErrorloggerwarningrhrminr)blockrar`rbrsr_ image_mimesizefhrexcr read_sizerrs rg_resource_link_to_partsrsP geUB'-2 . 4 4 6C  wufb)/R 0 6 6 8 @DD w+1r 2 8 8 : BdEGE;39r:@@BJdI s #D |)d    1;A\]aAbJ(4 99;&&D--"1!#;D6NeMffgh 4 !Bwwy !)4uE'8 #%O P tZ7X/Y Z  ! yy{""56 YYt_ &779%D &!$ 2 <-1$}YE[R[D\\]^   ) )"#:";4vVLD)cEPT[_`   M ! !  NN?tN T-;C5B   ( & &(   5sTJ)6se1=      sy7AI8I H:I ;JJ 3J+J:I?I J.J=JJ JJ K .KKKc t|dd}|gStt|ddxsdj}tt|ddxsdjxsd}t|trdt ||j dgSt|tr|jxsd} tj|d }t|rjt|tkDr%dt |d t|dtddgSt!|}dd|d|rd|ndzdddt#||xsdidgSt%|dt|}|dt|d|xsdd}n-|}t|tkDr|dtdt|dz }dt ||dgSt|dd}|rdt |t|dgSgS#t$r|jd d }Y)wxYw)Nr\rarYrsr)rarrT)validaterrrz%[Embedded image too large to inline: rrrrrrryrz[Binary embedded file omitted: rrz [Truncated to rz bytes])rrr] isinstancer5rrrblobr b64decode Exceptionencoderwrrrhrr) rr\rarsrrrrrs rg_embedded_resource_to_partsr;s3uj$/H ghr*0b 1 7 7 9CGHk26<"=CCEMI(01)>3X]])[\]](01}}" :##D48D i (4y22"1DSYK|\s[ttuv-S1G+3T)RSTT 8VT *D )>3SQUY)WXYY I? :;;wy;9D :s3GG43G4cg}|D]_}t|tr|j|j/t |ds<|jt |jadj |S)z@Extract plain text from ACP content blocks for display/commands.r )rr4appendrhasattrrjoin)promptpartsrs rg _extract_textrlsbE* e- . LL $ UF # LLUZZ ) * 99U ricPtt|ddxsdj}tt|ddxsdj}tt|ddxsdjxsd}|r|jdr|nd|d|}n|r|}nyd d |id S) zFConvert an ACP image content block to OpenAI-style multimodal content.rrYrarsryr~rNrrr)rrr]ro)rrrarsrs rg_image_block_to_openai_partrs wufb)/R 0 6 6 8D geUB'-2 . 4 4 6CGE;3B{CIIKZ{I oog.deI;htf4U ucl ;;ricg}g}|D]B}t|trF|jr9|jd|jd|j|jZt|trt |}||j|t|t rMt|}|D]<}|j||jddk(s)|j|d>t|tst|}|D]<}|j||jddk(s)|j|d>E|s t|Std|Drdj|S|S)zOConvert ACP prompt blocks into a Hermes/OpenAI-compatible user content payload.rrrc3DK|]}|jddk(yw)rrNr{.0parts rg z9_content_blocks_to_openai_user_content..s 8$488F v % 8s r)rr4rrrrr*rr{rrrallr)rr text_partsr image_partresource_partsrs rg&_content_blocks_to_openai_user_contentrsg#%EJ e- .zz fejjAB!!%**-  e. /4U;J% Z(  e1 24U;N& 4 T"88F#v-%%d6l3 4  e9 :8?N& 4 T"88F#v-%%d6l3 4 14 V$$  8% 88yy$$ Lric eZdZdZdddddddd d d Zd d ddddddddddddddddddddddd dddd df ZdZdZd Zd!Z d"Z ede d#e d$iZ e jDcic]\}}|| c}}}Z dUdVfd& ZdWd'ZdXd(ZdYd)ZedZd*Zd[d+Zed\d,Zed]d-Zd^d.Z dU d_d/Zd%d%d0 d`d1Zd^d2Z dad3Z db dcd4Zddd5Zeded6Zedfd7Z edfd8Z!e dgd9Z"edhd:Z#edid;Z$edjd<Z%d^d=Z& dU dkd>Z' dU dld?Z( dU dmd@Z)dndAZ* dU dodBZ+ dp dqdCZ, drdDZ-edsdEZ.dtdFZ/dtdGZ0dudHZ1dvdIZ2dvdJZ3dvdKZ4dvdLZ5dvdMZ6dvdNZ7dvdOZ8dvdPZ9dvdQZ: dwdRZ; dxdSZ< dydTZ=xZ>Scc}}}w)zHermesACPAgentz1ACP Agent implementation wrapping Hermes AIAgent.zShow available commandszShow or change current modelzList available toolszShow conversation context infozClear conversation historyzCompress conversation contextz5Inject guidance into the currently running agent turnz5Queue a prompt to run after the current turn finisheszShow Hermes version helpmodeltoolscontextresetcompactsteerqueueversionrzList available commands)r` descriptionrz1Show current model and provider, or switch modelszmodel name to switch to)r`r input_hintrz&List available tools with descriptionsrz(Show conversation message counts by rolerrrzguidance for the active turnrzprompt to run nextredit_approval_policyaskdefault accept_editsdont_askworkspace_sessionsessionNcVt||xs t|_d|_yN)super__init__rDsession_manager_conn)selfr __class__s rgrzHermesACPAgent.__init__ s% .B.2B+/ ric<||_tjdy)z8Store the client connection for sending session updates.zACP client connectedN)rrinfo)rconns rg on_connectzHermesACPAgent.on_connects  *+ric "tt|ddxs |j}||jvr |j}t |t |jddt |j ddt |jdd g S) aReturn ACP session modes while preserving Zed's separate model picker. Zed renders ``config_options`` in the prominent selector slot where the model picker was visible. Claude/Codex expose policy-like controls as ACP modes, which coexist with the model picker, so Hermes maps edit approval policy onto modes instead of advertising config options. moderYDefaultzAsk before edits.)idr`rz Accept EditszDAuto-allow workspace and /tmp edits; still asks for sensitive paths.z Don't Askz>Auto-allow file edits for this session except sensitive paths.)current_mode_idavailable_modes)rr _MODE_DEFAULT_MODE_TO_EDIT_APPROVAL_POLICYr0r/_MODE_ACCEPT_EDITS_MODE_DONT_ASK)rstatecurrents rg_session_modeszHermesACPAgent._session_modessgeVR0FD4F4FG $<< <((G#))" 3 ..' f **$ `  rictt|ddxs |j}|jj ||j }||j fS)Nr rY)rrrrr{_EDIT_APPROVAL_POLICY_DEFAULTcwd)rrr policys rg_edit_approval_policy_for_statez.HermesACPAgent._edit_approval_policy_for_state7sM75&"-C1C1CD3377d>`>`auyy  rict|xsdj}|syt|xsdjj}|s|S|d|S)zBEncode a model selection so ACP clients can keep provider context.rYr)rr]rn)providerr raw_model raw_providers rg_encode_model_choicez#HermesACPAgent._encode_model_choice<s[ $**, 8>r*00288:  q ,,ric t|jxst|jddxsdj }t|jddxst xsd} ddlm}m}m }||}||}g} t} ||D]\} } t| xsdj } | s&|j|| }|| vr=d|g}| r(|jt| j | |k(r|jd | jt|| d jd |D | j||j||}|r&|| vr"| j!dt||d|d  | rt#| |xs| dj$S |sy|j||}t#t||g|S#t&$rt(j+ddYPwxYw)z;Return the ACP model selector payload for editors like Zed.rrYrN openrouterr)curated_models_for_providernormalize_providerprovider_label Provider: ru • c3&K|] }|s| ywrrs rgrz4HermesACPAgent._build_model_state..ds0U$PT0Us)model_idr`ru • current)available_modelscurrent_model_idzCould not build ACP model stateTr)r(r`)rrragentr]r<hermes_cli.modelsr"r#r$setrrr"raddinsertr1r(rrdebug)rrrrr"r#r$normalized_provider provider_namer)seen_idsr(rrendered_model choice_id desc_partsr*fallback_choices rg_build_model_statez!HermesACPAgent._build_model_stateGs)EKKJ75;;#DJKQQS5;; D9^_=N^R^. K i i"4X"> *+>?M02 !$H)DEX)Y (%+!$X^!4!:!:!<% 556I>Z ( *=/:; %%c+&6&<&<&>?!U*%%i0 ''!*+$+LL0U*0U$U Y'' (* $889LeT $4H$D ''!1"&0|$L (%5%5%U9I!9L9U9U 33HeD 'uMN,   K LL:TL J Ks)EG)) H  H c|}|j} ddlm}m}|||\}}||k(r|||}|r|\}}||fS#t$rt j ddY||fSwxYw)zKResolve ``provider:model`` input into the provider and normalized model id.r)detect_provider_for_modelparse_model_inputz,Provider detection failed, using model as-isTr)r]r,r:r;rrr0)rcurrent_providertarget_provider new_modelr:r;detecteds rg_resolve_model_selectionz'HermesACPAgent._resolve_model_selections+OO%  X V):9FV)W &OY"224Y@PQ19.OY )) X LLGRVL W )) Xs)A A'&A'c |j}t|dd}tt|ddxsd}|dkry ddlm}||j t|ddxsdt|ddxsd }tdt|dt|dS#t $r4tjd d tt|d dxsd}Y^wxYw)aBuild ACP native context-usage data for clients like Zed. Zed's circular context indicator is driven by ACP ``usage_update`` session updates: ``size`` is the model context window and ``used`` is the current request pressure. Hermes estimates ``used`` from the same buckets it sends to providers: system prompt, conversation history, and tool schemas. context_compressorNcontext_lengthrestimate_request_tokens_rough_cached_system_promptrYr system_promptrz+Could not estimate ACP native context usageTrlast_prompt_tokens usage_update)session_updaterused) r+rintagent.model_metadatarEhistoryrrr0r8max)rr+ compressorrrErLs rg_build_usage_updatez"HermesACPAgent._build_usage_updates U$8$? 7:'7;@qA 19 J J0 %e-DbIOReWd3;tD)T1T1   J LLFQUL Vwz+?CHqID Js9B:CCcK|jsy|j|}|y |jj|j|d{y7#t$r%t j d|jdYywxYww)z6Send ACP native context usage to the connected client.N session_idupdatez.Failed to send ACP usage update for session %sTr)rrRrKrUrrr)rrrVs rg_send_usage_updatez!HermesACPAgent._send_usage_updateszz ))%0 >  **++ ++,    NN@     s:"B*AAABA+BBBBc t|jj|||S#t$rtj d|dYywxYw)zBBest-effort ``_meta.hermes.sessionProvenance`` for an ACP session.)previous_hermes_session_idz-Could not build ACP session provenance for %sTrN)rCr_get_dbrrr0)racp_session_idcurrent_hermes_session_idrYs rg_provenance_metazHermesACPAgent._provenance_metas^ *$$,,.)+E     LL?Z^    s&)!A  A r\rYcK|jsy |jjj|}|sy|jd}tjtjj}|j||xs||}tdt|t r|j#r|nd||} |jj%||d{y#t$rt j d|dYywxYw7,#t$rt j d |dYywxYww) a*Send ACP native session metadata after Hermes changes it. When the internal Hermes head rotated (e.g. compression-driven session split during a turn), pass ``previous_hermes_session_id`` so the attached ``_meta.hermes.sessionProvenance`` flags the rotation reason. Nz&Could not read ACP session info for %sTrrbsession_info_update)rKrb updated_at field_metarTz-Could not send ACP session info update for %s)rrrZ get_sessionrrr0r{rnowrutc isoformatr]r-rrr]rK) rrUr\rYrowrbrametarVs rg_send_session_info_updatez(HermesACPAgent._send_session_info_updates2zz  &&..0<)C.B D> D(D)D-D>.!DD>DD>D!D;8D>:D;;D>c|jsytj}|jtj|j |y)z>Schedule native context indicator refresh after ACP responses.N)rasyncioget_running_loop call_soon create_taskrW)rrloops rg_schedule_usage_updatez%HermesACPAgent._schedule_usage_updates9zz '') w**D,C,CE,JKricLK|sy ddlm}i}|D]}|j}t|trQ|j t |j|jDcic]}|j|jc}d}n<|j|jDcic]}|j|jc}d}|||<tj||d{ dd lm} dd lm} t-t/|j0d dxsd g|Dcgc]}|jc} } | |j0_t/|j0dd} | | | d|j0_|j0j4xsgD chc] } | dd c} |j0_| |j0t/|j0dd}t9|r|tj;d|j"t=|j0j4xsgycc}wcc}w7X#t$r%tj!d|j"dYywxYwcc}wcc} w#t$r%tj!d|j"dYywxYww)zERegister ACP-provided MCP servers and refresh the agent tool surface.Nr)register_mcp_servers)commandargsenv)rheadersz.Session %s: failed to register ACP MCP serversTrget_tool_definitionsinject_memory_provider_toolsenabled_toolsets hermes-acp)mcp_server_namesdisabled_toolsets)r{r~ quiet_modefunctionr`_invalidate_system_promptzHSession %s: refreshed tool surface after ACP MCP registration (%d tools)zESession %s: failed to refresh tool surface after ACP MCP registration)tools.mcp_toolrrr`rr!rslistrtruvaluerrvrk to_threadrrrrU model_toolsrxagent.memory_managerrzrFrr+r{rvalid_tool_namescallablerr)rr mcp_serversrr config_mapserverr`itemconfigrxrzr{r~tool invalidates rg_register_session_mcp_serversz,HermesACPAgent._register_session_mcp_serverss[    ;*,J% *{{fn5#)>> $V[[ 1BH**M$ 4:: 5MF &zzFLnn#UdDIItzz$9#UF$* 4  *##$8*E E E  8 I; %7>P<.>R0!$6T$B%8020246& &  sB:B<cKt|tsy|jj}t }|t k(r|r t SdS|r||k7ryt Swr)rrr]rnr<r:r)r method_idrnormalized_methodrs rg authenticatezHermesACPAgent.authenticatesf)S)%OO-335"$  = =.6') ?4 ?,8#%%sA#A%c t|tr|jSt|trg}|D]}t|tr}|j d}t|tr|j |F|j ddk(s[t|j dts{|j |dt|ts|j |djd|DjSy)aNormalize a persisted text-or-text-parts value into a single string. OpenAI-style assistant content (and provider reasoning fields) can arrive as either a scalar string or a list of ``{"text": ...}`` / ``{"type": "text", "content": ...}`` parts. Whitespace-only inputs collapse to an empty string so callers can treat ``""`` as "nothing to emit". rrcontentrc3dK|](}|s|js|j*ywr)r]rs rgrz7HermesACPAgent._flatten_history_text..s Udt TZZ\Us 000rY)rrr]rdictr{rr)rrrrs rg_flatten_history_textz$HermesACPAgent._flatten_history_texts eS !;;= eT "!E 'dD)88F+D!$, T*&)V3 488ICVX[8\ T)_5c*LL& '99UeUU[[] ]ricB|j|jdS)z?Extract displayable text from a persisted OpenAI-style message.rrr{)clsmessages rg_history_message_textz$HermesACPAgent._history_message_texts((Y)?@@ric^dD](}|j|j|}|s&|cSy)uExtract displayable reasoning/thought text from a persisted assistant message. Returns the first non-empty value among ``reasoning_content`` (the canonical field used by DeepSeek / Moonshot and the post-#16892 chat-completions normalizer) and ``reasoning`` (used by the codex event projector and several other transports). Both keys are actively written by live code paths, so neither branch is deprecated — they cover different transports rather than old vs. new sessions. )reasoning_content reasoningrYr)rrkeyrs rg_history_reasoning_textz&HermesACPAgent._history_reasoning_texts96 C,,W[[-=>D  ricftd|}|dk(r td|S|dk(r td|Sy) z@Build an ACP history replay update for a user/assistant message.rruseruser_message_chunk)rKr assistantagent_message_chunkN)r4r9r)rolerrs rg_history_message_updatez&HermesACPAgent._history_message_updatesL!f48 6>#3  ; $4 ric,tj|S)z7w)uReplay persisted user/assistant history during session/load or session/resume. Invoked inline (``await``) from both ``load_session`` and ``resume_session`` so that spec-compliant ACP clients receive the full transcript within the request's lifetime — see the comment at the call sites for the rationale and prior-art citations. Replays the conversation as user/assistant chunks, thinking-mode thought chunks, plus reconstructed tool-call start/completion notifications. Merely restoring server-side state makes Hermes remember context, but leaves the editor looking like a clean thread. NcK jjj|d{y7#t$r%tj djdYywxYww)NrTTz+Failed to replay ACP history for session %srF)rrKrUrrr)rVrrs rg_sendz5HermesACPAgent._replay_session_history.._sendsl jj//5;K;KTZ/[[[\ A$$!   s1A(*757A(7+A%"A($A%%A(rrYr)rrr tool_callsrr tool_namer)result function_argstodo)rVr returnbool)rrOrr{rrrrrrrrrrHr]poprGr=)rractive_tool_callsrrrrrVthoughtrrrrrtrr result_text plan_updates`` rg_replay_session_historyz&HermesACPAgent._replay_session_historyszz CE }}: Gw{{6*0b1Dv~11':!99t$9OF)f 2E2E{"66w?t/K/KG/T)U#U#U11':!99t$9OF)f 2E2E$[[6 j$/%/ # ))T:$'+'A'A)'L +$*.*K*KI*V 4;Dd:K),7%*+;L)UY+Z%[[[" #v~"7;;~#>#D"EKKM  K 8 >B?EEG 7; #44/@/D/D\/R,I}#9 Y/(263(?fT "'$!*&3 &"Ek"RK".U;=O7O7Ou: 3F $V 3F \8PsB J I?9JJ9JJBJJJ JB5J J  J J) J4J 5J;JJJJ J Jc K|jj|}|j||d{tj d|j ||j |j |j|t|j |j||j||j|j t|jd|j S7w)NrzNew session %s (cwd=%s)rU)rUmodelsmodesrb)rcreate_sessionrrrrU#_schedule_available_commands_updaterpr#r8rr]rr+)rrrrrs rg new_sessionzHermesACPAgent.new_sessionYs $$333<00 DDD -u/?/?E 001A1AB ##E*!''**51%%e,,,  '%++|UEUEU"V   Es2C8C6CC8c DK|jj||}|tjd|y|j ||d{tj d| |j |d{|j||j|t|j||j||j|t|jd|S77y#t$rtjd|dYwxYww)Nz"load_session: session %s not foundzLoaded session %susACP history replay raised during session/load for %s — load will still succeed, partial transcript may be missingTrrUrrrb)r update_cwdrrrrrrrrprr8rr]rr+rrrUrrrs rgrzHermesACPAgent.load_sessionms$$// C@ = NN? L00 DDD '4 ..u5 5 5 00< ##E*"**51%%e,,,GEKKzJ  9 E 6  NNM   sIA D  C5D )C9=C7>C9A4D 7C99!DD DD c K|jj||}|2tjd||jj |}|j ||d{tj d|j |j|d{|j|j|j|t|j||j||j|jt!|j"d|jS77#t$r%tjd|jdYwxYww) Nz2resume_session: session %s not found, creating newrzResumed session %suwACP history replay raised during session/resume for %s — resume will still succeed, partial transcript may be missingTrrUr)rrrrrrrrUrrrrpr&r8rr]rr+rs rgresume_sessionzHermesACPAgent.resume_sessionsH$$// C@ = NNOQ[ \((77C7@E00 DDD (%*:*:; ..u5 5 5 001A1AB ##E*$**51%%e,,,  '%++|UEUEU"V  ! E 6  NNO     sIA&E-(D8)$E-D<"D:#D<'BE-:D<<+E*'E-)E**E-c K|jj|}|r|jr|j5|jr|j r|j |_ddd|jj t|ddr0t|jdr|jjtjd|yyy#1swYzxYw#t$rtjd|dYHwxYww)Nr+ interruptz"Failed to interrupt ACP session %sTrzCancelled session %s)rrc cancel_event runtime_lock is_runningcurrent_prompt_textinterrupted_prompt_textr-rrr+rrrr0r)rrUrrs rgcancelzHermesACPAgent.cancels$$00< U''## N##(A(A494M4ME1 N    " " $ ^5'40WU[[+5VKK))+ KK. ;(5 N N ^ A:X\ ] ^s@6D*C""D=C'DC$ D'!D D D  DcfK|jj||}|r |jnd}||j||d{tj d|||r|j |t|||j|nd||j|SdS7gw)NrrYzForked session %s -> %s)rUrr) r fork_sessionrUrrrrrr8r)rrrUrrrnew_ids rgrzHermesACPAgent.fork_sessions$$11*#1F%*!!  44UKH H H -z6B   4 4V <"5:5F4**51D050A$%%e,  HL  IsAB1B/A(B1c K|jj|}|r't|D]\}}|d|k(s||dzd}ng}t|tkD}|dt}g}|D]c}|j d} | t | ts t| } |jt|d|d|j d| e|r|r|d jnd} t|| Sw) aList ACP sessions with optional ``cwd`` filtering and cursor pagination. ``cwd`` is passed through to ``SessionManager.list_sessions`` which already normalizes and filters by working directory. ``cursor`` is a ``session_id`` previously returned as ``next_cursor``; results resume after that entry. Server-side page size is capped at ``_LIST_SESSIONS_PAGE_SIZE``; when more results remain, ``next_cursor`` is set to the last returned ``session_id``. rrUrlNrarrb)rUrrbra)sessions next_cursor) r list_sessions enumerater_LIST_SESSIONS_PAGE_SIZEr{rrrr3rUr) rcursorrrinfosidxshas_morerrars rgrzHermesACPAgent.list_sessionss $$22s2; #E* Q\?f,!#'(OE  u: 88//0 A|,J%jS.I _ OO %%%.)   2:hhrl--D #X;OOs 8C/B4C/ch"#$%&'()*+,-./012Kjj//"tjdt dSt |j 2t|1td|D}t2xst1txr t1}|s t dS|rt1tr2jdrt2jd dkDr#2jd dj nd }d }d }/j 5/j"s$|r"/j$r/j$}d /_nd }ddd|r |d |221n|r|2|1|rt1tr2jdr~j'2/} | jj(rRt+j,| } j(j/| d{j1/d{t dS/j 5/j"r2xsd} /j2j5| t/j2} j(r=t+j,d| d} j(j/| d{t dcdddSd /_2xsd/_dddtj9d2ddj(&t;j<*/j>r/j>jAtCtD} i}d,d'd 0&r~tG&*| |/fd}tI&*}tK&*| |}tM&*+d?+0fd }tO&jP*% ddl)m*}|&jP*/fd'n d}d}d}d}d%/jZ$|$_.d$_/|$_0|$_1|$_2d,d)d(d-d@$%'(),-/12f d } tg/jZdd}tijj}*jmtn|jp|d{..jud!r%.d!/_;jjytg/jZdd}&r&|r$|r"||k7r j{||"d{.jud$d }t/j>xr/j>j}}t.jud%xs|}dd&l?m@}|xr|j|}|r|s dd'lAmB}dA&*fd( }tg/jZd)d"tg/jZd*d#|jj2|/jvtg/jZd)dtg/jZd*dtg/jZd+dtg/jZd,dtg/jZd-dd."#/fd/|0|rF&rD|sB0r.jud2r/t+j,|} &j/| d{/j 5d /_d /_ddd /j 5/j2s dddnz/j2jd}ddd&r-&j/t+jd{jtd3g4d{d} t.fd5d6Dr^t.jud7d.jud8d.jud9d.jud:.jud;<} j1/d{|rd=nd}!t |!| >S#1swYxYw777f#1swY?xYw#tV$rtjYdd YdwxYw7#tV$rUtjsd /j 5d /_d /_dddn #1swYnxYwt dcYSwxYw7#tV$rtjYd#d YwxYw#tV$rtjYd1d YwxYw7g#1swYLxYw#1swYxYw777<w)BzERun Hermes on the user's prompt and stream events back to the editor.Nzprompt: session %s not foundrefusal) stop_reasonc3<K|]}t|tywr)rr4)rrs rgrz(HermesACPAgent.prompt..$sWuz%1ABWsend_turnz/steerrlmaxsplitrYFTz, User correction/guidance after interrupt: r[Image attachment]Queued for the next turn. ( queued)zPrompt on session %s: %sdc&jSrrrrsrgz'HermesACPAgent.prompt..sD4X4XY^4_ri)edit_approval_policy_getterrc|rd|y)NTr')r message_cbstreamed_messages rgstream_delta_cbz.HermesACPAgent.prompt..stream_delta_cbs'+$4 rir) make_acp_edit_approval_requesterc&jSrrrsrgrz'HermesACPAgent.prompt..s0T0TUZ0[ri)auto_approve_getterz,Could not create ACP edit approval requesterrc ddlm}m}|} r( ddlm}|j |j  r dd l m }|  td tjjd tjd < j!j"xsd }| t% !tjj'd dntjd < r ddlm}|j   ddl m}| | | ||SSS#t$rd}d}tj ddYBwxYw#t$rtj ddY?wxYw#t$rtj d dYUwxYw#t$rtj ddYwxYw#t$rtj ddYwxYw#t$rtj ddYSwxYw#t$r#}tj+dd|j"dcYd}~ t% !tjj'd dntjd < r? ddlm}|j n&#t$rtj ddYnwxYw 6 ddl m}| n&#t$rtj ddYnwxYw|3|0 ||S#t$rtj ddYSwxYwSSd}~wwxYw# t% !tjj'd dntjd < r? ddlm}|j n&#t$rtj ddYnwxYw 6 ddl m}| n&#t$rtj ddYnwxYw|3|0 ||w#t$rtj ddYwwxYwwwxYw)Nr)clear_session_varsset_session_vars) session_keyz!Could not set ACP session contextTr) terminal_toolz#Could not set ACP approval callback)set_edit_approval_requesterz)Could not set ACP edit approval requesterHERMES_SESSION_IDr ) user_messageconversation_historytask_idpersist_user_messagez#Could not restore approval callback)reset_edit_approval_requesterz-Could not restore ACP edit approval requesterz#Could not clear ACP session contextzAgent error in session %szError: )final_responsemessages)gateway.session_contextrrrrr0rr_get_approval_callbackset_approval_callbackacp_adapter.edit_approvalrrJosenvironr{run_conversationrOrIrr% exception)rrsession_tokens_terminal_toolrrr%er+ approval_cbedit_approval_requesteredit_approval_tokeninteractive_tokenprevious_approval_cbprevious_session_idrUr user_content user_texts rg _run_agentz)HermesACPAgent.prompt.._run_agentsi Q"2j!I WE+9+P+P+R("88E']U*EF]*^'!?t D  #%**..1D"E .8BJJ* +% [//!-).&)2)J6J 0  %045FG&.JJNN#6=6IBJJ23[I&<<=QR'2e[56IJ"-2D2P[*>:3Q- Q!%%)" @4 P Q!WLL!FQULVW!]LL!LW[L\]L%[ %JUY Z[%e %T_c de %[ %JUY Z[9 T  !:$[ %JUY Z[3Q-3 T %045FG&.JJNN#6=6IBJJ23[I&<<=QR$[ %JUY Z[&2e[56IJ$e %T_c de!-2D2P[*>:$[ %JUY Z[3Q-s=D/'EF $H7F(G$G4/$EE E>=E> F%$F%( G  G  G10G14 HH M$'M M M J.. KKK&& L L L L=<L=MM AP=N)(P=) O  P= O  P=O! P=! PP=PP= PP= P85P=7P88P=rUzExecutor error for session %sr'r^z:Could not emit ACP provenance update after rotation for %sr& interrupted)"INTERRUPT_WAITING_FOR_MODEL_PREFIX)maybe_auto_titlecjr0jtjjyyr)call_soon_threadsaferkrnri)_titlerrorrUs rg_notify_title_updatez3HermesACPAgent.prompt.._notify_title_updateMs011#// :::Frirrbase_urlapi_keyapi_mode)rrrCrDrEcptjddk(xrtjddk(S)Nrr)rr+) _title_model_title_providerrsrgrz'HermesACPAgent.prompt..fs8 Wd;|KV#EKKTBoUri) main_runtimeruntime_validatortitle_callbackz#Failed to auto-title ACP session %sresponse_transformedr)rrUc3DK|]}j|duywrr)rrrs rgrz(HermesACPAgent.prompt..smsvzz#d*ms ) prompt_tokenscompletion_tokens total_tokensrNrOrPreasoning_tokenscache_read_tokens) input_tokens output_tokensrPthought_tokenscached_read_tokens cancelled)rusage)rrrNone)rr)rArrrY)Jrrcrerrorr%rr]rrrrrrrorrmrrr_handle_slash_commandrrupdate_agent_message_textrKrWqueued_promptsrrrrkrlrclearrrrAr@r?r>rBrequest_permissionr+rrr0r+tool_progress_callbackthinking_callbackreasoning_callback step_callbackstream_delta_callbackr contextvars copy_contextrun_in_executor _executorrunr/r{rO save_sessionriis_setagent.conversation_loopr=agent.title_generatorr>rZrupdate_user_message_textrr4anyr7)3rrrUrtext_only_prompt has_content steer_textinterrupted_prompt rewrite_idle response_textrV queued_textdepth tool_call_idstool_call_metatool_progress_cb reasoning_cbstep_cbrrr;pre_turn_hermes_idctxpost_turn_hermes_idr&rWr<r=suppress_interrupt_responser>rB next_promptrXrrGrHr+r3rr4r5r6rorr7r8rrrr9r:s3` ` @@@@@@@@@@@@@@@@@rgrzHermesACPAgent.prompts $$00< = LL7 D!i8 8!&)//1 =fE WPVWW9o |T * AtL/A !j9 9  < =)BVBVW_B`CFy`aGbCcfgCg!4Q7==?moJ!#  L## ,''J44-2-J-J*8:5'+  ,")*+AAK N ) & )  < =)BVBVWZB[ 66y%HM(:: ::=IF**33JGGG11%888%*==    J'?+? $$++K8E001:: ::5eWHEF**33JGGG%*= J J $E (1(I5IE % J  . IdsOLzz'')       $ $ &/:5/A 46#"&  4,_   ,D*dCL"4T=.YG(z4@J ! 11H1H$PZ[K \V*J++([ +' $ LG"OK '7$#'#/ %&5# $ ""Q [Q [f : ")lD!I  **,C// 377JOOF ::j !":.EM  - -j 9 &ekk<F #"#'99 44.A/A5 $4b9++K0B0B0I0I0KL 6::m45B  O&1' n6O6O .7 # "=# _B 'u{{GTB ")%++z4"H ((002"MM!(gt!D$+EKKT$J$+EKKT$J#*5;; 4#H$+EKKT$J "'$8#, /%4J)K 22>BF%%j&9 9 9    +$E (*E % +## :++ : :$2266q9  :))00=++(f;GH%   m6lm m#ZZ;$jj)Bd2?C#c$"Ad2%d &d26dd2d( d21d 2d2>d)?&d2%d,&B d23d/4d2 ` d2d2`!!`+&d2. ad2ad2a+b6b b6b$ b63d25b66d29b<'+'?'?'A,    NNG   s:A99A A AA9A!A63A95A66A9c|jsytj}|jtj|j |y)zDSend the command advertisement after the session response is queued.N)rrkrlrmrnr)rrUros rgrz2HermesACPAgent._schedule_available_commands_updates<zz '')    !E!Ej!Q ric "|jd}|djdj}t|dkDr|dj nd}|j |j |j|j|j|j|j|j|jd j|}|y |||S#t$r+}t j#d||d d |d |cYd}~Sd}~wwxYw) zDispatch a slash command and return the response text. Returns ``None`` for unrecognized commands so they fall through to the LLM (the user may have typed ``/something`` as prose). rlrrrrYrNzSlash command /%s error: %sTrzError executing /: )rmrrnrr] _cmd_help _cmd_model _cmd_tools _cmd_context _cmd_reset _cmd_compact _cmd_steer _cmd_queue _cmd_versionr{rrrZ)rrrrcmdrthandlerr2s rgr[z$HermesACPAgent._handle_slash_commands  A &Ahooc"((*#&u:>uQx~~rNN____((__((____((   #c(  ? 24' ' 2 LL6QL N&se2aS1 1 2sC D# D D Dcddg}|jjD]\}}|jd|dd||jd|jddj|S)NzAvailable commands:rYz /10s z@Unrecognized /commands are sent to the model as normal messages.r)_SLASH_COMMANDSitemsrr)rrtrlinesrdescs rgrzHermesACPAgent._cmd_helpsq&+--335 2IC LL3s3ir$0 1 2 R WXyyricN|sH|jxst|jdd}t|jddxsd}d|d|St|jddxsd}|j||\}}||_|jj |j |j|||_|jj|j t|jddxs|xs|}tjd |j |d |d|S) NrrrautozCurrent model: z Provider: r!)rUrrrequested_providerz Session %s: model switched to %szModel switched to: ) rrr+r@r _make_agentrUrrjrr) rrtrrrr<r=r>r$s rgrzHermesACPAgent._cmd_modelsKKK75;;#KEu{{J=GH$UG<zB B"5;; DAQ\%)%B%B4IY%Z" **66'' . 7  ))%*:*:; j$?f?fVf 68H8H)T$YK|N;KLLric  ddlm}ddlm}ddlm}t t|jddxsdg}||d}|t|xsg|xsgDchc]3}t|tr!|jd ijd 5c}|t|jd d } || | j}|sy dt|dg} |D]s} | jd ijd d} | jd ijdd} t| dkDr| dddz} | jd| d| udj!| Scc}w#t"$r}d|cYd}~Sd}~wwxYw)Nrrw)SimpleNamespaceryr{r|T)r{rrr`_memory_manager)rrr{rzNo tools available.zAvailable tools (z):?rrYPM...rrrzCould not list tools: )rrxtypesrrrzrFrr+rrrr{rrrrr)rrtrrxrrztoolsetsrr tool_viewrtr`rr2s rgrzHermesACPAgent._cmd_tools s! 0 8 - I3 %7>P<.H)(tTE'5;B'!& "!$-HHZ,008" "* ' 5F M I ) 3OOE,(U B78E 2uuZ,00=uuZ,00Ct9r>9u,D r$r$01  299U# #)"* 0+A3/ / 0s7AE'8E" 5E' BE'"E'' E?0E:4E?:E?c t|j}i}|jD],}|jdd}|j|ddz||<.|j}|jxs t |dd}t |ddxsd } t |d d} t t | d dxsd} t t | d dxsd} dd lm} t |ddxsd}t |ddxsd}| |j||}| dkr| dkDrt | dz} |rd|dndd|jddd|jddd|jddd|jddg}|r|jd ||jd!| |dkDrB| dkDr'|| z d"z}|jd#|d$d%| d$d&|d'd(n|jd#|d$d)| dkDr|dkDrq| dkDr| | z d"znd}t| |z d}|| k\r%|jd*| d$|rd+|d,d-ndzd.zn?|jd/|d$d0| d$|rd+|d,d-ndzd1zn|jd2| d$d)t |d3dd4ur|jd5n|jd6d7j|S#t$rtjddd}YwxYw)8z;Show ACP session context pressure and compression guidance.rrrrlrrYrNrrBrCthreshold_tokensrDrFrrGz$Could not estimate ACP context usageTrg?zConversation: z messagesz(Conversation is empty (no messages yet).z user: rz , assistant: rz, tool: rz , system: systemzModel: r%r zContext usage: ~,z / z tokens (z.1fz%) tokensz!Compression: due now (threshold ~z, z.0f%z). Run /compact.zCompression: ~z tokens until threshold (~z).zCompression threshold: ~compression_enabledFz'Compression is disabled for this agent.zD#89 ZL 2;uyy+,M%))KQR:S9TUYYvq)**UYYx5K4L N    LL75'* + z(,- 1 !*^;sB  &}Q&7s>!:LIV_`cUddfg / a/@HI a q M[^_M_!1N!Bc Ief  0= @!D  $44LL;.> ? ^. eL NNBEDTDT_cN d e  - -e.>.> ?s#)A00-B B#B  B##'C c |jsy |j}t|ddsyt|dsyddlm}t |j}t|d d xsd }t|d dxsd}||j|| }t|d d} d|_|j|jt|d d xsd ||j\} } | |_| |_|jj|jt |j} t|d d xs|} t|d dxs|}||j| | }d|d| d|dd|dd S#| |_wxYw#t$r}d|cYd}~Sd}~wwxYw)Nu.Nothing to compress — conversation is empty.rTz/Context compression is disabled for this agent._compress_contextz1Context compression not available for this agent.rrDrFrYrrG _session_db)rr#zContext compressed: z -> z messages ~rz -> ~rzCompression failed: ) rOr+rrrNrErrrrUrrjr)rrtrr+rEoriginal_count _sys_prompt_toolsroriginal_session_db compressed_ new_count_sys_prompt_after _tools_after new_tokensr2s rgrzHermesACPAgent._cmd_compacts}}C0 .KKE5"7>H5"56J J /N"%)@"EKKUGT2:dF9 [M#*%"E  8%)! % 7 7MME#:B?E2"/!,, !8! A%8!&EM  - -e.>.> ?EMM*I '/F K Z{ "5'48BFL6 /"J '~&6d9+F!!$E*Qw@ %8!" .)!- - .sBE4 E4AE4AE(BE4( E11E44 F =FF F c|j}|sy|jrPt|jdr: |jj |r|ddt |dkDrdndz}d|S |j5|jj|t |j}dddd d S#t $r0}tjd|j|d|cYd}~Sd}~wwxYw#1swYKxYw) NzUsage: /steer rrrrYu&⏩ Steer queued for the active turn: z#ACP steer failed for session %s: %su⚠️ Steer failed: u.No active turn — queued for the next turn. (r ) r]rrr+rrrrrrUrr]r)rrtrrrpreviewrrws rgrzHermesACPAgent._cmd_steersZZ\ -    W = 5;;$$Z0("o#j/B:NTVWGCG9MM1   .  ' ' 3,,-E .@whOO 5DeFVFVX[\.se44 5 . .s)7B;<1C7; C4%C/)C4/C47Dc|j}|sy|j5|jj|t |j}dddddS#1swYxYw)NzUsage: /queue r r )r]rr]rr)rrtrrvrws rgrzHermesACPAgent._cmd_queuesfjjl +    .  ' ' 4,,-E .-UG8<< . .s 1AA(cdtS)NzHermes Agent v)r)rrtrs rgrzHermesACPAgent._cmd_versions/00ricJK|jj|}|rt|jdd}|j ||xsd\}}||_t |xr||k7}|rdnt|jdd} |rdnt|jdd} |jj||j||| | |_|jj|tjd|||tStjd|yw) z8Switch the model for a session (called by ACP protocol).rNr!rCrE)rUrrrrCrEz0Session %s: model switched to %s via provider %sz6Session %s: model switch requested for missing session)rrcrr+r@rrrrrjrrr(r) rr(rUrrr<rresolved_modelprovider_changedcurrent_base_urlcurrent_api_modes rgset_session_modelz HermesACPAgent.set_session_models'$$00< &u{{JE 151N1N 0L2 . )EK#$4$_9KO_9_` '7tWU[[R\^b=c '7tWU[[R\^b=c ..::%II$#5)) ;EK  - -j 9 KKB"   +, ,OQ[\sD!D#crK|jj|}|tjd|yt |xsdj }||j vr |j}t|d||jj|tjd||tSw)zNPersist the editor-requested mode so ACP clients do not fail on mode switches.Nz5Session %s: mode switch requested for missing sessionrYr zSession %s: mode switched to %s) rrcrrrr]rrsetattrrjrr))rmode_idrUrrnormalized_modes rgset_session_modezHermesACPAgent.set_session_modes$$00< = NNRT^ _gm,224 $"D"D D"00Ov/ ))*5 5z?S%''sB5B7c K|jj|}|tjd|yt ||j k(r=|j jt ||j}t|d|n:t|dd}t|tsi}||t |<t|d||jj|tjd||tgSw)zVAccept ACP config option updates even when Hermes has no typed ACP config surface yet.Nz7Session %s: config update requested for missing sessionr config_optionsz$Session %s: config option %s updated)r)rrcrrr_EDIT_APPROVAL_POLICY_CONFIG_ID_EDIT_APPROVAL_POLICY_TO_MODEr{rrrrrrjrr')r config_idrUrrrr optionss rgset_config_optionz HermesACPAgent.set_config_options$$00< = NNTV` a y>TAA A5599#e*dFXFXYD E64 (e%5t M*"0HO b/ 3.jP&=1  ), 8;  ' D(((+(7:( &( AA*-A69AEHA .Ag0%s# G.rr)rarr`rrbrrr)rsrrr)r_r rr)rbytesrsrrr)rarrz Path | None)rrrsrrr) rarrrr`rrbrrrrr)rr*rlist[dict[str, Any]])rrrr)rrrr)rrrzdict[str, Any] | None)rrrzstr | list[dict[str, Any]])yr __future__rrkrrrrerloggingr, collectionsrrconcurrent.futuresrpathlibr typingr r r urllib.parser rr acp.schemarrrrrrrrrrrrrrrrrr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2r3r4r5r6r7r8r9acp_adapter.authr:r;r<acp_adapter.eventsr=r>r?r@rAacp_adapter.permissionsrBacp_adapter.provenancerCacp_adapter.sessionrDrErFacp_adapter.toolsrGrHtools.approvalrIrJ getLoggerrr hermes_clirKrrrhrrrprqrhrurwr|rrrrrrrrrAgentrr'rirgrsN"'   *1''* ,,,,,,,,,,,,\`_;:ZZC   8 $8 1 M $)  >^% O F 2  -  -  -  -  -  -  -` F.b  & < 0 0 0fjASYYjAY Ns>E;;FF