+
    jHàj¡  ã                   óB   € R t ^ RIHt ^ RIHt ^ RIHt  ! R R4      tR# )zKExact operator controls for canonical hosted attempts, never legacy replay.)Úhosted_room_driver)ÚRuntimeStoreError)ÚHostedRoomBindingc                   óH   a a€ ] tR t^t oR tR tR tRV 3R lltRtVt	V ;t
# )ÚHostedControlsc                ód  aaa€ \        V4      \        JgD   V^8  g=   \        S\        4      '       d'   S'       d   \        S\        4      '       d	   S'       g   \	        R4      hV P                  V4      w  rV\        V3R l\        P                  ! V P                  VR7       4       R4      oSeL   SR,          V8w  g>   SR,          P                  R4      ;'       g    SR,          P                  R4      S8w  d   \	        R	4      h\        ;QJ d6    VV3R
 lV P                  V4      R,           4       F  '       g   K   RM+	  RM'! VV3R
 lV P                  V4      R,           4       4      '       g   \	        R4      hV P                  VS4      '       d   \	        R4      hS\        WV4      3# )é   Úinvalid_paramsc              3   ó\   <"  € T F!  pVR ,          P                   S8X  g   K  Vx € K#  	  R# 5i)ÚidentityN)Útask_id)Ú.0Útr   s   & €ÚD/home/ubuntu/.hermes/hermes-agent/gateway/session_hosted_controls.pyÚ	<genexpr>Ú/HostedControls._control_task.<locals>.<genexpr>   s,   øé € ð :Ñ O˜1Ø˜*�×-Ñ-°Ñ8÷ ’QÓ Oùs   ƒ,¢
,©Úroom_idNÚexecution_generationÚpayloadÚtarget_member_idÚtarget_profileÚstale_generationc              3   ó    <"  € T FC  pVP                  R 4      S8H  ;'       d#    VP                  R4      SR,          R,          8H  x € KE  	  R# 5i)Ú	member_idÚprofiler   r   N)Úget)r   Úmr   Útasks   & €€r   r   r      sS   øé € ð <á:�qð —5‘5˜Ó%¨Ñ2÷ Mð MØ—u‘u˜YÓ'¨4°	­?Ð;KÕ+LÑLôMã:ùs
   ƒA£+AÚmembersTFÚpermission_deniedÚunsupported_operation)ÚtypeÚintÚ
isinstanceÚstrr   Ú_owned_authorityÚnextÚtasksÚ
list_tasksÚdb_pathr   ÚanyÚ_roomÚ_member_is_peerr   )Úselfr   r   r   r   ÚgatewayÚepochr   s   &&ff&  @r   Ú_control_taskÚHostedControls._control_task   s[  ú€ ÜÐ%Ó&¬cÓ1Ð5IÈAÔ5MÜ! )¬S×1Ò1¿Ü! '¬3×/Ò/·wÜ#Ð$4Ó5Ð5Ø×.Ñ.¨wÓ7‰ˆÜô :¤× 0Ò 0°·±ÀwÕ Oó :Ø;?óAˆàŠL˜DÐ!7Õ8Ð<PÔPØ˜•O×'Ñ'Ð(:Ó;×dÐd¸tÀI½×?RÑ?RÐScÓ?dÐirÔrÜ#Ð$6Ó7Ð7ß‹sõ <à ŸJ™J wÓ/°	Ö:ó<�s�sŠsõ <à ŸJ™J wÓ/°	Ö:ó<÷ <ò <ô $Ð$7Ó8Ð8Ø×Ñ ¨×3Ò3Ü#Ð$;Ó<Ð<ØÔ& w¸Ó?Ð?Ð?ó    c          
     ó¼  € V P                   ;_uu_ 4        V P                  WW44      w  rVR V 2pVR,          R8X  d#   VP                  R4      V8X  d   VuuRRR4       # VR,          R8w  d   \        R4      hV P	                  We4      pVP                  VR,          R,          R	VP                  P                  VVR
