File: //opt/saltstack/salt/lib/python3.10/site-packages/libcloud/__pycache__/http.cpython-310.pyc
o
;j>( � @ s� d Z ddlZddlZddlmZ ddlZddlmZ zddl m
Z
W n e y1 ddl m
Z
Y nw ddgZ
dZd ZG d
d � d e�ZG d d� d�ZG d
d� de�ZG dd� d�ZdS )z|
Subclass for httplib.HTTPSConnection with optional certificate name
verification, depending on libcloud.security settings.
� N)� HTTPAdapter)�urlparse)� PoolManager�LibcloudBaseConnection�LibcloudConnection� �< c s& e Zd Z� fdd�Zddd�Z� ZS )�SignedHTTPSAdapterc s || _ || _t� �� d S �N)� cert_file�key_file�super�__init__��selfr r �� __class__� �A/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/http.pyr . s zSignedHTTPSAdapter.__init__Fc C s t |||| j| jd�| _d S )N)Z num_pools�maxsize�blockr r )r r r Z poolmanager)r Z connectionsr r r r r �init_poolmanager3 s �z#SignedHTTPSAdapter.init_poolmanager)F)�__name__�
__module__� __qualname__r r �
__classcell__r r r r r - s r c @ sb e Zd ZdZdZdZdZdZdZdZ dZ
dZ dd� Z dd� Z
dd � Zd
d � Zd d
� Zddd�ZdS )r zk
Base connection class to inherit from.
Note: This class should not be instantiated directly.
NFc C s t �� | _d S r
)�requestsZSession�session�r r r r r Q � z LibcloudBaseConnection.__init__c C sj | j |d�}|d }|d }|d }|d }|d }|| _|| _|| _|| _|| _d| _||d�| j_d S )
a�
Set a HTTP proxy which will be used with this connection.
This will override any proxy environment variables.
:param proxy_url: Proxy URL (e.g. http://<hostname>:<port> without
authentication and
http://<username>:<password>@<hostname>:<port> for
basic auth authentication information.
:type proxy_url: ``str``
�� proxy_urlr r � � � T��http�httpsN) �_parse_proxy_url� proxy_scheme�
proxy_host�
proxy_port�proxy_username�proxy_password�http_proxy_usedr Zproxies)r r! �result�scheme�host�port�username�passwordr r r �set_http_proxyT s �z%LibcloudBaseConnection.set_http_proxyc C s� t � |�}|jdvrtd��|jr|jstd��|j}|j|j}}|j}d|v rK|�dd�d }|�dd�}t|�dk rAtd ��|d |d } }
nd
} d
}
|||| |
fS ) z�
Parse and validate a proxy URL.
:param proxy_url: Proxy URL (e.g. http://hostname:3128)
:type proxy_url: ``str``
:rtype: ``tuple`` (``scheme``, ``hostname``, ``port``)
r% z)Only http and https proxies are supportedzOproxy_url must be in the following format: <scheme>://<proxy host>:<proxy port>�@r r �:r" zURL is in an invalid formatN)r r0 �
ValueError�hostnamer2 �netloc�split�len) r r! �parsedr) r* r+ r: Zusername_passwordr; r, r- r r r r( s s&
� z'LibcloudBaseConnection._parse_proxy_urlc C s t jj| _d S r
)�libcloud�securityZVERIFY_SSL_CERT�verifyr r r r �
_setup_verify� r z$LibcloudBaseConnection._setup_verifyc K sP |� dtjj�}| jdu rd S t|t�r#d}t�|t � |d | _
d S || _
d S )N�ca_certFz�Providing a list of CA trusts is no longer supported since libcloud 2.0. Using the first element in the list. See http://libcloud.readthedocs.io/en/latest/other/changes_in_2_0.html#providing-a-list-of-ca-trusts-is-no-longer-supportedr ) �getr> r? Z
CA_CERTS_PATHr@ �
isinstance�list�warnings�warn�DeprecationWarningrB )r �kwargsZ
ca_certs_path�msgr r r �_setup_ca_cert� s
�
z%LibcloudBaseConnection._setup_ca_certc C s | j �dt||�� dS )z\
Setup request signing by mounting a signing
adapter to the session
zhttps://N)r Zmountr r r r r �_setup_signing� s z%LibcloudBaseConnection._setup_signing)NN)r r r �__doc__r r) r* r+ r, r- r. rB r r5 r( rA rK rL r r r r r = s &c @ s� e Zd ZdZdZdZddd�Zedd� �Zd dd�Z d d d
�Z
d d � Z d
d� Z edd� �Z
edd� �Zdd� Zdd� Zdd� Zdd� ZdS ) r Nc K s� |d ur|rdnd}d� |dkrdn|||dvr d� |�nd�| _|�dd �}| �� | �� t�| � |�d t�| j_ d
|v sDd |v rL| j
d
i |�� |rV| j |d � d S d S )Nr' r& z {}://{}{}� )�P rN z:{}� r! �timeoutr r r r ) �formatr1 �poprA rK r r �DEFAULT_REQUEST_TIMEOUTr rQ rL r5 )r r1 r2 ZsecurerI r0 r! r r r r � s �
�zLibcloudConnection.__init__c C s | j dur| j S | jS )zN
The option for SSL verification given to underlying requests
N)rB r@ r r r r � verification� s z LibcloudConnection.verificationFc C sH t �| j|�}| j|d�}| jj|�� |||t|| j| jj |d� | _
d S )N��headers) �method�url�datarW Zallow_redirects�streamr@ rQ �hooks) r �urljoinr1 �_normalize_headersr �request�lower�ALLOW_REDIRECTSrU rQ �response)r rX rY �bodyrW �rawr[ r\ r r r r_ � s �zLibcloudConnection.requestc C s` | j |d�}tj|d�| j|g�||d�}| j�|�}| jj||| jd ur(| jn| j d�| _
d S )NrV rP )rZ rW )r[ r@ ) r^ r �Request�joinr1 r Zprepare_request�sendrB r@ rb ) r rX rY rc rW rd r[ �reqZpreppedr r r �prepared_request� s �z#LibcloudConnection.prepared_requestc C s | j S r
)rb r r r r � getresponse� s z LibcloudConnection.getresponsec C s d| j jv r | j jd= | j jS )Nzcontent-encoding)rb rW r r r r �
getheaders� s
z LibcloudConnection.getheadersc C � | j jS r
)rb � status_coder r r r �status � zLibcloudConnection.statusc C s | j jdkrd S | j jS )Ni� )rb rm �textr r r r �reason s zLibcloudConnection.reasonc C s d S r
r r r r r �connect s zLibcloudConnection.connectc C rl r
)rb �contentr r r r �read � zLibcloudConnection.readc C s | j �� d S r
)rb �closer r r r rv s zLibcloudConnection.closec C s8 |pi }|� � D ]\}}t|ttf�rt|�||< q|S r
)�itemsrD �int�float�str)r rW �key�valuer r r r^ s �z%LibcloudConnection._normalize_headersr
)NNFFN)NNFF)r r r rQ r1 rb r �propertyrU r_ ri rj rk rn rq rr rt rv r^ r r r r r � s&
c @ sd e Zd ZdZdd� Zddd�Zddd�Zd d
� Zed d � �Z ed
d� �Z
edd� �Z edd� �Z dS )�HttpLibResponseProxyz}
Provides a proxy pattern around the :class:`requests.Response`
object to a :class:`httplib.HTTPResponse` object
c C s
|| _ d S r
)� _response)r rb r r r r ' s
z HttpLibResponseProxy.__init__Nc C rl r
)r rp )r �amtr r r rt * ru zHttpLibResponseProxy.readc C s || j j�� v r| j j| S |S )zi
Get the contents of the header name, or default
if there is no matching header.
)r rW �keys)r �name�defaultr r r � getheader- s z HttpLibResponseProxy.getheaderc C s t | jj�� �S )z:
Return a list of (header, value) tuples.
)rE r rW rw r r r r rk 7 s z HttpLibResponseProxy.getheadersc C rl r
)r rm r r r r rn = ro zHttpLibResponseProxy.statusc C rl r
)r rq r r r r rq A ro zHttpLibResponseProxy.reasonc C s dS )NZ11r r r r r �versionE s z HttpLibResponseProxy.versionc C rl r
)r rs r r r r rc J s zHttpLibResponseProxy.bodyr
)
r r r rM r rt r� rk r} rn rq r� rc r r r r r~ ! s
r~ )rM rF r Zrequests.adaptersr Zlibcloud.securityr> Zlibcloud.utils.py3r Zurllib3.poolmanagerr � ImportErrorZ%requests.packages.urllib3.poolmanager�__all__ra rT r r r r~ r r r r �<module> s$ �{i