o 'hY@sddlmZddlZddlZddlZddlZddlmZddlm Z ddl m Z m Z ddl mZddlmZdd lmZmZmZdd lmZmZmZmZdd lmZdd lmZdd lmZddl m!Z!ddl"m#Z#ddl$m%Z%m&Z&ej'rddl(Z(ddl)m*Z*gdZ+e,e-Z.dZ/dZ0Gdddej1Z2d)ddZ3e4e3e2e4e3e2dZ5eedZ6Gdd d eZ7Gd!d"d"e7Z8d*d'd(Z9dS)+) annotationsN) TracebackType)urljoin)HTTPHeaderDictRecentlyUsedContainer)RequestMethods) ProxyConfig)HTTPConnectionPoolHTTPSConnectionPoolport_by_scheme)LocationValueError MaxRetryErrorProxySchemeUnknownURLSchemeUnknown)BaseHTTPResponse)_TYPE_SOCKET_OPTIONS)connection_requires_http_tunnel)Retry)Timeout)Url parse_url)Self) PoolManager ProxyManagerproxy_from_url) key_file cert_file cert_reqsca_certs ca_cert_data ssl_versionssl_minimum_versionssl_maximum_version ca_cert_dir ssl_context key_passwordserver_hostnamei@c@seZdZUdZded<ded<ded<ded<d ed <d ed <d ed<ded<ded<ded<ded<ded<ded<ded<ded<ded<ded<ded<ded<d ed!<d"ed#<d ed$<d%ed&<d'ed(<d ed)<d*ed+<ded,<ded-<ded.<d/S)0PoolKeyz All known keyword arguments that could be provided to the pool manager, its pools, or the underlying connections. All custom key schemes should include the fields in this key at a minimum. str key_schemekey_host int | Nonekey_portzTimeout | float | int | None key_timeoutzRetry | bool | int | None key_retriesz bool | None key_blockztuple[str, int] | Nonekey_source_address str | None key_key_filekey_key_password key_cert_file key_cert_reqs key_ca_certszstr | bytes | Nonekey_ca_cert_datazint | str | Nonekey_ssl_versionzssl.TLSVersion | Nonekey_ssl_minimum_versionkey_ssl_maximum_versionkey_ca_cert_dirssl.SSLContext | Nonekey_ssl_context key_maxsizez!frozenset[tuple[str, str]] | None key_headers Url | None key__proxykey__proxy_headersProxyConfig | Nonekey__proxy_configz_TYPE_SOCKET_OPTIONS | Nonekey_socket_optionskey__socks_optionszbool | str | Nonekey_assert_hostnamekey_assert_fingerprintkey_server_hostname key_blocksizeN)__name__ __module__ __qualname____doc____annotations__rQrQO/var/www/html/olx_land/venv/lib/python3.10/site-packages/urllib3/poolmanager.pyr(8s>  r( key_class type[PoolKey]request_contextdict[str, typing.Any]returncCs|}|d|d<|d|d<dD]}||vr,||dur,t||||<q|d}|dur %s) rrXrrrrrYrrZrurlopen request_uriget_redirect_locationrstatusr_prepare_for_method_changerc isinstancerfrom_intremove_headers_on_redirect is_same_hostr_r`rg incrementrraise_on_redirect drain_connloginfo) rrrrrrconnrredirect_locationr new_headersheaderrQrQrRrs`              zPoolManager.urlopen)rtN)rurvrZrwrxryrWrz)rWr)rrrrrrrWrr{) rXr)rYr)rrvrUrrWr )rWrzNrpN rYr2rr,rXr2rrrWr )rUrVrWr )rr(rUrVrWr )rr)rrrWr )rrrWrV)rrrWrT rr)rr)rrrryrWr)rLrMrNrOrrrPrsr}rrrrrrrrrrr __classcell__rQrQrrRrs0  !    &     rcsheZdZdZ       d/d0fdd Z   d1d2fd"d# Z d3d4d&d'Z (d5d6fd-d. ZZS)7ra> 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. :param proxy_assert_hostname: The hostname of the certificate to verify against. :param proxy_assert_fingerprint: The fingerprint of the certificate to verify against. Example: .. code-block:: python import urllib3 proxy = urllib3.ProxyManager("https://localhost:3128/") resp1 = proxy.request("GET", "https://google.com/") resp2 = proxy.request("GET", "https://httpbin.org/") print(len(proxy.pools)) # 1 resp3 = proxy.request("GET", "https://httpbin.org/") resp4 = proxy.request("GET", "https://twitter.com/") print(len(proxy.pools)) # 3 rtNF proxy_urlr)rurvrZrw proxy_headersproxy_ssl_contextr=use_forwarding_for_httpsrproxy_assert_hostname"None | str | typing.Literal[False]proxy_assert_fingerprintr2rxryrWrzc  st|tr|jd|jd|j} n|} t| } | jdvr#t| j| js3t| jd} | j | d} | |_ |p9i|_ ||_ t |||||_|j | d<|j | d<|j| d<tj||fi| dS) Nz://:ror)r_proxyr[ _proxy_config)rr rXrYrrrr rc_replacerrrrr rsr|r}) rrrurZrrrrrrx str_proxy_urlrrrrrQrRr}#s,        zProxyManager.__init__rprYrr,rXrrr cs<|dkrtj||||dStj|jj|jj|jj|dS)Nrq)r)r|rrrrYrrX)rrYrrXrrrQrRrLsz!ProxyManager.connection_from_hostrtyping.Mapping[str, str]cCs0ddi}t|j}|r||d<|r|||S)z Sets headers needed by proxies: specifically, the Accept and Host headers. Only sets headers not provided by the user. Acceptz*/*Host)rnetlocupdate)rrrZheaders_rrQrQrR_set_proxy_headers\s  zProxyManager._set_proxy_headersTrrrrc sRt|}t|j|j|js|d|j}||||d<tj ||fd|i|S)z@Same as HTTP(S)ConnectionPool.urlopen, ``url`` must be absolute.rZr) rrrrrsrXrcrZrr|r)rrrrrrrZrrQrRrms zProxyManager.urlopen)rtNNNFNN)rr)rurvrZrwrrwrr=rrrrrr2rxryrWrzrrr{)rr)rZrwrWrrr) rLrMrNrOr}rrrrrQrQrrRrs$9, rrr)rrycKstdd|i|S)NrrQ)r)rrrQrQrRr|sr)rSrTrUrVrWr()rr)rryrWr): __future__r functoolsloggingtypingrtypesr urllib.parser _collectionsrr_request_methodsr connectionr connectionpoolr r r exceptionsr rrrrrutil.connectionr util.proxyr util.retryr util.timeoutrutil.urlrr TYPE_CHECKINGssltyping_extensionsr__all__ getLoggerrLrrri NamedTupler(rnpartialrrrrrrQrQrQrRsJ             ' <  L