&th0ddlmZddlZddlZddlZddlZddlZddlmZm Z m Z m Z m Z ddl mZmZddlmZ ddlmZn#e$r ddlmZYnwxYwgdZGd d ejZejZejZejZejZej Z!ej"Z#eeefZ$ee!e#fZ%d d d dddddddddddddZ&hdZ'ddhZ(e)e*e+fZ,ej-GddZ.d)d$Z/d*d&Z0ej-Gd'd(Z1dS)+) annotationsN)Callable GeneratorOptionalSequenceTuple) exceptions extensions)Data) apply_mask) OpcodeOP_CONTOP_TEXT OP_BINARYOP_CLOSEOP_PINGOP_PONG DATA_OPCODES CTRL_OPCODESFrame prepare_data prepare_ctrlClosec*eZdZdZd\ZZZd\ZZZ dS)rz#Opcode values for WebSocket frames.)rr ) N) __name__ __module__ __qualname____doc__CONTTEXTBINARYCLOSEPINGPONGe/var/www/html/mycamper/aliexpress-site/backend/venv/lib/python3.11/site-packages/websockets/frames.pyrr%s,--)D$(E4r+rOKz going awayzprotocol errorzunsupported typezno status code [internal]z'connection closed abnormally [internal]z invalid datazpolicy violationzmessage too bigzextension requiredzunexpected errorzservice restartztry again laterz bad gatewayzTLS failure [internal])ii> r.r/r0r1r3r4r5r6r7r8r9r:r.r/ceZdZUdZded<ded<dZded<d Zded <d Zded <d Zded <ddZ e dddd dZ ddd!dZ d"dZ dS)#raN WebSocket frame. Attributes: opcode: Opcode. data: Payload data. fin: FIN bit. rsv1: RSV1 bit. rsv2: RSV2 bit. rsv3: RSV3 bit. Only these fields are needed. The MASK bit, payload length and masking-key are handled on the fly when parsing and serializing frames. ropcodebytesdataTboolfinFrsv1rsv2rsv3returnstrcjd}t|jdt|jdkrdnd}|jrdnd}|jtur(t |j}nX|jturb|j}t|dkr(d|dd d |d dg}d d |D}n|jtur-tt |j}n|jr t |j}d}n|#ttf$rf|j}t|dkr(d|dd d |d dg}d d|D}d}YnwxYwd}t|dkr|dddz|ddz}dtd|||g}|jjd |d|dS)zC Return a human-readable represention of a frame. Nz byter s continuedr+si c3K|]}|dV dS02xNr*.0bytes r, z Frame.__str__..s&==dtMM======r+textc3K|]}|dV dSrNr*rPs r,rSz Frame.__str__..s&AA$4 AAAAAAr+binaryz''K0z...iz, z [])lenr>r@r<rreprdecoderjoinrrErparseUnicodeDecodeErrorAttributeErrorfiltername)selfcodinglength non_finalr>rVmetadatas r,__str__z Frame.__str__|sF  NNMMs49~~/B/BMM(3BB ;' ! ! ((**++DD [I % %YF6{{R6#2#; VBCC["IJJ88==f=====DD [H $ $u{{49--..DD Y   "DI,,..//&7 " " "v;;## XXvcrc{K&MNNFxxAA&AAAAA!  "D t99r>>9u$tCDDz1D99VD669*EFFGG+"88T88X8888s*(EA4G  G N)max_sizer read_exact-Callable[[int], Generator[None, None, bytes]]maskri Optional[int]r (Optional[Sequence[extensions.Extension]]Generator[None, None, Frame]c#tK|dEd{V}tjd|\}}|dzrdnd}|dzrdnd} |dzrdnd} |d zrdnd} t|d z} n'#t$r} t jd | d} ~ wwxYw|dzrdnd|krt jd |d z}|dkr)|dEd{V}tjd|\}n.|d kr(|dEd{V}tjd|\}|!||krt jd|d|d|r|dEd{V}||Ed{V}|rt||}|| ||| | | }|g}t|D]}| ||}| |S)a& Parse a WebSocket frame. This is a generator-based coroutine. Args: read_exact: generator-based coroutine that reads the requested bytes or raises an exception if there isn't enough data. 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: EOFError: if the connection is closed without a full WebSocket frame. UnicodeDecodeError: if the frame contains invalid UTF-8. PayloadTooBig: if the frame's payload size exceeds ``max_size``. ProtocolError: if the frame contains incorrect values. rN!BBTF@ rKzinvalid opcodezincorrect masking~!Hrz!Qzover size limit (z > z bytes))ri) structunpackr ValueErrorr ProtocolError PayloadTooBigr reversedr\check)clsrjrlrir r>head1head2r@rArBrCr<excre mask_bytesframe extensions r,r^z Frame.parses<%*Q--''''''}UD11 uj(3ddez)4ttuz)4ttuz)4ttu FEJ.//FF F F F*+;<<# E FJ& 1DDEd : :*+>?? ?# S==(jmm++++++D dD11IVV s]](jmm++++++D dD11IV  FX$5$5*@F@@x@@@   2$.JqMM111111J%*V,,,,,,,,  0dJ//DFD#tT488  J!*-- ? ?I$$UX$>>EE  sA$$ B.BB)r c<||g}|D]}||}tj}|jrdnd|jrdndz|jrdndz|jrdndz|jz}|rdnd}t|j }|dkr-| tj d|||zna|d kr.| tj d ||dz|n-| tj d ||d z||r)tjd }| ||rt!|j |} n|j } | | |S)aH Serialize a WebSocket frame. Args: mask: whether the frame should be masked i.e. whether the write happens on the client side. extensions: list of extensions, applied in order. Raises: ProtocolError: if the frame contains incorrect values. NrrrrsrtrKrwrqiz!BBHz!BBQrvry)rencodeioBytesIOr@rArBrCr<rZr>writerzpacksecrets token_bytesr getvalue) rcrlr routputrrrerr>s r, serializezFrame.serializes$  J# * *I##D))DD 8 *ZZ!Y-zzA /!Y-zzA /"Y-zzA /k   #) TY C<< LLUE56>BB C C C C e^^ LLVUECKHH I I I I LLVUECKHH I I I  % ,Q//J LL $ $ $  di44DD9D T   r+Nonec|js|js|jrtjd|jt vrGt|jdkrtjd|j stjddSdS)z Check that reserved bits and opcode have acceptable values. Raises: ProtocolError: if a reserved bit or the opcode is invalid. zreserved bits must be 0}zcontrol frame too longzfragmented control frameN) rArBrCr r}r<rrZr>r@rcs r,rz Frame.check3s 9 F  FTY F*+DEE E ;, & &49~~## ./GHHH8 K ./IJJJ ' & K Kr+rDrE) rjrkrlr?rirmr rnrDro)rlr?r rnrDr=rDr)r r!r"r#__annotations__r@rArBrCrh classmethodr^rrr*r+r,rrcs NNNKKKCDDD-9-9-9-9^ #'?C JJJJJ[J`@D 9!9!9!9!9!9!vKKKKKKr+rr>r rDTuple[int, bytes]ct|trt|dfSt|tr t |fSt d)a Convert a string or byte-like object to an opcode and a bytes-like object. This function is designed for data frames. If ``data`` is a :class:`str`, return ``OP_TEXT`` and a :class:`bytes` object encoding ``data`` in UTF-8. If ``data`` is a bytes-like object, return ``OP_BINARY`` and a bytes-like object. Raises: TypeError: if ``data`` doesn't have a supported type. utf-8data must be str or bytes-like) isinstancerErr BytesLiker TypeErrorr>s r,rrEsX $: G,,,, D) $ $:$8999r+r=ct|tr|dSt|trt |St d)ai Convert a string or byte-like object to bytes. This function is designed for ping and pong frames. If ``data`` is a :class:`str`, return a :class:`bytes` object encoding ``data`` in UTF-8. If ``data`` is a bytes-like object, return a :class:`bytes` object. Raises: TypeError: if ``data`` doesn't have a supported type. rr)rrErrr=rrs r,rr]sU$:{{7### D) $ $:T{{8999r+cXeZdZUdZded<ded<ddZedd Zdd Zdd Z dS)rz Code and reason for WebSocket close frames. Attributes: code: Close code. reason: Close reason. intcoderEreasonrDcd|jcxkrdkrnnd}n8d|jcxkrdkrnnd}n t|jd}|jd|d}|jr |d |j}|S) zS Return a human-readable represention of a close code and reason. i registeredz private useunknownz ()rL)r CLOSE_CODESgetr)rc explanationresults r,rhz Close.__str__s 49 # # # #t # # # # #&KK TY % % % % % % % % %'KK%//$)Y??KI///// ; /....F r+r>r=cJt|dkr^tjd|dd\}|ddd}|||}||St|dkr |ddSt jd) z Parse the payload of a close frame. Args: data: payload of the close frame. Raises: ProtocolError: if data is ill-formed. UnicodeDecodeError: if the reason isn't valid UTF-8. rrxNrrr2rGzclose frame too short)rZrzr{r\rr r})rr>rrcloses r,r^z Close.parses t99>>mD$rr(33GT!""X__W--FCf%%E KKMMML YY!^^3tR== *+BCC Cr+c|tjd|j|jdzS)z: Serialize the payload of a close frame. rxr)rrzrrrrrs r,rzClose.serializes: {4++dk.@.@.I.IIIr+rcv|jtvs(d|jcxkrdksntjddSdS)z Check that the close code has a valid value for a close frame. Raises: ProtocolError: if the close code is invalid. rrzinvalid status codeN)rEXTERNAL_CLOSE_CODESr r}rs r,rz Close.checksR 111TTY5M5M5M5M5M5M5M5M*+@AA A215M5Mr+Nr)r>r=rDr)rDr=r) r r!r"r#rrhrr^rrr*r+r,rrtsIIIKKK$DDD[D.JJJJ B B B B B Br+r)r>r rDr)r>r rDr=)2 __future__r dataclassesenumrrrztypingrrrrrrGr r r speedupsr ImportErrorutils__all__IntEnumrr$rr%rr&rr'rr(rr)rrrrrOK_CLOSE_CODESr= bytearray memoryviewr dataclassrrrrr*r+r,rs""""""  AAAAAAAAAAAAAA$$$$$$$$"$$$$$$$"""!!!!!!!!"   ")))))T\))) + + M < + +* ')     % 3         "! ,    9j (  ^K^K^K^K^K^K^K^KB::::0::::. HBHBHBHBHBHBHBHBHBHBs? A  A