+
    lHàjÇ%  ã                  ó¢  € ^ RI Ht ^ RIt^ RIHtHtHt ^ RIH	t	H
t
HtHt ^ RIHtHt ^ RIHtHtHt ^ RIHtHtHtHt ^ RIHtHt ^ R	IHtHt ^ R
IH t  ]PB                  ! ]"4      t#Rt$Rt%Rt&Rt'. R$Ot(]! RR7       ! R R4      4       t)]*! 0 R%m4      t+R R lt,R&R R llt-RRRRRR/R R llt.RRRRRR/R R llt/RRRR/R  R! llt0R" R# lt1R# )'é    )ÚannotationsN)Ú	dataclassÚfieldÚreplace)ÚAnyÚCallableÚOptionalÚSequence)Úconnectors_availableÚguest_identity_pending)ÚGatewayAuthErrorÚGatewayUnavailableÚToolGatewayError)ÚFileInputErrorÚmodel_parametersÚsave_outputsÚstage_inputs)Úfill_remote_failureÚsplice_remote_results)Úparse_connector_nameÚvendor_slug_candidates)ÚCallRefÚsign_in_expiredÚunreachableÚ
not_set_upzxHosted connectors are not set up for this user yet. Call manage_connections to connect the app first; that sets them up.ÚConnectorLegT)Úfrozenc                  óB   € ] tR t^#t$ ]! ]R7      tR]R&   RtR]R&   Rt	R# )r   )Údefault_factoryzdict[str, Any]ÚpayloadNúOptional[str]Úfailure© )
Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__r   Údictr    Ú__annotations__r"   Ú__static_attributes__r#   ó    ÚD/home/ubuntu/.hermes/hermes-agent/tools/connectors/gateway/bridge.pyr   r   #   s   ‡ ñ $°DÔ9€Gˆ^Ó9Ø!€Gˆ]×!r+   c               ó    € V ^8„  d   QhRRRR/# )é   ÚexcÚ	ExceptionÚreturnr!   r#   )Úformats   "r,   Ú__annotate__r3   -   s   € ÷ ñ �ið  Mñ r+   c                ó&  € \        V \        4      '       d   V P                  \        8X  d   \        # \        V \        4      '       dF   V P                  R 8X  g-   \        V P                  4      P                  4       \        9   d   \        # R# \        # )i‘  N)
Ú
isinstancer   ÚcodeÚ
NOT_SET_UPÚstatusÚstrÚupperÚ_TOKEN_REJECTED_CODESÚSIGN_IN_EXPIREDÚUNREACHABLE)r/   s   &r,   Ú_leg_failurer>   -   sc   € Ü�#Ô'×(Ò(¨S¯X©X¼Ô-CÜÐÜ�#Ô'×(Ò(Ø�:‰:˜Ô¤ C§H¡H£× 3Ñ 3Ó 5Ô9NÔ NÜ"Ð"ÙÜÐr+   c               ó   € V ^8„  d   QhRR/# )r.   ÚcallúOptional[CallRef]r#   )r2   s   "r,   r3   r3   7   s   € ÷ &ñ &Ð"3ñ &r+   c                ój   € ^ RI Hp \        4       '       d   \        \        \
        R7      hV! V R7      # )zVThe real client for the model's read and execute legs. These never create an identity.)ÚConnectorClient©r6   )r@   )Útools.connectors.gateway.clientrC   r   r   ÚNOT_SET_UP_MESSAGEr7   )r@   rC   s   & r,   Ú_default_client_factoryrG   7   s'   € å?ä×ÒÜÔ1¼
ÔCÐCÙ Ô%Ð%r+   ÚavailabilityÚclient_factoryr@   c          
     ó,   € V ^8„  d   QhRRRRRRRRR	R
/# )r.   ÚquerieszSequence[dict[str, Any]]rH   úOptional[Callable[[], bool]]rI   úOptional[Callable[[], Any]]r@   rA   r1   r   r#   )r2   s   "r,   r3   r3   @   s<   € ÷ 7ñ 7Ø%ð7ð /ð7ð 0ð	7ð
 ð7ð ñ7r+   c               óÎ  €  T;'       g    \         ! 4       pV'       d	   V '       g   \        4       # V'       d   V! 4       M
