관리-도구
편집 파일: web_request.cpython-37.pyc
B �k�a�l � @ s� U d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl m Z d dlm Z d dl m Z mZmZmZmZmZmZmZmZmZmZ d dlmZ d dlZd dlm Z m Z m Z m Z d dl m!Z! dd l"m#Z# dd l$m%Z% dd l&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/ dd l0m1Z1 dd l2m3Z3 ddl4m5Z5m6Z6 ddl7m8Z8m9Z9 ddl:m;Z;m<Z<m=Z=m>Z>m?Z?m@Z@ ddlAmBZB ddlCmDZD dZEe �r�ddlFmGZG ddlHmIZI ddlJmKZK ejLdddd�G dd� d��ZMejNejO d ZPe<eQ eRd < d eP� d �ZSe<eQ eRd < d �Td!�Ud"d#� d$eVeWd%d&�� D ���ZXe<eQ eRd'< d(ZYe<eQ eRd)< d*jTeXeYd+�ZZe<eQ eRd,< d-jTeSeZd.�Z[e<eQ eRd/< e�\d0�Z]e<eeQ eRd1< e�\e[�Z^e<eeQ eRd2< G d3d4� d4eeQef e,�Z_G d5d6� d6e_�Z`dS )7� N)� SimpleCookie)�MappingProxyType) � TYPE_CHECKING�Any�Dict�Iterator�Mapping�MutableMapping�Optional�Pattern�Tuple�Union�cast)� parse_qsl)� CIMultiDict�CIMultiDictProxy� MultiDict�MultiDictProxy)�URL� )�hdrs)�AbstractStreamWriter) �DEBUG�ETAG_ANY�LIST_QUOTED_ETAG_RE� ChainMapProxy�ETag� HeadersMixin�parse_http_date�reify�sentinel)�RawRequestMessage)� HttpVersion)�BodyPartReader�MultipartReader)�EmptyStreamReader� StreamReader)�DEFAULT_JSON_DECODER�Final� 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 )r0 �name�filename�file� content_typezCIMultiDictProxy[str]�headersN)�__name__� __module__� __qualname__�str�__annotations__�io�BufferedReader� rC rC �F/opt/alt/python37/lib64/python3.7/site-packages/aiohttp/web_request.pyr0 D s r0 z!#$%&'*+.^_`|~-�_TCHAR�[z]+�_TOKENz[{}]� c c s | ]}t |�V qd S )N)�chr)�.0�crC rC rD � <genexpr>S s rL )� � �! �# � �_QDTEXTz \\[\t !-~]� _QUOTED_PAIRz "(?:{quoted_pair}|{qdtext})*")ZqdtextZ quoted_pair�_QUOTED_STRINGz0({token})=({token}|{quoted_string})(:\d{{1,4}})?)�tokenZ quoted_string�_FORWARDED_PAIRz \\([\t !-~])�_QUOTED_PAIR_REPLACE_RE�_FORWARDED_PAIR_REc @ s� 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@e"eeAjA d �dZd[��ZBe"eeAjA d �d\d]��ZCeDee+eE d^�d_d`��ZFeGee ee/eEd;f da�dbdc��ZHe"ee/eEd;f d �ddde��ZIe"ee/eEd;f d �dfdg��ZJe"eeAjA d �dhdi��ZKe"e-d �djdk��ZLe"e0eef d �dldm��ZMe"eNd �dndo��ZOe"ed �dpdq��ZPe e-d �drds��ZQe e-d �dtdu��ZRe"e-d �dvdw��ZSdd �dxdy�ZTeUd �dzd{�ZVed �d|d}�ZWeXd~�eYed�d�d��ZZe[d �d�d��Z\d�d �d�d��Z]d�eeed��d�d��Z^ed �d�d��Z_e`e-d��d�d��Zae-d �d�d��Zbecdd��d�d��Zdeedd��d�d��ZfdS )�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�remoter3 zasyncio.Task[None]) �message�payload�protocol�payload_writer�task�looprj rk rl rm rn �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 sslcontextZpeernamerl rm rn )rY rZ r[ r\ r; r] �methodr^ �versionr_ �urlr` ra rb rc rd re rf rg � transport�AssertionError�get_extra_inforh ri ) �selfro rp rq rr rs rt rj rk rl rm rn ry rC rC rD �__init__� s6 zBaseRequest.__init__)rv �rel_urlr; rl rm rn )rv r~ r; rl rm rn ru 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 contentrv rx �pathr; c s s& | ] \}}|� d �|� d �fV qdS )zutf-8N)�encode)rJ �k�vrC rC rD rL � s z$BaseRequest.clone.<locals>.<genexpr>� raw_headersrl rm rn )rj rk )rb � RuntimeErrorr r r? r r �tuple�itemsrY �_replace� __class__r\ rZ r[ re rg rf rc �copy) r| rv r~ r; rl rm rn �dctZnew_urlro �kwargsrC rC rD �clone� s> zBaseRequest.clone)ru c C s | j S )N)re )r| rC rC rD rs � s zBaseRequest.taskc C s | j S )N)rZ )r| rC rC rD rq � s zBaseRequest.protocolc C s | j d krd S | j jS )N)rZ ry )r| rC rC rD ry � s zBaseRequest.transportc C s | j S )N)r[ )r| rC rC rD �writer s zBaseRequest.writerc C s t jdtdd� | jS )Nz Request.message is deprecated� )� stacklevel)�warnings�warn�DeprecationWarningrY )r| rC rC rD ro s zBaseRequest.messagec C s | j S )N)r` )r| rC rC rD r~ s zBaseRequest.rel_urlc C s t jdtdd� | jS )Nz#request.loop property is deprecated� )r� )r� r� r� rg )r| rC rC rD rt s zBaseRequest.loop)�keyru c C s | j | S )N)rc )r| r� rC rC rD � __getitem__ s zBaseRequest.__getitem__)r� �valueru c C s || j |< d S )N)rc )r| r� r� rC rC rD � __setitem__ s zBaseRequest.__setitem__c C s | j |= d S )N)rc )r| r� rC rC rD � __delitem__ s zBaseRequest.__delitem__c C s t | j�S )N)�lenrc )r| rC rC rD �__len__# s zBaseRequest.__len__c C s t | j�S )N)�iterrc )r| rC rC rD �__iter__& s zBaseRequest.__iter__c C s | j dkS )z5A bool indicating if the request is handled with SSL.�https)rl )r| rC rC rD �secure+ s zBaseRequest.secure.c C sf g }�xV| j j�tjd�D �]>}t|�}d}d}i }|�t�|�� �xd| kr^|k �rXn n�t � ||�}|dk r�|r�|� d|�}n\|� � \}} } | d dkr�t �d| dd � �} | r�| | 7 } | ||�� < |t|�d��7 }d }qH|| dk�rd}i }|�t�|�� |d7 }qH|| d k�r2d}|d7 }qH|| d k�rJ|d7 }qH|� d|�}qHW qW t|�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 rC r FN�,�"z\1r ���T�;z )rY r; Zgetallr Z FORWARDEDr� �append�typesr rX �match�find�groupsrW �sub�lower�groupr� ) r| ZelemsZ field_value�length�posZneed_separator�elemr� r7 r� �portrC rC rD � forwarded0 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� �httpN)rh )r| rC rC rD rl m 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. )r^ )r| rC rC rD rv } s zBaseRequest.methodc C s | j S )zxRead only property for getting HTTP version of request. Returns aiohttp.protocol.HttpVersion instance. )r_ )r| rC rC rD rw � s zBaseRequest.versionc C s$ | j j�tj�}|dk r |S t�� S )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)rY r; �getr ZHOST�socket�getfqdn)r| rm rC rC rD rm � s zBaseRequest.hostc C s6 | j dkrdS t| j ttf�r,t| j d �S t| j �S )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 Nr )ri � isinstance�listr� r? )r| rC rC rD rn � s zBaseRequest.remotec C s t j| j| jd�}|�| j�S )N)rl rm )r �buildrl rm �joinr` )r| rx rC rC rD rx � s zBaseRequest.urlc C s | j jS )z_The URL including *PATH INFO* without the host or scheme. E.g., ``/app/blog`` )r` r )r| rC rC rD r � s zBaseRequest.pathc C s t | j�S )zXThe URL including PATH_INFO and the query string. E.g, /app/blog?id=10 )r? r` )r| rC rC rD �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`` )rY r )r| rC rC rD �raw_path� s zBaseRequest.raw_pathzMultiDictProxy[str]c C s t | jj�S )z7A multidict with all the variables in the query string.)r r` �query)r| rC rC rD r� � s zBaseRequest.queryc C s | j jS )z:The query string in the URL. E.g., id=10 )r` � query_string)r| rC rC rD r� � s zBaseRequest.query_stringzCIMultiDictProxy[str]c C s | j S )z4A case-insensitive multidict proxy with all headers.)r] )r| rC rC rD r; � s zBaseRequest.headersc C s | j jS )z$A sequence of pairs for all headers.)rY r� )r| rC rC rD r� � s zBaseRequest.raw_headersc C s t | j�tj��S )zyThe value of If-Modified-Since HTTP header, or None. This header is represented as a `datetime` object. )r r; r� r ZIF_MODIFIED_SINCE)r| rC rC rD �if_modified_since� s z BaseRequest.if_modified_sincec C s t | j�tj��S )z{The value of If-Unmodified-Since HTTP header, or None. This header is represented as a `datetime` object. )r r; r� r ZIF_UNMODIFIED_SINCE)r| rC rC rD �if_unmodified_since� s z BaseRequest.if_unmodified_since)� etag_headerru c c s\ | t krtdt d�V n@x>t�| �D ]0}|�ddd�\}}}|rBP tt|�|d�V q$W dS )z'Extract `ETag` objects from raw header.F)�is_weakr� r� r� � N)r r r �finditerr� �bool)r� r� r� r� ZgarbagerC rC rD � _etag_values� s zBaseRequest._etag_values)� header_valueru c C s |sd S t | �|��S )N)r� r� )�clsr� rC rC rD �_if_match_or_none_impl s z"BaseRequest._if_match_or_none_implc C s | � | j�tj��S )zxThe value of If-Match HTTP header, or None. This header is represented as a `tuple` of `ETag` objects. )r� r; r� r ZIF_MATCH)r| rC rC rD �if_match s zBaseRequest.if_matchc C s | � | j�tj��S )z}The value of If-None-Match HTTP header, or None. This header is represented as a `tuple` of `ETag` objects. )r� r; r� r Z IF_NONE_MATCH)r| rC rC rD � if_none_match s zBaseRequest.if_none_matchc C s t | j�tj��S )zpThe value of If-Range HTTP header, or None. This header is represented as a `datetime` object. )r r; r� r ZIF_RANGE)r| rC rC rD �if_range s zBaseRequest.if_rangec C s | j j S )z Is keepalive enabled by client?)rY Z should_close)r| rC rC rD � keep_alive' s zBaseRequest.keep_alivec C s. | j �tjd�}t|�}tdd� |�� D ��S )zMReturn request cookies. A read-only dictionary-like object. rH c S s i | ]\}}|j |�qS rC )r� )rJ r� �valrC rC rD � <dictcomp>4 s z'BaseRequest.cookies.<locals>.<dictcomp>)r; r� r ZCOOKIEr r r� )r| �raw�parsedrC rC rD �cookies, s zBaseRequest.cookiesc C s� | j �tj�}d\}}|dk r�y 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) r] r� r �RANGE�re�findall� IndexError� ValueError�int�slice)r| �rng�start�end�patternrC rC rD � http_range6 s( zBaseRequest.http_rangec C s | j S )zReturn raw payload stream.)r\ )r| rC rC rD �contentZ s zBaseRequest.contentc C s t jdtdd� | j�� S )z@Return True if request's HTTP BODY can be read, False otherwise.z$Deprecated, use .can_read_body #2005r� )r� )r� r� r� r\ �at_eof)r| rC rC rD �has_body_ s zBaseRequest.has_bodyc C s | j �� S )z@Return True if request's HTTP BODY can be read, False otherwise.)r\ r� )r| rC rC rD � can_read_bodyg s zBaseRequest.can_read_bodyc C s t | j�tk S )z6Return True if request has HTTP BODY, False otherwise.)�typer\ r% )r| rC rC rD � body_existsl s zBaseRequest.body_existsc � s$ x | j �� s | j �� I dH qW dS )zKRelease request. Eat unread part of HTTP BODY if present. N)r\ r� �readany)r| rC rC rD �releaseq s zBaseRequest.releasec � sl | j dkrft� }xJ| j�� I dH }|�|� | jrRt|�}|| jkrRt| j|d��|sP qW t|�| _ | j S )z_Read request body if present. Returns bytes object with full request content. N)�max_size� actual_size) rb � bytearrayr\ r� �extendrf r� r- �bytes)r| �body�chunkZ body_sizerC rC rD �ready s zBaseRequest.readc � s" | � � I dH }| jpd}|�|�S )z1Return BODY as text using encoding from .charset.Nzutf-8)r� �charset�decode)r| Z bytes_body�encodingrC rC rD �text� s zBaseRequest.text)�loads)r� ru c � s | � � I dH }||�S )zReturn BODY as JSON.N)r� )r| r� r� rC rC rD �json� s zBaseRequest.jsonc � s t | j| j�S )z3Return async iterator to process BODY as multipart.)r$ r] r\ )r| rC rC rD � multipart� s zBaseRequest.multipartz,MultiDictProxy[Union[str, bytes, FileField]]c � s� | j dk r| j S | j| jkr.tt� �| _ | j S | j}|dkrNtt� �| _ | j S t� }|dk�r:| �� I dH }| j}|�� I dH }�x�|dk �r6d}|j � t j �}t |t��r |jdk s�t�|j�r�t�� }|jdd�I dH } xl| �rH|�| �} |�| � |t| �7 }d| k �r |k �r4n n|�� t||d��|jdd�I dH } q�W |�d� |dk�rbd}t|j|jt t 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 �r&n n t||d��nt#d��|�� I dH }q�W n>| � � I dH } | �rx| j$�pXd } |�%t&| �'� �| �d | d�� t|�| _ | j S )zReturn POST parameters.N)rH z!application/x-www-form-urlencodedzmultipart/form-datazmultipart/form-datar i )�size)r� r� zapplication/octet-streamT)r� ztext/zutf-8)�defaultz8To decode nested multipart you need to use custom reader)�keep_blank_valuesr� )(ra r^ � POST_METHODSr r r: r� rf �nextr; r� r Z CONTENT_TYPEr� r# r7 rz r8 �tempfile� TemporaryFileZ read_chunkr� �writer� �closer- �seekr0 r rA rB �addr� � startswith� get_charsetr� r� r� r �rstrip)r| r: �outr� r� �fieldr� Zfield_ct�tmpr� Zffr� r� �datarC rC rD �post� s� zBaseRequest.post)r7 r� ru c C s0 | j }|dkr|S |j}|dkr$|S |�||�S )z"Extra info from protocol transportN)rZ ry r{ )r| r7 r� rq ry rC rC rD r{ � s zBaseRequest.get_extra_infoc C s( | j �dd��d�}d�| jj| j|�S )N�ascii�backslashreplacez <{} {} {} >)r r� r� �formatr� r< r^ )r| Zascii_encodable_pathrC rC rD �__repr__ s zBaseRequest.__repr__)�otherru c C s t | �t |�kS )N)�id)r| r rC rC rD �__eq__ s zBaseRequest.__eq__c C s dS )NTrC )r| rC rC rD �__bool__ s zBaseRequest.__bool__)�responseru c � s d S )NrC )r| r rC rC rD � _prepare_hook s zBaseRequest._prepare_hook)�excru c C s | j �|� d S )N)r\ � set_exception)r| r rC rC rD �_cancel s zBaseRequest._cancel)N)gr< r= r> r Z METH_PATCHZ METH_POSTZMETH_PUTZ METH_TRACEZ METH_DELETEr� r �ATTRS� frozensetr! r& r �asyncioZAbstractEventLoopr� r r r? r r} r r, r* r� �propertyrs rq Z Transportry r� r ro r r~ rt r� r� r� r� r r� r� r� r r r� rl rv r" rw rm rn rx r r� r� r� r� r; r+ r� �datetimer� r� � staticmethodr r� � classmethodr� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r' r) r� r$ r� r r{ r �objectr r r. r � BaseExceptionr rC rC rC rD r/ n s� 6&. < #` 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 )r1 � _match_infoN)�argsr� ru c s t � j||� d | _d S )N)�superr} r )r| r r� )r� rC rD r} " s zRequest.__init__)r7 r� ru c s8 || j kr&tjd�| jj|�tdd� t� �||� d S )Nz-Setting custom {}.{} attribute is discouragedr� )r� ) r r� r� r r� r< r� r � __setattr__)r| r7 r� )r� rC rD r - s zRequest.__setattr__)rv r~ r; rl rm rn )rv r~ r; rl rm rn ru c s. t � j||||||d�}tt|�}| j|_|S )N)rv r~ r; rl rm rn )r r� r r1 r ) r| rv r~ r; rl rm rn �retZnew_ret)r� rC rD r� 7 s z Request.cloner4 )ru c C s | j }|dk st�|S )zResult of route resolving.N)r rz )r| � match_inforC rC rD r! M s zRequest.match_infor2 c C s | j }|dk st�|jS )zApplication instance.N)r rz Z current_app)r| r! rC rC rD �appT s z Request.appc C sH | j }|d k st�|j}| j}|�|�}tt|d |d � ��}t|�S )Nr )r rz Zappsr" �indexr� �reversedr )r| r! �lstr" �idxZsublistrC rC rD � config_dict[ s zRequest.config_dict)r ru c � s: | j }|d krd S x"|jD ]}|j�| |�I d H qW d S )N)r Z_appsZon_response_prepare�send)r| r r! r" rC rC rD r e s zRequest._prepare_hook)r< r= r> r/ r r r r} r r? r r r, r* r� r r! r r" r r' r. r � __classcell__rC rC )r� rD r1 s$ r1 )ar r rA r� r� �stringr� r� r� Z http.cookiesr r �typingr r r r r r r r r r r � urllib.parser �attrZ multidictr r r r Zyarlr rH r �abcr Zhelpersr r r r r r r r r Z http_parserr! Z http_writerr" r� r# r$ Zstreamsr% r& Ztypedefsr' r( r) r* r+ r, Zweb_exceptionsr- Z web_responser. �__all__Zweb_appr2 Z web_protocolr3 Zweb_urldispatcherr4 �sr0 �digits� ascii_lettersrE r? r@ rG r r� r� �rangerR rS rT rV �compilerW rX r/ r1 rC rC rC rD �<module> sd 4 , 0 5