File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/__pycache__/cloudsigma.cpython-310.pyc
Back
o ;j�& � @ sH d Z ddlZddlZddlZddlZddlZddlmZmZ ddl m Z m Z m Z m Z ddlmZmZmZ ddlmZmZ ddlmZmZmZmZmZmZ ddl m Z m Z dd l m Z dd l!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z) zddl*Z+W n e,y� ddl+Z+Y nw g d �Z-G d d � d e�Z.G dd� de,�Z/G dd� de,�Z0G dd� de�Z1G dd� de�Z2G dd� de�Z3G dd� de.�Z4G dd� de3�Z5G d d � d e4�Z6G d d � d e3�Z7G d d!� d!e4�Z8G d"d#� d#e�Z9G d$d%� d%�Z:G d&d'� d'�Z;G d(d)� d)e�Z<G d*d+� d+�Z=G d,d-� d-�Z>G d.d/� d/e�Z?G d0d1� d1e�Z@G d2d3� d3e.�ZAdS )4z+ Drivers for CloudSigma API v1.0 and v2.0. � N)�b�httplib)�dict2str�str2list� str2dicts�get_secure_random_string)�Response� JsonResponse�ConnectionUserAndKey)� ProviderError�InvalidCredsError)�Node�KeyPair�NodeSize� NodeImage� NodeDriver�is_private_subnet)�Provider� NodeState)� parse_date)� SPECS_TO_SIZE�DEFAULT_REGION�INSTANCE_TYPES�MAX_VIRTIO_UNITS�API_ENDPOINTS_1_0�API_ENDPOINTS_2_0�DEFAULT_API_VERSION�MAX_VIRTIO_CONTROLLERS) �CloudSigmaNodeDriver�CloudSigma_1_0_NodeDriver�CloudSigma_2_0_NodeDriver�CloudSigmaError�CloudSigmaNodeSize�CloudSigmaDrive� CloudSigmaTag�CloudSigmaSubscription�CloudSigmaFirewallPolicy� CloudSigmaFirewallPolicyRulec s0 e Zd ZdZdZddddef� fdd� Z� ZS )r Z CloudSigma�http://www.cloudsigma.com/NTc s< | t u r|dkr t} n |dkrt} ntd| ��t� �| �S )Nz1.0z2.0zUnsupported API version: %s)r r r �NotImplementedError�super�__new__)�cls�key�secret�secure�host�port� api_version�kwargs�� __class__� �W/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/cloudsigma.pyr+ D s z CloudSigmaNodeDriver.__new__)�__name__� __module__� __qualname__�name�websiter r+ � __classcell__r6 r6 r4 r7 r @ s �r c @ s e Zd Zdd� Zdd� ZdS )�CloudSigmaExceptionc C s | j d S )Nr ��args��selfr6 r6 r7 �__str__Z s zCloudSigmaException.__str__c C � d| j d S )Nz<CloudSigmaException '%s'>r r? rA r6 r6 r7 �__repr___ � z CloudSigmaException.__repr__N)r8 r9 r: rC rE r6 r6 r6 r7 r> Y s r> c @ s e Zd Zdd� ZdS )�$CloudSigmaInsufficientFundsExceptionc C rD )Nz+<CloudSigmaInsufficientFundsException '%s'>r r? rA r6 r6 r7 rE f rF z-CloudSigmaInsufficientFundsException.__repr__N)r8 r9 r: rE r6 r6 r6 r7 rG e s rG c @ s e Zd Zddd�Zdd� ZdS )r" Nc C s> || _ || _|| _|| _|| _|| _|| _|| _| pi | _d S �N) �idr; �cpu�ram�disk� bandwidth�price�driver�extra) rB rI r; rJ rK rL rM rN rO rP r6 r6 r7 �__init__m s zCloudSigmaNodeSize.__init__c C s* d| j | j| j| j| j| j| j| jjf S )NzV<NodeSize: id=%s, name=%s, cpu=%s, ram=%s disk=%s bandwidth=%s price=%s driver=%s ...>�rI r; rJ rK rL rM rN rO rA r6 r6 r7 rE x s ��zCloudSigmaNodeSize.__repr__rH )r8 r9 r: rQ rE r6 r6 r6 r7 r" l s r" c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�CloudSigma_1_0_Responsec C s, | j tjkr t� �d| j kodkS S )N�� i+ )�statusr � UNAUTHORIZEDr rA r6 r6 r7 �success� s z CloudSigma_1_0_Response.successc C s | j s| j S t| j �S rH )�bodyr rA r6 r6 r7 � parse_body� s z"CloudSigma_1_0_Response.parse_bodyc C s d| j �dd��� S )Nz Error: %szerrors:� )rX �replace�striprA r6 r6 r7 � parse_error� s z#CloudSigma_1_0_Response.parse_errorN)r8 r9 r: rW rY r] r6 r6 r6 r7 rS � s rS c @ s$ e Zd Zee d ZeZdd� ZdS )�CloudSigma_1_0_Connectionr0 c C �< d|d< d|d< dt �td�| j| j����d� |d< |S �Nzapplication/jsonZAcceptz Content-TypezBasic %s�{}:{}�utf-8Z Authorization��base64� b64encoder �formatZuser_idr- �decode�rB �headersr6 r6 r7 �add_default_headers� � �z-CloudSigma_1_0_Connection.add_default_headersN) r8 r9 r: r r r0 rS � responseClsrj r6 r6 r6 r7 r^ � s r^ c s e Zd ZejZdZdZeZ dZ e j e j e j e j d�Zddddef� fdd� Zd d � Zd d � Zd8d d�Zd8dd�Zdd� Z d9dd�Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Z d$d%� Z d&d'� Z d(d)� Z d*d+� Z d,d-� Z!d.d/� Z"d0d1� Z#d2d3� Z$d4d5� Z%d6d7� Z&� Z'S ):r zCloudSigma (API v1.0)r( i� )Zactive�stoppedZdeadZdumpedNTc sL |t vr td| ��|d u| _d| | _t� jd||||||d�|�� d S )N�Invalid region: %sz cloudsigma_%s�r- r. r/ r0 r1 �regionr6 )r � ValueError�_host_argument_set�api_namer* rQ �rB r- r. r/ r0 r1 rp r3 r4 r6 r7 rQ � s � �z"CloudSigma_1_0_NodeDriver.__init__c C sL | � |j�}|j}|tjkr| �|�}nd}|s td|j ��| �|�}|S )z� Reboot a node. Because Cloudsigma API does not provide native reboot call, it's emulated using stop and start. @inherits: :class:`NodeDriver.reboot_node` T� Could not stop node with id %s)� _get_noderI �stater �RUNNING� ex_stop_noder> � ex_start_node)rB �noderw rm rW r6 r6 r7 � reboot_node� s z%CloudSigma_1_0_NodeDriver.reboot_nodec C s^ | � |j�}|j}|tjkr| �|�}nd}|s td|j ��| jjd|j dd�}|j dkS )z� Destroy a node (all the drives associated with it are NOT destroyed). If a node is still running, it's stopped before it's destroyed. @inherits: :class:`NodeDriver.destroy_node` Tru z/servers/%s/destroy�POST��action�method�� ) rv rI rw r rx ry r> � connection�requestrU )rB r{ rw rm �responser6 r6 r7 � destroy_node� s z&CloudSigma_1_0_NodeDriver.destroy_nodec C sf | j jdd�j}g }|D ]$}|�d�r0|d dkr0t|d |d | j jd|d id�}|�|� q |S ) z� Return a list of available standard images (this call might take up to 15 seconds to return). @inherits: :class:`NodeDriver.list_images` z/drives/standard/info�r �typerL �driver; �size�rI r; rO rP )r� r� �object�getr rO �append)rB �locationr� �images�value�imager6 r6 r7 � list_images s � �z%CloudSigma_1_0_NodeDriver.list_imagesc C s` g }t D ])}|d }t|d |d |d |d |d |d | j|d�| jjd�}|�|� q|S ) NrI r; rJ �memoryrL rM ��size_idrR �r r" Z_get_size_pricer� rO r� )rB r� �sizesr� r- r� r6 r6 r7 � list_sizes s � z$CloudSigma_1_0_NodeDriver.list_sizesc C s: | j jdd�j}g }|D ]}| �|�}|r|�|� q |S )Nz /servers/infor� )r� r� r� �_to_noder� )rB r� �nodes�datar{ r6 r6 r7 � list_nodes- s �z$CloudSigma_1_0_NodeDriver.list_nodes�auto�e1000�hddc C s� |dvrt d��|dvrt d| ��i }|�|d|j |d�� | jjd|j t|�dd �j} | s5t d ��| d d } | jjd | d�j} t�� } d| d v r{| jjd | d�j} t�� | } | | j k} d| d v rp| rpt d��t� d� d| d v sOi }|�||j |j | d|d�� |�|dd�� |r�|�d|d�� | jjdt|�dd �j} t | t�s�| g} | �| d �}|du r�| �| � td��| �|�}|r�tj|_|S )a� Creates a CloudSigma instance @inherits: :class:`NodeDriver.create_node` :keyword name: String with a name for this new node (required) :type name: ``str`` :keyword smp: Number of virtual processors or None to calculate based on the cpu speed. :type smp: ``int`` :keyword nic_model: e1000, rtl8139 or virtio (is not specified, e1000 is used) :type nic_model: ``str`` :keyword vnc_password: If not set, VNC access is disabled. :type vnc_password: ``bool`` :keyword drive_type: Drive type (ssd|hdd). Defaults to hdd. :type drive_type: ``str`` )r� Zrtl8139�virtiozInvalid NIC model specified)r� Zssdz2Invalid drive type "%s". Valid types are: hdd, ssdz%sG)r; r� Z driveTypez/drives/%s/cloner} �r r� r� zDrive creation failedr r� z/drives/%s/infor� ZimagingzDrive imaging timed out� �ide:0:0)r; rJ �memr� Zboot�smpr� )z nic:0:model� nic:0:dhcp)�vnc:ip� vnc:passwordz/servers/createNz(Insufficient funds, node creation failed)r> �updaterL r� r� rI r r� �time�IMAGING_TIMEOUT�sleeprJ rK � isinstance�listr� �ex_drive_destroyrG rz r rx rw )rB r; r� r� r� Z nic_model� vnc_passwordZ drive_typeZ drive_datar� � drive_uuidZ imaging_startZ elapsed_timeZ timed_outZ node_datar{ �startedr6 r6 r7 � create_node: sp !��� � �� �� z%CloudSigma_1_0_NodeDriver.create_nodec C s� | � |�}g }|�� D ]'\}}|�d�s |�d�s |�d�r2|�d�s2|�d�s2|�d�s2|�|� q | �| �|��}|s?dS |D ]}| �|� qAdS ) z� Destroy a node and all the drives associated with it. :param node: Node which should be used :type node: :class:`libcloud.compute.base.Node` :rtype: ``bool`` zide:Zscsi�blockz:bytesz :requests�mediaFT)�_get_node_info�items� startswith�endswithr� r� r� r� )rB r{ Z drive_uuidsr- r� Znode_destroyedr� r6 r6 r7 �ex_destroy_node_and_drives� s. ������ � z4CloudSigma_1_0_NodeDriver.ex_destroy_node_and_drivesc C s0 | j jddd�}|jdkrtd��t|j�}|S )zf Return a list of available static IP addresses. :rtype: ``list`` of ``str`` z/resources/ip/list�GETr~ rT zCould not retrieve IP list)r� r� rU r> r rX )rB r� �ipsr6 r6 r7 �ex_static_ip_list� s z+CloudSigma_1_0_NodeDriver.ex_static_ip_listc C � | j jddd�}t|j�}|S )zb Return a list of all the available drives. :rtype: ``list`` of ``dict`` z /drives/infor� r~ �r� r� r rX �rB r� �resultr6 r6 r7 �ex_drives_list� � z(CloudSigma_1_0_NodeDriver.ex_drives_listc C r� )zX Create a new static IP address.p :rtype: ``list`` of ``dict`` z/resources/ip/creater� r~ r� r� r6 r6 r7 �ex_static_ip_create� r� z-CloudSigma_1_0_NodeDriver.ex_static_ip_createc C � | j jd| dd�}|jdkS )z� Destroy a static IP address. :param ip_address: IP address which should be used :type ip_address: ``str`` :rtype: ``bool`` z/resources/ip/%s/destroyr� r~ r� �r� r� rU )rB � ip_addressr� r6 r6 r7 �ex_static_ip_destroy� � � z.CloudSigma_1_0_NodeDriver.ex_static_ip_destroyc C r� )z� Destroy a drive with a specified uuid. If the drive is currently mounted an exception is thrown. :param drive_uuid: Drive uuid which should be used :type drive_uuid: ``str`` :rtype: ``bool`` �/drives/%s/destroyr} r~ r� r� �rB r� r� r6 r6 r7 r� � s � z*CloudSigma_1_0_NodeDriver.ex_drive_destroyc K s� d}g }t |�� �}|D ]}d}|D ] }t�||�r d} nq|s&|�|� q |r2tdd�|� ��| jjd|j t |�dd�} | j d koI| j d kS ) aT Update a node configuration. Changing most of the parameters requires node to be stopped. :param node: Node which should be used :type node: :class:`libcloud.compute.base.Node` :param kwargs: keyword arguments :type kwargs: ``dict`` :rtype: ``bool`` )z^name$z^parent$z^cpu$z^smp$z^mem$z^boot$z ^nic:0:model$z ^nic:0:dhcpz ^nic:1:model$z ^nic:1:vlan$z ^nic:1:mac$z^vnc:ip$z^vnc:password$z^vnc:tlsz^ide:[0-1]:[0-1](:media)?$z^scsi:0:[0-7](:media)?$z^block:[0-7](:media)?$FTz'Invalid configuration key specified: %s�,z/servers/%s/setr} r� rT rZ ) r� �keys�re�matchr� r> �joinr� r� rI r rU rX ) rB r{ r3 Z valid_keysZ invalid_keysr� r- �matchesZregexr� r6 r6 r7 �ex_set_node_configuration s* � � ��z3CloudSigma_1_0_NodeDriver.ex_set_node_configurationc C � | j jd|j dd�}|jdkS )z� Start a node. :param node: Node which should be used :type node: :class:`libcloud.compute.base.Node` :rtype: ``bool`` z/servers/%s/startr} r~ rT �r� r� rI rU �rB r{ r� r6 r6 r7 rz C � z'CloudSigma_1_0_NodeDriver.ex_start_nodec C � | j |d�S )N�r{ �� stop_node�rB r{ r6 r6 r7 ry P s z&CloudSigma_1_0_NodeDriver.ex_stop_nodec C r� )z� Stop (shutdown) a node. :param node: Node which should be used :type node: :class:`libcloud.compute.base.Node` :rtype: ``bool`` z/servers/%s/stopr} r~ r� r� r� r6 r6 r7 r� W r� z#CloudSigma_1_0_NodeDriver.stop_nodec C s | � |�S )zl Stop (shutdown) a node. @inherits: :class:`CloudSigmaBaseNodeDriver.ex_stop_node` )ry r� r6 r6 r7 �ex_shutdown_noded s z*CloudSigma_1_0_NodeDriver.ex_shutdown_nodec C r� )z� Destroy a drive. :param drive_uuid: Drive uuid which should be used :type drive_uuid: ``str`` :rtype: ``bool`` r� r} r~ r� r� r� r6 r6 r7 �ex_destroy_drivem r� z*CloudSigma_1_0_NodeDriver.ex_destroy_drivec C � i }| j st| j d |d< |S �zJ Return the host value based on the user supplied region. r0 )rr r rp �rB r3 r6 r6 r7 �_ex_connection_class_kwargs| � z5CloudSigma_1_0_NodeDriver._ex_connection_class_kwargsc C s. |r�z | j |d }W n ty tj}Y nw d|vr d S g }d|v r5t|d t�r0|d }n|d g}i }g d�}|D ]0\}}||v rm|| }|dkrRt|�}n|dkrfzt|�}W n tye Y nw |�||i� q=d|v r�d|v r�|�|d |d d �� t |d |d ||d | j j |d �} | S d S ) NrU Zserverr� ))rJ �int)r� r� )r� r� )rU �strr� r� r� r� )Zvnc_ipr� r; )rI r; rw � public_ips� private_ipsrO rP ) �NODE_STATE_MAP�KeyErrorr �UNKNOWNr� r� r� rq r� r r� rO ) rB r� rw r� rP � extra_keysr- Z value_typer� r{ r6 r6 r7 r� � sR � ��� z"CloudSigma_1_0_NodeDriver._to_nodec C s. | � � }dd� |D �}|std| ��|d S )Nc S s g | ] }|j |j kr|�qS r6 �rI )�.0r{ r6 r6 r7 � <listcomp>� � z7CloudSigma_1_0_NodeDriver._get_node.<locals>.<listcomp>z Node with id %s does not existr )r� r> )rB �node_idr� r{ r6 r6 r7 rv � s z#CloudSigma_1_0_NodeDriver._get_nodec C s& | j jd|j d�}t|j�}|d S )Nz/servers/%s/infor� r )r� r� rI r rX )rB r{ r� r� r6 r6 r7 r� � s z(CloudSigma_1_0_NodeDriver._get_node_inforH )r� r� Nr� )(r8 r9 r: r Z CLOUDSIGMAr� r; r< r^ � connectionClsr� r rx Z TERMINATEDr� r rQ r| r� r� r� r� r� r� r� r� r� r� r� r� rz ry r� r� r� r� r� rv r� r= r6 r6 r4 r7 r � sV � � �i ; < r c @ � e Zd ZdZed d ZdS )�CloudSigmaZrhConnectionzM Connection class for the CloudSigma driver for the Zurich end-point Zzrhr0 N�r8 r9 r: �__doc__r r0 r6 r6 r6 r7 r� � � r� c @ � e Zd ZdZeZdZdS )�CloudSigmaZrhNodeDriverz9 CloudSigma node driver for the Zurich end-point �cloudsigma_zrhN)r8 r9 r: r� r� r� rs r6 r6 r6 r7 r� � � r� c @ r� )�CloudSigmaLvsConnectionzP Connection class for the CloudSigma driver for the Las Vegas end-point Zlvsr0 Nr� r6 r6 r6 r7 r� � r� r� c @ r� )�CloudSigmaLvsNodeDriverz< CloudSigma node driver for the Las Vegas end-point Zcloudsigma_lvsN)r8 r9 r: r� r� r� rs r6 r6 r6 r7 r� � r� r� c s e Zd ZdZ� fdd�Z� ZS )r! z* Represents CloudSigma API error. c s( t � j|||d� || _|| _|| _dS )a :param http_code: HTTP status code. :type http_code: ``int`` :param error_type: Type of error (validation / notexist / backend / permissions database / concurrency / billing / payment) :type error_type: ``str`` :param error_msg: A description of the error that occurred. :type error_msg: ``str`` :param error_point: Point at which the error occurred. Can be None. :type error_point: ``str`` or ``None`` )� http_coder� rO N)r* rQ � error_type� error_msg� error_point)rB r� r� r� r� rO r4 r6 r7 rQ � s zCloudSigmaError.__init__)r8 r9 r: r� rQ r= r6 r6 r4 r7 r! � s r! c @ s, e Zd ZdZ d dd�Zdd� Zdd� ZdS ) r% z- Represents CloudSigma subscription. Nc C s@ || _ || _|| _|| _|| _|| _|| _|| _| | _| | _ dS )aE :param id: Subscription ID. :type id: ``str`` :param resource: Resource (e.g vlan, ip, etc.). :type resource: ``str`` :param period: Subscription period. :type period: ``str`` :param status: Subscription status (active / inactive). :type status: ``str`` :param price: Subscription price. :type price: ``str`` :param start_time: Start time for this subscription. :type start_time: ``datetime.datetime`` :param end_time: End time for this subscription. :type end_time: ``datetime.datetime`` :param auto_renew: True if the subscription is auto renewed. :type auto_renew: ``bool`` :param subscribed_object: Optional UUID of the subscribed object. :type subscribed_object: ``str`` N� rI �resource�amount�periodrU rN � start_time�end_time� auto_renew�subscribed_object) rB rI r r r rU rN r r r r r6 r6 r7 rQ s ) z CloudSigmaSubscription.__init__c C � | � � S rH �rE rA r6 r6 r7 rC J � z CloudSigmaSubscription.__str__c C � d| j | j| j| j| jf S )NzQ<CloudSigmaSubscription id=%s, resource=%s, amount=%s, period=%s, object_uuid=%s>)rI r r r r rA r6 r6 r7 rE M s ��z CloudSigmaSubscription.__repr__rH �r8 r9 r: r� rQ rC rE r6 r6 r6 r7 r% s �4 r% c @ s* e Zd ZdZd dd�Zdd� Zdd� ZdS ) r$ z- Represents a CloudSigma tag object. Nc C �$ || _ || _|r || _dS g | _dS )z� :param id: Tag ID. :type id: ``str`` :param name: Tag name. :type name: ``str`` :param resource: IDs of resources which are associated with this tag. :type resources: ``list`` of ``str`` N�rI r; � resources)rB rI r; r r6 r6 r7 rQ Z � zCloudSigmaTag.__init__c C r rH r rA r6 r6 r7 rC i r zCloudSigmaTag.__str__c C s d� | j| jt| j��S )Nz,<CloudSigmaTag id={}, name={}, resources={}>)rf rI r; �reprr rA r6 r6 r7 rE l s �zCloudSigmaTag.__repr__rH r r6 r6 r6 r7 r$ U s r$ c s2 e Zd ZdZd � fdd� Zdd� Zdd� Z� ZS ) r# z( Represents a CloudSigma drive. Nc s* t � j||||d� || _|| _|| _dS )aq :param id: Drive ID. :type id: ``str`` :param name: Drive name. :type name: ``str`` :param size: Drive size (in GBs). :type size: ``float`` :param media: Drive media (cdrom / disk). :type media: ``str`` :param status: Drive status (unmounted / mounted). :type status: ``str`` r� N)r* rQ r� r� rU )rB rI r; r� r� rU rO rP r4 r6 r7 rQ y s zCloudSigmaDrive.__init__c C r rH r rA r6 r6 r7 rC � r zCloudSigmaDrive.__str__c C r )Nz<<CloudSigmaSize id=%s, name=%s size=%s, media=%s, status=%s>)rI r; r� r� rU rA r6 r6 r7 rE � s �zCloudSigmaDrive.__repr__rH )r8 r9 r: r� rQ rC rE r= r6 r6 r4 r7 r# t s r# c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) r& z2 Represents a CloudSigma firewall policy. c C r )a :param id: Policy ID. :type id: ``str`` :param name: Policy name. :type name: ``str`` :param rules: Rules associated with this policy. :type rules: ``list`` of :class:`.CloudSigmaFirewallPolicyRule` objects N�rI r; �rules)rB rI r; r r6 r6 r7 rQ � r z!CloudSigmaFirewallPolicy.__init__c C r rH r rA r6 r6 r7 rC � r z CloudSigmaFirewallPolicy.__str__c C s d| j | jt| j�f S )Nz2<CloudSigmaFirewallPolicy id=%s, name=%s rules=%s>)rI r; r r rA r6 r6 r7 rE � s �z!CloudSigmaFirewallPolicy.__repr__Nr r6 r6 r6 r7 r& � s r& c @ s6 e Zd ZdZ d dd�Zdd� Zdd� ZdS ) r' z7 Represents a CloudSigma firewall policy rule. Nc C s4 || _ || _|| _|| _|| _|| _|| _|| _dS )a� :param action: Action (drop / accept). :type action: ``str`` :param direction: Rule direction (in / out / both)> :type direction: ``str`` :param ip_proto: IP protocol (tcp / udp). :type ip_proto: ``str``. :param src_ip: Source IP in CIDR notation. :type src_ip: ``str`` :param src_port: Source port or a port range. :type src_port: ``str`` :param dst_ip: Destination IP in CIDR notation. :type dst_ip: ``str`` :param src_port: Destination port or a port range. :type src_port: ``str`` :param comment: Comment associated with the policy. :type comment: ``str`` N�r � direction�ip_proto�src_ip�src_port�dst_ip�dst_port�comment) rB r r r r r r r r r6 r6 r7 rQ � s $ z%CloudSigmaFirewallPolicyRule.__init__c C r rH r rA r6 r6 r7 rC � r z$CloudSigmaFirewallPolicyRule.__str__c C s d| j | jf S )Nz6<CloudSigmaFirewallPolicyRule action=%s, direction=%s>)r r rA r6 r6 r7 rE � s �z%CloudSigmaFirewallPolicyRule.__repr__)NNNNNNr r6 r6 r6 r7 r' � s �- r' c @ s8 e Zd ZejejejejgZdd� Z dd� Z dd� Z dS )�CloudSigma_2_0_Responsec C s | j | jv S rH )rU �success_status_codesrA r6 r6 r7 rW � � z CloudSigma_2_0_Response.successc C s< t | j�tjkr td��| �� }| j|d�}|r |d �|S )NzInvalid credentials)rX r )r� rU r rV r rY �_parse_errors_from_body)rB rX �errorsr6 r6 r7 r] s z#CloudSigma_2_0_Response.parse_errorc C sX g }t |t�s dS |D ] }d|vrq t| j|d |d |d | jjd�}|�|� q |S )z� Parse errors from the response body. :return: List of error objects. :rtype: ``list`` of :class:`.CloudSigmaError` objects Nr� Z error_messager� )r� r� r� r� rO )r� r� r! rU r� rO r� )rB rX r �item�errorr6 r6 r7 r s � z/CloudSigma_2_0_Response._parse_errors_from_bodyN) r8 r9 r: r �OK�ACCEPTED� NO_CONTENT�CREATEDr rW r] r r6 r6 r6 r7 r � s � r c sB e Zd Zee d ZeZdZdd� Z dd� Z d � fd d � Z � Z S ) �CloudSigma_2_0_Connectionr0 z/api/2.0c C r_ r` rc rh r6 r6 r7 rj 2 rk z-CloudSigma_2_0_Connection.add_default_headersc C s t �|�}|S rH )�json�dumps)rB r� r6 r6 r7 � encode_data< s z%CloudSigma_2_0_Connection.encode_dataNr� Fc s: |pi }| j | }|dkrd|d< t� j||||||d�S )Nr� r �limit)r �paramsr� ri r� �raw)� api_prefixr* r� )rB r r, r� ri r� r- r4 r6 r7 r� A s �z!CloudSigma_2_0_Connection.request)NNNr� F) r8 r9 r: r r r0 r rl r. rj r* r� r= r6 r6 r4 r7 r' - s r' c s� e Zd ZdZdZdZdZeZdZ dZ e j e j e j e je je jd�Zdd d ef� fd d � Zd�d d �Zdd� Zdd� Z d�dd�Zd�dd�Zdd� Zdd� Zd�dd �Zd d � Z d�d d �Z d!d"� Z d�d#d$�Z d�d%d&�Z d'd(� Z!d)d*� Z"d+d,� Z#d-d.� Z$d/d0� Z%d�d2d3�Z&d�d4d5�Z'd�d6d7�Z(d8d9� Z)d:d;� Z*d<d=� Z+d>d?� Z,d@dA� Z-dBdC� Z.dDdE� Z/dFdG� Z0dHdI� Z1d�dJdK�Z2d�dLdM�Z3dNdO� Z4dPdQ� Z5dRdS� Z6dTdU� Z7dVdW� Z8d�dXdY�Z9dZd[� Z:d\d]� Z;d^d_� Z<d`da� Z=dbdc� Z>ddde� Z?d�dgdh�Z@didj� ZAd�dkdl�ZBdmdn� ZCdodp� ZDdqdr� ZEdsdt� ZFdudv� ZGdwdx� ZHdydz� ZId{d|� ZJd}d~� ZKdd�� ZLd�d�� ZMd�d�� ZNd�d�� ZOd�d�� ZPd�d�� ZQd�d�d��ZRd�d�� ZSd�d�� ZTe fd�d��ZUd�d�� ZV� ZWS )�r z) Driver for CloudSigma API v2.0. zCloudSigma (API v2.0)r� r( i� � )ZstartingZstoppingZ unavailableZrunningrm ZpausedTNc sN |t vr td| ��|std��|d u| _t� jd||||||d�|�� d S )Nrn z3CloudSigma driver only supports a secure connectionro r6 )r rq rr r* rQ rt r4 r6 r7 rQ l s � �z"CloudSigma_2_0_NodeDriver.__init__c s@ |rd|j }nd}� jj|dd�j}� fdd�|d D �}|S )z� List available nodes. :param ex_tag: If specified, only return servers tagged with the provided tag. :type ex_tag: :class:`CloudSigmaTag` z/tags/%s/servers/detail/z/servers/detail/r� r~ c � g | ]}� j |d ��qS ��r� )r� �r� r! rA r6 r7 r� � � z8CloudSigma_2_0_NodeDriver.list_nodes.<locals>.<listcomp>�objects)rI r� r� r� )rB Zex_tagr r� r� r6 rA r7 r� � s z$CloudSigma_2_0_NodeDriver.list_nodesc C s` g }t D ])}|d }t|d |d |d |d |d |d | j|d�| jjd�}|�|� q|S ) z' List available sizes. rI r; rJ r� rL rM r� rR r� )rB r� r� r- r� r6 r6 r7 r� � s � z$CloudSigma_2_0_NodeDriver.list_sizesc s8 � j jdd�j}� fdd�|d D �}dd� |D �}|S )z� Return a list of available pre-installed library drives. Note: If you want to list all the available library drives (both pre-installed and installation CDs), use :meth:`ex_list_library_drives` method. � /libdrives/r� c r0 r1 )� _to_imager3 rA r6 r7 r� � r4 z9CloudSigma_2_0_NodeDriver.list_images.<locals>.<listcomp>r5 c S s g | ] }|j d dkr|�qS )� image_typeZpreinst)rP )r� r� r6 r6 r7 r� � s �r� r� r� )rB r� r� r6 rA r7 r� � s z%CloudSigma_2_0_NodeDriver.list_imagesc C sh | j |d�} |r |} ntdd�} d| } |j} | s;| j|| d�} | j| dd�} | | jkr3| j| | d�} | j| dd�} n|} i }||d < |jd |d < |jd d |d < | |d< |r]||d< |rc||d< dddidd�}|g}|r|ddd|d�}|� |� | r�d}nd}dd|| j d�} | g}||d< ||d < d }| j j |d |d �}| � |jd d! �}| j||d"� |S )#a5 Create a new server. Server creation consists multiple steps depending on the type of the image used. 1. Installation CD: 1. Create a server and attach installation cd 2. Start a server 2. Pre-installed image: 1. Clone provided library drive so we can use it 2. Resize cloned drive to the desired size 3. Create a server and attach cloned drive 4. Start a server :param ex_metadata: Key / value pairs to associate with the created node. (optional) :type ex_metadata: ``dict`` :param ex_vnc_password: Password to use for VNC access. If not provided, random password is generated. :type ex_vnc_password: ``str`` :param ex_avoid: A list of server UUIDs to avoid when starting this node. (optional) :type ex_avoid: ``list`` :param ex_vlan: Optional UUID of a VLAN network to use. If specified, server will have two nics assigned - 1 with a public ip and 1 with the provided VLAN. :type ex_vlan: ``str`` :param public_keys: Optional list of SSH key UUIDs :type public_keys: ``list`` of ``str`` )r� � )r� z%s-drive)r� r; Z unmounted)r� rw )r� r� r; �� rJ � r� r� Zpubkeys�metaNZconfZdhcp)� boot_order� ip_v4_conf� ip_v6_conf)r> r? r@ ZvlanZider� r� z0:0�r> � dev_channelZdevicer� �nics�drivesz /servers/r} �r r� r� r5 r �r{ �ex_avoid)�_is_installation_cdr rL �ex_clone_drive� _wait_for_drive_state_transitionr� �ex_resize_driverJ rK r� rI r� r� r� r� rz )rB r; r� r� Z ex_metadataZex_vnc_passwordrG Zex_vlanZ public_keysZis_installation_cdr� Z drive_name� drive_sizer� r� �nicrC Z device_typerD r r� r{ r6 r6 r7 r� � s^ 1 � �z%CloudSigma_2_0_NodeDriver.create_nodeFc C s> d|j }|du rddi}nd}| jj|d|d�}|jtjkS )z� Destroy the node and all the associated drives. :return: ``True`` on success, ``False`` otherwise. :rtype: ``bool`` � /servers/%s/TZrecurseZ all_drivesN�DELETE)r r� r, �rI r� r� rU r r% )rB r{ Zex_delete_drivesr r, r� r6 r6 r7 r� P s z&CloudSigma_2_0_NodeDriver.destroy_nodec C sv |j }|tjkr| �|�}nd}|std|j ��d}td�D ]}z | �|�}W |S ty8 t � d� Y q w |S )z� Reboot a node. Because Cloudsigma API does not provide native reboot call, it's emulated using stop and start. :param node: Node to reboot. :type node: :class:`libcloud.compute.base.Node` Tru Fr/ r� ) rw r rx r� r> rI �range� start_noder! r� r� )rB r{ rw rm rW �_r6 r6 r7 r| a s" � �z%CloudSigma_2_0_NodeDriver.reboot_nodec C s� i }|j |d< |jd |d< |jd |d< |jd |d< t�|j�dg ��}||d< |�|� d|j }| jj|d |d �j }| j |d �}|S ) a Edit a node. :param node: Node to edit. :type node: :class:`libcloud.compute.base.Node` :param params: Node parameters to update. :type params: ``dict`` :return Edited node. :rtype: :class:`libcloud.compute.base.Node` r; �cpusrJ r� r� r� rC rN �PUTrE r2 ) r; rP �copy�deepcopyr� r� rI r� r� r� r� )rB r{ r, r� rC r r� r6 r6 r7 � ex_edit_node� s z&CloudSigma_2_0_NodeDriver.ex_edit_nodec C s> i }|r d� |�|d< d|j }| j|d|dd�}|jtjkS )a� Start a node. :param node: Node to start. :type node: :class:`libcloud.compute.base.Node` :param ex_avoid: A list of other server uuids to avoid when starting this node. If provided, node will attempt to be started on a different physical infrastructure from other servers specified using this argument. (optional) :type ex_avoid: ``list`` r� �avoid�/servers/%s/action/�startr} )�pathr r, r� )r� rI �_perform_actionrU r r$ )rB r{ rG r, r\ r� r6 r6 r7 rR � s z$CloudSigma_2_0_NodeDriver.start_nodec C �& d|j }| j|ddd�}|jtjkS )NrZ �stopr} �r\ r r� �rI r] rU r r$ �rB r{ r\ r� r6 r6 r7 r� � � z#CloudSigma_2_0_NodeDriver.stop_nodec C � | j ||d�S )NrF )rR )rB r{ rG r6 r6 r7 rz � s z'CloudSigma_2_0_NodeDriver.ex_start_nodec C r� )z Stop a node. r� r� r� r6 r6 r7 ry � s z&CloudSigma_2_0_NodeDriver.ex_stop_nodec C sB i }||d< ||d< d|j }| j|dd|d�j}| j|d�}|S )a Clone the provided node. :param name: Optional name for the cloned node. :type name: ``str`` :param random_vnc_password: If True, a new random VNC password will be generated for the cloned node. Otherwise password from the cloned node will be reused. :type random_vnc_password: ``bool`` :return: Cloned node. :rtype: :class:`libcloud.compute.base.Node` r; �random_vnc_passwordrZ �cloner} �r\ r r� r� r2 )rI r] r� r� )rB r{ r; re r� r\ r� r6 r6 r7 � ex_clone_node� s z'CloudSigma_2_0_NodeDriver.ex_clone_nodec C s. d| }| j j|d�j}|du r|S | �|�S )NrN r� T)r� r� r� r� )rB r� � return_jsonr r� r6 r6 r7 � ex_get_node� s z%CloudSigma_2_0_NodeDriver.ex_get_nodec C s( d|j }| j|ddd�j}|d }|S )a Open a VNC tunnel to the provided node and return the VNC url. :param node: Node to open the VNC tunnel to. :type node: :class:`libcloud.compute.base.Node` :return: URL of the opened VNC tunnel. :rtype: ``str`` rZ Zopen_vncr} r` �vnc_url)rI r] r� )rB r{ r\ r� rk r6 r6 r7 �ex_open_vnc_tunnel� s z,CloudSigma_2_0_NodeDriver.ex_open_vnc_tunnelc C r^ )z� Close a VNC server to the provided node. :param node: Node to close the VNC tunnel to. :type node: :class:`libcloud.compute.base.Node` :return: ``True`` on success, ``False`` otherwise. :rtype: ``bool`` rZ Z close_vncr} r` ra rb r6 r6 r7 �ex_close_vnc_tunnel � z-CloudSigma_2_0_NodeDriver.ex_close_vnc_tunnelc �* � j jdd�j}� fdd�|d D �}|S )z� Return a list of all the available library drives (pre-installed and installation CDs). :rtype: ``list`` of :class:`.CloudSigmaDrive` objects r6 r� c r0 r1 �� _to_driver3 rA r6 r7 r� " r4 zDCloudSigma_2_0_NodeDriver.ex_list_library_drives.<locals>.<listcomp>r5 r9 �rB r� rD r6 rA r7 �ex_list_library_drives s z0CloudSigma_2_0_NodeDriver.ex_list_library_drivesc ro )z� Return a list of all the available user's drives. :rtype: ``list`` of :class:`.CloudSigmaDrive` objects z/drives/detail/r� c r0 r1 rp r3 rA r6 r7 r� - r4 zACloudSigma_2_0_NodeDriver.ex_list_user_drives.<locals>.<listcomp>r5 r9 rr r6 rA r7 �ex_list_user_drives& s z-CloudSigma_2_0_NodeDriver.ex_list_user_drivesc C r rH )rt rA r6 r6 r7 � list_volumes1 r z&CloudSigma_2_0_NodeDriver.list_volumesrL c C s` i }||d d d |d�}|rd� |�|d< d}| jj|d||d�j}| j|d d d �} | S ) a� Create a new drive. :param name: Drive name. :type name: ``str`` :param size: Drive size in GBs. :type size: ``int`` :param media: Drive media type (cdrom, disk). :type media: ``str`` :param ex_avoid: A list of other drive uuids to avoid when creating this drive. If provided, drive will attempt to be created on a different physical infrastructure from other drives specified using this argument. (optional) :type ex_avoid: ``list`` :return: Created drive object. :rtype: :class:`.CloudSigmaDrive` r< �r; r� r� r� rY z/drives/r} �r r� r, r� r5 r r2 )r� r� r� r� rq ) rB r; r� r� rG r, r� r r� r� r6 r6 r7 �ex_create_drive4 s ��z)CloudSigma_2_0_NodeDriver.ex_create_drivec C s | j ||||d�S )N)r; r� r� rG )rx )rB r; r� r� rG r6 r6 r7 � create_volumeY s z'CloudSigma_2_0_NodeDriver.create_volumec C s^ i }i }|r d� |�|d< |r||d< d|j }| j|d||dd�}| j|jd d d �}|S ) a� Clone a library or a standard drive. :param drive: Drive to clone. :type drive: :class:`libcloud.compute.base.NodeImage` or :class:`.CloudSigmaDrive` :param name: Optional name for the cloned drive. :type name: ``str`` :param ex_avoid: A list of other drive uuids to avoid when creating this drive. If provided, drive will attempt to be created on a different physical infrastructure from other drives specified using this argument. (optional) :type ex_avoid: ``list`` :return: New cloned drive. :rtype: :class:`.CloudSigmaDrive` r� rY r; �/drives/%s/action/rf r} )r\ r r, r� r� r5 r r2 )r� rI r] rq r� )rB r� r; rG r, r� r\ r� r6 r6 r7 rI \ s �z(CloudSigma_2_0_NodeDriver.ex_clone_drivec C sP d|j }|j|d d d dd�}| j|dd|d�}| j|jd d d �}|S ) z� Resize a drive. :param drive: Drive to resize. :param size: New drive size in GBs. :type size: ``int`` :return: Drive object which is being resized. :rtype: :class:`.CloudSigmaDrive` rz r< rL rv �resizer} rg r5 r r2 )rI r; r] rq r� )rB r� r� r\ r� r� r6 r6 r7 rK � s z)CloudSigma_2_0_NodeDriver.ex_resize_drivec C s� | j |jdd�}dd� |d D �}d}tt�D ] }tt�D ]}d�||�|vr/d�||�} nq |r4 nqtd|j ��d|d t|j�d �}|d �|� d |j } | j j | |d d �} | j dkS )a= Attach drive to node :param node: Node to attach the drive to. :type node: :class:`libcloud.compute.base.Node` :param drive: Drive to attach. :type drive: :class:`.CloudSigmaDrive` :return: ``True`` on success, ``False`` otherwise. :rtype: ``bool`` T�ri c S � g | ]}|d �qS )rB r6 r3 r6 r6 r7 r� � � z=CloudSigma_2_0_NodeDriver.ex_attach_drive.<locals>.<listcomp>rD Nra z Could not attach drive to %sr� rA rN rU r� rT ) rj rI rQ r r rf r> r� r� r� r� rU ) rB r{ r� r� Z dev_channelsrB Z controllerZunitr! r r� r6 r6 r7 �ex_attach_drive� s, ��� z)CloudSigma_2_0_NodeDriver.ex_attach_drivec C rd �N)r{ r� )r �rB r{ Zvolumer6 r6 r7 � attach_volume� � z'CloudSigma_2_0_NodeDriver.attach_volumec sP | j |jdd�}� fdd�|d D �|d< d|j }| jj||dd�}|jd kS ) NTr| c s" g | ] }|d d � j kr|�qS )r� �uuidr� r3 �r� r6 r7 r� � s " z=CloudSigma_2_0_NodeDriver.ex_detach_drive.<locals>.<listcomp>rD rN rU r� rT )rj rI r� r� rU )rB r{ r� r� r r� r6 r� r7 �ex_detach_drive� s z)CloudSigma_2_0_NodeDriver.ex_detach_drivec C rd r� )r� r� r6 r6 r7 � detach_volume� r� z'CloudSigma_2_0_NodeDriver.detach_volumec C s( d| }| j j|d�j}| j|d�}|S )z� Retrieve information about a single drive. :param drive_id: ID of the drive to retrieve. :type drive_id: ``str`` :return: Drive object. :rtype: :class:`.CloudSigmaDrive` � /drives/%s/r� r2 )r� r� r� rq )rB �drive_idr r� r� r6 r6 r7 � ex_get_drive� s z&CloudSigma_2_0_NodeDriver.ex_get_drivec C �& d|j }| jj|dd�}|jtjkS )Nr� rO r~ rP )rB r� r r� r6 r6 r7 r� � rc z*CloudSigma_2_0_NodeDriver.ex_destroy_drivec C r� )Nr� )r� )rB r� r6 r6 r7 �destroy_volume� r z(CloudSigma_2_0_NodeDriver.destroy_volumec �0 d}� j j|dd�j}� fdd�|d D �}|S )zi List firewall policies. :rtype: ``list`` of :class:`.CloudSigmaFirewallPolicy` z/fwpolicies/detail/r� r~ c r0 r1 )�_to_firewall_policyr3 rA r6 r7 r� � r4 zGCloudSigma_2_0_NodeDriver.ex_list_firewall_policies.<locals>.<listcomp>r5 r9 )rB r r� Zpoliciesr6 rA r7 �ex_list_firewall_policies� � z3CloudSigma_2_0_NodeDriver.ex_list_firewall_policiesc C sV i }i }||d< |r||d< |g|d< d}| j j|d|d�j}| j|d d d�}|S ) an Create a firewall policy. :param name: Policy name. :type name: ``str`` :param rules: List of firewall policy rules to associate with this policy. (optional) :type rules: ``list`` of ``dict`` :return: Created firewall policy object. :rtype: :class:`.CloudSigmaFirewallPolicy` r; r r5 z /fwpolicies/r} rE r r2 )r� r� r� r� )rB r; r r� �objr r� �policyr6 r6 r7 �ex_create_firewall_policy� s z3CloudSigma_2_0_NodeDriver.ex_create_firewall_policyc sp t �|j�dg ��}� r� fdd�|D �}n|}t|�dkr"td��|d }|j|d< d|i}| j||d�}|S )at Attach firewall policy to a public NIC interface on the server. :param policy: Firewall policy to attach. :type policy: :class:`.CloudSigmaFirewallPolicy` :param node: Node to attach policy to. :type node: :class:`libcloud.compute.base.Node` :param nic_mac: Optional MAC address of the NIC to add the policy to. If not specified, first public interface is used instead. :type nic_mac: ``str`` :return: Node object to which the policy was attached to. :rtype: :class:`libcloud.compute.base.Node` rC c s g | ] }|d � kr|�qS )Zmacr6 )r� �n��nic_macr6 r7 r� + r� zGCloudSigma_2_0_NodeDriver.ex_attach_firewall_policy.<locals>.<listcomp>r z3Cannot find the NIC interface to attach a policy toZfirewall_policy)r{ r, )rV rW rP r� �lenrq rI rX )rB r� r{ r� rC rM r, r6 r� r7 �ex_attach_firewall_policy s z3CloudSigma_2_0_NodeDriver.ex_attach_firewall_policyc C r� )z� Delete a firewall policy. :param policy: Policy to delete to. :type policy: :class:`.CloudSigmaFirewallPolicy` :return: ``True`` on success, ``False`` otherwise. :rtype: ``bool`` z/fwpolicies/%s/rO r~ rP )rB r� r r� r6 r6 r7 �ex_delete_firewall_policy: rn z3CloudSigma_2_0_NodeDriver.ex_delete_firewall_policyc C � d}| j j|dd�}|jS )a< Return which running servers share the same physical compute host. :return: A list of server UUIDs which share the same physical compute host. Servers which share the same host will be stored under the same list index. :rtype: ``list`` of ``list`` z /servers/availability_groups/r� r~ r9 �rB r r� r6 r6 r7 �#ex_list_servers_availability_groupsK � z=CloudSigma_2_0_NodeDriver.ex_list_servers_availability_groupsc C r� )a1 Return which drives share the same physical storage host. :return: A list of drive UUIDs which share the same physical storage host. Drives which share the same host will be stored under the same list index. :rtype: ``list`` of ``list`` z /drives/availability_groups/r� r~ r9 r� r6 r6 r7 �"ex_list_drives_availability_groupsY r� z<CloudSigma_2_0_NodeDriver.ex_list_drives_availability_groupsc r� )zk List all the available tags. :rtype: ``list`` of :class:`.CloudSigmaTag` objects z /tags/detail/r� r~ c r0 r1 )�_to_tagr3 rA r6 r7 r� q r4 z:CloudSigma_2_0_NodeDriver.ex_list_tags.<locals>.<listcomp>r5 r9 )rB r r� �tagsr6 rA r7 � ex_list_tagsi r� z&CloudSigma_2_0_NodeDriver.ex_list_tagsc C s* d| }| j j|dd�j}| j|d�}|S )z� Retrieve a single tag. :param tag_id: ID of the tag to retrieve. :type tag_id: ``str`` :rtype: ``list`` of :class:`.CloudSigmaTag` objects � /tags/%s/r� r~ r2 �r� r� r� r� )rB Ztag_idr r� �tagr6 r6 r7 � ex_get_tagu s z$CloudSigma_2_0_NodeDriver.ex_get_tagc C sN i }d|ig|d< |r||d< d}| j j|d|d�j}| j|d d d�}|S ) aQ Create a tag. :param name: Tag name. :type name: ``str`` :param resource_uuids: Optional list of resource UUIDs to assign this tag go. :type resource_uuids: ``list`` of ``str`` :return: Created tag object. :rtype: :class:`.CloudSigmaTag` r; r5 r z/tags/r} rE r r2 r� )rB r; Zresource_uuidsr� r r� r� r6 r6 r7 � ex_create_tag� s z'CloudSigma_2_0_NodeDriver.ex_create_tagc C s" t |d�s td��| j|g|d�S )a� Associate tag with the provided resource. :param resource: Resource to associate a tag with. :type resource: :class:`libcloud.compute.base.Node` or :class:`.CloudSigmaDrive` :param tag: Tag to associate with the resources. :type tag: :class:`.CloudSigmaTag` :return: Updated tag object. :rtype: :class:`.CloudSigmaTag` rI �"Resource doesn't have id attribute)r r� )�hasattrrq �ex_tag_resources)rB r r� r6 r6 r7 �ex_tag_resource� s z)CloudSigma_2_0_NodeDriver.ex_tag_resourcec C s| |j dd� }|D ]}t|d�std��|�|j� q tt|��}|j|d�}d|j }| jj |d|d�j }| j |d�}|S ) a� Associate tag with the provided resources. :param resources: Resources to associate a tag with. :type resources: ``list`` of :class:`libcloud.compute.base.Node` or :class:`.CloudSigmaDrive` :param tag: Tag to associate with the resources. :type tag: :class:`.CloudSigmaTag` :return: Updated tag object. :rtype: :class:`.CloudSigmaTag` NrI r� )r; r r� rU rE r2 ) r r� rq r� rI r� �setr; r� r� r� r� )rB r r� r r� r r� r6 r6 r7 r� � s z*CloudSigma_2_0_NodeDriver.ex_tag_resourcesc C r� )z� Delete a tag. :param tag: Tag to delete. :type tag: :class:`.CloudSigmaTag` :return: ``True`` on success, ``False`` otherwise. :rtype: ``bool`` r� rO r~ rP )rB r� r r� r6 r6 r7 � ex_delete_tag� rn z'CloudSigma_2_0_NodeDriver.ex_delete_tagc C r� )z� Retrieve account balance information. :return: Dictionary with two items ("balance" and "currency"). :rtype: ``dict`` z /balance/r� r~ r9 r� r6 r6 r7 �ex_get_balance� � z(CloudSigma_2_0_NodeDriver.ex_get_balancec C r� )z� Retrieve pricing information that are applicable to the cloud. :return: Dictionary with pricing information. :rtype: ``dict`` z /pricing/r� r~ r9 r� r6 r6 r7 �ex_get_pricing� r� z(CloudSigma_2_0_NodeDriver.ex_get_pricingc C r� )z� Retrieve account current usage information. :return: Dictionary with two items ("balance" and "usage"). :rtype: ``dict`` z/currentusage/r� r~ r9 r� r6 r6 r7 � ex_get_usage� r� z&CloudSigma_2_0_NodeDriver.ex_get_usage�allc C sD i }|r||d< |rd� |�|d< | jjd|d�j}| j|d�}|S )as List subscriptions for this account. :param status: Only return subscriptions with the provided status (optional). :type status: ``str`` :param resources: Only return subscriptions for the provided resources (optional). :type resources: ``list`` :rtype: ``list`` rU r� r �/subscriptions/)r r, r2 )r� r� r� r� �_to_subscriptions)rB rU r r, r� � subscriptionsr6 r6 r7 �ex_list_subscriptions s z/CloudSigma_2_0_NodeDriver.ex_list_subscriptionsc C r^ )a Toggle subscription auto renew status. :param subscription: Subscription to toggle the auto renew flag for. :type subscription: :class:`.CloudSigmaSubscription` :return: ``True`` on success, ``False`` otherwise. :rtype: ``bool`` z/subscriptions/%s/action/r r} r` )rI r] rU r r# )rB � subscriptionr\ r� r6 r6 r7 �!ex_toggle_subscription_auto_renew" rn z;CloudSigma_2_0_NodeDriver.ex_toggle_subscription_auto_renewc C s@ ||||d�g}| j jd|dd�}|jd d }| j|d�}|S )aC Create a new subscription. :param amount: Subscription amount. For example, in dssd case this would be disk size in gigabytes. :type amount: ``int`` :param period: Subscription period. For example: 30 days, 1 week, 1 month, ... :type period: ``str`` :param resource: Resource the purchase the subscription for. :type resource: ``str`` :param auto_renew: True to automatically renew the subscription. :type auto_renew: ``bool`` )r r r r r� r} r� r5 r r2 )r� r� r� �_to_subscription)rB r r r r r� r� r� r6 r6 r7 �ex_create_subscription1 s �� z0CloudSigma_2_0_NodeDriver.ex_create_subscriptionc C s d}| j j|dd�}|j}|S )zb Retrieve all the basic and sensible limits of the API. :rtype: ``dict`` z/capabilities/r� r~ r9 )rB r r� Z capabilitiesr6 r6 r7 �ex_list_capabilitiesT s z.CloudSigma_2_0_NodeDriver.ex_list_capabilitiesc r� )zp List all the available key pair objects. :rtype: ``list`` of :class:`KeyPair` objects z /keypairsr� r~ c r0 r1 )� _to_key_pairr3 rA r6 r7 r� i r4 z<CloudSigma_2_0_NodeDriver.list_key_pairs.<locals>.<listcomp>r5 r9 )rB r r� r� r6 rA r7 �list_key_pairs` s z(CloudSigma_2_0_NodeDriver.list_key_pairsc C s$ d| }| j j|dd�j}| �|�S )z� Retrieve a single key pair. :param name: The uuid of the key pair to retrieve. :type name: ``str`` :rtype: :class:`.KeyPair` � /keypairs/%s/r� r~ �r� r� r� r� )rB Zkey_uuidr r� r6 r6 r7 � get_key_pairm s z&CloudSigma_2_0_NodeDriver.get_key_pairc C s8 d}dd|igi}| j j|d|d�j}| �|d d �S )zh Create a new SSH key. :param name: Key pair name. :type name: ``str`` � /keypairs/r5 r; r} rE r r� )rB r; r r� r� r6 r6 r7 �create_key_pair{ s z)CloudSigma_2_0_NodeDriver.create_key_pairc C sB d}d||� dd�d�gi}| jj|d|d�j}| �|d d �S ) z� Import a new public key from string. :param name: Key pair name. :type name: ``str`` :param key_material: Public key material. :type key_material: ``str`` :rtype: :class:`.KeyPair` object r� r5 � rZ )r; � public_keyr} rE r )r[ r� r� r� r� )rB r; Z key_materialr r� r� r6 r6 r7 �import_key_pair_from_string� s z5CloudSigma_2_0_NodeDriver.import_key_pair_from_stringc C s( d|j d }| jj|dd�}|jdkS )z� Delete an existing key pair. :param key_pair: Key pair object :type key_pair: :class:`.KeyPair` :rtype: ``bool`` r� r� rO r~ r� )rP r� r� rU )rB Zkey_pairr r� r6 r6 r7 �delete_key_pair� s z)CloudSigma_2_0_NodeDriver.delete_key_pairc C s g g }}|d }|d }|r|d nd}|r|d nd}|r#|d nd}|r+|d nd} g } |r6| � |� | r=| � | � |d } |d rI| d nd}|d rS| d nd}|r[|d nd}|rc|d nd} |rl| � |� | rs| � | � t| �} | D ]} t| �r�|� | � qy|� | � qy||fS ) z� Parse private and public IP addresses from the provided network interface object. :param nic: NIC object. :type nic: ``dict`` :return: (public_ips, private_ips) tuple. :rtype: ``tuple`` r? r@ �ipNr� �runtime�ip_v4�ip_v6)r� r� r ) rB rM r� r� Z ipv4_confZ ipv6_confr� r� Zipv4Zipv6r� r� r� r6 r6 r7 �_parse_ips_from_nic� s6 z-CloudSigma_2_0_NodeDriver._parse_ips_from_nicc C s� |d }|d }| j �|d tj�}g }g }|d d |d d d |d |d |d |d |d d �}d }d} |d D ]&} | d dkrb| �| d d �} | j} d�| j�dd�| j�dd��} nq<zt|d |d | f } t d i | �d| i��} W n> t y� t |d �t |d � t | � }t � |�d���� }d�|d |d | �}t |||d |d | d d| d�} Y nw |d D ]}| j|d �\}}|�|� |�|� q�t||||||| | |d � }|S ) Nr� r; rU rJ r; r� r< rC r� r= r� rD )rT r� rC r� r= r� rD r r> r� r� z{} {}� distributionrZ �versionrT r� rO rb z$custom, {} CPUs, {}MB RAM, {}GB diskrR )rM ) rI r; rw r� r� r� rO r� rP r6 )r� r� r r� r� r� rf rP r r" r� r� �hashlib�md5�encode� hexdigestr� �extendr )rB r� rI r; rw r� r� rP r� rL r! r� r3 r� Z id_to_hashr� Z size_namerM Z _public_ipsZ _private_ipsr{ r6 r6 r7 r� � sx � �� � �� � z"CloudSigma_2_0_NodeDriver._to_nodec C s: g d�}|d }|d }| j ||d�}t||| |d�}|S )N)� description�archr8 �osZlicensesr� r= r� r; )r� r� r� )�_extract_valuesr )rB r� r� rI r; rP r� r6 r6 r7 r7 % s z#CloudSigma_2_0_NodeDriver._to_imagec C s� |d }|d }|d d d d }|d }|d }|� dg �|� dd �|d � d d �|d � d d �|d � d d �|d � dd �|d � dd �|d � dd �d�}t|||||| |d�}|S )Nr� r; r� r< r� rU � mounted_on� storage_typerZ r= r� r� r� �paidr� � created_at)r� r� r� r� r� r� � architecturer� )rI r; r� r� rU rO rP )r� r# ) rB r� rI r; r� r� rU rP r� r6 r6 r7 rq 8 s0 � � z#CloudSigma_2_0_NodeDriver._to_drivec C s0 |d }dd� |D �}t |d |d |d�}|S )Nr c S r} )r� r6 )r� r r6 r6 r7 r� W r~ z5CloudSigma_2_0_NodeDriver._to_tag.<locals>.<listcomp>r� r; r )r$ )rB r� r r� r6 r6 r7 r� U s z!CloudSigma_2_0_NodeDriver._to_tagc C s, g }|d D ] }| j |d�}|�|� q|S )Nr5 r2 )r� r� )rB r� r� r! r� r6 r6 r7 r� ] s z+CloudSigma_2_0_NodeDriver._to_subscriptionsc C s� |� dd �r t|d �}nd }|� dd �r t|d �}nd }|d }t|d |d t|d �|d |d |d |||d |d � }|S ) Nr r r rI r r r rU rN r r )r� r r% r� )rB r� r r Zobj_uuidr� r6 r6 r7 r� f s( � z*CloudSigma_2_0_NodeDriver._to_subscriptionc C sr g }|� dg �D ]#}t|d |d |d |d |d |d |d |d d �}|�|� qt|d |d |d �}|S )Nr r r r r r r r r r r� r; r )r� r' r� r& )rB r� r r! Zruler� r6 r6 r7 r� � s � z-CloudSigma_2_0_NodeDriver._to_firewall_policyc C sH |d |d |d |d |d d�}t |d |d |d | |d |d �S ) Nr� r� � resource_uri� permissionsr= )r� r� r� r� r= r; r� � fingerprint� private_key)r; r� r� rO r� rP )r )rB r� rP r6 r6 r7 r� � s ��z&CloudSigma_2_0_NodeDriver._to_key_pairr} c C s2 |r|� � }ni }||d< | jj||||d�}|S )z@ Perform API action and return response object. Zdorw )rV r� r� )rB r\ r r� r, r� r� r6 r6 r7 r] � s z)CloudSigma_2_0_NodeDriver._perform_actionc C s t |t�r |jdkr dS dS )z_ Detect if the provided image is an installation CD. :rtype: ``bool`` ZcdromTF)r� r# r� )rB r� r6 r6 r7 rH � s z-CloudSigma_2_0_NodeDriver._is_installation_cdc C s i }|D ]}|| ||< q|S )aR Extract values from a dictionary and return a new dictionary with extracted values. :param obj: Dictionary to extract values from. :type obj: ``dict`` :param keys: Keys to extract. :type keys: ``list`` :return: Dictionary with extracted values. :rtype: ``dict`` r6 )rB r� r� r� r- r6 r6 r7 r� � s z)CloudSigma_2_0_NodeDriver._extract_valuesc C sr t � � }|j|kr7| j|jd�}|j|kr |S t � � }|| }||kr,d| }t|��t �| j� |j|ks |S )ad Wait for a drive to transition to the provided state. Note: This function blocks and periodically calls "GET drive" endpoint to check if the drive has already transitioned to the desired state. :param drive: Drive to wait for. :type drive: :class:`.CloudSigmaDrive` :param state: Desired drive state. :type state: ``str`` :param timeout: How long to wait for the transition (in seconds) before timing out. :type timeout: ``int`` :return: Drive object. :rtype: :class:`.CloudSigmaDrive` )r� zATimed out while waiting for drive transition (timeout=%s seconds))r� rU r� rI � Exceptionr� � DRIVE_TRANSITION_SLEEP_INTERVAL)rB r� rw �timeoutr Z current_time�delta�msgr6 r6 r7 rJ � s �� �z:CloudSigma_2_0_NodeDriver._wait_for_drive_state_transitionc C r� r� )rr r rp r� r6 r6 r7 r� r� z5CloudSigma_2_0_NodeDriver._ex_connection_class_kwargsrH )NNNNN)F)NN)rL N)r� N)r} NN)Xr8 r9 r: r� r; rs r< r' r� ZDRIVE_TRANSITION_TIMEOUTr� r ZPENDING�ERRORrx ZSTOPPEDZPAUSEDr� r rQ r� r� r� r� r� r| rX rR r� rz ry rh rj rl rm rs rt ru rx ry rI rK r r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r7 rq r� r� r� r� r� r] rH r� rJ r� r= r6 r6 r4 r7 r R s� � � � $ " % &. $ ! # 6F *r )Br� r� rV r� rd r� Zlibcloud.utils.py3r r Zlibcloud.utils.miscr r r r Zlibcloud.common.baser r r Zlibcloud.common.typesr r Zlibcloud.compute.baser r r r r r Zlibcloud.compute.typesr r Zlibcloud.utils.iso8601r Zlibcloud.common.cloudsigmar r r r r r r r Z simplejsonr( r� �__all__r r> rG r" rS r^ r r� r� r� r� r! r% r$ r# r& r' r r' r r6 r6 r6 r7 �<module> sX ( � 0 D ( <6%
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings