+
    TŎiI                       a R t@0 t R t^ RIt^ RIt^ RIHt ^ RIHtHtH	t	H
t
HtHt ^RIHt ^RIHt ^RIHtHt ^RIHt ^RIHtHtHt ^R	IHtHtHtHtHt ] U u0 uF  p ]! V 4      kK  	  up t ] ^ k ^t!^t"^t#^t$]PJ                  t&]PN                  t(Rt)]PT                  PV                  t,]PN                  PV                  t-]PJ                  PV                  t.]P^                  PV                  t0]Pb                  PV                  t2]Pf                  PV                  t4Rt5Rt6Rt7^ t8^t9]:Pv                  t<]t= ! R
 R4      t> ! R R4      t?R# u up i )z0Reader for WebSocket protocol versions 13 and 8.N)deque)DequeFinalOptionalSetTupleUnion)BaseProtocol)ZLibDecompressor)_EXC_SENTINELset_exception)	EofStream)UNPACK_CLOSE_CODEUNPACK_LEN3websocket_mask)WS_DEFLATE_TRAILINGWebSocketErrorWSCloseCode	WSMessage	WSMsgTypec                      a  ] tR t^6t o RtV 3R lR ltV 3R lR ltV 3R lR lt]3V 3R lR	 llt	V 3R
 lR lt
V 3R lR ltV 3R lR ltV 3R lR ltV 3R lR ltRtV tR# )WebSocketDataQueuezeWebSocketDataQueue resumes and pauses an underlying stream.

It is a destination for WebSocket data.
c                D   < V ^8  d   QhRS[ RS[RS[P                  RR/# )   protocollimitloopreturnN)r	   intasyncioAbstractEventLoop)format__classdict__s   "k/Users/ahmad/.openclaw/workspace/scripts/.venv/lib/python3.14/site-packages/aiohttp/_websocket/reader_py.py__annotate__WebSocketDataQueue.__annotate__<   s3     / /$/-0/;B;T;T/	/    c                   ^ V n         Wn        V^,          V n        W0n        RV n        RV n        RV n        \        4       V n        V P                  P                  V n
        V P                  P                  V n        R# )    FN)_size	_protocol_limit_loop_eof_waiter
_exceptionr   _bufferpopleft_get_bufferappend_put_buffer)selfr   r   r   s   &&&$r#   __init__WebSocketDataQueue.__init__<   sb     
!ai
	7;6:5:W<<//<<..r&   c                    < V ^8  d   QhRS[ /# r   r   )bool)r!   r"   s   "r#   r$   r%   J   s       r&   c                    V P                   # N)r-   r5   s   &r#   is_eofWebSocketDataQueue.is_eofJ   s    yyr&   c                0   < V ^8  d   QhRS[ S[,          /# r9   )r   BaseException)r!   r"   s   "r#   r$   r%   M   s      8M2 r&   c                    V P                   # r<   )r/   r=   s   &r#   	exceptionWebSocketDataQueue.exceptionM   s    r&   c                >   < V ^8  d   QhRS[ RS[P                   RR/# )r   exc	exc_causer   N)rA   builtins)r!   r"   s   "r#   r$   r%   P   s/     	2 	2	2 ))	2 
		2r&   c                j    R V n         Wn        V P                  ;pe   RV n        \        W1V4       R# R# TN)r-   r/   r.   r   )r5   rF   rG   waiters   &&& r#   r    WebSocketDataQueue.set_exceptionP   s5    
 	ll"F/DL&y1 0r&   c                   < V ^8  d   QhRR/# r   r   N )r!   r"   s   "r#   r$   r%   [   s     $ $ $r&   c                    V P                   ;pf   R # R V n         VP                  4       '       g   VP                  R 4       R # R # r<   )r.   done
set_result)r5   rK   s   & r#   _release_waiter"WebSocketDataQueue._release_waiter[   s9    ll"F+{{}}d# r&   c                   < V ^8  d   QhRR/# rN   rO   )r!   r"   s   "r#   r$   r%   b   s      $ r&   c                B    R V n         V P                  4        RV n        R# rJ   )r-   rS   r/   r=   s   &r#   feed_eofWebSocketDataQueue.feed_eofb   s    	r&   c                &   < V ^8  d   QhRRRRRR/# )r   datar   size
cython_intr   NrO   )r!   r"   s   "r#   r$   r%   g   s"     + +k + +$ +r&   c                &   V ;P                   V,          un         V P                  W34       V P                  4        V P                   V P                  8  d;   V P                  P
                  '       g   V P                  P                  4        R # R # R # r<   )r)   r4   rS   r+   r*   _reading_pausedpause_readingr5   rZ   r[   s   &&&r#   	feed_dataWebSocketDataQueue.feed_datag   sd    

