ÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂ U 'â7`4ã@søddlZddlZddlZddlZddlZddlZddlZddlmZm Z ddl mZddlm Z mZmZmZmZmZmZmZmZmZmZmZddlmZddlmZddlmZdd lmZm Z m!Z!m"Z"m#Z#dd l$m%Z%ddl&m'Z'm(Z(dZ)d Z*erddlm+Z+Gdd„de,ƒZ-Gdd„de.ej/ƒZ0eeeddœdd„Z1e0j2dœedee0ddœdd„Z3Gdd„dƒZ4Gdd„dƒZ5Gdd„deƒZ6Gd d!„d!e6ƒZ7Gd"d#„d#e7ƒZ8Gd$d%„d%e8ƒZ9Gd&d'„d'e6ƒZ:Gd(d)„d)e:ƒZ;Gd*d+„d+e:ƒZer.dd0lm?Z?m@Z@e@eAZBe?eAZCndd0lDm?Z?m@Z@e@ZBe?ZCGd1d2„d2e6ƒZEGd3d4„d4eEƒZFe5ƒZGeG He7eAeIeJf¡eG He8e.¡eG He9ejK¡eG He;ejL¡eG Hesr+c@seZdZdZdZdZdS)ÚOrderÚnormalÚ try_firstÚtry_lastN)r,r-r.r2r3r4r/r/r/r0r1Bsr1r )ÚdataÚargsÚkwargsÚreturncOstj|f|ž|ŽS©N)rÚget)r5r6r7r/r/r0rHsr©Úorder©ÚfactoryÚtyper<r8cCstj|||ddS©Nr;)rÚregister)r>r?r<r/r/r0Úregister_payloadLsrBc@s>eZdZejdœeeddœdd„Zededdœdd „ZdS) rr;N)r?r<r8cCs||_||_dSr9)r?r<)Úselfr?r<r/r/r0Ú__init__Sszpayload_type.__init__r )r>r8cCst||j|jd|Sr@)rBr?r<)rCr>r/r/r0Ú__call__Wszpayload_type.__call__) r,r-r.r1r2rrDrrEr/r/r/r0rRsrc@sZeZdZdZddœdd„Zedœeeeeddœd d „Zej dœe deeddœd d„ZdS)ÚPayloadRegistryzZPayload registry. note: we need zope.interface for more efficient adapter search N©r8cCsg|_g|_g|_dSr9)Ú_firstÚ_normalÚ_last©rCr/r/r0rDbszPayloadRegistry.__init__)Ú_CHAINr )r5r6rLr7r8cOsRt|tƒr|S||j|j|jƒD]&\}}t||ƒr ||f|ž|ŽSq tƒ‚dSr9)Ú isinstancer rHrIrJr+)rCr5rLr6r7r>r?r/r/r0r:gs zPayloadRegistry.getr;r=cCsf|tjkr|j ||f¡nF|tjkr8|j ||f¡n*|tjkrT|j ||f¡ntd|›ƒ‚dS)NzUnsupported order ) r1r3rHÚappendr2rIr4rJÚ ValueError)rCr>r?r<r/r/r0rArs zPayloadRegistry.register)r,r-r.Ú__doc__rDrrr:r1r2rrAr/r/r/r0rF\s"ÿþÿþrFc @seZdZdZdZdeddfeeee e eefee eeffeeeeeeeddœdd„Zeeedœdd„ƒZeeedœd d „ƒZee dœdd„ƒZeedœd d„ƒZeeedœdd„ƒZeedœdd„ƒZdeeeddœdd„Zeeddœdd„ƒZdS)r úapplication/octet-streamN)ÚvalueÚheadersÚcontent_typeÚfilenameÚencodingr7r8cKs||_||_tƒ|_||_|tk r8|dk r8||jtj<nD|jdk rnt |j¡d}|dkr`|j }||jtj<n|j |jtj<|j |pˆi¡dS©Nr)Ú _encodingÚ _filenamerÚ_headersÚ_valuerrÚCONTENT_TYPEÚ mimetypesZ guess_typeÚ_default_content_typeÚupdate)rCrRrSrTrUrVr7r/r/r0rD„s zPayload.__init__rGcCs|jS)zSize of the payload.)Ú_sizerKr/r/r0ÚsizežszPayload.sizecCs|jS)zFilename of the payload.)rYrKr/r/r0rU£szPayload.filenamecCs|jS)zCustom item headers)rZrKr/r/r0rS¨szPayload.headerscCs$d dd„|j ¡Dƒ¡ d¡dS)NÚcSs g|]\}}|d|d‘qS)z: z r/)Ú.0ÚkÚvr/r/r0Ú °sz+Payload._binary_headers..úutf-8s )ÚjoinrSÚitemsÚencoderKr/r/r0Ú_binary_headerssÿýÿzPayload._binary_headerscCs|jS)zPayload encoding)rXrKr/r/r0rV¶szPayload.encodingcCs|jtjS)zContent type)rZrr\rKr/r/r0rT»szPayload.content_typeT)ÚdisptypeÚquote_fieldsÚparamsr8cKs t|fd|i|—Ž|jtj<dS)z$Sets ``Content-Disposition`` header.rmN)rrZrÚCONTENT_DISPOSITION)rCrlrmrnr/r/r0Úset_content_dispositionÀsÿÿÿzPayload.set_content_disposition©Úwriterr8cÃsdS)zLWrite payload. writer is an AbstractStreamWriter instance: Nr/©rCrrr/r/r0ÚwriteÈsz Payload.write)T)r,r-r.r^r`rrrrrr Ústrr rrDÚpropertyÚintrarUrSÚbytesrkrVrTÚboolrprrrtr/r/r/r0r sLø ÿöÿþcs8eZdZeeeddœ‡fdd„Zeddœdd„Z‡ZS)r!N©rRr6r7r8cs”t|tttfƒs"td t|ƒ¡ƒ‚d|kr2d|d<tƒj|f|ž|Žt|tƒrZ|j |_ n t|ƒ|_ |j tkrt r|d|i}ni}tjdtf|ŽdS)Nz)value argument must be byte-ish, not {!r}rTrQÚsourcez}Sending a large body directly with raw bytes might lock the event loop. You should probably pass an io.BytesIO object instead)rMrxÚ bytearrayÚ memoryviewÚ TypeErrorÚformatr?ÚsuperrDÚnbytesr`ÚlenÚTOO_LARGE_BYTES_BODYrÚwarningsÚwarnÚResourceWarning©rCrRr6r7©Ú __class__r/r0rDÑs(ÿ üûzBytesPayload.__init__rqcÃs| |j¡IdHdSr9)rtr[rsr/r/r0rtîszBytesPayload.write) r,r-r.rrrDrrtÚ __classcell__r/r/rˆr0r!Ðsr!cs<eZdZdddœeeeeeeeddœ‡fdd„Z‡ZS)r"N©rVrT©rRr6rVrTr7r8csn|dkr2|dkrd}d}qFt|ƒ}|j dd¡}n|dkrBd|}|}tƒj| |¡f|ž||dœ|—ŽdS)Nrgútext/plain; charset=utf-8Úcharsetútext/plain; charset=%sr‹)rÚ parametersr:r€rDrj)rCrRrVrTr6r7Z real_encodingÚmimetyperˆr/r0rDós& ÿüýûzStringPayload.__init__) r,r-r.rrrrurDrŠr/r/rˆr0r"òsûùr"cs,eZdZeeeeddœ‡fdd„Z‡ZS)r'Nrzcstƒj| ¡f|ž|ŽdSr9)r€rDÚreadr‡rˆr/r0rDszStringIOPayload.__init__)r,r-r.rrurrDrŠr/r/rˆr0r'sr'cs@eZdZd eeeeeddœ‡fdd„ Zeddœdd„Z‡Z S) r#Ú attachmentN)rRÚdispositionr6r7r8csZd|krt|ƒ|d<tƒj|f|ž|Ž|jdk rV|dk rVtj|jkrV|j||jddS)NrU)rU)rr€rDrYrrorSrp)rCrRr”r6r7rˆr/r0rDszIOBasePayload.__init__rqc Ãspt ¡}zJ| d|jjd¡IdH}|rP| |¡IdH| d|jjd¡IdH}q"W5| d|jj¡IdHXdS©Ni)ÚasyncioÚget_event_loopÚrun_in_executorr[Úcloser’rt©rCrrZloopÚchunkr/r/r0rt#szIOBasePayload.write)r“) r,r-r.rrrurDrrtrŠr/r/rˆr0r#sÿþr#csbeZdZdddœeeeeeeeddœ‡fdd„Zeee dœdd„ƒZ edd œd d„Z‡Z S)r&Nr‹rŒcsd|dkr2|dkrd}d}qBt|ƒ}|j dd¡}n|dkrBd|}tƒj|f|ž||dœ|—ŽdS)NrgrrŽr©rTrV)rrr:r€rD)rCrRrVrTr6r7r‘rˆr/r0rD/s$ ÿüýûzTextIOPayload.__init__rGcCs:zt |j ¡¡j|j ¡WStk r4YdSXdSr9©ÚosÚfstatr[ÚfilenoÚst_sizeÚtellÚOSErrorrKr/r/r0raKszTextIOPayload.sizerqc Ãsxt ¡}zR| d|jjd¡IdH}|rX| | |j¡¡IdH| d|jjd¡IdH}q"W5| d|jj¡IdHXdSr•) r–r—r˜r[r™r’rtrjrXršr/r/r0rtRszTextIOPayload.write)r,r-r.r rrrurDrvrwrarrtrŠr/r/rˆr0r&.sûùr&c@seZdZeedœdd„ƒZdS)r$rGcCs.|j ¡}|j dtj¡}|j |¡||SrW)r[r¢ÚseekržÚSEEK_END)rCÚpositionÚendr/r/r0ra^s zBytesIOPayload.sizeN)r,r-r.rvrwrar/r/r/r0r$]sr$c@s"eZdZeeedœdd„ƒZdS)r%rGcCs:zt |j ¡¡j|j ¡WStk r4YdSXdSr9rrKr/r/r0ragszBufferedReaderPayload.sizeN)r,r-r.rvrrwrar/r/r/r0r%fsr%c s8eZdZddejfeeeeeeddœ‡fdd„ Z‡Z S)r(rgzapplication/jsonN)rRrVrTÚdumpsr6r7r8cs,tƒj||ƒ |¡f|ž||dœ|—ŽdS)Nrœ)r€rDrj)rCrRrVrTr¨r6r7rˆr/r0rDrs ÿüýûzJsonPayload.__init__) r,r-r.Újsonr¨rrurrDrŠr/r/rˆr0r(qsûør()Ú AsyncIterableÚ AsyncIteratorcs<eZdZdZeeeddœ‡fdd„Zeddœdd„Z‡Z S)r)NrzcsNt|tƒstd t|ƒ¡ƒ‚d|kr,d|d<tƒj|f|ž|Ž| ¡|_dS)NzOvalue argument must support collections.abc.AsyncIterablebe interface, got {!r}rTrQ) rMrªr~rr?r€rDÚ __aiter__Ú_iterr‡rˆr/r0rD•s þÿzAsyncIterablePayload.__init__rqcÃsL|jrHz&|j ¡IdH}| |¡IdHqWntk rFd|_YnXdSr9)rÚ __anext__rtÚStopAsyncIteration)rCrrr›r/r/r0rt¤szAsyncIterablePayload.write) r,r-r.rÚ_AsyncIterablerrDrrtrŠr/r/rˆr0r)‘sr)cs(eZdZeeeddœ‡fdd„Z‡ZS)ÚStreamReaderPayloadNrzcstƒj| ¡f|ž|ŽdSr9)r€rDZiter_anyr‡rˆr/r0rD±szStreamReaderPayload.__init__)r,r-r.rrrDrŠr/r/rˆr0r±°sr±)Rr–ÚenumÚior©r]ržr„ÚabcrrÚ itertoolsrÚtypingrrrrr r rrr rrrZ multidictrrbrrZhelpersrrrrrZstreamsrZtypedefsrrÚ__all__rƒr*Ú Exceptionr+ruÚEnumr1rr2rBrrFr r!r"r'r#r&r$r%r(rªr«rxZ_AsyncIteratorr°Úcollections.abcr)r±rrAr|r}ÚStringIOÚ TextIOBaseÚBytesIOÚBufferedReaderÚBufferedRandomÚIOBaser4r/r/r/r0Úsv8ÿþ #Q"/