o `g@sUdZddlZddlZddlZddlmZddlmZmZm Z m Z ddl m Z ddl mZddlmZd d lmZmZmZmZmZmZmZmZd d lmZmZd Zeeed <dZ GdddZ!dS)z%WebSocket protocol versions 13 and 8.N)partial)AnyFinalOptionalUnion) BaseProtocol)ClientConnectionResetError)ZLibCompressor)MASK_LENMSG_SIZEPACK_CLOSE_CODE PACK_LEN1 PACK_LEN2 PACK_LEN3 PACK_RANDBITSwebsocket_mask)WS_DEFLATE_TRAILING WSMsgType DEFAULT_LIMITic@seZdZdZdeeddddedej de de d ejd e d e d d fddZ dde de d ee d d fddZd e d efddZdde dee efd d fddZd S)WebSocketWritera3WebSocket writer. The writer is responsible for sending messages to the client. It is created by the protocol when a connection is established. The writer should avoid implementing any application logic and should only be concerned with the low-level details of the WebSocket protocol. Fr)use_masklimitrandomcompress notakeoverprotocol transportrrrrrreturnNcCsH||_||_||_t|jd|_||_||_d|_||_ d|_ d|_ dS)zInitialize a WebSocket writer. FrN) rrrr getrandbitsget_random_bitsrr_closing_limit _output_size _compressobj)selfrrrrrrrr)T/var/www/html/propose/venv/lib/python3.10/site-packages/aiohttp/_websocket/writer.py__init__-s  zWebSocketWriter.__init__messageopcodec s|jr |tj@s tdd}|s|jrF|dkrFd}|r"||}n |js,||j|_|j}||IdH||jr>t j nt j  t }t|}|j}|rQdnd}d|B|B} |dkrgt| ||B} d} n|d krvt| d|B|} d } n t| d |B|} d } |jrtd|rt|} t|}t| ||j| | ||jt7_n|tkr|j| |j|n|j| ||j| |7_|j|jkrd|_|jjr|j IdHdSdSdS) zs    (