bg4 |UddlZddlZddlZddlZddlZddlZddlZddlmZm Z ddl m Z ddl m Z mZmZmZmZmZmZmZmZmZmZmZddlmZddlmZddlmZdd lmZm Z m!Z!m"Z"m#Z#dd l$m%Z%dd l&m'Z'm(Z(d Z)d Z*ee+e,d<erddl m-Z-Gdde.Z/Gdde0ej1Z2dedededdfdZ3e2j4ddeddede2ddfdZ5Gdd Z6edZ7ee7efZ8Gd!d"Z9Gd#deZ:Gd$d%e:Z;Gd&d'e;Z<Gd(d)e<Z=Gd*d+e:Z>Gd,d-e>Z?Gd.d/e>Z@Gd0d1e>ZAGd2d3e;ZBerdd4l mCZCmDZDeDeEZFeCeEZGn dd4lHmCZCmDZDeDZFeCZGGd5d6e:ZIGd7d8eIZJe9ZKeKLe;eEeMeNfeKLeejTeKLeJe%eKLeIeCe2jUdS)9N)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 JsonPayloadAsyncIterablePayloadiTOO_LARGE_BYTES_BODY)ListceZdZdS) LookupErrorN)__name__ __module__ __qualname__F/opt/cloudlinux/venv/lib64/python3.11/site-packages/aiohttp/payload.pyr.r.=sDr3r.ceZdZdZdZdZdS)Ordernormal try_firsttry_lastN)r/r0r1r7r8r9r2r3r4r6r6As FIHHHr3r6dataargskwargsreturnr!c,tj|g|Ri|SN)rget)r:r;r<s r4rrGs#   6t 6 6 6v 6 66r3orderfactorytyperBc@t|||dSNrA)rregister)rCrDrBs r4register_payloadrHKs%gt599999r3cZeZdZejddededdfdZdeddedfd ZdS) r rArDrBr=Nc"||_||_dSr?)rDrB)selfrDrBs r4__init__zpayload_type.__init__Rs  r3rCr!c>t||j|j|SrF)rHrDrB)rKrCs r4__call__zpayload_type.__call__Vs $)4:>>>>r3) r/r0r1r6r7rrLrrNr2r3r4r r Qsv49LSETYDOr3r c deZdZdZddZeddededd d edd f d Zej d de dededdfdZ dS)PayloadRegistryzZPayload registry. note: we need zope.interface for more efficient adapter search r=Nc0g|_g|_g|_dSr?)_first_normal_lastrKs r4rLzPayloadRegistry.__init__es24 35 13 r3)_CHAINr:r;rVz!Type[chain[_PayloadRegistryItem]]r<r!ct|tr|S||j|j|jD]#\}}t||r||g|Ri|cS$t r?) isinstancer!rRrSrTr.)rKr:rVr;r<rCrDs r4r@zPayloadRegistry.getjs dG $ $ K#VDKtzJJ 6 6MGT$%% 6wt5d555f55555 6mmr3rArCrDrBc.|tjur|j||fdS|tjur|j||fdS|tjur|j||fdStd|)NzUnsupported order ) r6r8rRappendr7rSr9rT ValueError)rKrCrDrBs r4rGzPayloadRegistry.registerys EO # # K   / / / / / el " " L  $ 0 0 0 0 0 en $ $ J  wo . . . . .;%;;<<  =  = = = = = =r3rPceZdZUdZeed<dZeeed<de ddfde dee e e eefeeeeffde edefdeed eed e d dfd Zed eefd Zed eefdZed e fdZed efdZed eefdZed efdZ ddededede d df dZeded dfdZdS)r!application/octet-stream_default_content_typeN_sizevalueheaders content_typefilenameencodingr<r=c ||_||_t|_||_|t ur|||jt j<n]|j=tj |jd}||j }||jt j<n|j |jt j<|j |pidSNr) _encoding _filenamer_headers_valuerr CONTENT_TYPE mimetypes guess_typer`update)rKrbrcrdrerfr<s r4rLzPayload.__init__s"!&1mm  x ' 'L,D/;DM$+ , , ^ '$/??BL##9 /;DM$+ , ,/3/IDM$+ , W]+++++r3c|jS)zSize of the payload.)rarUs r4sizez Payload.sizes zr3c|jS)zFilename of the payload.)rjrUs r4rezPayload.filename ~r3c|jS)zCustom item headers)rkrUs r4rczPayload.headerss }r3cdd|jDddzS)Nc*g|]\}}|dz|zdzS)z: z r2).0kvs r4 z+Payload._binary_headers..s)LLLtq!QX\F*LLLr3utf-8s )joinrcitemsencoderUs r4_binary_headerszPayload._binary_headerssR GGLLt|7I7I7K7KLLL M M T T    r3c|jS)zPayload encoding)rirUs r4rfzPayload.encodingrtr3c0|jtjS)z Content type)rkrrmrUs r4rdzPayload.content_types}T.//r3Tr}disptype quote_fields_charsetparamsc Jt|f||d||jtj<dS)z$Sets ``Content-Disposition`` header.)rrN)rrkrCONTENT_DISPOSITION)rKrrrrs r4set_content_dispositionzPayload.set_content_dispositions>3M 3 #/(3 3 FL3 3  d.///r3writerc KdS)zLWrite payload. writer is an AbstractStreamWriter instance: Nr2rKrs r4writez Payload.writes r3)Tr})r/r0r1r`str__annotations__rar intrrrrr r rrrLpropertyrrrercbytesrrfrdboolrrrrr2r3r4r!r!sY!;3;;;E8C= 4<"&"&,,, ,S#XsCx0II J , Cy01 ,3-,3-,, ,,,,4hsmX(3-XX    X (3-X0c000X0"                 "6 4   ^   r3c@eZdZdedededdffd ZdeddfdZxZS) r"rbr;r<r=Nct|tttfst dt |d|vrd|d<t j|g|Ri|t|tr |j|_ nt||_ |j tkrd|i}tj dtfi|dSdS)Nz%value argument must be byte-ish, not rdr_sourcez}Sending a large body directly with raw bytes might lock the event loop. You should probably pass an io.BytesIO object instead)rXr bytearray memoryview TypeErrorrDsuperrLnbytesralenr+warningswarnResourceWarningrKrbr;r< __class__s r4rLzBytesPayload.__init__s%%J!?@@ USDKKSSTT T  ' '%?F> "0000000 eZ ( ( $DJJUDJ :, , ,%F M,           - ,r3rcJK||jd{VdSr?)rrlrs r4rzBytesPayload.writes2ll4;'''''''''''r3) r/r0r1r rrLrr __classcell__rs@r4r"r"s|j0("6(4((((((((r3r"c XeZdZddddededeedeededdf fd ZxZS) r#Nrfrdrbr;rfrdr<r=c|2|d}d}n4t|}|jdd}n |d|z}|}tj||g|R||d|dS)Nr}text/plain; charset=utf-8charsettext/plain; charset=%sr)r parametersr@rrLr) rKrbrfrdr;r< real_encodingmimetypers r4rLzStringPayload.__init__s  # ' : ),77 ( 3 7 7 7 K K #7(B $M LL ' '    "%        r3)r/r0r1rrr rLrrs@r4r#r#s #'&*      3-  sm               r3r#c<eZdZdeedededdffd ZxZS)r(rbr;r<r=Ncftj|g|Ri|dSr?)rrLreadrs r4rLzStringIOPayload.__init__s8777777777r3)r/r0r1rrrrLrrs@r4r(r(s]8bg8c8S8T8888888888r3r(c leZdZUeeed< d deededededdf fd Zd eddfd Z xZ S) r$rl attachmentrb dispositionr;r<r=Ncd|vrt||d<tj|g|Ri||j3|3tj|jvr"|||jdSdSdSdS)Nre)re)rrrLrjrrrcr)rKrbrr;r<rs r4rLzIOBasePayload.__init__s V # #!/!6!6F: 0000000 > %+*A't|;;,,[4>,RRRRR & %*A*A;;r3rcKtj} |d|jjdd{V}|rD||d{V|d|jjdd{V}|D|d|jjd{VdS#|d|jjd{VwxYw)N)asyncioget_event_looprun_in_executorrlrrclose)rKrloopchunks r4rzIOBasePayload.write+s%'' @..tT[5EuMMMMMMMME Rll5)))))))))"2249I5QQQQQQQQ R&&tT[->?? ? ? ? ? ? ? ? ? ?$&&tT[->?? ? ? ? ? ? ? ? ?s A-B,,(C)r) r/r0r1rrrrrLrrrrs@r4r$r$s sGOOO2> S SW S+. SFI SUX S  S S S S S S@"6@4@@@@@@@@r3r$c eZdZUeed<ddddededeedeeded df fd Ze d ee fd Z d e d dfd Z xZS)r'rlNrrbr;rfrdr<r=c|2|d}d}n2t|}|jdd}n|d|z}tj|g|R||d|dS)Nr}rrrrdrf)rrr@rrL)rKrbrfrdr;r<rrs r4rLzTextIOPayload.__init__9s  #": ),77#.229gFF#7(B      %        r3c tj|jj|jz S#t $rYdSwxYwr?osfstatrlfilenost_sizetellOSErrorrUs r4rrzTextIOPayload.sizeUs] 8DK..00119DK?? ? ? ? ? ? ? ? ? ?$&&tT[->?? ? ? ? ? ? ? ? ?s B#C""(D )r/r0r1rrrr rrLrrrrrrrrs@r4r'r'6s NNN #'&*      3-  sm           8hsmX @"6 @4 @ @ @ @ @ @ @ @r3r'c*eZdZedefdZdS)r%r=c|j}|jdtj}|j|||z Srh)rlrseekrSEEK_END)rKpositionends r4rrzBytesIOPayload.sizemsN;##%%kq"+.. """X~r3N)r/r0r1rrrrr2r3r4r%r%ls9 cXr3r%c6eZdZedeefdZdS)r&r=c tj|jj|jz S#t $rYdSwxYwr?rrUs r4rrzBufferedReaderPayload.sizevs_ 8DK..00119DK "0000000__&& r3rcK|jrU |jd{V}||d{V;#t$r d|_YdSwxYwdSr?)r __anext__rStopAsyncIteration)rKrrs r4rzAsyncIterablePayload.writes : " "."&*"6"6"8"8888888E ,,u---------.& " " "!  " " "srsd  ########                            "!!!!!%%%%%%"!!!!!////////  $)eCj(((     )   C 7c7#777777 88888m888 @@@@@G@@@43@3@3@3@3@M3@3@3@l]M     ,   ( #33333333"5)N"5)NN<<<<<<<<"N"N"""""7"""><<<<<.<<< #?$$, :(FGGG----/2;777-777."*555/"2CREV1WXXX-333-|<<<. U^TTTTTr3