7       V P                  P                  V4      p	V P                  P                  \        P                  WeW—R7      p
V P                  P                  VR4       V P                  P                  4        V
uuRRR4       #   + '       g   i     R# ; i)zdiscard:ÚstatusÚ	cancelledÚ	cancel_idNÚindeterminater   r   r   Úbot_room)r   ÚsourceÚ
session_idÚexpected_task_idr   )r7   F)Ú_policy_lockr1   r   r   Ú_resolve_member_transportÚdiscardÚrefr;   ÚruntimeÚ_ensure_leaseÚ_fencedr(   Ú"resolve_indeterminate_cancellationÚ_set_blockedÚwakeup)r.   r   r   r   r   r   Úbindingr7   ÚrpcÚleaseÚresults   &&$$$      r   Údiscard_room_taskÚ HostedControls.discard_room_task   s'  € Ø××ÓØ ×.Ñ.¨wÀ7Óa‰MˆDØ"Ð#7Ð"8Ð9ˆIØ�H�~ Ô,°·±¸+Ó1FÈ)Ô1SØ÷	 Òð
 �H�~ Ô0Ü'Ð(:Ó;Ð;Ø×0Ñ0°Ó?ˆCð �K‰K  Y¥Ð0@Õ AÈ*Ø#&§7¡7×#5Ñ#5ÈØ-Að ô Cð —L‘L×.Ñ.¨wÓ7ˆEØ—\‘\×)Ñ)¬%×*RÑ*RØ˜uð *ó ;ˆFà�L‰L×%Ñ% g¨uÔ5Ø�L‰L×ÑÔ!Ø÷% ××Óús   •?E
ÁC E
Å
E	c               ó”  € V P                   ;_uu_ 4        V P                  WW44      w  rVVR ,          R8X  d   \        R4      hVR ,          R8w  d   \        R4      hV P                  We4      pVP	                  VR,          R,          RVP
                  P                  R7      pVP                  R 4      R	8X  d   \        R4      hVP                  R
4      '       d   \        R4      hV P                  P                  V4      p	V P                  P                  \        P                  WYV4      uuRRR4       #   + '       g   i     R# ; i)r5   r8   Úunknown_executionÚdeferredr   r   r   r9   )r   r:   r;   ÚunknownÚactiveÚsession_busyN)r=   r1   r   r>   Úinfor@   r;   r   rA   rB   Ú_requeuer(   Úrequeue_deferred_task)
r.   r   r   r   r   r   rG   rH   rS   rI   s
   &&$$$     r   Úretry_room_taskÚHostedControls.retry_room_task0   s	  € Ø××ÓØ ×.Ñ.¨wÀ7Óa‰MˆDð �H�~ Ô0Ü'Ð(;Ó<Ð<Ø�H�~ Ô+Ü'Ð(:Ó;Ð;Ø×0Ñ0°Ó?ˆCØ—8‘8 D¨¥OÐ4DÕ$EÈjØ'*§w¡w×'9Ñ'9ð ó ;ˆDà�x‰x˜Ó! YÔ.Ü'Ð(;Ó<Ð<Ø�x‰x˜×!Ò!Ü'¨Ó7Ð7Ø—L‘L×.Ñ.¨wÓ7ˆEØ—<‘<×(Ñ(¬×)DÑ)DÀdÐSZÓ[÷! ××Óús   •CD6ÃAD6Ä6E	c                ó  <€ \         SV `  V4      pVf   V# VR,           Uu. uF  q3R,          R8w  g   K  VNK  	  pp\        P                  ! V P                  VR7       F�  pVR,          R9  d   K  VR,          P                  R4      ;'       g    VR,          R	,          pV P                  W4      '       d   K\  TP                  RVR,          R8X  d   R
MRRVRVR,          P                  RVR,          /4       KŸ  	  / VCRV/C# u upi )NÚpending_actionsÚkindÚretryr   r5   r8   r   r   r   r?   r   r   r   r   >   rO   r8   )	Úsuperr5   r(   r)   r*   r   r-   Úappendr   )r.   r   rJ   ÚaÚactionsr   ÚmemberÚ	__class__s   &&     €r   r5   ÚHostedControls.statusC   s  ø€ Ü‘‘ Ó(ˆØŠ?ØˆMØ$Ð%6Ö7ÓPÑ7˜¸V½9ÈÑ;O—1�1Ñ7ˆÐPÜ×$Ò$ T§\¡\¸7×CˆDØ�H�~Ð%BÔBÙØ˜)•_×(Ñ(Ð);Ó<×aÐaÀÀYÅÐP`Õ@aˆFØ×#Ñ# G×4Ò4ÙØ�N‰N˜F°°hµÀ?Ô1R¡IÐX_Ø'¨°¸DÀÕ<L×<TÑ<TØ2°DÐ9OÕ4PðRö Sñ Dð 6�&Ð5Ð+¨WÑ5Ð5ùò Qs
   ¢D	¶D	© )N)Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__r1   rK   rV   r5   Ú__static_attributes__Ú__classdictcell__Ú__classcell__)ra   Ú__classdict__s   @@r   r   r      s    ù‡ € ò@ò&ò*\÷&6÷ 6r3   r   N)	Ú__doc__r/   r   r(   Úhermes_state_runtimer   Útui_gateway.hosted_room_driverr   r   rc   r3   r   Ú<module>ro      s   ðÙ QÝ /Ý 2Ý <÷J6ó J6r3   