o

�h�H�@s~dd
lZdd
l
Z
dd
lZ
dd
lZdd
lZdd
lZddlmZ
ddlm	Z	m
Z
mZ
ddlm
Z
ddlmZmZmZmZ
ddlmZ
ddlmZ
ddlmZ
dd	lmZmZmZmZmZmZ
dd
l m!Z!
z
ddlm"Z"m#Z#
Wne$y}


ddlm"Z"m#Z#
Yn
wz#e�%��
ej&de'd
�
ddl(m)Z*
Wd
�
n1s�w



Y
Wne$y�


ddlm*Z*
Yn
wzddlm+Z+
Wne$y�


d
Z+Yn
wdd
l,Z-ddl.m/Z/m0Z0m1Z1m2Z2m3Z3
ddl4m5Z5m
Z
m6Z6m7Z7m8Z8m9Z9mZmZ
e1�
e�:e;�
Z<dZ=dZ>e
j?�@e
j?�AeB�
d�ZCzddlDmEZE
Wne$�
y


dd�ZEYn
wdd�ZF	
d'dd�
ZGdd�ZHdd �ZId!d"�ZJGd#d$�d$�ZKGd%d&�d&�ZLd
S)(�N)
�	b64encode)�PoolManager�Timeout�proxy_from_url)
�ConnectTimeoutError)�LocationParseError�NewConnectionError�
ProtocolError�
ProxyError)
�ReadTimeoutError)
�SSLError)
�Retry)�OP_NO_COMPRESSION�PROTOCOL_TLS�OP_NO_SSLv2�OP_NO_SSLv3�is_ipaddress�ssl)
�	parse_url)�OP_NO_TICKET�PROTOCOL_TLS_CLIENT�ignore)
�category)
�orig_util_SSLContext)
�
SSLContext)
�DEFAULT_CIPHERS)�
IPV6_ADDRZ_RE�ensure_bytes�filter_ssl_warnings�unquote�urlparse)�ConnectionClosedErrorr�EndpointConnectionError�HTTPClientError�InvalidProxiesConfigError�ProxyConnectionErrorrr�<�
z
cacert.pem)
�wherec
CstS�
N)
�DEFAULT_CA_BUNDLE�r+r+�G/usr/local/CyberCP/lib/python3.10/site-packages/botocore/httpsession.pyr(Xs
r(c
Cs&|d
u
r|St�}
t
�d|
���

|
S)NTzCertificate path: )r(�logger�debug)�verify�	cert_pathr+r+r,�
get_cert_path\s



r1cs
|r|tkrt
}t|�
�|r��|�

ntr��t�

|
d
ur"tjn
|
}
|d
ur:d}|tO}|tO}|t	O}|t
O}�j|O_|
tjksKtj
dkrVt�dd
�d
u
rVd�_�f
dd�}|
tjkrh|
�_|�
n|�
|
�_t�d�r�tj�d	�
}|r�tjjs�|�_�S)
z�This function is a vendored version of the same function in urllib3

    We vendor this function to ensure that the SSL contexts we construct
    always use the std lib SSLContext instead of pyopenssl.
    Nr
)����post_handshake_authTcst�d
d�du
r
d�_
dSdS)N�check_hostnameF)�getattrr6r+�
�contextr+r,�disable_check_hostname�s
�z6create_urllib3_context.<locals>.disable_check_hostname�keylog_filename�
SSLKEYLOGFILE)rrr�set_ciphersrr�
CERT_REQUIREDrrrr�options�sys�version_infor7r5�verify_mode�hasattr�os�environ�get�flags�ignore_environmentr;)�ssl_version�	cert_reqsr?�ciphersr:�
sslkeylogfiler+r8r,�create_urllib3_contextfs:	





	










rMc

Cst|t
�r|S|��d
kS)z~Ensures a boolean value if a string or boolean is provided

    For strings, the value for True/False is case insensitive
    �true)�
isinstance�bool�lower)
�valr+r+r,�ensure_boolean�s

rSc
Cs<d
}
t|�
}|j
r|�|j
|
d�}|jr|�|j|
d�}|S)z�
    Mask proxy url credentials.

    :type proxy_url: str
    :param proxy_url: The proxy url, i.e. https://username:password@proxy.com

    :return: Masked proxy url, i.e. https://***:***@proxy.com
    z***�
)r �username�replace�password)�	proxy_url�mask�
parsed_urlr+r+r,�mask_proxy_url�s	





r[c

Cst|�
p
t
t�|�
�
S)
z@Wrap urllib3's is_ipaddress to support bracketed IPv6 addresses.)rrPr�match)
�hostr+r+r,�
_is_ipaddress�sr^c@sNeZ
dZd
Zddd�
Zdd�Zdd�Zed	d
��
Zdd�Z	d
d�Z
dd�ZdS)�ProxyConfigurationa
Represents a proxy configuration dictionary and additional settings.

    This class represents a proxy configuration dictionary and provides utility
    functions to retrieve well structured proxy urls and proxy headers from the
    proxy configuration dictionary.
    NcCs(|
duri}
|duri}|
|_||_
dSr))�_proxies�_proxies_settings)�self�proxies�proxies_settingsr+r+r,�__init__�s





