/usr/local/lib64/python3.6/site-packages/aiohttp/__pycache__
Edit: /usr/local/lib64/python3.6/site-packages/aiohttp/__pycache__/payload.cpython-36.pyc (13433B)
3
8%Eg@5
@ s U d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZm Z d dl
m Z d dl m
Z
mZmZmZmZmZmZmZmZmZmZ d dlmZ ddlmZ ddlm Z dd l m Z m Z m Z m!Z!m"Z" dd
l#m$Z$ dd l%m&Z&m'Z'm(Z( d6Z)d7Z*e&e+ *er d dl m,Z, G d d d e-Z.G d d d e/ej0Z1eeedd d!d
Z2e1j3d"ed ee1dd#d$d%Z4G d&d dZ5ed Z6ee6ef Z7G d'd( d(Z8G d)d deZ9G d*d de9Z:G d+d de:Z;G d,d de;Z
G d/d de=Z?G d0d de=Z@G d1d de:ZAerLd d2l mBZBmCZC eCeD ZEeBeD ZFnd d2lGmBZBmCZC eCZEeBZFG d3d de9ZHG d4d5 d5eHZIe8 ZJeJjKe:eDeLeMf eJjKe;e/ eJjKeejO eJjKe?ejP eJjKe@ejQejRf eJjKe=ejS eJjKeIe$ eJjKeHeBe1jTd" dS )8 N)ABCabstractmethod)chain) IO
TYPE_CHECKINGAny
ByteStringDictIterableOptionalTextIOTupleTypeUnion) CIMultiDict )hdrs)AbstractStreamWriter)PY_36content_disposition_headerguess_filenameparse_mimetypesentinel) StreamReader)Final JSONEncoder _CIMultiDictPAYLOAD_REGISTRY get_payload payload_typePayload BytesPayload
StringPayload
IOBasePayloadBytesIOPayloadBufferedReaderPayload
TextIOPayloadStringIOPayload JsonPayloadAsyncIterablePayload )Listc @ s e Zd ZdS ) LookupErrorN)__name__
__module__ __qualname__ r1 r1 ;/usr/local/lib64/python3.6/site-packages/aiohttp/payload.pyr- < s r- c @ s e Zd ZdZdZdZdS )Ordernormal try_firsttry_lastN)r. r/ r0 r4 r5 r6 r1 r1 r1 r2 r3 @ s r3 )dataargskwargsreturnc O s t j| f||S )N)r get)r7 r8 r9 r1 r1 r2 r F s )order)factorytyper< r: c C s t j| ||d d S )N)r< )r register)r= r> r< r1 r1 r2 register_payloadJ s r@ c @ s> e Zd ZejdeeddddZed ed ddd ZdS )
r )r< N)r> r< r: c C s || _ || _d S )N)r> r< )selfr> r< r1 r1 r2 __init__Q s zpayload_type.__init__r )r= r: c C s t || j| jd |S )N)r< )r@ r> r< )rA r= r1 r1 r2 __call__U s zpayload_type.__call__) r. r/ r0 r3 r4 r rB r rC r1 r1 r1 r2 r P s c @ sV e Zd ZdZddddZedeededd d
d Zej d e
eedd
ddZ dS )PayloadRegistryzZPayload registry.
note: we need zope.interface for more efficient adapter search
N)r: c C s g | _ g | _g | _d S )N)_first_normal_last)rA r1 r1 r2 rB d s zPayloadRegistry.__init__)_CHAINz!Type[chain[_PayloadRegistryItem]]r )r7 r8 rH r9 r: c O sR t |tr|S x8|| j| j| jD ]"\}}t ||r"||f||S q"W t d S )N)
isinstancer rE rF rG r- )rA r7 rH r8 r9 r= r> r1 r1 r2 r; i s
zPayloadRegistry.get)r< )r= r> r< r: c C sf |t jkr | jj||f nF|t jkr8| jj||f n*|t jkrT| jj||f ntd|d S )NzUnsupported order ) r3 r5 rE appendr4 rF r6 rG
ValueError)rA r= r> r< r1 r1 r2 r? x s
zPayloadRegistry.register) r. r/ r0 __doc__rB r r r; r3 r4 PayloadTyper? r1 r1 r1 r2 rD ^ s
rD c
@ s e Zd ZU dZedZee deddfe ee
e e eef e
eeef f ee ee ee e ddddZeee dddZeee dd d
Zee dd d Zeedd
dZeee dddZeedddZdeeee ddddZeeddddZ dS ) r zapplication/octet-streamN)valueheaders content_typefilenameencodingr9 r: c K s || _ || _t | _|| _|tk r8|d k r8|| jtj< nD| jd k rntj | jd }|d kr`| j
}|| jtj< n| j
| jtj< | jj |pi d S )Nr ) _encoding _filenamer _headers_valuer r CONTENT_TYPE mimetypes
guess_type_default_content_typeupdate)rA rN rO rP rQ rR r9 r1 r1 r2 rB s
zPayload.__init__)r: c C s | j S )zSize of the payload.)_size)rA r1 r1 r2 size s z Payload.sizec C s | j S )zFilename of the payload.)rT )rA r1 r1 r2 rQ s zPayload.filenamec C s | j S )zCustom item headers)rU )rA r1 r1 r2 rO s zPayload.headersc C s$ dj dd | jj D jdd S )N c S s g | ]\}}|d | d qS )z: z
r1 ).0kvr1 r1 r2
s z+Payload._binary_headers..zutf-8s
)joinrO itemsencode)rA r1 r1 r2 _binary_headers s zPayload._binary_headersc C s | j S )zPayload encoding)rS )rA r1 r1 r2 rR s zPayload.encodingc C s | j tj S )z Content type)rU r rW )rA r1 r1 r2 rP s zPayload.content_typeTutf-8)disptype quote_fields_charsetparamsr: c K s" t |f||d|| jtj< dS )z$Sets ``Content-Disposition`` header.)ri rj N)r rU r CONTENT_DISPOSITION)rA rh ri rj rk r1 r1 r2 set_content_disposition s z Payload.set_content_disposition)writerr: c s dS )zLWrite payload.
writer is an AbstractStreamWriter instance:
Nr1 )rA rn r1 r1 r2 write s z
Payload.write)Trg ) r. r/ r0 rZ strr\ r intr r r r r r
r
rB propertyr] rQ rO bytesrf rR rP boolrm r r ro r1 r1 r1 r2 r s4
< c s8 e Zd Zeeedd fdd ZeddddZ ZS )r! N)rN r8 r9 r: c s t |tttfs"tdt|d|kr2d|d< t j|f|| t |trZ|j| _ n
t
|| _ | j t krt r|d| i}ni }t
jdtf| d S )Nz%value argument must be byte-ish, not rP zapplication/octet-streamsourcez}Sending a large body directly with raw bytes might lock the event loop. You should probably pass an io.BytesIO object instead)rI rs bytearray
memoryview TypeErrorr> superrB nbytesr\ lenTOO_LARGE_BYTES_BODYr warningswarnResourceWarning)rA rN r8 r9 ) __class__r1 r2 rB s
zBytesPayload.__init__)rn r: c s |j | jI d H d S )N)ro rV )rA rn r1 r1 r2 ro s zBytesPayload.write) r. r/ r0 r r rB r ro
__classcell__r1 r1 )r r2 r! s c s< e Zd Zdddeeee ee edd fddZ ZS )r" N)rR rP )rN r8 rR rP r9 r: c sn |d kr2|d krd}d}qFt |}|jjdd}n|d krBd| }|}t j|j|f|||d| d S )Nzutf-8ztext/plain; charset=utf-8charsetztext/plain; charset=%s)rR rP )r
parametersr; ry rB re )rA rN rR rP r8 r9 Z
real_encodingmimetype)r r1 r2 rB s
zStringPayload.__init__)r. r/ r0 rp r r rB r r1 r1 )r r2 r" s c s, e Zd Zee eedd fdd Z ZS )r' N)rN r8 r9 r: c s t j|j f|| d S )N)ry rB read)rA rN r8 r9 )r r1 r2 rB s zStringIOPayload.__init__)r. r/ r0 r rp r rB r r1 r1 )r r2 r' s c sJ e Zd ZU ee d ee eeedd fdd
ZeddddZ Z
S )
r#
attachmentN)rN dispositionr8 r9 r: c sZ d|krt ||d< t j|f|| | jd k rV|d k rVtj| jkrV| j|| jd d S )NrQ )rQ )r ry rB rT r rl rO rm )rA rN r r8 r9 )r r1 r2 rB ! s zIOBasePayload.__init__)rn r: c st t j }zN|jd | jjdI d H }x0|rR|j|I d H |jd | jjdI d H }q$W W d |jd | jjI d H X d S )Nr* i i )asyncioget_event_looprun_in_executorrV r ro close)rA rn loopchunkr1 r1 r2 ro - s zIOBasePayload.write)r ) r. r/ r0 r r rV rp rB r ro r r1 r1 )r r2 r# s
c sh e Zd ZU edddeeee ee edd fddZe ee
dddZ e dd d
d Z
ZS ) r& N)rR rP )rN r8 rR rP r9 r: c sd |d kr2|d krd}d}qBt |}|jjdd}n|d krBd| }t j|f|||d| d S )Nzutf-8ztext/plain; charset=utf-8r ztext/plain; charset=%s)rP rR )r r r; ry rB )rA rN rR rP r8 r9 r )r r1 r2 rB ; s zTextIOPayload.__init__)r: c C s6 y t j| jj j| jj S tk
r0 d S X d S )N)osfstatrV filenost_sizetellOSError)rA r1 r1 r2 r] W s zTextIOPayload.size)rn r: c s t j }zj|jd | jjdI d H }xL|rn| jr<|j| jdn|j }|j|I d H |jd | jjdI d H }q$W W d |jd | jjI d H X d S )Nr* r )rR i i ) r r r rV r rS re ro r )rA rn r r r7 r1 r1 r2 ro ^ s zTextIOPayload.write)r. r/ r0 r rV r r rp rB rr rq r] r ro r r1 r1 )r r2 r& 8 s
c @ s e Zd ZeedddZdS )r$ )r: c C s. | j j }| j jdtj}| j j| || S )Nr )rV r seekr SEEK_END)rA positionendr1 r1 r2 r] o s
zBytesIOPayload.sizeN)r. r/ r0 rr rq r] r1 r1 r1 r2 r$ n s c @ s" e Zd Zeee dddZdS )r% )r: c C s6 y t j| jj j| jj S tk
r0 d S X d S )N)r r rV r r r r )rA r1 r1 r2 r] x s zBufferedReaderPayload.sizeN)r. r/ r0 rr r rq r] r1 r1 r1 r2 r% w s c s8 e Zd Zddejfeeeeeedd fdd
Z Z S )r( zutf-8zapplication/jsonN)rN rR rP dumpsr8 r9 r: c s, t j||j|f|||d| d S )N)rP rR )ry rB re )rA rN rR rP r r8 r9 )r r1 r2 rB s
zJsonPayload.__init__)
r. r/ r0 jsonr r rp r rB r r1 r1 )r r2 r( s )
AsyncIterable
AsyncIteratorc sF e Zd ZU dZee eeedd fdd Ze ddddZ
Z S )r) N)rN r8 r9 r: c sN t |ts tdjt|d|kr,d|d< t j|f|| |j | _d S )NzMvalue argument must support collections.abc.AsyncIterable interface, got {!r}rP zapplication/octet-stream) rI r rx formatr> ry rB __aiter___iter)rA rN r8 r9 )r r1 r2 rB s
z AsyncIterablePayload.__init__)rn r: c sP | j rLy*x$| j j I d H }|j|I d H q
W W n tk
rJ d | _ Y nX d S )N)r __anext__ro StopAsyncIteration)rA rn r r1 r1 r2 ro s zAsyncIterablePayload.write) r. r/ r0 r r _AsyncIterator_AsyncIterabler rB r ro r r1 r1 )r r2 r) s
c s( e Zd Zeeedd fdd Z ZS )StreamReaderPayloadN)rN r8 r9 r: c s t j|j f|| d S )N)ry rB Ziter_any)rA rN r8 r9 )r r1 r2 rB s z StreamReaderPayload.__init__)r. r/ r0 r r rB r r1 r1 )r r2 r s r )
r r r r r! r" r# r$ r% r& r' r( r) i )Ur enumior rX r r} abcr r itertoolsr typingr r r r r r
r r r
r r Z multidictr r^ r r Zhelpersr r r r r streamsr Ztypedefsr r r __all__r| rq r, Exceptionr- rp Enumr3 r r4 r@ r rM Z_PayloadRegistryItemrD r r! r" r' r# r& r$ r% r( r r rs r r collections.abcr) r r r? rv rw StringIO
TextIOBaseBytesIOBufferedReaderBufferedRandomIOBaser6 r1 r1 r1 r2 s 4
'U 6