d
$&::#DNN,J,J,JNN((* -K#r&   c                    < V ^8  d   QhRS[ /# r9   r   )r!   r"   s   "r#   r$   r%   n   s     	( 	(I 	(r&   c                  "   V P                   '       gk   V P                  '       gY   V P                  '       d   Q hV P                  P	                  4       V n         V P                  G R j  xL
  V P                  4       # V P                  4       #  L$  \
        P                  \
        P                  3 d
    R T n        h i ; i5ir<   )	r0   r-   r.   r,   create_futurer   CancelledErrorTimeoutError_read_from_bufferr=   s   &r#   readWebSocketDataQueue.readn   s     |||DIII|||##::335DLll"" %%''t%%''	 #**G,@,@A #s9   $CC!CB *B+B / CB .B??Cc                    < V ^8  d   QhRS[ /# r9   rd   )r!   r"   s   "r#   r$   r%   y   s     	 	9 	r&   c                b   V P                   '       d   V P                  4       w  rV ;P                  V,          un        V P                  V P                  8  d7   V P                  P
                  '       d   V P                  P                  4        V# V P                  e   V P                  h\        hr<   )	r0   r2   r)   r+   r*   r^   resume_readingr/   r   r`   s   &  r#   ri   $WebSocketDataQueue._read_from_buffery   sv    <<<))+JDJJ$JzzDKK'DNN,J,J,J--/K??&//!r&   )
r0   r-   r/   r2   r+   r,   r*   r4   r)   r.   N)__name__
__module____qualname____firstlineno____doc__r6   r>   rC   r   r   rS   rW   ra   rj   ri   __static_attributes____classdictcell__r"   s   @r#   r   r   6   si     
/ /   -:	2 	2$ $ 
+ +	( 	(	 	r&   r   c                   ~   a  ] tR t^t o RV 3R lR lltV 3R lR ltV 3R lR ltV 3R lR ltV 3R	 lR
 ltRt	V t
R# )WebSocketReaderc                0   < V ^8  d   QhRS[ RS[RS[RR/# )r   queuemax_msg_sizecompressr   N)r   r   r:   )r!   r"   s   "r#   r$   WebSocketReader.__annotate__   s-     " "'"7:"FJ"	"r&   c                ,   Wn         W n        R V n        \        4       V n        \
        V n        \        V n        RV n	        \        V n
        . V n        ^ V n        RV n        RV n        R V n        ^ V n        ^ V n        \$        V n        R V n        W0n        R # )NFr&   )r{   _max_msg_size_exc	bytearray_partialREAD_HEADER_stateOP_CODE_NOT_SET_opcode
_frame_fin_frame_opcode_payload_fragments_frame_payload_len_tail	_has_mask_frame_mask_payload_bytes_to_read_payload_len_flagCOMPRESSED_NOT_SET_compressed_decompressobj	_compress)r5   r{   r|   r}   s   &&&&r#   r6   WebSocketReader.__init__   s     
))-	!!+"1/1"#
,0&'#!" 2:>!r&   c                   < V ^8  d   QhRR/# rN   rO   )r!   r"   s   "r#   r$   r~      s      $ r&   c                :    V P                   P                  4        R # r<   )r{   rW   r=   s   &r#   rW   WebSocketReader.feed_eof   s    

