+
    TŎi                       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4      P"                  t]! R4      P&                  t]! R4      P*                  t]! R	4      P*                  t]! R
4      P*                  t]! R4      P*                  t]! R4      P*                  tRt] ^ k ^t] ^k Rt] ^k ]P<                  R R l4       tR R lt ]'       g	   ]'       d   ] t!M	 ^RI"H#t# ]#t!]PJ                  ! R4      t&] ^k ]PJ                  ! R4      t'] ^k RR R llt(RR R llt)R#   ]$ d    ] t! LIi ; i)z1Helpers for WebSocket protocol versions 13 and 8.N)Struct)TYPE_CHECKINGFinalListOptionalPatternTuple)NO_EXTENSIONS)WSHandshakeErrorz!Qz!Hz!BBz!BBHz!BBQz!Ls$   258EAFA5-E914-47DA-95CA-C5AB0DC85B11c                :    V ^8  d   QhR\         \        ,          /# )   return)r   bytes)formats   "i/Users/ahmad/.openclaw/workspace/scripts/.venv/lib/python3.14/site-packages/aiohttp/_websocket/helpers.py__annotate__r      s     B BDK B    c            	      ~   a  \        R 4       U a u. uF!  o \        V 3R l\        R 4       4       4      NK#  	  up # u up i )   c              3   4   <"   T F  qS,          x  K  	  R # 5iN ).0abs   & r   	<genexpr>_xor_table.<locals>.<genexpr>   s     ,Aa%%s   )ranger   )r   s   `r   
_xor_tabler      s.    6;CjAjE,s,,jAAAs   ':c                4    V ^8  d   QhR\         R\        RR/# )r   maskdatar   N)r   	bytearray)r   s   "r   r   r      s!     - - -i -D -r   c                  a \        V\        4      '       g   Q V4       h\        V 4      ^8X  g   Q V 4       hV'       d   \        4       oV3R lV  4       w  r#rEVR,          P	                  V4      VR&   VR,          P	                  V4      VR&   VR,          P	                  V4      VR&   VR,          P	                  V4      VR&   R# R# )a[  Websocket masking function.

`mask` is a `bytes` object of length 4; `data` is a `bytearray`
object of any length. The contents of `data` are masked with `mask`,
as specified in section 5.3 of RFC 6455.

Note that this function mutates the `data` argument.

This pure-python implementation may be replaced by an optimized
version when available.

c              3   6   <"   T F  pSV,          x  K  	  R # 5ir   r   )r   n
_XOR_TABLEs   & r   r   )_websocket_mask_python.<locals>.<genexpr>0   s     2TjmmTs   :NN   :   Nr(   :r   Nr(   :   Nr(   N)
isinstancer"   lenr   	translate)r    r!   r   r   cdr&   s   &&    @r   _websocket_mask_pythonr0      s     dI&&,,&t9>4>\
2T2
aI''*S	$Z))!,T
$Z))!,T
$Z))!,T
 r   )_websocket_mask_cythonz^(?:;\s*(?:(server_no_context_takeover)|(client_no_context_takeover)|(server_max_window_bits(?:=(\d+))?)|(client_max_window_bits(?:=(\d+))?)))*$zpermessage-deflate([^,]+)?c                t    V ^8  d   QhR\         \        ,          R\        R\        \        \        3,          /# )r   extstrisserverr   )r   strboolr   int)r   s   "r   r   r   M   s.     0  0 # 0 $ 0 5dCS 0 r   c                    V '       g   R# ^ pRp\         P                  V 4       EF:  pVP                  ^4      pV'       g   ^p W#3# \        P	                  V4      pV'       d   ^pV'       da   VP                  ^4      '       d-   \        VP                  ^4      4      pV^8  g   V^	8  d   ^ pK  VP                  ^4      '       d   Rp W#3# VP                  ^4      '       d4   \        VP                  ^4      4      pV^8  g   V^	8  d   \        R4      hVP                  ^4      '       d   Rp W#3# V'       d   EK  \        RVP                  ^4      ,           4      h	  W#3# )    FTzInvalid window sizez#Extension for deflate not supported)r9   F)_WS_EXT_RE_SPLITfinditergroup
_WS_EXT_REmatchr7   r
   )r3   r4   compress
notakeoverextdefextr>   s   &&     r   ws_ext_parserC   M   sM   HJ((01HJ I   (H ;;q>>"5;;q>2H
  "}1#$ ;;q>>!%J$ ! ;;q>>"5;;q>2H
  "}1./DEE;;q>>!%J
  "#H399UV<#WXXQ 1T r   c                H    V ^8  d   QhR\         R\        R\        R\        /# )r   r?   r4   server_notakeoverr   )r7   r6   r5   )r   s   "r   r   r      s,     ! !!"&!CG!!r   c                    V ^	8  g   V ^8  d   \        R4      hR.pV'       g   VP                  R4       V ^8  d"   VP                  R\        V 4      ,           4       V'       d   VP                  R4       RP                  V4      # )	   zCCompress wbits must between 9 and 15, zlib does not support wbits=8zpermessage-deflateclient_max_window_bitszserver_max_window_bits=server_no_context_takeoverz; )
ValueErrorappendr5   join)r?   r4   rE   
enabledexts   &&& r   
ws_ext_genrN      s    
 !|x"}Q
 	
 ''J23"}3c(mCD67 99Z  r   c                z   V ^8  d   Qh/ ^ \         9   d   \        \        ,          ;R&   ^\         9   d   \        \        ,          ;R&   ^\         9   d   \        \        ,          ;R&   ^\         9   d    \        \        \
        ,          ,          ;R&   ^\         9   d    \        \        \
        ,          ,          ;R&   # )r   MSG_SIZEMASK_LENWS_KEYr=   r:   )__conditional_annotations__r   r7   r   r   r5   )r   s   "r   r   r      s     7 7"  %* # 8$  %* % 8( ? >e >) 8B E'#, C 8R R Q%% QS 8r   i @  )F)   FF)+rS   __doc__	functoolsrestructr   typingr   r   r   r   r   r   helpersr	   modelsr
   unpack_fromUNPACK_LEN3unpackUNPACK_CLOSE_CODEpack	PACK_LEN1	PACK_LEN2	PACK_LEN3PACK_CLOSE_CODEPACK_RANDBITSrP   rQ   rR   	lru_cacher   r0   websocket_maskr    r1   ImportErrorcompiler=   r:   rC   rN   r   )rS   s   @r   <module>rj      s0   7  	  G G # $Tl&&4L'' 5M	6N	6N	,##t!!  > > B B-2 M+N00/
 #%**/#
  )+

3P(Q  Q0 f! !E  0/0s   2D8 8	EE