+
    lHàj‰,  ã                  ó  a € 0 t $ R t^ RIHt ^ RIHtHtHt ^ RIH	t	H
t
Ht Rt] R2t] R2t] R2t] R2t] R	2t] R
2tRbt]Rc,          t]Rd,          t]Re,          t^t]t]Rf,          tRRgRRhRRhRRiRRiRRiRRjRRkRRlRRmRRnRRo/tR]R&   RRRRRRRR/tR]R &   RpR" R# llt ! R$ R%]	4      t ! R& R']4      t  ! R( R)]4      t! ! R* R+]4      t" ! R, R-]4      t# ! R. R/]4      t$ ! R0 R1]4      t% ! R2 R3]4      t& ! R4 R5]4      t' ! R6 R7]4      t( ! R8 R9]4      t) ! R: R;]4      t* ! R< R=]4      t+ ! R> R?]+4      t, ! R@ RA]4      t- ! RB RC]4      t. ! RD RE]4      t/]Rq,          t0 ! RF RG]4      t1 ! RH RI]4      t2 ! RJ RK]4      t3 ! RL RM]4      t4 ! RN RO]4      t5 ! RP RQ]4      t6 ! RR RS]4      t7 ! RT RU]4      t8 ! RV RW]4      t9 ! RX RY]4      t: ! RZ R[]4      t; ! R\ R]]4      t< ! R^ R_]4      t= ! R` Ra]4      t>R!# )rz§Wire models for the gateway connector routes.

Tolerate added gateway fields; callers receive plain dictionaries. Correlate results by position, never wire ``index``.
)Úannotations)ÚAnyÚLiteralÚOptional)Ú	BaseModelÚ
ConfigDictÚFieldzv1/connectorsz/searchz/schemasz/executez/connectionsz	/accountsz/files/uploadÚproductÚbackendÚTOOL_NOT_ALLOWEDÚCONNECTION_REQUIREDÚCONNECTION_EXPIREDÚALIAS_REQUIREDÚALIAS_UNKNOWNÚINVALID_ARGUMENTSÚTOOL_NOT_FOUNDÚPROVIDER_ERRORÚPROVIDER_RATE_LIMITEDÚPROVIDER_TIMEOUTÚPOLICY_UNAVAILABLEÚGATEWAY_ERRORz"dict[str, tuple[ErrorFamily, int]]ÚEXECUTE_ERROR_CODESÚFILE_NOT_ALLOWEDÚFILE_NOT_FOUNDÚFILE_TOO_LARGEÚFILE_UPLOAD_FAILEDzdict[str, ErrorFamily]ÚFILE_ERROR_FAMILIESNc               ó$   € V ^8„  d   QhRRRRRR/# )é   ÚcodeÚstrÚfamilyúOptional[str]Úreturn© )Úformats   "ÚB/home/ubuntu/.hermes/hermes-agent/tools/connectors/gateway/wire.pyÚ__annotate__r'   C   s&   € ÷ @ñ @˜sð @¨Mð @À]ñ @ó    c                óŠ   € VR9   d   V# \         P                  V 4      pV'       d
   V^ ,          # \        P                  V 4      # )zVThe gateway's family when it sent one, else the table's; ``None`` for an unknown code.©r	   r
   )r   Úgetr   )r   r!   Úknowns   && r&   Úexecute_error_familyr-   C   s=   € àÐ'Ô'ØˆÜ×#Ñ# DÓ)€Eßˆ5��8Ð?Ô"5×"9Ñ"9¸$Ó"?Ð?r(   c                  ó*   € ] tR t^Kt]! RRR7      tRtR# )Ú_WireÚignoreT)ÚextraÚpopulate_by_namer$   N)Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__r   Úmodel_configÚ__static_attributes__r$   r(   r&   r/   r/   K   s   † á H¸tÔD„Lr(   r/   c                  óR   € ] tR t^Pt$ ]! RR7      tR]R&   ]! RRR7      tR]R	&   R
