File: //proc/self/root/lib/python3.6/site-packages/botocore/__pycache__/httpsession.cpython-36.pyc
3
�T_�, � @ s� d dl Zd dlZd dlZd dlmZ d dlmZmZm Z m
Z
d dl m Z d dl
mZmZmZmZmZ d dlmZ d dlmZ d dlmZ d d lmZmZm Z yd d
l m Z W n e k
r� d d l
m Z Y nX d dl!Z"d d l#m$Z$ d d
l%m&Z& d dl'm(Z(m)Z) d dl*m+Z+m,Z,m-Z-mZm.Z.mZmZ e(� ej/e0�Z1dZ2dZ3ej4j5ej4j6e7�d�Z8yd dl9m:Z: W n e k
�r~ dd� Z:Y nX dd� Z;d dd�Z<G dd� de=�Z>G d d � d e=�Z?dS ) � N)� b64encode)� PoolManager� ProxyManager�proxy_from_url�Timeout)�Retry)�ssl� OP_NO_SSLv2� OP_NO_SSLv3�OP_NO_COMPRESSION�DEFAULT_CIPHERS)�SSLError)�ReadTimeoutError)�ConnectTimeoutError)�NewConnectionError�
ProtocolError�
ProxyError)�orig_util_SSLContext)�
SSLContext)�six)�unquote)�filter_ssl_warnings�urlparse)�ConnectionClosedError�EndpointConnectionError�HTTPClientErrorr �ProxyConnectionErrorr r
�< �
z
cacert.pem)�wherec C s t S )N)�DEFAULT_CA_BUNDLE� r! r! �!/usr/lib/python3.6/httpsession.pyr ' s r c C s | dk r | S t � S )NT)r )�verifyr! r! r" �
get_cert_path+ s r$ c C s� t | p
tj�}|dkr tjn|}|dkrDd}|tO }|tO }|tO }| j|O _t|dd�rl|j |pht
� ||_ t|dd�dk r�d|_ |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 Zsupports_set_ciphersT�check_hostnameF)
r r ZPROTOCOL_SSLv23�
CERT_REQUIREDr r
r �options�getattrZ set_ciphersr Z verify_moder% )Z ssl_version� cert_reqsr' Zciphers�contextr! r! r" �create_urllib3_context2 s r+ c @ sB e Zd ZdZddd�Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dS )�ProxyConfigurationz�Represents a proxy configuration dictionary.
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 kr i }|| _ d S )N)�_proxies)�self�proxiesr! r! r" �__init__^ s zProxyConfiguration.__init__c C s( t |�}| jj|j�}|r$| j|�}|S )z7Retrieves the corresponding proxy url for a given url. )r r- �get�scheme�_fix_proxy_url)r. �url�
parsed_url�proxyr! r! r" �
proxy_url_forc s
z ProxyConfiguration.proxy_url_forc C s2 i }| j |�\}}|r.|r.| j||�}||d< |S )zARetrieves the corresponding proxy headers for a given proxy url. zProxy-Authorization)�_get_auth_from_url�_construct_basic_auth)r. � proxy_url�headers�username�passwordZ
basic_authr! r! r" �proxy_headers_fork s z$ProxyConfiguration.proxy_headers_forc C s6 |j d�s|j d�r|S |j d�r*d| S d| S d S )Nzhttp:zhttps:z//zhttp://)�
startswith)r. r: r! r! r" r3 t s
z!ProxyConfiguration._fix_proxy_urlc C s, dj ||�}t|jd��j� j� }dj |�S )Nz{0}:{1}�asciiz Basic {0})�formatr �encode�strip�decode)r. r< r= Zauth_strZ encoded_strr! r! r" r9 | s z(ProxyConfiguration._construct_basic_authc C s: t |�}yt|j�t|j�fS ttfk
r4 dS X d S )N)NN)r r r< r= �AttributeError� TypeError)r. r4 r5 r! r! r" r8 � s
z%ProxyConfiguration._get_auth_from_url)N)
�__name__�
__module__� __qualname__�__doc__r0 r7 r> r3 r9 r8 r! r! r! r" r, W s
r, c @ sp e Zd ZdZdddeddfdd�Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
ddd�Z dd� Z dd� Z
dd� 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 kr2t}t |t
t f�sTt |d |d d�}d | _
d | _t |t�rr|| _
nt |t�r�|\| _
| _|| _|| _|| _|d kr�g | _i | _tf | j� �| _| j| j_d S )N)r/ )Zhttp�httpsr � )Zconnect�read)�_verifyr, �
_proxy_config�botocore�
awsrequestZAWSHTTPConnectionPoolZAWSHTTPSConnectionPool�_pool_classes_by_scheme�DEFAULT_TIMEOUT�
isinstance�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_certr! r! r" r0 � s,
zURLLib3Session.__init__c K s2 d| j | j| j� | j| j| jd�}|jf |� |S )NT)�strictrc �maxsizeZ ssl_contextrd Z cert_fileZkey_file)r\ r] �_get_ssl_contextr^ rX rY �update)r. Z extra_kwargsZpool_manager_kwargsr! r! r" r` � s
z'URLLib3Session._get_pool_manager_kwargsc C s t � S )N)r+ )r. r! r! r" rg � s z URLLib3Session._get_ssl_contextc C sJ || j kr@| jj|�}| j|d�}t|f|�}| j|_|| j |< | j | S )N)�
proxy_headers)r_ rP r> r` r rS rb )r. r: ri Zproxy_manager_kwargsZ
proxy_managerr! r! r" �_get_proxy_manager� s
z!URLLib3Session._get_proxy_managerc C s. t |�}|j}|sd}|jr*|d |j }|S )N�/�?)r �pathZquery)r. r4 r5 rm r! r! r" � _path_url� s zURLLib3Session._path_urlc C s4 |j � jd�r$|r$d|_t|�|_n d|_d |_d S )NrL r& Z CERT_NONE)�lowerr? r) r$ Zca_certs)r. �connr4 r# r! r! r" �_setup_ssl_cert� s
z URLLib3Session._setup_ssl_certc C s |r| j |�}n| j}|S )N)rj ra )r. r4 r: �managerr! r! r" �_get_connection_manager� s z&URLLib3Session._get_connection_managerc C s |r|j d�r|S | j|�S d S )Nzhttp:)r? rn )r. r4 r: r! r! r" �_get_request_target� s z"URLLib3Session._get_request_targetc C s |j dd�dkS )NzTransfer-Encoding� �chunked)r1 )r. r; r! r! r" �_chunked� s zURLLib3Session._chunkedc
C s y�| j j|j�}| j|j|�}|j|j�}| j||j| j� | j|j|�}|j|j ||j
|j t d�ddd| j
|j �d� }tjj|j|j|j |�}|js�|j |S tk
r� } zt|j|d��W Y d d }~X �n8 ttjfk
�r } zt|j|d��W Y d d }~X �n tk
�r6 } zt||d��W Y d d }~X n� t k
�rf } zt |j|d��W Y d d }~X n� t k
�r� } zt |j|d��W Y d d }~X nr t k
�r� } zt!|||jd��W Y d d }~X n@ t"k
�r } z"d} t#j$| dd� t%|d ��W Y d d }~X nX d S )
NF) �methodr4 �bodyr; ZretriesZassert_same_hostZpreload_contentZdecode_contentrv )� endpoint_url�error)r: r{ )r{ �requestrz z4Exception received when sending urllib3 HTTP requestT)�exc_info)r{ )&rP r7 r4 rs Zconnection_from_urlrq rO rt Zurlopenrx ry r; r rw rQ rR Z AWSResponseZstatusZ
stream_outputZcontent�URLLib3SSLErrorr
r �socketZgaierrorr r r �URLLib3ConnectTimeoutErrorr �URLLib3ReadTimeoutErrorr r r � Exception�logger�debugr )
r. r| r: rr rp Zrequest_targetZurllib_responseZ
http_response�e�messager! r! r" �send� sV zURLLib3Session.send)N)rG rH rI rJ �MAX_POOL_CONNECTIONSr0 r` rg rj rn rq rs rt rw r� r! r! r! r" rK � s
rK )NNNN)@Zos.path�osZloggingr �base64r Zurllib3r r r r Zurllib3.util.retryr Zurllib3.util.ssl_r r r
r r Zurllib3.exceptionsr
r~ r r� r r� r r r Zurllib3.contrib.pyopensslr r � ImportErrorZbotocore.awsrequestrQ Zbotocore.vendoredr Z(botocore.vendored.six.moves.urllib_parser Zbotocore.compatr r Zbotocore.exceptionsr r r r Z getLoggerrG r� rT r� rm �join�dirname�__file__r Zcertifir r$ r+ �objectr, rK r! r! r! r" �<module> sB $
$2