Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/compute/drivers/__pycache__/cloudsigma.cpython-39.pyc
Ðазад
a q�h� � @ sp d Z ddlZddlZddlZddlZz ddlZW n eyJ ddlZY n0 ddlm Z ddlm Z ddl m Z m Z mZ ddlmZmZmZ ddlmZmZ ddlmZ dd lmZ dd lmZ dd lmZmZ dd l m Z m Z dd l m Z m!Z!m"Z" ddl m#Z# ddl m$Z$ ddl%m&Z& ddl m'Z' g d�Z(G dd� de �Z)G dd� de�Z*G dd� de�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.�Z0G d#d$� d$e/�Z1G d%d&� d&e.�Z2G d'd(� d(e/�Z3G d)d*� d*e�Z4G d+d,� d,e5�Z6G d-d.� d.e5�Z7G d/d0� d0e#�Z8G d1d2� d2e5�Z9G d3d4� d4e5�Z:G d5d6� d6e�Z;G d7d8� d8e�Z<G d9d:� d:e)�Z=dS );z+ Drivers for CloudSigma API v1.0 and v2.0. � N)�b)�httplib)� str2dicts�str2list�dict2str)�ConnectionUserAndKey� JsonResponse�Response)�InvalidCredsError� ProviderError)�INSTANCE_TYPES)�API_ENDPOINTS_1_0)�API_ENDPOINTS_2_0)�DEFAULT_API_VERSION�DEFAULT_REGION)� NodeState�Provider)� NodeDriver�NodeSize�Node)� NodeImage)�is_private_subnet)� parse_date)�get_secure_random_string) �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 r0|dkrt} n|dkr$t} n td| ��tt | ��| �S )Nz1.0z2.0zUnsupported API version: %s)r r r �NotImplementedError�super�__new__)�cls�key�secret�secure�host�port� api_version�kwargs�� __class__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/libcloud/compute/drivers/cloudsigma.pyr' C s �z CloudSigmaNodeDriver.__new__)�__name__� __module__� __qualname__�name�websiter r' � __classcell__r2 r2 r0 r3 r ? s �r c @ s e Zd Zdd� Zdd� ZdS )�CloudSigmaExceptionc C s | j d S )Nr ��args��selfr2 r2 r3 �__str__Q s zCloudSigmaException.__str__c C s d| j d S )Nz<CloudSigmaException '%s'>r r; r= r2 r2 r3 �__repr__U s z CloudSigmaException.__repr__N)r4 r5 r6 r? r@ r2 r2 r2 r3 r: P s r: c @ s e Zd Zdd� ZdS )�$CloudSigmaInsufficientFundsExceptionc C s d| j d S )Nz+<CloudSigmaInsufficientFundsException '%s'>r r; r= r2 r2 r3 r@ [ s z-CloudSigmaInsufficientFundsException.__repr__N)r4 r5 r6 r@ r2 r2 r2 r3 rA Z s rA c @ s e Zd Zdd� Zdd� ZdS )r c C s4 || _ || _|| _|| _|| _|| _|| _|| _d S �N��idr7 �cpu�ram�disk� bandwidth�price�driver) r> rD r7 rE rF rG rH rI rJ r2 r2 r3 �__init__a 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 ...>rC r= r2 r2 r3 r@ k s ��zCloudSigmaNodeSize.__repr__N)r4 r5 r6 rK r@ r2 r2 r2 r3 r ` s r c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�CloudSigma_1_0_Responsec C s, | j tjkrt� �d| j ko&dkS S )N�� i+ )�statusr � UNAUTHORIZEDr r= r2 r2 r3 �successs s z CloudSigma_1_0_Response.successc C s | j s | j S t| j �S rB )�bodyr r= r2 r2 r3 � parse_bodyy s z"CloudSigma_1_0_Response.parse_bodyc C s d| j �dd��� S )Nz Error: %szerrors:� )rQ �replace�stripr= r2 r2 r3 � parse_error s z#CloudSigma_1_0_Response.parse_errorN)r4 r5 r6 rP rR rV r2 r2 r2 r3 rL r s rL c @ s$ e Zd Zee d ZeZdd� ZdS )�CloudSigma_1_0_Connectionr, c C s< d|d< d|d< dt �td| j| jf ���d� |d< |S �Nzapplication/json�Acceptz Content-TypezBasic %sz%s:%szutf-8� Authorization��base64� b64encoder Zuser_idr) �decode�r> �headersr2 r2 r3 �add_default_headers� s �� z-CloudSigma_1_0_Connection.add_default_headersN) r4 r5 r6 r r r, rL � responseClsra r2 r2 r2 r3 rW � s rW c s e Zd ZejZdZdZeZ dZ e j e j e j e j d�Zddddef� fdd� Zd d � Zd d � Zd8d d�Zd9dd�Zdd� Zd:dd�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 sP |t vrtd| ��|d u| _d| | _tt| �jf ||||||d�|�� d S )N�Invalid region: %sz cloudsigma_%s�r) r* r+ r, r- �region)r � ValueError�_host_argument_set�api_namer& r rK �r> r) r* r+ r, r- rf r/ r0 r2 r3 rK � 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_noderD �stater �RUNNING� ex_stop_noder: � ex_start_node)r> �noderm rc rP r2 r2 r3 � 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` Trk z/servers/%s/destroy�POST��action�method�� ) rl rD rm r rn ro r: � connection�requestrN )r> rq rm rc �responser2 r2 r3 � destroy_node� s ��z&CloudSigma_1_0_NodeDriver.destroy_nodec C sf | j jdd�j}g }|D ]H}|�d�r|d dkrt|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�ru �typerG �driver7 �size�rD r7 rJ �extra)rx ry �object�getr rJ �append)r> �locationrz �images�value�imager2 r2 r3 � list_images� s � � z%CloudSigma_1_0_NodeDriver.list_imagesc C s` g }t D ]R}|d }t|d |d |d |d |d |d | j|d�| jjd�}|�|� q|S ) NrD r7 rE �memoryrG rH �Zsize_idrC �r r Z_get_size_pricerx rJ r� )r> r� �sizesr� r) r r2 r2 r3 � list_sizes� s � z$CloudSigma_1_0_NodeDriver.list_sizesc C s: | j jdd�j}g }|D ] }| �|�}|r|�|� q|S )Nz /servers/infor| )rx ry r� �_to_noder� )r> rz �nodes�datarq r2 r2 r3 � list_nodes s z$CloudSigma_1_0_NodeDriver.list_nodes�auto�e1000�hddc C s� |dvrt d��|dvr$t d| ��i }|�|d|j |d�� | jjd|j t|�dd �j} | sjt d ��| d d } | jjd | d�j} t�� } d| d v r�| jjd | d�j} t�� | } | | j k} d| d v r�| r�t d��t� d� q�i }|�||j |j | d|d�� |�|dd�� |�r2|�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)r7 r Z driveTypez/drives/%s/cloners �ru r� rv zDrive creation failedr r~ z/drives/%s/infor| ZimagingzDrive imaging timed out� �ide:0:0)r7 rE �memr� �boot�smpr� )z nic:0:model� nic:0:dhcp)�vnc:ip� vnc:passwordz/servers/createNz(Insufficient funds, node creation failed)r: �updaterG rx ry rD r r� �time�IMAGING_TIMEOUT�sleeprE rF � isinstance�listr� �ex_drive_destroyrA rp r rn rm )r> r7 r r� r� Z nic_model� vnc_passwordZ drive_typeZ drive_datarz � drive_uuidZ imaging_startZ elapsed_timeZ timed_outZ node_datarq �startedr2 r2 r3 � create_node sr ��� � � ��� � z%CloudSigma_1_0_NodeDriver.create_nodec C s� | � |�}g }|�� D ]N\}}|�d�s<|�d�s<|�d�r|�d�s|�d�s|�d�s|�|� q| �| �|��}|s~dS |D ]}| �|� q�dS ) 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� )r> rq Z drive_uuidsr) r� Znode_destroyedr� r2 r2 r3 �ex_destroy_node_and_drivesg s* ����� z4CloudSigma_1_0_NodeDriver.ex_destroy_node_and_drivesc C s0 | j jddd�}|jdkr"td��t|j�}|S )zf Return a list of available static IP addresses. :rtype: ``list`` of ``str`` z/resources/ip/list�GETrt rM zCould not retrieve IP list)rx ry rN r: r rQ )r> rz �ipsr2 r2 r3 �ex_static_ip_list� s � z+CloudSigma_1_0_NodeDriver.ex_static_ip_listc C s | j jddd�}t|j�}|S )zb Return a list of all the available drives. :rtype: ``list`` of ``dict`` z /drives/infor� rt �rx ry r rQ �r> rz �resultr2 r2 r3 �ex_drives_list� s z(CloudSigma_1_0_NodeDriver.ex_drives_listc C s | j jddd�}t|j�}|S )zX Create a new static IP address.p :rtype: ``list`` of ``dict`` z/resources/ip/creater� rt r� r� r2 r2 r3 �ex_static_ip_create� s � z-CloudSigma_1_0_NodeDriver.ex_static_ip_createc C s | 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� rt rw �rx ry rN )r> � ip_addressrz r2 r2 r3 �ex_static_ip_destroy� s �z.CloudSigma_1_0_NodeDriver.ex_static_ip_destroyc C s | j jd| dd�}|jdkS )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/destroyrs rt rw r� �r> r� rz r2 r2 r3 r� � s �z*CloudSigma_1_0_NodeDriver.ex_drive_destroyc K s� d}g }t |�� �}|D ]4}d}|D ]}t�||�r$d} q>q$|s|�|� q|rdtdd�|� ��| jjd|j t |�dd�} | j d ko�| 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/setrs r� rM rS ) r� �keys�re�matchr� r: �joinrx ry rD r rN rQ ) r> rq r/ Z valid_keysZ invalid_keysr� r) �matches�regexrz r2 r2 r3 �ex_set_node_configuration� s. ���z3CloudSigma_1_0_NodeDriver.ex_set_node_configurationc C s | 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/startrs rt rM �rx ry rD rN �r> rq rz r2 r2 r3 rp � s �z'CloudSigma_1_0_NodeDriver.ex_start_nodec C s | j |d�S )N�rq �� stop_node�r> rq r2 r2 r3 ro s z&CloudSigma_1_0_NodeDriver.ex_stop_nodec C s | j jd|j dd�}|jdkS )z� Stop (shutdown) a node. :param node: Node which should be used :type node: :class:`libcloud.compute.base.Node` :rtype: ``bool`` z/servers/%s/stoprs rt rw r� r� r2 r2 r3 r� s �z#CloudSigma_1_0_NodeDriver.stop_nodec C s | � |�S )zl Stop (shutdown) a node. @inherits: :class:`CloudSigmaBaseNodeDriver.ex_stop_node` )ro r� r2 r2 r3 �ex_shutdown_node s z*CloudSigma_1_0_NodeDriver.ex_shutdown_nodec C s | j jd| dd�}|jdkS )z� Destroy a drive. :param drive_uuid: Drive uuid which should be used :type drive_uuid: ``str`` :rtype: ``bool`` r� rs rt rw r� r� r2 r2 r3 �ex_destroy_drive s �z*CloudSigma_1_0_NodeDriver.ex_destroy_drivec C s i }| j s t| j d |d< |S �zJ Return the host value based on the user supplied region. r, )rh r rf �r> r/ r2 r2 r3 �_ex_connection_class_kwargs+ s z5CloudSigma_1_0_NodeDriver._ex_connection_class_kwargsc C s4 |�r0z| j |d }W n ty0 tj}Y n0 d|vr>d S g }d|v rlt|d t�rb|d }n |d g}i }g d�}|D ]`\}}||v r||| }|dkr�t|�}n(|dkr�z t|�}W n ty� Y n0 |�||i� q|d|v �r d|v �r |�|d |d d �� t |d |d ||d | j j |d �} | S d S ) NrN �serverr� ))rE �int)r� r� )r� r� )rN �strr� r� r� r� )Zvnc_ipr� r7 �rD r7 rm � public_ips� private_ipsrJ r� ) �NODE_STATE_MAP�KeyErrorr �UNKNOWNr� r� r� rg r� r rx rJ ) r> r� rm r� r� � extra_keysr) Z value_typer� rq r2 r2 r3 r� 5 sH ��z"CloudSigma_1_0_NodeDriver._to_nodec C s. | � � }dd� |D �}|s&td| ��|d S )Nc S s g | ]}|j |j kr|�qS r2 )rD )�.0rq r2 r2 r3 � <listcomp>g � z7CloudSigma_1_0_NodeDriver._get_node.<locals>.<listcomp>z Node with id %s does not existr )r� r: )r> Znode_idr� rq r2 r2 r3 rl e s �z#CloudSigma_1_0_NodeDriver._get_nodec C s& | j jd|j d�}t|j�}|d S )Nz/servers/%s/infor| r )rx ry rD r rQ )r> rq rz r� r2 r2 r3 r� o s � z(CloudSigma_1_0_NodeDriver._get_node_info)N)N)r� r� Nr� )(r4 r5 r6 r Z CLOUDSIGMAr} r7 r8 rW � connectionClsr� r rn Z TERMINATEDr� r rK rr r{ r� r� r� r� r� r� r� r� r� r� r� rp ro r� r� r� r� r� rl r� r9 r2 r2 r0 r3 r � sJ �� � Y + 0 r c @ s e Zd ZdZed d ZdS )�CloudSigmaZrhConnectionzM Connection class for the CloudSigma driver for the Zurich end-point Zzrhr, N�r4 r5 r6 �__doc__r r, r2 r2 r2 r3 r� w s r� c @ s e Zd ZdZeZdZdS )�CloudSigmaZrhNodeDriverz9 CloudSigma node driver for the Zurich end-point �cloudsigma_zrhN)r4 r5 r6 r� r� r� ri r2 r2 r2 r3 r� ~ s r� c @ s e Zd ZdZed d ZdS )�CloudSigmaLvsConnectionzP Connection class for the CloudSigma driver for the Las Vegas end-point Zlvsr, Nr� r2 r2 r2 r3 r� � s r� c @ s e Zd ZdZeZdZdS )�CloudSigmaLvsNodeDriverz< CloudSigma node driver for the Las Vegas end-point Zcloudsigma_lvsN)r4 r5 r6 r� r� r� ri r2 r2 r2 r3 r� � s r� c s e Zd ZdZ� fdd�Z� ZS )r z* Represents CloudSigma API error. c s, t 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� rJ N)r& r rK � error_type� error_msg� error_point)r> r� r� r� r� rJ r0 r2 r3 rK � s �zCloudSigmaError.__init__)r4 r5 r6 r� rK r9 r2 r2 r0 r3 r � s r c @ s* e Zd ZdZd 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� rD �resource�amount�periodrN rI � start_time�end_time� auto_renew�subscribed_object) r> rD r� r� r� rN rI r� r� r� r� r2 r2 r3 rK � s z CloudSigmaSubscription.__init__c C s | � � S rB �r@ r= r2 r2 r3 r? � s z CloudSigmaSubscription.__str__c C s d| j | j| j| j| jf S )NzQ<CloudSigmaSubscription id=%s, resource=%s, amount=%s, period=%s, object_uuid=%s>)rD r� r� r� r� r= r2 r2 r3 r@ � s ��z CloudSigmaSubscription.__repr__)N�r4 r5 r6 r� rK r? r@ r2 r2 r2 r3 r! � s � )r! c @ s* e Zd ZdZd dd�Zdd� Zdd� ZdS ) r z- Represents a CloudSigma tag object. Nc C s || _ || _|r|ng | _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�rD r7 � resources)r> rD r7 r� r2 r2 r3 rK � s zCloudSigmaTag.__init__c C s | � � S rB r� r= r2 r2 r3 r? � s zCloudSigmaTag.__str__c C s d| j | jt| j�f S )Nz,<CloudSigmaTag id=%s, name=%s, resources=%s>)rD r7 �reprr� r= r2 r2 r3 r@ s �zCloudSigmaTag.__repr__)Nr� r2 r2 r2 r3 r � s r c s2 e Zd ZdZd � fdd� Zdd� Zdd� Z� ZS ) r z( Represents a CloudSigma drive. Nc s. t t| �j||||d� || _|| _|| _dS )aq :param id: Drive ID. :type id: ``str`` :param name: Drive name. :type name: ``str`` :param size: Drive size (in bytes). :type size: ``int`` :param media: Drive media (cdrom / disk). :type media: ``str`` :param status: Drive status (unmounted / mounted). :type status: ``str`` r� N)r& r rK r r� rN )r> rD r7 r r� rN rJ r� r0 r2 r3 rK s �zCloudSigmaDrive.__init__c C s | � � S rB r� r= r2 r2 r3 r? ! s zCloudSigmaDrive.__str__c C s d| j | j| j| j| jf S )Nz<<CloudSigmaSize id=%s, name=%s size=%s, media=%s, status=%s>)rD r7 r r� rN r= r2 r2 r3 r@ $ s �zCloudSigmaDrive.__repr__)N)r4 r5 r6 r� rK r? r@ r9 r2 r2 r0 r3 r s r c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) r" z2 Represents a CloudSigma firewall policy. c C s || _ || _|r|ng | _dS )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�rD r7 �rules)r> rD r7 r� r2 r2 r3 rK / s z!CloudSigmaFirewallPolicy.__init__c C s | � � S rB r� r= r2 r2 r3 r? > s z CloudSigmaFirewallPolicy.__str__c C s d| j | jt| j�f S )Nz2<CloudSigmaFirewallPolicy id=%s, name=%s rules=%s>)rD r7 r� r� r= r2 r2 r3 r@ A s �z!CloudSigmaFirewallPolicy.__repr__Nr� r2 r2 r2 r3 r" * s r" c @ s* e Zd ZdZd 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�ru � direction�ip_proto�src_ip�src_port�dst_ip�dst_port�comment) r> ru r� r� r� r� r� r r r2 r2 r3 rK K s z%CloudSigmaFirewallPolicyRule.__init__c C s | � � S rB r� r= r2 r2 r3 r? o s z$CloudSigmaFirewallPolicyRule.__str__c C s d| j | jf S )Nz6<CloudSigmaFirewallPolicyRule action=%s, direction=%s>)ru r� r= r2 r2 r3 r@ r s �z%CloudSigmaFirewallPolicyRule.__repr__)NNNNNNr� r2 r2 r2 r3 r# F s � $r# c @ s8 e Zd ZejejejejgZdd� Z dd� Z dd� Z dS )�CloudSigma_2_0_Responsec C s | j | jv S rB )rN �success_status_codesr= r2 r2 r3 rP s z CloudSigma_2_0_Response.successc C s< t | j�tjkrtd��| �� }| j|d�}|r8|d �|S )NzInvalid credentials)rQ r )r� rN r rO r rR �_parse_errors_from_body)r> rQ �errorsr2 r2 r3 rV � s z#CloudSigma_2_0_Response.parse_errorc C sX g }t |t�sdS |D ]<}d|vr$qt| 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� � error_messager� )r� r� r� r� rJ )r� r� r rN rx rJ r� )r> rQ r �item�errorr2 r2 r3 r � s � z/CloudSigma_2_0_Response._parse_errors_from_bodyN) r4 r5 r6 r �OK�ACCEPTED� NO_CONTENT�CREATEDr rP rV r r2 r2 r2 r3 r w s � r c sB e Zd Zee d ZeZdZdd� Z dd� Z d � fd d � Z � Z S ) �CloudSigma_2_0_Connectionr, z/api/2.0c C s< d|d< d|d< dt �td| j| jf ���d� |d< |S rX r[ r_ r2 r2 r3 ra � s �� z-CloudSigma_2_0_Connection.add_default_headersc C s t �|�}|S rB )�json�dumps)r> r� r2 r2 r3 � encode_data� s z%CloudSigma_2_0_Connection.encode_dataNr� Fc s> |pi }| j | }|dkr"d|d< tt| �j||||||d�S )Nr� r �limit)ru �paramsr� r` rv �raw)� api_prefixr& r ry )r> ru r r� r` rv r r0 r2 r3 ry � s �z!CloudSigma_2_0_Connection.request)NNNr� F) r4 r5 r6 r r r, r rb r ra r ry r9 r2 r2 r0 r3 r � s �r c s e Zd ZdZdZdZdZeZdZ dZ e j e j e j e je je jd�Zdd d ef� fd d � Zdxd d �Zdd� Zdd� Zdydd�Zdd� Zdd� Zdzdd�Zdd� Zd{d d �Z d d � Z d|d d!�Z d"d#� Z d$d%� Z d&d'� Z!d(d)� Z"d}d+d,�Z#d~d-d.�Z$d/d0� Z%d1d2� Z&d3d4� Z'd5d6� Z(dd7d8�Z)d�d9d:�Z*d;d<� Z+d=d>� Z,d?d@� Z-dAdB� Z.dCdD� Z/d�dEdF�Z0dGdH� Z1dIdJ� Z2dKdL� Z3dMdN� Z4dOdP� Z5dQdR� Z6d�dTdU�Z7dVdW� Z8d�dYdZ�Z9d[d\� Z:d]d^� Z;d_d`� Z<dadb� Z=dcdd� Z>dedf� Z?dgdh� Z@didj� ZAdkdl� ZBd�dndo�ZCdpdq� ZDdrds� ZEe fdtdu�ZFdvdw� ZG� ZHS )�r z) Driver for CloudSigma API v2.0. zCloudSigma (API v2.0)r� r$ i� � )�startingZstopping� unavailable�runningrc ZpausedTNc sR |t vrtd| ��|s td��|d u| _tt| �jf ||||||d�|�� d S )Nrd z3CloudSigma driver only supports a secure connectionre )r rg rh r& r rK rj r0 r2 r3 rK � 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� rt c s g | ]}� j |d ��qS ��r� )r� �r� r r= r2 r3 r� r� z8CloudSigma_2_0_NodeDriver.list_nodes.<locals>.<listcomp>�objects)rD rx ry r� )r> Zex_tagru rz r� r2 r= r3 r� � s z$CloudSigma_2_0_NodeDriver.list_nodesc C s` g }t D ]R}|d }t|d |d |d |d |d |d | j|d�| jjd�}|�|� q|S ) z' List available sizes. rD r7 rE r� rG rH r� rC r� )r> r� r� r) r r2 r2 r3 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 s g | ]}� j |d ��qS r )� _to_imager r= r2 r3 r� " r� z9CloudSigma_2_0_NodeDriver.list_images.<locals>.<listcomp>r c S s g | ]}|j d dkr|�qS )� image_typeZpreinst)r� )r� r� r2 r2 r3 r� ' s ��rx ry r� )r> rz r� r2 r= r3 r� s z%CloudSigma_2_0_NodeDriver.list_imagesc C sd | j |d�}|r|} n tdd�} d| } |jd d d } |s�| j|| d�} | j| dd�} | | jkrr| j| | d �} | j| dd�} n|} i } || d < |j| d < |jd d | d < | | d < |r�|| 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 )!a� 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`` )r� � )r z%s-drivei )r~ r7 Z unmounted)r~ rm )r~ r r7 rE r� r� �metaNZconfZdhcp)� boot_order� ip_v4_conf� ip_v6_conf)r# r$ r% ZvlanZider� r� z0:0)r# Z dev_channelZdevicer~ �nics�drivesz /servers/rs �ru rv r� r r �rq �ex_avoid)�_is_installation_cdr rG �ex_clone_drive� _wait_for_drive_state_transitionr �ex_resize_driverE rF r� rD rx ry r� r� rp )r> r7 r r� Z ex_metadataZex_vnc_passwordr* Zex_vlanZis_installation_cdr� Z drive_nameZ drive_sizer~ r� �nicr& Z device_typer' ru rz rq r2 r2 r3 r� + sn % � � ��� � �z%CloudSigma_2_0_NodeDriver.create_nodec C s0 d|j }ddi}| jj|d|d�}|jtjkS )z� Destroy the node and all the associated drives. :return: ``True`` on success, ``False`` otherwise. :rtype: ``bool`` � /servers/%s/�recurseZ all_drives�DELETE)ru rv r �rD rx ry rN r r )r> rq ru r rz r2 r2 r3 r{ � s �z&CloudSigma_2_0_NodeDriver.destroy_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` r7 rE r� r� r& r0 �PUTr( r ) r7 r� �copy�deepcopyr� r� rD rx ry r� r� )r> rq r r� r& ru rz r2 r2 r3 � ex_edit_node� s � z&CloudSigma_2_0_NodeDriver.ex_edit_nodec C s> i }|rd� |�|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/�startrs )�pathru r rv )r� rD �_perform_actionrN r r )r> rq r* r r; rz r2 r2 r3 � start_node� s �z$CloudSigma_2_0_NodeDriver.start_nodec C s& d|j }| j|ddd�}|jtjkS )Nr9 �stoprs �r; ru rv �rD r< rN r r �r> rq r; rz r2 r2 r3 r� � s �z#CloudSigma_2_0_NodeDriver.stop_nodec C s | j ||d�S )Nr) )r= )r> rq r* r2 r2 r3 rp � s z'CloudSigma_2_0_NodeDriver.ex_start_nodec C s | j |d�S )z Stop a node. r� r� r� r2 r2 r3 ro 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` r7 �random_vnc_passwordr9 �cloners �r; ru rv r� r )rD r< r� r� )r> rq r7 rB r� r; rz r2 r2 r3 � ex_clone_node s � z'CloudSigma_2_0_NodeDriver.ex_clone_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`` r9 Zopen_vncrs r? �vnc_url)rD r< r� )r> rq r; rz rF r2 r2 r3 �ex_open_vnc_tunnel& s �z,CloudSigma_2_0_NodeDriver.ex_open_vnc_tunnelc C s& d|j }| j|ddd�}|jtjkS )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`` r9 Z close_vncrs r? r@ rA r2 r2 r3 �ex_close_vnc_tunnel6 s �z-CloudSigma_2_0_NodeDriver.ex_close_vnc_tunnelc s* � 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 r r| c s g | ]}� j |d ��qS r �� _to_driver r= r2 r3 r� O r� zDCloudSigma_2_0_NodeDriver.ex_list_library_drives.<locals>.<listcomp>r r �r> rz r' r2 r= r3 �ex_list_library_drivesG s z0CloudSigma_2_0_NodeDriver.ex_list_library_drivesc s* � j jdd�j}� fdd�|d D �}|S )z� Return a list of all the available user's drives. :rtype: ``list`` of :class:`.CloudSigmaDrive` objects z/drives/detail/r| c s g | ]}� j |d ��qS r rI r r= r2 r3 r� Y r� zACloudSigma_2_0_NodeDriver.ex_list_user_drives.<locals>.<listcomp>r r rK r2 r= r3 �ex_list_user_drivesR s z-CloudSigma_2_0_NodeDriver.ex_list_user_drivesrG c C sT i }|||d�}|r"d� |�|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 bytes. :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` �r7 r r� r� r8 z/drives/rs �ru rv r r� r r r )r� rx ry r� rJ ) r> r7 r r� r* r r� ru rz r~ r2 r2 r3 �ex_create_drive\ s � �z)CloudSigma_2_0_NodeDriver.ex_create_drivec C s^ i }i }|rd� |�|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� r8 r7 �/drives/%s/action/rC rs )r; ru r r� rv r r r )r� rD r< rJ r� )r> r~ r7 r* r r� r; rz r2 r2 r3 r, � s �z(CloudSigma_2_0_NodeDriver.ex_clone_drivec C sD d|j }|j|dd�}| j|dd|d�}| j|jd d d �}|S ) z� Resize a drive. :param drive: Drive to resize. :param size: New drive size in bytes. :type size: ``int`` :return: Drive object which is being resized. :rtype: :class:`.CloudSigmaDrive` rQ rG rN �resizers rD r r r )rD r7 r< rJ r� )r> r~ r r; r� rz r2 r2 r3 r. � s �z)CloudSigma_2_0_NodeDriver.ex_resize_drivec C s dS )z6 Attach a drive to the provided node. Nr2 r� r2 r2 r3 �ex_attach_drive� s z)CloudSigma_2_0_NodeDriver.ex_attach_drivec 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` z /drives/%s/r| r )rx ry r� rJ )r> �drive_idru rz r~ r2 r2 r3 � ex_get_drive� s z&CloudSigma_2_0_NodeDriver.ex_get_drivec s0 d}� j j|dd�j}� fdd�|d D �}|S )zi List firewall policies. :rtype: ``list`` of :class:`.CloudSigmaFirewallPolicy` z/fwpolicies/detail/r� rt c s g | ]}� j |d ��qS r )�_to_firewall_policyr r= r2 r3 r� � r� zGCloudSigma_2_0_NodeDriver.ex_list_firewall_policies.<locals>.<listcomp>r r )r> ru rz Zpoliciesr2 r= r3 �ex_list_firewall_policies� s �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` r7 r� r z /fwpolicies/rs r( r r )rx ry r� rV )r> r7 r� r� �objru rz �policyr2 r2 r3 �ex_create_firewall_policy� s �z3CloudSigma_2_0_NodeDriver.ex_create_firewall_policyc sp t �|j�dg ��}� r,� fdd�|D �}n|}t|�dkrDtd��|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` r& c s g | ]}|d � kr|�qS )�macr2 )r� �n��nic_macr2 r3 r� r� zGCloudSigma_2_0_NodeDriver.ex_attach_firewall_policy.<locals>.<listcomp>r z3Cannot find the NIC interface to attach a policy toZfirewall_policy)rq r )r5 r6 r� r� �lenrg rD r7 )r> rY rq r^ r& r/ r r2 r] r3 �ex_attach_firewall_policy� s z3CloudSigma_2_0_NodeDriver.ex_attach_firewall_policyc C s& d|j }| jj|dd�}|jtjkS )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/r2 rt r3 )r> rY ru rz r2 r2 r3 �ex_delete_firewall_policy! s z3CloudSigma_2_0_NodeDriver.ex_delete_firewall_policyc C s 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� rt r �r> ru rz r2 r2 r3 �#ex_list_servers_availability_groups1 s z=CloudSigma_2_0_NodeDriver.ex_list_servers_availability_groupsc C s d}| j j|dd�}|jS )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� rt r rb r2 r2 r3 �"ex_list_drives_availability_groups> s z<CloudSigma_2_0_NodeDriver.ex_list_drives_availability_groupsc s0 d}� j j|dd�j}� fdd�|d D �}|S )zk List all the available tags. :rtype: ``list`` of :class:`.CloudSigmaTag` objects z /tags/detail/r� rt c s g | ]}� j |d ��qS r )�_to_tagr r= r2 r3 r� U r� z:CloudSigma_2_0_NodeDriver.ex_list_tags.<locals>.<listcomp>r r )r> ru rz �tagsr2 r= r3 � ex_list_tagsM s 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� rt r �rx ry r� re )r> Ztag_idru rz �tagr2 r2 r3 � ex_get_tagY 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` r7 r r� z/tags/rs r( r r ri )r> r7 Zresource_uuidsr� ru rz rj r2 r2 r3 � ex_create_tagg s �� �z'CloudSigma_2_0_NodeDriver.ex_create_tagc C s" t |d�std��| 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` rD �"Resource doesn't have id attribute)r� rj )�hasattrrg �ex_tag_resources)r> r� rj r2 r2 r3 �ex_tag_resource� s z)CloudSigma_2_0_NodeDriver.ex_tag_resourcec C s| |j dd� }|D ]"}t|d�s(td��|�|j� qtt|��}|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` NrD rm )r7 r� rh r4 r( r ) r� rn rg r� rD r� �setr7 rx ry r� re )r> r� rj r� r� ru rz r2 r2 r3 ro � s � � z*CloudSigma_2_0_NodeDriver.ex_tag_resourcesc C s& d|j }| jj|dd�}|jtjkS )z� Delete a tag. :param tag: Tag to delete. :type tag: :class:`.CloudSigmaTag` :return: ``True`` on success, ``False`` otherwise. :rtype: ``bool`` rh r2 rt r3 )r> rj ru rz r2 r2 r3 � ex_delete_tag� s z'CloudSigma_2_0_NodeDriver.ex_delete_tagc C s d}| j j|dd�}|jS )z� Retrieve account balance information. :return: Dictionary with two items ("balance" and "currency"). :rtype: ``dict`` z /balance/r� rt r rb r2 r2 r3 �ex_get_balance� s z(CloudSigma_2_0_NodeDriver.ex_get_balancec C s d}| j j|dd�}|jS )z� Retrieve pricing information that are applicable to the cloud. :return: Dictionary with pricing information. :rtype: ``dict`` z /pricing/r� rt r rb r2 r2 r3 �ex_get_pricing� s z(CloudSigma_2_0_NodeDriver.ex_get_pricingc C s d}| j j|dd�}|jS )z� Retrieve account current usage information. :return: Dictionary with two items ("balance" and "usage"). :rtype: ``dict`` z/currentusage/r� rt r rb r2 r2 r3 � ex_get_usage� s z&CloudSigma_2_0_NodeDriver.ex_get_usage�allc C sD i }|r||d< |r"d� |�|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`` rN r� r� �/subscriptions/)ru r r )r� rx ry r� �_to_subscriptions)r> rN r� r rz � subscriptionsr2 r2 r3 �ex_list_subscriptions� s � z/CloudSigma_2_0_NodeDriver.ex_list_subscriptionsc C s& d|j }| j|ddd�}|jtjkS )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� rs r? )rD r< rN r r )r> � subscriptionr; rz r2 r2 r3 �!ex_toggle_subscription_auto_renew s �z;CloudSigma_2_0_NodeDriver.ex_toggle_subscription_auto_renewFc 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� rw rs r� r r r )rx ry r� �_to_subscription)r> r� r� r� r� r� rz r{ r2 r2 r3 �ex_create_subscription 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� rt r )r> ru rz Z capabilitiesr2 r2 r3 �ex_list_capabilities: s �z.CloudSigma_2_0_NodeDriver.ex_list_capabilitiesc C s g g }}|d }|d }|r&|d nd}|r6|d nd}|rF|d nd}|rV|d nd} g } |rl| � |� | rz| � | � |d } |d r�| d nd}|d r�| d nd}|r�|d nd}|r�|d nd} |r�| � |� | r�| � | � t| �} | D ]$} t| ��r |� | � q�|� | � q�||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% �ipN�uuid�runtime�ip_v4�ip_v6)r� rq r ) r> r/ r� r� Z ipv4_confZ ipv6_confr� r� Zipv4Zipv6r� r� r� r2 r2 r3 �_parse_ips_from_nicF s6 z-CloudSigma_2_0_NodeDriver._parse_ips_from_nicc C s� g d�}|d }|d }| j �|d tj�}g }g }| j||d�}|d D ](} | j| d�\} } |�| � |�| � qJt|||||| |d�} | S ) N)rE r� r& r� r" r� r7 rN �rX r� r& )r/ r� )r� r� r r� �_extract_valuesr� �extendr ) r> r� r� rD r7 rm r� r� r� r/ Z _public_ipsZ _private_ipsrq r2 r2 r3 r� | s �z"CloudSigma_2_0_NodeDriver._to_nodec C s: g d�}|d }|d }| j ||d�}t||| |d�}|S )N)� description�archr �osZlicensesr� r" r� r7 r� r� )r� r )r> r� r� rD r7 r� r� r2 r2 r3 r � s z#CloudSigma_2_0_NodeDriver._to_imagec C sF |d }|d }|d }|d }|d }i }t |||||| |d�}|S )Nr� r7 r r� rN )rD r7 r r� rN rJ r� )r ) r> r� rD r7 r r� rN r� r~ r2 r2 r3 rJ � s �z#CloudSigma_2_0_NodeDriver._to_drivec C s0 |d }dd� |D �}t |d |d |d�}|S )Nr� c S s g | ] }|d �qS )r� r2 )r� r� r2 r2 r3 r� � r� z5CloudSigma_2_0_NodeDriver._to_tag.<locals>.<listcomp>r� r7 r� )r )r> r� r� rj r2 r2 r3 re � s �z!CloudSigma_2_0_NodeDriver._to_tagc C s, g }|d D ]}| j |d�}|�|� q |S )Nr r )r} r� )r> r� ry r r{ r2 r2 r3 rx � s z+CloudSigma_2_0_NodeDriver._to_subscriptionsc C s� |� dd �rt|d �}nd }|� dd �r8t|d �}nd }|d }t|d |d t|d �|d |d |d |||d |d � }|S ) Nr� r� r� rD r� r� r� rN rI r� r� )r� r r! r� )r> r� r� r� Zobj_uuidr{ r2 r2 r3 r} � s& � z*CloudSigma_2_0_NodeDriver._to_subscriptionc C sr g }|� dg �D ]F}t|d |d |d |d |d |d |d |d d �}|�|� qt|d |d |d �}|S )Nr� ru r� r� r� r� r� r r r� r� r7 r� )r� r# r� r" )r> r� r� r �rulerY r2 r2 r3 rV � s � �z-CloudSigma_2_0_NodeDriver._to_firewall_policyrs c C s2 |r|� � }ni }||d< | jj||||d�}|S )z@ Perform API action and return response object. �dorO )r5 rx ry )r> r; ru rv r r� rz r2 r2 r3 r< � s �z)CloudSigma_2_0_NodeDriver._perform_actionc C s t |t�r|jdkrdS dS )z_ Detect if the provided image is an installation CD. :rtype: ``bool`` ZcdromTF)r� r r� )r> r� r2 r2 r3 r+ � 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`` r2 )r> rX r� r� r) r2 r2 r3 r� � s z)CloudSigma_2_0_NodeDriver._extract_valuesc C sf t � � }|j|krb| j|jd�}|j|kr,qbt � � }|| }||krTd| }t|��t �| j� q|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` )rT zATimed out while waiting for drive transition (timeout=%s seconds))r� rN rU rD � Exceptionr� � DRIVE_TRANSITION_SLEEP_INTERVAL)r> r~ rm �timeoutr� � current_time�delta�msgr2 r2 r3 r- s �z:CloudSigma_2_0_NodeDriver._wait_for_drive_state_transitionc C s i }| j s t| j d |d< |S r� )rh r rf r� r2 r2 r3 r� > s z5CloudSigma_2_0_NodeDriver._ex_connection_class_kwargs)N)NNNN)N)N)NN)rG N)NN)N)N)N)rv N)F)rs NN)Ir4 r5 r6 r� r7 ri r8 r r� ZDRIVE_TRANSITION_TIMEOUTr� r ZPENDING�ERRORrn ZSTOPPEDZPAUSEDr� r rK r� r� r� r� r{ r7 r= r� rp ro rE rG rH rL rM rP r, r. rS rU rW rZ r` ra rc rd rg rk rl rp ro rr rs rt ru rz r| r~ r r� r� r rJ re rx r} rV r< r+ r� r- r� r9 r2 r2 r0 r3 r � s� � � � " ' % $ $ � $ 6 � � *r )>r� r� r� r5 r\ Z simplejsonr r� Zlibcloud.utils.py3r r Zlibcloud.utils.miscr r r Zlibcloud.common.baser r r Zlibcloud.common.typesr r Zlibcloud.common.cloudsigmar r r r r Zlibcloud.compute.typesr r Zlibcloud.compute.baser r r r r Zlibcloud.utils.iso8601r r �__all__r r: rA r rL rW r r� r� r� r� r r� r! r r r" r# r r r r2 r2 r2 r3 �<module> s^ j 8 % 13!
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка