kì6 H d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl m
Z
d dl m Z d dl
mZ d dlmZmZmZmZmZmZmZmZ d dlmZmZ ddlm Z 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+m,Z, dd l m-Z-m.Z.m/Z/ dd
l m0Z0 ddl1m2Z2m3Z3 dZ4erddl5m6Z6 ee7ef Z8n ej j Z8 G d dej9 Z: G d de8e& Z; G d de; Z d e?d ee7 d ee3 d e7d!e2d"eZ0dRd?Z1dRd@Z2dAe3ddfdBZ4dRdCZ5dUdAe3ddfdEZ6defdFZ7dGede8fdHZ9dGed e8ddfdIZ:dGeddfdJZ;defdKZdefdMZ?dNe@de
fdOZA xZBS )Vr& T Nstatusreasonheadersr7 r8 r9 returnc F d | _ d | _ d| _ d| _ d | _ t | _ d | _ d | _ d| _ d | _
d| _ i | _ |t | | _ nt | _ | || d S )NFr )_body _keep_alive_chunked _compression_compression_forcer _cookies_req_payload_writer _eof_sent_must_be_empty_body _body_length_stater _headers
set_status)selfr7 r8 r9 s r3 __init__zStreamResponse.__init__J s
+/
!;? $
+/ ?C 37 &( .9'.B.BDMM 'MMDM '''''r2 c | j d uS N)rC rJ s r3 preparedzStreamResponse.preparedf s #4//r2 Optional[asyncio.Task[None]]c , | j r | j j S d S rM )rB taskrN s r3 rR zStreamResponse.taskj s 9 9> !4r2 c | j S rM )_statusrN s r3 r7 zStreamResponse.statusq
|r2 c | j S rM )r> rN s r3 chunkedzStreamResponse.chunkedu
} r2 c | j S rM )r? rN s r3 compressionzStreamResponse.compressiony r2 c | j S rM )_reasonrN s r3 r8 zStreamResponse.reason} rU r2 c | j r
J d t | | _ |- t | j j }n# t
$ r d}Y nw xY w|| _ d S )NzGCannot change the response status code after the headers have been sent )rO intrT r phrase
ValueErrorr] )rJ r7 r8 s r3 rI zStreamResponse.set_status s
=
X
6{{ >
#DL118
s A AAc | j S rM r= rN s r3
keep_alivezStreamResponse.keep_alive s r2 c d| _ d S )NFrd rN s r3 force_closezStreamResponse.force_close s r2 c | j S rM )rF rN s r3 body_lengthzStreamResponse.body_length r[ r2 c ` t j dt | j sJ | j j S )Nzoutput_length is deprecated)warningswarnDeprecationWarningrC buffer_sizerN s r3
output_lengthz StreamResponse.output_length s1
35GHHH#####//r2
chunk_sizec d| _ t j | j v rt d | t j dt dS 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)r> r CONTENT_LENGTHrH RuntimeErrorrk rl rm )rJ rp s r3 enable_chunked_encodingz&StreamResponse.enable_chunked_encoding sX
$- / / S
! M: rs r rH r rr r rJ r s r3 r z StreamResponse.content_length sp JJE}
"U 25UDM$- . . . M d 14 8 8 8 8 8r2 c * t j S rM )r content_typer s r3 r zStreamResponse.content_type s ww##r2 c d | j t | | _ | d S rM )r r
_content_type _generate_content_type_headerr s r3 r zStreamResponse.content_type" s1 ZZ **,,,,,r2 c * t j S rM )r charsetr s r3 r zStreamResponse.charset( s ww r2 c | j }|dk rt d | j J | | j dd n)t | | j d< | d S )Napplication/octet-streamzYSetting charset for application/octet-stream doesn't make sense, setup content_type firstr )r rs
_content_dictr r lowerr )rJ r ctypes r3 r zStreamResponse.charset- s ! . . . ?
!--- = " "9d 3 3 3 3,/JJ,<,<,>,>D y ) **,,,,,r2 c d t | j t j S )zuThe value of Last-Modified HTTP header, or None.
This header is represented as a `datetime` object.
)r rH r r
LAST_MODIFIEDrN s r3
last_modifiedz StreamResponse.last_modified< s% t} 0 01C D DEEEr2 c * |'| j t j d d S t |t
t f rMt j dt j t j | | j t j < d S t |t j r;t j d|
| j t j < d S t |t r|| j t j < d S d S )Nz%a, %d %b %Y %H:%M:%S GMT)rH r r r ry r` floattimestrftimegmtimemathceildatetime utctimetupler r s r3 r z StreamResponse.last_modifiedD s = M d 0$ 7 7 7 7 7
U|
,
, 604
+T[59I9I-J-J1 1DM$, - - - x 0
1
1 604
+U-?-?-A-A1 1DM$, - - - s
#
# 605DM$, - - - 6 6r2 c 0 | j t j }|sd S |t k rt t S t
j | }|sd S | dd \ }}t t | | S )N)r r )is_weakr )
rH r r ETAGr r r fullmatchgrouprx )rJ quoted_valuematchr r s r3 etagzStreamResponse.etagU s }((33 (4
X
%
%h''' ' ( 66 4 Q**MM
r2 c |'| j t j d d S t |t
r |t k s%t |t r+|j t k rt | j t j < d S t |t
r)t | d| d| j t j < d S t |t rat |j t
rGt |j |j
r d|j dn
d|j d}|| j t j < d S t dt | d )N"zW/"zUnsupported etag type: z . etag must be str, ETag or None)
rH r r r ry r r r r r r rb rw )rJ r hdr_values r3 r zStreamResponse.etage sV = M di . . . . .$$ ():): ud # # *;(- x(?(?'/DM$) $ $ $
s
#
# & & &'35|||DM$) $ $ $
t
$
$ EK)E)E , , ,05
U,ek,,,,CUu{CUCUCUI'0DM$) $ $ $ 2$u++ 2 2 2
r2 CONTENT_TYPEc | j J | j J d d | j D }|r| j dz |z }n| j }|| j |< d S )Nz; c 3 * K | ]\ }}| d | V dS )=Nr1 ).0kvs r3 z?StreamResponse._generate_content_type_header.. s0 MM$!Qa::!::MMMMMMr2 )r r joinitemsrH )rJ r paramsr s r3 r z,StreamResponse._generate_content_type_headerz s !---!---MM$2D2J2J2L2LMMMMM '&-6EE&E&+
l###r2 codingc K |t j k rh| j J |j | j t
j < | j |j | j t
j d d S d S rM )
r% r- rC r rH r CONTENT_ENCODINGrz popallrr )rJ r s r3 _do_start_compressionz$StreamResponse._do_start_compression sx ]+ + +'33339 4 +' '#5gndk#R#R [[)))))))))r2 c K || _ |j x}| _ | d {V | | d {V | d {V |S rM )rB rC _prepare_headers
_prepare_hook_write_headers)rJ r writers r3 r zStreamResponse._start s (/(??%##%%%%%%%%%##D)))))))))!!#########
r2 c R K | j }|J | j }|J | j }||j }|| _ |j }| j }| j D ]@}| d dd }| t j | A| j r|
| d {V | j rx|t k r't! d |j | j s#| d|t j < t j |v r
|t j = nY| j rR| j |_ |j ?|t k r+| j s#| d|t j < n | j sd}| j rQt j |v r't3 |j | j r
|t j = t j |v r
|t j = n | t j d | t j t? | t j tB t j" |vr<|r |tF k rd|t j" < d S d S |t k rd |t j" < d S d S d S )
Nr_ )headerr z@Using chunked encoding is forbidden for HTTP/{0.major}.{0.minor}rW Fr z
keep-aliveclose)$rB rC r= re r rH rA valuesoutputaddr
SET_COOKIEr? r r> r! rs formatrE enable_chunkingTRANSFER_ENCODINGrr
_length_checkr lengthr r r7
setdefaultr DATEr SERVERr
CONNECTIONr )rJ r r re r r9 cookier s r3 r z StreamResponse._prepare_headers s )"""%!!!%
+J%/-m**,, 0 0FMMM,,QRR0E KK / / / / 3))'22 2 2 2 2 2 2 2 = '-''"3396'/3J3J +
<&&(((2;./"g--D /0
' /FM}$m++ 3 D ..000:C 67 1 '!&J #
N"g--2N 3 3- D /0 %00D 23 t 02L M M M49&;&=&=>>>4;888 ?' ) )
7m++/;GDO,,, ,+ m++/6GDO,,,
* )
,+r2 c K | j }|J | j }|J |j }d |d |d | j | j }| || j d {V d S )NzHTTP/{}.{} {} {}r r )rB rC r r rT r]
write_headersrH )rJ r r r status_lines r3 r z StreamResponse._write_headers s )"""%!!!/(// AJ
DL$,
"";
>>>>>>>>>>>r2 datac K t |t t t f sJ dt | z | j rt
d | j t
d | j | d {V d S )N#data argument must be byte-ish (%r)z%Cannot call write() after write_eof()z$Cannot call write() before prepare()) ry bytes bytearray
memoryviewrw rD rs rC writerJ r s r3 r zStreamResponse.write s 5)Z0
> > 04:: = > >
> H FGG G ' EFF F"((...........r2 c K | j r
J d | j
J d t j dt d | j d {V d S )NzEOF has already been sent Response has not been startedz2drain method is deprecated, use await resp.write()r )
stacklevel)rD rC rk rl rm drainrN s r3 r zStreamResponse.drain s >>>#>>>!#//1P///
@
"((***********r2 r2 c B K t |t t t f sJ dt | z | j rd S | j
J d | j | d {V d| _ d | _ | j j | _
d | _ d S )Nr r T) ry r r r rw rD rC write_eofrB output_sizerF r s r3 r zStreamResponse.write_eof s 5)Z0
> > 04:: = > >
> F#//1P///",,T222222222 0 < # r2 c | j rd}n/| j r&| j J | j j d| j j d}nd}d| j j d| j d| dS )Neof z not prepared<>)rD rO rB r r r r. r8 )rJ infos r3 __repr__zStreamResponse.__repr__ sy > "DD
] "9(((i&:: :::DD!DB4>*BBT[BB4BBBBr2 keyc | j | S rM rG rJ r s r3 __getitem__zStreamResponse.__getitem__) s {3 r2 c || j |< d S rM r
)rJ r r s r3 __setitem__zStreamResponse.__setitem__, s Cr2 c | j |= d S rM r
r s r3 __delitem__zStreamResponse.__delitem__/ s K r2 c * t | j S rM )lenrG rN s r3 __len__zStreamResponse.__len__2 s 4; r2 c * t | j S rM )iterrG rN s r3 __iter__zStreamResponse.__iter__5 s DK r2 c : t t | S rM )hashidrN s r3 __hash__zStreamResponse.__hash__8 s BtHH~~ r2 otherc
| |u S rM r1 )rJ r s r3 __eq__zStreamResponse.__eq__; s u} r2 )r: rP rM )r: N)r: r{ )r r) r: Nr2 )Cr. r/ r0 r r` r r r$ rK propertyrx rO rR r7 rW rZ r8 rI re rg ri ro rt r r% rz r9 r r~ r r r 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 r r objectr
__classcell__r s @r3 r& r& F sT M
$*. ( ( ( (
(
,' (
( ( ( (8 0$ 0 0 0 X0 X X X !T ! ! ! X! X !%
HTN X ! ! ! ! !S ! ! ! X! 0s 0 0 0 X0
P P(3- P4 P P P P =A( ( eD-$7 89(
( ( ( ($ X X "& $-1!%#'!%"&1% 1% 1%1% 1%
# 1%
1% %S/*1% 1% 1% 4.1% # 1% 3-1%
1% 1% 1% 1%h 59c
$,SM
@C
$ &
& & & & & X& 9HSM 9d 9 9 9 9 $c $ $ $ $ $ X$ -# -$ - - - -
# X
^ -Xc] -t - - - ^ - Fx(9 : F F F XF 6 eC0A3$F GH6
6 6 6 6
htn
X
[(5s#34 [* $(#4
,
,
,
,
,
,
,<- 2MPW2W T ./{{7++ L00 +w/B$' 0C + *$ w(>> 6BL!23
v|LLL DII DI15 #5 +r2 c | j S rM )r< rN s r3 r% z
Response.body s
zr2 c |d | _ d| _ nt |t t f r|| _ d| _ n t
j | x| _ }n2# t
j $ r t dt | z w xY wd| _ | j }t j
|vr|j |t j
< |j r(|j D ]\ }}||vr|||< d | _ d S )NFzUnsupported body type %rT)r<
_body_payloadry r r r PAYLOAD_REGISTRYr LookupErrorrb rw rH r r r r9 r r/ )rJ r% r9 r r s r3 r% z
Response.body s$ <*.DJ',D
ui 0
1
1 - DJ!&D
J$+$<$@$@$F$FF
TT&
J
J
J !;d4jj!HIII
J "&D mG //-1->)* |
-$(L$6$6$8$8 - -LS%'))', $ s &A% %/Bc V | j d S | j | j pd S )Nr, )r< decoder rN s r3 r& z
Response.text s, : 4z !8999r2 c |/t |t sJ dt | z | j dk rd| _ | j d| _ | | j | _ d| _ d | _ d S )Nr* r r+ r, F) ry r rw r r r. r< r5 r/ )rJ r& s r3 r& z
Response.text s |z #
|| +d4jj 8 |
: : : ,D < "DL[[ ..
" $ r2 c | j rd S t j | j v rt j S | j t | j S | j rd S | j t | j S dS )Nr )
r> r rr rH r r r/ r r5 r< r s r3 r zResponse.content_length st = 4 $- / /77) ) ,t,-- -
4
Z
#tz?? "1r2 r c t d )Nz#Content length is set automatically)rs r s r3 r zResponse.content_length s @AAAr2 r2 r c p K | j rd S | j | j }n| j }|r
J d| | j J | j J || j r(t
d {V d S | j rXt t | } |j | j d {V t
d {V d S t
t t | d {V d S t
d {V d S )Nz data arg is not supported, got )
rD r/ r< rB rC rE r r r5 r
r" r r )rJ r r% r r s r3 r zResponse.write_eof s > F (48JDD(DCCC4CCCCxy$$$#/// '
;gg'')))))))))))#
; w--#gmD$8999999999gg'')))))))))))gg''UD(9(9:::::::::::''##%% % % % % % % % % %r2 r r) c K t |j | j r&t j | j v r| j t j = n| j st j | j vr| j rCt t | j
j }|!t | | j t j < nv| j
rt | j
nd}|dk s2| j dk rH|j t j k r!t | | j t j < t! | d {V S )N0i0 )r r r7 r rr rH r> r5 r
r" r< sizer r upper METH_HEADr r )rJ r r@ body_lenr s r3 r zResponse._start s ' D D G"dm33M$"56 G4#6dm#K#K!
GGTZ005#9+?+?+A+AT^+S+S9 r r r% r- r r r r0 r1 r< r rk rl compressflushr/ rH r r rr )rJ r
compressorr s r3 r z Response._do_start_compression sv ? ? 66v>>>>>>>> > ]+ + + ( V\**$($< , J
:)))'/C
OOk4Q4Q
XDJX X X !))$*55555555
8H8H8J8JJ
! (44439r_ s ' ' ' ' ' ' % % % % % % ( ' ' ' ' ' ' ' % % % % % % - - - - - - @ ? ? ? ? ? ? ? ? ? / / / / / / / /
J /(((((( sCx(II.I DI v v v v v Y v v v rXQ XQ XQ XQ XQ~ XQ XQ XQx &**
3- 5/
SM
l
# r2