+
    „WÝj  ã                   ó   € R t  ! R R4      tR# )zLCLI notification ownership, structured queueing and last-moment consumption.c                   ó\   a € ] tR t^t o V 3R lR ltV 3R lR ltV 3R lR ltR tRtV t	R	# )
ÚCLIProcessNotificationsMixinc                ó&   <€ V ^8„  d   QhRS[ RS[/# )é   ÚeventÚreturn)ÚdictÚbool)ÚformatÚ__classdict__s   "€ÚXC:\Users\johnn\AppData\Local\hermes\hermes-agent\hermes_cli\cli_process_notifications.pyÚ__annotate__Ú)CLIProcessNotificationsMixin.__annotate__   s   ø€ ÷ 0ñ 0±ð 0¹ñ 0ó    c                ó^  € \        VP                  R4      ;'       g    R4      p\        \        V RR4      ;'       g    R4      pV'       d	   V'       g   R# W#8X  d   R#  \        V RR4      pVe   VP                  V4      MT;'       g    Tp\        V4      V8H  #   \         d    Tp Li ; i)zoWhether this session owns a delegation event (pre-compression keys resolve to their continuation; fail closed).Úsession_keyÚ Ú
session_idFTÚ_session_dbN)ÚstrÚgetÚgetattrÚresolve_resume_session_idÚ	Exception)Úselfr   Ú	event_keyÚcurrent_keyÚ
session_dbÚresolved_keys   &&    r   Ú_owns_process_notificationÚ7CLIProcessNotificationsMixin._owns_process_notification   s¬   € ä˜Ÿ	™	 -Ó0×6Ð6°BÓ7ˆ	Üœ' $¨°bÓ9×?Ð?¸RÓ@ˆß§ÙØÔ#Ùð	%Ü   }°dÓ;ˆJàCMÒCY�
×4Ñ4°YÔ?Ð_h÷ð àð ô
 �<Ó  KÑ/Ð/øô ô 	%Ø$ŠLð	%ús   Á *B ÂB ÂB,Â+B,c                ó    <€ V ^8„  d   QhRS[ /# )r   r   )r	   )r
   r   s   "€r   r   r      s   ø€ ÷ ñ ±dñ r   c                óð   €  ^ RI Hp \        VP                  R4      ;'       g    / P                  R4      ;'       g    R4      P	                  4       P                  4       pVR8H  #   \         d     R# i ; i)u‡  Whether ``display.background_process_notifications`` is ``off`` for this CLI session.

The key gates the gateway's completion injection (#9290) but the CLI drain never consulted
it, so the documented ``off`` escape hatch silently did nothing here (#123114). Mirrors the
gateway semantics: events are still drained, claimed and acknowledged â€” only the
turn-starting injection is suppressed.)Ú
CLI_CONFIGÚdisplayÚ background_process_notificationsr   FÚoff)Úclir#   r   r   ÚstripÚlowerr   )r   r#   Úmodes   &  r   Ú$_background_notifications_suppressedÚACLIProcessNotificationsMixin._background_notifications_suppressed   sl   € ð	Ý&Ü˜
Ÿ™ yÓ1×7Ð7°R×<Ñ<Ð=_Ó`×fÐfÐdfÓg×mÑmÓo×uÑuÓwˆDð �u‰}Ðøô ô 	Úð	ús   ‚"A& ¥A& ¾#A& Á&A5Á4A5c                ó$   <€ V ^8„  d   QhRS[ RR/# )r   Úconsumerr   N)r   )r
   r   s   "€r   r   r   $   s   ø€ ÷ &-ñ &-±Sð &-¸Tñ &-r   c                óJ  € ^ RI HpHp V! V 4      pVe   V! W4       R# ^ RIHp ^ RIHpHp ^ RIH	pH
p	Hp
HpHp . pTP                  \        V RR4      ;'       g    RV P                   R7       F.  w  rïV! Wá4      pVf   K  VP#                  Wï34       V! VV4       K0  	  V P%                  4       '       d/   V UUu. uF   w  rïVP'                  R	4      R
8X  g   K  Wï3NK"  	  pppV! V4       F¬  pV^ ,          w  rïVP'                  R	R4      pVR8X  d
   V	! V4      pMaVR8X  d   V
! Wü! V4      V4      pMJVR
8X  d   V
P)                  Wþ4      MTp^ RIHp V! V4      '       d   \/        VV
4      '       g   V
! WÿRR4      pV P0                  P3                  V4       K®  	  R# u uppi )é    )Úgateway_storeÚqueue_admitted_turnN©Úprocess_registry)Úclaim_event_deliveryÚcomplete_event_delivery)ÚHEARTBEAT_DISPLAY_KINDÚProcessNotificationBatchÚTimelineNotificationÚgroup_process_notificationsÚheartbeat_display_textr   r   )r   Ú
owns_eventÚtypeÚasync_delegationÚ
completionÚ	heartbeat)Údiagnostic_process_eventÚinternal_notificationÚ
diagnostic)Úhermes_cli.gateway_tools_notifyr1   r2   Útools.process_registryr4   Útools.async_delegationr5   r6   Ú$tools.process_registry_notificationsr7   r8   r9   r:   r;   Údrain_notificationsr   r   Úappendr+   r   Úfor_delegationÚagent.notification_presentationrA   Ú
isinstanceÚ_pending_inputÚput)r   r.   r1   r2   Ústorer4   r5   r6   r7   r8   r9   r:   r;   Úclaimedr   ÚtextÚclaimÚnotificationsÚevt_typeÚpendingrA   s   &&                   r   Ú_drain_process_notificationsÚ9CLIProcessNotificationsMixin._drain_process_notifications$   s–  € ßVÙ˜dÓ#ˆØÒñ   Ô,ÙÝ;ßX÷	$õ 	$ð ˆØ+×?Ñ?Ü  l°BÓ7×=Ð=¸2È$×JiÑJið @ö 
‰KˆEñ )¨Ó9ˆEØŠ}ÙØ�N‰N˜E˜=Ô)Ù# E¨5Ö1ñ
ð ×4Ñ4×6Ò6á8?Ôk¹©¨À5Ç9Á9ÈVÓCTÐXjÑCj”}˜“}¹ˆGÑkÙ8¸ÖAˆMØ'¨Õ*‰KˆEØ—y‘y ¨Ó6ˆHØ˜<Ô'Ù2°=ÓA‘Ø˜[Ô(Ù.¨tÐ5KÈEÓ5RÐTjÓk‘àNVÐZlÔNlÐ.×=Ñ=¸dÔJÐrv�ÝTÙ+¨E×2Ò2¼:ÀgÐOc×;dÒ;dÙ2°4Ð?VÐXdÓe�GØ×Ñ×#Ñ# GÖ,ó Bùó ls   Â<FÃFc                ó®  € ^ RI HpHp ^ RIHp ^ RIHpHpHp \        W4      '       d4   VP                  V4      pT;'       d    V! W�P                  V4      V4      p\        W4      p	V	'       d   VP                  p\        W4      p
V
'       dE   ^ RIHp V! W4       VP                  '       d   VP                  VP                  3MVP                  pWV
3# )zpUnwrap ``_VoiceInputMessage`` / ``_SeededQueryMessage`` -> ``(text_or_tuple, is_voice_input, is_seeded_query)``.)Ú_VoiceInputMessageÚ_SeededQueryMessager3   )ÚPROCESS_COMPLETE_DISPLAY_KINDr8   r9   )Úarm_adopted)r'   rY   rZ   rE   r4   rG   r[   r8   r9   rL   ÚrenderÚdisplay_textrQ   rD   r\   Úimages)r   Ú
user_inputrY   rZ   r4   r[   r8   r9   ÚrenderedÚis_voice_inputÚis_seeded_queryr\   s   &&          r   Ú_tui_unwrap_inputÚ.CLIProcessNotificationsMixin._tui_unwrap_inputL   s¿   € ç?Ý;÷	[ñ 	[ä�j×;Ò;Ø!×(Ñ(Ð)9Ó:ˆHØ!÷ dð dÑ&:Ø×1Ñ1Ð2BÓCÐEbó'dˆJô $ JÓCˆßØ#Ÿ™ˆJÜ$ ZÓEˆßÝCÙ˜Ô)ØAK×AR×ARÐAR˜*Ÿ/™/¨:×+<Ñ+<Ñ=ÐXb×XgÑXgˆJØ¨?Ð:Ð:r   © N)
Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__r   r+   rV   rd   Ú__static_attributes__Ú__classdictcell__)r   s   @r   r   r      s.   ø‡ € ÷0ð 0÷"ð ÷&-ð &-÷P;ð ;r   r   N)Ú__doc__r   rf   r   r   Ú<module>rn      s   ðÙ R÷\;ó \;r   