`gjSh d Z ddlmZ ddlZddlZddlZddlZddlZddlZddl Z ddl
Z
ddl m Z ddl
mZ ddlmZ ddlmZ ddlmZmZ dd lmZmZ dd
lmZ dd lm Z d Z d
Z ej> dej@ Z! ej> dej@ Z"dZ#dZ$d%dZ%d&dZ&d'dZ'd&dZ(d(dZ)d)dZ*d*dZ+ d+ d,dZ,d-dZ- d.dZ.d/d Z/d0d Z0d1d Z1 G d d Z2 G d! d" Z3 G d# d$ Z4y)2at OpenAI-compatible shim that forwards Hermes requests to `copilot --acp`.
This adapter lets Hermes treat the GitHub Copilot ACP server as a chat-style
backend. Each request starts a short-lived ACP session, sends the formatted
conversation as a single prompt, collects text chunks, and converts the result
back into the minimal shape Hermes expects from an OpenAI client.
) annotationsN)deque)Path)SimpleNamespace)Any ChatCompletionMessageToolCallFunction)get_read_block_errorget_write_denied_error)redact_sensitive_text)hermes_subprocess_envz
acp://copilotg @z&\s*(\{.*?\})\s*zd\{\s*\"id\"\s*:\s*\"[^\"]+\"\s*,\s*\"type\"\s*:\s*\"function\"\s*,\s*\"function\"\s*:\s*\{.*?\}\s*\})z
gh-copilot)zhas been deprecatedz no commands will be executedc | j t fdt D syt fdt D S )zHTrue iff stderr looks like the deprecated gh-copilot extension's banner.c 3 & K | ] }|v
y wN ).0reqlowers K/root/.hermes/venv/lib/python3.12/site-packages/agent/copilot_acp_client.py z5_is_gh_copilot_deprecation_message..9 s =se|= Fc 3 & K | ] }|v
y wr r )r markerr s r r z5_is_gh_copilot_deprecation_message..; s B6vBr )r any_DEPRECATION_REQUIRED_DEPRECATION_MARKERS) stderr_textr s @r "_is_gh_copilot_deprecation_messager 5 s7
E ='<= = B-AB BB c t j dd j xs( t j dd j xs dS )NHERMES_COPILOT_ACP_COMMAND COPILOT_CLI_PATHcopilot)osgetenvstripr r r _resolve_commandr) > sD
.399;
99' , 2 2 4 r c t j dd j } | sddgS t j | S )NHERMES_COPILOT_ACP_ARGSr# z--acpz--stdio)r& r' r( shlexsplit)raws r
_resolve_argsr/ F s9
))-r
2
8
8
:C ## ;;s r c ` t j j dd j } | r| S t j j d }|r|dk7 r|S ddl}|j t j j j }|r|S y# t $ r Y yw xY w)z-Return a stable HOME for child ACP processes.HOMEr# ~r Nz/tmp) r& environgetr( path
expanduserpwdgetpwuidgetuidpw_dir Exception)homeexpandedr7 resolveds r _resolve_home_dirr? M s
::>>&" % + + -D ww!!#&HHO
<< ,3399; O
s AB! ! B-,B-c X t d } t }|| d< ddlm} || | S )NT)inherit_credentialsr1 r )apply_subprocess_home_env)r r? hermes_constantsrB )envr< rB s r _build_subprocess_envrE f s/ D
9C DCK: c" Jr c d| ||ddS )N2.0)codemessage)jsonrpciderrorr )
message_idrH rI s r _jsonrpc_errorrN r s
r c d| dddiidS )NrG outcome cancelledrJ rK resultr )rM s r _permission_deniedrT } s$ ;
r c g d}|r|j d| t |t r|rg }|D ] }t |t s|j d xs i }t |t s:|j d }t |t
r|j
sl|j |j
|j dd |j di d |r)|j d t j |d
z |)|j d t j |d
g } | D ] }
t |
t st |
j d
xs d j
j } | dk( rd} n| dvrd} |
j d } t | }
|
s{ddddddj | | j }| j | d|
| r#|j ddj | z |j d dj d |D S ) N)z>You are being used as the active ACP agent backend for Hermes.z'Use ACP capabilities to complete tasks.zIMPORTANT: If you take an action with a tool, you MUST output tool calls using {...} blocks with JSON exactly in OpenAI function-call shape.z&If no tool is needed, answer normally.z Hermes requested model hint: functionname descriptionr#
parameters)rW rX rY zAvailable tools (OpenAI function schema). When using a tool, emit ONLY {...} with one JSON object containing id/type/function{name,arguments}. arguments must be a JSON string.
F ensure_asciizTool choice hint: roleunknowntool> usersystem assistantcontextcontentSystemUser AssistantToolContext)r` r_ ra r^ rb z:
zConversation transcript:
z
z7Continue the conversation from the latest user request.c 3 d K | ]( }|s|j s|j * y wr r( )r sections r r z-_format_messages_as_prompt.. s ^7'gmmow}}^ 000)
append
isinstancelistdictr4 strr( jsondumpsr _render_message_contenttitlejoin)messagesmodeltools tool_choicesections
tool_specstfnrW
transcriptrI r\ rc renderedlabels r _format_messages_as_promptr s- H
7w?@% 5+-
A a&z"(bB b$'66&>D dC(
JJL#%66-#<"$&& r":
OOb **Ze<=
,TZZ RW-X,YZ[ J 3'4( 7;;v&3)4::<BBD 6>D
8
8 D++i(*73 $
#dDJJL
!
UG3xj12+3. 6Z9PPQ OOMN ;;^h^ ^^r c @ | yt | t r| j S t | t rd| v r,t | j d xs d j S d| v rKt | j d t r,t | j d xs d j S t j | d S t | t rg }| D ] }t |t r|j | %t |t s6|j d }t |t sX|j si|j |j dj | j S t | j S )Nr# textrc TrZ
)
rn rq r( rp r4 rr rs ro rm rv )rc partsitemr s r rt rt s> '3 }} '4 W w{{6*0b1779 9 Jw{{9/Es$Kw{{9-34::< <zz'55'4 /D$$ T"D$'xx' dC(TZZ\LL .
/ yy %%'' w< r c
8 t | | ddt || S )zDBuild an OpenAI-compatible tool-call object for downstream handling.NrV rW arguments)rK call_idresponse_item_idtyperV r r rW r s r _build_openai_tool_callr s' )
ty9 r c r | j d }|j }d}|j rg }t |j D ]n \ }}|j t |t
|dd t
|dd t t
|j dd t
|j dd p t d
|j xs d||j |j }t t d||j g| j d
}t g | j | j
}||gS )z@Convert a one-shot ACP response into OpenAI-style stream chunks.r NrK r rV rW r r )indexrK r rV ra )r\ rc
tool_callsreasoning_content reasoning)r delta
finish_reason)choicesrx usage)r rI r enumeraterm r getattrrV rc r r r rx r )
completionchoicerI tool_call_deltasr tool_callr
data_chunk usage_chunks r _completion_to_stream_chunksr s@
"FnnG )'*<*< = E9 # # y$5 FJ? , $Y%7%7 F"))*<*._try_add_tool_call1 s **X&C #t$
WWZ
"d# &&.'3'w}} &&d+'3'jju=G''$-'3'w}}!#i."2!34G # ]]_!
# s D$ $ D0/D0r r r c 3 d K | ]( }|s|j s|j * y wr rj )r ps r r z0_extract_tool_calls_from_text..m s DaA!'') Drl )r rq returnNone)rn rq r( _TOOL_CALL_BLOCK_REfinditergrouprm startend_TOOL_CALL_JSON_REsortmaxr rv ) r consumed_spansr mr. mergedr r r cursorcleanedr s @r _extract_tool_calls_from_textr * s dC
2v
57I,.N
8 !
)
)$
/ 4ggaj3 qwwy!%%' 234 #,,T2 8A''!*C s # ! !1779aeeg"6 7 8
$**,&&$&F$ B
sA . MM5#, ' *Q-VBZ]C)@AF2J B E
F "
s E> LLfU+ ,VS!" D
T&']#iiD5DDJJLG g r c t | }|j s t d |j }t | j } |j | |S # t
$ r}t d| d| d |d }~ww xY w)Nz'ACP file-system paths must be absolute.zPath 'z ' is outside the session cwd 'z'.)r is_absolutePermissionErrorresolve relative_to
ValueError) path_textcwd candidater> rootexcs r _ensure_path_within_cwdr r s YI " GHH "H 9 Db T" O b xj0NtfTV WX^aabs A$ $ B-B Bc e Zd ZddZddZy)_ACPChatCompletionsc || _ y r )_clientselfclients r __init__z _ACPChatCompletions.__init__ s r c : | j j di |S )Nr )r _create_chat_completion)r kwargss r createz_ACPChatCompletions.create s 3t||33=f==r Nr z'CopilotACPClient')r r r r )__name__
__module__ __qualname__r r r r r r r s >r r c e Zd ZddZy)_ACPChatNamespacec $ t | | _ y r )r completionsr s r r z_ACPChatNamespace.__init__ s .v6r Nr )r r r r r r r r r s 7r r c e Zd ZdZddddddddd d dZd dZddddddd d
dZdd Z dd
Zy)CopilotACPClientz8Minimal OpenAI-client-compatible facade for Copilot ACP.N)api_keybase_urldefault_headers acp_commandacp_argsacp_cwdcommandargsc |xs d| _ |xs t | _ t |xs i | _ |xs |xs
t | _ t |xs |xs
t | _ t t |xs t j j | _ t! | | _ d| _ d | _ t) j* | _ y )N copilot-acpF)r ACP_MARKER_BASE_URLr rp _default_headersr) _acp_commandro r/ _acp_argsrq r r& getcwdr _acp_cwdr chat is_closed_active_process threadingLock_active_process_lock)
r r r r r r r r r _s
r r zCopilotACPClient.__init__ s /- 7$7
$_%: ; ' H7 H6F6H h A$ A-/BD!7BIIK 8 @ @ BC
%d+ =A $-NN$4!r c & | j 5 | j }d | _ d d d d| _ y |j |j d y # 1 sw Y 7xY w# t
$ r$ |j
Y y # t
$ r Y Y y w xY ww xY w)NT timeout)r r r terminatewaitr; kill)r procs r closezCopilotACPClient.close s
&
& (''D#'D ( < NN IIaI ( (
s4 A"A# A # B-A?? B B B BF)rx rw r ry rz streamc ^ t |xs g ||| }|t } n~t |t t f r t | } n\dD
cg c] }
t ||
d } }
| D cg c]$ } t | t t f st | & }
} |
r t
|
nt } | j || \ }}t | \ }}t dddt d }t |||xs d |xs d d }|rdnd }t ||
}t |g||xs d }|r t | S |S c c}
w c c} w )
N)rx ry rz )readwriteconnectpoolr )timeout_secondsr )
cached_tokens)
prompt_tokenscompletion_tokens total_tokensprompt_tokens_details)rc r r r reasoning_detailsr stop)rI r r )r r rx ) r _DEFAULT_TIMEOUT_SECONDSrn intfloatr r _run_promptr r r )r rx rw r ry rz r r prompt_text_effective_timeoutattr _candidatesv_numeric
response_textreasoning_textr cleaned_textr assistant_messager r r s r r z(CopilotACPClient._create_chat_completion sh 1 N#
?!9
#u
.!&w L t,K +6UQAU|9TaUHU2:X @X (,(8(8 . )9 )
%
~
$A #O
L "1"B
, !$, , 4 "
)3
):-X$H(=
/
; ;I Vs D% D*9
D*c
t j j g j z t j t j t j dd j
t
j j j t d d _ j 5 _ d d d t j
t# d d!
fd
}d!fd }t% j& |d }t% j& |d }|j) |j) d
d d dd"
fd} |ddddddiddddd |d j
g d xs i } t+ | j- d xs d j/ }
|
s t d g } g } |d |
d |d gd | | dj1 | dj1 | f j3 S # t $ r }t d j d |d }~ww xY w# 1 sw Y uxY w# j3 w xY w)#NTr )stdinstdoutstderrr bufsizer rD z%Could not start Copilot ACP command 'zQ'. Install GitHub Copilot CLI or set HERMES_COPILOT_ACP_COMMAND/COPILOT_CLI_PATH.z6Copilot ACP process did not expose stdin/stdout pipes.F( )maxlenc j y j D ]' } j t j | ) y # t $ r% j d| j d i Y Xw xY w)Nr. r )r! putrr r r; rstrip)lineinboxr s r _stdout_readerz4CopilotACPClient._run_prompt.._stdout_reader sh {{"
::IIdjj ./
: ! :IIudkk$&7 89:s $A+A43A4c j y j D ]" } j | j d $ y )Nr )r" rm r( )r) r stderr_tails r _stderr_readerz4CopilotACPClient._run_prompt.._stderr_reader s: {{"
6""4;;t#45
6r )targetdaemonr )
text_partsreasoning_partsc d dz
}d|| |d} j j t j | dz j j t j z }t j |k r j n
j d }
j |
j || r\|j d |k7 rqd |v r9|j d xs i }t d
| d |j d xs | |j d
S dj j } j )| r't! | rt d| t d| t# d| d # t j $ r Y ._request+ s qLG J G
JJ TZZ 04 7 8 JJ ~~'/9H.."X-99;* ))C)0C ..
)$3 / 774=J. c> '''*0bC&&vhi 8J8Qc7RS wwx(( ))K0668Kyy{&;5kB& , -8= :
#%G }#UVV !OPVxWX YZ ZO {{ s F F/.F/
initializefs) readTextFile
writeTextFilez hermes-agentz Hermes Agentz0.0.0)rW ru version)protocolVersionclientCapabilities
clientInfoz session/new)r
mcpServers sessionIdr# z'Copilot ACP did not return a sessionId.zsession/promptr )r r )rQ promptr r )
r4 rq r5 dict[str, Any]r1 list[str] | Noner2 rU r r )
subprocessPopenr r PIPEr rE FileNotFoundErrorr? r r! r r r r r< Queuer r Threadr rq r4 r( rv r )r r r r r+ r.
out_thread
err_threadrG session
session_idr1 r2 r* rF r r- s ` ` @@@@r r z CopilotACPClient._run_prompt sh ##""#dnn4 oo!!MM)+ D :: !4 IIK WX X
&
& (#'D ( .3[[]"'r"2 : 6 %%^DI
%%^DI
\` GK : [ : [x/ '( ,0-1 + !/!/#*#
" =="$
W[[ 5 ;<BBDJ "#LMM$&J)+O !+ %+$/ & /
77:&(@@ JJLe ! 78I8I7J Ka a
( (N
JJLs1 A1H ?H: B!I H7H22H7:IIc 6 |j d }t |t sy|dk( r|j d xs i }|j d xs i }t |j d xs d j } |j d xs i }
d} t |
t r t |
j d xs d } | d
k( r| r||j | y | d k( r| r||j | y |j y |j d
} |j d xs i }|dk( r
t | }
n|dk( r t t |j d xs d | }t t | }|r t | |j }
|j d }|j d }t |t rL|dkD rG|
j d }|dz
}t |t r
|dkD r||z nd }dj ||| }
|
r
t! |
d }
d| d|
id}
n|dk( r t t |j d xs d | }t' t | }|r t | |j( j+ d d |j- t |j d xs d d| d d}
nt% | d d | d }
|j j/ t1 j2 |
d z |j j5 y # t $ r d}
Y w xY w# t" $ r }t% | dt | }
Y d }~d }~ww xY w# t" $ r }t% | dt | }
Y d }~d }~ww xY w) Nr4 Fzsession/updater5 update
sessionUpdater# rc r agent_message_chunkagent_thought_chunkTrK zsession/request_permissionzfs/read_text_filer5 r) limitr )keependsr )forcerG rR izfs/write_text_file)parentsexist_okizACP client method 'z!' is not supported by Hermes yet.r )r4 rn rq r( rp rm r rT r r r read_textrY r
splitlinesrv r
r; rN r parentmkdir
write_textr rr rs r8 )r rD r6 r r1 r2 r4 r5 ra kindrc
chunk_textrM responser5 block_errorr) re linesr r r denieds r r> z'CopilotACPClient._handle_server_message sq "&#& % %WWX&,"FZZ)/RFvzz/28b9??AD jj+1rGJ'4( V!4!: ;
,,
@V!!*- ..:/B] &&z2 == WWT]
"(b 1 1)*5H
*
*
H.s6::f3E3K/LcR 23t9 = )+66! "nn .G zz&)
7+ dC(TAX # . . . =E 1HE+5eS+Aeai%%-UYC ggeE#&6 7G 3G4 HG $$!7 +
+
H.s6::f3E3K/LcR/D :)&11 !!$!>FJJy$9$?R @A $$ " &%fX-NOH
DJJx 04 78
Y ) ! G!$
H)*fc#hG
H
H)*fc#hG
HsW A M L1 BM :BM/ 1 M <M ?M M M, M''M,/ N8NN)r
str | Noner ru r zdict[str, str] | Noner ru r rU r ru r ru r rU r r rS )rx ru rw list[dict[str, Any]] | Noner z float | Nonery rv rz r r boolr r r r )r rq r r r ztuple[str, str]) rD rT r6 zsubprocess.Popen[str]r rq r1 rU r2 rU r rw ) r r r __doc__r r r r r> r r r r r s: B
# #15"&%) " "!%5 5 5
/ 5
5 #5 5 5 5 50( !04 $-1 > > . >
> +
> > > >
>@^@W
W ' W
W %
W *W
Wr r )r rq r rw )r rq )r z list[str])r zdict[str, str])rM r rH r rI rq r rT )rM r r rT )NNN)
rw zlist[dict[str, Any]]rx ru ry rv rz r r rq )rc r r rq )r rq rW rq r rq r r )r r r zlist[SimpleNamespace])r rq r z/tuple[list[ChatCompletionMessageToolCall], str])r rq r rq r r )5rx
__future__r rr r& r< rer, rV r r9 collectionsr pathlibr typesr typingr 3openai.types.chat.chat_completion_message_tool_callr r
agent.file_safetyr r agent.redactr
tools.environments.localr r r compileDOTALLr r r r r r) r/ r? rE rN rT r rt r r r r r r r r r r r sv # !
K . :% bjj!JBIIV RZZ !H JL JS JS T ( C 2 )- H_"H_ H_ 'H_ H_
H_V 0
#
+%\D P
> >7 7
c cr