i5UddlmZddlZddlZddlZddlZddlZddlmZm Z m Z m Z m Z ddl mZmZddlmZ ddlmZn#e$r ddlmZYnwxYwgdZGd d ejZejZejZejZejZej Z!ej"Z#eeefZ$ee!e#fZ%Gd d ejZ&e&j'd e&j(de&j)de&j*de&j+de&j,de&j-de&j.de&j/de&j0de&j1de&j2de&j3de&j4de&j5diZ6de7d<e&j'e&j(e&j)e&j*e&j-e&j.e&j/e&j0e&j1e&j2e&j3e&j4h Z8e&j'e&j(e&j+hZ9e:e;eGddZ?d)d$Z@d*d&ZAej>Gd'd(ZBdS)+) 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__CONTTEXTBINARYCLOSEPINGPONGW/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/websockets/frames.pyrr%s,--)D$(E4r+rcNeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdS) CloseCodez-Close code values for WebSocket close frames.iiiiiiiiiiiiiiiN)r r!r"r#NORMAL_CLOSURE GOING_AWAYPROTOCOL_ERRORUNSUPPORTED_DATANO_STATUS_RCVDABNORMAL_CLOSURE INVALID_DATAPOLICY_VIOLATIONMESSAGE_TOO_BIGMANDATORY_EXTENSIONINTERNAL_ERRORSERVICE_RESTARTTRY_AGAIN_LATER BAD_GATEWAY TLS_HANDSHAKEr*r+r,r.r.7sc77NJNNLONOOKMMMr+r.OKz going awayzprotocol errorzunsupported datazno status received [internal]zabnormal closure [internal]zinvalid frame payload datazpolicy violationzmessage too bigzmandatory extensionzinternal errorzservice restartztry again laterz bad gatewayz TLS handshake failure [internal]zdict[int, str]CLOSE_CODE_EXPLANATIONSceZdZUdZded<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)zE Return a human-readable representation of a frame. Nz byter s continuedr+si c3K|]}|dV dS02xNr*.0bytes r, z Frame.__str__..s&==dtMM======r+textc3K|]}|dV dSrSr*rUs r,rXz Frame.__str__..s&AA$4 AAAAAAr+binaryz''K0z...iz, z [])lenrCrErArreprdecoderjoinrrJrparseUnicodeDecodeErrorAttributeErrorfiltername)selfcodinglength non_finalrCr[metadatas 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]]maskrn 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@ rPzinvalid opcodezincorrect masking~!Hrz!Qzover size limit (z > z bytes))rn) structunpackr ValueErrorr ProtocolError PayloadTooBigr reversedracheck)clsrorqrnr rChead1head2rErFrGrHrAexcrj mask_bytesframe extensions r,rcz 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. NrwrrxryrPr|rviz!BBHz!BBQr{r~)rencodeioBytesIOrErFrGrHrAr_rCwriterpacksecrets token_bytesr getvalue) rhrqr routputrrrjrrCs 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) rFrGrHr rrArr_rCrErhs r,rz Frame.checkLs 9 F  FTY F*+DEE E ;, & &49~~## ./GHHH8 K ./IJJJ ' & K Kr+rIrJ) rorprqrDrnrrr rsrIrt)rqrDr rsrIrBrIr)r r!r"r#__annotations__rErFrGrHrm classmethodrcrrr*r+r,rr|s NNNKKKCDDD-9-9-9-9^ #'?C JJJJJ[J`@D 9!9!9!9!9!9!vKKKKKKr+rrCr rITuple[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) isinstancerJrr BytesLiker TypeErrorrCs r,rr^sX $: G,,,, D) $ $:$8999r+rBct|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)rrJrrrBrrs r,rrvsU$:{{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. intcoderJreasonrIcd|jcxkrdkrnnd}n8d|jcxkrdkrnnd}n t|jd}|jd|d}|jr |d |j}|S) zU Return a human-readable representation of a close code and reason. i registeredz private useunknownz ()rQ)rr?getr)rh explanationresults r,rmz Close.__str__s 49 # # # #t # # # # #&KK TY % % % % % % % % %'KK155diKKKI///// ; /....F r+rCrBc^t|dkr^tjd|dd\}|ddd}|||}||St|dkr|t jdStjd)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. rr}NrrrLzclose frame too short) r_rrrarr.r3r r)rrCrrcloses r,rcz Close.parses t99>>mD$rr(33GT!""X__W--FCf%%E KKMMML YY!^^3y/44 4*+BCC Cr+c|tjd|j|jdzS)z: Serialize the payload of a close frame. r}r)rrrrrrrs 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 rrs r,rz Close.checksR 111TTY5M5M5M5M5M5M5M5M*+@AA A215M5Mr+Nr)rCrBrIr)rIrBr) r r!r"r#rrmrrcrrr*r+r,rrsIIIKKK$DDD[D.JJJJ B B B B B Br+r)rCr rIr)rCr rIrB)C __future__r dataclassesenumrrrtypingrrrrrrLr r r speedupsr ImportErrorutils__all__IntEnumrr$rr%rr&rr'rr(rr)rrrr.r/r0r1r2r3r4r5r6r7r8r9r:r;r<r=r?rrOK_CLOSE_CODESrB bytearray memoryviewr dataclassrrrrr*r+r,rs|"""""""  AAAAAAAAAAAAAA$$$$$$$$"$$$$$$$"""!!!!!!!!"   ")))))T\))) + + M < + +* ')  .d , .  2 =  = 8  2 0 !#8 . 0 0 = ?+,       !     "   9j (  ^K^K^K^K^K^K^K^KB::::0::::. HBHBHBHBHBHBHBHBHBHBsA A A