tR# )ÚConnectorSearchQueryÚuseCase©Úaliasr    Úuse_caseNÚknownFields©Údefaultr=   r"   Úknown_fieldsr$   )	r3   r4   r5   r6   r   r>   Ú__annotations__rB   r8   r$   r(   r&   r:   r:   P   s"   ‡ Ù 	Ô*€HˆcÓ*Ù"'°¸MÔ"J€L�-×Jr(   r:   c                  ó"   € ] tR t^Ut$ R]R&   RtR# )ÚConnectorSearchRequestzlist[ConnectorSearchQuery]Úqueriesr$   N©r3   r4   r5   r6   rC   r8   r$   r(   r&   rE   rE   U   s   ‡ Ø'×'r(   rE   c                  óX   € ] tR t^Yt$ R]R&   R]R&   RtR]R&   ]! ]RR7      tR]R	&   R
t	R# )ÚConnectorToolSchemar    Ú	connectorÚtoolÚ ÚdescriptionÚinputSchema©Údefault_factoryr=   údict[str, Any]Úinput_schemar$   N)
r3   r4   r5   r6   rC   rM   r   ÚdictrR   r8   r$   r(   r&   rI   rI   Y   s'   ‡ ØƒNØ
ƒIØ€K�ÓÙ#(¸À]Ô#S€L�.×Sr(   rI   c                  óÞ   € ] tR t^`t$ R]R&   ]! RRR7      tR]R&   ]! ]R7      tR	]R
&   ]! ]RR7      t	R	]R&   ]! ]R7      t
R	]R&   RtR]R&   ]! RRR7      tR]R&   RtR]R&   RtR]R&   RtR# )ÚConnectorSearchResultÚintÚindexrL   r;   r@   r    r>   ©rP   ú	list[str]ÚtoolsÚrelatedToolsrO   Úrelated_toolsÚ
connectorsNr"   ÚguidanceÚ	planStepszOptional[list[str]]Ú
plan_stepsÚpitfallsÚerrorr$   )r3   r4   r5   r6   rC   r   r>   ÚlistrZ   r\   r]   r^   r`   ra   rb   r8   r$   r(   r&   rU   rU   `   sx   ‡ àƒJÙ "¨IÔ6€HˆcÓ6Ù¨TÔ2€Eˆ9Ó2Ù$°TÀÔP€M�9ÓPÙ!°$Ô7€J�	Ó7Ø"€HˆmÓ"Ù&+°DÀÔ&L€JÐ#ÓLØ$(€HÐ!Ó(Ø€Eˆ=×r(   rU   c                  ó>   € ] tR t^mt$ R]R&   RtR]R&   RtR]R&   RtR	# )
ÚConnectorConnectionStatusr    rJ   FÚboolÚ	connectedrL   rM   r$   N)r3   r4   r5   r6   rC   rg   rM   r8   r$   r(   r&   re   re   m   s   ‡ ØƒNØ€IˆtÓØ€K�×r(   re   c                  óŠ   € ] tR t^st$ ]! ]R7      tR]R&   ]! ]R7      t	R]R&   ]! ]R7      t
R]R&   ]! ]RR	7      tR
]R&   RtR# )ÚConnectorSearchResponserX   zlist[ConnectorSearchResult]Úresultsúdict[str, ConnectorToolSchema]Úschemaszlist[ConnectorConnectionStatus]ÚconnectionsÚ	nextStepsrO   rY   Ú
next_stepsr$   N)r3   r4   r5   r6   r   rc   rj   rC   rS   rl   rm   ro   r8   r$   r(   r&   ri   ri   s   sC   ‡ Ù+0ÀÔ+F€GÐ(ÓFÙ.3ÀDÔ.I€GÐ+ÓIÙ38ÈÔ3N€KÐ0ÓNÙ!°$¸kÔJ€J�	×Jr(   ri   c                  ó"   € ] tR t^zt$ R]R&   RtR# )ÚConnectorSchemasRequestrY   rZ   r$   NrG   r$   r(   r&   rq   rq   z   s   ‡ Ø×r(   rq   c                  ón   € ] tR t^~t$ ]! ]R7      tR]R&   ]! ]RR7      t	R]R&   ]! ]R7      t
R]R	&   R
tR# )ÚConnectorSchemasResponserX   rk   rl   ÚnotFoundrO   rY   Ú	not_foundzdict[str, list[str]]Úsuggestionsr$   N)r3   r4   r5   r6   r   rS   rl   rC   rc   ru   rv   r8   r$   r(   r&   rs   rs   ~   s3   ‡ Ù.3ÀDÔ.I€GÐ+ÓIÙ °¸ZÔH€IˆyÓHÙ(-¸dÔ(C€KÐ%×Cr(   rs   c                  óJ   € ] tR t^„t$ R]R&   R]R&   R]R&   R]R&   R]R&   RtR	# )
ÚConnectorFileUploadRequestr    ÚtoolkitrK   ÚfilenameÚmimetyperV   Úsizer$   NrG   r$   r(   r&   rx   rx   „   s   ‡ ØƒLØ
ƒIØƒMØƒMØ
‡Ir(   rx   c                  ó:   € ] tR t^Œt$ RtR]R&   R]R&   R]R&   RtR# )ÚConnectorFileDescriptorz=The value a ``file_uploadable`` tool input takes on the wire.r    Únamer{   Ús3keyr$   N)r3   r4   r5   r6   Ú__doc__rC   r8   r$   r(   r&   r~   r~   Œ   s   ‡ ÙGà
ƒIØƒMØ‡Jr(   r~   c                  óv   € ] tR t^”t$ ]! RR7      tR]R&   ]! ]R7      tR]R&   R]R	&   ]! R
R7      t	R]R&   Rt
R# )ÚConnectorFileUploadResponseÚ	uploadUrlr<   r    Ú
upload_urlrX   zdict[str, str]Úheadersr~   Ú
descriptorÚ	expiresAtÚ
expires_atr$   N)r3   r4   r5   r6   r   r…   rC   rS   r†   r‰   r8   r$   r(   r&   rƒ   rƒ   ”   s5   ‡ Ù +Ô.€J�Ó.Ù#°DÔ9€Gˆ^Ó9Ø'Ó'Ù +Ô.€J�×.r(   rƒ   c                  ó’   € ] tR t^›t$ R]R&   R]R&   RtR]R&   ]! RRR	7      tR]R
&   ]! RRR	7      tR]R&   Rt	R]R&   Rt
R]R&   RtR# )ÚConnectorToolErrorÚConnectorErrorCoder   r    ÚmessageNr"   rJ   Ú
connectUrlr@   Úconnect_urlÚconnectionIdÚconnection_idÚhintr!   r$   )r3   r4   r5   r6   rC   rJ   r   r�   r‘   r’   r!   r8   r$   r(   r&   r‹   r‹   ›   sM   ‡ Ø
ÓØƒLØ#€Iˆ}Ó#Ù!&¨t¸<Ô!H€K�ÓHá#(°¸^Ô#L€M�=ÓLØ€Dˆ-ÓØ €FˆM× r(   r‹   c                  ó:   € ] tR t^¦t$ Rt]! RRR7      tR]R&   RtR# )ÚConnectorExecuteFailurez1The body of a non-2xx single-call execute answer.NÚ	requestIdr@   r"   Ú
request_idr$   )	r3   r4   r5   r6   r�   r   r–   rC   r8   r$   r(   r&   r”   r”   ¦   s   ‡ Ù;á %¨d¸+Ô F€J�×Fr(   r”   c                  óV   € ] tR t^¬t$ R]R&   R]R&   ]! ]R7      tR]R&   RtR]R	&   R
t	R# )ÚConnectorExecuteCallr    rJ   rK   rX   rQ   Ú	argumentsNr"   Úaccountr$   )
r3   r4   r5   r6   rC   r   rS   r™   rš   r8   r$   r(   r&   r˜   r˜   ¬   s'   ‡ ØƒNØ
ƒIÙ %°dÔ ;€Iˆ~Ó;ð "€Gˆ]×!r(   r˜   c                  ó`   € ] tR t^µt$ R]R&   ]! RRR7      tR]R&   ]! R^^€R7      tR	]R
&   RtR# )ÚConnectorExecuteRequestzlist[ConnectorExecuteCall]rZ   NÚreturnTor@   úOptional[ConnectorReturnTarget]Ú	return_to©rA   Ú
min_lengthÚ
max_lengthr"   Úopr$   ©	r3   r4   r5   r6   rC   r   rŸ   r£   r8   r$   r(   r&   rœ   rœ   µ   s-   ‡ Ø%Ó%á16¸tÈ:Ô1V€IÐ.ÓVÙ d°qÀSÔI€Bˆ×Ir(   rœ   c                  ó`   € ] tR t^¼t$ R]R&   ]! RRR7      tR]R&   ]! R^^€R7      tR	]R
&   RtR# )ÚConnectorExecuteSingleRequestr˜   ÚcallNr�   r@   rž   rŸ   r    r"   r£   r$   r¤   r$   r(   r&   r¦   r¦   ¼   s-   ‡ Ø
ÓÙ16¸tÈ:Ô1V€IÐ.ÓVÙ d°qÀSÔI€Bˆ×Ir(   r¦   c                  ó"   € ] tR t^Æt$ R]R&   RtR# )ÚConnectorDataUsezlist[DataUseRequirement]Úrequiresr$   NrG   r$   r(   r&   r©   r©   Æ   s   ‡ Ø&×&r(   r©   c                  ón   € ] tR t^Êt$ RtR]R&   RtR]R&   RtR]R&   RtR]R	&   ]	! RR
R7      t
R]R&   RtR# )ÚConnectorExecuteSingleResultrL   r    rJ   rK   Nr   Údatar"   rš   ÚdataUser@   úOptional[ConnectorDataUse]Údata_user$   )r3   r4   r5   r6   rJ   rC   rK   r­   rš   r   r°   r8   r$   r(   r&   r¬   r¬   Ê   s;   ‡ Ø€IˆsÓØ€Dˆ#ƒNØ€Dˆ#ÓØ!€Gˆ]Ó!Ù+0¸ÀYÔ+O€HÐ(×Or(   r¬   c                  ó"   € ] tR t^Òt$ R]R&   RtR# )ÚConnectorExecuteSingleResponser¬   Úresultr$   NrG   r$   r(   r&   r²   r²   Ò   s   ‡ Ø(×(r(   r²   c                  óŠ   € ] tR t^Öt$ ^ tR]R&   RtR]R&   RtR]R&   RtR]R	&   Rt	R
]R&   Rt
R]R&   ]! RRR7      tR]R&   RtR# )ÚConnectorExecuteResultrV   rW   rL   r    rJ   rK   Nr   r­   zOptional[ConnectorToolError]rb   r"   rš   r®   r@   r¯   r°   r$   )r3   r4   r5   r6   rW   rC   rJ   rK   r­   rb   rš   r   r°   r8   r$   r(   r&   rµ   rµ   Ö   sO   ‡ à€Eˆ3ƒNØ€IˆsÓØ€Dˆ#ƒNØ€Dˆ#ÓØ*.€EÐ'Ó.à!€Gˆ]Ó!Ù+0¸ÀYÔ+O€HÐ(×Or(   rµ   c                  óŽ   € ] tR t^ât$ ]! ]R7      tR]R&   ]! ^ RR7      tR]R&   ]! ^ RR7      t	R]R	&   ]! ^ R
R7      t
R]R&   RtR# )ÚConnectorExecuteResponserX   zlist[ConnectorExecuteResult]rj   ÚsuccessCountr@   rV   Úsuccess_countÚ
errorCountÚerror_countÚ
totalCountÚtotal_countr$   N)r3   r4   r5   r6   r   rc   rj   rC   r¹   r»   r½   r8   r$   r(   r&   r·   r·   â   sE   ‡ Ù,1À$Ô,G€GÐ)ÓGÙ q°Ô?€M�3Ó?Ù Q¨lÔ;€K�Ó;Ù Q¨lÔ;€K�×;r(   r·   c                  ó¨   € ] tR t^ét$ R]R&   RtR]R&   RtR]R&   ]! RR	R
7      tR]R&   ]! RRR
7      t	R]R&   ]! R^^€R7      t
R]R&   RtR]R&   RtR# )ÚConnectorConnectionsRequestrY   r]   Frf   Ú
reinitiateNr"   r=   r�   r@   r‘   r�   rž   rŸ   r    r£   zOptional[ConnectorInitiator]Ú	initiatorr$   )r3   r4   r5   r6   rC   rÀ   r=   r   r‘   rŸ   r£   rÁ   r8   r$   r(   r&   r¿   r¿   é   s]   ‡ ØÓØ€J�ÓØ€Eˆ=Óá#(°¸^Ô#L€M�=ÓLÙ16¸tÈ:Ô1V€IÐ.ÓVá d°qÀSÔI€BˆÓIØ.2€IÐ+×2r(   r¿   c                  ó°   € ] tR t^õt$ R]R&   R]R&   ]! RRR7      tR]R	&   ]! RR
R7      tR]R&   RtR]R&   Rt	R]R&   ]! RRR7      t
R]R&   RtR]R&   RtR# )ÚConnectorConnectionResultr    rJ   z(Literal['active', 'initiated', 'failed']ÚstatusNrŽ   r@   r"   r�   r�   r‘   r=   ÚinstructionÚstatusReasonÚstatus_reasonFrf   Úreinitiatedr$   )r3   r4   r5   r6   rC   r   r�   r‘   r=   rÅ   rÇ   rÈ   r8   r$   r(   r&   rÃ   rÃ   õ   s`   ‡ ØƒNØ4Ó4Ù!&¨t¸<Ô!H€K�ÓHñ $)°¸^Ô#L€M�=ÓLØ€Eˆ=ÓØ!%€K�Ó%á#(°¸^Ô#L€M�=ÓLØ€K�×r(   rÃ   c                  ó˜   € ] tR tRt$ R]R&   RtR]R&   RtR]R&   ]! R	R
R7      tR]R&   ]! R	RR7      t	R]R&   ]! ]
RR7      tR]R&   RtR	# )ÚConnectorListItemi  r    rJ   Trf   ÚenabledFrg   NÚconnectionStatusr@   zOptional[ConnectionStatus]Úconnection_statusrÆ   r"   rÇ   ÚdisabledToolsrO   rY   Úgateway_disabled_toolsr$   )r3   r4   r5   r6   rC   rË   rg   r   rÍ   rÇ   rc   rÏ   r8   r$   r(   r&   rÊ   rÊ     sR   ‡ ØƒNØ€GˆTÓØ€IˆtÓÙ49À$ÐN`Ô4aÐÐ1ÓaÙ#(°¸^Ô#L€M�=ÓLÙ(-¸dÈ/Ô(ZÐ˜I×Zr(   rÊ   c                  ó@   € ] tR tRt$ R]R&   ]! RRR7      tR]R&   R	tR# )
ÚConnectorListResponsei  zlist[ConnectorListItem]ÚitemsNÚ
nextCursorr@   r"   Únext_cursorr$   )r3   r4   r5   r6   rC   r   rÔ   r8   r$   r(   r&   rÑ   rÑ     s   ‡ Ø"Ó"Ù!&¨t¸<Ô!H€K�×Hr(   rÑ   c                  óà   € ] tR tRt$ ]! RR7      tR]R&   R]R&   R]R&   ]! R	R
R7      tR]R&   ]! ^R7      tR]R&   R	t	R]R&   R]R&   Rt
R]R&   ]! RR7      tR]R&   ]! RR7      tR]R&   RtR	# )ÚConnectorAccounti  r�   r<   r    r‘   rJ   ÚConnectionStatusrÄ   NrÆ   r@   r"   rÇ   )r¡   Úlabelr=   rf   ÚactiveFÚdisabledÚ	createdAtÚ
created_atÚ	updatedAtÚ
updated_atr$   )r3   r4   r5   r6   r   r‘   rC   rÇ   rØ   r=   rÚ   rÜ   rÞ   r8   r$   r(   r&   rÖ   rÖ     ss   ‡ Ù ^Ô4€M�3Ó4ØƒNØÓÙ#(°¸^Ô#L€M�=ÓLÙ !Ô$€Eˆ3Ó$Ø€Eˆ=ÓàƒLà€HˆdÓÙ +Ô.€J�Ó.Ù +Ô.€J�×.r(   rÖ   c                  ó"   € ] tR tRt$ R]R&   RtR# )ÚConnectorAccountsResponsei   zlist[ConnectorAccount]Úaccountsr$   NrG   r$   r(   r&   rà   rà      s   ‡ Ø$×$r(   rà   c                  óH   € ] tR tRt$ ]! RR7      tR]R&   R]R&   R]R&   R	tR
# )ÚRemovedConnectorAccounti$  r�   r<   r    r‘   rJ   zLiteral['removed']rÄ   r$   N)r3   r4   r5   r6   r   r‘   rC   r8   r$   r(   r&   rã   rã   $  s   ‡ Ù ^Ô4€M�3Ó4ØƒNØ×r(   rã   c                  óP   € ] tR tRt$ ^ tR]R&   ^ tR]R&   ^ tR]R&   ^ tR]R&   Rt	R# )	ÚConnectorConnectionsSummaryi*  rV   ÚtotalrÙ   Ú	initiatedÚfailedr$   N)
r3   r4   r5   r6   ræ   rC   rÙ   rç   rè   r8   r$   r(   r&   rå   rå   *  s'   ‡ Ø€Eˆ3ƒNØ€FˆCƒOØ€IˆsÓØ€FˆC‡Or(   rå   c                  óP   € ] tR tRt$ ]! ]R7      tR]R&   ]! ]R7      t	R]R&   Rt
R# )	ÚConnectorConnectionsResponsei1  rX   zlist[ConnectorConnectionResult]rj   rå   Úsummaryr$   N)r3   r4   r5   r6   r   rc   rj   rC   rå   rë   r8   r$   r(   r&   rê   rê   1  s'   ‡ Ù/4ÀTÔ/J€GÐ,ÓJÙ+0Ø3ô,€GÐ(÷ r(   rê   i  @)ÚpendingrÙ   rè   ÚexpiredÚrevokedÚinactive)zhermes-desktopzhermes-desktop-devÚportal)Ú
agent_toolÚdesktop_pageÚ
card_retryr*   )r	   i“  )r	   i™  )r	   i¦  )r	   i”  )r
   iö  )r
   i­  )r
   iø  )r
   i÷  )r
   iô  )N)Úno_trainingÚzero_retention)?Ú__conditional_annotations__r�   Ú
