vg1|UddlmZddlZddlZddlZddlZddlZddlZddlm Z m Z ddl m Z m Z ddlmZmZ 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?ej>Gd d!Z@dd"lAmBZBdS)#) annotationsN) GeneratorSequence)CallableUnion) PayloadTooBig ProtocolError) apply_mask) OpcodeOP_CONTOP_TEXT OP_BINARYOP_CLOSEOP_PINGOP_PONG DATA_OPCODES CTRL_OPCODESFrameClosec*eZdZdZd\ZZZd\ZZZ dS)r z#Opcode values for WebSocket frames.)rr) N) __name__ __module__ __qualname____doc__CONTTEXTBINARYCLOSEPINGPONGN/var/www/pixelcanvas.ch/venv/lib/python3.11/site-packages/websockets/frames.pyr r $s,--)D$(E4r'r cNeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdS) CloseCodez-Close code values for WebSocket close frames.iiiiiiiiiiiiiiiN)rrrrNORMAL_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*6sc77NJNNLONOOKMMMr'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 <e e j d dZ d"dZedddd#dZddd$dZd%d!ZdS)&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. r opcodez#Union[bytes, bytearray, memoryview]dataTboolfinFrsv1rsv2rsv3WEBSOCKETS_MAX_LOG_SIZE75returnstrc<d}t|jdt|jdkrdnd}|jrdnd}|jtur5t t |j}n|jtur|j}t||j dzkr<|j dzdz dz}d |dd |zd || dg}d d |D}n|jtur-tt|j}n|jr t t |j}d }n#tt f$r|j}t||j dzkr<|j dzdz dz}d |dd |zd || dg}d d|D}d}YnwxYwd}t||j kr)|j dzdz }|dd |zdz|| dz}d t#d|||g}|jjd |d|dS)zE Return a human-readable representation of a frame. Nz byters continuedr'rs c3K|]}|dV dS02xNr&.0bytes r( z Frame.__str__..s&==dtMM======r'textc3K|]}|dV dSrOr&rQs r(rTz Frame.__str__..s&AA$4 AAAAAAr'binaryz''z...z, z [])lenr>r@r=rreprbytesdecoder MAX_LOG_SIZEjoinrrGrparseUnicodeDecodeErrorAttributeErrorfiltername)selfcodinglength non_finalr>rWcutmetadatas r(__str__z Frame.__str__s  NNMMs49~~/B/BMM(3BB ;' ! !di((//1122DD [I % %YF6{{T.!333(A-1a76)AG)#4k63$%%="QRR88==f=====DD [H $ $u{{49--..DD Y  "E$),,335566&7 " " "v;;!2a!777,1A5!;C XXviCi'8+vsdee}&UVVFxxAA&AAAAA!  "D t99t( ( (#q(1,C !c' ?U*T3$%%[8D99VD669*EFFGG+"88T88X8888s5F BHHN)max_size extensions read_exact-Callable[[int], Generator[None, None, bytes]]maskrk int | Nonerl%Sequence[extensions.Extension] | NoneGenerator[None, None, Frame]c#JK|dEd{V}tjd|\}}|dzrdnd}|dzrdnd} |dzrdnd} |d zrdnd} t|d z} n"#t$r} t d | d} ~ wwxYw|dzrdnd|krt d |d z}|dkr)|dEd{V}tjd|\}n.|d kr(|dEd{V}tjd|\}|||krt |||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. PayloadTooBig: If the frame's payload size exceeds ``max_size``. ProtocolError: If the frame contains incorrect values. rN!BBTF@ zinvalid opcodezincorrect masking~!Hrz!Q)rk) structunpackr ValueErrorr r r reversedr\check)clsrmrorkrlr>head1head2r@rArBrCr=excrf mask_bytesframe extensions r(r_z Frame.parsesg:%*Q--''''''}UD11 uj(3ddez)4ttuz)4ttuz)4ttu ;EJ.//FF ; ; ; 011s : ;J& 1DDEd : : 344 4# S==(jmm++++++D dD11IVV s]](jmm++++++D dD11IV  FX$5$511 1  2$.JqMM111111J%*V,,,,,,,,  0dJ//DFD#tT488  J!*-- ? ?I$$UX$>>EE  sA$$ B.A>>Brlr[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. Nrurrvrwrxr{rtiz!BBHz!BBQrzr})rencodeioBytesIOr@rArBrCr=rYr>writer~packsecrets token_bytesr getvalue) rdrorlroutputrrrfrr>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|jrtd|jt vr=t |jdkrtd|jstddSdS)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=rrYr>r@rds r(rz Frame.checkNs 9 ;  ;TY ; 9:: : ;, & &49~~###$<===8 @#$>??? ' & @ @r'rFrG) rmrnror?rkrprlrqrFrr)ror?rlrqrFr[rFr)rrrr__annotations__r@rArBrCintosenvirongetr]rj classmethodr_rrr&r'r(rr{s* NNN----CDDD3rz~~&?FFGGL09090909d $<@ GGGGG[GZ=A 9!9!9!9!9!9!v@@@@@@r'rcXeZdZUdZded<ded<ddZedd Zdd Zdd Z dS)rz Code and reason for WebSocket close frames. Attributes: code: Close code. reason: Close reason. rcoderGreasonrFcd|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 ()rM)rr;rr)rd explanationresults r(rjz Close.__str__ns 49 # # # #t # # # # #&KK TY % % % % % % % % %'KK155diKKKI///// ; /....F r'r>r[cRt|dkr]tjd|dd\}|dd}|||}||St|dkr|t jdStd)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|NrrIzclose frame too short)rYr~rr\rr*r/r )rr>rrcloses r(r_z Close.parses t99>>mD$rr(33GT!""X__&&FCf%%E KKMMML YY!^^3y/44 4 788 8r'c|tjd|j|jzS)z: Serialize the payload of a close frame. r|)rr~rrrrrs r(rzClose.serializes8 {4++dk.@.@.B.BBBr'rcl|jtvs#d|jcxkrdksntddSdS)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 rs r(rz Close.checksO 111TTY5M5M5M5M5M5M5M5M 566 6215M5Mr'Nr)r>r[rFr)rFr[r) rrrrrrjrr_rrr&r'r(rr`sIIIKKK$999[9.CCCC 7 7 7 7 7 7r'rr)C __future__r dataclassesenumrrrr~collections.abcrrtypingrr exceptionsr r speedupsr ImportErrorutils__all__IntEnumr r r r!rr"rr#rr$rr%rrrr*r+r,r-r.r/r0r1r2r3r4r5r6r7r8r9r;rrOK_CLOSE_CODESr[ bytearray memoryview BytesLike dataclassrrrIrlr&r'r(rsV"""""""  ////////""""""""44444444"$$$$$$$"""!!!!!!!!"   )))))T\))) + + M < + +* ')  .d , .  2 =  = 8  2 0 !#8 . 0 0 = ?+,       !     "   9j (  a@a@a@a@a@a@a@a@H H7H7H7H7H7H7H7H7XsA A A