File: //usr/local/CyberCP/lib/python3.10/site-packages/websockets/legacy/__pycache__/http.cpython-310.pyc
o
�h� � @ s� d dl mZ d dlZd dlZd dlZddlmZ ddlmZ ddgZ e
ej � dd ��Z
e
ej � d
d ��Zd dd�Ze�d�Ze�d�Zd dd�Zd!dd�Zd"dd �Zd#d d �ZdS )$� )� annotationsN� )�Headers)�
SecurityError� read_request�
read_response�WEBSOCKETS_MAX_NUM_HEADERS�128�WEBSOCKETS_MAX_LINE_LENGTH�8192�value�bytes�return�strc C s | j dd�S )zG
Decode a bytestring for interpolating into an error message.
�backslashreplace)�errors)�decode)r � r �I/usr/local/CyberCP/lib/python3.10/site-packages/websockets/legacy/http.py�d s r s [-!#$%&\'*+.^_`|~0-9a-zA-Z]+s [\x09\x20-\x7e\x80-\xff]*�stream�asyncio.StreamReader�tuple[str, Headers]c
� s� �z t | �I dH }W n ty } ztd�|�d}~ww z |�dd�\}}}W n ty8 tdt|�� ��d�w |dkrFtdt|�� ���|dkrStd t|�� ���|�d
d �}t| �I dH }||fS ) a�
Read an HTTP/1.1 GET request and return ``(path, headers)``.
``path`` isn't URL-decoded or validated in any way.
``path`` and ``headers`` are expected to contain only ASCII characters.
Other characters are represented with surrogate escapes.
:func:`read_request` doesn't attempt to read the request body because
WebSocket handshake requests don't have one. If the request contains a
body, it may be read from ``stream`` after this coroutine returns.
Args:
stream: Input to read the request from.
Raises:
EOFError: If the connection is closed without a full HTTP request.
SecurityError: If the request exceeds a security limit.
ValueError: If the request isn't well formatted.
Nz1connection closed while reading HTTP request line� r zinvalid HTTP request line: s GETzunsupported HTTP method: � HTTP/1.1�unsupported HTTP version: �ascii�surrogateescape)� read_line�EOFError�split�
ValueErrorr r � read_headers)r � request_line�exc�method�raw_path�version�path�headersr r r r - s& �
�� � �tuple[int, str, Headers]c
� s �z t | �I dH }W n ty } ztd�|�d}~ww z |�dd�\}}}W n ty8 tdt|�� ��d�w |dkrFtdt|�� ���zt|�}W n ty] tdt|�� ��d�w d | krhd
k srn td t|�� ���t�|�s�td t|�� ���|�� }t | �I dH }|||fS )
a�
Read an HTTP/1.1 response and return ``(status_code, reason, headers)``.
``reason`` and ``headers`` are expected to contain only ASCII characters.
Other characters are represented with surrogate escapes.
:func:`read_request` doesn't attempt to read the response body because
WebSocket handshake responses don't have one. If the response contains a
body, it may be read from ``stream`` after this coroutine returns.
Args:
stream: Input to read the response from.
Raises:
EOFError: If the connection is closed without a full HTTP response.
SecurityError: If the response exceeds a security limit.
ValueError: If the response isn't well formatted.
Nz0connection closed while reading HTTP status liner r zinvalid HTTP status line: r r zinvalid HTTP status code: �d i� z unsupported HTTP status code: z invalid HTTP reason phrase: )
r r r r! r �int� _value_re� fullmatchr r" ) r � status_liner$ r' �raw_status_code�
raw_reason� status_code�reasonr) r r r r ^ s4 �
�� � �
r c � s� �t � }ttd �D ]p}z t| �I dH }W n ty& } ztd�|�d}~ww |dkr. |S z
|�dd�\}}W n tyI tdt|�� ��d�w t� |�sXtdt|�� ���|�
d�}t � |�sktd t|�� ���|� d
�}|� d
d �}|||< q
t
d ��)
zo
Read HTTP headers from ``stream``.
Non-ASCII characters are represented with surrogate escapes.
� Nz,connection closed while reading HTTP headers� � :zinvalid HTTP header line: zinvalid HTTP header name: s zinvalid HTTP header value: r r ztoo many HTTP headers)r �range�MAX_NUM_HEADERSr r r r! r � _token_rer. �stripr- r r ) r r) �_�liner$ �raw_name� raw_value�namer r r r r" � s4 �
��� �
r" c � sB �| � � I dH }t|�tkrtd��|�d�std��|dd� S )z[
Read a single line from ``stream``.
CRLF is stripped from the return value.
Nz
line too longs
zline without CRLF���)�readline�len�MAX_LINE_LENGTHr �endswithr )r r< r r r r � s �
r )r r
r r )r r r r )r r r r* )r r r r )r r r r
)�
__future__r �asyncio�os�re�datastructuresr �
exceptionsr �__all__r, �environ�getr8 rC r �compiler9 r- r r r" r r r r r �<module> s
1
4(