codekingpro/portable-devtools
114k
1�
2 ��jW] � � � S SK Jr S SKrS SKrS SKrS SKrS SKJr S SKJ r SSK3J r J r SSK
Jr SSKJr SS KJrJrJr SS4KJrJrJrJr SS KJr SS K J r SS
K J r SSK J!r! SSK"J#r# SSK$J%r%J&r& \RN ( a5 S SK(r(S SK)J*r* / SQr+\RX " \-5 r.Sr/Sr0 " S S\Rb 5 r2 S S jr3\Rh " \3\25 \Rh " \3\25 S.r5\\S.r6 " S S\5 r7 " S S \75 r8S S jr9g) � )� annotationsN)�
TracebackType)�urljoin� )�HTTPHeaderDict�RecentlyUsedContainer)�RequestMethods)� ProxyConfig)�HTTPConnectionPool�HTTPSConnectionPool�port_by_scheme)�LocationValueError�
MaxRetryError�ProxySchemeUnknown�URLSchemeUnknown)�BaseHTTPResponse)�_TYPE_SOCKET_OPTIONS)� connection_requires_http_tunnel)�Retry)�Timeout)�Url� parse_url)�Self)� PoolManager� ProxyManager�proxy_from_url) �key_file� cert_file� cert_reqs�ca_certs� ca_cert_data� ssl_version�ssl_minimum_version�ssl_maximum_version� ca_cert_dir� ssl_context� key_password�server_hostnamei @ c �< � \ rS rSr% SrS\S' S\S' S\S' S\S ' S6\S ' S \S
' S\S' S\S' S\S' S\S' S\S' S\S' S\S' S\S' S\S' S\S ' S\S ' S \S ' S\S ' S!\S"' S#\S$' S!\S%' S&\S'' S(\S)' S!\S*' S+\S,' S\S-' S\S.' S\S/' S0rg1)2�PoolKey�8 z�7All known keyword arguments that could be provided to the pool manager, its8pools, or the underlying connections.9 10All custom key schemes should include the fields in this key at a minimum.11�str�12key_scheme�key_host�13int | None�key_portz Timeout | float | int | None� key_timeoutzRetry | bool | int | None� key_retriesz bool | None� key_blockztuple[str, int] | None�key_source_address�14str | None� key_key_file�key_key_password�
key_cert_file�
key_cert_reqs� key_ca_certszstr | bytes | None�key_ca_cert_datazint | str | None�key_ssl_versionzssl.TLSVersion | None�key_ssl_minimum_version�key_ssl_maximum_version�key_ca_cert_dir�ssl.SSLContext | None�key_ssl_context� key_maxsizez!frozenset[tuple[str, str]] | None� key_headers�15Url | None�16key__proxy�key__proxy_headers�ProxyConfig | None�key__proxy_configz_TYPE_SOCKET_OPTIONS | None�key_socket_options�key__socks_optionszbool | str | None�key_assert_hostname�key_assert_fingerprint�key_server_hostname�
key_blocksize� N)�__name__�17__module__� __qualname__�__firstlineno__�__doc__�__annotations__�__static_attributes__rO � �YD:\code\apps\devtools\python\user_packages\Python313\site-packages\urllib3/poolmanager.pyr* r* 8 s� � �� �O��M���-�-�*�*���.�.� � � � � � � � � � �(�(�%�%� 2�2� 2�2� � �*�*���2�2���9�9�)�)�3�3�9�9�*�*� &�&�#�#� � rW r* c � � UR 5 nUS R 5 US' US R 5 US' S H. nX2; d M18 X# c M [ X# R 5 5 X#' M0 UR S5 nUb [ U5 US' [
UR 5 5 H nUR U5 USU- ' M U R H nXR; d M19 SX%' M UR S5 c [ US' U " S0 UD6$ ) a� 20Create a pool key out of a request context dictionary.21 22According to RFC 3986, both the scheme and host are case-insensitive.23Therefore, this function normalizes both before constructing the pool24key for an HTTPS request. If you wish to change this behaviour, provide25alternate callables to ``key_fn_by_scheme``.26 27:param key_class:28 The class to use when constructing the key. This should be a namedtuple29 with the ``scheme`` and ``host`` keys at a minimum.30:type key_class: namedtuple31:param request_context:32 A dictionary-like object that contain the context for a request.33:type request_context: dict34 35:return: A namedtuple that can be used as a connection pool key.36:rtype: PoolKey37�scheme�host)�headers�_proxy_headers�_socks_optionsN�socket_options�key_rN rO ) �copy�lower� frozenset�items�get�tuple�list�keys�pop�_fields�_DEFAULT_BLOCKSIZE)� key_class�request_context�context�key� socket_opts�fields rX �_default_key_normalizerrr _ s � �. �"�"�$�G� ��)�/�/�1�G�H�� �f�o�+�+�-�G�F�O� ?�� �>�g�l� 6�$�W�\�%7�%7�%9�:�G�L� ?� �+�+� .�/�K�� �$)�+�$6�� �!� �G�L�L�N�#�� '� � �C� 0���� � � $� �"�"�� � � !�G�N� #�38 �{�{�?�#�+�#5��� � � �w� � rW ��http�httpsc �Z ^ � \ rS rSr% SrSrS\S' SrS\S' S SU 4S jjjrSS jr SS39 jr40 S SS jjr SS jr S S S
jjr
S S jr S S jr S S S jjr S!S jrS"S jr S# S$S jjrSrU =r$ )%r � a 41Allows for arbitrary requests while transparently keeping track of42necessary connection pools for you.43 44:param num_pools:45 Number of connection pools to cache before discarding the least46 recently used pool.47 48:param headers:49 Headers to include with all requests, unless other headers are given50 explicitly.51 52:param \**connection_pool_kw:53 Additional parameters are used to create fresh54 :class:`urllib3.connectionpool.ConnectionPool` instances.55 56Example:57 58.. code-block:: python59 60 import urllib361 62 http = urllib3.PoolManager(num_pools=2)63 64 resp1 = http.request("GET", "https://google.com/")65 resp2 = http.request("GET", "https://google.com/mail")66 resp3 = http.request("GET", "https://yahoo.com/")67 68 print(len(http.pools))69 # 270 71NrD �proxyrG � proxy_configc �0 >� [ TU ] U5 SU; aD US n[ U[ 5 ( d* [ R " U5 nUR 5 nXCS' X0l U [ U5 U l [ U l [ R 5 U l72 g )N�retries) �super�__init__�73isinstancer �from_intra �connection_pool_kwr �pools�pool_classes_by_scheme�key_fn_by_scheme)�self� num_poolsr\ r� r{ � __class__s �rX r} �PoolManager.__init__� s� �� � ����!� �*� *�(��3�G� �g�u�-�-� �.�.��1��%7�%<�%<�%>�"�07�9�-�"4� � �*�9�5��74� '=��#� 0� 5� 5� 7�� rW c � � U $ �NrO �r� s rX � __enter__�PoolManager.__enter__� s � �� rW c �$ � U R 5 g)NF)�clear)r� �exc_type�exc_val�exc_tbs rX �__exit__�PoolManager.__exit__� s � �
�75�76� �rW c �" � U R U nUc U R R 5 nUR S5 c [ US' S H nUR US5 M US:X a [ H nUR US5 M U" X#40 UD6$ )a� 77Create a new :class:`urllib3.connectionpool.ConnectionPool` based on host, port, scheme, and78any additional pool keyword arguments.79 80If ``request_context`` is provided, it is provided as keyword arguments81to the pool class used. This method is used to actually create the82connection pools handed out by :meth:`connection_from_url` and83companion methods. It is intended to be overridden for customization.84N� blocksize)rZ r[ �portrt )r� r� ra re rk ri � SSL_KEYWORDS)r� rZ r[ r� rm �pool_clsro �kws rX � _new_pool�PoolManager._new_pool� s� � � .2�-H�-H��-P�� � "� "� 5� 5� :� :� <�O� � � �{� +� 3�+=�O�K� (� .�C� � � ��T� *� .� �V� �"�� �#�#�B��-� #� ��6�o�6�6rW c �8 � U R R 5 g)z�85Empty our store of pools and direct them all to close.86 87This will not affect in-flight connections, but they will not be88re-used after completion.89N)r� r� r� s rX r� �PoolManager.clear s � �
�90�91���rW c �� � U( d [ S5 eU R U5 nU=( d SUS' U( d( [ R " US R 5 S5 nX%S' XS' U R U5 $ )al 92Get a :class:`urllib3.connectionpool.ConnectionPool` based on the host, port, and scheme.93 94If ``port`` isn't given, it will be derived from the ``scheme`` using95``urllib3.connectionpool.port_by_scheme``. If ``pool_kwargs`` is96provided, it is merged with the instance's ``connection_pool_kw``97variable and used to create the new connection pool, if one is98needed.99zNo host specified.rt rZ �P r� r[ )r �_merge_pool_kwargsr
re rb �connection_from_context)r� r[ r� rZ � pool_kwargsrm s rX �connection_from_host� PoolManager.connection_from_host" sv � �" �$�%9�:� :� �1�1�+�>��$*�$4�f���!��!�%�%�o�h�&?�&E�&E�&G��L�D�"&�� �"&�� ��+�+�O�<�<rW c � � SU; a, [ R " S[ 5 UR S5 US R 5 nU R100 R
U5 nU( d [ U5 eU" U5 nU R XAS9$ )z�101Get a :class:`urllib3.connectionpool.ConnectionPool` based on the request context.102 103``request_context`` must at least contain the ``scheme`` key and its104value must be a key in ``key_fn_by_scheme`` instance variable.105�strictzbThe 'strict' parameter is no longer needed on Python 3+. This will raise an error in urllib3 v3.0.rZ �rm ) �warnings�warn�
FutureWarningri rb r� re r �connection_from_pool_key)r� rm rZ �pool_key_constructor�pool_keys rX r� �#PoolManager.connection_from_context? s� � � �� &� �M�M�<� �
�106
� � �� )� ��*�0�0�2�� #� 4� 4� 8� 8�� @� �#�"�6�*� *�'��8���,�,�X�,�W�WrW c � � U R R U R R U5 nU( a UsSSS5 $ US nUS nUS nU R XEXbS9nX0R U' SSS5 U$ ! , ( d f W$ = f)z�107Get a :class:`urllib3.connectionpool.ConnectionPool` based on the provided pool key.108 109``pool_key`` should be a namedtuple that only contains immutable110objects. At a minimum it must have the ``scheme``, ``host``, and111``port`` fields.112NrZ r[ r� r� )r� �lockre r� )r� r� rm �poolrZ r[ r� s rX r� �$PoolManager.connection_from_pool_keyX s� � � �Z�Z�_�_� �:�:�>�>�(�+�D��� �_� %�X�.�F�"�6�*�D�"�6�*�D��>�>�&��>�V�D�#'�J�J�x� � � � � �_� � �s �$A<�-A<�<113B c �x � [ U5 nU R UR UR UR US9$ )a� 114Similar to :func:`urllib3.connectionpool.connection_from_url`.115 116If ``pool_kwargs`` is not provided and a new pool needs to be117constructed, ``self.connection_pool_kw`` is used to initialize118the :class:`urllib3.connectionpool.ConnectionPool`. If ``pool_kwargs``119is provided, it is used instead. Note that if a new pool does not120need to be created for the request, the provided ``pool_kwargs`` are121not used.122)r� rZ r� )r r� r[ r� rZ )r� �urlr� �us rX �connection_from_url� PoolManager.connection_from_urlr s: � �
�c�N���(�(�
�F�F�������k� )� 123� 124rW c � � U R R 5 nU( a% UR 5 H u p4Uc X# M
XBU' M U$ ! [ a M$ f = f)z�125Merge a dictionary of override values for self.connection_pool_kw.126 127This does not modify self.connection_pool_kw and returns a new dict.128Any keys in the override dictionary with a value of ``None`` are129removed from the merged dictionary.130)r� ra rd �KeyError)r� �override�base_pool_kwargsro �values rX r� � PoolManager._merge_pool_kwargs� se � � �2�2�7�7�9�� � &�n�n� .�131���=� � ,� 1� -2�S�)� /� � �� $� � � �s �A � 132A�Ac �~ � U R c g[ U R U R UR 5 ( + $ )z�133Indicates if the proxy requires the complete destination URL in the134request. Normally this is only needed when not using an HTTP CONNECT135tunnel.136F)rx r ry rZ )r� �137parsed_urls rX �!_proxy_requires_url_absolute_form�-PoolManager._proxy_requires_url_absolute_form� s: � � �:�:� ��2� �J�J��)�)�:�+<�+<�138� 139� 140rW c �� � [ U5 nUR c [ R " S[ SS9 U R UR UR UR S9nSUS' SUS' S U; a U R US ' U R U5 ( a UR " X40 UD6nO UR " XR 40 UD6nU=( a UR 5 nU( d U$ [ X(5 nUR S141:X a& S nSUS ' [ US 5 R! 5 US ' UR# S
UR$ 5 n [' U [( 5 ( d [( R* " X�S9n U R, ( ak UR/ U5 ( dU US R1 5 n142US H5 n U R3 5 U R, ; d M# U143R5 U S5 M7 X�S ' U R7 XXvS9n X�S
' X4S' [> RA SX(5 UR= 5 U R " X40 UD6$ ! [8 a' U R: ( a UR= 5 e Us $ f = f)a 144Same as :meth:`urllib3.HTTPConnectionPool.urlopen`145with custom cross-host redirect logic and only sends the request-uri146portion of the ``url``.147 148The given ``url`` parameter must be absolute, such that an appropriate149:class:`urllib3.connectionpool.ConnectionPool` can be chosen for it.150Nz�URLs without a scheme (ie 'https://') are deprecated and will raise an error in urllib3 v3.0. To avoid this FutureWarning ensure all URLs start with 'https://' or 'http://'. Read more in this issue: https://github.com/urllib3/urllib3/issues/2920� )�category�151stacklevel)r� rZ F�assert_same_host�redirectr\ i/ �GET�bodyr{ )r� )�response�_poolzRedirecting %s -> %s)!r rZ r� r� r� r� r[ r� r\ r� �urlopen� request_uri�get_redirect_locationr �statusr �_prepare_for_method_changere r{ r~ r r �remove_headers_on_redirect� is_same_hostra rb ri � incrementr �raise_on_redirect�152drain_conn�log�info) r� �methodr� r� r� r� �connr� �redirect_locationr{ � new_headers�headers rX r� �PoolManager.urlopen� s= � �
�c�N�� �8�8� � �M�M�A� '� �
� �(�(����a�f�f�Q�X�X�(�N��!&�� � � ��:�� �B� � �L�L�B�y�M� � 1� 1�!� 4� 4��|�|�F�6�2�6�H��|�|�F�M�M�@�R�@�H� $� I��)G�)G�)I�� ��O� $�C� ;�� �?�?�c� !��F� �B�v�J� *�2�i�=� 9� T� T� V�B�y�M��&�&��H�$4�$4�5���'�5�)�)��n�n�W�@�G�153 � -� -�d�6G�6G� �7154� 7155� �Y�-�,�,�.�K� �Y�-���<�<�>�W�%G�%G�G� �O�O�F�D�1� (� (�y�M� � �'�'��h�'�S�G� �9�
�!�:�� ���'��@���� ��|�|�F�<��<�<�� � ��(�(��#�#�%���O� �s �-H> �>.I/�.I/)r� r� r� r� )�156 N)r� �intr\ � typing.Mapping[str, str] | Noner� �157typing.Any�return�None)r� r )r� ztype[BaseException] | Noner� zBaseException | Noner� zTracebackType | Noner� ztyping.Literal[False]r� )158rZ r, r[ r, r� r� rm � dict[str, typing.Any] | Noner� r )r� r� �Nrt N�159r[ r5 r� r/ rZ r5 r� r� r� r )rm �dict[str, typing.Any]r� r )r� r* rm r� r� r )r� r, r� r� r� r )r� r� r� r� )r� r r� �bool�T�160r� r, r� r, r� r� r� r� r� r )rP rQ rR rS rT rx rU ry r} r� r� r� r� r� r� r� r� r� r� r� rV �
__classcell__�r� s @rX r r � s� �� � �B �E�:� �'+�L�$�+� �37� 8�� 8� 1� 8� )� 8�161 162� 8� 8�>��,�� &�� %� �163 164 � � 9=� $7��$7� �$7� � $7�165 6� $7� 166 �
$7�L� � #�48� =��=� �=� � =�167 2� =� 168 �
=�:X� 4�X� �X�2� ��2G�� ��6 EI�169��170�%A�171� �172�$ �4� � � �, 173� 7;�P=��P=� #�P=�/3�P=�BL�P=� �P=� P=rW r c �� ^ � \ rS rSrSr S S U 4S jjjr S174 S U 4S jjjr S S
S jjr S SU 4S jjjrSr U =r175$ )r i� a 176Behaves just like :class:`PoolManager`, but sends all requests through177the defined proxy, using the CONNECT method for HTTPS URLs.178 179:param proxy_url:180 The URL of the proxy to be used.181 182:param proxy_headers:183 A dictionary containing headers that will be sent to the proxy. In case184 of HTTP they are being sent with each request, while in the185 HTTPS/CONNECT case they are sent only once. Could be used for proxy186 authentication.187 188:param proxy_ssl_context:189 The proxy SSL context is used to establish the TLS connection to the190 proxy when using HTTPS proxies.191 192:param use_forwarding_for_https:193 (Defaults to False) If set to True will forward requests to the HTTPS194 proxy to be made on behalf of the client instead of creating a TLS195 tunnel via the CONNECT method. **Enabling this flag means that request196 and response headers and content will be visible from the HTTPS proxy**197 whereas tunneling keeps request and response headers and content198 private. IP address, target hostname, SNI, and port are always visible199 to an HTTPS proxy even when this flag is disabled.200 201:param proxy_assert_hostname:202 The hostname of the certificate to verify against.203 204:param proxy_assert_fingerprint:205 The fingerprint of the certificate to verify against.206 207Example:208 209.. code-block:: python210 211 import urllib3212 213 proxy = urllib3.ProxyManager("https://localhost:3128/")214 215 resp1 = proxy.request("GET", "http://google.com/")216 resp2 = proxy.request("GET", "http://httpbin.org/")217 218 # One pool was shared by both plain HTTP requests.219 print(len(proxy.pools))220 # 1221 222 resp3 = proxy.request("GET", "https://httpbin.org/")223 resp4 = proxy.request("GET", "https://twitter.com/")224 225 # A separate pool was added for each HTTPS target.226 print(len(proxy.pools))227 # 3228 229c �B >� [ U[ 5 ( a) UR SUR SUR 3n230OUn231[ U2325 n U R S; a [
U R 5 eU R ( d0 [ R " U R S5 n U R U S9n X�l233 U=( d 0 U l XPl [ UUUU5 U l U R U S' U R U S' U R U S' [ T
U ]@ " X#40 U D6 g ) Nz://�:rs r� )r� �_proxyr] �
_proxy_config)r~ r rZ r[ r� r r r
re �_replacerx �
proxy_headers�proxy_ssl_contextr234 ry r| r} )r� � proxy_urlr� r\ r� r� �use_forwarding_for_https�proxy_assert_hostname�proxy_assert_fingerprintr� �
str_proxy_urlrx r� r� s �rX r} �ProxyManager.__init__3 s235 �� � �i�!3� 4� 4� (� /� /� 0��I�N�N�3C�1�Y�^�^�DT� U�M� %�M��-�(�� �<�<� 0� 0�$�U�\�\�2� 2��z�z�!�%�%�e�l�l�B�7�D��N�N��N�-�E��236� *� 0�b���!2� � '� � $� !� $� 237��� (,�z�z��8�$�/3�/A�/A��+�,�.2�.?�.?��?�+�
����B�/A�BrW c �� >� US:X a [ TU ] XX4S9$ [ TU ] U R R U R R U R R238 US9$ )Nru )r� )r| r� rx r[ r� rZ )r� r[ r� rZ r� r� s �rX r� �!ProxyManager.connection_from_host\ se �� � �W� ��7�/��F� 0� �
� �w�+� �J�J�O�O�T�Z�Z�_�_�d�j�j�.?�.?�[� ,� 239� 240rW c �~ � SS0n[ U5 R nU( a XCS' U( a UR U5 U$ )zx241Sets headers needed by proxies: specifically, the Accept and Host242headers. Only sets headers not provided by the user.243�Acceptz*/*�Host)r �netloc�update)r� r� r\ �headers_r s rX �_set_proxy_headers� ProxyManager._set_proxy_headersl s< � � �e�$���3� �&�&�� � %�V� � � �O�O�G� $��rW c � >� [ U5 n[ U R U R UR 5 ( d0 UR SU R 5 nU R X&5 US' [ TU ]$ " X4SU0UD6$ )z@Same as HTTP(S)ConnectionPool.urlopen, ``url`` must be absolute.r\ r� )244r r rx ry rZ re r\ r r| r� )r� r� r� r� r� r� r\ r� s �rX r� �ProxyManager.urlopen} sn �� �
�c�N��.�t�z�z�4�;L�;L�a�h�h�W�W� �f�f�Y�� � �5�G� � 3� 3�C� A�B�y�M��w��v�D�X�D��D�DrW )rx ry r� r� )r� NNNFNN)r� r, r� r� r\ r� r� r� r� r@ r� r� r� z"None | str | typing.Literal[False]r� r5 r� r� r� r� r� r� r� )r� r, r\ r� r� ztyping.Mapping[str, str]r� r� ) rP rQ rR rS rT r} r� r r� rV r� r� s @rX r r � sA �� �6�v �37�9=�37�).�DH�/3�'C��'C� �'C� 1� 'C�245 7� 'C� 1�
'C� #'�'C� B�'C� #-�'C� )�'C� 246�'C� 'C�X � #�48� 247��248� �249� � 250�251 2� 252� 253 �
254� 255�" DH����!@�� !��$ 7;� E�� E� #� E�/3� E�BL� E� � E� ErW r c � � [ SSU 0UD6$ )Nr� rO )r )r� r� s rX r r � s � � � ,�#� ,�� ,�,rW )rl z
type[PoolKey]rm r� r� r* )r� r, r� r� r� r ):�256__future__r � functools�logging�typingr� �typesr � urllib.parser � _collectionsr r �_request_methodsr �257connectionr258 �connectionpoolr r r
�259exceptionsr r r r r� r �util.connectionr �260util.proxyr �261util.retryr � util.timeoutr �util.urlr r �
TYPE_CHECKING�ssl�typing_extensionsr �__all__� getLoggerrP r� r� rk �262NamedTupler* rr �partialr� r� r r r rO rW rX �<module>r s �� "� � �
� � � � ?� ,� #� S� S�� � '� 1� 7� � !� $� ����&�263;�� ����!��
� � � �$ �f� � � $ �N4 � �4 �/D�4 � �4 �x
� � � 5�w� ?�
�
�
� 6��
@�� �264 #5�?R�S� �U=�.� U=�p265OE�;� OE�d-rW