§
    µ·Äjÿ  ã                   óÈ  — d Z ddlZddlZddlZddlZddlZddlZddlZddlm	Z	  ej
        e¦  «                             ¦   «         j        Zej                             dd¦  «          ej        d¦  «        Zej        Zej        j        Zej        j        Zd„ Zd„ Zeej        _        d„ Ze	d	„ ¦   «         Zeej        _        ed
k    rddlZ ej         eddd¬¦  «         dS dS )zITemporary runtime wrapper; no endpoint and no credential/payload logging.é    N)ÚasynccontextmanagerzB/home/lighthouse/esp32-dev/.cache/watch-codex-quota-startup/serverzdevice_gateway.appc                  ó8  — |                       t          j        ¦   «         t          j        ¦   «         ¬¦  «         t          dz                       d¦  «        5 }|                     t          j        | ¦  «        dz   ¦  «         d d d ¦  «         d S # 1 swxY w Y   d S )N)Úwall_nsÚmono_nszwss-trace-send.jsonlÚaú
)	ÚupdateÚtimeÚtime_nsÚmonotonic_nsÚROOTÚopenÚwriteÚjsonÚdumps)ÚfieldsÚstreams     úu/home/lighthouse/esp32-dev/.cache/speech-playback-diagnostics-20261006/.cache/speech-diagnostics/wss_trace_gateway.pyÚrecordr      sÃ   € Ø
‡M‚M�$œ,™.œ.µ$Ô2CÑ2EÔ2E€MÑFÔFÐFÝ
Ð%Ñ
%×	+Ò	+¨CÑ	0Ô	0ð .°FØ�Š•T”Z Ñ'Ô'¨Ñ,Ñ-Ô-Ð-ð.ð .ð .ñ .ô .ð .ð .ð .ð .ð .ð .ð .øøøð .ð .ð .ð .ð .ð .s   Á+BÂBÂBc              ƒ   óR  K  — |                      dd¦  «        }|                     d¦  «        st          | |¦  «        ƒ d {V —†S t          ||                      d¦  «        |                      d¦  «        ¬¦  «        }t	          dddi|¤Ž t          j        ¦   «         }	 t          | |¦  «        ƒ d {V —† nL# t          $ r?}t	          dd	t          |¦  «        j	        t          j        ¦   «         |z
  d
z  dœ|¤Ž ‚ d }~ww xY wt	          ddt          j        ¦   «         |z
  d
z  dœ|¤Ž d S )NÚtypeÚ Úspeech_Ú	speech_idÚsequence)r   r   r   ÚeventÚ
send_beginÚ
send_errorg    €„.A)r   ÚerrorÚ
elapsed_msÚsend_complete)r   r    © )
ÚgetÚ
startswithÚoriginal_sendÚdictr   r
   r   ÚBaseExceptionr   Ú__name__)ÚdeviceÚframeÚkindÚinfoÚbeganr   s         r   Útraced_sendr.      sb  è è € Ø�9Š9�V˜RÑ Ô €DØ�?Š?˜9Ñ%Ô%ð 2Ý" 6¨5Ñ1Ô1Ð1Ð1Ð1Ð1Ð1Ð1Ð1Ý�T U§Y¢Y¨{Ñ%;Ô%;ÀeÇiÂiÐPZÑF[ÔF[Ð\Ñ\Ô\€DÝ
Ð&Ð&�Ð& Ð&Ð&Ð&ÝÔÑÔ€EðÝ˜F EÑ*Ô*Ð*Ð*Ð*Ð*Ð*Ð*Ð*Ð*øÝð ð ð ÝÐr�\­¨e©¬Ô)=Í4ÔK\ÑK^ÔK^Ð_dÑKdÐfiÑJiÐrÐrÐmqÐrÐrÐrØøøøøðøøøõ ÐU�­dÔ.?Ñ.AÔ.AÀ%Ñ.GÈÑ-LÐUÐUÐPTÐUÐUÐUÐUÐUs   ÂB5 Â5
C>Â?:C9Ã9C>c               ƒ   óV  ‡K  — t           dz  } 	 t          j        d¦  «        ƒ d {V —† |                      ¦   «         sŒ0t	          j        |                      ¦   «         ¦  «        }|                      ¦   «          t          j	         
                    d¦  «        }|�&|j        rt          j                             |¦  «        st          d¬¦  «         ŒÂt           dz                       ¦   «         Št          dt!          ‰¦  «        t#          j        ‰¦  «                             ¦   «         t!          ‰¦  «        d	z   d
