← Back
Editing: framing.cpython-311.pyc
� �=Xc� � �� � d dl mZ d dlZd dlmZmZmZmZmZm Z m Z ddl m Z m Z ddlmZmZ ddlmZ n# e$ r ddlmZ Y nw xY w G d� d e� � Zdd l mZmZmZ dd�Zdd�ZdS )� )� annotationsN)�Any� Awaitable�Callable� NamedTuple�Optional�Sequence�Tuple� )� extensions�frames)� PayloadTooBig� ProtocolError)� apply_maskc � � e Zd ZU ded< ded< ded< dZded< dZded < dZded < ed d �� � Zd!d�Z d"d�Z e ddd�d#d�� � Z dd �d$d �Z dS )%�Frame�bool�finz frames.Opcode�opcode�bytes�dataF�rsv1�rsv2�rsv3�return� frames.Framec �p � t j | j | j | j | j | j | j � � S �N)r r r r r r r r ��selfs �;/usr/lib/python3/dist-packages/websockets/legacy/framing.py� new_framezFrame.new_frame s4 � ��|� �K� �I� �H� �I� �I� �I� � � � �strc �* � t | j � � S r )r$ r" r s r! �__str__z Frame.__str__$ s � ��4�>�"�"�"r# �Nonec �4 � | j � � � S r )r" �checkr s r! r) z Frame.check' s � ��~�#�#�%�%�%r# N)�max_sizer �reader�!Callable[[int], Awaitable[bytes]]�maskr* � Optional[int]r �(Optional[Sequence[extensions.Extension]]c � �� K � |d� � � d{V ��}t j d|� � \ }}|dz rdnd}|dz rdnd} |dz rdnd} |d z rdnd} t j |d z � � } n"# t $ r} t d � � | �d} ~ ww xY w|dz rdnd|k rt d � � �|d z }|dk r) |d� � � d{V ��}t j d|� � \ }n.|d k r( |d� � � d{V ��}t j d|� � \ }|� ||k rt d|� d|� d�� � �|r |d� � � d{V ��} ||� � � d{V ��}|rt ||� � }t j | ||| | | � � }|�g }t |� � D ]}|� ||�� � }�|� � � | |j |j |j |j |j |j � � S )a@ Read a WebSocket frame. Args: reader: coroutine that reads exactly the requested number of bytes, unless the end of file is reached. 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: PayloadTooBig: if the frame exceeds ``max_size``. ProtocolError: if the frame contains incorrect values. r Nz!BB� TF�@ � � � zinvalid opcodezincorrect masking� �~ z!H� z!Qzover size limit (z > z bytes)� )r* )�struct�unpackr �Opcode� ValueErrorr r r r �reversed�decoder) r r r r r r )�clsr+ r- r* r r �head1�head2r r r r r �exc�length� mask_bitsr" � extensions r! �readz Frame.read* s� � � � �6 �V�A�Y�Y�������� �}�U�D�1�1� ��u� �j�(�3�d�d�e�� �z�)�4�t�t�u�� �z�)�4�t�t�u�� �z�)�4�t�t�u�� ;��]�5�:�#5�6�6�F�F��� ;� ;� ;� � 0�1�1�s� :����� ;���� �J�&� 1�D�D�E�d� :� :� � 3�4�4� 4���#�� �S�=�=� �����?�?�?�?�?�?�D� � �d�D�1�1�I�V�V� �s�]�]� �����?�?�?�?�?�?�D� � �d�D�1�1�I�V� � �F�X�$5�$5� � P�F� P� P�x� P� P� P�Q�Q� Q� � (� $�f�Q�i�i�������I� �V�F�^�^�#�#�#�#�#�#�� � /� �d�I�.�.�D��L���s�D�$��E�E� � � ��J�!�*�-�-� G� G�I�!�(�(��X�(�F�F�I�I��������s� �M� � � �N� �N� �N� �N� � � s �A) �) B�3B�B)r �write�Callable[[bytes], Any]c �P � || j � ||�� � � � dS )a� Write a WebSocket frame. Args: frame: frame to write. write: function that writes bytes. 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. )r- r N)r" � serialize)r rH r- r s r! rH z Frame.writey s/ � �0 ��d�n�&�&�D�Z�&�H�H�I�I�I�I�Ir# )r r )r r$ )r r' ) r+ r, r- r r* r. r r/ r r )rH rI r- r r r/ r r' )�__name__� __module__� __qualname__�__annotations__r r r �propertyr" r& r) � classmethodrG rH � r# r! r r s � � � � � � � �I�I�I������K�K�K��D������D������D����� � � � � �X� �#� #� #� #�&� &� &� &� � #'�?C� L � L � L � L � L � �[�L �f @D� J� J� J� J� J� J� J� Jr# r )�Close� prepare_ctrl� prepare_datar r r �Tuple[int, str]c �F � t j | � � }|j |j fS )z� Parse the payload from a close frame. Returns: Tuple[int, str]: close code and reason. Raises: ProtocolError: if data is ill-formed. UnicodeDecodeError: if the reason isn't valid UTF-8. )rS �parse�code�reason)r �closes r! � parse_closer\ � s" � � �K�� � �E� �:�u�|� #�#r# rY �intrZ r$ c �F � t | |� � � � � S )z3 Serialize the payload for a close frame. )rS rK )rY rZ s r! �serialize_closer_ � s � � ��v� � � (� (� *� *�*r# )r r r rV )rY r] rZ r$ r r ) � __future__r r: �typingr r r r r r r � r r � exceptionsr r �speedupsr � ImportError�utilsr rS rT � encode_datarU r\ r_ rR r# r! �<module>rh sa �� "� "� "� "� "� "� � � � � R� R� R� R� R� R� R� R� R� R� R� R� R� R� R� R� R� R� !� !� !� !� !� !� !� !� 5� 5� 5� 5� 5� 5� 5� 5�#�%�%�%�%�%�%�%��� #� #� #�"�"�"�"�"�"�"�"�#����AJ� AJ� AJ� AJ� AJ�J� AJ� AJ� AJ�L F� E� E� E� E� E� E� E� E� E� $� $� $� $� +� +� +� +� +� +s �5 � A�A
Save File
Cancel