\        V4      p\        VP                  \	        V 4      4      ;'       g    / R 7      #   \
         d#    \        P                  R4       \        4       u # \         d6   p\        P                  RT4       \        \        T4      R7      u Rp?# Rp?ii ; i)©r    z&Connector search skipped: gateway darkz!Connector search failed (D32): %s©r"   N)r   r   rG   ÚsearchÚlistr   ÚloggerÚdebugr0   Úwarningr>   )rK   rH   rI   r@   Ú	availableÚclientr/   s   &$$$   r,   Úconnector_search_hitsrX   @   s§   € ð7Ø!×9Ð9Ô%9Ð9Ó<ˆ	ß§Ü“>Ð!ß%3‘Ô!Ô9PÐQUÓ9VˆÜ F§M¡M´$°w³-Ó$@×$FÐ$FÀBÔGÐGøÜô Ü�‰Ð=Ô>Ü‹~ÒÜô 7Ü�‰Ð:¸CÔ@Ü¤L°Ó$5Ô6Õ6ûð7úsH   ‚A9 ‹A9 ŸA9 §	A9 ±A9 ¹7A9 Á1A9 Á9*C$Â%C$Â.C$Â/*CÃC$ÃC$c          
     ó,   € V ^8„  d   QhRRRRRRRRR	R
/# )r.   ÚnameszSequence[str]rH   rL   rI   rM   r@   rA   r1   r   r#   )r2   s   "r,   r3   r3   U   s<   € ÷ /7ñ /7Øð/7ð /ð/7ð 0ð	/7ð
 ð/7ð ñ/7r+   c          
     óN  a€  T;'       g    \         ! 4       pV'       g   \        4       # / p. pV  Fu  p\        V4      pVe   VP                  V9   d   K%  \	        VP
                  VP                  4      p	W•VP                  &   V	 F  p
W¦9  g   K  VP                  V
4       K  	  Kw  	  V'       g   \        4       # V'       d   V! 4       M
\        V4      pVP                  V4      ;'       g    / p\        VP                  R4      \        4      '       d   VP                  R4      M/ o/ pVP                  4        Fm  w  ré\        V3R lV	 4       R 4      pVf   K!  R\        VP                  R4      ;'       g    R4      R\!        YïP                  R4      ;'       g    / 4      /WÞ&   Ko  	  \        RV/R7      #   \"         d#    \$        P'                  R	4       \        4       u # \(         d6   p\$        P+                  R
T4       \        \-        T4      R7      u R p?# R p?ii ; i)NÚschemasc              3  ó„   <"  € T F5  p\        SP                  V4      \        4      '       g   K*  SV,          x € K7  	  R # 5i©N)r5   Úgetr(   )Ú.0Úslugr\   s   & €r,   Ú	<genexpr>Ú%connector_describe.<locals>.<genexpr>t   s1   øé € ð 9©: 4Ü˜wŸ{™{¨4Ó0´$×7ô �˜—’«:ùs
   ƒ'A ¯A ÚdescriptionÚ Ú
