Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/common/__pycache__/cloudstack.cpython-39.pyc
Ðазад
a q�h� � @ s� d dl Z d dlZd dlZd dlZd dlmZ d dlmZ d dlmZ d dlmZ d dl m Z d dl m Z m Z d dl mZ d d l mZ d d lmZ G d d � d e�ZG d d� de e �ZG dd� de�ZdS )� N)�httplib�� urlencode)�urlquote)�b)� ProviderError)�ConnectionUserAndKey�PollingConnection)� JsonResponse)�MalformedResponseError)�InvalidCredsErrorc @ s e Zd Zdd� ZdS )�CloudStackResponsec C s| | j tjkrtd��d }| �� }t|d�rJt|�� �d }d|v rJ|d }|d u rX| j}|s`d}t || j | j j d�}|�d S )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 ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/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 � Zd� fdd� Zd dd�Zdd� Zdd� Zd dd�Z� ZS ) �CloudStackConnection� � _sync_requestiX r � c C s |r t |�}|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_dataA s z CloudStackConnection.encode_datac C s� dd� t |�� �D �}|jdd� d� g }|D ]B}tt|d �dd�}tt|d �d d�}d ||f }|�|� q.d �|�}|�� �d d�}t j t | j �t |�t jd�}t�t |�� ��S )Nc S s g | ]\}}|� � |f�qS r )�lower)�.0�k�vr r r � <listcomp>M � z8CloudStackConnection._make_signature.<locals>.<listcomp>c S s | d S )Nr r )�xr r r �<lambda>N r+ z6CloudStackConnection._make_signature.<locals>.<lambda>)�keyr z[])�safer! z[]*z%s=%s�&�+z%20)�msg� digestmod)r �items�sortr �str�append�joinr& �replace�hmac�newr r. �hashlib�sha1�base64� b64encode�digest)r �params� signature�pairs�pairr. r �itemr r r �_make_signatureL s �z$CloudStackConnection._make_signaturec C s | j |d< d|d< |S )NZapiKey�json�response)Zuser_id)r rA r r r �add_default_params^ s z'CloudStackConnection.add_default_paramsc C s | � |�|d< ||fS )NrB )rF )r rA �headersr r r �pre_connect_hookd s z%CloudStackConnection.pre_connect_hookN�GETc s@ |rt �|�}ni }||d< tt| �j||||||d�}|d S )N�command)�actionrA r$ rJ �method�context� jobresult)�copy�deepcopy�superr Z async_request) r rM rN rA r$ rJ rO rP �result�� __class__r r �_async_requesti s �z#CloudStackConnection._async_request� c C s |d }||||||d�}|S )NrM �rM rN rA r$ rJ rO r ) r rN rA r$ rJ rO rP rM �request_kwargsr r r �get_request_kwargsw s �z'CloudStackConnection.get_request_kwargsc C s |d }d|i}d|d�}|S )NZjobidZqueryAsyncJobResult)rM rA r )r rH rP r[ Zjob_idrA �kwargsr r r �get_poll_request_kwargs s z,CloudStackConnection.get_poll_request_kwargsc C s> |� d| j�}|| jkr4|� di �� d|�}t|��|| jkS )NZ jobstatusrQ r )�get� ASYNC_PENDING� ASYNC_FAILURE� Exception� ASYNC_SUCCESS)r rH r r2 r r r � has_completed� s z"CloudStackConnection.has_completedc C s� |rt �|�}ni }||d< | j| jj||||d�}|�� }|dkrTd|jvrT|}n |dkrld|jv rld}n|d }||jvr�td�|�|j | jd ��|j| }|S ) z� This method handles synchronous calls which are generally fast information retrieval requests and thus return 'quickly'. rM )rN rA r$ rJ rO ZrevokesecuritygroupingressZ"revokesecuritygroupingressresponseZrestorevirtualmachineZrestorevmresponserH zUnknown response format {})r r ) rR rS �requestr �pathr& �objectr �formatr )r rM rN rA r$ rJ rO rU r r r r" � s2 ��� � z"CloudStackConnection._sync_request)NNNNrL N)NrY NrL N)NNNNrL )r r r r Z responseCls� poll_interval�request_method�timeoutr` rc ra r% rF rI rK rX r\ r^ rd r" � __classcell__r r rV r r 7 s, � � �r c s> e Zd ZdZdZeZd � fdd� Zd dd�Zd dd �Z � Z S ) �CloudStackDriverMixInNTc s& |p| j }tt| ��|||||� d S )N)�hostrT rm �__init__)r r. �secret�securern �portrV r r ro � s �z CloudStackDriverMixIn.__init__rL c C s | j j||||||d�S )NrZ )r r" )r rM rN rA r$ rJ rO r r r r" � s �z#CloudStackDriverMixIn._sync_requestc C s | j j|||||||d�S )N)rM rN rA r$ rJ rO rP )r rX )r rM rN rA r$ rJ rO rP r r r rX � s �z$CloudStackDriverMixIn._async_request)NTNN)NNNNrL )NNNNrL N) r r r rn rf r Z connectionClsro r" rX rl r r rV r rm � s � �rm )r> r< rR r: Zlibcloud.utils.py3r r r r Zlibcloud.common.typesr Zlibcloud.common.baser r r r Zlibcloud.compute.typesr r r rg rm r r r r �<module> s ~
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка