Ë
|
ñúhN ã óÄ d dl mZ d dlZd dlZd dlZddlmZmZ ddlm Z m
|
Z
|
m Z ddl m Z mZmZmZmZ ddlmZ ddlmZ dd lmZ dd
|
lmZ dd lmZ dd l m Z g d ¢Z ej> e « Z!dZ"dZ# ejH de#« Z%dZ& ejH de&« Z'd Z( ejR e(e%« ejR e(e%« dZ*e e
|
dZ+ G d de« Z, G d de,« Z-d Z.y)é )Úabsolute_importNé )ÚHTTPHeaderDictÚRecentlyUsedContainer)ÚHTTPConnectionPoolÚHTTPSConnectionPoolÚport_by_scheme)ÚLocationValueErrorÚ MaxRetryErrorÚProxySchemeUnknownÚProxySchemeUnsupportedÚURLSchemeUnknown)Úsix)Úurljoin)ÚRequestMethods)Ú connection_requires_http_tunnel)ÚRetry)Ú parse_url)Ú PoolManagerÚ ProxyManagerÚproxy_from_url) Úkey_fileÚ cert_fileÚ cert_reqsÚca_certsÚ ssl_versionÚ ca_cert_dirÚ ssl_contextÚ key_passwordÚserver_hostname)Ú
|
key_schemeÚkey_hostÚkey_portÚ key_timeoutÚ key_retriesÚ
|
key_strictÚ key_blockÚkey_source_addressÚ key_key_fileÚkey_key_passwordÚ key_cert_fileÚ key_cert_reqsÚ key_ca_certsÚkey_ssl_versionÚkey_ca_cert_dirÚkey_ssl_contextÚ key_maxsizeÚ key_headersÚ
|
key__proxyÚkey__proxy_headersÚkey__proxy_configÚkey_socket_optionsÚkey__socks_optionsÚkey_assert_hostnameÚkey_assert_fingerprintÚkey_server_hostnameÚPoolKey)r Úuse_forwarding_for_httpsÚ ProxyConfigc óÎ |j « }|d j « |d< |d j « |d< dD ], }||v s|| t || j « « ||< . |j d« }|t |« |d< t |j « « D ] }|j |« |d|z < | j D ] }||vsd||< | di |¤S )a÷
|
Create a pool key out of a request context dictionary.
|
|
According to RFC 3986, both the scheme and host are case-insensitive.
|
Therefore, this function normalizes both before constructing the pool
|
key for an HTTPS request. If you wish to change this behaviour, provide
|
alternate callables to ``key_fn_by_scheme``.
|
|
:param key_class:
|
The class to use when constructing the key. This should be a namedtuple
|
with the ``scheme`` and ``host`` keys at a minimum.
|
:type key_class: namedtuple
|
:param request_context:
|
A dictionary-like object that contain the context for a request.
|
:type request_context: dict
|
|
:return: A namedtuple that can be used as a connection pool key.
|
:rtype: PoolKey
|
ÚschemeÚhost)ÚheadersÚ_proxy_headersÚ_socks_optionsNÚsocket_optionsÚkey_© )
|
ÚcopyÚlowerÚ frozensetÚitemsÚgetÚtupleÚlistÚkeysÚpopÚ_fields)Ú key_classÚrequest_contextÚcontextÚkeyÚ socket_optsÚfields úRH:\Change_password\venv_build\Lib\site-packages\pip/_vendor/urllib3/poolmanager.pyÚ_default_key_normalizerrX O s ð* ×"Ñ"Ó$GØ Ñ)×/Ñ/Ó1GHÑØ fo×+Ñ+Ó-GFOð ?ò ;Ø '>g clÑ 6Ü$ W¨S¡\×%7Ñ%7Ó%9Ó:GCLð;ð ++Ð .Ó/KØÐ Ü$)¨+Ó$6Ð Ñ!ô GLLNÓ#ò 1Ø '§ ¡ ¨CÓ 0 Ò ð1ð ×"Ñ"ò "Ø Ò Ø !GENð"ñ Ñ wÑ Ð ó ©ÚhttpÚhttpsc ór e Zd ZdZdZdZddZd Zd ZddZ d Z
|
ddZ d Z dd
|
Z dd Zd Zd Zd ZddZy)r a$
|
Allows for arbitrary requests while transparently keeping track of
|
necessary connection pools for you.
|
|
:param num_pools:
|
Number of connection pools to cache before discarding the least
|
recently used pool.
|
|
:param headers:
|
Headers to include with all requests, unless other headers are given
|
explicitly.
|
|
:param \**connection_pool_kw:
|
Additional parameters are used to create fresh
|
:class:`urllib3.connectionpool.ConnectionPool` instances.
|
|
Example::
|
|
>>> manager = PoolManager(num_pools=2)
|
>>> r = manager.request('GET', 'http://google.com/')
|
>>> r = manager.request('GET', 'http://google.com/mail')
|
>>> r = manager.request('GET', 'http://yahoo.com/')
|
>>> len(manager.pools)
|
2
|
|
Nc ó¦ t j | |« || _ t |« | _ t
|
| _ t j « | _ y ©N)r Ú__init__Úconnection_pool_kwr ÚpoolsÚpool_classes_by_schemeÚkey_fn_by_schemerG )ÚselfÚ num_poolsrA ra s rW r` zPoolManager.__init__« sA Ü× Ñ gÔ.Ø"4Ô Ü*¨9Ó5
|
ô '=Ô#Ü 0× 5Ñ 5Ó 7Õ rY c ó | S r_ rF ©re s rW Ú __enter__zPoolManager.__enter__µ s Ø rY c ó$ | j « y)NF)Úclear)re Úexc_typeÚexc_valÚexc_tbs rW Ú__exit__zPoolManager.__exit__¸ s Ø
|
|
àrY c óâ | j | }|| j j « }dD ] }|j |d« |dk( r t D ] }|j |d« |||fi |¤S )aÎ
|
Create a new :class:`urllib3.connectionpool.ConnectionPool` based on host, port, scheme, and
|
any additional pool keyword arguments.
|
|
If ``request_context`` is provided, it is provided as keyword arguments
|
to the pool class used. This method is used to actually create the
|
connection pools handed out by :meth:`connection_from_url` and
|
companion methods. It is intended to be overridden for customization.
|
N)r? r@ Úportr[ )rc ra rG rO Ú SSL_KEYWORDS)re r? r@ rq rR Úpool_clsrT Úkws rW Ú _new_poolzPoolManager._new_pool½ s ð ×.Ñ.¨vÑ6Ø Ð "Ø "× 5Ñ 5× :Ñ :Ó <Oð .ò +CØ × Ñ TÕ *ð +ð VÒ Ü"ò .Ø ×#Ñ# B¨Õ-ð .ñ dÑ6 oÑ6Ð6rY c ó8 | j j « y)z´
|
Empty our store of pools and direct them all to close.
|
|
This will not affect in-flight connections, but they will not be
|
re-used after completion.
|
N)rb rk rh s rW rk zPoolManager.clearØ s ð
|
|
×ÑÕrY c óØ |s t d« | j |« }|xs d|d< |s't j |d j « d« }||d< ||d< | j |« S )a¤
|
Get a :class:`urllib3.connectionpool.ConnectionPool` based on the host, port, and scheme.
|
|
If ``port`` isn't given, it will be derived from the ``scheme`` using
|
``urllib3.connectionpool.port_by_scheme``. If ``pool_kwargs`` is
|
provided, it is merged with the instance's ``connection_pool_kw``
|
variable and used to create the new connection pool, if one is
|
needed.
|
zNo host specified.r[ r? éP rq r@ )r
|
Ú_merge_pool_kwargsr rK rH Úconnection_from_context)re r@ rq r? Ú pool_kwargsrR s rW Úconnection_from_hostz PoolManager.connection_from_hostá sz ñ Ü$Ð%9Ó:Ð :à ×1Ñ1°+Ó>Ø$*Ò$4¨fÑ!ÙÜ!×%Ñ% o°hÑ&?×&EÑ&EÓ&GÈÓLDØ"&Ñ Ø"&Ñ à×+Ñ+¨OÓ<Ð<rY c ó® |d j « }| j j |« }|s t |« ||« }| j ||¬« S )zù
|
Get a :class:`urllib3.connectionpool.ConnectionPool` based on the request context.
|
|
``request_context`` must at least contain the ``scheme`` key and its
|
value must be a key in ``key_fn_by_scheme`` instance variable.
|
r? ©rR )rH rd rK r Úconnection_from_pool_key)re rR r? Úpool_key_constructorÚpool_keys rW rz z#PoolManager.connection_from_contextø s\ ð ! Ñ*×0Ñ0Ó2Ø #× 4Ñ 4× 8Ñ 8¸Ó @Ð Ù#Ü" 6Ó*Ð *Ù'¨Ó8à×,Ñ,¨XÀÐ,ÓWÐWrY c ó | j j 5 | j j |« }|r |cddd« S |d }|d }|d }| j ||||¬« }|| j |< ddd« |S # 1 sw Y S xY w)a
|
Get a :class:`urllib3.connectionpool.ConnectionPool` based on the provided pool key.
|
|
``pool_key`` should be a namedtuple that only contains immutable
|
objects. At a minimum it must have the ``scheme``, ``host``, and
|
``port`` fields.
|
Nr? r@ rq r~ )rb ÚlockrK ru )re r rR Úpoolr? r@ rq s rW r z$PoolManager.connection_from_pool_key s ð ZZ__ñ (ð ::>> (Ó+DÙØ÷ (ñ (ð % XÑ.FØ" 6Ñ*DØ" 6Ñ*DØ>> &¨$°Ào>ÓVDØ#'DJJxÑ ÷ (ð ÷ (ð ús A=Á 3A=Á=Bc ó~ t |« }| j |j |j |j |¬« S )aÖ
|
Similar to :func:`urllib3.connectionpool.connection_from_url`.
|
|
If ``pool_kwargs`` is not provided and a new pool needs to be
|
constructed, ``self.connection_pool_kw`` is used to initialize
|
the :class:`urllib3.connectionpool.ConnectionPool`. If ``pool_kwargs``
|
is provided, it is used instead. Note that if a new pool does not
|
need to be created for the request, the provided ``pool_kwargs`` are
|
not used.
|
)rq r? r{ )r r| r@ rq r? )re Úurlr{ Úus rW Úconnection_from_urlz PoolManager.connection_from_url s: ô cNØ×(Ñ(Ø FF¨¯©¸kð )ó
|
ð
|
rY c ó¤ | j j « }|r$|j « D ] \ }}| ||= |||< |S # t $ r Y !w xY w)a
|
Merge a dictionary of override values for self.connection_pool_kw.
|
|
This does not modify self.connection_pool_kw and returns a new dict.
|
Any keys in the override dictionary with a value of ``None`` are
|
removed from the merged dictionary.
|
)ra rG rJ ÚKeyError)re ÚoverrideÚbase_pool_kwargsrT Úvalues rW ry z PoolManager._merge_pool_kwargs/ sq ð ×2Ñ2×7Ñ7Ó9ÐÙ Ø &nnÓ .ò 2
|
UØ=ð Ø ,¨SÑ 1ð -2Ð$ SÒ)ð 2ð Ð øô $ò Ù ð ús ¶AÁ AÁAc ót | j yt | j | j |j « S )z³
|
Indicates if the proxy requires the complete destination URL in the
|
request. Normally this is only needed when not using an HTTP CONNECT
|
tunnel.
|
F)Úproxyr Ú proxy_configr? )re Ú
|
parsed_urls rW Ú!_proxy_requires_url_absolute_formz-PoolManager._proxy_requires_url_absolute_formC s: ð ::Ð Øä2Ø JJ×)Ñ)¨:×+<Ñ+<ó
|
ð
|
ð
|
rY c óÀ | j |dk7 ry| j j dk7 ryt j r"| j j
|
s t d« yy)z
|
Validates that were not attempting to do TLS in TLS connections on
|
Python2 or with unsupported SSL implementations.
|
Nr\ zfContacting HTTPS destinations through HTTPS proxies 'via CONNECT tunnels' is not supported in Python 2)r r? r ÚPY2r r< r )re Ú
|
url_schemes rW Ú$_validate_proxy_scheme_url_selectionz0PoolManager._validate_proxy_scheme_url_selectionP s] ð
|
::Ð ¨wÒ!6Ø à ::× Ñ Ò 'Ø ä 774×,Ñ,×EÒEÜ(ðEóð ð F7rY c ó² t |« }| j |j « | j |j |j
|
|j ¬« }d|d< d|d< d|vr | j j « |d< | j |« r |j ||fi |¤}n |j ||j fi |¤}|xr |j « }|s|S t ||« }|j dk( r&d}d|d < t |d « j « |d< |j! d
|
« } t# | t$ « st% j& | |¬ « } | j( rk|j+ |« sZt- t/ j0 |d « « }
|
|
|
D ]4 } | j3 « | j( v s |d j5 | d« 6 | j7 ||||¬ « } | |d
|
< ||d< t> jA d ||« |j= « | j ||fi |¤S # t8 $ r" | j: r|j= « |cY S w xY w)aN
|
Same as :meth:`urllib3.HTTPConnectionPool.urlopen`
|
with custom cross-host redirect logic and only sends the request-uri
|
portion of the ``url``.
|
|
The given ``url`` parameter must be absolute, such that an appropriate
|
:class:`urllib3.connectionpool.ConnectionPool` can be chosen for it.
|
)rq r? FÚassert_same_hostÚredirectrA i/ ÚGETNÚbodyÚretries)r )ÚresponseÚ_poolzRedirecting %s -> %s)!r r r? r| r@ rq rA rG r ÚurlopenÚ request_uriÚget_redirect_locationr Ústatusr Ú_prepare_for_method_changerK Ú
|
isinstancer Úfrom_intÚremove_headers_on_redirectÚ is_same_hostrM r ÚiterkeysrH rO Ú incrementr Úraise_on_redirectÚ
|
drain_connÚlogÚinfo) re Úmethodr r rt r Úconnr Úredirect_locationr rA Úheaders rW r zPoolManager.urlopena s? ô cNØ ×1Ñ1°!·(±(Ô;à×(Ñ(¨¯©°a·f±fÀQÇXÁXÐ(ÓNà!&Ð Ñ Ø :à BÑ Ø LL× -Ñ -Ó /ByMà × 1Ñ 1°!Ô 4Ø#t|| F¨CÑ6°2Ñ6Hà#t|| F¨A¯M©MÑ@¸RÑ@Hà $Ò I¨×)GÑ)GÓ)IÐÙ ØOô $ CÐ):Ó ;Ðà ??cÒ !àFà BvJÜ *¨2¨i©=Ó 9× TÑ TÓ VByMà&&Ó#Ü'¤5Ô)Ünn W°xÔ@Gð
|
× -Ò -°d×6GÑ6GØ ô7
|
ô 3<<¨¨9© Ó6Ó7GØ!ò 4Ø<<> W×%GÑ%GÒGØyM×%Ñ% f¨dÕ3ð 4ð Ø ×'Ñ'¨°¸hÈdÐ'ÓSGð 9 Ø!:ä Ð'¨Ð.?Ô@à×ÑÔ Øt||FÐ$5Ñ<¸Ñ<Ð<øô ò Ø×(Ò(Ø×#Ñ#Ô%ØØOð ús ÇH+ È+(IÉI)é
|
Nr_ ©Nr[ N©T)Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r r r` ri ro ru rk r| rz r r ry r r r rF rY rW r r sV ñð6 EØLó8òòó
|
7ò6ó=ò. Xó ó0
|
ò ò(
|
òô"D=rY r c óN e Zd ZdZ d fd Zd fd ZddZd fd Z xZS )
|
r a>
|
Behaves just like :class:`PoolManager`, but sends all requests through
|
the defined proxy, using the CONNECT method for HTTPS URLs.
|
|
:param proxy_url:
|
The URL of the proxy to be used.
|
|
:param proxy_headers:
|
A dictionary containing headers that will be sent to the proxy. In case
|
of HTTP they are being sent with each request, while in the
|
HTTPS/CONNECT case they are sent only once. Could be used for proxy
|
authentication.
|
|
:param proxy_ssl_context:
|
The proxy SSL context is used to establish the TLS connection to the
|
proxy when using HTTPS proxies.
|
|
:param use_forwarding_for_https:
|
(Defaults to False) If set to True will forward requests to the HTTPS
|
proxy to be made on behalf of the client instead of creating a TLS
|
tunnel via the CONNECT method. **Enabling this flag means that request
|
and response headers and content will be visible from the HTTPS proxy**
|
whereas tunneling keeps request and response headers and content
|
private. IP address, target hostname, SNI, and port are always visible
|
to an HTTPS proxy even when this flag is disabled.
|
|
Example:
|
>>> proxy = urllib3.ProxyManager('http://localhost:3128/')
|
>>> r1 = proxy.request('GET', 'http://google.com/')
|
>>> r2 = proxy.request('GET', 'http://httpbin.org/')
|
>>> len(proxy.pools)
|
1
|
>>> r3 = proxy.request('GET', 'https://httpbin.org/')
|
>>> r4 = proxy.request('GET', 'https://twitter.com/')
|
>>> len(proxy.pools)
|
3
|
|
c ó" t |t « r&d|j |j |j fz }t |« }|j dvrt |j « |j s2t j |j d« } |j | ¬« }|| _
|
|xs i | _ || _ t ||« | _ | j |d< | j |d< | j |d< t t | F ||fi |¤ y )Nz
|
%s://%s:%irZ rx )rq Ú_proxyrB Ú _proxy_config)r¤ r r? r@ rq r r r rK Ú_replacer Ú proxy_headersÚproxy_ssl_contextr= r Úsuperr r` ) re Ú proxy_urlrf rA r¾ r¿ r< ra r rq Ú __class__s rW r` zProxyManager.__init__Ð s ø ô iÔ!3Ô 4Ø$Ø× Ñ ØØð(ñ Iô
|
)Ó$à <<Ð 0Ñ 0Ü$ U§\¡\Ó2Ð 2àzzÜ!×%Ñ% e§l¡l°BÓ7DØNN¨NÓ-Eà
|
Ø *Ò 0¨bÔØ!2Ô Ü 'Ð(9Ð;SÓ TÔà'+§z¡zÐ8Ñ$Ø/3×/AÑ/AÐÐ+Ñ,Ø.2×.?Ñ.?Ð?Ñ+ä lDÑ*¨9°gÑTÐASÓTrY c óâ |dk( rt t | ||||¬« S t t | | j j | j j
|
| j j |¬« S )Nr\ )r{ )rÀ r r| r r@ rq r? )re r@ rq r? r{ r s rW r| z!ProxyManager.connection_from_hostõ sl ø Ø WÒ Ü tÑAØdF° ð Bó ð ô \ 4Ñ=Ø JJOOTZZ__¨d¯j©j×.?Ñ.?È[ð >ó
|
ð
|
rY c ól ddi}t |« j }|r||d< |r|j |« |S )z
|
Sets headers needed by proxies: specifically, the Accept and Host
|
headers. Only sets headers not provided by the user.
|
ÚAcceptz*/*ÚHost)r ÚnetlocÚupdate)re r rA Úheaders_rÇ s rW Ú_set_proxy_headersz ProxyManager._set_proxy_headersÿ s> ð
|
eÐ$ä3 ×&Ñ&Ù Ø %HVÑ á Ø OOGÔ $ØrY c ó t |« }t | j | j |j « s1|j d| j « }| j ||« |d< t t | * ||fd|i|¤S )z@Same as HTTP(S)ConnectionPool.urlopen, ``url`` must be absolute.rA r ) r r r r r? rK rA rÊ rÀ r r )re r® r r rt r rA r s rW r zProxyManager.urlopen sq ø ä cNÜ.¨t¯z©z¸4×;LÑ;LÈaÏhÉhÔWð ffY¨¯ © Ó5GØ × 3Ñ 3°C¸Ó AByMä\ 4Ñ0°¸ÑVÀxÐVÐSUÑVÐVrY )r² NNNFr³ r_ r´ ) rµ r¶ r· r¸ r` r| rÊ r Ú __classcell__)r s @rW r r ¨ s7 ø ñ%ðT ØØØ Ø!&õ#UõJ
|
ó ÷
|
Wñ
|
WrY r c ó t dd| i|¤S )NrÁ rF )r )r rt s rW r r s Ü Ñ , #Ð ,¨Ñ ,Ð,rY )/Ú
|
__future__r Ú collectionsÚ functoolsÚloggingÚ _collectionsr r Úconnectionpoolr r r Ú
|
exceptionsr
|
r r r r Úpackagesr Ú packages.six.moves.urllib.parser Úrequestr Ú
|
util.proxyr Ú
|
util.retryr Úutil.urlr Ú__all__Ú getLoggerrµ r¬ rr Ú _key_fieldsÚ
|
namedtupler; Ú_proxy_config_fieldsr= rX Úpartialrd rc r r r rF rY rW ú<module>rá sù ðÝ &ã Û Û ç ?ß SÑ S÷õ õ Ý 4Ý #Ý 7Ý Ý â
|
;ð g×ÑÓ!ð
|
ð ð> !+×
|
Ñ
|
¨KÓ
|
8àBÐ Ø$k×$Ñ$ ]Ð4HÓI ò. ðl I× Ñ Ð 5°wÓ ?Ø Y× Ñ Ð 6¸Ó @ñÐ ð
|
#5Ð?RÑSÐ ôY=.ô Y=ôxpW;ô pWóf-rY
|
