+
    lHàj¨  ã                  óP   € R t ^ RIHt ^RIHt R R ltR R ltRR R	 lltR
 tR# )zJJSON-RPC admission and worker dispatch. Rebound onto the server namespace.)Úannotations)Úbind_modulec               ó    € V ^8„  d   QhRRRR/# ©é   ÚreqÚdictÚreturnúdict | None© )Úformats   "Ú=/home/ubuntu/.hermes/hermes-agent/tui_gateway/rpc_dispatch.pyÚ__annotate__r      s   € ÷ -ñ -˜ð - ñ -ó    c                óî   € ^ RI Hp VP                  4       ;_uu_ 4       pV'       g'   \        V P	                  R4      RR4      uuRRR4       # \        V 4      uuRRR4       #   + '       g   i     R# ; i)é    ©Ú
retirementÚidé«  ú*backend is retiring; reconnect to continueN)Úhermes_cli.backend_retirementr   ÚworkÚ_errÚgetÚ_handle_admitted_request)r   r   Úadmitteds   &  r   Úhandle_requestr      sM   € Ý8à	�‰×	Ô	˜hßÜ˜Ÿ™ › tÐ-YÓZ÷ 
Ò	ô (¨Ó,÷ 
×	×	Ó	ús   Ÿ$A#Á
A#Á#A4	c               ó    € V ^8„  d   QhRRRR/# r   r   )r   s   "r   r   r      s   € ÷ ñ  $ð ¨;ñ r   c                óJ  € \        V 4      p\        V\        4      '       d   V# Vw  r#p\        P	                  V4      ;p'       g   \        VRRV R24      # \        P                  P	                  V4      pVe)   \        P                  Wd4      w  rGVe   \        VRV4      # \        P                  V4      p V! W$4      p	 \        P                  T4       Tem   \        T	\        4      '       dW   \        T	P	                  R4      \        4      '       d2   \        P                  Yd4       \        P                  YiR,          4       T	#   \         d6   p
\        TR\        T
4      4      u Rp
?
\        P                  T4       # Rp
?
ii ; i  \        P                  T4       i ; i)iY  zunknown method: uq    â€” the client and the Hermes backend are out of sync (different versions); run `hermes update` and restart bothNi   ià  Úresulti§€ÿÿ)Ú_normalize_requestÚ
isinstancer   Ú_methodsr   r   Ú
_contractsÚMETHODSÚvalidate_paramsÚ_current_rpc_methodÚsetÚProfileUnavailableErrorÚstrÚresetÚcheck_params_acceptedÚcheck_result)r   Ú
normalizedÚridÚmethodÚparamsÚfnÚcontractÚproblemÚtokenÚresponseÚexcs   &          r   r   r      si  € Ü# CÓ(€JÜ�*œd×#Ò#ØÐØ$Ñ€C�Ü—,‘,˜vÓ&Ð&ˆBÖ&Ü�C˜Ð#3°F°8ð <Qð "Qó Rð 	Rô ×!Ñ!×%Ñ% fÓ-€HØÒÜ$×4Ñ4°XÓF‰ˆØÒÜ˜˜T 7Ó+Ð+Ü×#Ñ# FÓ+€Eð)Ù�c“?‰ô 	×!Ñ! %Ô(ØÒ¤
¨8´T× :Ò :¼zÈ(Ï,É,ÐW_ÓJ`Ôbf×?gÒ?gÜ×(Ñ(¨Ô:Ü×Ñ °8Õ*<Ô=Ø€Oøô #ô )Ü�C˜œs 3›xÓ(Ô(ä×!Ñ! %Õ(ûð)ûô 	×!Ñ! %Õ(ús0   Â8E ÅFÅFÅ(FÅ)F ÆFÆF ÆF"Nc               ó$   € V ^8„  d   QhRRRRRR/# )r   r   r   Ú	transportzOptional[Transport]r	   r
   r   )r   s   "r   r   r   -   s"   € ÷ -ñ -�$ð -Ð#6ð -À+ñ -r   c                ó`  a aaa	a
€ T;'       g    \         o
\        S
4      p ^ RIHp VP	                  S 4      '       d]   VP                  S S
4      '       g7   \        S 4      '       g&   \        P                  RS P                  R4      4        \        V4       R# \        S 4      p\        V\        4      '       d   V\        V4       # V^,          \        9  d   \        S 4      \        V4       # ^ RIHo SP%                  4       '       g(   \'        S P                  R4      RR4      \        V4       #  \(        P+                  4       oV^,          P                  R4      pV^,          \,        9   dJ   \        V\        4      '       d4   VP                  R	4      R
8X  d   SP/                  \0        V^,          4       V V
3R lo	\2        P5                  VV	3R l4      pTP;                  T3R l4        \        T4       R#   \6         d    SP9                  4        h i ; i  \        T4       i ; i)uR  Route inbound RPCs â€” long handlers to the pool (returns None; the worker writes its own
response via the bound transport), everything else inline (returns the response dict).
*transport* pins every write of this request â€” events included â€” to that transport;
omitted â†’ the module stdio transport (``tui_gateway.entry`` behaviour).)Úserver_requestsz2dropping response for unknown server request id=%rr   Nr   r   r   ÚownerÚtypeÚsessionc                 ó¼   <€  \        S4      p V e   SP	                  V 4       R# R#   \         d*   p\        SP                  R 4      RRT 24      p  Rp?LHRp?ii ; i)r   zhandler error: Ni ƒÿÿ)r   Ú	Exceptionr   r   Úwrite)Úrespr7   r   Úts     €€r   ÚrunÚdispatch.<locals>.runK   s\   ø€ ðPÜ3°CÓ8�Dð Ò#Ø—G‘G˜D–Mñ $øô !ô PÜ §¡¨£¨v¸ÈÈÐ7NÓO•DûðPús   ƒ' §A²AÁAc                 ó&   <€ S P                  S4      # ©N)rD   )ÚctxrD   s   €€r   Ú<lambda>Údispatch.<locals>.<lambda>R   s   ø€ ¨#¯'©'°#¬,r   c                ó$   <€ SP                  4       # rG   )Úrelease)Ú_r   s   &€r   rI   rJ   W   s   ø€ ¨:×+=Ñ+=Ô+?r   )Ú_stdio_transportÚbind_transportÚtui_gatewayr;   Úis_response_frameÚresolve_responseÚ_relay_compute_host_responseÚloggerÚdebugr   Úreset_transportr!   r"   r   Ú_LONG_HANDLERSr   r   r   Úacquirer   ÚcontextvarsÚcopy_contextÚ_CONNECTOR_RPC_METHODSrD   Ú_capture_connector_rpc_ownerÚ_poolÚsubmitÚBaseExceptionrL   Úadd_done_callback)r   r9   r5   r;   r.   r<   ÚfuturerH   r   rD   rC   s   f&     @@@@r   Údispatchrb   -   s¿  ü€ ð
 	×%Ð%Ô%€AÜ˜1Ó€Eð&Ý/Ø×,Ñ,¨S×1Ò1à"×3Ñ3°C¸×;Ò;ÔD`Ðad×DeÒDeÜ—‘ÐQÐSV×SZÑSZÐ[_ÓS`ÔaØô@ 	˜Öô? (¨Ó,ˆ
Ü�j¤$×'Ò'Øô: 	˜Õð9 �a�=¤Ô.Ü! #Ó&ô6 	˜Õõ5 	=ð ×!Ñ!×#Ò#Ü˜Ÿ™ › tÐ-YÓZô, 	˜Õð+	Ü×*Ñ*Ó,ˆCØ˜q•M×%Ñ% gÓ.ˆEØ˜!�}Ô 6Ô6¼:ÀeÌT×;RÒ;RÐW\×W`ÑW`ÐagÓWhÐluÔWuØ—‘Ô4°jÀµmÔDö"ô —\‘\Õ"6Ó7ˆFð
 	× Ñ Ô!?Ô@Øä˜Öøô ô 	Ø×ÑÔ Øð	ûô 	˜ÕúsB   ¢4H  Á6H  Â"H  Ã	H  Ã1H  ÄH  Ä5B(H  ÇH  È HÈH  È H-c                ó.   € \        \        4       V 4       R # rG   )r   Úglobals)Úservers   &r   Úregisterrf   ]   s   € Ü”“	˜6Ö"r   rG   )	Ú__doc__Ú
__future__r   Ú
method_ctxr   r   r   rb   rf   r   r   r   Ú<module>rj      s#   ðÙ På "å #õ-õ÷8-ô`#r   