r&   c                V   < V ^8  d   QhRS[ S[S[S[3,          RS[S[S[3,          /# )r   rZ   r   )r   bytesr   
memoryviewr   r:   )r!   r"   s   "r#   r$   r~      s2      %J67	tU{	r&   c                   \        V4      \        Jd   \        V4      pV P                  e   RV3#  V P                  V4       \        #   \         d-   pY n        \        T P                  T4       \        u R p?# R p?ii ; i)NT)	typer   r   
_feed_data	Exceptionr   r{   EMPTY_FRAME_ERROREMPTY_FRAME)r5   rZ   rF   s   && r#   ra   WebSocketReader.feed_data   sq     :U";D99 :	%OOD!   	%I$**c*$$	%s   A	 	B !A;5B ;B c          
      x   < V ^8  d   QhRS[ RS[S[S[3,          RS[S[S[3,          RS[S[S[3,          RR/# )r   finopcodepayload
compressedr   N)r:   r   r   r\   r   r   )r!   r"   s   "r#   r$   r~      s`     K KK c:o&K ui'(	K
 #z/*K 
Kr&   c           	     B   V\         \        \        09   Edb   V\        8X  d0   V P                  \        8X  d   \        \        P                  R 4      hV'       g   V\        8w  d   W n        V ;P                  V,          un        V P                  '       db   \        V P                  4      V P                  8  d>   \        \        P                  R\        V P                  4       RV P                   24      hR# \        V P                  4      pV\        8X  d   V P                  p\        V n        M&V'       d   \        \        P                  RV: 24      hV'       d/   V P                  V,           pV P                  P                  4        MTpV P                  '       dN   \        V4      V P                  8  d4   \        \        P                  R\        V4       RV P                   24      hV'       d   V P                  '       g   \        RR7      V n        V P                  P!                  V\"        ,           V P                  '       d   V P                  ^,           MV P                  4      pV P                  '       dB   \        V4      V P                  8  d(   \        \        P                  RV P                   24      hM!\%        V4      \&        J d   TpM\'        V4      pV\         8X  dO    VP)                  R4      pT P.                  P1                  \3        \4        \6        TR
34      \        T4      4       R# V P.                  P1                  \3        \4        \8        VR
34      \        V4      4       R# V\:        8X  d   \        V4      ^8  d   \=        VR,          4      ^ ,          p
V
R8  d)   V
\>        9  d   \        \        P                  RV
 24      h VR,          P)                  R4      p\3        \4        \@        PB                  Y34      pMMV'       d%   \        \        P                  RV RV RV: 24      h\3        \4        \@        PB                  ^ R
34      pV P.                  P1                  V^ 4       R# V\D        8X  dI   \3        \4        \@        PF                  VR
34      pV P.                  P1                  V\        V4      4       R# V\H        8X  dI   \3        \4        \@        PJ                  VR
34      pV P.                  P1                  V\        V4      4       R# \        \        P                  RV: 24      h  \*         d!   p	\        \        P,                  R	4      T	hRp	?	ii ; i  \*         d!   p	\        \        P,                  R	4      T	hRp	?	ii ; i)z*Continuation frame for non started messagezMessage size z exceeds limit Nz8The opcode in non-fin frame is expected to be zero, got T)suppress_deflate_headerz(Decompressed message exceeds size limit zutf-8zInvalid UTF-8 text message :Nr   Ni  zInvalid close code: :r   NNzInvalid close frame:  zUnexpected opcode=)&OP_CODE_TEXTOP_CODE_BINARYOP_CODE_CONTINUATIONr   r   r   r   PROTOCOL_ERRORr   r   lenMESSAGE_TOO_BIGr:   clearr   r
   decompress_syncr   r   r   decodeUnicodeDecodeErrorINVALID_TEXTr{   ra   	TUPLE_NEWr   WS_MSG_TYPE_TEXTWS_MSG_TYPE_BINARYOP_CODE_CLOSEr   ALLOWED_CLOSE_CODESr   CLOSEOP_CODE_PINGPINGOP_CODE_PONGPONG)r5   r   r   r   r   has_partialassembled_payloadpayload_mergedtextrF   
close_codeclose_messagemsgs   &&&&&        r#   _handle_frameWebSocketReader._handle_frame   s    lN4HII--$,,/2Q$..@  11#)L(%%%#dmm*<@R@R*R(#33'DMM(:'; <))-););(<> 
 t}}-K--. $..''-j2  $(MMG$;!##%$+!!!!c*;&<@R@R&R$//#C(9$:#; <%%)%7%7$8:  ****:SW*XD' "&!4!4!D!D%(;;  --- **Q.!//" %%%#n*=@R@R*R(#33B4CUCUBVW  '(E1!2!&'8!9%)009D 

$$i*:D")EF'
 

$$i*<nb)QR' }$7|q .wr{;A>
$;N)N(#22.zl; $+BK$6$6w$?M
  	IOOZ+WX$..+C5&7+F 
  	IOOQ+CDJJ  a(|#I	'DECJJ  c'l3|#I	'DECJJ  c'l3 **.@
,K c * (#002N8 * (#002Ns0   0U U3 U0U++U03V>VVc                $   < V ^8  d   QhRS[ RR/# )r   rZ   r   N)r   )r!   r"   s   "r#   r$   r~   D  s#     ZT ZTu ZT ZTr&   c                
   V P                   '       d   V P                   V,           Ruqn         ^ p\        V4      pTp V P                  \        8X  Ed   W2,
          ^8  d   EMWB,          pWB^,           ,          pV^,          pV^,	          ^,          pV^,	          ^,          pV^,	          ^,          p	V^,	          ^,          p
V^,          pV	'       g#   V
'       g   V'       d-   V P                  '       g   \        \        P                  R4      hV^8  d"   V^ 8X  d   \        \        P                  R4      hV^,	          ^,          pV^,          pV^8  d"   V^}8  d   \        \        P                  R4      hV P                  '       g   V P                  \        8X  d   V'       d   \        M\        V n	        M"V'       d   \        \        P                  R4      h\        V4      V n        Wn        \        V4      V n        Wn        \"        V n        V P                  \"        8X  d   V P                   pV^~8X  dF   W2,
          ^8  d   EM
WB,          pWB^,           ,          pV^,          pV^,          V,          V n        M=V^~8  d1   W2,
          ^8  d   EM\'        W4      ^ ,          V n        V^,          pMWn        V P                  '       d   \(        M\*        V n        V P                  \(        8X  d4   W2,
          ^8  d   EMPWBV^,            V n        V^,          p\*        V n        V P                  \*        8X  g   EK  W2,
          pV P$                  V8  d   TpV ;P$                  V,          un        MW P$                  ,           p^ V n        V P.                  pV ;P.                  VV,
          ,          un        TpTpV P$                  ^ 8w  d!   V P0                  P3                  VVV 4       EMeV'       d   V P0                  P3                  VVV 4       V P                  '       dN   V P,                  f   Q h\5        RP7                  V P0                  4      4      p\9        V P,                  V4       TpMRP7                  V P0                  4      pV P0                  P;                  4        McV P                  '       dM   V P,                  f   Q hVVV p\=        V4      \4        Jd   \5        V4      p\9        V P,                  V4       TpMVVV pV P?                  V P                  V P                  VV P                  4       ^ V n        \        V n        EK  W#8  d   WBV V n         R# RV n         R# )z&Return the next frame from the socket.r&   z*Received frame with non-zero reserved bitsz!Received fragmented control framez5Control frame payload cannot be larger than 125 bytesN) r   r   r   r   r   r   r   r   r   r   r   COMPRESSED_TRUECOMPRESSED_FALSEr:   r   r   r   READ_PAYLOAD_LENGTHr   r   READ_PAYLOAD_MASKREAD_PAYLOADr   r   r   r3   r   joinr   r   r   r   )r5   rZ   	start_posdata_len	data_cstr
first_bytesecond_byter   rsv1rsv2rsv3r   has_masklengthlen_flag	chunk_len	f_end_poshad_fragmentsf_start_pospayload_bytearrayr   s   &&                   r#   r   WebSocketReader._feed_dataD  s   :::#zzD0#D*	t9	{{k)'!+&1
'A6Q	!Q!+"a1,"a1,"a1,#c) 4D(#22D 
 C<C1H(#22; 
 (1,1$t+ C<FSL(#22O  ???d&6&6:L&L:>DTD$(#22D 
 #'s)%+"!%h)/&1 {{1111s?+a/!*!5J"+M":KNI2</K2OD/^+a/2=d2Nq2QD/NI2:/37>>>/| {{//'!+#,Q#G Q	*{{l*$0	..); (I//9</ ),G,G GI23D/ $ 7 7''9y+@@''%	..!3 ++229[3ST !++229[3ST~~~#//;;;,5chht?V?V6W,X)&t'7'79JK"3"%((4+B+B"C++113^^^++777(1+i(H%-.i? -66G,H)"4#3#35FG/G'I>G""OOT%7%7$BRBR +,') 7@6JY2
PS
r&   )r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r{   N)T)rp   rq   rr   rs   r6   rW   ra   r   r   ru   rv   rw   s   @r#   ry   ry      s>     " "2  $K KZZT ZTr&   ry   c                l    V ^8  d   Qh/ ^ \         9   d    \        \        \        ,          ,          ;R&   # )r   r   )__conditional_annotations__r   r   r   )r!   s   "r#   r$   r$      s#     6 6( E DU3s8_ D) 7r&   )Tr&   )Fr&   )Ar   rt   r   rH   collectionsr   typingr   r   r   r   r   r   base_protocolr	   compression_utilsr
   helpersr   r   streamsr   r   r   r   modelsr   r   r   r   r   r   r   r   r   r   r   BINARYr   TEXTr   r   CONTINUATIONvaluer   r   r   r   r   r   r   r   r   r   r   r   r   r   tuple__new__r   r\   r   ry   r$   )ir   s   0@r#   <module>r      s3   6    < < ( 0 2  C C  9D'D1A'D  D   %% >>   --33 ~~##!!''%%~~##~~##   MM	
L L^YT YTa (Es   E	