Team Ai
Datasetpublic

codekingpro/portable-devtools

sourceHugging Faceupdated 5mo agoView on Hugging Face
1likes15kdownloads
client_reqrep.cpython-313.pyc330 linesDownload Raw Back to __pycache__
1�

2��j���
�z�SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK	J3r4 SSKJrJ
r
Jr SSKJrJr SSKJrJr SSKJrJrJrJrJrJrJrJrJrJrJ r J!r! SSK"r"SSK#J$r$J%r%J&r&J'r' SSK(J)r) S	S5K*J+r+J,r,J-r-J.r.J/r/ S	SK0J1r1J2r2J3r3 S	SK4J5r5 S	S
K6J7r7J8r8J9r9J:r:J;r;J<r< S	SK=J>r>J?r? S	SK@JArA S	SK,JBrBJCrCJDrDJErEJFrFJGrGJHrHJIrIJJrJJKrK S	SK-JLrLJMrMJNrNJOrOJPrP S	SKQJRrR S	SKSJTrTJUrUJVrVJWrWJXrXJYrY \(aSSKZrZSSKZJ[r[ OSSKZrZSSKZJ[r[ Sr^\(aS	SK_J`r` S	SKaJbrb S	SKcJdrd \7"S5re\R�"S5rg\R�"S5rhS\i4Sjrj\"R�"SSSS9"S S!55rl"S"S#\5rm"S$S%\m5rn"S&S'5ro\Zb\ZR�\p\o\q"S54rrO6\p\q"S54rrS(\!S)\p\o4S*\\pS+\S)S,\\sS\!S)\p\o447S-jrt\u"S.5rv"S/S0\5rwS1\iS2\iS\p4S3jrxS;S4\/R�S5\zSS4S6jjr{"S7S8\E5r|"S9S:5r}g!\\a SrZ\]r[GN-f=f)<�N)�Mapping)�md5�sha1�sha256)�Morsel�SimpleCookie)�MappingProxyType�
TracebackType)�
TYPE_CHECKING�Any�Callable�Dict�Iterable�List�Literal�8NamedTuple�Optional�Tuple�Type�Union)�CIMultiDict�CIMultiDictProxy�	MultiDict�MultiDictProxy)�URL�)�hdrs�helpers�http�	multipart�payload)�parse_cookie_header�parse_set_cookie_headers� preserve_morsel_with_coded_value)�AbstractStreamWriter)�ClientConnectionError�
ClientOSError�ClientResponseError�ContentTypeError�9InvalidURL�ServerFingerprintMismatch)�10HAS_BROTLI�HAS_ZSTD)�FormData)11�	_SENTINEL�BaseTimerContext�	BasicAuth�HeadersMixin�	TimerNoop�noop�reify�sentinel�
set_exception�12set_result)�SERVER_SOFTWARE�HttpVersion�
HttpVersion10�
HttpVersion11�StreamWriter)�StreamReader)�DEFAULT_JSON_DECODER�JSONDecoder�LooseCookies�LooseHeaders�Query�13RawHeaders)�14SSLContext)�
ClientRequest�ClientResponse�RequestInfo�Fingerprint)�
ClientSession)�15Connection)�Trace�Connection closedz[^-!#$%&'*+.^_`|~0-9a-zA-Z]z!^application/(?:[\w.+-]+?\+)?json�returnc��SS/n[(aURS5 [(aURS5 SRU5$)N�gzip�deflate�br�zstd�, )r,�appendr-�join)�	encodingss �[D:\code\apps\devtools\python\user_packages\Python313\site-packages\aiohttp/client_reqrep.py�_gen_default_accept_encodingrYisF�����I��z�������x����� ��9�9�Y���T)�auto_attribs�frozen�slotsc�@�\rSrSr%\\\S'S\S'\\\S'Srg)�ContentDisposition�u�typezMappingProxyType[str, str]�16parameters�filename�N)�__name__�17__module__�__qualname__�__firstlineno__r�str�__annotations__�__static_attributes__rdrZrXr_r_us��18�3�-��,�,��s�m�rZr_c�>�\rSrSr%\\S'\\S'S\S'\\S'Srg)	�_RequestInfo�|�url�method�CIMultiDictProxy[str]�headers�real_urlrdN)rerfrgrhrrjrirkrdrZrXrmrm|s��	�H��K�
$�$��MrZrmc�B�\rSrSr\4S\S\SSS\\\4SS419Sjjr	S	r20g21)rH�rorprrrqrsrNc�R�[RXX#U[LaU45$U45$)zeCreate a new RequestInfo instance.22 23For backwards compatibility, the real_url parameter is optional.24)�tuple�__new__r6)�clsrorprrrss     rXrx�RequestInfo.__new__�s6���}�}��v�x�8�/C��R�25�	26�IQ�R�27�	28rZrdN)rerfrgrhr6rrirr/rxrkrdrZrXrHrH�sJ��+3�
29�
�
30��
31�)�	
32�33��Y��'�
34�35�

