o mh7@sUddlmZddlZddlZddlZddlZddlZddlZddlm Z m Z m Z ddl m Z mZddlmZzddlmZWneyNddlmZYnwgdZGd d d ejZejZejZejZejZejZ ej!Z"eeefZ#ee e"fZ$Gd d d ejZ%e%j&d e%j'de%j(de%j)de%j*de%j+de%j,de%j-de%j.de%j/de%j0de%j1de%j2de%j3de%j4diZ5de6d<e%j&e%j'e%j(e%j)e%j,e%j-e%j.e%j/e%j0e%j1e%j2e%j3h Z7e%j&e%j'e%j*hZ8e9e:e;fZd+d$d%Z?d,d'd(Z@ej=Gd)d*d*ZAdS)-) annotationsN)Callable GeneratorSequence) 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/zoom/venv/lib/python3.10/site-packages/websockets/frames.pyr &s r c@sLeZdZdZdZdZdZdZdZdZ 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(8s"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_EXPLANATIONSc@seZdZUdZded<ded<dZded<d Zded <d Zded <d Zded <e e j d dZ d%ddZedddd&ddZddd'd d!Zd(d#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 opcodebytesdataTboolfinFrsv1rsv2rsv3WEBSOCKETS_MAX_LOG_SIZE75returnstrc Csd}t|jdt|jdkrdnd}|jrdnd}|jtur)t|j}n|jtura|j}t||jdkrV|jddd}d |dd |d || dg}d d d |D}n^|jt urot t |j}nP|jrz t|j}d}WnAttfy|j}t||jdkr|jddd}d |dd |d || dg}d dd |D}d}Ynwd}t||jkr|jdd}|dd |d|| d}d td|||g}|jjd |d|dS)zE Return a human-readable representation of a frame. Nz byters continuedrs cs|]}|dVqdS02xNr&.0byter&r&r' z Frame.__str__..textcsrLrMr&rOr&r&r'rRrSbinaryz''z...z, z [])lenr<r>r:r reprdecoder MAX_LOG_SIZEjoinrrErparseUnicodeDecodeErrorAttributeErrorfiltername)selfcodinglength non_finalr<rUcutmetadatar&r&r'__str__s>&  & &"z Frame.__str__N)max_sizer read_exact-Callable[[int], Generator[None, None, bytes]]maskrh int | Noner%Sequence[extensions.Extension] | NoneGenerator[None, None, Frame]c cs|dEdH}td|\}}|d@rdnd}|d@rdnd} |d@r&dnd} |d @r.dnd} zt|d @} WntyJ} ztd | d} ~ ww|d@rQdnd|krZtd |d @}|dkrq|dEdH}td|\}n|d kr|dEdH}td|\}|dur||krtd|d|d|r|dEdH}||EdH}|rt||}|| ||| | | }|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@ zinvalid opcodezincorrect masking~!Hrz!Qzover size limit (z > z bytes))rh) structunpackr ValueErrorr ProtocolError PayloadTooBigr reversedrYcheck)clsrirkrhrr<head1head2r>r?r@rAr:excrc mask_bytesframe extensionr&r&r'r\sL    z Frame.parse)rc Cs&||dur g}|D]}||}q t}|jrdnd|jr#dndB|jr*dndB|jr1dndB|jB}|r;dnd}t |j }|dkrS| t d|||Bn|d kre| t d ||dB|n | t d ||d B||r~td }| ||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. Nrprrqrrrsrvroiz!BBHz!BBQrurx)rencodeioBytesIOr>r?r@rAr:rWr<writerypacksecrets token_bytesr getvalue) rarkrroutputrrrcrr<r&r&r' serializes>          zFrame.serializeNonecCsV|js |js |jrtd|jtvr't|jdkrtd|j s)tddSdS)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@rArr|r:rrWr<r>rar&r&r'rSs    z Frame.checkrDrE) rirjrkr=rhrlrrmrDrn)rkr=rrmrDr;rDr)rrrr__annotations__r>r?r@rAintosenvirongetrZrg classmethodr\rrr&r&r&r'r}s"      2P;rr<r rDtuple[int, bytes]cCs0t|tr t|fSt|trt|fStd)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. data must be str or bytes-like) isinstancerEr r BytesLiker TypeErrorr<r&r&r'res   rr;cCs,t|tr |St|trt|Std)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. r)rrErrr;rrr&r&r'r}s  rc@sNeZdZUdZded<ded<dddZedd d Zdd dZdddZ dS)rz Code and reason for WebSocket close frames. Attributes: code: Close code. reason: Close reason. rcoderEreasonrDcCszd|jkr dkrnnd}nd|jkrdkr nnd}nt|jd}|jd|d}|jr;|d |j}|S) zU Return a human-readable representation of a close code and reason. i registeredz private useunknownz ()rK)rr9rr)ra explanationresultr&r&r'rgsz Close.__str__r<r;cCsjt|dkr$td|dd\}|dd}|||}||St|dkr0|tjdStd)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. rrwNrrFzclose frame too short) rWryrzrYrr(r-rr|)rr<rrcloser&r&r'r\s     z Close.parsecCs |td|j|jS)z: Serialize the payload of a close frame. rw)rryrrrrrr&r&r'rszClose.serializercCs4|jtvsd|jkrdksntddSdS)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_CODESrr|rr&r&r'rs" z Close.checkNr)r<r;rDr)rDr;r) rrrrrrgrr\rrr&r&r&r'rs     r)r<r rDr)r<r rDr;)B __future__r dataclassesenumrrrrytypingrrrrFrrr speedupsr ImportErrorutils__all__IntEnumr r r r!r r"rr#rr$rr%rrrr(r)r*r+r,r-r.r/r0r1r2r3r4r5r6r7r9rrOK_CLOSE_CODESr; bytearray memoryviewr dataclassrrrrr&r&r&r's       h