a `g@sUdZddlZddlZddlmZddlmZmZmZm Z m Z m Z ddl m Z ddlmZed jZed jZed jZed jZed jZed jZedjZdZeeed<dZeeed<dZeeed<ej eedddZ!ee"ddddZ#ese r e#Z$n.zddl%m&Z&e&Z$Wne'y8e#Z$Yn0e(dZ)ee e*ed<e(dZ+ee e*ed<d(e e*e,e ee,fd!d"d#Z-d)ee,e,e*d%d&d'Z.dS)*z1Helpers for WebSocket protocol versions 13 and 8.N)Struct) TYPE_CHECKINGFinalListOptionalPatternTuple) NO_EXTENSIONS)WSHandshakeErrorz!Qz!Hz!BBz!BBHz!BBQz!Li@MSG_SIZEMASK_LENs$258EAFA5-E914-47DA-95CA-C5AB0DC85B11WS_KEY)returncCsddtdDS)Ncs&g|]tfddtdDqS)c3s|]}|AVqdSN).0abrh/var/www/html/cobodadashboardai.evdpl.com/venv/lib/python3.9/site-packages/aiohttp/_websocket/helpers.py z(_xor_table...)bytesrange)rrrr rz_xor_table..r)rrrrr _xor_tablesr)maskdatarcst|tsJ|t|dks&J||rtfdd|D\}}}}|ddd||ddd<|ddd||ddd<|ddd||ddd<|ddd||ddd<dS)awWebsocket 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. rc3s|]}|VqdSrr)rnZ _XOR_TABLErrr0rz)_websocket_mask_python..Nr r ) isinstance bytearraylenr translate)r r!rrcdrr#r_websocket_mask_pythons r+)_websocket_mask_cythonz^(?:;\s*(?:(server_no_context_takeover)|(client_no_context_takeover)|(server_max_window_bits(?:=(\d+))?)|(client_max_window_bits(?:=(\d+))?)))*$ _WS_EXT_REzpermessage-deflate([^,]+)?_WS_EXT_RE_SPLITF)extstrisserverrcCs|sdSd}d}t|D]}|d}|s4d}qt|}|rd}|r|drxt|d}|dksr|dkrxd}q|drd}qq|d rt|d }|dks|dkrtd |d rd}qq|std |dq||fS) N)rFrFr r TzInvalid window sizer z#Extension for deflate not supported)r.finditergroupr-matchintr )r/r0compressZ notakeoverextZdefextr6rrr ws_ext_parseMs>      r:r1)r8r0server_notakeoverrcCs^|dks|dkrtddg}|s,|d|dkrF|dt||rT|dd|S) Nr2r1zCCompress wbits must between 9 and 15, zlib does not support wbits=8zpermessage-deflateZclient_max_window_bitszserver_max_window_bits=Zserver_no_context_takeoverz; ) ValueErrorappendstrjoin)r8r0r;Z enabledextrrr ws_ext_gens  r@)F)r1FF)/__doc__ functoolsrestructrtypingrrrrrrhelpersr modelsr unpack_fromZ UNPACK_LEN3unpackZUNPACK_CLOSE_CODEpackZ PACK_LEN1Z PACK_LEN2Z PACK_LEN3ZPACK_CLOSE_CODEZ PACK_RANDBITSr r7__annotations__rrr lru_cacherr&r+Zwebsocket_maskr r, ImportErrorcompiler-r>r.boolr:r@rrrrsH               4