o 4j @sUdZddlZddlZddlmZddlmZddlmZmZddl m Z dd l m Z ed j Zed jZed jZed jZedjZed jZedjZdZeeed<dZeeed<dZeeed<ejdeefddZdede ddfddZ!ese re!Z"nz ddl#m$Z$e$Z"Wn e%ye!Z"Ynwe&dZ'eee(ed<e&d Z)eee(ed!<d,d#e(dBd$e*de+ee*ffd%d&Z, "d-d(ed$e*d)e*de(fd*d+Z-dS).z1Helpers for WebSocket protocol versions 13 and 8.N)Pattern)Struct) TYPE_CHECKINGFinal) NO_EXTENSIONS)WSHandshakeErrorz!Qz!Hz!BBz!BBHz!BBQz!Li@MSG_SIZEMASK_LENs$258EAFA5-E914-47DA-95CA-C5AB0DC85B11WS_KEYreturncCsddtdDS)Ncs&g|]tfddtdDqS)c3s|]}|AVqdSN).0abrW/var/www/kodo/Anonymous/send/lib/python3.10/site-packages/aiohttp/_websocket/helpers.py z(_xor_table...)bytesrange)rrrr s&z_xor_table..r)rrrrr _xor_tablesrmaskdatacst|ts J|t|dksJ||rctfdd|D\}}}}|ddd||ddd<|ddd||ddd<|ddd||ddd<|ddd||ddd<dSdS)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. r c3s|]}|VqdSrr)rn _XOR_TABLErrr1rz)_websocket_mask_python..Nrr) isinstance bytearraylenr translate)rrrrcdrr 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_SPLITFextstrisservercCs|sdSd}d}t|D]m}|d}|sd}||fSt|}|rod}|rK|dr?t|d}|dks<|dkr?d}q |drFd}||fS|d rct|d }|dks_|dkrctd |d rjd}||fS|sztd |dq ||fS) N)rFrFrr TzInvalid window sizerz#Extension for deflate not supported)r,finditergroupr+matchintr )r-r.compress notakeoverextdefextr4rrr ws_ext_parseNsF %     r:r/r6server_notakeovercCs^|dks|dkr tddg}|s|d|dkr#|dt||r*|dd|S) Nr0r/zCCompress wbits must between 9 and 15, zlib does not support wbits=8zpermessage-deflateclient_max_window_bitszserver_max_window_bits=server_no_context_takeoverz; ) ValueErrorappendstrjoin)r6r.r; enabledextrrr ws_ext_gens   rC)F)r/FF).__doc__ functoolsrerstructrtypingrrhelpersrmodelsr unpack_from UNPACK_LEN3unpackUNPACK_CLOSE_CODEpack PACK_LEN1 PACK_LEN2 PACK_LEN3PACK_CLOSE_CODE PACK_RANDBITSr r5__annotations__r r r lru_cachelistrr$r)websocket_maskrr* ImportErrorcompiler+r@r,booltupler:rCrrrrsX             $4