File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/common/__pycache__/cloudstack.cpython-310.pyc
Back
o ;j7 � @ s� d dl Z d dlZd dlZd dlZd dlmZmZmZmZ d dl m Z m Z m Z d dl mZmZ d dlmZ G dd� de �ZG dd � d e e �ZG d d � d �ZdS ) � N)�b�httplib�urlquote� urlencode)� JsonResponse�PollingConnection�ConnectionUserAndKey)� ProviderError�MalformedResponseError)�InvalidCredsErrorc @ s e Zd Zdd� ZdS )�CloudStackResponsec C sx | j tjkr td��d }| �� }t|d�r%t|�� �d }d|v r%|d }|d u r,| j}|s0d}t || j | j j d�}|�)Nz Invalid provider credentials�valuesr � errortextz7WARNING: error message text sent by provider was empty.)�valueZ http_code�driver) �statusr � UNAUTHORIZEDr Z parse_body�hasattr�listr �bodyr � connectionr )�selfr r r �error� r �N/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/common/cloudstack.py� parse_error s z CloudStackResponse.parse_errorN)�__name__� __module__� __qualname__r r r r r r s r c s� e Zd ZeZdZdZdZdZdZ dZ dd� Z dd � Z d d � Z d d � Z d� fdd� Z d dd�Zdd� Zdd� Z d dd�Z� ZS ) �CloudStackConnection� � _sync_requestiX r � c C s |rt |�}|S )z� Must of the data is sent as part of query params (eeww), but in newer versions, userdata argument can be sent as a urlencoded data in the request body. )r )r �datar r r � encode_data: s z CloudStackConnection.encode_datac C s� dd� t |�� �D �}|jdd� d� g }|D ]!}tt|d �dd�}tt|d �d d�}d �||�}|�|� qd �|�}|�� � d d�}t j t | j �t |�tjd�}t�t |�� ��S )Nc S s g | ] \}}|� � |f�qS r )�lower)�.0�k�vr r r � <listcomp>F s z8CloudStackConnection._make_signature.<locals>.<listcomp>c S s | d S )Nr r )�xr r r �<lambda>G s z6CloudStackConnection._make_signature.<locals>.<lambda>)�keyr z[])�safer z[]*z{}={}�&�+z%20)�msgZ digestmod)r �items�sortr �str�format�append�joinr% �replace�hmac�newr r, �hashlib�sha1�base64� b64encode�digest)r �params� signature�pairs�pairr, r �itemr r r �_make_signatureE s z$CloudStackConnection._make_signaturec C s | j |d< d|d< |S )NZapiKey�json�response)Zuser_id)r r? r r r �add_default_paramsV s z'CloudStackConnection.add_default_paramsc C s | � |�|d< ||fS )Nr@ )rD )r r? �headersr r r �pre_connect_hook\ s z%CloudStackConnection.pre_connect_hookN�GETc s< |rt �|�}ni }||d< t� j||||||d�}|d S )N�command)�actionr? r# rH �method�context� jobresult)�copy�deepcopy�superZ async_request) r rK rL r? r# rH rM rN �result�� __class__r r �_async_requesta s �z#CloudStackConnection._async_request� c C s |d }||||||d�}|S )NrK �rK rL r? r# rH rM r ) r rL r? r# rH rM rN rK �request_kwargsr r r �get_request_kwargs| s �z'CloudStackConnection.get_request_kwargsc C s |d }d|i}d|d�}|S )NZjobidZqueryAsyncJobResult)rK r? r )r rF rN rY Zjob_idr? �kwargsr r r �get_poll_request_kwargs� s z,CloudStackConnection.get_poll_request_kwargsc C s> |� d| j�}|| jkr|� di �� d|�}t|��|| jkS )NZ jobstatusrO r )�get� ASYNC_PENDING� ASYNC_FAILURE� Exception� ASYNC_SUCCESS)r rF r r0 r r r � has_completed� s z"CloudStackConnection.has_completedc C s� |rt �|�}ni }||d< | j| jj||||d�}|�� }|dkr*d|jvr*|}n|dkr6d|jv r6d}n|d }||jvrKtd�|�|j | jd ��|j| }|S ) z� This method handles synchronous calls which are generally fast information retrieval requests and thus return 'quickly'. rK )rL r? r# rH rM ZrevokesecuritygroupingressZ"revokesecuritygroupingressresponseZrestorevirtualmachineZrestorevmresponserF zUnknown response format {})r r ) rP rQ �requestr �pathr% �objectr r4 r )r rK rL r? r# rH rM rS r r r r! � s4 � � z"CloudStackConnection._sync_request�NNNNrJ N)NrW NrJ N�NNNNrJ )r r r r Z responseClsZ poll_intervalZrequest_method�timeoutr^ ra r_ r$ rD rG rI rV rZ r\ rb r! � __classcell__r r rT r r 0 s2 � � �r c sL e Zd ZdZdZeZd � fdd� Z d dd�Z d dd �Z � Z S ) �CloudStackDriverMixInNTc s" |p| j }t� �|||||� d S )N)�hostrR �__init__)r r, ZsecretZsecurerk �portrT r r rl � s z CloudStackDriverMixIn.__init__rJ c C s | j j||||||d�S )NrX )r r! )r rK rL r? r# rH rM r r r r! � s �z#CloudStackDriverMixIn._sync_requestc C s | j j|||||||d�S )N)rK rL r? r# rH rM rN )r rV )r rK rL r? r# rH rM rN r r r rV � s �z$CloudStackDriverMixIn._async_request)NTNNrg rf ) r r r rk rd r Z connectionClsrl r! rV ri r r rT r rj � s ��rj )rP r8 r< r: Zlibcloud.utils.py3r r r r Zlibcloud.common.baser r r Zlibcloud.common.typesr r Zlibcloud.compute.typesr r r rj r r r r �<module> s
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings