| Server IP : 3.96.16.70 / Your IP : 216.73.216.15 Web Server : Apache System : Linux ip-172-31-26-103.ca-central-1.compute.internal 6.1.163-186.299.amzn2023.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Feb 24 16:35:42 UTC 2026 x86_64 User : ec2-user ( 1000) PHP Version : 8.4.18 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : OFF Directory : /lib/python3.9/site-packages/awscli/botocore/__pycache__/ |
Upload File : |
a
wA�i�I � @ sf d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlmZ d dl m
Z
m Z m Z d dl
mZ d dl
mZmZmZmZ d dl
mZ d dl
mZ d d lmZ d d
lmZ d d l m Z m Z m Z m Z m!Z!m"Z" d d l#m$Z$ zd d
l m%Z%m&Z& W n$ e'�y d d
l"m%Z%m&Z& Y n0 zd dl(m)Z* W n e'�y> d dl m*Z* Y n0 zd dl m+Z+ W n e'�yh dZ+Y n0 d dl,Z-d dl.m/Z/m0Z0m1Z1m2Z2m3Z3 d dl4m5Z5mZm6Z6m7Z7m8Z8m9Z9mZmZ e1� e �:e;�Z<dZ=dZ>ej?�@d�ZAdZBeCed��r�dZBzd dlDmEZE W n e'�y dd� ZEY n0 dd � ZFd)d d �ZGd d � ZHd!d"� ZId#d$� ZJG d%d&� d&�ZKG d'd(� d(�ZLdS )*� N)� b64encode)�CancelledError)� PoolManager�Timeout�proxy_from_url)�ConnectTimeoutError)�LocationParseError�NewConnectionError�
ProtocolError�
ProxyError)�ReadTimeoutError)�SSLError)�PoolKey)�Retry)�OP_NO_COMPRESSION� PROTOCOL_TLS� OP_NO_SSLv2� OP_NO_SSLv3� is_ipaddress�ssl)� parse_url)� OP_NO_TICKET�PROTOCOL_TLS_CLIENT)�orig_util_SSLContext)�
SSLContext)�DEFAULT_CIPHERS)�
IPV6_ADDRZ_RE� ensure_bytes�filter_ssl_warnings�unquote�urlparse)�ConnectionClosedErrorr �EndpointConnectionError�HTTPClientError�InvalidProxiesConfigError�ProxyConnectionErrorr r
�< �
z /etc/pki/tls/certs/ca-bundle.crtZ
key_blocksizei )�wherec C s t S �N)�DEFAULT_CA_BUNDLE� r+ r+ �?/usr/lib/python3.9/site-packages/awscli/botocore/httpsession.pyr( \ s r( c C s& | dur | S t � }t�d|� �� |S )NTzCertificate path: )r( �logger�debug)�verifyZ cert_pathr+ r+ r, �
get_cert_path` s
r0 c s | r | t krt} t| �� |r(� �|� ntr6� �t� |du rDtjn|}|du rtd}|tO }|tO }|t O }|t
O }� j |O _ |tjks�t j
dkr�t� dd�dur�d� _� fdd�}|tjkr�|� _|� n |� |� _t� d��r
tj�d �}|�r
t jj�s
|� _� 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_authTc s t � dd �d urd� _d S )N�check_hostnameF)�getattrr5 r+ ��contextr+ r, �disable_check_hostname� s �z6create_urllib3_context.<locals>.disable_check_hostname�keylog_filenameZ
SSLKEYLOGFILE)r r r Z set_ciphersr r �
CERT_REQUIREDr r r r �options�sys� version_infor6 r4 Z verify_mode�hasattr�os�environ�get�flags�ignore_environmentr: )Z ssl_version� cert_reqsr< Zciphersr9 Z
sslkeylogfiler+ r7 r, �create_urllib3_contextj sB
���
rF c C s t | t�r| S | �� dkS dS )z~Ensures a boolean value if a string or boolean is provided
For strings, the value for True/False is case insensitive
�trueN)�
isinstance�bool�lower)�valr+ r+ r, �ensure_boolean� s
rL c C s< d}t | �}|jr"| �|j|d�} |jr8| �|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 rT c C s t | �ptt�| ��S )z@Wrap urllib3's is_ipaddress to support bracketed IPv6 addresses.)r rI r �match)�hostr+ r+ r, �
_is_ipaddress� s rW c @ sN e Zd ZdZddd�Zdd� Zdd� Zed d
� �Zd d � Z d
d� Z
dd� Z dS )�ProxyConfigurationa Represents a proxy configuration dictionary and additional settings.
This class represents a proxy configuration dictionary and provides utility
functions to retreive well structured proxy urls and proxy headers from the
proxy configuration dictionary.
Nc C s( |d u r i }|d u ri }|| _ || _d S r) )�_proxies�_proxies_settings)�self�proxies�proxies_settingsr+ r+ r, �__init__� s zProxyConfiguration.__init__c C s( t |�}| j�|j�}|r$| �|�}|S )z6Retrieves the corresponding proxy url for a given url.)r rY rB �scheme�_fix_proxy_url)r[ �urlrS �proxyr+ r+ r, �
proxy_url_for� s
z ProxyConfiguration.proxy_url_forc C s2 i }| � |�\}}|r.|r.| �||�}||d< |S )z@Retrieves the corresponding proxy headers for a given proxy url.zProxy-Authorization)�_get_auth_from_url�_construct_basic_auth)r[ rQ �headersrN rP Z
basic_authr+ r+ r, �proxy_headers_for� s z$ProxyConfiguration.proxy_headers_forc C s | j S r) )rZ �r[ r+ r+ r, �settings� s zProxyConfiguration.settingsc C s6 |� d�s|� d�r|S |� d�r*d| S d| S d S )N�http:zhttps:z//zhttp://)�
startswith)r[ rQ r+ r+ r, r` s
z!ProxyConfiguration._fix_proxy_urlc C s. |� d|� �}t |�d���� �� }d|� �S )N�:�asciizBasic )r �encode�strip�decode)r[ rN rP Zauth_strZ encoded_strr+ r+ r, re
s z(ProxyConfiguration._construct_basic_authc C s< t |�}zt|j�t|j�fW S ttfy6 Y dS 0 d S )N)NN)r r rN rP �AttributeError� TypeError)r[ ra rS r+ r+ r, rd s
z%ProxyConfiguration._get_auth_from_url)NN) �__name__�
__module__� __qualname__�__doc__r^ rc rg �propertyri r` re rd r+ r+ r+ r, rX � s
rX c @ s� e Zd ZdZdddedddfdd�Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z d dd�Z
dd� Zdd� Zdd� Zd d � 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.
TNc C s� || _ t||d�| _tjjtjjd�| _|d u r4t}t |t
t f�sVt |d |d d�}d | _
d | _t |t�rt|| _
nt |t�r�|\| _
| _|| _|| _|| _|d u r�g | _i | _tf i | �� ��| _| j| j_d S )N)r\ r] )�http�httpsr rM )Zconnect�read)�_verifyrX �
_proxy_config�botocore�
awsrequestZAWSHTTPConnectionPoolZAWSHTTPSConnectionPool�_pool_classes_by_scheme�DEFAULT_TIMEOUTrH �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)r[ r/ r\ �timeoutZmax_pool_connections�socket_optionsZ client_certZproxies_configr+ r+ r, r^ # s2
��
zURLLib3Session.__init__c K s, | j j}d|�d�i|�}dd� |�� D �S )N�use_forwarding_for_httpsZ proxy_use_forwarding_for_httpsc S s i | ]\}}|d ur||�qS r) r+ )�.0�k�vr+ r+ r, �
<dictcomp>R � z2URLLib3Session._proxies_kwargs.<locals>.<dictcomp>)r} ri rB �items)r[ �kwargsr] Zproxies_kwargsr+ r+ r, �_proxies_kwargsJ s ���z URLLib3Session._proxies_kwargsc K s@ | j | j| �� | j| j| jd�}tr,t|d< |jf i |�� |S )N)r� �maxsizeZ ssl_contextr� Z cert_fileZkey_fileZ blocksize)r� r� �_get_ssl_contextr� r� r� � BUFFER_SIZE�update)r[ Z extra_kwargsZpool_manager_kwargsr+ r+ r, r� T s �z'URLLib3Session._get_pool_manager_kwargsc C s t � S r) )rF rh r+ r+ r, r� b s z URLLib3Session._get_ssl_contextc C sj || j vr`| j�|�}| �|�}| j|d�}|�| j|d�� t|fi |��}| j|_ || j |< | j | S )N)�
proxy_headers)�proxy_ssl_context)
r� r} rg �_setup_proxy_ssl_contextr� r� r� r r� r� )r[ rQ r� r� Zproxy_manager_kwargsZ
proxy_managerr+ r+ r, �_get_proxy_managere s
�
�
z!URLLib3Session._get_proxy_managerc C s. t |�}|j}|sd}|jr*|d |j }|S )N�/�?)r �path�query)r[ ra rS r� r+ r+ r, � _path_urlu s zURLLib3Session._path_urlc C s4 |� � �d�r$|r$d|_t|�|_n d|_d |_d S )Nrz r; Z CERT_NONE)rJ rk rE r0 Zca_certs)r[ �connra r/ r+ r+ r, �_setup_ssl_cert~ s
z URLLib3Session._setup_ssl_certc
C s� | j j}|�d�}|�d�}|d u r0|d u r0d S | �� }zht|�}t|j�sRd|_|d urf|j|d� t |t
�r�|j |d |d d� nt |t �r�|� |� |W S t
ttfy� } zt|d��W Y d }~n
d }~0 0 d S ) N�proxy_ca_bundleZproxy_client_certT)Zcafiler rM )Zkeyfile��error)r} ri rB r� r rW rV r5 Zload_verify_locationsrH r� Zload_cert_chainr� �OSError�URLLib3SSLErrorr r$ )r[ rQ r] r� Z
proxy_certr8 ra �er+ r+ r, r� � s&
z'URLLib3Session._setup_proxy_ssl_contextc C s |r| � |�}n| j}|S r) )r� r� )r[ ra rQ �managerr+ r+ r, �_get_connection_manager� s z&URLLib3Session._get_connection_managerc C sX |d u}|s| � |�S t|�j}|dko6| �� �dd�}|sF|�d�rJ|S | � |�S d S )Nrz r� Frj )r� r r_ r� rB rk )r[ ra rQ Z has_proxyZ proxy_schemeZ using_https_forwarding_proxyr+ r+ r, �_get_request_target� s
�z"URLLib3Session._get_request_targetc C s |� dd�}t|�}|�� dkS )NzTransfer-Encodingr� s chunked)rB r rJ )r[ rf Ztransfer_encodingr+ r+ r, �_chunked� s zURLLib3Session._chunkedc C s& | j �� | j�� D ] }|�� qd S r) )r� �clearr� �values)r[ r� r+ r+ r, �close� s
zURLLib3Session.closec C s^ z�| j �|j�}| �|j|�}|�|j�}| �||j| j� ttj �
dd��rdt |j�j }||j
d< | �|j|�}|j|j||j|jtd�ddd| �|j�d� }tj�|j|j|j|�}|js�|j |W S t� y� } z t |j| d��W Y d } ~ �ndd } ~ 0 t t j f�y8 } z t |j| d��W Y d } ~ �n*d } ~ 0 t!�yl } z t"t#|�| d��W Y d } ~ n�d } ~ 0 t$�y� } zt%|j| d��W Y d } ~ n�d } ~ 0 t&�y� } zt'|j| d��W Y d } ~ n�d } ~ 0 t(�y } z t)| ||jd��W Y d } ~ n^d } ~ 0 t*�y � Y nB t+�yX } z(d }
t,j-|
d
d � t.| d ��W Y d } ~ n
d } ~ 0 0 d S )
NZ(BOTO_EXPERIMENTAL__ADD_PROXY_HOST_HEADER� rV F) �methodra �bodyrf ZretriesZassert_same_hostZpreload_contentZdecode_contentZchunked)� endpoint_urlr� )rQ r� )r� �requestr� z4Exception received when sending urllib3 HTTP requestT)�exc_infor� )/r} rc ra r� Zconnection_from_urlr� r| rL r@ rA rB r �hostnamer� r� Zurlopenr� r� rf r r� r~ r Z AWSResponseZstatusZ
stream_outputZcontentr� r
r �socketZgaierrorr" r r% rT �URLLib3ConnectTimeoutErrorr �URLLib3ReadTimeoutErrorr r
r! r � Exceptionr- r. r# ) r[ r� rQ r� r� rV Zrequest_targetZurllib_responseZ
http_responser� �messager+ r+ r, �send� sj �
� �$$�""�zURLLib3Session.send)N)rs rt ru rv �MAX_POOL_CONNECTIONSr^ r� r� r� r� r� r� r� r� r� r� r� r� r+ r+ r+ r, rx s*
�
'
rx )NNNN)MZloggingr@ Zos.pathr� r= �base64r �concurrent.futuresr Zurllib3r r r Zurllib3.exceptionsr r� r r r
r r r� r
r� Zurllib3.poolmanagerr Zurllib3.util.retryr Zurllib3.util.ssl_r r r r r r Zurllib3.util.urlr r r � ImportErrorZurllib3.contrib.pyopensslr r r Zbotocore.awsrequestr~ Zbotocore.compatr r r r r Zbotocore.exceptionsr! r" r# r$ r% Z getLoggerrs r- r� r� r� �joinr* r� r? Zcertifir( r0 rF rL rT rW rX rx r+ r+ r+ r, �<module> sd
(
�
P ;