U
'�7`Vg �
@ sf d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl m
Z
d dl m Z d dlm
Z
d dlmZmZmZmZmZmZmZmZmZmZ d dlmZ d dlZd dl m Z m Z m Z m Z d dl!m"Z" d d
l#m$Z$ d d l%m&Z& d d l'm(Z(m)Z)m*Z*m+Z+m,Z, d d
l-m.Z. d dl/m0Z0 d dl1m2Z2m3Z3 d dl4m5Z5m6Z6 d dl7m8Z8m9Z9m:Z:m;Z;m<Z< d dl=m>Z> d dl?m@Z@ dZAe�r�d dlBmCZC d dlDmEZE d dlFmGZG ejHdddd�G dd� d��ZIejJejK d ZLd eL� d �ZMd �Nd �Od!d"� d#ePeQd$d%�� D ���ZRd&ZSd'jNeReSd(�ZTd)jNeMeTd*�ZUe�Vd+�ZWe�VeU�ZXG d,d-� d-eeYef e*�ZZG d.d/� d/eZ�Z[dS )0� N)� parsedate)� SimpleCookie)�MappingProxyType)
�
TYPE_CHECKING�Any�Dict�Iterator�Mapping�MutableMapping�Optional�Tuple�Union�cast)� parse_qsl)� CIMultiDict�CIMultiDictProxy� MultiDict�MultiDictProxy)�URL� )�hdrs)�AbstractStreamWriter)�DEBUG�
ChainMapProxy� HeadersMixin�reify�sentinel)�RawRequestMessage)� HttpVersion)�BodyPartReader�MultipartReader)�EmptyStreamReader� StreamReader)�DEFAULT_JSON_DECODER� JSONDecoder� LooseHeaders�
RawHeaders�StrOrURL)�HTTPRequestEntityTooLarge)�StreamResponse)� BaseRequest� FileField�Request)� Application)�RequestHandler)�UrlMappingMatchInfoT)Z auto_attribs�frozen�slotsc @ s8 e Zd ZU eed< eed< ejed< eed< ded< dS )r+ �name�filename�file� content_type�CIMultiDictProxy[str]�headersN)�__name__�
__module__� __qualname__�str�__annotations__�io�BufferedReader� r? r? �F/opt/alt/python38/lib64/python3.8/site-packages/aiohttp/web_request.pyr+ 9 s
r+ z!#$%&'*+.^_`|~-�[z]+z[{}]� c c s | ]}t |�V qd S �N)�chr)�.0�cr? r? r@ � <genexpr>H s rG )� � �! �# � z
\\[\t !-~]z "(?:{quoted_pair}|{qdtext})*")ZqdtextZ quoted_pairz0({token})=({token}|{quoted_string})(:\d{{1,4}})?)�tokenZ
quoted_stringz \\([\t !-~])c @ sl e Zd ZejejejejejhZ e
j e ddddddddd d
d d d
ddddg�B Z dddddd�e
ededejeeeeef ee ee ee dd� dd�Zeeeeeed�eeeeeed d�d d �Ze dd �d d ��Z e dd �d!d"��Z e eej d �d#d$��Z e ed �d%d&��Z!e"e
d �d'd(��Z#e"e$d �d)d*��Z%e"ejd �d+d,��Z&eed-�d.d/�Z'eedd0�d1d2�Z(edd-�d3d4�Z)ed �d5d6�Z*e+e d �d7d8�Z,e"e-d �d9d:��Z.e"e/e0eef d;f d �d<d=��Z1e"ed �d>d?��Z2e"ed �d@dA��Z3e"e4d �dBdC��Z5e"ed �dDdE��Z6e"ee d �dFdG��Z7e"e$d �dHdI��Z8e"ed �dJdK��Z9e"ed �dLdM��Z:e"ed �dNdO��Z;e"dPd �dQdR��Z<e"ed �dSdT��Z=e"dUd �dVdW��Z>e"e?d �dXdY��Z@eAee eeBjB dZ�d[d\��ZCe"eeBjB d �d]d^��ZDe"eeBjB d �d_d`��ZEe"eeBjB d �dadb��ZFe"e-d �dcdd��ZGe"e0eef d �dedf��ZHe"eId �dgdh��ZJe"ed �didj��ZKe e-d �dkdl��ZLe e-d �dmdn��ZMe"e-d �dodp��ZNdd �dqdr�ZOePd �dsdt�ZQed �dudv�ZReSdw�eTedx�dydz�ZUeVd �d{d|�ZWd}d �d~d�ZXd�eeed��d�d��ZYed �d�d��ZZe[e-d��d�d��Z\e-d �d�d��Z]e^dd��d�d��Z_e`dd��d�d��ZadS )�r* �_message� _protocol�_payload_writer�_payload�_headers�_method�_version�_rel_url�_post� _read_bytes�_state�_cache�_task�_client_max_size�_loop�_transport_sslcontext�_transport_peernamei N)�client_max_size�state�scheme�host�remoter. zasyncio.Task[None]) �message�payload�protocol�payload_writer�task�loopr_ r` ra rb rc �returnc
C s� |d kr i }|| _ || _|| _|| _|j| _|j| _|j| _ |j
| _ d | _ d | _
|| _i | _|| _|| _|| _| jj} | d k s�t�| �d�| _| �d�| _| d k r�| | jd< |
d k r�|
| jd< | d k r�| | jd< d S )NZ
sslcontextZpeernamera rb rc )rN rO rP rQ r7 rR �methodrS �versionrT �urlrU rV rW rX rY rZ r[ r\ � transport�AssertionError�get_extra_infor] r^ )
�selfrd re rf rg rh ri r_ r` ra rb rc rn r? r? r@ �__init__� s8 �
zBaseRequest.__init__�rk �rel_urlr7 ra rb rc �rk rt r7 ra rb rc rj c C s� | j rtd��i }|tk r"||d< |tk rFt|�}||d< t|�|d< |tk rxtt|��|d< tdd� |�� D ��|d< | j j
f |�} i }
|tk r�||
d < |tk r�||
d
< |tk r�||
d < | j | | j | j
| j| j| jf| j| j�� d �|
��S )
a Clone itself with replacement some attributes.
Creates and returns a new instance of Request object. If no parameters
are given, an exact copy is returned. If a parameter is not passed, it
will reuse the one from the current request object.
z.Cannot clone request after reading its contentrk rm �pathr7 c s s& | ] \}}|� d �|� d �fV qdS )�utf-8N)�encode)rE �k�vr? r? r@ rG � s z$BaseRequest.clone.<locals>.<genexpr>� raw_headersra rb rc )r_ r` )rW � RuntimeErrorr r r; r r �tuple�itemsrN �_replace� __class__rQ rO rP rZ r\ r[ rX �copy) rq rk rt r7 ra rb rc ZdctZnew_urlrd �kwargsr? r? r@ �clone� sF � �� �zBaseRequest.clone�rj c C s | j S rC )rZ �rq r? r? r@ rh � s zBaseRequest.taskc C s | j S rC )rO r� r? r? r@ rf � s zBaseRequest.protocolc C s | j d krd S | j jS rC )rO rn r� r? r? r@ rn � s
zBaseRequest.transportc C s | j S rC )rP r� r? r? r@ �writer� s zBaseRequest.writerc C s t jdtdd� | jS )Nz Request.message is deprecated� ��
stacklevel)�warnings�warn�DeprecationWarningrN r� r? r? r@ rd � s zBaseRequest.messagec C s | j S rC )rU r� r? r? r@ rt s zBaseRequest.rel_urlc C s t jdtdd� | jS )Nz#request.loop property is deprecated� r� )r� r� r� r\ r� r? r? r@ ri s �zBaseRequest.loop)�keyrj c C s
| j | S rC �rX �rq r� r? r? r@ � __getitem__ s zBaseRequest.__getitem__)r� �valuerj c C s || j |< d S rC r� )rq r� r� r? r? r@ � __setitem__ s zBaseRequest.__setitem__c C s | j |= d S rC r� r� r? r? r@ � __delitem__ s zBaseRequest.__delitem__c C s
t | j�S rC )�lenrX r� r? r? r@ �__len__ s zBaseRequest.__len__c C s
t | j�S rC )�iterrX r� r? r? r@ �__iter__ s zBaseRequest.__iter__c C s
| j dkS )z5A bool indicating if the request is handled with SSL.�https)ra r� r? r? r@ �secure s zBaseRequest.secure.c C sX g }| j j�tjd�D �]6}t|�}d}d}i }|�t�|�� d| krT|k rn qt �
||�}|dk r�|r~|� d|�}n\|� � \}} }
| d dkr�t
�d| dd � �} |
r�| |
7 } | ||�� < |t|�d��7 }d
}q@|| dk�r d}i }|�t�|�� |d7 }q@|| d k�r(d}|d7 }q@|| d k�r@|d7 }q@|� d|�}q@qt|�S )
a� A tuple containing all parsed Forwarded header(s).
Makes an effort to parse Forwarded headers as specified by RFC 7239:
- It adds one (immutable) dictionary per Forwarded 'field-value', ie
per proxy. The element corresponds to the data in the Forwarded
field-value added by the first proxy encountered by the client. Each
subsequent item corresponds to those added by later proxies.
- It checks that every value has valid syntax in general as specified
in section 4: either a 'token' or a 'quoted-string'.
- It un-escapes found escape sequences.
- It does NOT validate 'by' and 'for' contents as specified in section
6.
- It does NOT validate 'host' contents (Host ABNF).
- It does NOT validate 'proto' contents for valid URI scheme names.
Returns a tuple containing one or more immutable dicts
r? r FN�,�"z\1r ���T�;z )rN r7 Zgetallr Z FORWARDEDr� �append�typesr �_FORWARDED_PAIR_RE�match�find�groups�_QUOTED_PAIR_REPLACE_RE�sub�lower�groupr} ) rq ZelemsZ field_valueZlength�posZneed_separator�elemr� r2 r� Zportr? r? r@ � forwarded% s@
zBaseRequest.forwardedc C s | j r
dS dS dS )a A string representing the scheme of the request.
Hostname is resolved in this order:
- overridden value by .clone(scheme=new_scheme) call.
- type of connection to peer: HTTPS if socket is SSL, HTTP otherwise.
'http' or 'https'.
r� ZhttpN)r] r� r? r? r@ ra b s zBaseRequest.schemec C s | j S )zyRead only property for getting HTTP method.
The value is upper-cased str like 'GET', 'POST', 'PUT' etc.
)rS r� r? r? r@ rk r s zBaseRequest.methodc C s | j S )zxRead only property for getting HTTP version of request.
Returns aiohttp.protocol.HttpVersion instance.
)rT r� r? r? r@ rl z s zBaseRequest.versionc C s( | j j�tj�}|dk r |S t�� S dS )z�Hostname of the request.
Hostname is resolved in this order:
- overridden value by .clone(host=new_host) call.
- HOST HTTP header
- socket.getfqdn() value
N)rN r7 �getr ZHOST�socketZgetfqdn)rq rb r? r? r@ rb � s
zBaseRequest.hostc C s$ t | jttf�r| jd S | jS dS )z�Remote IP of client initiated HTTP request.
The IP is resolved in this order:
- overridden value by .clone(remote=new_remote) call.
- peername of opened socket
r N)�
isinstancer^ �listr} r� r? r? r@ rc � s
zBaseRequest.remotec C s t j| j| jd�}|�| j�S )N)ra rb )r Zbuildra rb �joinrU )rq rm r? r? r@ rm � s zBaseRequest.urlc C s | j jS )z_The URL including *PATH INFO* without the host or scheme.
E.g., ``/app/blog``
)rU rv r� r? r? r@ rv � s zBaseRequest.pathc C s
t | j�S )zXThe URL including PATH_INFO and the query string.
E.g, /app/blog?id=10
)r; rU r� r? r? r@ �path_qs� s zBaseRequest.path_qsc C s | j jS )z�The URL including raw *PATH INFO* without the host or scheme.
Warning, the path is unquoted and may contains non valid URL characters
E.g., ``/my%2Fpath%7Cwith%21some%25strange%24characters``
)rN rv r� r? r? r@ �raw_path� s zBaseRequest.raw_pathzMultiDictProxy[str]c C s | j jS )z7A multidict with all the variables in the query string.)rU �queryr� r? r? r@ r� � s zBaseRequest.queryc C s | j jS )z:The query string in the URL.
E.g., id=10
)rU � query_stringr� r? r? r@ r� � s zBaseRequest.query_stringr6 c C s | j S )z4A case-insensitive multidict proxy with all headers.)rR r� r? r? r@ r7 � s zBaseRequest.headersc C s | j jS )z$A sequence of pairs for all headers.)rN r{ r� r? r? r@ r{ � s zBaseRequest.raw_headers)� _date_strrj c C s8 | dk r4t | �}|dk r4tj|dd� dtjji�S dS )z/Process a date string, return a datetime objectN� Ztzinfo)r �datetime�timezoneZutc)r� Z timetupler? r? r@ �
_http_date� s
zBaseRequest._http_datec C s | � | j�tj��S )zyThe value of If-Modified-Since HTTP header, or None.
This header is represented as a `datetime` object.
)r� r7 r� r ZIF_MODIFIED_SINCEr� r? r? r@ �if_modified_since� s z BaseRequest.if_modified_sincec C s | � | j�tj��S )z{The value of If-Unmodified-Since HTTP header, or None.
This header is represented as a `datetime` object.
)r� r7 r� r ZIF_UNMODIFIED_SINCEr� r? r? r@ �if_unmodified_since� s z BaseRequest.if_unmodified_sincec C s | � | j�tj��S )zpThe value of If-Range HTTP header, or None.
This header is represented as a `datetime` object.
)r� r7 r� r ZIF_RANGEr� r? r? r@ �if_range� s zBaseRequest.if_rangec C s
| j j S )z Is keepalive enabled by client?)rN Z should_closer� r? r? r@ �
keep_alive� s zBaseRequest.keep_alivec C s. | j �tjd�}t|�}tdd� |�� D ��S )zMReturn request cookies.
A read-only dictionary-like object.
rB c S s i | ]\}}||j �qS r? )r� )rE r� �valr? r? r@ �
<dictcomp> s z'BaseRequest.cookies.<locals>.<dictcomp>)r7 r� r ZCOOKIEr r r~ )rq �rawZparsedr? r? r@ �cookies� s zBaseRequest.cookiesc C s� | j �tj�}d\}}|dk r�z d}t�||�d \}}W n tk
rV td��Y nX |rdt|�nd}|rtt|�nd}|dkr�|dk r�| }d}|dk r�|dk r�|d7 }||kr�td��|| kr�dkr�n ntd��t ||d�S ) zMThe content of Range HTTP header.
Return a slice instance.
)NNNz^bytes=(\d*)-(\d*)$r z range not in acceptable formatr zstart cannot be after endz"No start or end of range specified)
rR r� r �RANGE�re�findall�
IndexError�
ValueError�int�slice)rq �rng�start�end�patternr? r? r@ �
http_range s( zBaseRequest.http_rangec C s | j S )zReturn raw payload stream.)rQ r� r? r? r@ �content) s zBaseRequest.contentc C s t jdtdd� | j�� S )�@Return True if request's HTTP BODY can be read, False otherwise.z$Deprecated, use .can_read_body #2005r� r� )r� r� r� rQ �at_eofr� r? r? r@ �has_body. s �zBaseRequest.has_bodyc C s | j �� S )r� )rQ r� r� r? r? r@ �
can_read_body6 s zBaseRequest.can_read_bodyc C s t | j�tk S )z6Return True if request has HTTP BODY, False otherwise.)�typerQ r! r� r? r? r@ � body_exists; s zBaseRequest.body_existsc � s | j �� s | j �� I dH q dS )zKRelease request.
Eat unread part of HTTP BODY if present.
N)rQ r� �readanyr� r? r? r@ �release@ s
zBaseRequest.releasec � sh | j dkrbt� }| j�� I dH }|�|� | jrPt|�}|| jkrPt| j|d��|sqXqt|�| _ | j S )z_Read request body if present.
Returns bytes object with full request content.
N��max_sizeZ actual_size) rW � bytearrayrQ r� �extendr[ r� r( �bytes)rq �body�chunkZ body_sizer? r? r@ �readH s
�
zBaseRequest.readc � s" | � � I dH }| jpd}|�|�S )z1Return BODY as text using encoding from .charset.Nrw )r� �charset�decode)rq Z
bytes_body�encodingr? r? r@ �text] s
zBaseRequest.text)�loads)r� rj c � s | � � I dH }||�S )zReturn BODY as JSON.N)r� )rq r� r� r? r? r@ �jsonc s zBaseRequest.jsonc � s t | j| j�S )z3Return async iterator to process BODY as multipart.)r rR rQ r� r? r? r@ � multiparth s zBaseRequest.multipartz,MultiDictProxy[Union[str, bytes, FileField]]c � sv | j dk r| j S | j| jkr.tt� �| _ | j S | j}|dkrNtt� �| _ | j S t� }|dk�r(| �� I dH }| j}|�� I dH }|dk �rfd}|j �
t j �}t
|t��r|jdk s�t�|j�r�t�� }|jdd�I dH } | �r:|�| �} |�| � |t| �7 }d| k �r|k �r&n n t||d��|jdd�I dH } q�|�d� |dk�rRd}t|j|jtt j |�||j �}
|� |j|
� n�|j d d
�I dH } |dk�s�|� d ��r�|j!d d
�} |� |j| �| �� n|� |j| � |t| �7 }d| k �r�|k �rn n t||d��nt"d��|�� I dH }q�n>| � � I dH }
|
�rf| j#�pFd } |�$t%|
�&� �| �d | d�� t|�| _ | j S )zReturn POST parameters.N)rB z!application/x-www-form-urlencoded�multipart/form-datar� r i )�sizer� zapplication/octet-streamT)r� ztext/rw )�defaultz8To decode nested multipart you need to use custom reader)Zkeep_blank_valuesr� )'rV rS � POST_METHODSr r r5 r� r[ �nextr7 r� r Z CONTENT_TYPEr� r r2 ro r3 �tempfileZ
TemporaryFileZ
read_chunkr� �writer� r( �seekr+ r r= r> �addr� �
startswithZ get_charsetr� r� r� r �rstrip)rq r5 �outr� r� Zfieldr� Zfield_ctZtmpr� Zffr� r� �datar? r? r@ �postl s�
�
� �� ��
zBaseRequest.post)r2 r� rj c C s0 | j }|dkr|S |j}|dkr$|S |�||�S )z"Extra info from protocol transportN)rO rn rp )rq r2 r� rf rn r? r? r@ rp � s zBaseRequest.get_extra_infoc C s( | j �dd��d�}d�| jj| j|�S )N�ascii�backslashreplacez <{} {} {} >)rv rx r� �formatr� r8 rS )rq Zascii_encodable_pathr? r? r@ �__repr__� s � �zBaseRequest.__repr__)�otherrj c C s t | �t |�kS rC )�id)rq r� r? r? r@ �__eq__� s zBaseRequest.__eq__c C s dS )NTr? r� r? r? r@ �__bool__� s zBaseRequest.__bool__��responserj c � s d S rC r? )rq r� r? r? r@ �
_prepare_hook� s zBaseRequest._prepare_hook)�excrj c C s | j �|� d S rC )rQ Z
set_exception)rq r� r? r? r@ �_cancel� s zBaseRequest._cancel)N)br8 r9 r: r Z
METH_PATCHZ METH_POSTZMETH_PUTZ
METH_TRACEZ METH_DELETEr� r �ATTRS� frozensetr r" r �asyncioZAbstractEventLoopr� r r r; r rr r r' r% r� �propertyrh rf Z Transportrn r� r rd r rt ri r� r� r� r� r r� �boolr� r r r� ra rk r rl rb rc rm rv r� r� r� r� r7 r& r{ � staticmethodr� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r# r$ r� r r� r� rp r� �objectr� r� r) r� �
BaseExceptionr r? r? r? r@ r* a s ��� �� 4�� 9 <
#_ r* c s� e Zd Zejedg�B Zeedd�� fdd� ZerHe edd�� fdd� Z
e e e e e e d �e e e
e e e d d
�� fd d �Zed
d�dd��Zedd�dd��Zeed�dd��Zedd�dd�Z� ZS )r, � _match_infoN)�argsr� rj c s t � j||� d | _d S rC )�superrr r )rq r
r� �r� r? r@ rr � s zRequest.__init__)r2 r� rj c s8 || j kr&tjd�| jj|�tdd� t� �||� d S )Nz-Setting custom {}.{} attribute is discouragedr� r� ) r r� r� r� r� r8 r� r � __setattr__)rq r2 r� r r? r@ r
� s
��zRequest.__setattr__rs ru c s. t � j||||||d�}tt|�}| j|_|S )Nrs )r r� r r, r ) rq rk rt r7 ra rb rc ZretZnew_retr r? r@ r� s
�
z
Request.cloner/ r� c C s | j }|dk st�|S )zResult of route resolving.N)r ro �rq �
match_infor? r? r@ r s zRequest.match_infor- c C s | j }|dk st�|jS )zApplication instance.N)r ro Z current_appr r? r? r@ �app" s z Request.appc C sH | j }|d k st�|j}| j}|�|�}tt|d |d � ��}t|�S )Nr )r ro Zappsr �indexr� �reversedr )rq r Zlstr �idxZsublistr? r? r@ � config_dict) s
zRequest.config_dictr� c � s6 | j }|d krd S |jD ]}|j�| |�I d H qd S rC )r Z_appsZon_response_prepare�send)rq r� r r r? r? r@ r� 3 s
zRequest._prepare_hook)r8 r9 r: r* r r r rr r r; r
r r' r% r� r r r r r r r) r� �
__classcell__r? r? r r@ r, � s4
�� r, )\r r� r= r� r� �stringr� r� r� Z email.utilsr Z http.cookiesr r �typingr r r r r r
r r r
r Z urllib.parser �attrZ multidictr r r r Zyarlr rB r �abcr Zhelpersr r r r r Z http_parserr Z http_writerr r� r r Zstreamsr! r" Ztypedefsr# r$ r% r& r' Zweb_exceptionsr( Z web_responser) �__all__Zweb_appr- Z web_protocolr. Zweb_urldispatcherr/ �sr+ ZdigitsZ
ascii_lettersZ_TCHARZ_TOKENr� r� r} �rangeZ_QDTEXTZ _QUOTED_PAIRZ_QUOTED_STRINGZ_FORWARDED_PAIR�compiler� r� r; r* r, r? r? r? r@ �<module> sp 0 � � �