File: //usr/local/lib/python3.10/dist-packages/aiohttp/__pycache__/http_parser.cpython-310.pyc
o
���g� � @ s$ U d dl Z d dlZd dlZd dlZd dlmZ d dlmZ d dlm Z m
Z
m Z m Z m
Z
mZmZmZmZmZmZmZmZmZ d dlmZmZmZ d dlm Z ddl m Z dd l m Z dd
l!m"Z"m#Z#m$Z$ dd l%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z, dd l-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6 dd
l7m8Z8m9Z9 ddl:m;Z;m<Z< ddl=m>Z> dZ?ed Z@eAejB�ZCe eeD eEd< e�Fd�ZGe eD eEd< e�HdeG� d��ZIe eeD eEd< e�HdejJ�ZKe eeD eEd< e�HdejJ�ZLe eeD eEd< e�Hd �ZMe eeN eEd < G d d � d e�ZOG d d!� d!e�ZPed"eOeP�ZQG d#d$� d$e�ZRG d%d&� d&e�ZSG d'd(� d(�ZTd)eeD d*eUfd+d,�ZVG d-d.� d.e jWe eQ �ZXG d/d0� d0eXeO �ZYG d1d2� d2eXeP �ZZG d3d4� d4�Z[G d5d6� d6�Z\eYZ]eZZ^eOZ_ePZ`z e*�s�dd7lamYZYmZZZmOZOmPZP eYZbeZZceOZdePZeW dS W dS ef�y� Y dS w )8� N)�suppress)�IntEnum)�Any�ClassVar�Final�Generic�List�Literal�
NamedTuple�Optional�Pattern�Set�Tuple�Type�TypeVar�Union)� CIMultiDict�CIMultiDictProxy�istr)�URL� )�hdrs)� BaseProtocol)�
HAS_BROTLI�BrotliDecompressor�ZLibDecompressor)�
_EXC_SENTINEL�DEBUG�EMPTY_BODY_METHODS�EMPTY_BODY_STATUS_CODES�
NO_EXTENSIONS�BaseTimerContext�
set_exception) �BadHttpMessage�
BadHttpMethod�
BadStatusLine�ContentEncodingError�ContentLengthError�
InvalidHeader�InvalidURLError� LineTooLong�TransferEncodingError)� HttpVersion�
HttpVersion10)�
EMPTY_PAYLOAD� StreamReader)�
RawHeaders)�
HeadersParser�
HttpParser�HttpRequestParser�HttpResponseParser�RawRequestMessage�RawResponseMessage)�
�
�ASCIISETz!#$%&'*+-.^_`|~�_TCHAR_SPECIALSz
[0-9A-Za-zz]+�TOKENREzHTTP/(\d)\.(\d)�VERSREz\d+�DIGITSs [0-9a-fA-F]+� HEXDIGITSc @ sb e Zd ZU eed< eed< eed< ded< eed< eed< ee ed< eed < eed
< e ed < d S )
r5 �method�path�version�CIMultiDictProxy[str]�headers� raw_headers� should_close� compression�upgrade�chunked�urlN)
�__name__�
__module__� __qualname__�str�__annotations__r, r0 �boolr r � rP rP �>/usr/local/lib/python3.10/dist-packages/aiohttp/http_parser.pyr5 Q s
r5 c @ s^ e Zd ZU eed< eed< eed< ee ed< eed< e ed< e
e ed< e ed< e ed < d
S ) r6 rA �code�reasonrC rD rE rF rG rH N) rJ rK rL r, rN �intrM r r0 rO r rP rP rP rQ r6 ^ s
r6 �_MsgTc @ s e Zd ZdZdZdZdZdS )�
ParseStater r � � N)rJ rK rL �
PARSE_NONE� PARSE_LENGTH�
PARSE_CHUNKED�PARSE_UNTIL_EOFrP rP rP rQ rV m s
rV c @ s e Zd ZdZdZdZdZdZdS )�
ChunkStater r rW rX � N)rJ rK rL �PARSE_CHUNKED_SIZE�PARSE_CHUNKED_CHUNK�PARSE_CHUNKED_CHUNK_EOF�PARSE_MAYBE_TRAILERS�PARSE_TRAILERSrP rP rP rQ r] u s r] c @ sR e Zd Z ddededededd f
d
d �Zd ee ded
e f fdd�Z
d S )r1 � � � F�
max_line_size� max_headers�max_field_size�lax�returnNc C s || _ || _|| _|| _d S �N)rf rg rh �_lax)�selfrf rg rh ri rP rP rQ �__init__~ s
zHeadersParser.__init__�linesrB c C s< t � }g }d}|d }t|�}|�rz
|�dd�\}}W n ty( t|�d �w t|�dkr3t|��|d |d hddh@ rCt|��|�d�}t|�| jkrctd�|� d d
��t
| j�t
t|����|� d d �} t � | �srt|��t|�}
|d7 }|| }| j
o�|o�|d d
v } | r�|g} | r�|
t|�7 }
|
| jkr�td�|� d d
��t
| j�t
|
���| �|� |d7 }||k r�|| }|r�|d d
v } nd}n| s�d�| �}n|
| jkr�td�|� d d
��t
| j�t
|
���|�d�}|� d d �}
d|
v �sd|
v �sd|
v �rt|��|�| |
� |�||f� |st|�t|�fS )Nr � :r ���� � s zrequest header name {}�utf8�backslashreplace�utf-8�surrogateescape)rr rs zrequest header field {}� �
�
� )r �len�split�
ValueErrorr( �lstriprh r* �format�decoderM r; � fullmatchrl �append�join�strip�addr �tuple)rm ro rC rD � lines_idx�line�
line_count�bname�bvalue�name�
header_length� continuation�
bvalue_lst�valuerP rP rQ �
parse_headers� s�
�
�
�
��
��
��
�QzHeadersParser.parse_headers)rd re rd F) rJ rK rL rT rO rn r �bytesr r0 r� rP rP rP rQ r1 } s* �����
� �
�r1 rC rj c C s | � tjd��� dv S )z)Check if the upgrade header is supported.� > �tcp� websocket)�getr �UPGRADE�lower�rC rP rP rQ �_is_supported_upgrade� s r� c @ sn e Zd ZU dZee ed< d0dee d ee j
d
e d e d e d
e dee dee dee
deee dedededdf dd�Zejdee defdd��Zejde
defd d ��Zdee fd d �Zd d!ejejej fd"ed#e d$ed%e d&e
d'e de ee ee f eef fd(d)�Z!dee de d*e"ee ee
eef fd+d,�Z#d-eddfd.d/�Z$dS )1r2 Fri N� rd re T�protocol�loop�limitrf rg rh �timerrR r? �payload_exception�response_with_body�read_until_eof�auto_decompressrj c C s� || _ || _|| _|| _|| _|| _|| _| | _|
| _| | _ | | _
g | _ d| _ d| _
d | _d | _|
| _|| _t|||| j�| _d S )Nrx F)r� r� rf rg rh r� rR r? r� r� r� �_lines�_tail� _upgraded�_payload�_payload_parser�_auto_decompress�_limitr1 ri �_headers_parser)rm r� r� r� rf rg rh r� rR r? r� r� r� r� rP rP rQ rn � s*
�zHttpParser.__init__ro c C � d S rk rP )rm ro rP rP rQ �
parse_message � zHttpParser.parse_message�tec C r� rk rP �rm r� rP rP rQ �_is_chunked_te r� zHttpParser._is_chunked_tec C s� | j d ur| j �� d | _ d S | jr| j�| j� | jrC| jd dkr)| j�d� tt�� | �| j�W d � S 1 s>w Y d S )Nrq z
rx )r� �feed_eofr� r� r� r � Exceptionr� �rm rP rP rQ r� s
�
�zHttpParser.feed_eofr7 rx �data�SEP�EMPTY�CONTENT_LENGTH� METH_CONNECT�SEC_WEBSOCKET_KEY1c s� g }| j r| j | d}| _ t|�}d} | j}
d} | |k �r�| jd u �rg| j�sg|�|| �} | | kr<| js<| t|� } q| | k�r]| rGtd��|| | � }
|dkrV|
�d�}
| j� |
� | t|� } | jd |k�r\z
| �
| j��W | j� � n| j� � w dt t
f� �fd d
� }|� }|�jv r�t|���jo�t�j�| _t�d | j�}t�d d�}| jd us�J �|tv p�t|o�|tv �}|s�|d ur�|dks̈jr�| js�t| j| j|
| jd
�}t ||�j|�j | j | j | j | j!d� }|j"s�|| _n^||k�r t#�t$��sJ �t| j| j|
| jd
�}d| _t |�j�j | j | j!d�| _n4|�sP|d u �rP| j%�rPt| j| j|
| jd
�}t ||�j|�j | j | j | j | j!d� }|j"�sO|| _nt&}|� �|f� �j'} n~|| d � | _ |}nx| jd u �rx| j�rx| j�rwJ �ng|�r�| |k �r�| j�r�J �| jd u�s�J �z| j�(|| d � |�\}}W n. t)�y� } z!|}| j*d u�r�| �*t+|��}t,| jj-||� d}d}W Y d }~nd }~ww |�r�d} t|�}d | _qnn| |k s |�r�| |k �r�|| d � }n|}|| j|fS )Nrx r Fz Data after `Connection: close`r8 �
rq rj c s2 �j �� �} | d u r d S t�| �st� ��t| �S rk )rC r� r= r� r( rT )�
length_hdr�r� �msgrP rQ �get_content_length_ s
z0HttpParser.feed_data.<locals>.get_content_lengthr? rR )r� r� r� )�lengthrH r? rF rR r� r� ri T)r? rF r� ri ).r� r| r� r� r� �findr� r# �rstripr� r� �clearr rT rC r( rG r� �getattrr? r� r rO r rH r/ r� r� �HttpPayloadParserrF rR r� r� ri �done�
isinstancer5 r� r. rE � feed_data�
BaseExceptionr� rM r" �payload)rm r� r� r� r� r� r� �messages�data_len� start_posr� rE �posr� r� r� r? rR �
empty_bodyr� �payload_parser�eof�underlying_exc� reraised_excrP r� rQ r� . s
�
���� �
�
��� �� ���� �� $ zHttpParser.feed_datarB c
s0 | j �|�\� }d}d}d}d}tjtjtjtjtjtjtj tj
tj tj f
}t
� fdd�|D �d�}|dur>td|� d���� �tj�} | rd| �� }
|
dkrQd}n|
d krXd}n |
d
krd� �tj�rdd}� �tj�} | rv| �� } | d v rv| }� �tj �} | dur�| �| �r�d}tj� v r�td ��� |||||fS )
z�Parses RFC 5322 headers from a stream.
Line continuations are supported. Returns list of header name
and value pairs. Header name is in upper case.
NFc 3 s( � | ]}t � �|d ��dkr|V qdS )rP r N)r| �getall)�.0�hr� rP rQ � <genexpr>
s �& z+HttpParser.parse_headers.<locals>.<genexpr>z Duplicate 'z' header found.�closeTz
keep-aliverG )�gzip�deflate�brz6Transfer-Encoding can't be present with Content-Length)r� r� r r� �CONTENT_LOCATION�
CONTENT_RANGE� CONTENT_TYPE�ETAG�HOST� MAX_FORWARDS�SERVER�TRANSFER_ENCODING�
USER_AGENT�nextr# r� �
CONNECTIONr� r� �CONTENT_ENCODINGr� )
rm ro rD �
close_conn�encodingrG rH �
singletons�bad_hdr�conn�v�encr� rP r� rQ r� � sT
�
�zHttpParser.parse_headers�valc C s
|| _ dS )zZSet connection upgraded (to websocket) mode.
:param bool val: new state.
N)r� )rm r� rP rP rQ � set_upgraded. s
zHttpParser.set_upgraded)
NNr� rd re rd NNNNTFT)%rJ rK rL ri r rO rN r r �asyncio�AbstractEventLooprT r! rM r r� rn �abc�abstractmethodr r� rU r� r� r� r r� r� r� �_SEPr r r/ r� r0 r� r� rP rP rP rQ r2 � s�
�������� �
�
� �
��
�'�������
� ?��
�Br2 c @ s8 e Zd ZdZdee defdd�Zdede fdd�Z
d S )
r3 z�Read request status line.
Exception .http_exceptions.BadStatusLine
could be raised in case of any errors in status line.
Returns RawRequestMessage.
ro rj c C s� |d � dd�}z |jddd�\}}}W n ty t|�d �w t|�| jkr5tdt| j�tt|����t� |�s>t|��t
� |�}|d u rKt |��t t
|�d��t
|�d���}|d krftj|d
d �}nD|�d �r�|�d
�\} }
} | �d�\} } }
tj| |
| d
d�}n%|dkr�|dkr�t|d
d�}nt|d
d�}|jdkr�t|jdd�� d���| �|�\}}}}}}|d u r�|tkr�d
}nd}t||||||||||�
S )Nr rv rw � rW ��maxsplit�Status line is too longr �CONNECTT)� authority�encoded�/�#�?)r@ � query_string�fragmentr� �*�OPTIONS)r� r� )�errors�latin1F)r� r} r~ r$ r| rf r* rM r; r� r< r% r, rT �groupr �build�
startswith� partition�schemer) �encoder� r- r5 )rm ro r� r? r@ rA �match� version_orI � path_part�_hash_separator� url_fragment�_question_mark_separator�qs_partrC rD r� rF rG rH rP rP rQ r� > st
��
�
� ��z HttpRequestParser.parse_messager� c C s, |j ddd�d �d��� dkrdS td��) N�,r r� rq � rH Tz'Request has invalid `Transfer-Encoding`)�rsplitr� r� r# r� rP rP rQ r� � s z HttpRequestParser._is_chunked_teN) rJ rK rL �__doc__r r� r5 r� rM rO r� rP rP rP rQ r3 6 s Ur3 c s� e Zd ZdZe Z ddedee de de de
e e
e e
f eef f
� fdd �
Zd
e e de fd d �Zd
edefdd�Z� ZS )r4 z�Read response status line and headers.
BadStatusLine could be raised in case of any errors in status line.
Returns RawResponseMessage.
Nr� r� �args�kwargsrj c s0 |d u r
t rdnd}t� j||g|�R i |��S )Nr7 r8 )r �superr� )rm r� r� r r �� __class__rP rQ r� � s z HttpResponseParser.feed_dataro c
C s� |d � dd�}z
|jdd�\}}W n ty t|�d �w z
|jdd�\}}W n ty8 |�� }d}Y nw t|�| jkrMtdt| j�tt|����t �
|�}|d u rZt|��t t |�
d��t |�
d���}t|�d kstt�
|�sxt|��t |�}| �|�\} }
} } }
}| d u r�|tkr�d
} n!d | kr�d k s�n |d
v r�d} ntj| v s�tj| v r�d} nd
} t|||�� | |
| | |
|� S )Nr rv rw r r� r� r� rW rX T�d �� > �0 �� F)r� r} r~ r% r� r| rf r* rM r< r� r, rT r r= r� r- r r� r� r6 )rm ro r� rA �statusrS r
r �status_irC rD r� rF rG rH rP rP rQ r� � sd
� ��
� �z HttpResponseParser.parse_messager� c C s |j ddd�d �d��� dkS )Nr r r� rq r rH )r r� r� r� rP rP rQ r� � s z!HttpResponseParser._is_chunked_terk )rJ rK rL r r ri r� r r� r r r r6 r/ rO r� r� rM r� �
__classcell__rP rP r rQ r4 � s" ������ ?r4 c @ s� e Zd Z ddedee dedee dee d ee d
ed ed ed
dfdd�Zddd�Z dde
de de
d
e ee
f fdd�Z
dS ) r� NFTr� r� rH rF rR r? r� r� ri rj c
C s� d| _ tj| _tj| _d| _d| _|| _ | | _
d| _ |r'|r'| j r't ||�}
n|}
|s7tj
| _|
�� d| _ n |r>tj| _n|d urUtj| _|| _ | j dkrU|
�� d| _ |
| _d S )Nr rx FT)�_lengthrV r\ �_typer] r_ �_chunk� _chunk_size� _chunk_tailr� rl r� �
DeflateBufferrY r� r[ rZ r� ) rm r� r� rH rF rR r? r� r� ri � real_payloadrP rP rQ rn � s4 �
zHttpPayloadParser.__init__c C sF | j tjkr
| j�� d S | j tjkrtd��| j tjkr!td��d S )Nz2Not enough data for satisfy content length header.z3Not enough data for satisfy transfer length header.) r% rV r\ r� r� rZ r' r[ r+ r� rP rP rQ r� " s � ��zHttpPayloadParser.feed_eofr7 � ;�chunkr� � CHUNK_EXTc
C s� | j tjkrF| j}t|�}||kr+|| | _| j�||� | jdkr)| j�� dS d S d| _| j�|d |� |� | j�� d||d � fS | j tjk�r�| j rX| j | }d| _ |�r�| j
t j kr�|�
|�}|dkr�|�
|d|�}|dkr�|d |� }d|||� } v r�td| ���}
t| j|
� |
�n|d |� }| jr�|�� }t�t|�s�t|d |� �dd��}
t| j|
� |
�tt|�d �} ||t|� d � }| dkr�t j| _
| jr�|�d
�r�|d d � }nt j| _
| | _ | j� � n|| _ d S | j
t jk�r4| j }t|�}||k�r|| | _ | j�||� d S d| _ | j�|d |� |� ||d � }t j | _
| j� � | j
t j k�rh| j�rK|�d
��rK|d d � }|d t|�� |k�rc|t|�d � }t j | _
n|| _ d S | j
t jk�r�|d t|�� } | |k�r�| j�� d|t|�d � fS | �s�d S | |d d � k�r�| | _ d S t j | _
| j
t j k�r�|�
|�}|dk�r�||t|� d � }t j| _
n|| _ d S |s[d S | j tj!k�r�| j�|t|�� d S )
Nr )Trx Trx r8 z"Unexpected LF in chunk-extension: �asciirw � r� r )Frx )"r% rV rZ r$ r| r� r� r� r[ r( r& r] r_ r� r# r" rl r� �rer� r> r+ r� rT r� rb r r` r' �begin_http_chunk_receivingra �end_http_chunk_receivingrc r\ )
rm r, r� r- �required� chunk_lenr� �i�size_b�ext�exc�size�headrP rP rQ r� . s�
w�
� � � �
�j�zHttpPayloadParser.feed_data)NFNNNTTF�rj N)r7 r+ )rJ rK rL r/ r rT rO rM rn r� r� r� r r� rP rP rP rQ r� � sR �������� �
�
�
.
����
�r� c @ s� e Zd ZU dZeed< dedee ddfdd�Z e
fd e d
e ddfd d �Z d
e
deddfdd�Zddd�Zddd�Zddd�ZdS )r) zDDeflateStream decompress stream and feed data into specified stream.� decompressor�outr� rj Nc C sL || _ d| _|| _d| _| |dkr tstd��t� | _d S t|d�| _d S )Nr Fr� zECan not decode content-encoding: brotli (br). Please install `Brotli`)r� ) r= r9 r� �_started_decodingr r& r r< r )rm r= r� rP rP rQ rn � s � zDeflateBuffer.__init__r8 � exc_causec C s t | j||� d S rk )r" r= )rm r8 r? rP rP rQ r" � s zDeflateBuffer.set_exceptionr, r9 c C s� |sd S | j |7 _ | js#| jdkr#|d d@ dkr#t| jdd�| _z| j�|�}W n ty9 td| j ��w d| _|rJ| j� |t
|�� d S d S )Nr� r � � T)r� �suppress_deflate_headerz#Can not decode content-encoding: %s) r9 r> r� r r< �decompress_syncr� r& r= r� r| )rm r, r9 rP rP rQ r� � s* �
� ���zDeflateBuffer.feed_datac C sR | j �� }|s | jdkr"| j�|t|�� | jdkr"| j js"td��| j� � d S )Nr r� )
r< �flushr9 r= r� r| r� r� r& r� )rm r, rP rP rQ r� � s
zDeflateBuffer.feed_eofc C � | j �� d S rk )r= r1 r� rP rP rQ r1 � � z(DeflateBuffer.begin_http_chunk_receivingc C rE rk )r= r2 r� rP rP rQ r2 � rF z&DeflateBuffer.end_http_chunk_receivingr; )rJ rK rL r r rN r/ r rM rn r r� r" r� rT r� r� r1 r2 rP rP rP rQ r) � s
���
�
r) )r3 r4 r5 r6 )gr� r� r0 �string�
contextlibr �enumr �typingr r r r r r r
r r r
r r r r � multidictr r r �yarlr r� r �
base_protocolr �compression_utilsr r r �helpersr r r r r r! r" �http_exceptionsr# r$ r% r& r' r( r) r* r+ � http_writerr, r- �streamsr. r/ �typedefsr0 �__all__r� �set� printabler9 rM rN �escaper: �compiler; �ASCIIr< r= r> r� r5 r6 rU rV r] r1 rO r� �ABCr2 r3 r4 r� r) �HttpRequestParserPy�HttpResponseParserPy�RawRequestMessagePy�RawResponseMessagePy� _http_parser�HttpRequestParserC�HttpResponseParserC�RawRequestMessageC�RawResponseMessageC� ImportErrorrP rP rP rQ �<module> sn
@ $, "
l JdY CN
� �