;3hlt \UddlZddlZddlZddlZddlZddlZddlZddlZddlm Z m Z ddl m Z ddl mZmZmZmZmZmZmZmZmZmZmZmZddlmZddlmZddlmZdd lm 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<dZ.ee,e-d<e/Z0eejbde-d<erddl m2Z2Gdde3Z4Gdde5ejlZ7dedededdfdZ8e7jrddedded e7ddfd!Z:Gd"d#Z;edZGd&de Z?Gd'd(e?Z@Gd)d*e@ZAGd+d,eAZBGd-d.e?ZCGd/d0eCZDGd1d2eCZEGd3d4eCZFGd5d6e@ZGerdd7l mHZHmIZIeIeJZKeHeJZLn dd7lMmHZHmIZIeIZKeHZLGd8d9e?ZNGd:d;eNZOe>ZPePje@eJeReSfePjeAe5ePjeBejePjeDejePjeEejePjeFejejfePjeCejePjeOe&ePjeNeHe7jy)<N)ABCabstractmethod)chain) IO TYPE_CHECKINGAnyDictFinalIterableOptionalSetTextIOTupleTypeUnion) CIMultiDict)hdrs)AbstractStreamWriter) _SENTINELcontent_disposition_headerguess_filenameparse_mimetypesentinel) StreamReader) JSONEncoder _CIMultiDict) PAYLOAD_REGISTRY get_payload payload_typePayload BytesPayload StringPayload IOBasePayloadBytesIOPayloadBufferedReaderPayload TextIOPayloadStringIOPayload JsonPayloadAsyncIterablePayloadiTOO_LARGE_BYTES_BODYi READ_SIZE_CLOSE_FUTURES)Listc eZdZy) LookupErrorN)__name__ __module__ __qualname__O/var/www/html/audio-gradio/venv/lib/python3.12/site-packages/aiohttp/payload.pyr0r0Asr5r0ceZdZdZdZdZy)Ordernormal try_firsttry_lastN)r1r2r3r9r:r;r4r5r6r8r8Es FIHr5r8dataargskwargsreturnr!c4tj|g|i|SN)rget)r<r=r>s r6rrKs    6t 6v 66r5orderfactorytyperDc4tj|||yNrC)rregister)rErFrDs r6register_payloadrJOsgt59r5cVeZdZejddededdfdZdeddedfd Zy) r rCrFrDr?Nc ||_||_yrA)rFrD)selfrFrDs r6__init__zpayload_type.__init__Vs  r5rEr!cJt||j|j|SrH)rJrFrD)rMrEs r6__call__zpayload_type.__call__Zs$))4::>r5) r1r2r3r8r9rrNrrPr4r5r6r r Us>49LLSETYDOr5r c peZdZdZdZddZeddeded d d edd f d Ze jdde dede ddfdZ y)PayloadRegistryzZPayload registry. note: we need zope.interface for more efficient adapter search _first_normal_last_normal_lookupr?Nc<g|_g|_g|_i|_yrArSrMs r6rNzPayloadRegistry.__init__ks24 35 13 68r5)_CHAINr<r=rZz!Type[chain[_PayloadRegistryItem]]r>r!c|jr.|jD]\}}t||s||g|i|cS|jjt |x}r ||g|i|St|t r|S||j |jD]\}}t||s||g|i|cStrA) rT isinstancerWrBrFr!rUrVr0)rMr<rZr=r>rEtype_lookup_factorys r6rBzPayloadRegistry.getqs ;;"&++ :dE*"49$9&99 :"0044T$Z@ @> @!$888 8 dG $K$T\\4::> 6NGU$&t5d5f55 6mr5rCrErFrDc|tjur|jj||fy|tjurT|j j||ft |tr|D]}||j|<y||j|<y|tjur|jj||fytd|)NzUnsupported order ) r8r:rTappendr9rUr\r rWr;rV ValueError)rMrErFrDts r6rIzPayloadRegistry.registers EOO # KK   / ell " LL  $ 0$)5A-4D''*5-4##D) enn $ JJ  wo .1%;< = =r5rRceZdZUdZeed<dZeeed<de ddfde dee e e eefeeeeffde edefdeed eed e d dfd Zed eefd Zed eefdZed e fdZed efdZed eefdZed efdZ ddededede d df dZedd eded efdZeded dfdZdedeed dfdZ y) r!application/octet-stream_default_content_typeN_sizevalueheaders content_typefilenameencodingr>r?c (||_||_t|_||_|t ur |||jt j<n|jutjdk\rtj}ntj}||jd}| |j}||jt j<n'|j|jt j<|r|jj|yy)N) r) _encoding _filenamer_headers_valuerr CONTENT_TYPEsys version_info mimetypesguess_file_type guess_typerhupdate)rMrjrkrlrmrnr>guessers r6rNzPayload.__init__s"!&1m  x 'L,D/;DMM$++ , ^^ '7*#33#.."4>>215L##99 /;DMM$++ ,/3/I/IDMM$++ ,  MM  ) r5c|jS)zSize of the payload.)rirYs r6sizez Payload.sizeszzr5c|jS)zFilename of the payload.)rsrYs r6rmzPayload.filename~~r5c|jS)zCustom item headers)rtrYs r6rkzPayload.headerss}}r5cdj|jjDcgc]\}}|dz|zdzc}}jddzScc}}w)Nz: z utf-8s )joinrkitemsencode)rMkvs r6_binary_headerszPayload._binary_headerssY GGt||7I7I7KLtq!QX\F*L M T T   LsA c|jS)zPayload encoding)rrrYs r6rnzPayload.encodingrr5c<|jtjS)z Content type)rtrrvrYs r6rlzPayload.content_types}}T..//r5disptype quote_fields_charsetparamsc Xt|f||d||jtj<y)z$Sets ``Content-Disposition`` header.)rrN)rrtrCONTENT_DISPOSITION)rMrrrrs r6set_content_dispositionzPayload.set_content_dispositions33M 3 #/(3 FL3  d../r5errorscy)z~Return string representation of the value. This is named decode() to allow compatibility with bytes objects. Nr4rMrnrs r6decodezPayload.decodesr5writerc Kyw)aWrite payload to the writer stream. Args: writer: An AbstractStreamWriter instance that handles the actual writing This is a legacy method that writes the entire payload without length constraints. Important: For new implementations, use write_with_length() instead of this method. This method is maintained for backwards compatibility and will eventually delegate to write_with_length(writer, None) in all implementations. All payload subclasses must override this method for backwards compatibility, but new code should use write_with_length for more flexibility and control. Nr4rMrs r6writez Payload.writesscontent_lengthcBK|j|d{y7w)a Write payload with a specific content length constraint. Args: writer: An AbstractStreamWriter instance that handles the actual writing content_length: Maximum number of bytes to write (None for unlimited) This method allows writing payload content with a specific length constraint, which is particularly useful for HTTP responses with Content-Length header. Note: This is the base implementation that provides backwards compatibility for subclasses that don't override this method. Specific payload types should override this method to implement proper length-constrained writing. N)rrMrrs r6write_with_lengthzPayload.write_with_lengths*jj   s )Trrstrict)!r1r2r3rhstr__annotations__rir intrrrrr r rrrNpropertyrrmrkbytesrrnrlboolrrrrrrr4r5r6r!r!s!;3;E8C= 4<"&"&** ,S#XsCx0II J * Cy01 *3-*3-** *>hsm(3-   (3-0c00"             s c    "6 4  &!*!r?Ncdd|vrd|d<t||g|i|t|tr|j|_n>t|t tfrt||_ntdt||j tkDr d|i}tjdtfi|yy)Nrlrgz%value argument must be byte-ish, not sourcez}Sending a large body directly with raw bytes might lock the event loop. You should probably pass an io.BytesIO object instead)superrNr\ memoryviewnbytesrir bytearraylen TypeErrorrFr+warningswarnResourceWarningrMrjr=r> __class__s r6rNzBytesPayload.__init__"s  '%?F> " 000 eZ (DJ y1 2UDJCDK?ST T ::, ,%F MM,      -r5rnrc:|jj||SrA)rurrs r6rzBytesPayload.decode;s{{!!(F33r5rcVK|j|jd{y7w)aWrite the entire bytes payload to the writer stream. Args: writer: An AbstractStreamWriter instance that handles the actual writing This method writes the entire bytes content without any length constraint. Note: For new implementations that need length control, use write_with_length(). This method is maintained for backwards compatibility and is equivalent to write_with_length(writer, None). Nrrurs r6rzBytesPayload.write>sll4;;'''s )')rcK|'|j|jd|d{y|j|jd{y7)7w)a Write bytes payload with a specific content length constraint. Args: writer: An AbstractStreamWriter instance that handles the actual writing content_length: Maximum number of bytes to write (None for unlimited) This method writes either the entire byte sequence or a slice of it up to the specified content_length. For BytesPayload, this operation is performed efficiently using array slicing. Nrrs r6rzBytesPayload.write_with_lengthMsJ  %,,t{{?N;< < <,,t{{+ + + = +s!$AA#A A AAr)r1r2r3rrrrrrrNrrrrr rr __classcell__rs@r6r"r"s M5)Z78ADPS 24s4c44 ("6 (4 (,*,r?c|/|d}d}n1t|}|jjdd}n |d|z}|}t||j |g|||d|y)Nrtext/plain; charset=utf-8charsettext/plain; charset=%sr)r parametersrBrrNr) rMrjrnrlr=r> real_encodingmimetypers r6rNzStringPayload.__init__cs  # ' : ),7 ( 3 3 7 7 7 K #7(B $M  LL '   "%   r5)r1r2r3rrr rNrrs@r6r#r#bsW #'&*    3-  sm       r5r#c6eZdZdeedededdffd ZxZS)r(rjr=r>r?NcHt||jg|i|yrA)rrNreadrs r6rNzStringIOPayload.__init__s  777r5)r1r2r3rrrrNrrs@r6r(r(s-8bg8c8S8T88r5r(c >eZdZUejed< ddeededededdf fd Z d e e de e e e ffd Zd e e de fd Zede e fd Zd eddfdZd ede e ddfdZde e de d e e defdZdej0ddfdZddededefdZxZS)r$rurj dispositionr=r>r?Ncd|vrt||d<t||g|i||j>|;tj |j vr|j||jyyyy)Nrm)rm)rrrNrsrrrkr)rMrjrr=r>rs r6rNzIOBasePayload.__init__sy V #!/!6F:  000 >> %+*A''t||;,,[4>>,R<+B %r5remaining_content_lenc|j}||jjt|xst|xstfS)a Read the file-like object and return both its total size and the first chunk. Args: remaining_content_len: Optional limit on how many bytes to read in this operation. If None, READ_SIZE will be used as the default chunk size. Returns: A tuple containing: - The total size of the remaining unread content (None if size cannot be determined) - The first chunk of bytes read from the file object This method is optimized to perform both size calculation and initial read in a single operation, which is executed in a single executor job to minimize context switches and file operations when streaming content. )rrurminr,)rMrrs r6_read_and_available_lenz%IOBasePayload._read_and_available_lens@(yyT[[%% ! #8#EI F   r5cH|jj|xstS)a Read a chunk of data from the file-like object. Args: remaining_content_len: Optional maximum number of bytes to read. If None, READ_SIZE will be used as the default chunk size. Returns: A chunk of bytes read from the file object, respecting the remaining_content_len limit if specified. This method is used for subsequent reads during streaming after the initial _read_and_available_len call has been made. )rurr,)rMrs r6_readzIOBasePayload._reads {{ 5 BCCr5c tj|jjj|jj z S#t tf$rYywxYwrA)osfstatrufilenost_sizetellAttributeErrorOSErrorrYs r6rzIOBasePayload.sizesR 88DKK..0199DKKz'IOBasePayload.decode..6sSaqxx&1Ss)rru readlinesrs ``r6rzIOBasePayload.decode5s%wwS4;;;P;P;RSSSr5) attachmentr)r1r2r3ioIOBaserrrrrNr rrrrrrrrrrrrrAbstractEventLooprrrrs@r6r$r$sI II2> SW S+. SFI SUX S  S %-c] x}e# $ 2D8C=DUD$hsm 3"6343$:,*:,)B)B>t>TsTcTTr5r$c eZdZUejed<ddddededee dee ded df fd Z d ee d e ee e ffd Zd ee d e fd Zdde de d e fdZxZS)r'ruNrrjr=rnrlr>r?c|/|d}d}n/t|}|jjdd}n|d|z}t||g|||d|y)Nrrrrrlrn)rrrBrrN)rMrjrnrlr=r>rrs r6rNzTextIOPayload.__init__<s|  #": ),7#..229gF#7(B      %   r5rc|j}|jjt|xst|xst}||j r|j |j fS|j fS)a Read the text file-like object and return both its total size and the first chunk. Args: remaining_content_len: Optional limit on how many bytes to read in this operation. If None, READ_SIZE will be used as the default chunk size. Returns: A tuple containing: - The total size of the remaining unread content (None if size cannot be determined) - The first chunk of bytes read from the file object, encoded using the payload's encoding This method is optimized to perform both size calculation and initial read in a single operation, which is executed in a single executor job to minimize context switches and file operations when streaming content. Note: TextIOPayload handles encoding of the text content before writing it to the stream. If no encoding is specified, UTF-8 is used as the default. )rrurrr,rrr)rMrrrs r6rz%TextIOPayload._read_and_available_lenXsd0yy   ! #8#EI F T^^U\\$..1WWWWr5c|jj|xst}|jr|j |jS|j S)a Read a chunk of data from the text file-like object. Args: remaining_content_len: Optional maximum number of bytes to read. If None, READ_SIZE will be used as the default chunk size. Returns: A chunk of bytes read from the file object and encoded using the payload's encoding. The data is automatically converted from text to bytes. This method is used for subsequent reads during streaming after the initial _read_and_available_len call has been made. It properly handles text encoding, converting the text content to bytes using the specified encoding (or UTF-8 if none was provided). )rurr,rrr)rMrrs r6rzTextIOPayload._readvsB$   !6!C)D/3~~u||DNN+Q5<<>Qr5rc6|jjSrA)rurrs r6rzTextIOPayload.decodes{{!!r5r)r1r2r3r TextIOBaserrrr rrNrrrrrrrrs@r6r'r'9s MM #'&*    3-  sm      8X%-c]X x}e# $X<R8C=RUR*"s"c""r5r'ceZdZUejed<edefdZd de de de fdZ de ddfd Z de d e eddfd Zy) r%rur?c|jj}|jjdtj}|jj|||z S)Nr)rurseekrSEEK_END)rMpositionends r6rzBytesIOPayload.sizesJ;;##%kkq"++. "X~r5rnrcV|jjj||SrArurrrs r6rzBytesIOPayload.decode"{{!((6::r5rNcBK|j|dd{S7wrArrs r6rzBytesIOPayload.writes++FD9999s rc6Kd}|} |jjtx}r|dkDrtjdd{||j |d{nK|j |d|d{|t |z}|dkr |jjy|dz }|jjtx}r|jjy777y#|jjwxYww)a: Write BytesIO payload with a specific content length constraint. Args: writer: An AbstractStreamWriter instance that handles the actual writing content_length: Maximum number of bytes to write (None for unlimited) This implementation is specifically optimized for BytesIO objects: 1. Reads content in chunks to maintain memory efficiency 2. Yields control back to the event loop periodically to prevent blocking when dealing with large BytesIO objects 3. Respects content_length constraints when specified 4. Properly cleans up by closing the BytesIO object when done or on error The periodic yielding to the event loop is important for maintaining responsiveness when processing large in-memory buffers. rNr)rurr,rsleeprrr)rMrr loop_countremaining_bytesrs r6rz BytesIOPayload.write_with_lengths, ( ;;++I66%6> "--***"* ,,u--- ,,u-=o'>???#s5z1O&!+ KK   a  ;;++I66%6 KK   +-? KK   s^D>C:C4C:!C6"C:>C8?C:D2&C:D4C:6C:8C::DDr)r1r2r3rBytesIOrrrrrrrrr rr4r5r6r%r%st JJ c ;s;c;;:"6:4:) *) r?Nc\t|||j|g|||d|y)Nr)rrNr)rMrjrnrlrr=r>rs r6rNzJsonPayload.__init__sC  %L   )   %   r5) r1r2r3jsonrrrrrNrrs@r6r)r)s` .!ZZ              r5r)) AsyncIterable AsyncIteratorceZdZUdZeeed<eed<dedededdffd Z d e ddfd Z d e d ee ddfd Z dd ededefdZxZS)r*N_iterrurjr=r>r?ct|ts#tdjt |d|vrd|d<t ||g|i||j|_y)NzMvalue argument must support collections.abc.AsyncIterable interface, got {!r}rlrg) r\rrformatrFrrN __aiter__rrs r6rNzAsyncIterablePayload.__init__sf%/!6$u+.   '%?F> " 000__& r5rcDK|j|dd{y7w)a Write the entire async iterable payload to the writer stream. Args: writer: An AbstractStreamWriter instance that handles the actual writing This method iterates through the async iterable and writes each chunk to the writer without any length constraint. Note: For new implementations that need length control, use write_with_length() directly. This method is maintained for backwards compatibility with existing code. Nrrs r6rzAsyncIterablePayload.writes$$VT222rrcK|jy|} tjdk\rt|jd{}n"|jj d{}||j |d{n/|dkDr*|j |d|d{|t |z}7s7R797#t$r d|_YywxYww)a Write async iterable payload with a specific content length constraint. Args: writer: An AbstractStreamWriter instance that handles the actual writing content_length: Maximum number of bytes to write (None for unlimited) This implementation handles streaming of async iterable content with length constraints: 1. Iterates through the async iterable one chunk at a time 2. Respects content_length constraints when specified 3. Handles the case when the iterable might be used twice Since async iterables are consumed as they're iterated, there is no way to restart the iteration if it's already in progress or completed. N)rp r)rrwrxanext __anext__rrStopAsyncIteration)rMrrr rs r6rz&AsyncIterablePayload.write_with_lengths( ::  ( ##w."' "33E"&**"6"6"88E"* ,,u---$q( ,,u-=o'>???#s5z1O38-@ " DJ scC,B;B3"B;"B5#B;=B7>!B;B9 B;5B;7B;9B;;C C CCrnrctd)NzUnable to decode.)rrs r6rzAsyncIterablePayload.decodeDs+,,r5r)r1r2r3rr _AsyncIteratorr_AsyncIterablerrNrrrrrrrrs@r6r*r*s&*E8N #*  'n 'S 'C 'D '3"6343"+*+r?NcHt||jg|i|yrA)rrNiter_anyrs r6rNzStreamReaderPayload.__init__Is! );D;F;r5)r1r2r3rrrNrrs@r6r'r'Hs)r<s  #    "%"/  $)eCj( 5:,/EGNN4()1 ) C 7c7#777 8m8 pTGpTfS"MS"l9 ]9 x;M; , (3"5)N"5)N<"N"NS-7S-l<.< #$, :(FG--/2;;7-7."**5/"2C2CREVEV1WX-3-|<. U^^Tr5