U
'7`Zf @ s d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
m Z d dl m
Z
d dlmZmZ d dlmZmZmZmZmZmZmZmZmZmZ d dl m Z m Z ddl m Z m!Z! dd l"m#Z# dd
l$m%Z%m&Z&m'Z'm(Z( dd l)m*Z*m+Z+m,Z,m-Z- dd l!m.Z. dd
l/m0Z0m1Z1 dZ2er<ddl3m4Z4 ee5ef Z6nej"jZ6e%sTdej7d< G dd dej8Z9G dd de6e&Z:G dd de:Z;e(fddddddej<deee5 ee= e>ee5 ee1 e5e0e;d d d Z?dS ) N)Executor) parsedate)Morsel SimpleCookie)
TYPE_CHECKINGAnyDictIteratorMappingMutableMappingOptionalTupleUnioncast) CIMultiDictistr )hdrspayload)AbstractStreamWriter)PY_38 HeadersMixinrfc822_formatted_timesentinel) RESPONSESSERVER_SOFTWARE
HttpVersion10
HttpVersion11)Payload) JSONEncoder LooseHeaders)
ContentCodingStreamResponseResponse
json_response) BaseRequestZSameSitesamesitec @ s e Zd ZdZdZdZdS )r! deflategzipidentityN)__name__
__module__ __qualname__r' r( r) r- r- G/opt/alt/python38/lib64/python3.8/site-packages/aiohttp/web_response.pyr! 4 s r! c
s e Zd ZdZddddeee ee ddddZe e
dd d
Z e d dd d
Z e edddZ
e e
dddZe e
dddZe edddZdefeee eeeeef f ddddZe ee
dddZdddd Ze edd d Ze edd d Zdpee dd!d"d#Zdqeee
ef dd$d%d&Z e d'dd(d)Z e d*dd+d,Z dddd-ddddd.eeee ee eeeef eee
ee
ee ee dd/ d0d1Z dd-d2eee edd3d4d5Z e ee d fd6d7 Z!e!j"ee dd8d9d7Z!e ed fd:d; Z#e#j"edd8d<d;Z#e ee d fd=d> Z$e$j"ee dd8d?d>Z$e ee%j% dd@dAZ&e&j"eeee'e%j%ef dd8dBdAZ&e(j)fe*ddCdDdEZ+eddFdGdHZ,dIddJdKdLZ-dIee. dJdMdNZ/dIe.dJdOdPZ0dddQdRZ1dddSdTZ2e3ddUdVdWZ4dddXdYZ5dre3ddUd[d\Z6edd]d^Z7ee8d_d`daZ9ee8ddbdcddZ:edd_dedfZ;eddgdhZ<e=e ddidjZ>eddkdlZ?e@e
dmdndoZA ZBS )sr" T Nstatusreasonheaders)r1 r2 r3 returnc C sp d | _ d | _d| _d| _d | _t | _d | _d | _d| _ d| _
i | _ |d k rXt || _
nt | _
| || d S )NFr )_body _keep_alive_chunked _compression_compression_forcer _cookies_req_payload_writer _eof_sent _body_length_stater _headers
set_status)selfr1 r2 r3 r- r- r. __init__G s zStreamResponse.__init__r4 c C s
| j d k S N)r< rB r- r- r. preparedb s zStreamResponse.preparedzasyncio.Task[None]c C s t | jdd S )Ntask)getattrr; rF r- r- r. rH f s zStreamResponse.taskc C s | j S rE )_statusrF r- r- r. r1 j s zStreamResponse.statusc C s | j S rE )r7 rF r- r- r. chunkedn s zStreamResponse.chunkedc C s | j S rE )r8 rF r- r- r. compressionr s zStreamResponse.compressionc C s | j S rE )_reasonrF r- r- r. r2 v s zStreamResponse.reason)r1 r2
_RESPONSESr4 c C sV | j rtdt|| _|d krLz|| j d }W n tk
rJ d}Y nX || _d S )NzGCannot change the response status code after the headers have been sentr )rG AssertionErrorintrJ ExceptionrM )rB r1 r2 rN r- r- r. rA z s
zStreamResponse.set_statusc C s | j S rE r6 rF r- r- r.
keep_alive s zStreamResponse.keep_alivec C s
d| _ d S )NFrS rF r- r- r. force_close s zStreamResponse.force_closec C s | j S rE )r> rF r- r- r. body_length s zStreamResponse.body_lengthc C s t dt | jst| jjS )Nzoutput_length is deprecated)warningswarnDeprecationWarningr< rP Z buffer_sizerF r- r- r.
output_length s
z StreamResponse.output_length)
chunk_sizer4 c C s2 d| _ tj| jkrtd|dk r.tdt dS )z,Enables automatic chunked transfer encoding.Tz>You can't enable chunked encoding when a content length is setNz Chunk size is deprecated #1615)r7 r CONTENT_LENGTHr@ RuntimeErrorrW rX rY )rB r[ r- r- r. enable_chunked_encoding s z&StreamResponse.enable_chunked_encoding)forcer4 c C sT t |tkr*|rtjntj}tdt n|dk rDt|tsDt dd| _
|| _ dS )z&Enables response compression encoding.z+Using boolean for force is deprecated #3318Nz1force should one of None, bool or ContentEncodingT) typeboolr! r' r) rW rX rY
isinstancerP r8 r9 )rB r_ r- r- r. enable_compression s z!StreamResponse.enable_compressionzCIMultiDict[str]c C s | j S rE )r@ rF r- r- r. r3 s zStreamResponse.headerszSimpleCookie[str]c C s | j S rE )r: rF r- r- r. cookies s zStreamResponse.cookies/)expiresdomainmax_agepathsecurehttponlyversionr& ) namevaluerf rg rh ri rj rk rl r& r4 c
C s | j |} | dk r,| jdkr,| j |d || j |< | j | } |dk rR|| d< n| ddkrf| d= |dk rv|| d< |dk rt|| d< nd| kr| d= || d< |dk r|| d< |dk r|| d < | dk r| | d
< |
dk r|
| d < dS ) zSet or update response cookie.
Sets new cookie or updates existent with new value.
Also updates only those params which are not None.
NrO rf Thu, 01 Jan 1970 00:00:00 GMTrg zmax-ageri rj rk rl r& )r: getZ coded_valuepopstr)
rB rm rn rf rg rh ri rj rk rl r& oldcr- r- r.
set_cookie s0
zStreamResponse.set_cookie)rg ri )rm rg ri r4 c C s( | j |d | j|ddd||d dS )zBDelete cookie.
Creates new empty expired cookie.
NrO r ro )rh rf rg ri )r: rq ru )rB rm rg ri r- r- r.
del_cookie s zStreamResponse.del_cookiec s t jS rE )supercontent_lengthrF __class__r- r. rx s z StreamResponse.content_lengthrn r4 c C sD |d k r0t |}| jr tdt|| jtj< n| jtjd d S )Nz<You can't set content length when chunked encoding is enable)rQ r7 r] rr r@ r r\ rq rB rn r- r- r. rx s c s t jS rE )rw content_typerF ry r- r. r} s zStreamResponse.content_typec C s | j t|| _| d S rE )r} rr
_content_type _generate_content_type_headerr| r- r- r. r} s
c s t jS rE )rw charsetrF ry r- r. r # s zStreamResponse.charsetc C sZ | j }|dkrtd| jd k s$t|d kr<| jdd nt| | jd< | d S )Napplication/octet-streamzYSetting charset for application/octet-stream doesn't make sense, setup content_type firstr )r} r]
_content_dictrP rq rr lowerr )rB rn ctyper- r- r. r ( s c C sF | j tj}|dk rBt|}|dk rBtj|dd dtjjiS dS )zuThe value of Last-Modified HTTP header, or None.
This header is represented as a `datetime` object.
N Ztzinfo)r@ rp r
LAST_MODIFIEDr datetimetimezoneZutc)rB ZhttpdateZ timetupler- r- r.
last_modified7 s z StreamResponse.last_modifiedc C s |d kr| j tjd nlt|ttfrJtdt t
|| j tj< n<t|t j rptd|
| j tj< nt|tr|| j tj< d S )Nz%a, %d %b %Y %H:%M:%S GMT)r@ rq r r rb rQ floattimestrftimegmtimemathZceilr Z utctimetuplerr r| r- r- r. r D s
) CONTENT_TYPEr4 c C s^ | j d k st| jd k s tddd | j D }|rJ| jd | }n| j}|| j|< d S )Nz; c s s | ]\}}| d | V qdS )=Nr- ).0kvr- r- r. <genexpr>Z s z?StreamResponse._generate_content_type_header.<locals>.<genexpr>)r rP r~ joinitemsr@ )rB r Zparamsr r- r- r. r U s z,StreamResponse._generate_content_type_headercodingr4 c sH |t jkrD| jd k st|j| jtj< | j|j | j tj
d d S rE ) r! r) r< rP rn r@ r CONTENT_ENCODINGrc Zpopallr\ )rB r r- r- r. _do_start_compressiona s
z$StreamResponse._do_start_compressionr% requestr4 c s\ | j r| | j I d H n>|jtjd }tD ]$}|j|kr2| |I d H d S q2d S )NrO ) r9 r r3 rp r ZACCEPT_ENCODINGr r! rn )rB r Zaccept_encodingr r- r- r. _start_compressionj s
z!StreamResponse._start_compressionc s* | j r
d S | jd k r| jS | |I d H S rE )r= r< _startrB r r- r- r. preparet s
zStreamResponse.preparec sB || _ |j }| _| I d H || I d H | I d H |S rE )r; r< _prepare_headersZ
_prepare_hook_write_headers)rB r writerr- r- r. r | s zStreamResponse._startc s | j }|d k st| j}|d k s$t| j}|d kr8|j}|| _|j}| j}| j D ]&}|j dddd }|
t j | qT| j
r| |I d H | jr|tkrtd|j| d|t j< t j|kr|t j= nr| jrH| j|_|jd kr*|tkr$| d|t j< t j|kr(|t j= nd}n |tkrH| jdkrH|t j= |t jd |t j t |t j t t j |kr|r|t!krd |t j < n|tkrd
|t j < d S ) NrO )headerr z@Using chunked encoding is forbidden for HTTP/{0.major}.{0.minor}rK F)d e f g r z
keep-aliveclose)"r; rP r< r6 rT rl r@ r: valuesoutputaddr Z
SET_COOKIEr8 r r7 r r] formatZenable_chunkingZTRANSFER_ENCODINGr\
_length_checkrx Zlengthr1
setdefaultr ZDATEr ZSERVERr Z
CONNECTIONr )rB r r rT rl r3 Zcookiern r- r- r. r s\
z StreamResponse._prepare_headersc s^ | j }|d k st| j}|d k s$t|j}d|d |d | j| j}||| jI d H d S )NzHTTP/{}.{} {} {}r r ) r; rP r< rl r rJ rM Z
write_headersr@ )rB r r rl Z status_liner- r- r. r s z StreamResponse._write_headersdatar4 c sV t |tttfs tdt| | jr.td| jd kr@td| j |I d H d S )N#data argument must be byte-ish (%r)z%Cannot call write() after write_eof()z$Cannot call write() before prepare())
rb bytes bytearray
memoryviewrP r` r= r] r< writerB r r- r- r. r s
zStreamResponse.writec sD | j rtd| jd k s tdtjdtdd | j I d H d S )NzEOF has already been sent Response has not been startedz2drain method is deprecated, use await resp.write() )
stacklevel)r= rP r< rW rX rY drainrF r- r- r. r s zStreamResponse.drain c sn t |tttfs tdt| | jr*d S | jd k s<td| j|I d H d| _d | _ | jj
| _ d | _d S )Nr r T) rb r r r rP r` r= r< write_eofr; Z output_sizer> r r- r- r. r s
zStreamResponse.write_eofc C s\ | j r d}n2| jr:| jd k s t| jj d| jj d}nd}d| jj d| j d| dS )Neof z not prepared<>) r= rG r; rP methodri rz r* r2 )rB infor- r- r. __repr__ s zStreamResponse.__repr__)keyr4 c C s
| j | S rE r? rB r r- r- r. __getitem__ s zStreamResponse.__getitem__)r rn r4 c C s || j |< d S rE r )rB r rn r- r- r. __setitem__ s zStreamResponse.__setitem__c C s | j |= d S rE r r r- r- r. __delitem__ s zStreamResponse.__delitem__c C s
t | jS rE )lenr? rF r- r- r. __len__ s zStreamResponse.__len__c C s
t | jS rE )iterr? rF r- r- r. __iter__ s zStreamResponse.__iter__c C s t t| S rE )hashidrF r- r- r. __hash__ s zStreamResponse.__hash__)otherr4 c C s | |kS rE r- )rB r r- r- r. __eq__ s zStreamResponse.__eq__)N)N)r )Cr* r+ r, r rQ r rr r rC propertyra rG rH r1 rK rL r2 r r
r
rA rT rU rV rZ r^ r r! rc r3 rd ru rv rx setterr} r r r r r r r r r r r r r r r r r r r r r r r r r r r r objectr
__classcell__r- r- ry r. r" C s 5
:
r" c sV e Zd Zdddddddddd eeee ee ee ee ee ee ee dd
fddZ e
ee e e
f ddd Zejejejfe eedd
d d Ze
ee dd d
Zejedddd
Ze
ee d fdd Zejee ddddZd"e dd fdd
Zded fdd Zedd d d Zedd fd d! Z Z S )#r# Nr/ ) bodyr1 r2 textr3 r} r zlib_executor_size
zlib_executor)
r r1 r2 r r3 r} r r r r4 c s^ |d k r|d k rt d|d kr(t }
nt|ts<t|}
n|}
|d k rXd|krXt d|d k rtj|
kr||sr|rt dnRt|tstdt| |d krd}|d krd}|d | |
tj< ||}d }nNtj|
kr|d k s|d k rt dn*|d k r |d k r|d| 7 }||
tj< t j
|||
d |d k rB|| _ n|| _ d | _
|| _| | _d S )
Nz&body and text are not allowed togetherr z,charset must not be in content_type argumentzPpassing both Content-Type header and content_type or charset params is forbidden text argument must be str (%r)
text/plainutf-8z
; charset=r0 )
ValueErrorr rb r r rr TypeErrorr` encoderw rC r r _compressed_body_zlib_executor_size_zlib_executor) rB r r1 r2 r r3 r} r r r Z real_headersry r- r. rC sP
zResponse.__init__rD c C s | j S rE )r5 rF r- r- r. r Y s z
Response.body)r r r\ r4 c C s |d krd | _ d| _nt|ttfr2|| _ d| _nztj| | _ }W n& tjk
rn t dt
| Y nX d| _| j }| j s||kr|j
}|d k rt|||< ||kr|j||< |jr|j D ]\}}||kr|||< qd | _d S )NFzUnsupported body type %rT)r5
_body_payloadrb r r r ZPAYLOAD_REGISTRYrp LookupErrorr r` r@ r7 sizerr r} r3 r r )rB r r r\ r3 r r rn r- r- r. r ] s.
c C s | j d krd S | j | jp dS )Nr )r5 decoder rF r- r- r. r s
z
Response.text)r r4 c C s` |d ks"t |ts"tdt| | jdkr2d| _| jd krBd| _|| j| _d| _d | _ d S )Nr r r r F)
rb rr rP r` r} r r r5 r r )rB r r- r- r. r s
c sX | j r
d S tj| jkr t jS | jd k r2t| jS | jr<d S | j d k rPt| j S dS d S )Nr )
r7 r r\ r@ rw rx r r r r5 rF ry r- r. rx s
zResponse.content_lengthr{ c C s t dd S )Nz#Content length is set automatically)r] r| r- r- r. rx s r r c s | j r
d S | jd kr | j}n| j}|r4td|| jd k sBt| jd k sPt|d k r| jjtjksp| j dkrt
I d H q| j rt
t|}|| jI d H t
I d H qt
t
t|I d H nt
I d H d S )Nz data arg is not supported, got )r i0 )r= r r5 rP r; r< _methodr Z METH_HEADrJ rw r r r r r r )rB r r r ry r- r. r s"
zResponse.write_eofr% r c sX | j sFtj| jkrF| jsF| jd k r:tt| j| jtj< n d| jtj< t |I d H S )N0)
r7 r r\ r@ r r5 rr r rw r r ry r- r. r s
zResponse._start) zlib_moder4 c C sB |dks t tj|d}| j}|d k s*t ||| | _d S )Nr )Zwbits)rP zlib compressobjr5 compressflushr )rB r r body_inr- r- r. _compress_body s
zResponse._compress_bodyr c s | j s | jr t |I d H S |tjkr|tjkr<dtj ntj}| j }|d k sTt
| j d k rt || j krt
| j| j|I d H n
| | | j}|d k st
|j| jtj< tt || jtj< d S )N )r r7 rw r r! r) r( r Z MAX_WBITSr5 rP r r asyncioZget_event_loopZrun_in_executorr r r rn r@ r r rr r\ )rB r r r Zbody_outry r- r. r s*
z Response._do_start_compression)r ) r* r+ r, r rQ r rr r r rC r r r r r r r r r\ r r rx r r r r r! r r r- r- ry r. r# sX F (
r# r/ zapplication/json)r r r1 r2 r3 r} dumps) r r r r1 r2 r3 r} r r4 c C s6 | t k r"|s|rtdn|| }t||||||dS )Nz3only one of data, text, or body should be specified)r r r1 r2 r3 r} )r r r# )r r r r1 r2 r3 r} r r- r- r. r$ s
r$ )@r Zcollections.abc collectionsr enumZjsonr r rW r concurrent.futuresr Z email.utilsr Z http.cookiesr r typingr r r r r
r r r
r r Z multidictr r rO r r abcr Zhelpersr r r r Zhttpr r r r r Ztypedefsr r __all__Z web_requestr% rr Z BaseClassZ _reservedEnumr! r" r# r r rQ r$ r- r- r- r. <module> sj 0
R f