c,O, z U d dl Z d dlZd dlZd dlZd dlmZmZmZmZm Z m
Z
m Z m Z m
Z
mZmZmZ ddlmZ ddlmZ ddlmZmZmZ ddlmZmZ ddl m Z m Z m Z m Z dd l!m"Z" d
Z#erdd l$m%Z% e
e e&ged f Z' e(ej) * d Z+e
e( e,d
< G d de" Z-dS ) N) IO
TYPE_CHECKINGAny AwaitableCallableFinalIteratorListOptionalTupleUnioncast )hdrs)AbstractStreamWriter)ETAG_ANYETagmust_be_empty_body) LooseHeadersPathLike)HTTPNotModifiedHTTPPartialContentHTTPPreconditionFailed HTTPRequestRangeNotSatisfiable)StreamResponse) FileResponse) BaseRequestAIOHTTP_NOSENDFILE
NOSENDFILEc
e Zd ZdZ d dedededee d ee d
df fd
Z d e
d
e e deded
e
f
dZ
ddd
e e deded
e
f
fd Zededeedf d
efd Zdddeded
ee
f fd Zddd
ee
f fd Zded
eej ej ef fd Zddd
ee
f fd Z xZ S ) r z,A response object can be used to send files. Npath
chunk_sizestatusreasonheadersreturnc t ||| t j | | _ || _ d S )N)r% r& r' )super__init__pathlibPath_path _chunk_size)selfr# r$ r% r& r' __class__s l/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib64/python3.11/site-packages/aiohttp/web_fileresponse.pyr+ zFileResponse.__init__/ sC vwGGG \$''
% writerfobjoffsetcountc K | j }t j }| d |j | d {V | d |j | d {V }|rY| | d {V ||z
}|dk rn2| d |j t || d {V }|Y| d {V |S Nr ) r/ asyncioget_event_looprun_in_executorseekreadwritemindrain)r0 r4 r5 r6 r7 r$ loopchunks r2 _sendfile_fallbackz FileResponse._sendfile_fallback< s %
%''""4F;;;;;;;;;**4JGGGGGGGG X,,u%% % % % % % % %J&Ezz ..tTYJPU@V@VWWWWWWWWE X llnn
r3 requestr c K t | d {V }|J t s| j r | |||| d {V S |j }|j }|J | |||| d {V n.# t $ r! | |||| d {V cY S w xY wt d {V |S N)
r* preparer compressionrD _loop transportsendfileNotImplementedError write_eof) r0 rE r5 r6 r7 r4 rB rK r1 s r2 _sendfilezFileResponse._sendfileR sJ www////////!!! N) N 00vuMMMMMMMM M}% $$$ N-- 4?? ? ? ? ? ? ? ? ?" N N N 00vuMMMMMMMM M M M N gg !!!!!!!!!
s . B
(B87B8
etag_valueetags.c t | dk r|d j t k rdS t fd|D S )Nr r Tc 3 < K | ]}|j |j k V d S rG )is_weakvalue).0etagrP s r2 z2FileResponse._strong_etag_match..k s1 RRT\R4:+RRRRRRr3 )lenrU r any)rP rQ s ` r2 _strong_etag_matchz FileResponse._strong_etag_matchg sJ u::??uQx~ 9 94RRRRRRRRRRr3
last_modifiedc K | t j d| _ || _ || _ t
| d {V S )NF)
set_statusr status_code
_length_checkrW r\ r* rH )r0 rE rP r\ r1 s r2
_not_modifiedzFileResponse._not_modifiedm s_
3444 " * WW__W---------r3 c K | t j d| _ t | d {V S r9 )r^ r r_ content_lengthr* rH )r0 rE r1 s r2 _precondition_failedz!FileResponse._precondition_failedx sO
.:;;; WW__W---------r3 check_for_gzipped_filec | j }|rE| |j dz } || dfS # t $ r Y nw xY w|| dfS )zReturn the file path, stat result, and gzip status.
This method should be called from a thread executor
since it calls os.stat which may block.
z.gzTF)r. with_namenamestatOSError)r0 re filepath gzip_paths r2 _get_file_path_stat_and_gzipz)FileResponse._get_file_path_stat_and_gzip s : ! **8=5+@AAI
).."2"2D88
%//s ?
A A c K t j }d|j t j d v }| d | j | d {V \ }}}|j dd|j d}|j
}|j } | 1| || s|
| d {V S |j }
|
:| 8|j
|
k r|
| d {V S |j } | 3| || r | ||| d {V S |j } | <| :|j
| k r | ||| d {V S t j | j vr+t) j t- | \ }
}|
sd}
d}n|rdnd }d}| j }|j }|}d }|j }| |j
| k r> |j }|j }|j }nm# t8 $ r` d| | j t j < | t> j tC " | d {V cY S w xY w|||d k r|||z
}|d k rd }||z
}ntG ||n|| |z
}||k r]d| | j t j < | t> j tC " | d {V S tH j }| | |r|
| _% |r|| j t j& < |r%t j | j t j' < d| _( || _) |j
| _* || _+ d
| j t j, < t[ t\ | }|tH j k r/d / |||z d z
| | j t j < |d k sta |j1 | j2 r'tC " | d {V S | d |j3 d
d {V }|r|}nd } | 4 |||| d {V t j5 | d |j6 d {V S # t j5 | d |j6 d {V w xY w)Ngzip x-zapplication/octet-streamTFzbytes */r byteszbytes {}-{}/{}r rb)7r: r; r' getr ACCEPT_ENCODINGr< rm st_mtime_nsst_sizest_mtimeif_matchr[ rd if_unmodified_since timestamp
if_none_matchra if_modified_since CONTENT_TYPE mimetypes
guess_typestr_statusif_range
http_rangestartstop
ValueError
CONTENT_RANGEr^ r r_ r* rH r@ r content_typeCONTENT_ENCODINGVARY _compressionrW r\ rc
ACCEPT_RANGESr intformatr methodr% openrO shieldclose)r0 rE rB re rk stro rP r\ ifmatch
unmodsince ifnonematchmodsincectencoding
should_set_ctr% file_sizer7 r ifrangerngend
real_startr5 r6 r1 s r2 rH zFileResponse.prepare s %''!'7?+>+>t?SUW+X+X!X #'#7#7 $35K$
$
"d 9992:999
" t'>'>z7'S'S 227;;;;;;;; ; 0
" j 2 2 4 444 227;;;;;;;; ; + "t'>'>z;'W'W " ++GZ OOOOOOOO O, # x 1 1 3 333 ++GZ OOOOOOOO O DL 0 0$/H
>>LB
0/ MM!%/vv4H !M J " ?bkW->->-@-@ @ @
6 ( h
6
6
6 4Ji3I3I T /0 > JKKK "WW__W 5 5555555555
6 CO199Y&E qyy !" % -EE 3?CC 9MMPUU I%% 8N)7M7MDL!34OO$B$NOOO!& !9!99999999+7 ''' # "D ;2:DL. / &&*&:DL # !&D [ #+2 T'(#u%%
'3 3 3/?/F/FJ . 2I0 0DL+ ,
A::+GNDKHH: 11111111 1))$
tDDDDDDDD FFF I vuEEEEEEEE E.!5!5dDJ!G!GHH H H H H H H H H'.!5!5dDJ!G!GHH H H H H H H H Hs <H A'I<;I<2 S 5S9)r! r" NN) __name__
__module__ __qualname____doc__r r r r r r+ r r r rD rO staticmethodr r boolr[ floatra rd r, r- os stat_resultrm rH
__classcell__)r1 s @r2 r r , s^ 66
% $*.
& & & & &
& ,'
&
& & & & & &*24S'CFOR ,$,.sG=@IL * Ss S5s3C S S S S \S
.$ .25 .FK . & ' . . . . . ..$. & '. . . . . .0&*0 w|R^T1 20 0 0 0&[I] [Ix@T7U [I [I [I [I [I [I [I [I [I [Ir3 r ).r: r r r, typingr r r r r r r r
r r r
r rp r abcr helpersr r r typedefsr r web_exceptionsr r r r web_responser __all__ web_requestr rs _T_OnChunkSentr environru r __annotations__r r3 r2 r s
% % % % % % 7 7 7 7 7 7 7 7 7 7 , , , , , , , , ) ( ( ( ( (
)(((((( (E7IdO#;<= $rz~~.B C CDD
E$K D D DAI AI AI AI AI> AI AI AI AI AIr3