zProxyConfiguration.__init__cCs(t|
�
}|j
�|j�
}|r|�|�
}|S)
z6Retrieves the corresponding proxy url for a given url.)r r`rF�scheme�_fix_proxy_url)rb�urlrZ�proxyr+r+r,�
proxy_url_for�s





z ProxyConfiguration.proxy_url_forcCs2i}|�|
�
\}}|r|r|�
||�}||d
<|S)z@Retrieves the corresponding proxy headers for a given proxy url.zProxy-Authorization)�_get_auth_from_url�_construct_basic_auth)rbrX�headersrUrW�
basic_authr+r+r,�proxy_headers_for�s




z$ProxyConfiguration.proxy_headers_forc


Cs|jSr))
ra�
rbr+r+r,�settings�szProxyConfiguration.settingscCs2|
�d
�
s
|
�d�
r|
S|
�d�
rd
|
Sd|
S)N�http:zhttps:z//zhttp://)
�
startswith)rbrXr+r+r,rg�s





z!ProxyConfiguration._fix_proxy_urlcCs.|
�d
|��}t|�
d�
�
����}d|��S)N�
:�asciizBasic )r�encode�strip�decode)rbrUrW�auth_str�encoded_strr+r+r,rl
s



z(ProxyConfiguration._construct_basic_authc	Cs8t|
�
}zt
|j�
t
|j�
fWSttfy


Yd
Sw)N�NN)r rrUrW�AttributeError�	TypeError)rbrhrZr+r+r,rk
s




�z%ProxyConfiguration._get_auth_from_urlr{)�__name__�
__module__�__qualname__�__doc__rerjro�propertyrqrgrlrkr+r+r+r,r_�s

		

r_c@s�eZ
dZd
Zdddedddfdd�
Zdd�Zdd	�Zd
d�Zdd
�Z	dd�Z
dd�Zdd�Zddd�
Z
dd�Zdd�Zdd�Zdd�ZdS)�URLLib3Sessiona_A basic HTTP client that supports connection pooling and proxies.

    This class is inspired by requests.adapters.HTTPAdapter, but has been
    boiled down to meet the use cases needed by botocore. For the most part
    this classes matches the functionality of HTTPAdapter in requests v2.7.0
    (the same as our vendored version). The only major difference of note is
    that we currently do not support sending chunked requests. While requests
    v2.7.0 implemented this themselves, later version urllib3 support this
    directly via a flag to urlopen so enabling it if needed should be trivial.
    TNcCs�|
|_t
||d
�|_tjjtjjd�|_|durt}t	|t
tf�s+t|d|dd�}d|_
d|_t	|t�r:||_
nt	|t�rE|\|_
|_||_||_||_|durUg|_i|_tdi|���
�
|_|j|j_dS)N)rcrd)�http�httpsr
rT)�connect�readr+)�_verifyr_�
_proxy_config�botocore�
awsrequest�AWSHTTPConnectionPool�AWSHTTPSConnectionPool�_pool_classes_by_scheme�DEFAULT_TIMEOUTrO�int�floatr�
_cert_file�	_key_file�str�tuple�_timeout�_max_pool_connections�_socket_options�_proxy_managersr�_get_pool_manager_kwargs�_manager�pool_classes_by_scheme)rbr/rc�timeout�max_pool_connections�socket_options�client_cert�proxies_configr+r+r,re
s2


�
�
















zURLLib3Session.__init__c
Ks,|jj
}d
|�d�
i
|
�
}dd�|��D�
S)N�use_forwarding_for_https�proxy_use_forwarding_for_httpsc
Ssi|]\}
}|du
r|
|�qSr)r+)�.0�
k�
vr+r+r,�
<dictcomp>N
sz2URLLib3Session._proxies_kwargs.<locals>.<dictcomp>)r�rqrF�items)rb�kwargsrd�proxies_kwargsr+r+r,�_proxies_kwargsF
s

���zURLLib3Session._proxies_kwargsc
Ks4|j|j
|��|j|j|jd
�}|jdi|
�
�

|S)N)r��maxsize�ssl_contextr��	cert_file�key_filer+)r�r��_get_ssl_contextr�r�r��update)rb�extra_kwargs�pool_manager_kwargsr+r+r,r�P
s




�
z'URLLib3Session._get_pool_manager_kwargsc


Cst�Sr))
rMrpr+r+r,r�\
s
zURLLib3Session._get_ssl_contextcCsj|
|jv
r0|j
�|
�
}|�|
�
}|j|d
�
}|�|j|d�
�

t|
f
i|�
�
}|j|_	||j|
<|j|
S)N)
�
proxy_headers)
�proxy_ssl_context)
r�r�ro�_setup_proxy_ssl_contextr�r�r�rr�r�)rbrXr�r��proxy_manager_kwargs�
proxy_managerr+r+r,�_get_proxy_manager_
s






�

�



z!URLLib3Session._get_proxy_managercCs.t|
�
}|j
}|sd
}|jr|d|j}|S)N�
/�
?)r �path�query)rbrhrZr�r+r+r,�	_path_urlo
s






zURLLib3Session._path_urlcCs6|���
d
�
r|rd|
_t|�
|
_dSd|
_d|
_dS)Nr�r>�	CERT_NONE)rQrsrJr1�ca_certs)rb�connrhr/r+r+r,�_setup_ssl_certx
s





zURLLib3Session._setup_ssl_certc
Cs�|jj
}|�d
�
}|�d�
}|dur|durdS|��}z6t|
�
}t|j�
s)d|_|du
r3|j|d�

t	|t
�rF|j|d|dd�
|WSt	|t�rP|�|�

|WSt
ttfyf
}
zt|d�
�
d}~w
w)	N�proxy_ca_bundle�proxy_client_certT)
�cafiler
rT)
�keyfile�
�error)r�rqrFr�rr^r]r6�load_verify_locationsrOr��load_cert_chainr��OSError�URLLib3SSLErrorrr$)rbrXrdr��
proxy_certr9rh�
er+r+r,r��
s,















�




��z'URLLib3Session._setup_proxy_ssl_contextcCs|r	|�|�
}|S|j
}|Sr))r�r�)rbrhrX�managerr+r+r,�_get_connection_manager�
s



�
z&URLLib3Session._get_connection_managercCsT|du
}|s|�|
�
St
|�
j}|d
ko|���dd�}|s#|
�d�
r%|
S|�|
�
S)Nr�r�Frr)r�r rfr�rFrs)rbrhrX�	has_proxy�proxy_scheme�using_https_forwarding_proxyr+r+r,�_get_request_target�
s




�

z"URLLib3Session._get_request_targetcCs |
�d
d�}t
|�
}|��dkS)NzTransfer-Encoding�schunked)rFrrQ)rbrm�transfer_encodingr+r+r,�_chunked�
s


zURLLib3Session._chunkedc
Cs&|j�
�
|j��D]}
|
�
�
q
dSr))r��clearr��values)rbr�r+r+r,�close�
s




�zURLLib3Session.closecCs�
zd|j�
|
j�
}|�|
j|�}|�|
j�
}|�||
j|j�
ttj	�
d
d��
r2t|
j�
j}||j
d<|�|
j|�}|j|
j||
j|
jtd�
ddd|�|
j�
d�	}tj�|
j|j|j|�}|
jsb|j
|WStyw
}	
zt|
j|	d��
d}	~	w
ttjfy�
}	
zt |
j|	d��
d}	~	w
t!y�
}	
zt"t#|�
|	d��
d}	~	w
t$y�
}	
zt%|
j|	d��
d}	~	w
t&y�
}	
zt'|
j|	d��
d}	~	w
t(y�
}	
zt)|	|
|
jd��
d}	~	w
t*y�
}	
zd	}
t+j,|
d
d�
t-|	d�
�
d}	~	w
w)
N�(BOTO_EXPERIMENTAL__ADD_PROXY_HOST_HEADER�r]F)	�methodrh�bodyrm�retries�assert_same_host�preload_content�decode_content�chunked)�endpoint_urlr�)rXr�)r��requestr�z4Exception received when sending urllib3 HTTP requestT)
�exc_infor�).r�rjrhr��connection_from_urlr�r�rSrDrErFr �hostnamer�r��urlopenr�r�rmr
r�r�r��AWSResponse�status�
stream_output�contentr�rr�socket�gaierrorr"r
r%r[�URLLib3ConnectTimeoutErrorr�URLLib3ReadTimeoutErrorrr	r!�	Exceptionr-r.r#)rbr�rXr�r�r]�request_target�urllib_response�
http_responser��messager+r+r,�send�
sv






�












�



�

�

�


��
�

�


��



��zURLLib3Session.sendr))r~rr�r��MAX_POOL_CONNECTIONSrer�r�r�r�r�r�r�r�r�r�r�r�r+r+r+r,r�
s,








�'
	
r�)NNNN)M�loggingrD�os.pathr�r@�warnings�base64r�urllib3rrr�urllib3.exceptionsrr�rrr	r
rr�rr��urllib3.util.retryr
�urllib3.util.ssl_rrrrrr�urllib3.util.urlrrr�ImportError�catch_warnings�simplefilter�DeprecationWarning�urllib3.contrib.pyopensslrrr�botocore.awsrequestr��botocore.compatrrrrr �botocore.exceptionsr!r"r#r$r%�	getLoggerr~r-r�r�r��join�dirname�__file__r*�certifir(r1rMrSr[r^r_r�r+r+r+r,�<module>
sn








 


�

��
�

�
(






�
�P;