epj*\UdZddlmZddlZddlZddlZddlZddlm Z m Z ddl m Z m Z mZddlmZmZejeZdZd Zdhd ZdidZdjdZdkdZdldZdmdZdmdZdndZdodZdpd Z dqd"Z!drd$Z"dsd)Z#dtd,Z$dud/Z%dud0Z&dvdwd2Z'dud3Z(dxd6Z)dydzd;Z*dud<Z+ed=e,e,e-e,e fd>d?@Z.edAe,e.dBd?@Z/dCdDdEdFddGdHdIidgdJd>dBdCdKdLdFdGdMdIdGdNdIdGdOdIdPd d&gdJd>dBdCdQdRdFidSd>dBdCdTdUdFdGdVdIdWdXdIdYd'gdJd>dBdCdZd[dFdGd\dIdGd]dIdGgd^d_d`dGdadIdbd4d&gdJd>dBdcZ0dde1de<e%e&e'e(e+dcZ2d{dgZ3dS)|u A2A client tools — let the Hermes agent talk to *other* agents as a peer. Tools (registered in the ``a2a`` toolset): - a2a_discover(url) -> fetch + summarize a peer's Agent Card - a2a_call(agent, message) -> send a task to a peer, return its reply - a2a_list() -> list configured peers + persisted conversations - a2a_history(context_id) -> recall a persisted A2A conversation - a2a_orchestrate(...) -> fan-out task to multiple peers by capability Peers are resolved from config.yaml under ``a2a_agents``:: a2a_agents: researcher: url: "http://localhost:9999" auth: { type: bearer, token: "sk-..." } timeout: 120 capabilities: [web_search, research] Transport is stdlib urllib (no a2a-sdk dependency). The wire format is the A2A v1.0 JSON-RPC ``message/send`` method; replies from v0.3 peers still parse. ) annotationsN)ThreadPoolExecutor as_completed)AnyOptional TypedDict)protocolsecurityxreturndictcL ddlm}|piS#t$ricYSwxYw)Nr load_config)hermes_cli.configr Exceptionrs A/home/thesage/.hermes/hermes-agent/plugins/platforms/a2a/tools.py _load_configr-sN111111{}}""  s  ##agentstrOptional[dict]c|ds|dr |itgdSt}|dpi}||}|sdS|dd|dipit |d t|d gpg|d dd S) zWResolve a peer name to {url, auth, timeout, capabilities}, or treat ``agent`` as a URL.zhttp://zhttps://)urlauthtimeout capabilities a2a_agentsNrrrrtenant)rrrrr!) startswith_DEFAULT_TIMEOUTrgetint)rcfgpeersentrys r _resolve_peerr)5s  ""[e&6&6z&B&B[b5EWYZZZ ..C GGL ! ! 'RE IIe  E tyy## &"%%+uyy,<==>> ."55;))Hb))   rc|r;|ddkr"|dr dd|diSiS)Ntypebearertoken AuthorizationzBearer )r$)rs r _auth_headerr0GsN <  H,,'1B1B,!:4=!:!:;; Ir*rheadersrr%c.tj||d}tj||5}t j|dcdddS#1swxYwYdS)NGET)r1methodrutf-8)urllibrequestRequesturlopenjsonloadsreaddecode)rr1rreqresps r_http_get_jsonrAQs . ge D DC   W  5 57z$))++,,W5566777777777777777777s9B  BBbodyctj|d}dtjd|}t j|||d}t j||5}tj | dcdddS#1swxYwYdS)Nr6zapplication/json)z Content-Typez A2A-VersionPOST)datar1r4r5) r;dumpsencoder PROTOCOL_VERSIONr7r8r9r:r<r=r>)rrBr1rrEhdrsr?r@s r_http_post_jsonrJWs :d   " "7 + +D.x?X d d\c dD . 4f M MC   W  5 57z$))++,,W5566777777777777777777s=9CC Cbase_urlc2|ddzS)N/z/.well-known/agent-card.jsonrstriprKs r _card_urlrQ_s ??3  "@ @@r*c2|ddzS)NrMz/.well-known/agent.jsonrNrPs r_legacy_card_urlrSes ??3  "; ;;r*c tt|||S#tjj$r}|jdkrYd}~nd}~wwxYwtt |||S)Ni)rArQr7error HTTPErrorcoderS)rKr1res r _fetch_cardrYis}i117GDDD < ! 6S==  ==== *844gw G GGs A  AA cardct|trb|dgpgD]I}t|tr2|ddkr|dr|cSJdS)NsupportedInterfacesprotocolBindingJSONRPCr isinstancerr$)rZifaces r_select_jsonrpc_interfacerbrs$XX3R88>B  E%&& 5995F+G+G9+T+TY^YbYbchYiYi+T 4r*ct|}|rt|dSt|tr8t|dtr|dr|dS|dS)zPrefer the card's JSONRPC interface (v1.0 supportedInterfaces), then the card's legacy top-level url, then the configured base.rrM)rbrr`rr$rO)rKrZras r_rpc_urlrdzs &d + +E !5<   $*TXXe__c"B"BtE{E{ ??3  r*peerct|}|r*|drt|dSt|dpdS)Nr!r )rbr$r)rZreras r_interface_tenantrgs[ %d + +E $8$$$5?### txx!!'R ( ((r*statec|r<|ddddndS)zDTASK_STATE_COMPLETED -> completed (also passes through v0.3 states). TASK_STATE_r _-)replacelower)rhs r _short_stateros=IN V5== + + 3 3C = = C C E E ETVVr* agent_labelmessage context_idtuple[str, str, str]c |dd}t|dipi}t|dt}d} t ||t |d}n#t $rYnwxYw|ptj}tj |} dtj dd tj tj | | id } t||} | r | | d d <tjd|| d| tj|d| | dtjxjdz c_t't)||| ||} d| vr1| d} t+d|d| d | | di}tj|}t/|}|d}}t1|t2rA|d|}|dpidd}tj|d|| dtjxjdz c_|||fS)zSend one message/send to a peer. Returns (reply_text, context_id, state). Raises urllib errors / ValueError for the caller to format. Handles outbound redaction, audit, persistence, and metrics. rr rrNz2.0 SendMessagerq)rr)jsonrpcidr4paramsryr!outboundrxuserr rUzPeer 'z' returned an error: result contextIdstatusrhr)r$r0r%r#rYminrr new_context_idr redact_outbound new_task_id text_message ROLE_USERrgauditpersist_messagemetricsoutbound_totalrJrd ValueErrorunwrap_send_message_response_reply_text_from_resultr`r inbound_total)rprerqrrrKr1rrZctx safe_messagerpc_bodyr!r@errr|payloadreply reply_ctxrhs r _send_taskrs xxr""H488FB//5266G$((9&67788G D 8Wc'2.>.>??        1/11C+G44L"$$ x,X-?Z]^^^ HtT * *F .'-8$ N:{HTNLIII S&,GGG ##q(## 8Hd33Xw P PD$7m]+]]CGGIWZD[D[]]^^^ XXh # #F3F;;G #G , ,EBuI'4  ?KK S11 X&&,"11'2>> YGGG ""a'"" )U ""s'B BBr|rctj|}t|tst |S|dgpgD]}tj|}|r|cS|dipi}|d}|rtj|Stj|S)N artifactsr~rq)r rr`rrr$ extract_text)r|artifacttxtr~msgs rrrs  26 : :F fd # #6{{JJ{B//52#H--  JJJ  ZZ" % % +F **Y  C *$S)))   ( ((r*argsrkc t|dpd}|sdS t|it}nJ#t jj$r}d|jd|dcYd}~Sd}~wt$r}d|d |dcYd}~Sd}~wwxYw|d d }|d d}|d ipi}|dgpg}|drdnd} |dgpg} d d| Dpd|dd d} d|d|dt||d| dt|ddt|dd | d!t|d"g} |dd#D]Y} | d$| d | d%d d&| d dZd' | S)(z.Fetch and summarize the Agent Card at ``url``.rr z6Error: 'url' is required (e.g. http://localhost:9999).u!Error: discovery failed — HTTP z from .NzError: could not reach u — name? descriptionrskillsr yesnor\, c3K|]H}t|t|ddd|ddVIdS)r]rz vprotocolVersionNr_).0is r za2a_discover..sq :a.. 55"C ( (KKAEE2CS,I,IKKr*vrz (pre-1.0 card)zAgent: z Description: zURL: z Protocol: z Streaming: streamingz Push: pushNotificationsz Auth required: zSkills (): - rx:  )rr$striprYr#r7rUrVrWrjoinrdboollenappend)rrkrrZrXrdesccapsrrifacesprotolinesss r a2a_discoverrs dhhuoo# $ $ * * , ,C HGG83$455 < !HHHG16GGGGGGGGGGG 88877717777777778 88FC D 88M2 & &D 88NB ' ' -2D XXh # # )rFHHZ(( 255dD XX+R 0 0 6BF II   ? ?TXX' - - > > > $%d##%%Uwd488K0011ww4I\@]@];^;^wwquww"3v;;"""  ECRC[[[ YAEE&!%%c*:*:;;YYquu]TV?W?WYYZZZZ 99U  s/AB' A:4B: BBBBc vt|dp+|dp|dpd}t|dp+|dp|dpd}t|dp|d pd}|r|sd St|}|r|d sd |d S t ||||\}}}n#t jj$rJ} | jdvrd|d| jdcYd} ~ S| jdkr d|dcYd} ~ Sd|d| jdcYd} ~ Sd} ~ wt$r} t| cYd} ~ Sd} ~ wt$r} d|d| dcYd} ~ Sd} ~ wwxYwd|d|} |r| dt|z } | dz } |pd} |tj kr | d|dz } | d | S)!zSend a task to a peer agent and return its reply. ``agent`` is a configured peer name (from ``a2a_agents``) or a direct URL. ``context_id`` continues a prior exchange (multi-turn) when provided. r agent_namerr rqtexttaskrrr}z/Error: both 'agent' and 'message' are required.rzError: unknown agent 'zP'. Configure it under 'a2a_agents' in config.yaml or pass a full http(s):// URL.)iiz Error: peer 'z' rejected auth (HTTP z). Check the configured token.Niz*' rate limited us (HTTP 429). Retry later.zError: call to 'u' failed — HTTP ru ' failed — [u · context u · ]z(no text reply)uS (The peer needs more input — answer by calling a2a_call again with context_id 'z'.)r)rr$rr)rr7rUrVrWrrror STATE_INPUT_REQUIRED) rrkrrqrrrerrrhrXheaderrBs ra2a_callrs !!UTXXl%;%;Utxx?O?OUSU V V \ \ ^ ^E$((9%%S&)9)9STXXf=M=MSQSTTZZ\\GTXXl++Jtxx /D/DJKKQQSSJ AA@@   D  txx  :U : : : ;",UD':"N"Ny%% < !EEE 6Z  f5fffff f f f f f f 6S==T5TTT T T T T T TD%DD16DDDDDDDDD 1vv ;;;:%::a:::::::::;0 / /I / /F /.e,,... cMF  %%D ---  / ) / / /     sZ?EG0*F/G0F/G0 F/)G0/ G0<G G0 G0G+%G0+G0 dict | Nonec lt}|dpi}g}|r|dt|d|D]\}}|dpidd}|dg}|rdd |nd } |d |d |d dd|d| n|dt j} | r`|d |dt| d| ddD]} |d | t j } |d |d| dd| dd| dd| dd| dd | d!d"| d#d$| d%d&| d'd(d)|S)*z:List configured A2A peers and any persisted conversations.rzConfigured peers (rrr,nonerz caps: rr rrrrz (auth: )z@No peers configured. Add them under 'a2a_agents' in config.yaml.zPersisted conversations (u) — recall with a2a_history:Nz 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) rr$rritemsrr list_conversationsrsnapshot) rrkr&r'rrr(rrcap_strconvoscms ra2a_listr1s ..C GGL ! ! 'RE E Y 8#e**888999 ;;== Y YKD%IIf%%+00@@D99^R00D59A1 $111rG LLWWW %(=(=WWtWWgWW X X X X  Y  WXXX  ( * *F % R \V\\\]]] % %A LL $ $ $ $ !!##A LL LL0Q/00q9I7J00'(00676G00'(0045kN00*+00:;;P9Q00*+ 000111 99U  r*c t|dp|dpd}|sdS tdt t |dpdd}n#t tf$rd}YnwxYwtj || }|sd |d Sd |d t|dg}|D]|}|dd}|dpd}t|dkr |dddz}| d|d|}d |S)zRecall a persisted A2A conversation by context_id. This is how prior A2A exchanges survive compaction/restarts: every turn is written to ~/.hermes/a2a_conversations/.jsonl and can be reloaded here. rrr}r zGError: 'context_id' is required (see a2a_list for known conversations).r limit2)rz'No persisted conversation for context ''.z Conversation z (last z messages):rolerriNu …[truncated]rz] r) rr$rmaxrr%r TypeErrorr load_conversationrrr) rrkrrrmessagesrrrrs r a2a_historyrSsTXXl++Jtxx /D/DJKKQQSSJ YXXAs3txx006B77==>>  ")*EBBBH HGGGGG JZ J JH J J J KE ))uuVS!!f #**,, t99t  ;!22D '''''(((( 99U  sABB('B( capabilitylist[tuple[str, dict]]ct}|dpi}g}|D]>\}}|dgpg}||vs|dkr|||f?|S)z:Find configured peers that advertise the given capability.rr*)rr$rr)rr&r'matchesrr(rs r_match_peers_by_capabilityrrs ..C GGL ! ! 'REG{{}}** eyy,,2   s!2!2 NND%= ) ) ) Nr*r r peer_entrytuple[str, str]c$ |dd|dipit|dtd}t||||\}}}||pdfS#t$r}|d|fcYd}~Sd}~wwxYw) zCCall a single peer synchronously. Returns (agent_name, reply_text).rr rr)rrrz (no reply)Error: N)r$r%r#rr) rrrqrrrer_ctx_staterXs r_call_peer_syncr~s +>>%,,NN62..4":>>)5EFFGG   )T7JOOtVE1\22 +++MaMM*******+sA1A44 B>B B Bc @t|dpd}t|dp|dpdt|dpd}t|dpdsdS|sd St |}|sd |d S|d vrd}gt t t|t 5fd|D}t|D]}||}  | |dkr<dd ds|D]}| n2u#t$r$}  |d| fYd} ~ d} ~ wwxYwdddn #1swxYwYddD} d'fd } |dkr2| s | St!| d} d| dd| dS|dkr| s | S| d\}} d |d| Sd!|d"t|d#g}D]3\}} | d$|d%| | 4d&|S)(uFan-out a task to multiple peer agents by capability. Modes: - ``all``: send to all peers matching the capability, return all replies. - ``first``: send to all matching peers, return the first successful reply. - ``best``: send to all, return the longest successful reply (a coarse detail heuristic — use ``all`` when you want to judge yourself). Configured peers advertise capabilities in config.yaml:: a2a_agents: researcher: url: "http://localhost:9991" capabilities: [web_search, research] coder: url: "http://localhost:9992" capabilities: [code, debug] rr rqrmodeallrrzError: 'message' is required.z;Error: 'capability' is required (or use '*' for all peers).z1Error: no configured peers advertise capability 'rrfirstbest) max_workersc Ti|]$\}}t|||%S)submitr)rrr(rrrqpools r z#a2a_orchestrate..sC   e KKugz J JD   r*rr Error:rNc|dS)Nrrrs rz!a2a_orchestrate..s qtr*)keycFg|]\}}|d||fS)r)r")rrrs r z#a2a_orchestrate..s4\\\;4AQAQRZA[A[\$\\\r*rrczdg}D] \}}|d|d|!d|S)NzAll peers failed:z rr)rr)rrrresultss r _all_failedz$a2a_orchestrate.._all_failedsV$%" / /KD% LL-d--e-- . . . .yyr*rc,t|dS)Nr )rrs rrz!a2a_orchestrate..sC!IIr*z[best: rz] z[first: zOrchestrated 'z' to z peer(s):z --- z ---r)rr)rr$rrnrrrr_ORCHESTRATE_MAX_WORKERSrrr|r"cancelrsortrr)rrkrrrfuturesfutrfrX successesr rrrrrrqrr s @@@@ra2a_orchestraters&TXXl++1r2288::J$((9%%?&)9)9?R@@FFHHG txx(5 ) ) / / 1 1 7 7 9 9DTXXl++1r2288::J /.. MLL(44G RQ:QQQQ +++&(G CLL:R(S(S T T T6X\      &    (( 6 6C3+D+DX+N+N?$## E 6 6 6mmm455555555 6666666666666666$ LL^^L$$$\\'\\\I       v~~ !;== 9"5"5666.a..T!W...  !;== l e*$**5***J*JJ3w<<JJJK"  KD% LL,$,,, - - - LL    yys=*H-A'G0-H-0 H:HH-HH--H14H1_FunctionSchema)rr parametersF)total _ToolSchema)r,functionrrzFetch 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.objectstringzr6s.#""""" ????????++++++++++  8 $ $$7777 7777AAAA <<<<HHHH    ))))WWWW 3#3#3#3#l))))*    F++++\D>     + + + + +P P P P n)-C_cdgildl_m/n/nv{|||i 'Q'QY^___ "I !H={||#G   &; !&.@BCC(0A|}}+3EM#N#N %i0  ,g#+2>>  !) !+3Do"p"p&/@opp*N   (%% !+3EJ#K#K(0Ajkk%-7O7O7OaLMM+3Dp"q"q  *95    GY$Y$YYYYx!&           r*