
    h=              	           % S SK r S SKrS SKrS SKrS SKrS SKrS SKrS SKrS SKJ	r	J
r
  S SKJr  S SKJrJrJrJrJrJrJrJrJrJrJr  S SKJr  SSKJr  SSKJr  SS	KJrJ r J!r!J"r"J#r#  SS
K$J%r%  SSK&J'r'J(r(  Sr)Sr*\\+   \,S'   \(       a  S SKJ-r-   " S S\.5      r/ " S S\0\Rb                  5      r2S\S\S\SS4S jr3\2Rh                  S.S\S   S\S\2SS4S jjr5 " S S 5      r6\S   r7\\7\4   r8 " S! S"5      r9 " S# S\	5      r: " S$ S%\:5      r; " S& S'\;5      r< " S( S)\<5      r= " S* S+\:5      r> " S, S-\>5      r? " S. S/\>5      r@ " S0 S1\>5      rA " S2 S3\;5      rB\(       a  S S4KJCrCJDrD  \D\E   rF\C\E   rGOS S4KHJCrCJDrD  \DrF\CrG " S5 S6\:5      rI " S7 S8\I5      rJ\9" 5       rK\KR                  \;\E\M\N45        \KR                  \<\05        \KR                  \=\R                  5        \KR                  \?\R                  5        \KR                  \@\R                  5        \KR                  \A\R                  \R                  45        \KR                  \>\R                  5        \KR                  \J\%5        \KR                  \I\C\2R                  S9  g)9    N)ABCabstractmethod)chain)IOTYPE_CHECKINGAnyDictFinalIterableOptionalTextIOTupleTypeUnion)CIMultiDict   )hdrs)AbstractStreamWriter)	_SENTINELcontent_disposition_headerguess_filenameparse_mimetypesentinel)StreamReader)JSONEncoder_CIMultiDict)PAYLOAD_REGISTRYget_payloadpayload_typePayloadBytesPayloadStringPayloadIOBasePayloadBytesIOPayloadBufferedReaderPayloadTextIOPayloadStringIOPayloadJsonPayloadAsyncIterablePayloadi   TOO_LARGE_BYTES_BODY)Listc                       \ rS rSrSrg)LookupError=    N)__name__
__module____qualname____firstlineno____static_attributes__r/       A/var/www/html/env/lib/python3.13/site-packages/aiohttp/payload.pyr-   r-   =   s    r5   r-   c                        \ rS rSrSrSrSrSrg)OrderA   normal	try_firsttry_lastr/   N)r0   r1   r2   r3   r:   r;   r<   r4   r/   r5   r6   r8   r8   A   s    FIHr5   r8   dataargskwargsreturnr    c                 6    [         R                  " U /UQ70 UD6$ N)r   get)r=   r>   r?   s      r6   r   r   G   s    6t6v66r5   orderfactorytyperE   c                ,    [         R                  XUS9  g NrD   )r   register)rF   rG   rE   s      r6   register_payloadrK   K   s     g59r5   c                   d    \ rS rSr\R
                  S.S\S\SS4S jjrS\S	   S\S	   4S
 jr	Sr
g)r   Q   rD   rG   rE   r@   Nc                    Xl         X l        g rB   )rG   rE   )selfrG   rE   s      r6   __init__payload_type.__init__R   s    	
r5   rF   r    c                 B    [        XR                  U R                  S9  U$ rI   )rK   rG   rE   )rO   rF   s     r6   __call__payload_type.__call__V   s    ))4::>r5   )rE   rG   )r0   r1   r2   r3   r8   r:   r   rP   r   rS   r4   r/   r5   r6   r   r   Q   s>    49LL S E T Y DO r5   r   c                       \ rS rSrSrSrSS jr\S.S\S	\S
SS\SS4
S jjr	\
R                  S.S\S\S\
SS4S jjrSrg)PayloadRegistry_   zRPayload registry.

