+ kHj.Ja0t$Rt^RIHt^RIt^RIt^RIt^RIt^RI t^RI H t H t ^RI HtHt^RIHtHt^RIHtHt]P0!]4t^xt^tRRltR R ltR R ltR Rlt RRlt!R\RRllt"RRlt#RRlt$RRlt%RRlt&RRlt'RRlt(RR lt)R!t*R"]*R#]*R$R%/t+R&R'lt,R(R)lt-R\R*R+llt.R,R-lt/R.R/lt0R]R0R1llt1R2R3lt2R4R5lt3R6],R7R8]3!R94/R8.3R:]-R;R<]3!R=4R>]3!R?4R@]3!RA4/R.3RB].RC/.3RD]/RER@]3!RF4RGRHRIRJRK//R@.3RL]2RMRN]3!RO4R>]3!RP4RQRHRRRS.R^ORJRT/R@]3!RU4/RNR>.3/t4RV]5RW&RXRYlt6RZR[lt7R#)_a(A2A client tools (``a2a`` toolset): a2a_discover/call/list/history/orchestrate talk to *other* agents. Peers come from config.yaml ``a2a_agents: {name: {url, auth: {type: bearer, token}, timeout, capabilities}}``. Stdlib urllib; wire format is A2A v1.0 ``SendMessage`` (v0.3 replies still parse).) annotationsN)ThreadPoolExecutor as_completed)AnyOptional) coerce_portget_scoped_secret)protocolsecuritycV^8dQhRR/#returndict)formats"@/home/ubuntu/.hermes/hermes-agent/plugins/platforms/a2a/tools.py __annotate__rs((d(c0^RIHpV!4;'g/#)zORead-only view of config.yaml; peers are only read, never mutated (cache-safe).load_config_readonly)hermes_cli.configrrs r _load_configrs6  ! ' 'R'rcV^8dQhRR/#r r)rs"rrrs2242rcH\4PR4;'g/#) a2a_agents)rgetrrr_configured_peersrs >  l + 1 1r1rc$V^8dQhRRRRRR/#)r entryrextrarrr)rs"rrr#s&MMDM3M4Mrc RVPRR4RVPR/4;'g/R\VPR\44/VC#)urlauthtimeout)rint_DEFAULT_TIMEOUT)r r!s&,r_peer_from_entryr)#sT 599UB'621F1L1L" s599Y0@AB MFK MMrc V^8dQhRRRR/#)r agentstrrOptional[dict]r)rs"rrr(sHHHHrcVPR 4'dRVR/R\R./#\4PV4pV'd8\ YPR.4;'g.VPRR4R7#R#) zUPeer name -> {url, auth, timeout, capabilities, tenant}, or treat ``agent`` as a URL.r#r%r& capabilitiestenantr$)r/r0N)zhttp://zhttps://) startswithr(rrr))r+r s& r _resolve_peerr2(s /00ufb)5E~WYZZ   # #E *Ex} E ."0M0S0SQS\a\e\efnpr\s tHDHHrc V^8dQhRRRR/#)r r%rrr)rs"rrr0strcV'd<VPR4R8Xd&VPR4'dRRVR, 2/#/#)typebearertoken AuthorizationzBearer r)r%s&r _auth_headerr:0sC;?DHHVDTX`D`eiememnuevevOwtG}o6 7~|~~rc 0V^8dQhRRRRRRRRRR R R/#) r r#r,headersrr&r'methoddatazOptional[bytes]rr)rs"rrr4s777C7$77c77dh7rc8\PPWWR7p\PPWRR7;_uu_4p\P !VP 4PR44uuRRR4# +'giR#;i))r>r<r=)r&utf-8N)urllibrequestRequesturlopenjsonloadsreaddecode)r#r<r&r=r>reqresps&&&&& r _http_jsonrK4sa ..  PC     5 5zz$))+,,W56 6 5 5 5s 3B B c(V^8dQhRRRRRRRR/#)r r#r,r<rr&r'rr)rs"rrr:s(444d4S4T4rc\WVR4#)GET)rK)r#r<r&s&&&r_http_get_jsonrO:s cGU 33rc ,V^8dQhRRRRRRRRRR/#) r r#r,bodyrr<r&r'rr)rs"rrr>s6TTTDT4T#T$Trc RRR\P/VCp\WVR\P!V4P R44#)z Content-Typezapplication/jsonz A2A-VersionPOSTr@)r PROTOCOL_VERSIONrKrEdumpsencode)r#rQr<r&hdrss&&&& r_http_post_jsonrX>sB . x?X?X d\c dD c&$**T2B2I2I'2R SSrc(V^8dQhRRRRRRRR/#)r base_urlr,r<rr&r'rr)rs"rrrCs.NN#NNsNtNrcVPR4p\VR,W4# \PPdpTP R8wdhRp?MRp?ii;i\TR,Y4#)zLGET the v1.0 agent-card.json; on 404 fall back to the v0.2 agent.json alias./z/.well-known/agent-card.jsoniNz/.well-known/agent.json)rstriprOrAerror HTTPErrorcode)rZr<r&basees&&& r _fetch_cardrcCsj ??3 Dd%CCWVV << ! ! 66S=   $!::G MMs&A!AA!c V^8dQhRRRR/#)r cardr-rr)rs"rrrNsN~rc\V\4'doVPR.4;'g.FNp\V\4'gKVPR4R8XgK3VPR4'gKLVu# R#)supportedInterfacesprotocolBindingJSONRPCr#N isinstancerr)reifaces& r_select_jsonrpc_interfacermNsj$XX3R8>>B>E%&&5995F+G9+TY^YbYbchYiYi ? rc$V^8dQhRRRRRR/#)r rZr,rer-rr)rs"rrrVs!  s . S rc\V4;p'd\VR,4#\V\4'd>\VP R4\4'dVR,'d VR,#VP R4#)zYCard's JSONRPC interface (v1.0 supportedInterfaces) > card's legacy top-level url > base.r#r\)rmr,rkrrr])rZrerls&& r_rpc_urlrpVsc)$//u/5<  $*TXXe_c"B"BtE{{E{ ??3 rc ,V^8dQhRRRRRRRRRR/#) r agent_labelr,peerrmessage context_idrztuple[str, str, str]r)rs"rrr_s0!#!#C!#t!#c!#s!#Oc!#rcVPRR4p\VPR/4;'g/4p\VPR\44p\ WE\ V^44pT;'g\P!4p\P!V4p RRR\P!4R R R R \P!\PWR 7//p \V4p V 'd*V PR4'd\V R,4M#\VPR4;'gR4p V 'd WR ,R&\P !RW R,V 4\P"!VRWR,4\P$;P&^, un\)\+WG4WV4p RV 9d0\-RV RV R,PR V R,4 24h\P.!V PR/44p\1V4pTRpp\3V\44'd>VPRV4pVPR4;'g/PRR4p\P"!VRWR,4\P$;P6^, unVVV3# \ dRpELi;i)zOne SendMessage to a peer -> (reply_text, context_id, state). Raises urllib errors / ValueError for the caller to format; handles redaction, audit, persistence, metrics.r#r$r%r&Njsonrpcz2.0idr= SendMessageparamsrt)rur0outbounduserr^zPeer 'z' returned an error: result contextIdstatusstater+)rr:r'r(rcmin Exceptionr new_context_idr redact_outbound new_task_id text_message ROLE_USERrmr,auditpersist_messagemetricsoutbound_totalrXrp ValueErrorunwrap_send_message_response_reply_text_from_resultrkr inbound_total)rrrsrtrurZr<r&rectx safe_messagerpc_bodyrlr0rJpayloadreply reply_ctxrs&&&& r _send_taskr_saxxr"H488FB/5526G$((9&678G8c'2.>?  1 1//1C++G4L5$(<(<(>-9h&;&;H YG ""a'" )U ""3 sK K.-K.c V^8dQhRRRR/#)r r}rrr,r)rs"rrrs \ \C \C \rc\P!V4p\V\4'g \ V4#VP R.4;'g.F%p\P !V4pV'gK#Vu# \P !VP R/4;'g/P R4;'gT4#) artifactsrrt)r rrkrr,r extract_text)r}artifacttxts& rrrs  2 26 :F fd # #6{JJ{B/5525##H- 3J6  &**Xr":"@"@b!E!Ei!P!Z!ZTZ [[rzNError: peer '{agent}' rejected auth (HTTP {code}). Check the configured token.iiiz>Error: peer '{agent}' rate limited us (HTTP 429). Retry later.c$V^8dQhRRRRRR/#r argsr_rrr,r)rs"rrrs!t##rc \VPR4;'gR4P4pV'gR#\V/\4pTPR /4;'g/pTPR .4;'g.pTPR 4'dR MRpRPRTPR.4;'g.44;'gRTPRR4 R2pRTPRR4 2RTPRR4 2R\Y#4 2RT 2R\TPR44 R\TPR44 R T 2R!\T4 R"2.p T PR#TR$,44R%PT 4# \ P PdpRTP RT R2uRp?#Rp?i\dpRT R T R2uRp?#Rp?ii;i)&z.Fetch and summarize the Agent Card at ``url``.r#r$z6Error: 'url' is required (e.g. http://localhost:9999).u!Error: discovery failed — HTTP z from .NzError: could not reach u — r/skillsr yesno, c3"TFDp\V\4'gKVPRR4 RVPRR4 2xKF R#5i)rh?z vprotocolVersionNrj).0is& r a2a_discover..sH;A 1d@S L155"C ( )AEE2CS,I+JK;s A/Argvrrz (pre-1.0 card)zAgent: namez Description: descriptionzURL: z Protocol: z Streaming: streamingz Push: pushNotificationsz Auth required: zSkills ():c 3"TF=pRVPRVPRR44 RVPRR4 2xK? R#5i) - rrxr: rr$Nr9)rss& rrrsDk_jZ[4faeeD#&678155PR;S:TU_jsAA:NN )r,rstriprcr(rAr^r_r`rjoinrpboollenextend) rrr#rerbcapsrr%protoliness &, r a2a_discoverrs dhhuo## $ * * ,C G83$45 88NB ' - -2D XXh # ) )rFHHZ((5dD II((0"5;;;  ? ? TXX' - .o > txx,- .-XZ@[?\0]afgopsgzf{_|% !4 567xTXXNaEb@c?dduvzu{ |F }B ' )E LLk_efi_jkk 99U ! << ! !H2166(&QGG 8(U1#Q778s5F%%G=GG= G=)G=*G82G=8G=c$V^8dQhRRRRRR/#rr)rs"rrrs!4ccrc \VPR4;'g5VPR4;'gVPR4;'gR4P4p\VPR4;'g5VPR4;'gVPR4;'gR4P4p\VPR4;'gVPR 4;'gR4P4pV'd V'gR #\V4pV'dVPR 4'gR V R 2#\ W%W44wrgpTPRR4PRR4P4p RT RT 2T'dRT 2MR,R,p T;'gRp T\P 8XdT RT R2, p T RT 2# \ P PdEp \PT PR4PY)PR7uRp ? #Rp ? i\dp \T 4uRp ? #Rp ? i\dp RT RT R2uRp ? #Rp ? ii;i)zaSend a task to a peer (configured name or direct URL); ``context_id`` continues a prior exchange.r+ agent_namerr$rttexttaskrur~z/Error: both 'agent' and 'message' are required.r#zError: unknown agent 'zP'. Configure it under 'a2a_agents' in config.yaml or pass a full http(s):// URL.u0Error: call to '{agent}' failed — HTTP {code}.)r+r`NzError: call to 'u ' failed — r TASK_STATE_r-[u · context u · ]z(no text reply)uS (The peer needs more input — answer by calling a2a_call again with context_id 'z'.)r)r,rrr2rrAr^r__HTTP_CALL_ERRORSr`rrrreplacelowerr STATE_INPUT_REQUIRED) rrr+rtrursrrrrb short_stateheaderrQs &, ra2a_callrs+ !UUTXXl%;UUtxx?OUUSU V \ \ ^E$((9%SS&)9SSTXXf=MSSQSTZZ\GTXXl+JJtxx /DJJKQQSJ @  D txx'w.~;",U'"N%-- r2::3DJJLK|I; /5T+3GVX Y\_ _F  % %%D --- ghqgrruvvXRv  << ! !B $$QVV-_`ggns{A{AgB B 1v ;!% aS::;sNG..J  9I J  J J  I*$J * J 7J 8JJ J c$V^8dQhRRRRRR/#)r rz dict | Nonerrrr,r)rs"rrrs!;CCrc \4p.pV'dVPR\V4 R24VP4FwrEVP R.4pTPRT RVP RR4 RVP R 4;'g/P R R 4 R 2V'dR RP V4 2MR,4K MVPR4\ P!4;p'dOVPR4VPR\V4 R24VPRVR,44\ PP4pVPR4VPRVR, RVR, RVR, RVR, RVR, RVR , R!VR", R#VR$, R%VR&, R'24R(P V4#))z@List configured A2A peers, persisted conversations, and metrics.zConfigured peers (rr/rrr#rz (auth: r%r5none)z caps: rr$z@No peers configured. Add them under 'a2a_agents' in config.yaml.zPersisted conversations (u) — recall with a2a_history:c3,"TF pRV 2xK R#5i)rNr)rcs& rra2a_list..s5AtA3Zs:NNz Metrics: rz in / rz out, tasks_completedz completed, tasks_failedz failed, streams_startedz streams, push_sentz push sent, anti_loop_triggersz anti-loop, rate_limit_triggersz rate-limited, avg avg_latency_msmsr) rappendritemsrrr list_conversationsrrsnapshot) rrpeersrrr rconvosms &, ra2a_listrs  E E  )#e*R89 ;;=KD99^R0D LL4vR %(='>h RXHYH_H_]_GdGdekmsGtFuuvw;?gdiio%67RI J)  WX,,..v. R 0V =[\] 555!!#A LL LL9Q/0q9I7J6K6RSTeRfQggsn%&i2C0D/EZPQR]P^O__k*+,L;P9Q8RRefghxfyezz|~ 99U rc$V^8dQhRRRRRR/#rr)rs"rrrs!  d   rc \VPR4;'gVPR4;'gR4P4pV'gR#\^\ \ VPR4;'g^2^24^44p\ P!W#R7pV'gRV R2#R V R \V4 R 2.pVFspVPR 4;'gRP4pTPR VPRR4 R\V4R8dVR,R,MT 24Ku RPV4#)zCRecall a persisted A2A conversation (survives compaction/restarts).rur~r$zGError: 'context_id' is required (see a2a_list for known conversations).limit)rz'No persisted conversation for context ''.z Conversation z (last z messages):rrrolerz] i:NiNu …[truncated]r) r,rrmaxr _coerce_intr load_conversationrrr)rrrurmessagesrrrs&, r a2a_historyrs TXXl+JJtxx /DJJKQQSJ X 3{488G#4#:#:B?E FE))*BH 8 BGGZLH k J KE f ##**, qvs+,BRUVZR[^bRbtE{=N/Nhl.mno 99U rc V^8dQhRRRR/#)r capabilityr,rzlist[tuple[str, dict]]r)rs"rrrsYY3Y3IYrc \4P4UUu.uF1wrYPR.4;'g.9g VR8XgK.W3NK3 upp#uuppi)zAConfigured peers that advertise the capability ('*' matches all).r/*)rrr)rrr s& r_match_peers_by_capabilityrs^->-@-F-F-H Y-Hkdii;AArBjTWFW TM-H YY YsA A Ac ,V^8dQhRRRRRRRRRR/#) r rr, peer_entryrrtrurztuple[str, str]r)rs"rrrs1+++++QT+^m+rc\V\V4W#4wrEpY;'gR3# \dpTRT 23uRp?#Rp?ii;i)z=Call a single peer synchronously -> (agent_name, reply_text).z (no reply)Error: N)rr)r)rrrtrur_ctx_staterbs&&&& r_call_peer_syncrsS+(5Ej5QSZgV11\22 +gaSM**+s%( A?AAc$V^8dQhRRRRRR/#rr)rs"rrrs&#c#c$#cS#cS#crc \VPR4;'gR4P4p\VPR4;'gVPR4;'gR4P4p\VPR4;'gR4P4P4pVR 9dTMRp\VPR 4;'gR4P4pV'gR #V'gR #\ V4;p'gR V R 2#.p\ \ \V4\4R7;_uu_4pVU U u/uFwrVP\WW54V bK p p p \V 4Ftp W,p VPV P44VR8XdCVR!,^,PR4'gV Fp V P4K MKtKv RRR4VP#RR7VU Uu.uF!wrVPR4'dKW3NK# pp pVR"9dgV'g4RP%R.VU Uu.uF wrRV RV 2NK upp ,4#VR8Xd\'VRR7MV^,wrRV RV RV 2#RP%RV R\V4 R2.VU UUu.uFwrRV R2V3FpVNK K uppp ,4#uup p i \ d#pTPT RT 234Rp?EKRp?ii;i +'giELD;iuupp iuupp iuuppp i)#uFan-out a task to peers matching a capability. Modes: ``all``, ``first`` (first successful), ``best`` (longest successful — coarse; use ``all`` to judge yourself).rr$rtrmodeallfirstbestruzError: 'message' is required.z;Error: 'capability' is required (or use '*' for all peers).z1Error: no configured peers advertise capability 'r) max_workerszError:rNcV^,#)rrs&r!a2a_orchestrate..sqtr)keyrzAll peers failed:z rc&\V^,4#))rr s&rr r s 3qt9rrz] zOrchestrated 'z' to z peer(s):z --- z ---rrr)rr)r,rrrrrrr_ORCHESTRATE_MAX_WORKERSsubmitrrrr}r1cancelrsortrr)rrrrtrrumatchesresultspoolrr futuresfutfrbr successeslines&, ra2a_orchestratersTXXl+11r288:J$((9%??&)9??R@FFHG txx((5 ) / / 1 7 7 9D334DTXXl+11r288:J . L1*= =G =B:,bQQ%'G CL:R(S T TX\krskr\g\`4;;WQSWWkrs(C+D+DX+N+N$ %,O? ) U LL^L$29\';4AQAQRZA[$'I\   9912^e5f^e{t4&5'6J^e5ffg gAEc))<=U^_`Ua 4&4&E7++ 99zl%G ~YOP07avdVSWEXZ_D`DD`ab cc%t 6sm455 6 U T T]6gbsaL?#L >L?A$L<L?$MM/M M L? L< L7 0L?7L< <L?? M c V^8dQhRRRR/#)r rr,rrr)rs"rrr$s::c:d:rcRRRV/#)r5stringrr)rs&r_strr#$s Hm[ 99rrzFetch and summarize another agent's A2A Agent Card from a URL (its name, description, capabilities, and skills). Use this to find out what a remote agent can do before calling it.r#z R #) z@Register the client tools in the ``a2a`` toolset (config-gated).r5object propertiesrequiredr+rr parametersu🧩)rtoolsethandlerrschemaemojicheck_fnN)r&r register_toolr2)rrr;rr7r8r9s& rregister_toolsr@asg>Dlln::wZ&,h j%Q %-z " tUG"($ {LZd!e ,7K  M ?Mr)N)r$r)8__conditional_annotations____doc__ __future__rr-rElogging urllib.errorrAurllib.requestconcurrent.futuresrrtypingrrgateway.platforms._sharedrrrr/r$r r getLogger__name__loggerr(rrrr)r2r:rKrOrXrcrmrprr _AUTH_ERRrrrrrrrrr#r&__annotations__r2r@)rAs@rrOsh# ? i   8 $( 2M H7 4T N !#H \ ] )S)S:z{460  Y +#cL: \uT"`abejdkm<4 bcT"]^%m np9%'gikmopKR!4(S#Tvy-Apqs!N $ =&t,q'r"D)R$S&(F