parametersÚinput_schemaÚtoolsrO   z(Connector describe skipped: gateway darkz#Connector describe failed (D32): %srP   )r   r   r   Úrawr   Ú	connectorÚtoolÚappendrG   r\   r5   r_   r(   ÚitemsÚnextr9   r   r   rS   rT   r0   rU   r>   )rZ   rH   rI   r@   rV   ÚwantedÚrequest_slugsÚnameÚparsedÚ
candidatesra   rW   Úresponserh   ÚcomposedÚschemar/   r\   s   &$$$             @r,   Úconnector_describerw   U   sÏ  ø€ ð(7Ø!×9Ð9Ô%9Ð9Ó<ˆ	ßÜ“>Ð!à-/ˆØ#%ˆÛˆDÜ)¨$Ó/ˆFØŠ~ §¡¨vÔ!5ÙÜ/°×0@Ñ0@À&Ç+Á+ÓNˆJØ!+�6—:‘:ÑÛ"�ØÖ,Ø!×(Ñ(¨Ö.ó #ñ ÷ Ü“>Ð!ß%3‘Ô!Ô9PÐQUÓ9VˆØ—>‘> -Ó0×6Ð6°BˆÜ-7¸¿¹ÀYÓ8OÔQU×-VÒ-V�(—,‘,˜yÔ)Ð\^ˆØ "ˆØ$*§L¡L¦NÑ ˆHÜô9©:ó 9àóˆFð
 Š~Ùàœs 6§:¡:¨mÓ#<×#BÐ#BÀÓCØÔ.¨x¿¹ÀNÓ9S×9YÐ9YÐWYÓZðˆE‹Oñ %3ô  W¨eÐ$4Ô5Ð5øÜô Ü�‰Ð?Ô@Ü‹~ÒÜô 7Ü�‰Ð<¸cÔBÜ¤L°Ó$5Ô6Õ6ûð7úsd   ƒF9 ŒF9  	F9 ªA!F9 Â F9 Â1	F9 Â;F9 Ã)F9 Ã-BF9 Å9#F9 ÆF9 Æ9*H$Ç%H$Ç.H$Ç/*HÈH$ÈH$Úturn_idÚtask_idc               ó0   € V ^8„  d   QhRRRRRRRRRRR	R
/# )r.   Údispatch_idr!   rH   rL   rI   rM   rx   ry   r1   úlist[dict[str, Any]]r#   )r2   s   "r,   r3   r3   ‡   sN   € ÷ \ñ \àð\ð /ð	\ð
 0ð\ð ð\ð ð\ð ñ\r+   c          
     ó¨  €  T;'       g    \         ! 4       pV'       g   \        V RRR7      # V  Uu. uF5  p\        V\	        VP
                  VP                  4      ^ ,          R7      NK7  	  pp V'       d   V! 4       M\        \        WAR7      4      p	\        V \        W˜V4      4      p
. p. p\        \!        Y
4      4       Fº  w  pw  r\	        TP
                  TP                  4      w  pp\#        T\$        4      '       d   TP'                  R4      MRpTT8w  g   K]  \#        T\$        4      '       g   Ku  TP'                  R4      R8X  g   K�  TP)                  T4       TP)                  \        TTR7      4       K¼  	  T'       g   T
#  \        T\        Y�T4      4      p\!        TT4       F
  w  ppTY®&   K  	  T
#   \         d    R p ELµi ; iu upi   \         d<   p\        P                  RTTP                  T4       \        T RT 24      u Rp?# Rp?i\         d.   p\        P                  R	TT4       \        T R
4      u Rp?# Rp?ii ; i  \         d<   p\        P                  RTTP                  T4       \        TRT 24      p Rp?LõRp?i\         d/   p\        P                  RTT4       \        TR
4      p Rp?EL,Rp?ii ; i)Fz;Unknown tool: connectors are not available in this session.ÚTOOL_NOT_FOUNDrD   )rk   )rx   Útool_call_idz1Connector execute for dispatch %s failed (%s): %sz&The connector gateway request failed: Nz9Connector execute for dispatch %s failed unexpectedly: %sz2The connector gateway request failed unexpectedly.Úerrorr6   z:Connector execute fallback for dispatch %s failed (%s): %szBConnector execute fallback for dispatch %s failed unexpectedly: %s)r   r0   r   Údataclass_replacer   rj   rk   rG   r   r   Ú_execute_with_filesr   rS   rU   r6   Ú	enumerateÚzipr5   r(   r_   rl   )Úplannedr{   rH   rI   rx   ry   rV   ÚplanÚwire_plannedrW   Úentriesr/   Úfallback_slotsÚfallback_plannedÚslotÚentryÚprimaryÚliteralr€   Úfallback_entriesÚfallback_entrys   &&$$$$               r,   Ú
run_remoter‘   ‡   s»  € ðØ!×9Ð9Ô%9Ð9Ó<ˆ	÷ Ü"ØØIØ!ô
ð 	
ñ óñ
 ˆDô	 	ØÜ'¨¯©¸¿	¹	ÓBÀ1ÕE÷	
ñ ð ð ð
ß%3‘Ô!Ô9PÜ˜GÔ>ó:@ˆä'¨Ô1DÀVÐ[bÓ1cÓdˆð* !#€NØÐÜ(¬¨WÓ)>Ö?Ñˆ‰mˆtÜ1°$·.±.À$Ç)Á)ÓLÑˆ�Ü&0°¼×&=Ò&=�—	‘	˜'Ô"À4ˆà�wÖÜ˜5¤$×'Ô'Ø—	‘	˜&Ó!Ð%5Ö5à×!Ñ! $Ô'Ø×#Ñ#Ô$5°dÀÔ$IÖJñ  @÷ Øˆð
Ü0ØÔ1°&ÈGÓTóVÐô* !$ NÐ4DÖ EÑˆˆnØ&ˆ‹ñ !Fà€Nøôc ô Ø‹	ðüòøô ô 	
Ü�‰Ø?ØØ�H‰HØô		
ô #ØÐ=¸c¸UÐCó
õ 	
ûô ô 
Ü�‰ØGØØô	
ô
 #ØÐIó
õ 	
ûð
ûô: ô 	
Ü�‰ØHØØ�H‰HØô		
ô /ØÐ FÀsÀeÐLó
Õûô ô 
Ü�‰ØPØØô	
ô
 /ØÐRó
Öûð
ús{   ‚F< ‹F< ±;GÁ/:G Æ
I Æ<GÇGÇIÇ 0HÈIÈIÈ#IÈ$"IÉIÉIÉKÉ1JÊKÊ"KÊ##KËKc               ó(   € V ^8„  d   QhRRRRRRRR/# )	r.   rW   r   r…   zSequence[Any]ry   r!   r1   r|   r#   )r2   s   "r,   r3   r3   ç   s)   € ÷ ñ  ð ¨mð Àmð ÐXlñ r+   c           
     ó   € ^ RI Hp R.\        V4      ,          p. p\        V4       F$  w  rg VP	                  V\        WVR7      34       K&  	  V'       d[   V P                  ! V U	Uu. uF  w  r—VNK	  	  upp	3/ V! 4       B p
\        YZ;'       g    R4       F  w  w  rip\        W4      WF&   K  	  V#   \         dJ   p\        P                  RTP                  TP                  T4       TP                  4       YF&    Rp?KÛ  Rp?ii ; iu upp	i )zØExecute ``planned`` with every file input staged first and every returned file saved.

A call whose file input is refused or fails to stage gets that error as its result and is never
executed; its siblings still run.)Úreturn_to_argsN)ry   z(Connector %s file input refused (%s): %sr#   )rE   r”   Úlenrƒ   rl   r   r   rS   rU   rq   r6   ÚresultÚexecuter„   r   )rW   r…   ry   r”   ÚresultsÚrunnabler‹   r†   r/   Ú_Úremoter–   s   &&&         r,   r‚   r‚   ç   sç   € õ
 ?à/3¨f´s¸7³|Õ.C€GØ&(€HÜ Ö(‰
ˆð	)Ø�O‰O˜T¤<°ÀgÔ#NÐOÖPñ )÷ ð —’±XÔ >±X©'¨!£±XÒ >ÑSÁ.ÓBRÑSˆÜ!$ X¯|¨|¸Ö!<Ñ‰IˆT�vÜ(¨Ó8ˆG‹Mñ "=à€Nøô ô 	)Ü�N‰NÐEÀtÇyÁyÐRU×RZÑRZÐ\_Ô`ØŸJ™J›LˆG�Mûð	)üó !?s   ­B3Á(D

Â3DÂ>>DÄD)r7   rF   r<   r=   r   rw   rX   r‘   >   ÚUNAUTHORIZEDÚINVALID_TOKENÚTOKEN_EXPIREDr^   )2Ú
__future__r   ÚloggingÚdataclassesr   r   r   r�   Útypingr   r   r	   r
   Útools.connectors.gateway.configr   r   Útools.connectors.gateway.errorsr   r   r   Útools.connectors.gateway.filesr   r   r   r   Útools.connectors.gateway.merger   r   Útools.connectors.gateway.namesr   r   Útools.managed_gateway_identityr   Ú	getLoggerr$   rS   r<   r=   r7   rF   Ú__all__r   Ú	frozensetr;   r>   rG   rX   rw   r‘   r‚   r#   r+   r,   Ú<module>r¬      sý   ðÝ "ã ß FÑ Fß 4Ó 4ç Xß bÑ bß gÓ gß Uß WÝ 2à	×	Ò	˜8Ó	$€à#€Ø€à€
ð]Ð ò	€ñ �$Ô÷"ð "ó ð"ñ "Ò"TÓUÐ õ÷&ð7ð 26ð7ð 37ð	7ð
 #÷7ð*/7ð 26ð/7ð 37ð	/7ð
 #÷/7ðd\ð "ð\ð "÷\÷@r+   