note: we need zope.interface for more efficient adapter search
_first_normal_last_normal_lookupr@   Nc                 <    / U l         / U l        / U l        0 U l        g rB   rX   rO   s    r6   rP   PayloadRegistry.__init__g   s    243513
68r5   )_CHAINr=   r>   r`   z!Type[chain[_PayloadRegistryItem]]r?   r    c                   U R                   (       a3  U R                    H#  u  pV[        X5      (       d  M  U" U/UQ70 UD6s  $    U R                  R                  [	        U5      5      =n(       a  U" U/UQ70 UD6$ [        U[
        5      (       a  U$ U" U R                  U R                  5       H#  u  pV[        X5      (       d  M  U" U/UQ70 UD6s  $    [        5       erB   )	rY   
isinstancer\   rC   rG   r    rZ   r[   r-   )rO   r=   r`   r>   r?   rF   type_lookup_factorys           r6   rC   PayloadRegistry.getm   s     ;;"&++d**"49$9&99 #. "0044T$Z@@>@!$8888dG$$K$T\\4::>NG$&&t5d5f55 ? mr5   rD   rF   rG   rE   c                   U[         R                  L a  U R                  R                  X45        g U[         R                  L aX  U R
                  R                  X45        [        U[        5      (       a  U H  nXR                  U'   M     g XR                  U'   g U[         R                  L a  U R                  R                  X45        g [        SU< 35      e)NzUnsupported order )r8   r;   rY   appendr:   rZ   rb   r   r\   r<   r[   
ValueError)rO   rF   rG   rE   ts        r6   rJ   PayloadRegistry.register   s     EOO#KK/ell"LL0$))A-4''*  -4##D)enn$JJwo.1%;<<r5   )rY   r[   rZ   r\   )r@   N)r0   r1   r2   r3   __doc__	__slots__rP   r   r   rC   r8   r:   PayloadTyperJ   r4   r/   r5   r6   rV   rV   _   s    
 AI9 7<	  4	
  
0 BG="=*-=9>=	= =r5   rV   c                      \ rS rSr% Sr\\S'   Sr\\	   \S'   S\
SS4S\S\\\\\\4   \\\\4      4      S\\S\4   S	\\   S
\\   S\SS4S jjr\S\\	   4S j5       r\S\\   4S j5       r\S\4S j5       r\S\4S j5       r\S\\   4S j5       r\S\4S j5       r  SS\S\S\S\SS4
S jjr\SS
\S\S\4S jj5       r\S\SS4S j5       r Sr!g) r       application/octet-stream_default_content_typeN_sizevalueheaderscontent_typefilenameencodingr?   r@   c                 2   XPl         X@l        [        5       U l        Xl        U[
        La   Ub  X0R                  [        R                  '   OU R                  bv  [        R                  S:  a  [        R                  nO[        R                  nU" U R                  5      S   nUc  U R                  nX0R                  [        R                  '   O'U R                  U R                  [        R                  '   U(       a  U R                  R                  U5        g g )N)      r   )	_encoding	_filenamer   _headers_valuer   r   CONTENT_TYPEsysversion_info	mimetypesguess_file_type
guess_typerq   update)rO   rs   rt   ru   rv   rw   r?   guessers           r6   rP   Payload.__init__   s     "!&1mx'L,D/;MM$++,^^'7*#33#.."4>>215L##99/;MM$++,/3/I/IDMM$++,MM  ) r5   c                     U R                   $ )zSize of the payload.rr   r^   s    r6   sizePayload.size   s     zzr5   c                     U R                   $ )zFilename of the payload.)r|   r^   s    r6   rv   Payload.filename        ~~r5   c                     U R                   $ )zCustom item headers)r}   r^   s    r6   rt   Payload.headers   s     }}r5   c                     SR                  U R                  R                  5        VVs/ s H  u  pUS-   U-   S-   PM     snn5      R                  S5      S-   $ s  snnf )N z: z
utf-8s   
)joinrt   itemsencode)rO   kvs      r6   _binary_headersPayload._binary_headers   s]     GGt||7I7I7KL7KtqQX\F*7KLMTT 	
Ls   A
c                     U R                   $ )zPayload encoding)r{   r^   s    r6   rw   Payload.encoding   r   r5   c                 <    U R                   [        R                     $ )zContent type)r}   r   r   r^   s    r6   ru   Payload.content_type   s     }}T..//r5   disptypequote_fields_charsetparamsc                 V    [        U4X#S.UD6U R                  [        R                  '   g)z$Sets ``Content-Disposition`` header.)r   r   N)r   r}   r   CONTENT_DISPOSITION)rO   r   r   r   r   s        r6   set_content_dispositionPayload.set_content_disposition   s1     3M3
#/3
FL3
d../r5   errorsc                     g)znReturn string representation of the value.

This is named decode() to allow compatibility with bytes objects.
Nr/   rO   rw   r   s      r6   decodePayload.decode   s    r5   writerc                    #    g7f)z<Write payload.