__future__r   Útypingr   r   r   Úpydanticr   r   r   ÚCONNECTORS_PATHÚCONNECTOR_SEARCH_PATHÚCONNECTOR_SCHEMAS_PATHÚCONNECTOR_EXECUTE_PATHÚCONNECTOR_CONNECTIONS_PATHÚCONNECTOR_ACCOUNTS_PATHÚCONNECTOR_FILE_UPLOAD_PATHÚCONNECTOR_FILE_MAX_BYTESr×   ÚConnectorReturnTargetÚConnectorInitiatorÚWIRE_BATCH_MAXr    rŒ   ÚErrorFamilyr   rC   r   r-   r/   r:   rE   rI   rU   re   ri   rq   rs   rx   r~   rƒ   r‹   r”   r˜   rœ   r¦   ÚDataUseRequirementr©   r¬   r²   rµ   r·   r¿   rÃ   rÊ   rÑ   rÖ   rà   rã   rå   rê   )rö   s   @r&   Ú<module>r     sÞ  øðôõ
 #ç )Ñ )ç 1Ñ 1à!€Ø*Ð+¨7Ð3Ð Ø+Ð,¨HÐ5Ð Ø+Ð,¨HÐ5Ð Ø /Ð0°Ð=Ð Ø,Ð-¨YÐ7Ð Ø /Ð0°Ð>Ð à+Ð ð
 ÐZÕ[Ð àÐ PÕQÐ ð ÐGÕHÐ ð €ð Ð àÐ*Õ+€ð
 Ð(ØÐ+ØÐ*ØÐ&ØÐ%ØÐ)ØÐ&ØÐ&ØÐ-ØÐ(ØÐ*ØÐ%ð;Ð Ð7ó ð$ ˜	Ø�iØ�iØ˜)ð	/Ð Ð+ó ÷@ôEˆIô Eô
K˜5ô Kô
(˜Uô (ôT˜%ô Tô
 ˜Eô 
 ô ô ôK˜eô Kô˜eô ôD˜uô Dô ô ô˜eô ô/ %ô /ô!˜ô !ôGÐ0ô Gô"˜5ô "ôJ˜eô JôJ Eô Jð Ð<Õ=Ð ô'�uô 'ôP 5ô Pô) Uô )ô	P˜Uô 	Pô<˜uô <ô	3 %ô 	3ô ô ô[˜ô [ôI˜Eô Iô
/�uô /ô% ô %ô˜eô ô %ô ô 5ö r(   