z  ¬¦  «          G ˆfd„d¦  «        }t          j        j        } |¦   «         t          j        _        	 t          j                             |dd¦  «        s$t          d¬¦  «         	 |t          j        _        �Œ´t          j        j        |j                 }|j        ƒ d {V —† t          d|j        ¬¦  «         |t          j        _        n# |t          j        _        w xY w�Œ)Nzwss-trace-command.jsonTgš™™™™™¹?zesp32s3-28848543a200Ú	not_ready©r   zdeterministic-2s.pcmÚsourcei�  i�  )r   ÚbytesÚsha256Úchunksc                   ó   •— e Zd Zˆ fd„ZdS )ú watch_commands.<locals>.FixedPCMc              “   ó   •K  — ‰S )Nr"   )ÚselfÚtextÚlanguageÚpcms      €r   Ú
synthesizez+watch_commands.<locals>.FixedPCM.synthesize0   s   øè è € Ø�
ó    N)r(   Ú
__module__Ú__qualname__r=   )r<   s   €r   ÚFixedPCMr7   /   s.   ø€ € € € € ðð ð ð ð ð ð r>   rA   ÚscreenzFixed PCM WSS diagnosticÚstart_rejectedÚmanager_finished)r   r   )r   ÚasyncioÚsleepÚexistsr   ÚloadsÚ	read_textÚunlinkÚgatewayÚdevicesr#   ÚonlineÚspeechesÚcapabler   Ú
read_bytesÚlenÚhashlibr4   Ú	hexdigestÚproviderÚstartÚactiveÚconnection_idÚtaskr   )ÚcommandÚoptionsr)   rA   rT   Úplaybackr<   s         @r   Úwatch_commandsr\   !   s+  øè è € ÝÐ+Ñ+€Gð1ÝŒm˜BÑÔÐÐÐÐÐÐÐØ�~Š~ÑÔð 	ØÝ”*˜W×.Ò.Ñ0Ô0Ñ1Ô1ˆØ�ŠÑÔÐÝ”×$Ò$Ð%;Ñ<Ô<ˆØˆ> ¤ˆ>µgÔ6F×6NÒ6NÈvÑ6VÔ6Vˆ>Ý˜Ð%Ñ%Ô%Ð%ØÝÐ*Ñ*×6Ò6Ñ8Ô8ˆÝ�X¥S¨¡X¤Xµg´nÀSÑ6IÔ6I×6SÒ6SÑ6UÔ6UÕ_bÐcfÑ_gÔ_gÐhlÑ_lÐosÑ^sÐtÑtÔtÐtð	ð 	ð 	ð 	ð 	ð 	ð 	ñ 	ô 	ð 	õ Ô#Ô,ˆØ$, H¡J¤J�ÔÔ!ð	1ÝÔ#×)Ò)¨&°(Ð<VÑWÔWð ÝÐ-Ð.Ñ.Ô.Ð.Øð
 )1�GÔÔ%Ñ%õ	 Ô'Ô.¨vÔ/CÔDˆHØ”-ÐÐÐÐÐÐÐÝÐ+°xÔ7IÐJÑJÔJÐJà(0�GÔÔ%Ð%ø¨�GÔÔ%Ð0Ð0Ð0Ð0ñ31s   Å=1H Ç?H ÈH&c                ó¸  K  — t          | ¦  «        4 ƒd {V —† t          j        t          ¦   «         ¦  «        }t	          d¬¦  «         	 d W V — |                     ¦   «          t          j        |d¬¦  «        ƒ d {V —† n5# |                     ¦   «          t          j        |d¬¦  «        ƒ d {V —† w xY w	 d d d ¦  «        ƒd {V —† d S # 1 ƒd {V —†swxY w Y   d S )NÚwrapper_readyr1   T)Úreturn_exceptions)Úoriginal_lifespanrE   Úcreate_taskr\   r   ÚcancelÚgather)ÚinstancerX   s     r   Úlifespanre   >   s€  è è € å  Ñ*Ô*ð ?ð ?ð ?ð ?ð ?ð ?ð ?ð ?ÝÔ"¥>Ñ#3Ô#3Ñ4Ô4ˆÝ�_Ð%Ñ%Ô%Ð%ð	?ØˆEˆEˆEˆEà�KŠK‰MŒMˆMÝ”. ¸Ð>Ñ>Ô>Ð>Ð>Ð>Ð>Ð>Ð>Ð>Ð>øð �KŠK‰MŒMˆMÝ”. ¸Ð>Ñ>Ô>Ð>Ð>Ð>Ð>Ð>Ð>Ð>Ð>øøøÐ>ð?ð ?ð ?ñ ?ô ?ð ?ð ?ð ?ð ?ð ?ð ?ð ?ð ?ð ?ð ?ð ?ð ?ð ?ð ?ð ?ð ?ð ?ð ?ð ?øøøð ?ð ?ð ?ð ?ð ?ð ?s)   ˜1C	Á
B Á1C	Â 2B2Â2C	Ã	
CÃCÚ__main__i    z	127.0.0.1i¡F  )Úws_max_sizeÚhostÚport)!Ú__doc__rE   rR   Ú	importlibr   ÚpathlibÚsysr
   Ú
contextlibr   ÚPathÚ__file__ÚresolveÚparentr   ÚpathÚinsertÚimport_modulerK   ÚappÚrouterÚlifespan_contextr`   rN   Úsendr%   r   r.   r\   re   r(   ÚuvicornÚrunr"   r>   r   ú<module>r|      sz  ðØ OÐ OØ <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ø *Ð *Ð *Ð *Ð *Ð *à€w„|�HÑÔ×%Ò%Ñ'Ô'Ô.€Ø „‡‚�ÐWÑ XÔ XÐ XØ
!ˆ)Ô
!Ð"6Ñ
7Ô
7€Ø„k€Ø”JÔ/Ð ØÔ Ô%€ð.ð .ð .ð
Vð Vð Vð $€Ô Ô ð1ð 1ð 1ð: ð?ð ?ñ Ôð?ð '€„
Ô ØˆzÒÐØ€N€N€NØ€G„K� ¨K¸eÐDÑDÔDÐDÐDÐDð Ðr>   