writer is an AbstractStreamWriter instance:
Nr/   rO   r   s     r6   writePayload.write   s     s   )r{   r|   r}   r~   )Tr   r   strict)"r0   r1   r2   r3   rq   str__annotations__rr   r   intr   r   r   r   r	   r   r   r   rP   propertyr   rv   rt   bytesr   rw   ru   boolr   r   r   r   r   r4   r/   r5   r6   r    r       s   !;3;E8C= 4<"&"&** ,S#XsCx0IIJ
* Cy01* 3-* 3-* * 
*> hsm   (3-      
 
 
 (3-   0c 0 0 "	



 

 	


 

 


 s c    "6 4  r5   c                      ^  \ rS rSr% \\S'   S\\\\4   S\	S\	SS4U 4S jjr
SS	\S
\S\4S jjrS\SS4S jrSrU =r$ )r!      r~   rs   r>   r?   r@   Nc                   > SU;  a  SUS'   [         TU ]  " U/UQ70 UD6  [        U[        5      (       a  UR                  U l        OD[        U[        [        45      (       a  [        U5      U l        O[        S[        U5      < 35      eU R
                  [        :  a!  SU 0n[        R                  " S[        40 UD6  g g )Nru   rp   z%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)superrP   rb   
memoryviewnbytesrr   r   	bytearraylen	TypeErrorrG   r*   warningswarnResourceWarningrO   rs   r>   r?   	__class__s       r6   rP   BytesPayload.__init__   s     '%?F>"000eZ((DJy122UDJCDK?STT::,,%FMM,  	
  -r5   rw   r   c                 8    U R                   R                  X5      $ rB   )r~   r   r   s      r6   r   BytesPayload.decode  s    {{!!(33r5   r   c                 V   #    UR                  U R                  5      I S h  vN   g  N7frB   )r   r~   r   s     r6   r   BytesPayload.write  s     ll4;;'''s   )')r   r   )r0   r1   r2   r3   r   r   r   r   r   r   rP   r   r   r   r   r4   __classcell__r   s   @r6   r!   r!      sl    M5)Z78ADPS	24s 4c 4 4("6 (4 ( (r5   r!   c                   Z   ^  \ rS rSrSSS.S\S\S\\   S\\   S\S	S4U 4S
 jjjrSrU =r	$ )r"   i  Nrw   ru   rs   r>   rw   ru   r?   r@   c                   > Uc0  Uc  SnSnO2[        U5      nUR                  R                  SS5      nO
Uc  SU-  nUn[        TU ]  " UR                  U5      /UQ7UUS.UD6  g )Nr   text/plain; charset=utf-8charsettext/plain; charset=%sr   )r   
parametersrC   r   rP   r   )	rO   rs   rw   ru   r>   r?   real_encodingmimetyper   s	           r6   rP   StringPayload.__init__  s     # ':),7 ( 3 3 7 7	7 K#7(B$MLL'	
 		
"%	

 	
r5   r/   )
r0   r1   r2   r3   r   r   r   rP   r4   r   r   s   @r6   r"   r"     sW    
 #'&*

 
 3-	

 sm
 
 

 
r5   r"   c                   B   ^  \ rS rSrS\\   S\S\SS4U 4S jjrSrU =r	$ )	r'   i9  rs   r>   r?   r@   Nc                 J   > [         TU ]  " UR                  5       /UQ70 UD6  g rB   )r   rP   readr   s       r6   rP   StringIOPayload.__init__:  s     777r5   r/   )
r0   r1   r2   r3   r   r   r   rP   r4   r   r   s   @r6   r'   r'   9  s-    8bg 8c 8S 8T 8 8r5   r'   c                      ^  \ rS rSr% \R
                  \S'    SS\\   S\	S\S\SS4
U 4S	 jjjr
S
\SS4S jrSS\	S\	S\	4S jjrSrU =r$ )r#   i>  r~   rs   dispositionr>   r?   r@   Nc                    > SU;  a  [        U5      US'   [        TU ]  " U/UQ70 UD6  U R                  b=  Ub9  [        R
                  U R                  ;  a  U R                  X R                  S9  g g g g )Nrv   )rv   )r   r   rP   r|   r   r   rt   r   )rO   rs   r   r>   r?   r   s        r6   rP   IOBasePayload.__init__A  sw     V#!/!6F:000>>%+*A''t||;,,[>>,R < +B%r5   r   c                   #    [         R                  " 5       n UR                  S U R                  R                  S5      I S h  vN nU(       aQ  UR                  U5      I S h  vN   UR                  S U R                  R                  S5      I S h  vN nU(       a  MQ  UR                  S U R                  R                  5      I S h  vN   g  N Nm N@ N! UR                  S U R                  R                  5      I S h  vN    f = f7f)N   )asyncioget_event_looprun_in_executorr~   r   r   close)rO   r   loopchunks       r6   r   IOBasePayload.writeM  s     %%'	@..tT[[5E5EuMMEll5)))"2249I9I5QQ % &&tT[[->->??? N)Q?$&&tT[[->->???sp   D*C CC #C$.C CC  )D	C
