File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/common/__pycache__/base.cpython-310.pyc
Back
o ;j�� � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZm Z m Z m Z m Z d dl Z d dlmZmZ d dlmZmZmZmZ d dlmZ d dlmZ d dlmZm Z d dl m Z g d �Z d Z d Z!G d d � d �Z"G d d� dej#�Z#G dd� d�Z$G dd� de$�Z%G dd� de$�Z&G dd� de$�Z'G dd� d�Z(G dd� de(�Z)G dd � d e(�Z*G d d � d e(�Z+G d d � d e+�Z,G d!d"� d"e*�Z-G d#d$� d$�Z.dS )%� N)�Any�Dict�Type�Union�Optional)�LibcloudConnection�HttpLibResponseProxy)�ET�httplib�urlparse� urlencode)�lowercase_keys)�Retry)� LibcloudError�MalformedResponseError)�exception_from_message) �RETRY_FAILED_HTTP_REQUESTS� BaseDriver� Connection�PollingConnection� ConnectionKey�ConnectionUserAndKey�CertificateConnection�Response� HTTPResponse� JsonResponse� XmlResponse� RawResponseFc @ s( e Zd ZdZedd� �Zedd� �ZdS )� LazyObjectz6An object that doesn't get initialized until accessed.c s G � ��fdd�d� �}|� S )Nc s8 e Zd ZdZdd� Zdd� Zdd� Z� ��fdd �ZdS ) z LazyObject._proxy.<locals>.ProxyNc S s d S �N� ��selfr r �H/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/common/base.py�__init__C s z)LazyObject._proxy.<locals>.Proxy.__init__c S s t �| d�� }t||�S �N� _get_lazy_obj)�object�__getattribute__�getattr)r" �attr�lazy_objr r r# r( G s z1LazyObject._proxy.<locals>.Proxy.__getattribute__c S s t �| d�� }t|||� d S r% )r' r( �setattr)r" r* �valuer+ r r r# � __setattr__K s z,LazyObject._proxy.<locals>.Proxy.__setattr__c s4 t �| d�}|d u r� �i ���}t �| d|� |S )N� _lazy_obj)r' r( r. )r" r+ ��cls�lazy_init_args�lazy_init_kwargsr r# r& O s z.LazyObject._proxy.<locals>.Proxy._get_lazy_obj)�__name__� __module__� __qualname__r/ r$ r( r. r& r r0 r r# �Proxy@ s r7 r )r1 r2 r3 r7 r r0 r# �_proxy> s zLazyObject._proxyc O s | j |i |��S )z;Create a lazily instantiated instance of the subclass, cls.)r8 r0 r r r# �lazyX s zLazyObject.lazyN)r4 r5 r6 �__doc__� classmethodr8 r9 r r r r# r ; s r c @ s e Zd Zddd�ZdS )r Nc C s2 | j d u rdS | jdkr| �� dS tj�| |�S )N� �HEAD)�fp�_method�closer r �read)r" �amtr r r# rA d s zHTTPResponse.readr )r4 r5 r6 rA r r r r# r ^ s r c @ sN e Zd ZdZejZi ZdZdZ dZ dZ dZ dd� Z dd� Zdd � Zd d � ZdS ) r z/ A base Response class to derive from. NFc C s� || _ tt|j��| _|j| _|j| _|j| _|j | _ |j dur+t |j d�r+|j � � nd| _ | �� s=t| j| �� | jd��| �� | _dS )z� :param response: HTTP response object. (optional) :type response: :class:`httplib.HTTPResponse` :param connection: Parent connection object. :type connection: :class:`.Connection` N�stripr< )�code�message�headers)� connectionr �dictrF �reason�error� status_code�status�request� iter_content�text�hasattrrC �body�successr � parse_error� parse_bodyr' )r" �responserG r r r# r$ � s ���zResponse.__init__c C s | j dur| j S dS )z� Parse response body. Override in a provider's subclass. :return: Parsed body. :rtype: ``str`` Nr< �rQ r! r r r# rT � s zResponse.parse_bodyc C s | j S )z� Parse the error messages. Override in a provider's subclass. :return: Parsed error. :rtype: ``str`` rV r! r r r# rS � s zResponse.parse_errorc C �* ddl }| j|jj|jjtjtjtjfv S �z� Determine if our request was successful. The meaning of this can be arbitrary; did we receive OK status? Did the node get created? Were we authenticated? :rtype: ``bool`` :return: ``True`` or ``False`` r N� �requestsrL Zcodes�ok�createdr �OK�CREATED�ACCEPTED�r" rZ r r r# rR � � �zResponse.success)r4 r5 r6 r: r r] rL rF rQ r' rJ rG �parse_zero_length_bodyr$ rT rS rR r r r r# r o s r c @ � e Zd ZdZdd� ZeZdS )r z4 A Base JSON Response class to derive from. c C sP t | j�dkr | js | jS z t�| j�}W |S ty' td| j| jjd��w )Nr zFailed to parse JSON�rQ �driver) �lenrQ rb �json�loads� Exceptionr rG re �r" rQ r r r# rT � s � ��zJsonResponse.parse_bodyN�r4 r5 r6 r: rT rS r r r r# r � s r c @ rc )r z3 A Base XML Response class to derive from. c C s| t | j�dkr | js | jS z z t�| j�}W W |S ty, t�| j�d��}Y W |S w ty= td| j| j j d��w )Nr zutf-8zFailed to parse XMLrd ) rf rQ rb r ZXML� ValueError�encoderi r rG re rj r r r# rT � s �� ��zXmlResponse.parse_bodyNrk r r r r# r � s r c @ sB e Zd Zd dd�Zdd� Zedd� �Zedd � �Zed d � �ZdS ) r Nc C st d| _ d| _i | _d| _d| _|| _|dur.tt|j��| _|j | _ |j | _ |j | _ |j| _| �� s8| �� dS dS )zm :param connection: Parent connection object. :type connection: :class:`.Connection` N)Z_status� _response�_headers�_error�_reasonrG r rH rF rI rJ rK rL rM rN rR rS )r" rG rU r r r# r$ � s �zRawResponse.__init__c C rW rX rY r` r r r# rR ra zRawResponse.successc C s2 | j s| jj�� }t|�| _ | �� s| �� | j S r )rn rG � getresponser rR rS �r" rU r r r# rU % s zRawResponse.responsec C s | j jS r )rU rQ r! r r r# rQ . s zRawResponse.bodyc C s | j s| jj| _ | j S r )rq rU rI r! r r r# rI 4 s zRawResponse.reasonr ) r4 r5 r6 r$ rR �propertyrU rQ rI r r r r# r � s r c @ s e Zd ZdZeZeZeZ e Z dZ dZ dZdZdZdZdZdZdZdZdZ d0dd �Zd d � Zd d � Zdd� Zdd� Zd1dd�Z dd� Z dd� Z d2dd�Z de d e!d e"e e#f d e d e$d e$d!e%eef fd"d#�Z&d$d%� Z'd&d'� Z(d(d)� Z)d*d+� Z*d,d-� Z+d.d/� Z,dS )3r z1 A Base Connection class to derive from. Nz 127.0.0.1� � FTc C s� |rdpd| _ g | _i | _| js|std��d| _|r || _|d ur&|| _n | j dkr/d| _nd| _|rA| �|�\| _| _| _ | _|pE| j | _ || _ || _ || _ d S )Nrv r z7Non https connections are not allowed (use secure=True)r< ru �P ) �secure�ua�context�allow_insecurerl � request_path�host�port�_tuple_from_url�timeout� retry_delay�backoff� proxy_url) r" rx r} r~ �urlr� r� r� r� r r r# r$ R s0 � zConnection.__init__c C s || _ | jj|d� dS )a Set a HTTP / HTTPS proxy which will be used with this connection. :param proxy_url: Proxy URL (e.g. http://<hostname>:<port> without authentication and <scheme>://<username>:<password>@<hostname>:<port> for basic auth authentication information. :type proxy_url: ``str`` )r� N)r� rG �set_http_proxy)r" r� r r r# r� � s zConnection.set_http_proxyc C s t |t�s td��|| _d S )Nz context needs to be a dictionary)� isinstancerH � TypeErrorrz )r" rz r r r# � set_context� s zConnection.set_contextc C s i | _ d S r )rz r! r r r# � reset_context� s zConnection.reset_contextc C s� d}d }t � |�\}}}}}} |dvrtd�||���|dkr!d}d|v r0|�d�\}}t|�}|s;|dkr9d}nd}|} t|�}| |||fS ) Nrv )�http�httpsz Invalid scheme: {} in url {}r� r �:rw ru )r r �format�rsplit�int) r" r� rx r~ �scheme�netlocr| �param�query�fragmentr} r r r# r � s" zConnection._tuple_from_urlc K sP d}| j }t| dd�r |du r | �t| d��\}}}}n|dur*| �|�\}}}}n |p.| j}|p3| j}t|�}t|d�sD|�d|i� t|d�sP|�d|i� t|d�s]|�d| j i� t|d�sqt| d�rq|�dt| d�i� t|d�s�t| d�r�|�dt| d�i� | jr�|�d| ji� | j r�|�d | j i� | j d i |��}|| _ dS ) a Establish a connection with the API server. :type host: ``str`` :param host: Optional host to override our default :type port: ``int`` :param port: Optional port to override our default :returns: A connection N�base_urlr} r~ rx �key_file� cert_filer� r� r ) rx r) r r} r~ r� rP �updater� r� � conn_classrG )r" r} r~ r� �kwargsrG rx r| r r r# �connect� s2 zConnection.connectc C sF d� dd� | jD ��}| jrd�tj| jj|�}|S d�tj|�}|S )N� c S s g | ]}d | �qS )z(%s)r )�.0�xr r r# � <listcomp>� s z*Connection._user_agent.<locals>.<listcomp>zlibcloud/{} ({}) {}zlibcloud/{} {})�joinry re r� �libcloud� __version__�name)r" Zuser_agent_suffixZ user_agentr r r# � _user_agent� s ��zConnection._user_agentc C s | j �|� dS )z� Append a token to a user agent string. Users of the library should call this to uniquely identify their requests to a provider. :type token: ``str`` :param token: Token to add to the user agent. N)ry �append)r" �tokenr r r# �user_agent_append� s z Connection.user_agent_append�GETc C s� |du ri }nt � |�}|du ri }nt � |�}tj�dd�p t} | dur'| } | �|�}|| _|| _|| _| � |�}| j rG|dkrG| j |d�}| � |�}|� d| �� i� |� ddi� t| j�} | d vrr|� d d | j| f i� n|� d | ji� |r�| �|�}| �||�\}}|r�d |v r�d �|t|dd�f�} nd �|t|dd�f�} n|} | jdu r�| �� | j} | r�| j| j| j| j d�}|| j�} | | |||||d�S )a< Request a given `action`. Basically a wrapper around the connection object's `request` that does some helpful pre-processing. :type action: ``str`` :param action: A path. This can include arguments. If included, any extra parameters are appended to the existing ones. :type params: ``dict`` :param params: Optional mapping of additional parameters to send. If None, leave as an empty ``dict``. :type data: ``unicode`` :param data: A body of data to send with the request. :type headers: ``dict`` :param headers: Extra headers to add to the request None, leave as an empty ``dict``. :type method: ``str`` :param method: An HTTP method such as "GET" or "POST". :type raw: ``bool`` :param raw: True to perform a "raw" request aka only send the headers and use the rawResponseCls class. This is used with storage API when uploading a file. :type stream: ``bool`` :param stream: True to return an iterator in Response.iter_content and allow streaming of the response data (for downloading large files) :param retry_failed: True if failed requests should be retried. This argument can override module level constant and environment variable value on per-request basis. :return: An :class:`Response` instance. :rtype: :class:`Response` instance NZ#LIBCLOUD_RETRY_FAILED_HTTP_REQUESTSFr� )�paramsz User-AgentzAccept-Encodingz gzip,deflate)rw ru �Hostz%s:%d�?�&T)�doseq)r� r� r� )r� �method�raw�streamrF �data) �copy�os�environ�getr �morph_action_hook�actionr� r� �add_default_params� cache_busting� _add_cache_busting_to_params�add_default_headersr� r� r� r~ r} � encode_data�pre_connect_hookr� r rG r� �_retryable_request�retryClsr� r� r� )r" r� r� r� rF r� r� r� rg Z retry_failedZ retry_enabledr~ r� Zrequest_to_be_executedZ retry_requestr r r# rM sX 6 � � �zConnection.requestr� r� rF r� r� r� �returnc C s4 z#| j d usJ �|r| j j||||||d� n | j j|||||d� W nI tjyU } z%t|�}t|dd �} | dkrK| jj} d|| | j f } t�| ��| � � |�d }~w t j yl } z | � � t � t|���d }~ww |r{| j } | | j �� d�} n | j} | | j �� d�} z| di | ��}W | � � |S | � � w )N)r� r� rQ rF r� r� )r� r� rQ rF r� �errno���zl%s. Perhaps "host" Connection class attribute (%s.connection) is set to an invalid, non-hostname value (%s)?)rG rU r )rG Zprepared_requestrM �socket�gaierror�strr) � __class__r4 r} r� �ssl�SSLError�rawResponseClsrr � responseCls)r" r� r� rF r� r� r� �erE r� � class_name�msgr� r� rU r r r# r� � sV � �� �� ��� �z Connection._retryable_requestc C sH t r| j| S t�| j�d��d�d |�d��}|�d�s"d| S |S )as Here we strip any duplicated leading or trailing slashes to prevent typos and other issues where some APIs don't correctly handle double slashes. Keep in mind that in some situations, "/" is a valid path name so we have a module flag which disables this behavior (https://github.com/apache/libcloud/issues/1529). �/)�ALLOW_PATH_DOUBLE_SLASHESr| r �urljoin�lstrip�rstrip� startswith)r" r� r� r r r# r� � s $ z Connection.morph_action_hookc C � |S )z� Adds default parameters (such as API key, version, etc.) to the passed `params` Should return a dictionary. r )r" r� r r r# r� � � z Connection.add_default_paramsc C r� )z� Adds default headers (such as Authorization, X-Foo-Bar) to the passed `headers` Should return a dictionary. r )r" rF r r r# r� � r� z Connection.add_default_headersc C s ||fS )aK A hook which is called before connecting to the remote server. This hook can perform a final manipulation on the params, headers and url parameters. :type params: ``dict`` :param params: Request parameters. :type headers: ``dict`` :param headers: Request headers. r )r" r� rF r r r# r� � s zConnection.pre_connect_hookc C r� )zO Encode body data. Override in a provider's subclass. r )r" r� r r r# r� s zConnection.encode_datac C s> t �t�d���d�}t|t�r||d< |S |�d|f� |S )a( Add cache busting parameter to the query parameters of a GET request. Parameters are only added if "cache_busting" class attribute is set to True. Note: This should only be used with *naughty* providers which use excessive caching of responses. � �asciiz cache-busting)�binascii�hexlifyr� �urandom�decoder� rH r� )r" r� Zcache_busting_valuer r r# r� s �z'Connection._add_cache_busting_to_params�TNNNNNNN)NNN)NNNr� FFNN)-r4 r5 r6 r: r r� r r� r r� r r� rG r} r~ r� rx re r� r� r� r� r{ r$ r� r� r� r r� r� r� rM r� �bytesr r �boolr r� r� r� r� r� r� r� r r r r# r ; s� �. 9 � �� ���� �A r c @ sD e Zd ZdZdZdZdZ ddd�Z dd d �Zd d � Z d d� Z dS )r z� Connection class which can also work with the async APIs. After initial requests, this class periodically polls for jobs status and waits until the job has finished. If job doesn't finish in timeout seconds, an Exception thrown. g �?�� rM Nr� c C s� t | | j�}| j||||||d�}|di |��} | j| ||d�}t�� | j } d} t�� | k rN| sN|di |��} | j| d�} | sFt�| j� t�� | k rN| r1| sWt d| j ��| S )a� Perform an 'async' request to the specified path. Keep in mind that this function is *blocking* and 'async' in this case means that the hit URL only returns a job ID which is the periodically polled until the job has completed. This function works like this: - Perform a request to the specified path. Response should contain a 'job_id'. - Returned 'job_id' is then used to construct a URL which is used for retrieving job status. Constructed URL is then periodically polled until the response indicates that the job has completed or the timeout of 'self.timeout' seconds has been reached. :type action: ``str`` :param action: A path :type params: ``dict`` :param params: Optional mapping of additional parameters to send. If None, leave as an empty ``dict``. :type data: ``unicode`` :param data: A body of data to send with the request. :type headers: ``dict`` :param headers: Extra headers to add to the request None, leave as an empty ``dict``. :type method: ``str`` :param method: An HTTP method such as "GET" or "POST". :type context: ``dict`` :param context: Context dictionary which is passed to the functions which construct initial and poll URL. :return: An :class:`Response` instance. :rtype: :class:`Response` instance )r� r� r� rF r� rz )rU rz �request_kwargsF)rU z"Job did not complete in %s secondsNr ) r) �request_method�get_request_kwargs�get_poll_request_kwargs�timer� � has_completed�sleep� poll_intervalr ) r" r� r� r� rF r� rz rM r� rU �endZ completedr r r# � async_request* s0 ,�� �z PollingConnection.async_requestc C s |||||d�}|S )zh Arguments which are passed to the initial request() call inside async_request. )r� r� r� rF r� r )r" r� r� r� rF r� rz r� r r r# r� q s �z$PollingConnection.get_request_kwargsc C � t d��)a� Return keyword arguments which are passed to the request() method when polling for the job status. :param response: Response object returned by poll request. :type response: :class:`HTTPResponse` :param request_kwargs: Kwargs previously used to initiate the poll request. :type response: ``dict`` :return ``dict`` Keyword arguments z'get_poll_request_kwargs not implemented��NotImplementedError)r" rU rz r� r r r# r� � s z)PollingConnection.get_poll_request_kwargsc C r� )z� Return job completion status. :param response: Response object returned by poll request. :type response: :class:`HTTPResponse` :return ``bool`` True if the job has completed, False otherwise. z has_completed not implementedr� rs r r r# r� � s z PollingConnection.has_completed)NNNr� N) r4 r5 r6 r: r� r� r� r� r� r� r� r r r r# r s �H � r c �2 e Zd ZdZ d� fdd� Z� ZS )r zH Base connection class which accepts a single ``key`` argument. TNc s& t � j|||||||| d� || _dS )zk Initialize `user_id` and `key`; set `secure` to an ``int`` based on passed value. )rx r} r~ r� r� r� r� r� N)�superr$ �key) r" r� rx r} r~ r� r� r� r� r� �r� r r# r$ � s � zConnectionKey.__init__r� �r4 r5 r6 r: r$ � __classcell__r r r� r# r � � �r c r� )r zN Base connection class which accepts a single ``cert_file`` argument. TNc s& t � j||||||| |d� || _dS �zc Initialize `cert_file`; set `secure` to an ``int`` based on passed value. �rx r} r~ r� r� r� r� r� N)r� r$ r� ) r" r� rx r} r~ r� r� r� r� r� r� r r# r$ � s � z CertificateConnection.__init__r� r� r r r� r# r � r� r c s8 e Zd ZdZdZ d� fdd� Z� ZS )�KeyCertificateConnectionz_ Base connection class which accepts both ``key_file`` and ``cert_file`` argument. NTc s( t � j||||||| | |d� || _dS r� )r� r$ r� ) r" r� r� rx r} r~ r� r� r� r� r� Zca_certr� r r# r$ � s � z!KeyCertificateConnection.__init__) TNNNNNNNN)r4 r5 r6 r: r� r$ r� r r r� r# r� � s �r� c s6 e Zd ZdZdZ d� fdd� Z� ZS )r zQ Base connection class which accepts a ``user_id`` and ``key`` argument. NTc s( t � j||||||| | |d� || _d S )Nr� )r� r$ �user_id) r" r� r� rx r} r~ r� r� r� r� r� r� r r# r$ s � z ConnectionUserAndKey.__init__r� )r4 r5 r6 r: r� r$ r� r r r� r# r s �r c @ s2 e Zd ZdZeZ ddd�Zdd� ZdS ) r zF Base driver class from which other classes can inherit from. NTc K s� || _ || _|| _|| _|| _| �� } | �|�dd�|�dd�|�dd�|�dd�d�� | j g} | jdur<| �| j� | �|� | �dd�pH|}|durR| �|� |dur[| �|� | j | i | ��| _ | | j _ | j � � dS )a� :param key: API key or username to be used (required) :type key: ``str`` :param secret: Secret password to be used (required) :type secret: ``str`` :param secure: Whether to use HTTPS or HTTP. Note: Some providers only support HTTPS, and it is on by default. :type secure: ``bool`` :param host: Override hostname used for connections. :type host: ``str`` :param port: Override port used for connections. :type port: ``int`` :param api_version: Optional API version. Only used by drivers which support multiple API versions. :type api_version: ``str`` :param region: Optional driver region. Only used by drivers which support multiple regions. :type region: ``str`` :rtype: ``None`` r� Nr� r� r� )r� r� r� r� r} ) r� �secretrx � api_version�region�_ex_connection_class_kwargsr� �popr� � connectionClsrG re r� ) r" r� r� rx r} r~ r� r� r� Z conn_kwargs�argsr r r# r$ 4 s2 ' �� zBaseDriver.__init__c C s i S )zy Return extra connection keyword arguments which are passed to the Connection class constructor. r r! r r r# r� ~ s z&BaseDriver._ex_connection_class_kwargs)NTNNNN)r4 r5 r6 r: r r� r$ r� r r r r# r - s � Jr )/r� r� r� rg r� r� r� �typingr r r r r r� Z libcloud.httpr r Zlibcloud.utils.py3r r r r Zlibcloud.utils.miscr Zlibcloud.utils.retryr Zlibcloud.common.typesr r Zlibcloud.common.exceptionsr �__all__r r� r r r r r r r r r r r� r r r r r r# �<module> sF #_A e "#)"
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings