/opt/cloudlinux/venv/lib/python3.11/site-packages/aiohttp/__pycache__
Edit: /opt/cloudlinux/venv/lib/python3.11/site-packages/aiohttp/__pycache__/payload.cpython-311.pyc (24234B)
b1`˅ | U d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZm Z d dl
m Z d dl m
Z
mZmZmZmZmZmZmZmZmZmZmZ d dlmZ ddlm Z ddlm Z dd l m Z m Z m!Z!m"Z"m#Z# dd
l$m%Z% dd l&m'Z'm(Z( d Z)d
Z*ee+ e,d< erd dl m-Z- G d de. Z/ G d de0ej1 Z2dedededdfdZ3e2j4 dded d ed e2ddfd Z5 G d d Z6ed Z7ee7ef Z8 G d! d" Z9 G d# de Z: G d$ d%e: Z; G d& d'e; Z< G d( d)e< Z= G d* d+e: Z> G d, d-e> Z? G d. d/e> Z@ G d0 d1e> ZA G d2 d3e; ZBerd d4l mCZCmDZD eDeE ZFeCeE ZGn d d4lHmCZCmDZD eDZFeCZG G d5 d6e: ZI G d7 d8eI ZJ e9 ZKeKL e;eEeMeNf eKL e
ejT eKL eJe% eKL eIeCe2jU dS )9 N)ABCabstractmethod)chain) IO
TYPE_CHECKINGAny
ByteStringDictFinalIterableOptionalTextIOTupleTypeUnion) CIMultiDict )hdrs)AbstractStreamWriter) _SENTINELcontent_disposition_headerguess_filenameparse_mimetypesentinel) StreamReader) JSONEncoder _CIMultiDict)
PAYLOAD_REGISTRY get_payload payload_typePayload BytesPayload
StringPayload
IOBasePayloadBytesIOPayloadBufferedReaderPayload
TextIOPayloadStringIOPayload JsonPayloadAsyncIterablePayloadi TOO_LARGE_BYTES_BODY)Listc e Zd ZdS ) LookupErrorN)__name__
__module__ __qualname__ c/builddir/build/BUILD/cloudlinux-venv-1.0.12/venv/lib64/python3.11/site-packages/aiohttp/payload.pyr. r. = s Dr3 r. c e Zd ZdZdZdZdS )Ordernormal try_firsttry_lastN)r/ r0 r1 r7 r8 r9 r2 r3 r4 r6 r6 A s
FIHHHr3 r6 dataargskwargsreturnr! c , t j | g|R i |S N)r get)r: r; r< s r4 r r G s# 6t 6 6 6v 6 66r3 orderfactorytyperB c @ t | || d S NrA )r register)rC rD rB s r4 register_payloadrH K s% gt5 99999r3 c Z e Zd Zej ddededdfdZded ded fd ZdS )
r rA rD rB r= Nc " || _ || _ d S r? )rD rB )selfrD rB s r4 __init__zpayload_type.__init__R s
r3 rC r! c > t || j | j |S rF )rH rD rB )rK rC s r4 __call__zpayload_type.__call__V s $)4:>>>>r3 ) r/ r0 r1 r6 r7 r rL r rN r2 r3 r4 r r Q sv 49L S E T Y DO r3 r c d e Zd ZdZddZeddededd d
edd f
d Zej d
de
dededdfdZ dS )PayloadRegistryzZPayload registry.
note: we need zope.interface for more efficient adapter search
r= Nc 0 g | _ g | _ g | _ d S r? )_first_normal_lastrK s r4 rL zPayloadRegistry.__init__e s 24 35 13
r3 )_CHAINr: r; rV z!Type[chain[_PayloadRegistryItem]]r< r! c t |t r|S || j | j | j D ]#\ }}t || r ||g|R i |c S $t r? )
isinstancer! rR rS rT r. )rK r: rV r; r< rC rD s r4 r@ zPayloadRegistry.getj s dG $ $ K #VDK tz J J 6 6MGT$%%
6 wt5d555f55555
6 mmr3 rA rC rD rB c . |t j u r | j ||f d S |t j u r | j ||f d S |t j u r | j ||f d S t d| )NzUnsupported order ) r6 r8 rR appendr7 rS r9 rT
ValueError)rK rC rD rB s r4 rG zPayloadRegistry.registery s EO # # K / / / / /
el
"
" L $ 0 0 0 0 0
en
$
$ J wo . . . . . ;% ; ;<<
=
=
=
=
=
=
=r3 rP c e Zd ZU dZeed< dZee ed< de ddfde
dee e e
eef eeeef f de edef dee d ee d
e
d dfd Zed ee fd
Zed ee fd Zed e fd Zed efd Zed ee fd Zed efd Z d dededede
d df
dZe de d dfd Z dS ) r! application/octet-stream_default_content_typeN_sizevalueheaders content_typefilenameencodingr< r= c || _ || _ t | _ || _ |t
ur||| j t j < n]| j =t j | j d }|| j
}|| j t j < n| j
| j t j < | j |pi d S Nr ) _encoding _filenamer _headers_valuer r CONTENT_TYPE mimetypes
guess_typer` update)rK rb rc rd re rf r< s r4 rL zPayload.__init__ s "!&1mm
x ' 'L,D/;DM$+ , ,
^
'$/??BL# # 9 /;DM$+ , ,/3/IDM$+ ,
W]+++++r3 c | j S )zSize of the payload.)ra rU s r4 sizez Payload.size s zr3 c | j S )zFilename of the payload.)rj rU s r4 re zPayload.filename ~ r3 c | j S )zCustom item headers)rk rU s r4 rc zPayload.headers s } r3 c d d | j D d dz S )N c * g | ]\ }}|d z |z dz S )z: z
r2 ).0kvs r4
z+Payload._binary_headers.. s) LLLtq!QX\F*LLLr3 utf-8s
)joinrc itemsencoderU s r4 _binary_headerszPayload._binary_headers sR
GGLLt|7I7I7K7KLLL M M T T
r3 c | j S )zPayload encoding)ri rU s r4 rf zPayload.encoding rt r3 c 0 | j t j S )z Content type)rk r rm rU s r4 rd zPayload.content_type s }T .//r3 Tr} disptype quote_fields_charsetparamsc J t |f||d|| j t j < dS )z$Sets ``Content-Disposition`` header.)r r N)r rk r CONTENT_DISPOSITION)rK r r r r s r4 set_content_dispositionz Payload.set_content_disposition s> 3M 3
#/(3
3
FL3
3
d.///r3 writerc
K dS )zLWrite payload.
writer is an AbstractStreamWriter instance:
Nr2 rK r s r4 writez
Payload.write s
r3 )Tr} ) r/ r0 r1 r` str__annotations__ra r
intr r r r r
r r r rL propertyrr re rc bytesr rf rd boolr r r r r2 r3 r4 r! r! sY !;3;;; E8C=
4<"&"&, ,, ,S#XsCx 0II J
, Cy 01
, 3-, 3-, ,
, , , ,4 hsm X (3- X X
X
(3- X 0c 0 0 0 X0 "
"6 4 ^ r3 c @ e Zd Zdedededdf fd ZdeddfdZ xZS ) r" rb r; r< r= Nc t |t t t f s t dt | d|vrd|d< t
j |g|R i | t |t r
|j | _ nt | | _ | j t k r d| i}t j
dt fi | d S d S )Nz%value argument must be byte-ish, not rd r_ sourcez}Sending a large body directly with raw bytes might lock the event loop. You should probably pass an io.BytesIO object instead)rX r bytearray
memoryview TypeErrorrD superrL nbytesra lenr+ warningswarnResourceWarningrK rb r; r< __class__s r4 rL zBytesPayload.__init__ s %%J!?@@ U SDKK S STT T ' '%?F> "0000000 eZ ( ( $ DJJ UDJ :, , , %F M,
- ,r3 r c J K | | j d {V d S r? )r rl r s r4 r zBytesPayload.write s2 ll4;'''''''''''r3 ) r/ r0 r1 r r rL r r
__classcell__r s @r4 r" r" s| j 0("6 (4 ( ( ( ( ( ( ( (r3 r" c
X e Zd Zddddededee dee deddf fd Z xZS )
r# Nrf rd rb r; rf rd r< r= c |2|d}d}n4t | }|j dd }n |d|z }|} t j | | g|R ||d| d S )Nr} text/plain; charset=utf-8charsettext/plain; charset=%sr )r
parametersr@ r rL r ) rK rb rf rd r; r<
real_encodingmimetyper s r4 rL zStringPayload.__init__ s # '
: ),77 ( 3 7 7 7 K K
# 7( B $M LL ' '
"%
r3 )r/ r0 r1 r r r
rL r r s @r4 r# r# s
#'&*
3-
sm
r3 r# c < e Zd Zdee dededdf fd Z xZS )r( rb r; r< r= Nc f t j | g|R i | d S r? )r rL readr s r4 rL zStringIOPayload.__init__ s8 777777777r3 )r/ r0 r1 r r r rL r r s @r4 r( r( s] 8bg 8c 8S 8T 8 8 8 8 8 8 8 8 8 8r3 r( c l e Zd ZU ee ed< d dee dedededdf
fd
Zd
eddfd Z xZ
S )
r$ rl
attachmentrb dispositionr; r< r= Nc d|vrt | |d< t j |g|R i | | j 3|3t j | j vr"| || j d S d S d S d S )Nre )re )r r rL rj r r rc r )rK rb r r; r< r s r4 rL zIOBasePayload.__init__ s V # #!/!6!6F: 0000000 > %+*A't|;;,,[4>,RRRRR & %*A*A;;r3 r c K t j } | d | j j d d {V }|rD| | d {V | d | j j d d {V }|D| d | j j d {V d S # | d | j j d {V w xY w)N )asyncioget_event_looprun_in_executorrl r r close)rK r loopchunks r4 r zIOBasePayload.write+ s %'' @ ..tT[5EuMMMMMMMME
R ll5))))))))) " 2 249I5 Q QQQQQQQ
R &&tT[->?? ? ? ? ? ? ? ? ? ?$&&tT[->?? ? ? ? ? ? ? ? ?s A-B, ,(C)r ) r/ r0 r1 r r r r rL r r r r s @r4 r$ r$ s sGOOO 2>
S
SW
S+.
SFI
SUX
S
S
S
S
S
S
S@"6 @4 @ @ @ @ @ @ @ @r3 r$ c
e Zd ZU eed< ddddededee dee ded df fd
Ze d ee
fd Z d e d dfd
Z
xZS )r' rl Nr rb r; rf rd r< r= c |2|d}d}n2t | }|j dd }n|d|z } t j |g|R ||d| d S )Nr} r r r rd rf )r r r@ r rL )rK rb rf rd r; r< r r s r4 rL zTextIOPayload.__init__9 s #" : ),77#.229gFF# 7( B
%
r3 c t j | j j | j z
S # t $ r Y d S w xY wr? osfstatrl filenost_sizetellOSErrorrU s r4 rr zTextIOPayload.sizeU s] 8DK . . 0 0119DK?? ? ? ? ? ? ? ? ? ?$&&tT[->?? ? ? ? ? ? ? ? ?s B#C" "(D
)r/ r0 r1 r r r r
r rL r r rr r r r r s @r4 r' r' 6 s NNN #'&*
3-
sm
8 hsm X
@"6
@4
@
@
@
@
@
@
@
@r3 r' c * e Zd Zedefd ZdS )r% r= c | j }| j dt j }| j | ||z
S rh )rl r seekr SEEK_END)rK positionends r4 rr zBytesIOPayload.sizem sN ;##%%k q"+.. """X~ r3 N)r/ r0 r1 r r rr r2 r3 r4 r% r% l s9
c X r3 r% c 6 e Zd Zedee fd ZdS )r& r= c t j | j j | j z
S # t $ r Y d S w xY wr? r rU s r4 rr zBufferedReaderPayload.sizev s_ 8DK . . 0 0119DK "0000000__&&
r3 r c K | j rU | j d {V }| | d {V ;# t $ r d | _ Y d S w xY wd S r? )r __anext__r StopAsyncIteration)rK r r s r4 r zAsyncIterablePayload.write s : "
"."&*"6"6"8"8 8 8 8 8 8 8E ,,u---------. &
"
"
" !
" " "s r sd # # # # # # # #
" ! ! ! ! ! % % % % % % " ! ! ! ! ! / / / / / / / / $) eCj ( ( ( ) C 7c 7# 7 7 7 7 7 7
8 8 8 8 8m 8 8 8
@ @ @ @ @G @ @ @43@ 3@ 3@ 3@ 3@M 3@ 3@ 3@l ] M
,
( #33333333"5)N"5)NN<<<<<<<<"N"N " " " " "7 " " ">< < < < <. < < <
#?$$ , :(F G G G - - - - /2; 7 7 7 - 7 7 7 ."* 5 5 5 /"2CREV1W X X X - 3 3 3 -| < < < .
U^ T T T T Tr3