File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/__pycache__/http.cpython-310.pyc
Back
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
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings