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@ dZAerd dlBmCZC d dlDmEZE d dlFmGZG ejHddddG dd dZIejJejK d ZLd eL d ZMd Nd Od!d" d#ePeQd$d% D ZRd&ZSd'jNeReSd(ZTd)jNeMeTd*ZUeVd+ZWeVeUZXG d,d- d-eeYef e*ZZG d.d/ d/eZZ[dS )0 N) parsedate) SimpleCookie)MappingProxyType)
TYPE_CHECKINGAnyDictIteratorMappingMutableMappingOptionalTupleUnioncast) parse_qsl) CIMultiDictCIMultiDictProxy MultiDictMultiDictProxy)URL )hdrs)AbstractStreamWriter)DEBUG
ChainMapProxy HeadersMixinreifysentinel)RawRequestMessage) HttpVersion)BodyPartReaderMultipartReader)EmptyStreamReader StreamReader)DEFAULT_JSON_DECODER JSONDecoder LooseHeaders
RawHeadersStrOrURL)HTTPRequestEntityTooLarge)StreamResponse) BaseRequest FileFieldRequest) Application)RequestHandler)UrlMappingMatchInfoT)Z auto_attribsfrozenslotsc @ s8 e Zd ZU eed< eed< ejed< eed< ded< dS )r+ namefilenamefile content_typeCIMultiDictProxy[str]headersN)__name__
__module__ __qualname__str__annotations__ioBufferedReader 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).0cr? 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
ddddgB Z dddddde
ededejeeeeef ee ee ee dd ddZeeeeeedeeeeeed dd 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'eedd0d1d2Z(edd-d3d4Z)ed d5d6Z*e+e d d7d8Z,e"e-d d9d:Z.e"e/e0eef d;f d d<d=Z1e"ed d>d?Z2e"ed d@dAZ3e"e4d dBdCZ5e"ed dDdEZ6e"ee d dFdGZ7e"e$d dHdIZ8e"ed dJdKZ9e"ed dLdMZ:e"ed dNdOZ;e"dPd dQdRZ<e"ed dSdTZ=e"dUd dVdWZ>e"e?d dXdYZ@eAee eeBjB dZd[d\ZCe"eeBjB d d]d^ZDe"eeBjB d d_d`ZEe"eeBjB d dadbZFe"e-d dcddZGe"e0eef d dedfZHe"eId dgdhZJe"ed didjZKe e-d dkdlZLe e-d dmdnZMe"e-d dodpZNdd dqdrZOePd dsdtZQed dudvZReSdweTedxdydzZUeVd d{d|ZWd}d d~dZXdeeedddZYed ddZZe[e-dddZ\e-d ddZ]e^ddddZ_e`ddddZadS )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_sizestateschemehostremoter. zasyncio.Task[None]) messagepayloadprotocolpayload_writertaskloopr_ r` ra rb rc returnc
C s |d kr i }|| _ || _|| _|| _|j| _|j| _|j| _ |j
| _ d | _ d | _
|| _i | _|| _|| _|| _| jj} | d k st| 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\ transportAssertionErrorget_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 rtdi }|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 kvr? r? r@ rG s z$BaseRequest.clone.<locals>.<genexpr> raw_headersra rb rc )r_ r` )rW RuntimeErrorr r r; r r tupleitemsrN _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.clonerj 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)warningswarnDeprecationWarningrN 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 | jS rC )lenrX r r? r? r@ __len__ s zBaseRequest.__len__c C s
t | jS 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 jtjdD ]6}t|}d}d}i }|t| d| krT|k rn qt
||}|dk r|r~| d|}n\| \}} }
| d dkrt
d| dd } |
r| |
7 } | || < |t|d7 }d
}q@|| dkr d}i }|t| |d7 }q@|| d kr(d}|d7 }q@|| d kr@|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 appendtypesr _FORWARDED_PAIR_REmatchfindgroups_QUOTED_PAIR_REPLACE_REsublowergroupr} ) rq ZelemsZ field_valueZlengthposZneed_separatorelemr 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 jtj}|dk r |S t S dS )zHostname 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 ZHOSTsocketZgetfqdn)rq rb r? r? r@ rb s
zBaseRequest.hostc C s$ t | jttfr| jd S | jS dS )zRemote 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}|| jS )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 | jS )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 )zThe 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 dtjjiS dS )z/Process a date string, return a datetime objectN Ztzinfo)r datetimetimezoneZutc)r Z timetupler? r? r@
_http_date s
zBaseRequest._http_datec C s | | jtjS )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 | | jtjS )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 | | jtjS )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 rz d}t||d \}}W n tk
rV tdY nX |rdt|nd}|rtt|nd}|dkr|dk r| }d}|dk r|dk r|d7 }||krtd|| krdkrn ntdt ||dS ) 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 RANGErefindall
IndexError
ValueErrorintslice)rq rngstartendpatternr? 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 | jtk 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.
Nmax_sizeZ actual_size) rW bytearrayrQ r extendr[ r r( bytes)rq bodychunkZ body_sizer? r? r@ readH s
zBaseRequest.readc s" | I dH }| jpd}||S )z1Return BODY as text using encoding from .charset.Nrw )r charsetdecode)rq Z
bytes_bodyencodingr? 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| jS )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 }|dkr(| I dH }| j}| I dH }|dk rfd}|j
t j }t
|tr|jdk st|jrt }|jddI dH } | r:|| } || |t| 7 }d| k r|k r&n n t||d|jddI dH } q|d |dkrRd}t|j|jtt j |||j }
| |j|
n|j d d
I dH } |dks| d r|j!d d
} | |j| | n| |j| |t| 7 }d| k r|k rn n t||dnt"d| I dH }qn>| I dH }
|
rf| j#pFd } |$t%|
& | d | d t|| _ | j S )zReturn POST parameters.N)rB z!application/x-www-form-urlencodedmultipart/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 ddd}d| jj| j|S )Nasciibackslashreplacez <{} {} {} >)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 ZejedgB Zeedd fdd ZerHe edd fdd Z
e e e e e e d e e e
e e e d d
fd d Zed
dddZeddddZeedddZeddddZ 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_preparesend)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_PAIRcompiler r r; r* r, r? r? r? r@ <module> sp 0