U.jddlmZddlZddlmZmZddlmZmZm Z ddl m Z m Z ddl mZmZddl mZdd lmZ dd lmZGd d e Zdd ZddZeZddl mZddZddZy#e$r dd lmZY1wxYw)) annotationsN) AwaitableSequence)AnyCallable NamedTuple) extensionsframes) PayloadTooBig ProtocolError) BytesLike)Data) apply_maskceZdZUded<ded<ded<dZded<dZded <dZded <edd Zdd Z dd Z e ddd ddZ dd ddZ y)Frameboolfinz frames.OpcodeopcodebytesdataFrsv1rsv2rsv3ctj|j|j|j|j |j |jSN)r rrrrrrrselfs [C:\xampp\htdocs\tradingbinance\backend\.venv\Lib\site-packages\websockets/legacy/framing.py new_framezFrame.new_frames=|| KK II HH II II II   c,t|jSr)strr rs r__str__z Frame.__str__&s4>>""r!c6|jjSr)r checkrs rr&z Frame.check)s~~##%%r!N)max_sizer cK|dd{}tjd|\}}|dzrdnd}|dzrdnd} |dzrdnd} |d zrdnd} tj|d z} |dzrdnd|k7r t d |d z}|dk(r)|dd{}tjd|\}n-|d k(r(|dd{}tjd|\}|||kDr t |||r|dd{}||d{}|r t|}tj| ||| | | }|g}t|D]}|j||}|j||j|j|j|j|j |j"S7#t$r} t d | d} ~ wwxYw7H777ԭw)a@ Read a WebSocket frame. Args: reader: Coroutine that reads exactly the requested number of bytes, unless the end of file is reached. mask: Whether the frame should be masked i.e. whether the read happens on the server side. max_size: Maximum payload size in bytes. extensions: List of extensions, applied in reverse order. Raises: PayloadTooBig: If the frame exceeds ``max_size``. ProtocolError: If the frame contains incorrect values. r Nz!BBTF@ zinvalid opcodezincorrect masking~z!Hz!Q)r')structunpackr Opcode ValueErrorr r rrreverseddecoder&rrrrrr)clsreadermaskr'r rhead1head2rrrrrexclength mask_bitsr extensions rreadz Frame.read,s6AY}}UD1 uj(dez)tuz)tuz)tu ;]]5:#56FJ&DEd : 34 4# S=?D dD1IV s]?D dD1IV  FX$51 1 $QiIF^# dI.DLLsD$E  J!*-I!((X(FI.  MM    NN NN NN NN   W ; 01s : ;## ($sw G'F=AG'G),G'G-G'G rmsn" /,,!5#% @JJ@JF:0:0  $ +[#"#sA$$ A21A2