% d Z ddlZddlZddlmZmZmZmZmZm Z ddl
m Z ddl m
Z
ddlmZ ddlmZ d Z G d
d e Z edd Z edd Zeeeged f Zeed ged f Z G d
de
ZdedefdZdedd defdZ e Z ddl m Z e j Z ese Z dS dS # e!$ r Y dS w xY w)z"Http related parsers and protocol. N)Any AwaitableCallable
NamedTupleOptionalUnion) CIMultiDict )AbstractStreamWriter) BaseProtocol)
NO_EXTENSIONS) StreamWriter HttpVersion
HttpVersion10
HttpVersion11c $ e Zd ZU eed< eed< dS )r majorminorN)__name__
__module__ __qualname__int__annotations__ u/builddir/build/BUILD/imunify360-venv-2.6.2/opt/imunify360/venv/lib64/python3.11/site-packages/aiohttp/http_writer.pyr r s" JJJ JJJJJr r CIMultiDict[str]c e Zd Z d dedej dededdf
dZe de
ej fd Z e defd Z
d d
Zd ej fd ed
eddfdZdeddfdZddddedededdfdZdeddddfdZd deddfd Zd d ZdS )!r Nprotocolloop
on_chunk_senton_headers_sentreturnc || _ || _ d | _ d| _ d| _ d| _ d| _ d | _ d | _ || _ || _
d S )NFr ) _protocolr lengthchunked buffer_size output_size_eof _compress
_drain_waiter_on_chunk_sent_on_headers_sent)selfr r r! r" s r __init__zStreamWriter.__init__ s\ " " !.;2A r c | j j S N)r% transportr/ s r r3 zStreamWriter.transport4 s
~''r c | j S r2 )r% r4 s r r zStreamWriter.protocol8 s
~ r c d| _ d S )NT)r' r4 s r enable_chunkingz StreamWriter.enable_chunking< s
r deflateencodingstrategyc ~ |dk rdt j z n t j }t j || | _ d S )Ngzip )wbitsr: )zlib MAX_WBITS compressobjr+ )r/ r9 r: zlib_modes r enable_compressionz StreamWriter.enable_compression? s< ,4v+=+=B ''4> ) HMMMr chunkc t | }| xj |z
c_ | xj |z
c_ | j }| j j r|| rt d | | d S )Nz!Cannot write to closing transport) lenr( r) r3 r% connected
is_closingConnectionResetErrorwrite)r/ rD sizer3 s r _writezStreamWriter._writeE s 5zz D D N ~' L9+< @T@T@V@V+<&'JKK K r Ti )drainLIMITrM rN c K | j | | d{V t |t r-|j t | k r| d }| j | j | }|sdS | j Dt | }| j |k r| j |z
| _ n|d| j }d| _ |sdS |ry| j r-dt | z
d }||z dz }| | | j |k r'|r'd| _ |
d{V dS dS dS dS )zWrites chunk of data to a stream.
write_eof() indicates end of stream.
writer can't be used after write_eof() method being called.
write() return drain future.
Ncr %x
asciis
)r-
isinstance
memoryviewnbytesrF castr+ compressr& r' encoderL r( rM )r/ rD rM rN chunk_len
chunk_len_pres r rJ zStreamWriter.writeN s *%%e,, , , , , , , , eZ ( ( (|s5zz))
3 > %N++E22E
; "E
I{i'' "kI 5 m m, F #|
8!)CJJ!6 > >w G G
%-7 KK %''E'#$ jjll""""""""" # # ('''r status_lineheadersr c K | j | | d{V t || }| | dS )z*Write request/response status and headers.N)r. _serialize_headersrL )r/ r[ r\ bufs r
write_headerszStreamWriter.write_headersy s` ,''00 0 0 0 0 0 0 0 !g66 Cr r c 2 K | j rd S |r"| j | | d {V | j ro|r| j | }|| j z }|r4| j r-dt
| z d }||z dz }n9| j r2|r.dt
| z d }||z dz }nd}|r| | | d {V d| _ d S )NrQ rR s
0
s 0
T)
r* r- r+ rW flushr' rF rX rL rM )r/ rD rY s r write_eofzStreamWriter.write_eof sV 9 F -T(4%%e,, , , , , , , , > )
7 //66DN 0 0 2 22E
=
= %E
2 : :7 C C !E),<<|
) )!)CJJ!6 > >w G GI % -0@ @EE (E KK jjll r c d K | j j !| j d{V dS dS )zFlush the write buffer.
The intended use is to write
await w.write(data)
await w.drain()
N)r% r3
_drain_helperr4 s r rM zStreamWriter.drain sG > # /...00 0 0 0 0 0 0 0 0 0 0 /r )NN)r# N)r )r r r r asyncioAbstractEventLoop_T_OnChunkSent_T_OnHeadersSentr0 propertyr Transportr3 r r7 r? Z_DEFAULT_STRATEGYstrr rC bytesrL boolrJ r` rc rM r r r r r s
)-,0 B B B 'B & B
* B
B B B B, (8G$56 ( ( ( X( , X (9PN NN36N
N N N N E d .2)# )# )#)#&*)#:=)#
)# )# )# )#V );
U T < 1 1 1 1 1 1r r stringr# c 4 d| v sd| v rt d | S )N
zRNewline or carriage return detected in headers. Potential header injection attack.)
ValueError)rp s r _safe_headerru s1 v~~
1
Mr r[ r\ c d | D }| dz d | z dz }| d S )Nc 3 ` K | ])\ }}t | d z t | z V *dS )z: N)ru ).0kvs r z(_py_serialize_headers.. s< XX1<??T)LOO;XXXXXXr z
z
zutf-8)itemsjoinrX )r[ r\ headers_genlines r _py_serialize_headersr sO XX
XXXK &++k":": :Z GD ;;w r )"__doc__rf r? typingr r r r r r multidictr abcr
base_protocolr helpersr
__all__r r r rn rh ri r rm ru r r^ aiohttp._http_writer _http_writer_c_serialize_headers ImportErrorr r r r s ( ( H H H H H H H H H H H H H H H H ! ! ! ! ! ! % % % % % % ' ' ' ' ' ' " " " " " "
K *
Aq!!
Aq!!
(E7IdO#;<=H&8%99T?%J KL N1 N1 N1 N1 N1' N1 N1 N1b s 5G E + //////': 2 12 2 DD s ,C C
C