36�
37rZrHc�p�\rSrSr\\\S.rS\SS4Sjr	\38S\4Sj5rS\RSS4S	jrS39rg)rI�)��� �fingerprintrNNc���[U5nURRU5nU(d[S5eU[Ld	U[40La[S5eX0lXlg)Nzfingerprint has invalid lengthz8md5 and sha1 are insecure and not supported. Use sha256.)�len�HASHFUNC_BY_DIGESTLEN�get�41ValueErrorrr�	_hashfunc�_fingerprint)�selfr��	digestlen�hashfuncs    rX�__init__�Fingerprint.__init__�sV����$�	��-�-�1�1�)�<����=�>�>�
��_��D� 0��W�X�X�!��'�rZc��UR$�N)r��r�s rXr��Fingerprint.fingerprint����� � � rZ�	transportc�"�URS5(dgURS5nURSS9nURU5R5nX@R:wa*URS5tpVn[URXEU5eg)N�42sslcontext�43ssl_objectT)�binary_form�peername)�get_extra_info�getpeercertr��digestr�r+)r�r��sslobj�cert�got�host�port�_s        rX�check�Fingerprint.check�s����'�'��5�5���)�)�,�7���!�!�d�!�3���n�n�T�"�)�)�+���#�#�#�&�5�5�j�A�N�D��+�D�,=�,=�s�$�O�O�$rZ)r�r�)rerfrgrhrrrr��bytesr��propertyr��asyncio�	Transportr�rkrdrZrXrIrI�s]�������(�E�(�d�(��!�U�!��!�P�w�0�0�P�T�PrZrI�sslrE�44verify_ssl�ssl_contextr�c��UcSnUb3U(d,[R"S[SS9 USLa[S5eSnUb,[R"S[SS9 USLa[S5eUnUb5[R"S[SS9 USLa[S5e[	U5n[U[5(d[S	RU55eU$)45NTz/verify_ssl is deprecated, use ssl=False instead���46stacklevelzNverify_ssl, ssl_context, fingerprint and ssl parameters are mutually exclusiveFz2ssl_context is deprecated, use ssl=context insteadzCfingerprint is deprecated, use ssl=Fingerprint(fingerprint) insteadzFssl should be SSLContext, bool, Fingerprint or None, got {!r} instead.)	�warnings�warn�DeprecationWarningr�rI�47isinstance�SSL_ALLOWED_TYPES�	TypeError�format)r�r�r�r�s    rX�_merge_ssl_paramsr��s����{�����j��
�
�=���	48�49�d�?��4��
�50�C����
�
�@���	51�52�d�?��4��
�53�C����
�
�Q���	54�55�d�?��4��
�56�k�*�C��c�,�-�-��
 � &��s��57�	58��JrZ)�https�wssc��\rSrSr%\\S'\\\S'\\S'\	\59\\4\S'\\\S'\\
\S'\\\S'S	rg60)�
ConnectionKey��r�r��is_sslr��proxy�61proxy_auth�proxy_headers_hashrdN)rerfrgrhrirjr�int�boolrrErIrr1rkrdrZrXr�r��sI���I�62�3�-���L�	�z�4��,�	-�-��C�=����#�#� ��
�%rZr��response_content_type�expected_content_typec�D�US:Xa[RU5SL$X;$)N�application/json)�json_re�match)r�r�s  rX�_is_expected_content_typer�s+��� 2�2��}�}�2�3�4�?�?� �9�9rZr!r�c��UR(d-UR(d[R"S[US9 ggg)z�Warn if the payload is not closed.63 64Callers must check that the body is a Payload before calling this method.65 66Args:67    payload: The payload to check68    stacklevel: Stack level for the warning (default 2 for direct callers)69z�The previous request body contains unclosed resources. Use await request.update_body() instead of setting request.body directly to properly close resources and avoid leaks.r�N)�	autoclose�consumedr�r��ResourceWarning)r!r�s  rX�_warn_if_unclosed_payloadr�s7�����W�%5�%5��
�
�
D�
�!�	70�&6�rZc���\rSrSr%Sr\\\S'Sr\	\S'Sr71\\\S'Sr\
\S'Sr\\\S'Sr\\\S'S	r\S72\S'Sr\\S'Sr\S
\S'Sr\\\S'Sr\\\S4\S'Sr\S\S'Sr\\R:\S'Sr\S\S'SrSr Sr!Sr"\#S\/\4\S'Sr$\S\S'S\S\%SS S!\SS"\&S#\'S$\(S%S&\)RTS'SS(S4S)jr+S[S*\,S(S4S+jjr-\.S(\S4S,j5r/\/R`S\SS(S4S-j5r/\.S(\4S.j5r1\1R`S/\S(S4S0j5r1\2S(\%4S1j5r3\2S(\%4S2j5r4\2S(\%4S3j5r5\2S(\4S4j5r6\2S\S5j5r7\2S(\4S6j5r8\2S(\'4S7j5r9\2S(\\:4S8j5r;\<4S9\=S(S4S:jjr>S(\4S;jr?\.S(\S
4S<j5r@\2S(\S734S=j5rA\2S]S>j5rBS^S?jrCS_S@jrD\.S(\E4SAj5rFS_SBjrGS(\=4SCjrH\.S(\E4SDj5rIS_SEjrJS_SFjrKS_SGjrLS_SHjrMS_SIjrNS_SJjrOS(\4SKjrPS(\4SLjrQS`SM\\SN\S(\4SOjjrRS\SSPSQ.SM\\SR\TSS\\S(\=4STjjrUSaSUjrVSV\\W\XSW\\XSX\\YS(S4SYjrZSZr[g)brGiN�version�status�reason�content�_body�_headersrd)rG.�_history�_raw_headersrK�_connection�_cookies.�_raw_cookie_headerszasyncio.Future[bool]�	_continue�_source_tracebackrJ�_sessionTFc��g)N�utf-8rd)r�s rX�<lambda>�ClientResponse.<lambda>;s��GrZ�_resolve_charset�asyncio.Task[None]�_ClientResponse__writerrpro�writerzOptional[asyncio.Task[None]]�continue100�timer�request_info�tracesrL�loop�sessionrNc���[U5[LdeXlX lUR(aURS5OUUlUbX0lUbX@lX`l	UbUO	[5Ul0UlXpl
X�lU	bX�lU	R UlUR#5(a0[$R&"[(R*"S55Ulgg)Nr)rarrp�	_real_url�raw_fragment�
with_fragment�_url�_writerr��
_request_infor3�_timer�_cache�_traces�_loopr�r��	get_debug�	traceback�
extract_stack�sys�	_getframer�)74r�rpror�r�r�r�r�r�r�s75          rXr��ClientResponse.__init__?s����C�y�C��������/2�/?�/?�C�%�%�d�+�S��	���!�L��"�(�N�)��$�0�e�i�k���&(������76���#�M�$+�$<�$<�D�!��>�>���%.�%<�%<�S�]�]�1�=M�%N�D�"�rZr�c��SUlgr��r��r�r�s  rX�__reset_writer�ClientResponse.__reset_writerf�	����
rZc��UR$)z�The writer task for streaming data.77 78_writer is only provided for backwards compatibility79for subclasses that may need to access it.80r�r�s rXr��ClientResponse._writeris���}�}�rZc���URb%URRUR5 XlUcgUR5(aSUlgUR	UR5 g)z'Set the writer task for streaming data.N)r��remove_done_callback�_ClientResponse__reset_writer�done�add_done_callback�r�r�s  rXr�rrsY���=�=�$��M�M�.�.�t�/B�/B�C��
��>���;�;�=�=� �D�M��$�$�T�%8�%8�9rZc���URc\URb@[5nUR[	UR55 XlUR$[5UlUR$r�)r�r�r�updater#�r��cookiess  rXr�ClientResponse.cookies�s_���=�=� ��'�'�3�&�.�����7��8P�8P�Q�R� '�
��}�}��!-���
��}�}�rZrc�x�XlU(a&[SUR555UlgSUlg)Nc3�@# �UHoR5v� M g7fr�)�OutputString)�.0�morsels  rX�	<genexpr>�)ClientResponse.cookies.<locals>.<genexpr>�s���-�4D�&�#�#�%�%�4D�s�)r�rw�valuesr�rs  rXrr
�s5���
��',�-�4;�N�N�4D�-�(�D�$�(,�D�$rZc��UR$r�)r�r�s rXro�ClientResponse.url�����y�y�rZc�N�[R"S[SS9 UR$)NzDeprecated, use .url #1654�r�)r�r�r�r�r�s rX�url_obj�ClientResponse.url_obj�s���
�
�2�4F�ST�U��y�y�rZc��UR$r�)r�r�s rXrs�ClientResponse.real_url�s���~�~�rZc�`�URRceURR$r�)r�r�r�s rXr��ClientResponse.host�s$���y�y�~�~�)�)�)��y�y�~�~�rZc��UR$r�)r�r�s rXrr�ClientResponse.headers�����}�}�rZc��UR$r�)r�r�s rX�raw_headers�ClientResponse.raw_headers�r�rZc��UR$r�)r�r�s rXr��ClientResponse.request_info�s���!�!�!rZc���URR[R5nUcg[R81"U5up#[
U5n[R"U5n[X$U5$r�)	r�r�r�CONTENT_DISPOSITIONr �parse_content_dispositionr	�content_disposition_filenamer_)r��raw�disposition_type�82params_dct�paramsrcs      rX�content_disposition�"ClientResponse.content_disposition�s`���m�m���� 8� 8�9���;��'0�'J�'J�3�'O�$��!�*�-���9�9�&�A��!�"2�H�E�ErZ�	_warningsc��UR(agURb�URR5 UR5 URR5(aaSU0nUR"SU<3[40UD6 USS.nUR(aURUS'URRU5 ggg)N�sourcezUnclosed response zUnclosed response)�client_response�message�source_traceback)83�_closedr��release�_cleanup_writerr�r�r�r�r��call_exception_handler)r�r3�kwargs�contexts    rX�__del__�ClientResponse.__del__�s����<�<�����'����$�$�&�� � �"��z�z�#�#�%�%�"�D�)�����!3�D�8�<�o�X�QW�X�.2�?R�S���)�)�26�2H�2H�G�.�/��84�85�1�1�'�:�
&�	(rZc�d�[R"5n[UR5nUR(a,URRSS5R
S5nOSn[SRX RU5US9 [URUS9 UR5$)N�ascii�backslashreplace�Nonez<ClientResponse({}) [{} {}]>)�file)�io�StringIOriror��encode�decode�printr�r�rr�getvalue)r��out�ascii_encodable_url�ascii_encodable_reasons    rX�__repr__�ClientResponse.__repr__�s����k�k�m��!�$�(�(�m���;�;�%)�[�[�%7�%7��+�&��f�W�o�
#�&,�"�
�*�1�1�#�[�[�2H�
��		86�	�d�l�l��%��|�|�~�rZc��UR$r�)r�r�s rX�87connection�ClientResponse.connection�s�����rZc��UR$)z2A sequence of of responses, if redirects occurred.)r�r�s rX�history�ClientResponse.history�s���}�}�rZc	��SRURRS/55nU(d[[	55$[	5n[88R"SU5GHn[89R"SU5nUcM UR5upVUR
S5SSn[	5nUHRn	[90R"SU	[91R5nUcM.UR5up�p�URX�5 MT URSU5n92URS	URR[U555 UR[U935[U55 GM [U5$)94NrT�linkz	,(?=\s*<)z
\s*<(.*)>(.*)�;rz%^\s*(\S*)\s*=\s*(['\"]?)(.*?)(\2)\s*$�relro)rVrr�getallrr�re�splitr��groups�M�addr�rorri)
r��	links_str�links�valr�ro�95params_strr0rX�param�keyr��values
             rXrb�ClientResponse.links�s.���I�I�d�l�l�1�1�&�"�=�>�	��!�)�+�.�.�<E�K���8�8�L�)�4�C��H�H�-�s�3�E��}��#�l�l�n�O�C��%�%�c�*�1�2�.�F�/8�{�D������!I�5�RT�RV�RV�W���=��#(�<�<�>� �������$� ��(�(�5�#�&�C��H�H�U�D�H�H�M�M�#�c�(�3�4��I�I�c�#�h��t� 4�5�/5�2�e�$�$rZc96���# �SUlURUlXlUR URnUR5IShv�Nup4URS:d URS:�dURS:XaO,URb[URS5 SUlM�SSS5 WR "UR"5 WR$UlURUlUR(UlURUlUR,UlX@lURR3[4R6S5=n(a[9U5UlU$GN&![RaEn[URURURURURS9UeSnAff=f!,(df   GN(=f7f)	zStart response processing.FTN�r�r7rr�d���erd)r9�protocol�	_protocolr�r��readr�HttpProcessingErrorr(r�rU�coder7rrr�r8�on_eof�
_response_eofr�r�r�r�r%r�r�r[r�97SET_COOKIErwr�)r�rRrnr7r!�exc�cookie_hdrss       rX�start�ClientResponse.starts������#�,�,���%��
�[�[��98�#�~�~�H�-5�]�]�_�'<�$�G��<�<�#�%�����);�w�|�|�s�?R���>�>�-��t�~�~�t�4�%)�D�N�'��.	���t�)�)�*�������l�l����n�n��� ����
�#�/�/������,�,�-�-�d�o�o�r�B�B�;�B�',�[�'9�D�$���I(=���/�/��-��)�)����"�x�x� #��� #�����
����
�[�sT�+G&�G�E8�E5�E8�AG�3CG&�5E8�8G�AG�G�G�99G#�G&c���UR(agUR=(a URRnUbUR(agSUlUR	5 UR5 g�NT)r9r�rn�upgradedr;�_release_connection)r�rns  rXrt�ClientResponse._response_eofAsZ���<�<���#�#�A��(8�(8�(A�(A����H�$5�$5���������� � �"rZc��UR$r�)r9r�s rX�closed�ClientResponse.closedNs���|�|�rZc�,�UR(dUR5 SUlURbURR	5(agUR5 URb"URR5 SUlggr{)�	_released�_notify_contentr9r��	is_closedr;r��closer�s rXr��ClientResponse.closeRsr���~�~�� � �"�����:�:�����!5�!5�!7�!7���������'����"�"�$�#�D��(rZc��UR(dUR5 SUlUR5 UR	5 [5$r{)r�r�r9r;r}r4r�s rXr:�ClientResponse.release_s;���~�~�� � �"��������� � �"��v�
rZc� �SUR:�$)z�Returns ``True`` if ``status`` is less than ``400``, ``False`` if not.100 101This is **not** a check for ``200 OK`` but a check that the response102status is under 400.103i�)r�r�s rX�ok�ClientResponse.okis���T�[�[� � rZc��UR(doURceUR(dUR5 [	UR104URURURURS9eg)Nrj)	r�r��_in_contextr:r(r�rUr�rrr�s rX�raise_for_status�ClientResponse.raise_for_statusrsd���w�w��;�;�*�*�*��#�#�����%��!�!�����{�{��������
�rZc�^�TRbOTRc"TRR5 STlgTRRU4Sj5 gg)Nc�$>�TR5$r�)r})�fr�s �rXr��4ClientResponse._release_connection.<locals>.<lambda>�s���$�:R�:R�:TrZ)r�r�r:rr�s`rXr}�"ClientResponse._release_connection�sK������'��}�}�$�� � �(�(�*�#'�� ��
�
�/�/�0T�U�(rZc��4# �URbURIShv�N UR5 gN![RaI [RS:�a2[R105"5=n(aUR
5(aeNof=f7f�N)r��)r�r��CancelledErrorr��version_info�current_task�106cancellingr}�r��tasks  rX�_wait_released�ClientResponse._wait_released�s{����=�=�$�
��m�m�#�#�	
� � �"�$���)�)�
��$�$��/�!(�!5�!5�!7�7��7����)�)���

��2�B�8�6�8�B�8�AB�B�B�Bc�`�URbURR5 SUlgr�)r��cancelr�r�s rXr;�ClientResponse._cleanup_writer�s#���=�=�$��M�M� � �"���
rZc�z�URnU(a!UR5c[U[5 SUlgr{)r��	exceptionr7�_CONNECTION_CLOSED_EXCEPTIONr�)r�r�s  rXr��ClientResponse._notify_content�s.���,�,���w�(�(�*�2��'�#?�@���rZc��4# �URbURIShv�N UR5 gN![RaI [RS:�a2[R107"5=n(aUR
5(aeNof=f7fr�)r�r�r�r�r�r�r�r:r�s  rX�wait_for_close�ClientResponse.wait_for_close�sx����=�=�$�
��m�m�#�#�	
����$���)�)�
��$�$��/�!(�!5�!5�!7�7��7����)�)���

�r�c��R# �URcuURR5IShv�NUlURH<nUR	UR108URUR5IShv�N M> OUR(a[S5eUR=(a URRnUbUR(dUR5IShv�N UR$N�N�![a UR5 ef=fN37f)zRead response payload.NrM)r�r�rpr��send_response_chunk_receivedrpro�
BaseExceptionr�r�r&r�rnr|r�)r��tracerns   rXrp�ClientResponse.read�s�����:�:��
�#'�<�<�#4�#4�#6�6��109�!�\�\�E��<�<����T�X�X�t�z�z����*��^�^�'�(;�<�<��#�#�A��(8�(8�(A�(A����8�#4�#4��%�%�'�'�'��z�z��7���!�
��110�111���
��
(�sL�D'�D�D�AD�;D�<D�A-D'�1D%�2D'�D�D�D"�"D'c�^�URR[RS5R	5n[112R"U5nURRS5nU(aI[R"[[5 [R"U5RsSSS5 $URS:Xa!UR S:XdUR S:XagUR"c[%S5eUR'XR"5$!,(df   Nr=f)N��charset�application�json�rdapr�z7Cannot compute fallback encoding of a not yet read body)rrr�r�CONTENT_TYPE�lowerr�parse_mimetyperb�113contextlib�suppress�LookupErrorr��codecs�lookup�namera�subtyper��RuntimeErrorr�)r��ctype�mimetype�encodings    rX�get_encoding�ClientResponse.get_encoding�s������ � ��!2�!2�B�7�=�=�?���)�)�%�0���&�&�*�*�9�5����$�$�[�*�=��}�}�X�.�3�3�>�=��=�=�M�)�����&�(�*:�*:�f�*D���:�:���I��
��$�$�T�:�:�6�6�>�=�s� D�114D,r��errorsc��# �URcUR5IShv�N UcUR5nURRXS9$N07f)z!Read response payload and decode.N)r�)r�rpr�rI)r�r�r�s   rX�text�ClientResponse.text�sO����:�:���)�)�+������(�(�*�H��z�z� � �� �9�9�
�s�!A�A�1Ar�)r��loads�content_typer�r�c���# �URcUR5IShv�N U(a�URR[R115S5R
5n[XC5(d8[URURURSU-URS9eURR5nU(dgUcUR5nU"URU55$N�7f)zRead and decodes JSON response.Nr�z3Attempt to decode JSON with unexpected mimetype: %srj)r�rprrr�rr�r�r�r)r�rUr��stripr�rI)r�r�r�r�r��strippeds      rXr��ClientResponse.json�s�����:�:���)�)�+�����L�L�$�$�T�%6�%6��;�A�A�C�E�,�U�A�A�&��%�%��L�L��;�;�M�PU�U� �L�L����:�:�#�#�%�������(�(�*�H��X�_�_�X�.�/�/�-
�s�!C=�C;�CC=c��# �SUlU$7fr{)r�r�s rX�116__aenter__�ClientResponse.__aenter__s��������s�117�exc_type�exc_val�exc_tbc��n# �SUlUR5 UR5IShv�N gN7f)NF)r�r:r�)r�r�r�r�s    rX�	__aexit__�ClientResponse.__aexit__s,���!���	
�����!�!�#�#�#�s�+5�3�5)�__writerr�r�r9r�r�r�r�r�r�ror�r�r�r�r�r�r�r�r�r�r�r�r�rpr�r�r�r�)rNrq)rNz/MultiDictProxy[MultiDictProxy[Union[str, URL]]])rRrKrNrG�rNN)N�strict)rNrG)\rerfrgrhr�rr:rjr�r�r�rir�r>r�r�r�rr�rr�rDr�r�rr�r�r�r��StackSummaryr�r9r�r�r�r
r�rr0rHrr��AbstractEventLoopr��objectrr�r��setterrr5rorrsr�rrr%r�r_r1r�rr?rOrRrUrbrxrtr�r�r�r:r�r�r}r�r;r�r�rpr�r�r?r@r�r�rr�r118r�rkrdrZrXrGrGs���&*�G�X�k�
"�)��F�C�� �F�H�S�M� � �G�\� �!�E�8�E�?�!�&*�H��s�#�*�-/�H�e�)�*�/�#�L�*�#�*.�K��,�'�.�'+�H�h�|�$�+�59���%��S��/�2�9�26�I�x�.�/�6�:>��x�	� 6� 6�7�>�*.�H�h��'�.��G��I��K�AS��h� 0�%�8�#�=�>�S�/3�H�h�+�,�3�%O��%O��%O�119/�%O��4�5�
%O� �%O�"�%O��W�
�%O��'�'�%O�!�%O�120�%O�N���$�����"6�7����
�^�^�:�h�';�<�:��:��:�������
�^�^�,�|�,��,��,���S������������#������c���������!�Z�!��!��"�k�"��"��F�X�.@�%A�F��F�(0�;��;�D�;� �#��$� �H�\�2� �� ����4�5�����!%��!%�F/�b#�������$�����!�D�!��!��$V�#��121���E��(7�c�7�.:�8�C�=�:��:�TW�:�#'�1�&8�0��3�-�0��	0�122�s�m�0�123
�
0�B�$��4�
�.�/�$��-�(�$���'�	$�124125�$rZrGc0�x�\rSrSr%\R126\R\R\R1r	\R\R\R1r
\	R\
5R\R15r\R"S\R$\"50rSr\S\R04\S'SrSrSr\S\S'\"5rSr Sr!Sr"\S\S	'SSSSSS\#RHSSS127SSSSSSSSSS128SS.S
\%S\S\&S\\'S\\(\%S\)S\\*S\\+S\#RXS\\%\-S4S\\-S\-S\\.R^S\\0SS\\S\\+S\\1S\S S!\\2\-\34S"\\'S#\\4S$S%\-S&\\%4.S'jjr5SXS(\6S)S4S*jjr7S)\\84S+jr9\:S)\;S4S,j5r<\:S)\S4S-j5r=\=R|SYS/j5r=S)\-4S0jr?\:S)\S1\-\344S2j5r@\:S)\A4S3j5rB\:S)\%4S4j5rC\:S)\\84S5j5rD\:S)\\R0\ES644S7j5rF\FR|S8\)S)S4S9j5rF\:S)\G4S:j5rH\:SZS;j5rIS\S)S4S<jrJS\\#RX\%4S)S4S=jrKS\\'S)S4S>jrLS\\(\%S)S4S?jrMS\\*S)S4S@jrNS\)S)S4SAjrOS[SBjrPS\S\\+S%\-S)S4SCjjrQS]SD\)SE\8S)S4SFjjrRSD\)S)S4SGjrSSD\)S)S4SHjrTS\SI\-S)S4SJjjrUS\\S\\+S"\\'S)S4SKjrVSXS.\WSLSMSN\\8S)S4SOjjrXS^SPjrYS[SQjrZS[SRjr[S
\%S\SS\\S)S4STjr]S
\%S\SSUS)S4SVjr^SWr_g)_rFiz*/*Nr�r��_ClientRequest__writer�GETzCIMultiDict[None]�_skip_auto_headersFT)r0rr�skip_auto_headers�datar�authr��compress�chunked�	expect100r��response_classr�r�r�r�r��
proxy_headersr��	trust_env�server_hostnamerpror0rrr�r�rr�r�r�r�r�r�r�rGr�r�r�r�rJr�r�r�rLr�r�c��U
c[R"5n
[RU5=n(a"[	SU<SUR5<S35e[
U5[LdU5eUb[
U5[LdU5e[(aUceUUl	U(aURU5nX lUR(aURS5OUUlUR5UlX�lX�lX�lSUlUc[*nOUnUUlUbUO	[/5UlUbUOSUlUUlU
R75(a/[8R:"[<R>"S55Ul URCU	5 UREU5 URGU5 URIU5 URKU5 URMU5 UROUU5 URQUUU5 URSU5 UcUR URT;aURW5 URYU5 Uc/Ul-gUUl-g)Nz+Method cannot contain non-token characters z (found at least �)Tr).r��get_event_loop�_CONTAINS_CONTROL_CHAR_RE�searchr��grouprarrr��extend_query�original_urlr�r�ro�upperrpr�r�r��lengthrGr�r3r��_sslr�r�r�r�r�r�r��update_version�update_host�update_headers�update_auto_headers�update_cookies�update_content_encoding�update_auth�update_proxy�update_body_from_data�GET_METHODS�update_transfer_encoding�update_expect_continuer�)r�rpror0rrr�r�rr�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r��real_response_classs                          rXr��ClientRequest.__init__=s1��6�<��)�)�+�D�-�4�4�V�<�<�5�<��=�f�Z�H#�#(�;�;�=�"3�1�6��
�129�C�y�C��$��$������;�#�%�,�u�,�%��=��&�&�&���
���"�"�6�*�C���.1�.>�.>�3�$�$�T�*�C����l�l�n����� �
��	�����!�"0��"0��4G���$�0�e�i�k����?�C���	�.����>�>���%.�%<�%<�S�]�]�1�=M�%N�D�"����G�$���������G�$�� � �!2�3����G�$��$�$�T�*�����y�)����%��]�;��"�"�4�(���t�{�{�$�2B�2B�B��)�)�+��#�#�I�.�#�^�r�����rZr�rNc��SUlgr��r�r�s  rXr��ClientRequest.__reset_writer�rrZc���[RUR;agUR[Rn[U5$![a [	SU35Sef=f)z�Extract and validate Content-Length header value.130 131Returns parsed Content-Length value or None if not set.132Raises ValueError if header exists but cannot be parsed as an integer.133NzInvalid Content-Length header: )r�CONTENT_LENGTHrrr�r�)r��content_length_hdrs  rX�_get_content_length�!ClientRequest._get_content_length�sj�����d�l�l�2��!�\�\�$�*=�*=�>��	��)�*�*���	��1�2D�1E�F���
�	�s�134A	�	A#c�<�UR=(d135 [5$r�)r�rr�s rXr��ClientRequest.skip_auto_headers�s���&�&�7�+�-�7rZc��UR$r�r	r�s rXr��ClientRequest._writer�r#rZr�c��URb%URRUR5 XlURUR5 gr�)r�r�_ClientRequest__reset_writerrrs  rXr�r�s=���=�=�$��M�M�.�.�t�/B�/B�C��
�� � ��!4�!4�5rZc�<�URR[;$r�)ro�scheme�_SSL_SCHEMESr�s rXr��ClientRequest.is_ssl�s���x�x���,�.�.rZrEc��UR$r�)r�r�s rXr��ClientRequest.ssl�rrZc136�d�UR=n(a#[[UR555nOSnURn[R[UR=(d SURUR[;URURURU45$)Nr�)r��hashrw�itemsrorxr��raw_hostr�rrr�r�r�)r�r��hros    rX�connection_key�ClientRequest.connection_key�s��� �.�.�.�=�.�#�E�-�*=�*=�*?�$@�A�A��A��h�h���}�}�����"������137�138�l�*��	�	��139�140�����
�141�	142rZc�<�URRnUceU$r�)ror)r��rets  rXr��ClientRequest.host�s ���h�h���������143rZc�.�URR$r�)ror�r�s rXr��ClientRequest.port�s���x�x�}�}�rZrZc�,�UR=(d S$)z
Request body.rZ)r�r�s rX�body�ClientRequest.body�s���z�z� �S� rZrgc��URb.[URSS9 URR5 URU5 g)a�Set request body with warning for non-autoclose payloads.144 145WARNING: This setter must be called from within an event loop and is not146thread-safe. Setting body outside of an event loop may raise RuntimeError147when closing file-based payloads.148 149DEPRECATED: Direct assignment to body is deprecated and will be removed150in a future version. Use await update_body() instead for proper resource151management.152Nr�r�)r�r��_close�_update_body)r�rgs  rXr)r*�s>���:�:�!�
&�d�j�j�Q�?�153
�J�J�������%� rZc��[UR5n[R[UR154URXR45$r�)rrrrwrxrHrorpr�)r�rrs  rXr��ClientRequest.request_info�s=��)9�$�,�,�)G��155�}�}��$�(�(�D�K�K��:K�:K�L�156�	157rZc��UR$)z�Return the ClientSession instance.158 159This property provides access to the ClientSession that initiated160this request, allowing middleware to make additional requests161using the same session.162)r�r�s rXr��ClientRequest.session�s���}�}�rZc��UR(d[U5eUR(dUR(aC[R163"UR=(d SUR=(d S5Ulgg)z8Update destination host, port and connection type (ssl).r�N)	rr*�raw_user�raw_passwordrr1�user�passwordr�)r�ros  rXr��ClientRequest.update_hostsP���|�|��S�/�!��<�<�3�+�+��)�)�#�(�(�.�b�#�,�,�:L�"�M�D�I�,rZc�<�[U[5(a_URSS5Vs/sHo"R5PM nn[R164"[
US5[
US55nXlgs snf![a [SU35Sef=f)zTConvert request version to two elements tuple.165 166parser HTTP version '1.1' => (1, 1)167�.rrz#Can not parse http version number: N)	r�rir]r�rr:r�r�r�)r�r��part�vs    rXr��ClientRequest.update_versions���168�g�s�#�#�*1�-�-��Q�*?�@�*?�$����*?�A�@�
��*�*�3�q��t�9�c�!�A�$�i�@��169���A���
� �9�'��C����
�s�A<�/B�Bc��[5UlURRnUceX R[R170'U(dg[
U[[[45(aUR5nUHDup4U[R;aX@RU'M)URRX45 MF g)zUpdate request headers.N)
rrrro�host_port_subcomponentr�HOSTr��dictrrr�HOST_ALLr`)r�rrr�rfrgs     rXr��ClientRequest.update_headers s���)4�����x�x�.�.������"&���T�Y�Y�����g��n�i�@�A�A��m�m�o�G�!�J�C��d�m�m�#�$)���S�!���� � ��,�"rZc��UbV[S[U555UlURR	5nURUR5 OURnURR5Hup4X2;dMX@RU'M [RU;a"[UR[R'gg)Nc3�(# �UHoS4v� M171 g7fr�rd)r�hdrs  rXr�4ClientRequest.update_auto_headers.<locals>.<genexpr>;s���2�'@��d��'@�s�)r�sortedr�rr�copy�extend�DEFAULT_HEADERSrr�172USER_AGENTr9)r�r��used_headersrErcs     rXr��!ClientRequest.update_auto_headers9s����(�&1�2�'-�.?�'@�2�'�D�#� �<�<�,�,�.�L����� 7� 7�8� �<�<�L��,�,�2�2�4�H�C��&�$'���S�!�5��?�?�,�.�,;�D�L�L����)�/rZc�F�U(dg[5n[RUR;a]UR	[URR
[RS555 UR[R	[U[5(aUR5nOUnUH-upE[U[5(a[U5X$'M)XRU'M/ URSSS9R5UR[R'g)zUpdate request cookies header.Nr�rY)�header�sep)rr�COOKIErrr173r"r�r�rrrr$�outputr�)r�r�c�iter_cookiesr�rgs      rXr��ClientRequest.update_cookiesLs������N���;�;�$�,�,�&�
�H�H�(����)9�)9�$�+�+�r�)J�K�L����T�[�[�)��g�w�'�'�"�=�=�?�L�"�L�'�K�D��%��(�(�:�5�A����$��(�%&�H�H�B�C�H�$@�$F�$F�$H����T�[�[�!rZc��U(dSUlgURR[R5(aUR(a[S5egUR(aU[
UR[5(dSUlURUR[R'SUlgg)zSet request content encoding.Nz9compress can not be set if Content-Encoding header is setrQT)	r�rrr�r�CONTENT_ENCODINGr�r�rir�)r�r�s  rXr��%ClientRequest.update_content_encodingds���� �D�M���<�<���D�1�1�2�2��}�}� �O�����]�]��d�m�m�S�1�1� )��
�26�-�-�D�L�L��.�.�/��D�L�	rZc�j�URR[RS5R	5nSU;aUR174(a[
S5egUR175(aG[RUR;a[
S5eSUR[R'gg)z!Analyze transfer-encoding header.r�r�zDchunked can not be set if "Transfer-Encoding: chunked" header is setz6chunked can not be set if Content-Length header is setN)rrr�r�TRANSFER_ENCODINGr�r�r�r)r��tes  rXr�&ClientRequest.update_transfer_encodingvs���
�\�\�
�
�d�4�4�b�
9�
?�
?�
A����?��|�|� �D�����\�\��"�"�d�l�l�2� �L���4=�D�L�L��/�/�0�
rZc���UcURnUcg[U[R5(d[	S5eUR5UR[R'g)zSet basic auth.Nz%BasicAuth() tuple is required instead)	r�r�rr1r�rHrrr�
AUTHORIZATION)r�r�r�s   rXr�ClientRequest.update_auth�sQ���<��9�9�D��<���$�� 1� 1�2�2��C�D�D�+/�;�;�=����T�'�'�(rZr)�_stacklevelc��URb[URUS9 UcnSUlURUR;aLUR(d;[176RUR;aSUR[177R'g[U[5(aU"5OUn[RRUSS9nX@lUR(d[[178RUR;a=UR=nb'[U5UR[179R'OSUlUR(deURnUR nURR#5Hup�X�;dUbX�;aMX�U'M g![Ra [U5"5nN�f=f)zUpdate request body from data.Nr��0)�dispositionT)r�r�rprr�rrrrr�r.r!�PAYLOAD_REGISTRYr�r��sizerir�r)180r�r)r`�
maybe_payload�body_payloadrerr�skip_headersrfrgs181          rXr�#ClientRequest.update_body_from_data�sn���:�:�!�%�d�j�j�[�I��<��D�J����4�#3�#3�3�����'�'�t�|�|�;�47����T�0�0�1��#-�T�8�"<�"<���$�
�	5�"�3�3�7�7�
�SW�7�X�L�"�182��|�|�� 3� 3�4�<�<� G�$�)�)�)��6�47��I����T�0�0�1�#����#�#�#�#��,�,���.�.��&�.�.�4�4�6�J�C��~�,�":�s�?R�� �C�L�7���"�"�	5�#�M�2�4�L�	5�s�2F$�$$G�183Gc��[RUR;aUR[R	UR(a9[RUR;aUR[R	URUSS9 UcURUR;aUR5 gg)z/Update request body after its already been set.�)r`N)	rrrrr�rZrrprr�r�r)s  rXr-�ClientRequest._update_body�s������$�,�,�.����T�0�0�1��<�<�D�2�2�d�l�l�B����T�3�3�4�	
�"�"�4�Q�"�7���t�{�{�$�2B�2B�B��)�)�+� CrZc��# �URb"URR5IShv�N URU5 gN7f)a184Update request body and close previous payload if needed.185 186This method safely updates the request body by first closing any existing187payload to prevent resource leaks, then setting the new body.188 189IMPORTANT: Always use this method instead of setting request.body directly.190Direct assignment to request.body will leak resources if the previous body191contains file handles, streams, or other resources that need cleanup.192 193Args:194    body: The new body content. Can be:195        - bytes/bytearray: Raw binary data196        - str: Text data (will be encoded using charset from Content-Type)197        - FormData: Form data that will be encoded as multipart/form-data198        - Payload: A pre-configured payload object199        - AsyncIterable: An async iterable of bytes chunks200        - File-like object: Will be read and sent as binary data201        - None: Clears the body202 203Usage:204    # CORRECT: Use update_body205    await request.update_body(b"new request data")206 207    # WRONG: Don't set body directly208    # request.body = b"new request data"  # This will leak resources!209 210    # Update with form data211    form_data = FormData()212    form_data.add_field('field', 'value')213    await request.update_body(form_data)214 215    # Clear body216    await request.update_body(None)217 218Note:219    This method is async because it may need to close file handles or220    other resources associated with the previous payload. Always await221    this method to ensure proper cleanup.222 223Warning:224    Setting request.body directly is highly discouraged and can lead to:225    - Resource leaks (unclosed file handles, streams)226    - Memory leaks (unreleased buffers)227    - Unexpected behavior with streaming payloads228 229    It is not recommended to change the payload type in middleware. If the230    body was already set (e.g., as bytes), it's best to keep the same type231    rather than converting it (e.g., to str) as this may result in unexpected232    behavior.233 234See Also:235    - update_body_from_data: Synchronous body update without cleanup236    - body property: Direct body access (STRONGLY DISCOURAGED)237 238N)r�r�r-rls  rX�update_body�ClientRequest.update_body�s;���t�:�:�!��*�*�"�"�$�$�$����$��
%�s�+A�A�A�expectc�:�U(aSUR[R'OO[RUR;a1UR[RR5S:XaSnU(a URR5Ulgg)Nz100-continueT)rrr�EXPECTr�r��
create_futurer�)r�rqs  rXr�$ClientRequest.update_expect_continuesf���(6�D�L�L����%��K�K�4�<�<�'����T�[�[�)�/�/�1�^�C��F��!�Y�Y�4�4�6�D�N�rZc��XlUcSUlSUlgU(a*[U[R2395(d[
S5eX lUb&[U[[45(d[U5nX0lg)Nz,proxy_auth must be None or BasicAuth() tuple)240r�r�r�r�rr1r�rrr)r�r�r�r�s    rXr�ClientRequest.update_proxyst���241��=�"�D�O�!%�D����j��W�5F�5F�G�G��K�L�L�$���$�Z��I�~�6�.242�.243�(�
�6�M�*�rZ�connrK�content_lengthc244��2# �URb<UR5 UR5IShv�N URIShv�N URnUceURb#URRX5IShv�N UR
5IShv�N UR5 gN�NqN1N![awnUnURSL=(d [U[R5(+nU(a$[URSUR<35n[XFU5 SnAgSnAf[R a UR#5 e[$a(n[U['SU<SU<35U5 SnAgSnAff=f7f)a�245Write the request body to the connection stream.246 247This method handles writing different types of request bodies:2481. Payload objects (using their specialized write_with_length method)2492. Bytes/bytearray objects2503. Iterable body content251 252Args:253    writer: The stream writer to write the body to254    conn: The connection being used for this request255    content_length: Optional maximum number of bytes to write from the body256                    (None means write the entire body)257 258The method properly handles:259- Waiting for 100-Continue responses if required260- Content length constraints for chunked encoding261- Error handling for network issues, cancellation, and other exceptions262- Signaling EOF and timeout management263 264Raises:265    ClientOSError: When there's an OS-level error writing the body266    ClientConnectionError: When there's a general connection error267    asyncio.CancelledError: When the operation is cancelled268 269NzCan not write request body for z4Failed to send bytes into the underlying connection z: )r��send_headers�drainrnr��write_with_length�	write_eof�
start_timeout�OSError�errnor�r��TimeoutErrorr'ror7r�r��	Exceptionr&)r�r�rxryrn�underlying_exc�reraised_exc�exc_is_not_timeouts        rX�write_bytes�ClientRequest.write_bytes0s}���B�>�>�%����!��,�,�.� � ��.�.� � ��=�=���#�#�#�'	%��z�z�%��j�j�2�2�6�J�J�J�<�"�"�$�$�$��"�"�$�Y
!� �K�<
%��;�
	B�)�L�"0�!5�!5�T�!A�"���� 4� 4�J�F��"�,�"�(�(�5�d�h�h�]�C� ��270
�(�.�A�A���%�%�	��J�J�L���	���%�J��i�r�.�!3�5���

�
��	�s��1F�B7�F�B9�F�+B?�	B;�271B?�F�!B=�"F�9F�;B?�=F�?272F�	A-D;�6F�;1F�,F�273F�F�Fc���# �UR[R:Xa7URRnUceUSURR2743nORUR(a+UR5(d[UR5nOURRnURnUce[UURUR(a6[R"UR URUR5OSUR(a6[R"UR"URUR5OSS9nUR$(aUR'UR$5 UR(bUR+5 URUR,;afUR.b[R0UR.;a;[R0UR2;aSUR2[R0'UR4n[R6UR2;ajUR8R:(a(U[<:XaSUR2[R6'O'U[>:XaSUR2[R6'URSUSUR@SURB3nUREXpR25IShv�N URF(dURHcURJ(a�URMXQURO55n[PRRS	:�a [TRV"X�RS275S9n	OURRYU5n	U	R[5(aSn	O)X�l.O"UR_5 URa5 Sn	URbn276U277ceU278"URURdU	URHURfURhURURURjS9	Ul6URl$GNd7f)
N�:)�
on_chunk_sent�on_headers_sentzapplication/octet-streamr�z279keep-alive� z HTTP/r9)r��T)r��eager_start)r�r�r�r�r�r�r�)7rpr�METH_CONNECTro�host_subcomponentr�r�r�ri�raw_path_qsrnr=r�r��	functools�partial�_on_chunk_request_sent�_on_headers_request_sentr��enable_compressionr��enable_chunking�POST_METHODSr�r�rrr��280CONNECTION�281_connector�force_closer<r;�major�minor�
write_headersr�r��writing_pausedr�rr�r�r��Task�create_taskrr�r�set_eofr�r�r�r�r��response)r�rx�connect_host�pathrnr�r;�status_line�coror�r�s           rX�send�ClientRequest.send�s;���282�;�;�$�+�+�+��8�8�5�5�L��+�+�+�"�^�1�T�X�X�]�]�O�4�D�
�Z�Z����
�
��t�x�x�=�D��8�8�'�'�D��=�=���#�#�#����I�I��<�<��!�!�$�"=�"=�t�{�{�D�H�H�U���<�<��!�!�$�"?�"?����d�h�h�W��
283���=�=��%�%�d�m�m�4��<�<�#��"�"�$�
�K�K�4�,�,�,��'�'�/��$�$�D�,C�,C�C��!�!����5�.H�D�L�L��*�*�+��L�L���?�?�$�,�,�.����*�*��
�%�4;�D�L�L����1���m�#�0<����T�_�_�-����
�Q�t�f�F�1�7�7�)�1�Q�W�W�I�F���"�"�;���=�=�=��:�:����3�x�7N�7N��#�#�F�$�2J�2J�2L�M�D����7�*��|�|�D�y�y�d�K���y�y�,�,�T�2���y�y�{�{���#��
�"�"�$��N�N���D��,�,���)�)�)�&��K�K���������+�+��*�*��<�<�����M�M�284285��
��}�}��K	>�s�LQ,�Q)�E$Q,c��# �URbURIShv�N ggN![RaM [RS:�a6[R286"5=n(aUR
5(aegggf=f7fr�)r�r�r�r�r�r�r�r�s  rXr��ClientRequest.close�s~����=�=�$�
��m�m�#�#�%�#���)�)�
��$�$��/�!(�!5�!5�!7�7��7����)�)��*�8�0�
�s2�B
�)�'�)�B
�)�AB287�B
�	B288�289B
c���URbfURR5(dURR5 URR	UR2905 SUlggr�)r�r�r�r�rrr�s rX�	terminate�ClientRequest.terminate�sS���=�=�$��9�9�&�&�(�(��
�
�$�$�&��M�M�.�.�t�/B�/B�C� �D�M�	%rZ�chunkc��j# �URHnURXU5IShv�N M gN	7fr�)r��send_request_chunk_sent)r�rpror�r�s     rXr��$ClientRequest._on_chunk_request_sent�s,����\�\�E��/�/��U�C�C�C�"�C���%3�1�2913zCIMultiDict[str]c��j# �URHnURXU5IShv�N M gN	7fr�)r��send_request_headers)r�rprorrr�s     rXr��&ClientRequest._on_headers_request_sent�s.����\�\�E��,�,�V�'�B�B�B�"�B�r�)r�r�r�r�r�r�r�r�r�r�r�r�r�rrr�r�rpr�r�r�r�r�r�r�ror�r�)r�r�rNN)rNrJr�)F)r�)rxrKrNrG)`rerfrgrhr�METH_GET�	METH_HEAD�METH_OPTIONS�292METH_TRACEr�293METH_PATCH�	METH_POST�METH_PUTr��union�METH_DELETE�ALL_METHODS�ACCEPT�ACCEPT_ENCODINGrYrJr�rr!�Payloadrjr�r�r�rrrorpr�r�rr<rirCrBrrrAr1r:r�r�r�rr0rErIrr�r�rr�rr�rr�r�r�r�r�r�r!r�r�rr)rHr�r�r�r�r�r�r�r�rrrr-rorrr%r�r�r�r�r�r�r�rkrdrZrXrFrFs
���
�
����������	�K��O�O�T�^�^�T�]�]�C�L��#�#�L�1�7�7��9I�9I�8J�K�K�	
���U����:�<��O�+/�E�5��w���&�'�.��D��H�/3�H�h�+�,�3��%�C�
�F��I�8<���!4�5�<��*.�59��*.�$(�$(�$6�$6�+/�"&��48�;?�#�*.�,0�-1�48�04�*.��)-�3M8��M8��M8�294�M8��,�'�
M8�$�H�S�M�2�M8��M8��,�'�M8��y�!�M8��!�!�M8���T�4��(�M8��$��M8��M8��w�0�0�1�M8� !��&6�!7�8�!M8�"��}�#M8�$�Y�'�%M8�&�(�)�'M8�(�/�*�)M8�*�:�t�[�0�
1�+M8�, ��-�-M8�.��g��'�/M8�0�1M8�2"�#��3M8�^���$���X�c�]��"�8�;�t�#4�8��8����"6�7����
�^�^�6��6�/��/���U�<��{�:�;�����295�
�296��297�&��c����298��h�s�m�����!�e�G�O�O�W�S�\�9�:�!��!�299300�[�[�!�#�!�$�!��!�.�301�k�302��303�����N�s�N�t�N�
�e�D�,<�,<�c�,A�&B�
�t�
�-�h�|�&<�-��-�2<�X�h�s�m�5L�<�QU�<�&I�h�|�&<�I��I�0 �C� �D� �$=�&3049��� 3�3059��3069�QU�3079�'!�#�'!�C�'!��'!�R,��,��,�$< �c�< �d�< �|3087�T�3097�d�3107�+���}�+��Y�'�+� ��-�	+�311312�+�4)-�	P%�$�P%��P%�!��
�	P%�313314�P%�da�F315�!�D�3�D�S�D��D�SW�D�C��C� #�C�.@�C�	
�CrZrF)r)~r�r�r�r�rFr\r�r�r��collections.abcr�hashlibrrr�http.cookiesrr�typesr	r316�typingrrr
rrrrrrrrr�attr�	multidictrrrr�yarlrr�rrrr r!�_cookie_helpersr"r#r$�abcr%�client_exceptionsr&r'r(r)r*r+�compression_utilsr,r-�formdatar.r/r0r1r2r3r4r5r6r7r8r9r:r;r<r=�streamsr>�typedefsr?r@rArBrCrDr�rE�ImportErrorr��__all__�clientrJ�	connectorrK�tracingrLr��compiler�r�rirY�sr_rmrHrIr�rar�r�r��	frozensetrr�r�r�r�r�rGrFrdrZrX�<module>r�sd���
���	�	�317���#�%�%�-�1�
�
�
�
��N�N��5�5���318&���4�������"��������"�L���%�%�� 5�5H�I���J�J�'E�F��319�*�*�9�320:��	 �c�	 ����T�$�d�3���4���:��321�,�322�$P�P�@�?�����{�D��J�G���t�D�z�*��4�	�|�T�;�.�	/�4����4��,�'�4��%��	4�323�<��{�*�+�4�n�)�*��	&�J�	&�:��:�7:�:�	�:�324�w���325�C�326�PT�327�&w$�\�w$�tgC�gC��G�����328��s�329H,�,330H:�9H:
codekingpro/portable-devtools · Team Ai