o ЭjY2@sUddlmZddlZddlZddlZddlZddlZddlZddlm Z m Z ddl m Z ddl mZmZddl mZzddlmZWneyRddlmZYnwgd ZGd d d ejZejZejZejZejZej Z!ej"Z#eeefZ$ee!e#fZ%Gd d d ejZ&e&j'de&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+hZ9ej:Gdd d Z;ej:Gd!d"d"ZZ>dS)$) annotationsN) GeneratorSequence)Callable) PayloadTooBig ProtocolError) BytesLike) apply_mask) OpcodeOP_CONTOP_TEXT OP_BINARYOP_CLOSEOP_PINGOP_PONG DATA_OPCODES CTRL_OPCODES CloseCodeFrameClosec@s$eZdZdZd\ZZZd\ZZZ dS)r z#Opcode values for WebSocket frames.)rr) N) __name__ __module__ __qualname____doc__CONTTEXTBINARYCLOSEPINGPONGr%r%N/var/www/html/CropPilot/venv/lib/python3.10/site-packages/websockets/frames.pyr &s r c@sLeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdS)rz-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&r8s"rOKz 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 opcoder dataTboolfinFrsv1rsv2rsv3WEBSOCKETS_MAX_LOG_SIZE75returnstrc Csd}t|jdt|jdkrdnd}|jrdnd}|jtur+tt|j}n|jturc|j}t||j dkrX|j ddd}d |dd |d || dg}d d d |D}n`|jt urqt t |j}nR|jrz tt|j}d}WnAttfy|j}t||j dkr|j ddd}d |dd |d || dg}d dd |D}d}Ynwd}t||j kr|j dd}|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__..textcsrIrJr%rLr%r%r&rOrPbinaryz''z...z, z [])lenr9r;r8r reprbytesdecoder MAX_LOG_SIZEjoinrrBrparseUnicodeDecodeErrorAttributeErrorfiltername)selfcodinglength non_finalr9rRcutmetadatar%r%r&__str__s>&  & &"z Frame.__str__N)max_size extensions read_exact9Callable[[int], Generator[None, None, bytes | bytearray]]maskrf int | Nonerg%Sequence[extensions.Extension] | NoneGenerator[None, None, Frame]c cs|dEdH}td|\}}|d@rdnd}|d@rdnd} |d@r&dnd} |d @r.dnd} zt|d @} WntyI} ztd | d} ~ ww|d@rPdnd|krXtd |d @}|dkro|dEdH}td|\}n|d kr|dEdH}td|\}|dur||krt|||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. PayloadTooBig: If the frame's payload size exceeds ``max_size``. ProtocolError: If the frame contains incorrect values. rN!BBTF@ zinvalid opcodezincorrect masking~!Hrz!Q)rf) structunpackr ValueErrorrrr reversedrWcheck)clsrhrjrfrgr9head1head2r;r<r=r>r8excra mask_bytesframe extensionr%r%r&rZsH    z Frame.parsergrVc 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. Nrorrprqrrrurniz!BBHz!BBQrtrw)r|encodeioBytesIOr;r<r=r>r8rTr9writerxpacksecrets token_bytesr getvalue) r_rjrgroutputr~rrarr9r%r%r& serializes>          zFrame.serializeNonecCsP|js |js |jr td|jtvr$t|jdkrtd|js&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=r>rr8rrTr9r;r_r%r%r&r|Ns z Frame.checkrArB) rhrirjr:rfrkrgrlrArm)rjr:rgrlrArVrAr)rrrr__annotations__r;r<r=r>intosenvirongetrXre classmethodrZrr|r%r%r%r&rzs"      2Ms      fN