a یxd0@sxddlmZddlZddlZddlZddlZddlZddlmZm Z m Z m Z m Z ddl mZmZddlmZzddlmZWneyddlmZYn0gdZGd d d ejZejZejZejZejZej Z!ej"Z#eeefZ$ee!e#fZ%d d d dddddddddddddZ&hdZ'hdZ(e)e*e+fZ,ej-GdddZ.dd d!d"d#Z/dd$d!d%d&Z0ej-Gd'd(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@s$eZdZdZd\ZZZd\ZZZ dS)r z#Opcode values for WebSocket frames.)rr) N) __name__ __module__ __qualname____doc__CONTTEXTBINARYCLOSEPINGPONGr(r(I/var/www/html/Ranjet/env/lib/python3.9/site-packages/websockets/frames.pyr %s r OKz 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,r-r.r0r1r2r3r4r5r6r7>r+r,r/c@seZdZUdZded<ded<dZded<d Zded <d Zded <d Zded <d dddZ e dddddddddddZ ddddddddZ dddd Z 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. r opcodebytesdataTboolfinFrsv1rsv2rsv3strreturnc Csd}t|jdt|jdkr"dnd}|jr4dnd}|jturRt|j}n|jtur|j}t|dkrd|dd d |d dg}d d d|D}n|jt urt t |j}n|jrFzt|j}d}Wndt tfyB|j}t|dkr&d|dd d |d dg}d dd|D}d}Yn0nd}t|dkrt|ddd|dd}dtd|||g}|jjd |d|dS)zE Return a human-readable representation of a frame. Nz byters continuedsi css|]}|dVqdS02xNr(.0byter(r(r) rGz Frame.__str__..textcss|]}|dVqdSrJr(rLr(r(r)rOrGbinaryz''K0z...iz, z [])lenr:r<r8rreprdecoderjoinrr@rparseUnicodeDecodeErrorAttributeErrorfiltername)selfZcodinglengthZ non_finalr:rQmetadatar(r(r)__str__s6&       z Frame.__str__N)max_sizer z-Callable[[int], Generator[None, None, bytes]]z Optional[int]z(Optional[Sequence[extensions.Extension]]zGenerator[None, None, Frame]) read_exactmaskrbr rBc cs|dEdH}td|\}}|d@r*dnd}|d@r:dnd} |d@rJdnd} |d @rZdnd} zt|d @} Wn0ty} ztd | WYd} ~ n d} ~ 00|d@rdnd|krtd |d @}|dkr|dEdH}td|\}n&|d kr|dEdH}td|\}|dur>||kr>td|d|d|rR|dEdH}||EdH}|rpt||}|| ||| | | }|durg}t|D]}|j ||d}q| |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@ rHzinvalid opcodezincorrect masking~!Hrz!Qzover size limit (z > z bytes))rb) structunpackr ValueErrorr ProtocolErrorZ PayloadTooBigr reversedrWcheck)clsrcrdrbr r:head1head2r<r=r>r?r8excr_ mask_bytesframe extensionr(r(r)rYsF"     z Frame.parse)r )rdr rBc Cs(||durg}|D]}||}qt}|jr:dnd|jrFdndB|jrTdndB|jrbdndB|jB}|rvdnd}t |j }|dkr| t d|||Bn>|d kr| t d ||dB|n| t d ||d B||rtd }| ||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. NrfrrgrhrHrkreiz!BBHz!BBQrjrm)rsencodeioBytesIOr<r=r>r?r8rUr:writernpacksecretsZ token_bytesr getvalue) r^rdr rzoutputrurvr_rxr:r(r(r) serializes>          zFrame.serializeNonecCsR|js|js|jrtd|jtvrNt|jdkr>td|j sNtddS)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) r=r>r?r rqr8rrUr:r<r^r(r(r)rs7s   z Frame.check)rrr r!__annotations__r<r=r>r?ra classmethodrYrrsr(r(r(r)rgs     /P;rr zTuple[int, bytes]r:rBcCs6t|trt|dfSt|tr*t|fStddS)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-likeN) isinstancer@rr{ BytesLiker TypeErrorr:r(r(r)rIs   rr9cCs2t|tr|dSt|tr&t|StddS)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. rrN)rr@r{rr9rrr(r(r)ras    rc@s`eZdZUdZded<ded<ddddZed dd d d Zd dd dZddddZ dS)rz Code and reason for WebSocket close frames. Attributes: code: Close code. reason: Close reason. intcoder@reasonrAcCszd|jkrdkr nnd}n.d|jkr6dkr@nnd}nt|jd}|jd|d}|jrv|d |j}|S) zU Return a human-readable representation of a close code and reason. i registeredz private useunknownz ()rI)r CLOSE_CODESgetr)r^Z explanationresultr(r(r)rasz Close.__str__r9rcCsnt|dkrJtd|dd\}|ddd}|||}||St|dkr`|ddStddS) 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. rrlNrrr/rCzclose frame too short)rUrnrorWrsr rq)rtr:rrcloser(r(r)rYs    z Close.parsecCs"|td|j|jdS)z: Serialize the payload of a close frame. rlr)rsrnrrrr{rr(r(r)rszClose.serializercCs0|jtvs,d|jkr dks,ntddS)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 rqrr(r(r)rss"z Close.checkN) rrr r!rrarrYrrsr(r(r(r)rxs  r)2 __future__r dataclassesenumr|rrntypingrrrrrrCr r r Zspeedupsr ImportErrorutils__all__IntEnumr r"rr#rr$rr%rr&rr'rrrrrZOK_CLOSE_CODESr9 bytearray memoryviewr dataclassrrrrr(r(r(r)s`      b