DC C C D*DDDDrw   r   c                 n   ^^ SR                  UU4S jU R                  R                  5        5       5      $ )Nr   c              3   F   >#    U  H  oR                  TT5      v   M     g 7frB   )r   ).0rrw   r   s     r6   	<genexpr>'IOBasePayload.decode.<locals>.<genexpr>X  s     S;Raxx&11;Rs   !)r   r~   	readlinesr   s    ``r6   r   IOBasePayload.decodeW  s%    wwS4;;;P;P;RSSSr5   r/   )
attachmentr   )r0   r1   r2   r3   ioIOBaser   r   r   r   rP   r   r   r   r4   r   r   s   @r6   r#   r#   >  s    II 2>
SW
S+.
SFI
SUX
S	
S 
S@"6 @4 @Ts Tc T T Tr5   r#   c                      ^  \ rS rSr% \R
                  \S'   SSS.S\S\S\	\
   S\	\
   S	\S
S4U 4S jjjr\S
\	\   4S j5       rSS\
S\
S
\
4S jjrS\S
S4S jrSrU =r$ )r&   i[  r~   Nr   rs   r>   rw   ru   r?   r@   c                   > Uc0  Uc  SnSnO0[        U5      nUR                  R                  SS5      nOUc  SU-  n[        TU ]  " U/UQ7UUS.UD6  g )Nr   r   r   r   ru   rw   )r   r   rC   r   rP   )rO   rs   rw   ru   r>   r?   r   r   s          r6   rP   TextIOPayload.__init__^  s|     #":),7#..229gF#7(B	
 		
%	

 	
r5   c                      [         R                  " U R                  R                  5       5      R                  U R                  R                  5       -
  $ ! [         a     g f = frB   )osfstatr~   filenost_sizetellOSErrorr^   s    r6   r   TextIOPayload.sizez  sM    	88DKK..0199DKK<L<L<NNN 		s   AA 
A"!A"r   c                 6    U R                   R                  5       $ rB   )r~   r   r   s      r6   r   TextIOPayload.decode  s    {{!!r5   r   c                   #    [         R                  " 5       n UR                  S U R                  R                  S5      I S h  vN nU(       a  U R
                  (       a  UR                  U R
                  S9OUR                  5       nUR                  U5      I S h  vN   UR                  S U R                  R                  S5      I S h  vN nU(       a  M  UR                  S U R                  R                  5      I S h  vN   g  N Nm N@ N! UR                  S U R                  R                  5      I S h  vN    f = f7f)Nr   )rw   )	r   r   r   r~   r   r{   r   r   r   )rO   r   r   r   r=   s        r6   r   TextIOPayload.write  s     %%'	@..tT[[5E5EuMME ~~ LL$..L9 
 ll4((("2249I9I5QQ % &&tT[[->->??? N )Q?$&&tT[[->->???sq   E*D D	AD D.D DD )EDE	D D D E*E;D><EEr/   r   )r0   r1   r2   r3   r   
TextIOBaser   r   r   r   r   rP   r   r   r   r   r   r   r4   r   r   s   @r6   r&   r&   [  s    MM #'&*

 
 3-	

 sm
 
 

 
8 hsm  "s "c " "@"6 @4 @ @r5   r&   c                   f    \ rS rSr% \R
                  \S'   \S\4S j5       r	S
S\
S\
S\
4S jjrSrg	)r$   i  r~   r@   c                     U R                   R                  5       nU R                   R                  S[        R                  5      nU R                   R                  U5        X!-
  $ )Nr   )r~   r   seekr   SEEK_END)rO   positionends      r6   r   BytesIOPayload.size  sH    ;;##%kkq"++."~r5   rw   r   c                 T    U R                   R                  5       R                  X5      $ rB   r~   r   r   r   s      r6   r   BytesIOPayload.decode       {{!((::r5   r/   Nr   )r0   r1   r2   r3   r   BytesIOr   r   r   r   r   r   r4   r/   r5   r6   r$   r$     sD    JJc  ;s ;c ; ; ;r5   r$   c                   l    \ rS rSr% \R
                  \S'   \S\\	   4S j5       r
S
S\S\S\4S jjrSrg	)r%   i  r~   r@   c                      [         R                  " U R                  R                  5       5      R                  U R                  R                  5       -
  $ ! [        [        4 a     g f = frB   )r   r   r~   r   r   r   r   AttributeErrorr^   s    r6   r   BufferedReaderPayload.size  sT    	88DKK..0199DKK<L<L<NNN( 	
 	s   AA A('A(rw   r   c                 T    U R                   R                  5       R                  X5      $ rB   r  r   s      r6   r   BufferedReaderPayload.decode  r  r5   r/   Nr   )r0   r1   r2   r3   r   BufferedIOBaser   r   r   r   r   r   r   r4   r/   r5   r6   r%   r%     sJ    hsm  ;s ;c ; ; ;r5   r%   c                   f   ^  \ rS rSrSS\R
                  4S\S\S\S\S\S	\S
S4U 4S jjjr	Sr
U =r$ )r(   i  r   zapplication/jsonrs   rw   ru   dumpsr>   r?   r@   Nc                 ^   > [         TU ]  " U" U5      R                  U5      /UQ7UUS.UD6  g )Nr   )r   rP   r   )rO   rs   rw   ru   r  r>   r?   r   s          r6   rP   JsonPayload.__init__  sC     	%L)	
 		
%	

 	
r5   r/   )r0   r1   r2   r3   jsonr  r   r   r   rP   r4   r   r   s   @r6   r(   r(     s`      .!ZZ

 
 	

 
 
 
 

 
r5   r(   )AsyncIterableAsyncIteratorc                      ^  \ rS rSr% Sr\\   \S'   \\S'   S\S\	S\	SS4U 4S	 jjr
S
\SS4S jrSS\S\S\4S jjrSrU =r$ )r)   i  N_iterr~   rs   r>   r?   r@   c                    > [        U[        5      (       d#  [        SR                  [	        U5      5      5      eSU;  a  SUS'   [
        TU ]  " U/UQ70 UD6  UR                  5       U l        g )NzMvalue argument must support collections.abc.AsyncIterable interface, got {!r}ru   rp   )	rb   r  r   formatrG   r   rP   	__aiter__r!  r   s       r6   rP   AsyncIterablePayload.__init__  si    %//!6$u+.  '%?F>"000__&
r5   r   c                    #    U R                   (       a?    U R                   R                  5       I S h  vN nUR                  U5      I S h  vN   M=  g  N  N	! [         a
    S U l          g f = f7frB   )r!  	__anext__r   StopAsyncIteration)rO   r   r   s      r6   r   AsyncIterablePayload.write  sd     ::" "&**"6"6"88E ,,u--- 	 
 9-% "!
"sJ   A/A AA AA A/A A A,)A/+A,,A/rw   r   c                     [        S5      e)NzUnable to decode.)r   r   s      r6   r   AsyncIterablePayload.decode  s    +,,r5   )r!  r   )r0   r1   r2   r3   r!  r   _AsyncIteratorr   _AsyncIterabler   rP   r   r   r   r   r4   r   r   s   @r6   r)   r)     sl    &*E8N#*'n 'S 'C 'D '	""6 	"4 	"-s -c - - -r5   r)   c                   <   ^  \ rS rSrS\S\S\SS4U 4S jjrSrU =r$ )	StreamReaderPayloadi  rs   r>   r?   r@   Nc                 J   > [         TU ]  " UR                  5       /UQ70 UD6  g rB   )r   rP   iter_anyr   s       r6   rP   StreamReaderPayload.__init__  s!    );D;F;r5   r/   )	r0   r1   r2   r3   r   r   rP   r4   r   r   s   @r6   r/  r/    s)    <l <3 <# <$ < <r5   r/  )Vr   enumr   r  r   r   r   r   abcr   r   	itertoolsr   typingr   r   r   r	   r
   r   r   r   r   r   r   	multidictr   r   r   r   helpersr   r   r   r   r   streamsr   typedefsr   r   __all__r*   r   r   r+   	Exceptionr-   r   Enumr8   r   r:   rK   r   rm   _PayloadRegistryItemrV   r    r!   r"   r'   r#   r&   r$   r%   r(   r  r  r   r,  r-  collections.abcr)   r/  r   rJ   r   r   StringIOr  r  BufferedReaderBufferedRandomr   r<   r/   r5   r6   <module>rC     s     	   	 
  #     "  %  " /  $) eCj (	) 	C 7c 7# 7 7 7
 <A<<:)_:$':38:	:  9o[#-. 4= 4=n^c ^B (7  (F
L 
>8m 8
TG T:6@M 6@r;] ;;M ;$
, 
( 3"5)N"5)N<"N"N -7  -F<. <
 #$    ,	:(F G   - -   /2;; 7   - 7   ."** 5   /"2C2CREVEV1W X   - 3   -| <   .U^^  Tr5   