Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/compute/drivers/__pycache__/cloudstack.cpython-39.pyc
Ðазад
a q�h� � - @ s� d dl mZ d dlZd dlZd dlmZ d dlmZ d dlmZ d dl m Z d dl m Z m Z mZmZ d dl mZmZmZ d d l mZ d d lmZmZ d d lmZmZ d d lmZ d d� Zde d�de d�de d�de d�de d�de d�de d�de d�de d�de d�de d�de d�d e d�d e d�d e d�d e d�d e d�d!e d�d"e d�d#e d�d$�d%e d�d&e d�de d�d'e d�d(e d�d)e d�d*e d�d+e d�d,e d�d-e d�d.e d�d/e d�d0e d�d1e d�d2e d�d#e d�d3e d�d4�d5e d�d6ed�d7e d�d-e d�de d�de d�d&e d�de d�d8�d5e d�d9e d�d:ed�d e d�de d�d;e d�de d�d&e d�d<�d=e d�d>ed�d?ed�d@ed�d9e d�d:e d�dAed�dBed�dCed�dDed�dEed�dFed�dGed�dHed�dIed�dJed�dKed�dLed�dMed�dNed�dOed�dPed�dQed�dRed�de d�dSe d�dTed�dUed�dVed�dWed�dXed�dYed�dZed�d[ed�d\ed�d]ed�d^ed�d_ed�d`ed�da�'dbdce d�idde d�d2e d�d#e d�dee d�df�d=e d�d9e d�d:e d�dge d�dhed�died�dje d�dk�d=e d�d9e d�d:e d�dde d�d2e d�d#e d�dl�dm� Z G dndo� doe �Z G dpdq� dqe!�Z"G drds� dse!�Z#G dtdu� due!�Z$G dvdw� dwe!�Z%G dxdy� dye!�Z&G dzd{� d{e!�Z'G d|d}� d}e!�Z(G d~d� de!�Z)G d�d�� d�e!�Z*G d�d�� d�e!�Z+G d�d�� d�e!�Z,G d�d�� d�e!�Z-G d�d�� d�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�e!�Z5G d�d�� d�e e �Z6dS )�� )�with_statementN)�b)�urlparse)�Provider)�CloudStackDriverMixIn)�Node� NodeDriver� NodeImage� NodeLocation)�NodeSize� StorageVolume�VolumeSnapshot)�KeyPair)� NodeState� LibcloudError)�KeyPairDoesNotExistError�StorageVolumeState)�is_private_subnetc C sV z t | �W S tyP } z.t| ��� dkr8W Y d }~dS |�W Y d }~n d }~0 0 d S )NZ unlimited���)�int� ValueError�str�lower)�value�e� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/libcloud/compute/drivers/cloudstack.py�transform_int_or_unlimited# s r Zbroadcastdomaintype)�key_name�transform_func� traffictypeZzonenameZnetworkofferingnameZnetworkofferingdisplaytextZnetworkofferingavailabilityZissystem�state�dns1�dns2�typeZacltypeZsubdomainaccess� networkdomainZphysicalnetworkidZcanusefordeploy�gateway�netmask�vpcid� projectid)Zbroadcast_domain_type� traffic_type� zone_nameZnetwork_offering_nameZ network_offeringdisplay_textZ network_offering_availabilityZ is_systemr! r" r# r$ Zacl_typeZsubdomain_access�network_domainZphysical_network_idZcan_use_for_deployr& r' �vpc_id� project_id�haenable�zoneid�keypair�password� templateidZ templatenameZtemplatdisplaytextZpasswordenabled�serviceofferingidZserviceofferingnameZ rootdeviceidZrootdevicetype� hypervisor�project�nic)r/ �zone_idr+ r r2 Zimage_idZ image_nameZtemplate_display_textZpassword_enabledZsize_idZ size_nameZroot_device_idZroot_device_typer5 r6 r. znics:�createdZdeviceid�virtualmachineid)r9 Z device_idZ instance_idZserviceoffering_idr! Z volume_typer8 r+ �domain�domainid� vpcofferingid)r9 r; � domain_idr, r! �vpc_offering_idr+ r8 �account� cpuavailable�cpulimit�cputotal� ipavailable�iplimit�iptotal�memoryavailable� memorylimit� memorytotal�networkavailable� networklimit� networktotal�primarystorageavailable�primarystoragelimit�primarystoragetotal�secondarystorageavailable�secondarystoragelimit�secondarystoragetotal�snapshotavailable� snapshotlimit� snapshottotal�tags�templateavailable� templatelimit� templatetotal� vmavailable�vmlimit� vmrunning�vmtotal�volumeavailable� volumelimit� volumetotal� vpcavailable�vpclimit�vpctotal)'r@ rA rB rC r; r< rD rE rF rG rH rI rJ rK rL rM rN rO rP rQ rR rS rT rU r! rV rW rX rY rZ r[ r\ r] r^ r_ r` ra rb rc Z secondary_ipZ secondaryip� fordisplay�removed)� for_displayr6 r. re �dpd� esplifetime� ikelifetime�name)r@ r; r> rg � esp_lifetime� ike_lifetimerj )r@ r; r> rf r6 r. ) �network�node�volume�vpcr6 r7 � vpngateway�vpncustomergateway� vpnconnectionc @ sf e Zd ZdZdd� Zdd� Zddd�Zdd d �Zd d � Zdd� Z ddd�Z dd� Z dd� Z dd� Z dS )�CloudStackNodezB Subclass of Node so we can expose our extension methods. c C s | j �| �S )z@ Allocate a public IP and bind it to this node. )�driver�ex_allocate_public_ip��selfr r r rv � s z$CloudStackNode.ex_allocate_public_ipc C s | j �| |�S )z; Release a public IP that this node holds. �ru �ex_release_public_ip)rx �addressr r r rz � s z#CloudStackNode.ex_release_public_ipNc C s | j j| ||||d�S )zI Add a NAT/firewall forwarding rule for a port or ports. )rn r{ �protocol� start_port�end_port)ru � ex_create_ip_forwarding_rule)rx r{ r| r} r~ r r r r � s �z+CloudStackNode.ex_create_ip_forwarding_ruleTc C s | j j| |||||||d�S )z? Add a port forwarding rule for port or ports. )rn r{ � private_port� public_portr| �public_end_port�private_end_port� openfirewall)ru � ex_create_port_forwarding_rule)rx r{ r� r� r| r� r� r� r r r r� � s �z-CloudStackNode.ex_create_port_forwarding_rulec C s | j j| |d�S )z0 Delete a port forwarding rule. �rn �rule)ru � ex_delete_ip_forwarding_rule�rx r� r r r r� � s z+CloudStackNode.ex_delete_ip_forwarding_rulec C s | j j| |d�S )z- Delete a NAT/firewall rule. r� )ru � ex_delete_port_forwarding_ruler� r r r r� � s z-CloudStackNode.ex_delete_port_forwarding_rulec C s | j j| |d�S )z) Restore virtual machine )rn �template)ru � ex_restore)rx r� r r r r� � s zCloudStackNode.ex_restorec C s | j j| |d�S )z6 Change virtual machine offering/size )rn �offering)ru �ex_change_node_size)rx r� r r r r� � s z"CloudStackNode.ex_change_node_sizec C s | j j| d�S )z3 Starts a stopped virtual machine. �rn )ru �ex_startrw r r r r� � s zCloudStackNode.ex_startc C s | j j| d�S )z2 Stops a running virtual machine. r� )ru �ex_stoprw r r r r� � s zCloudStackNode.ex_stop)N)NNT)N)�__name__� __module__� __qualname__�__doc__rv rz r r� r� r� r� r� r� r� r r r r rt � s � � rt c @ s2 e Zd ZdZd dd�Zdd� Zdd� Zd d � ZdS ) �CloudStackAddressan A public IP address. :param id: UUID of the Public IP :type id: ``str`` :param address: The public IP address :type address: ``str`` :param associated_network_id: The ID of the network where this address has been associated with :type associated_network_id: ``str`` :param vpc_id: VPC the ip belongs to :type vpc_id: ``str`` :param virtualmachine_id: The ID of virutal machine this address is assigned to :type virtualmachine_id: ``str`` Nc C s( || _ || _|| _|| _|| _|| _d S �N)�idr{ ru �associated_network_idr- �virtualmachine_id)rx r� r{ ru r� r- r� r r r �__init__ s zCloudStackAddress.__init__c C s | j j| d� d S )N�r{ ry rw r r r �release s zCloudStackAddress.releasec C s | j S r� r� rw r r r �__str__" s zCloudStackAddress.__str__c C s | j |j u o| j|jkS r� �� __class__r� �rx �otherr r r �__eq__% s zCloudStackAddress.__eq__)NNN)r� r� r� r� r� r� r� r� r r r r r� s � r� c @ s" e Zd ZdZddd�Zdd� ZdS )�CloudStackFirewallRulez A firewall rule. Nc C s4 || _ || _|| _|| _|| _|| _|| _|| _dS )a� A Firewall rule. @note: This is a non-standard extension API, and only works for CloudStack. :param id: Firewall Rule ID :type id: ``int`` :param address: External IP address :type address: :class:`CloudStackAddress` :param cidr_list: cidr list :type cidr_list: ``str`` :param protocol: TCP/IP Protocol (TCP, UDP) :type protocol: ``str`` :param icmp_code: Error code for this icmp message :type icmp_code: ``int`` :param icmp_type: Type of the icmp message being sent :type icmp_type: ``int`` :param start_port: start of port range :type start_port: ``int`` :param end_port: end of port range :type end_port: ``int`` :rtype: :class:`CloudStackFirewallRule` N)r� r{ � cidr_listr| � icmp_code� icmp_typer} r~ ) rx r� r{ r� r| r� r� r} r~ r r r r� . s %z CloudStackFirewallRule.__init__c C s | j |j u o| j|jkS r� r� r� r r r r� \ s z CloudStackFirewallRule.__eq__)NNNN�r� r� r� r� r� r� r r r r r� ) s � .r� c @ s" e Zd ZdZddd�Zdd� ZdS )� CloudStackEgressFirewallRulez! A egress firewall rule. Nc C s4 || _ || _|| _|| _|| _|| _|| _|| _dS )a� A egress firewall rule. @note: This is a non-standard extension API, and only works for CloudStack. :param id: Firewall Rule ID :type id: ``int`` :param network_id: the id network network for the egress firwall services :type network_id: ``str`` :param protocol: TCP/IP Protocol (TCP, UDP) :type protocol: ``str`` :param cidr_list: cidr list :type cidr_list: ``str`` :param icmp_code: Error code for this icmp message :type icmp_code: ``int`` :param icmp_type: Type of the icmp message being sent :type icmp_type: ``int`` :param start_port: start of port range :type start_port: ``int`` :param end_port: end of port range :type end_port: ``int`` :rtype: :class:`CloudStackEgressFirewallRule` N)r� � network_idr� r| r� r� r} r~ ) rx r� r� r� r| r� r� r} r~ r r r r� e s &z%CloudStackEgressFirewallRule.__init__c C s | j |j u o| j|jkS r� r� r� r r r r� � s z#CloudStackEgressFirewallRule.__eq__)NNNNr� r r r r r� ` s � /r� c @ s* e Zd ZdZd dd�Zdd� Zdd� ZdS ) �CloudStackIPForwardingRulez) A NAT/firewall forwarding rule. Nc C s( || _ || _|| _|| _|| _|| _dS )a� A NAT/firewall forwarding rule. @note: This is a non-standard extension API, and only works for CloudStack. :param node: Node for rule :type node: :class:`Node` :param id: Rule ID :type id: ``int`` :param address: External IP address :type address: :class:`CloudStackAddress` :param protocol: TCP/IP Protocol (TCP, UDP) :type protocol: ``str`` :param start_port: Start port for the rule :type start_port: ``int`` :param end_port: End port for the rule :type end_port: ``int`` :rtype: :class:`CloudStackIPForwardingRule` N)rn r� r{ r| r} r~ )rx rn r� r{ r| r} r~ r r r r� � s z#CloudStackIPForwardingRule.__init__c C s | j j| d� d S �N�r� )rn r� rw r r r �delete� s z!CloudStackIPForwardingRule.deletec C s | j |j u o| j|jkS r� r� r� r r r r� � s z!CloudStackIPForwardingRule.__eq__)N�r� r� r� r� r� r� r� r r r r r� � s "r� c @ s* e Zd ZdZd dd�Zdd� Zdd� ZdS ) � CloudStackPortForwardingRulez0 A Port forwarding rule for Source NAT. Nc C s4 || _ || _|| _|| _|| _|| _|| _|| _dS )a� A Port forwarding rule for Source NAT. @note: This is a non-standard extension API, and only works for EC2. :param node: Node for rule :type node: :class:`Node` :param rule_id: Rule ID :type rule_id: ``int`` :param address: External IP address :type address: :class:`CloudStackAddress` :param protocol: TCP/IP Protocol (TCP, UDP) :type protocol: ``str`` :param public_port: External port for rule (or start port if public_end_port is also provided) :type public_port: ``int`` :param private_port: Internal node port for rule (or start port if public_end_port is also provided) :type private_port: ``int`` :param public_end_port: End of external port range :type public_end_port: ``int`` :param private_end_port: End of internal port range :type private_end_port: ``int`` :param network_id: The network of the vm the Port Forwarding rule will be created for. Required when public Ip address is not associated with any Guest network yet (VPC case) :type network_id: ``str`` :rtype: :class:`CloudStackPortForwardingRule` N)rn r� r{ r| r� r� r� r� ) rx rn �rule_idr{ r| r� r� r� r� r� r r r r� � s *z%CloudStackPortForwardingRule.__init__c C s | j j| d� d S r� )rn r� rw r r r r� � s z#CloudStackPortForwardingRule.deletec C s | j |j u o| j|jkS r� r� r� r r r r� s z#CloudStackPortForwardingRule.__eq__)NNNr� r r r r r� � s � 3r� c @ s" e Zd ZdZddd�Zdd� ZdS )�CloudStackNetworkACLListz) a Network ACL for the given VPC Nc C s" || _ || _|| _|| _|| _dS )aQ a Network ACL for the given VPC @note: This is a non-standard extension API, and only works for Cloudstack. :param acl_id: ACL ID :type acl_id: ``int`` :param name: Name of the network ACL List :type name: ``str`` :param vpc_id: Id of the VPC associated with this network ACL List :type vpc_id: ``string`` :param description: Description of the network ACL List :type description: ``str`` :rtype: :class:`CloudStackNetworkACLList` N�r� rj r- ru � description)rx �acl_idrj r- ru r� r r r r� s z!CloudStackNetworkACLList.__init__c C s d| j | j| j| jj| jf S )NzP<CloudStackNetworkACLList: id=%s, name=%s, vpc_id=%s, driver=%s, description=%s>r� rw r r r �__repr__& s ��z!CloudStackNetworkACLList.__repr__)N�r� r� r� r� r� r� r r r r r� s r� c @ s" e Zd ZdZddd�Zdd� ZdS )�CloudStackNetworkACLzL a ACL rule in the given network (the network has to belong to VPC) Nc C s4 || _ || _|| _|| _|| _|| _|| _|| _dS )a� a ACL rule in the given network (the network has to belong to VPC) @note: This is a non-standard extension API, and only works for Cloudstack. :param id: the ID of the ACL Item :type id ``int`` :param protocol: the protocol for the ACL rule. Valid values are TCP/UDP/ICMP/ALL or valid protocol number :type protocol: ``string`` :param acl_id: Name of the network ACL List :type acl_id: ``str`` :param action: scl entry action, allow or deny :type action: ``string`` :param cidr_list: the cidr list to allow traffic from/to :type cidr_list: ``str`` :param start_port: the starting port of ACL :type start_port: ``str`` :param end_port: the ending port of ACL :type end_port: ``str`` :param traffic_type: the traffic type for the ACL,can be Ingress or Egress, defaulted to Ingress if not specified :type traffic_type: ``str`` :rtype: :class:`CloudStackNetworkACL` N)r� r| r� �actionr� r} r~ r* ) rx r� r| r� r� r� r} r~ r* r r r r� 2 s 'z CloudStackNetworkACL.__init__c C s | j |j u o| j|jkS r� r� r� r r r r� b s zCloudStackNetworkACL.__eq__)Nr� r r r r r� - s � 0r� c @ s e Zd ZdZdd� Zdd� ZdS )�CloudStackDiskOfferingz, A disk offering within CloudStack. c C s || _ || _|| _|| _d S r� �r� rj �size� customizable)rx r� rj r� r� r r r r� k s z CloudStackDiskOffering.__init__c C s | j |j u o| j|jkS r� r� r� r r r r� q s z CloudStackDiskOffering.__eq__Nr� r r r r r� f s r� c @ s" e Zd ZdZddd�Zdd� ZdS )�CloudStackNetworkz2 Class representing a CloudStack Network. Nc C s2 || _ || _|| _|| _|| _|| _|p*i | _d S r� )� displaytextrj �networkofferingidr� r0 ru �extra)rx r� rj r� r� r0 ru r� r r r r� z s zCloudStackNetwork.__init__c C s" d| j | j| j| j| j| jjf S )Nz_<CloudStackNetwork: displaytext=%s, name=%s, networkofferingid=%s, id=%s, zoneid=%s, driver=%s>)r� rj r� r� r0 ru rw r r r r� � s ��zCloudStackNetwork.__repr__)Nr� r r r r r� u s � r� c @ s" e Zd ZdZddd�Zdd� ZdS )�CloudStackNetworkOfferingz; Class representing a CloudStack Network Offering. Nc C s8 || _ || _|| _|| _|| _|| _|| _|p0i | _d S r� )� display_textrj � guest_ip_typer� �service_offering_id�for_vpcru r� ) rx rj r� r� r� r� r� ru r� r r r r� � s z"CloudStackNetworkOffering.__init__c C s& d| j | j| j| j| j| j| jjf S )Nz}<CloudStackNetworkOffering: id=%s, name=%s, display_text=%s, guest_ip_type=%s, service_offering_id=%s, for_vpc=%s, driver=%s>)r� rj r� r� r� r� ru rw r r r r� � s ��z"CloudStackNetworkOffering.__repr__)Nr� r r r r r� � s � r� c @ s* e Zd ZdZd dd�Zdd� Zdd� ZdS ) � CloudStackNicz< Class representing a CloudStack Network Interface. Nc C s> || _ || _|| _|| _|| _|| _|| _|| _| p6i | _d S r� � r� r� �net_maskr& � ip_address� is_default� mac_addressru r� ) rx r� r� r� r& r� r� r� ru r� r r r r� � s zCloudStackNic.__init__c C s* d| j | j| j| j| j| j| j| jjf S )Nzv<CloudStackNic: id=%s, network_id=%s, net_mask=%s, gateway=%s, ip_address=%s, is_default=%s, mac_address=%s, driver%s>) r� r� r� r& r� r� r� ru rj rw r r r r� � s ��zCloudStackNic.__repr__c C s | j |j u o| j|jkS r� r� r� r r r r� � s zCloudStackNic.__eq__)N)r� r� r� r� r� r� r� r r r r r� � s � r� c @ s" e Zd ZdZddd�Zdd� ZdS )� CloudStackVPCz. Class representing a CloudStack VPC. Nc C s8 || _ || _|| _|| _|| _|| _|| _|p0i | _d S r� )r� rj r? r� r8 �cidrru r� ) rx rj r? r� r� ru r8 r� r� r r r r� � s zCloudStackVPC.__init__c C s& d| j | j| j| j| jj | j| jf S )Nzd<CloudStackVPC: name=%s, vpc_offering_id=%s, id=%s, cidr=%s, driver=%s, zone_id=%s, display_text=%s>)rj r? r� r� ru r8 r� rw r r r r� � s ��zCloudStackVPC.__repr__)NNNr� r r r r r� � s � r� c @ s" e Zd ZdZddd�Zdd� ZdS )�CloudStackVPCOfferingz7 Class representing a CloudStack VPC Offering. Nc C s& || _ || _|| _|| _|p i | _d S r� )rj r� r� ru r� )rx rj r� r� ru r� r r r r� � s z CloudStackVPCOffering.__init__c C s d| j | j| j| jj f S )NzC<CloudStackVPCOffering: name=%s, display_text=%s, id=%s, driver=%s>)rj r� r� ru rw r r r r� � s ��z CloudStackVPCOffering.__repr__)Nr� r r r r r� � s � r� c @ s6 e Zd ZdZd dd�Zedd� �Zdd� Zd d � ZdS ) �CloudStackVpnGatewayz6 Class representing a CloudStack VPN Gateway. Nc C s8 || _ || _|| _|| _|| _|| _|| _|p0i | _d S r� �r� r@ r; r> � public_ipr- ru r� ) rx r� r@ r; r> r� r- ru r� r r r r� � s z CloudStackVpnGateway.__init__c C s6 | j �� D ]}| j|jkr | S q td| j ��d S )NzVPC with id=%s not found)ru � ex_list_vpcsr- r� r )rx rp r r r rp � s zCloudStackVpnGateway.vpcc C s | j j| d�S )N)� vpn_gateway)ru �ex_delete_vpn_gatewayrw r r r r� s zCloudStackVpnGateway.deletec C s& d| j | j| j| j| j| j| jjf S )Nzf<CloudStackVpnGateway: account=%s, domain=%s, domain_id=%s, id=%s, public_ip=%s, vpc_id=%s, driver=%s>)r@ r; r> r� r� r- ru rj rw r r r r� s ��z CloudStackVpnGateway.__repr__)N) r� r� r� r� r� �propertyrp r� r� r r r r r� � s � r� c @ s* e Zd ZdZd dd�Zdd� Zdd� ZdS ) � CloudStackVpnCustomerGatewayz? Class representing a CloudStack VPN Customer Gateway. Nc C s8 || _ || _|| _|| _|| _|| _|| _|p0i | _d S r� �r� r� � esp_policyr& � ike_policy� ipsec_pskru r� ) rx r� r� r� r& r� r� ru r� r r r r� s z%CloudStackVpnCustomerGateway.__init__c C s | j j| d�S )N)�vpn_customer_gateway)ru � ex_delete_vpn_customer_gatewayrw r r r r� s �z#CloudStackVpnCustomerGateway.deletec C s& d| j | j| j| j| j| j| jjf S )Nzv<CloudStackVpnCustomerGateway: id=%s, cidr_list=%s, esp_policy=%s, gateway=%s, ike_policy=%s, ipsec_psk=%s, driver=%s>)r� r� r� r& r� r� ru rj rw r r r r� $ s ��z%CloudStackVpnCustomerGateway.__repr__)N)r� r� r� r� r� r� r� r r r r r� s � r� c @ sB e Zd ZdZd dd�Zedd� �Zedd� �Zd d � Zd d � Z dS )�CloudStackVpnConnectionz9 Class representing a CloudStack VPN Connection. Nc C s2 || _ || _|| _|| _|| _|| _|p*i | _d S r� �r� �passive�vpn_customer_gateway_id�vpn_gateway_idr! ru r� )rx r� r� r� r� r! ru r� r r r r� 0 s z CloudStackVpnConnection.__init__c C s< z| j j| jd�d W S ty6 td| j ��Y n0 d S )N�r� r z)VPN Customer Gateway with id=%s not found)ru � ex_list_vpn_customer_gatewaysr� � IndexErrorr rw r r r r� : s �� �z,CloudStackVpnConnection.vpn_customer_gatewayc C s< z| j j| jd�d W S ty6 td| j ��Y n0 d S )Nr� r z VPN Gateway with id=%s not found)ru �ex_list_vpn_gatewaysr� r� r rw r r r r� C s �z#CloudStackVpnConnection.vpn_gatewayc C s | j j| d�S )N)�vpn_connection)ru �ex_delete_vpn_connectionrw r r r r� K s z CloudStackVpnConnection.deletec C s" d| j | j| j| j| j| jjf S )Nzp<CloudStackVpnConnection: id=%s, passive=%s, vpn_customer_gateway_id=%s, vpn_gateway_id=%s, state=%s, driver=%s>)r� r� r� r� r! ru rj rw r r r r� N s ��z CloudStackVpnConnection.__repr__)N) r� r� r� r� r� r� r� r� r� r� r r r r r� , s � r� c @ s e Zd ZdZdd� Zdd� ZdS )�CloudStackRouterz1 Class representing a CloudStack Router. c C s( || _ || _|| _|| _|| _|| _d S r� �r� rj r! r� r- ru )rx r� rj r! r� r- ru r r r r� [ s zCloudStackRouter.__init__c C s" d| j | j| j| j| j| jjf S )NzP<CloudStackRouter: id=%s, name=%s, state=%s, public_ip=%s, vpc_id=%s, driver=%s>r� rw r r r r� c s ��zCloudStackRouter.__repr__Nr� r r r r r� V s r� c @ s" e Zd ZdZddd�Zdd� ZdS )�CloudStackProjectz2 Class representing a CloudStack Project. Nc C s& || _ || _|| _|| _|p i | _d S r� �r� rj r� ru r� )rx r� rj r� ru r� r r r r� o s zCloudStackProject.__init__c C s d| j | j| j| jjf S )Nz><CloudStackProject: id=%s, name=%s, display_text=%s,driver=%s>)r� r� rj ru rw r r r r� v s ��zCloudStackProject.__repr__)Nr� r r r r r� j s r� c @ s e Zd ZdZdd� Zdd� ZdS )�CloudStackAffinityGroupz8 Class representing a CloudStack AffinityGroup. c C s4 || _ || _|| _|| _|| _|| _|| _|| _dS )a� A CloudStack Affinity Group. @note: This is a non-standard extension API, and only works for CloudStack. :param id: CloudStack Affinity Group ID :type id: ``str`` :param account: An account for the affinity group. Must be used with domainId. :type account: ``str`` :param description: optional description of the affinity group :type description: ``str`` :param domain: the domain name of the affinity group :type domain: ``str`` :param domainid: domain ID of the account owning the affinity group :type domainid: ``str`` :param name: name of the affinity group :type name: ``str`` :param group_type: the type of the affinity group :type group_type: :class:`CloudStackAffinityGroupType` :param virtualmachine_ids: virtual machine Ids associated with this affinity group :type virtualmachine_ids: ``str`` :rtype: :class:`CloudStackAffinityGroup` N)r� r@ r� r; r< rj r$ �virtualmachine_ids) rx r� r@ r� r; r< rj � group_typer� r r r r� � s %z CloudStackAffinityGroup.__init__c C s d| j | j| jf S )Nz2<CloudStackAffinityGroup: id=%s, name=%s, type=%s>)r� rj r$ rw r r r r� � s �z CloudStackAffinityGroup.__repr__Nr� r r r r r� } s .r� c @ s e Zd ZdZdd� Zdd� ZdS )�CloudStackAffinityGroupTypez< Class representing a CloudStack AffinityGroupType. c C s || _ dS )a3 A CloudStack Affinity Group Type. @note: This is a non-standard extension API, and only works for CloudStack. :param type_name: the type of the affinity group :type type_name: ``str`` :rtype: :class:`CloudStackAffinityGroupType` N�r$ )rx � type_namer r r r� � s z$CloudStackAffinityGroupType.__init__c C s d| j S )Nz&<CloudStackAffinityGroupType: type=%s>r� rw r r r r� � s z$CloudStackAffinityGroupType.__repr__Nr� r r r r r� � s r� c s� e Zd ZdZdZdZdZejZ ddgiZ e j e j e je je je je je jd�Zejejejejejejejejejejd� Zdԇ fd d � Zd�d d�Z dd� Z d�dd�Z d�dd�Z d�dd�Z d�dd�Z!d�dd�Z"d�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-� Z+d�d.d/�Z,d�d0d1�Z-d2d3� Z.d�d4d5�Z/d�d6d7�Z0d�d8d9�Z1d:d;� Z2d<d=� Z3d�d>d?�Z4d@dA� Z5d�dBdC�Z6dDdE� Z7d�dFdG�Z8d�dHdI�Z9dJdK� Z:dLdM� Z;dNdO� Z<dPdQ� Z=dRdS� Z>dTdU� Z?d�dVdW�Z@dXdY� ZAdZd[� ZBd�d\d]�ZCd^d_� ZDd`da� ZEd�dbdc�ZFddde� ZGd�dfdg�ZHd�dhdi�ZIdjdk� ZJd�dldm�ZKd�dndo�ZLdpdq� ZMd�drds�ZNd�dtdu�ZOdvdw� ZPdxdy� ZQdzd{� ZRd|d}� ZSd~d� ZTd�d�� ZUd�d�� ZVd�d�� ZWd�d�� ZXd�d�� ZYd�d�� ZZd�d�d��Z[d�d�� Z\d�d�� Z]d�d�� Z^d�d�� Z_d�d�� Z`d�d�� Zad�d�d��Zbd�d�� Zcd�d�� Zdd�d�� Zed�d�� Zfd�d�d��Zgd�d�� Zhd�d�d��Zid�d�� Zjd�d�� Zkd�d�d��Zld�d�� Zmd�d�d��Znd�d�d��Zod�d�� Zpd�d�d��Zqd�d�d��Zrd�d�� Zsd�d�d��Ztd�d�d��Zud�dÄ Zvd�dń Zwd�d�dDŽZxd�dɄ Zyd�d˄ Zzd�d̈́ Z{d�dτ Z|d�dф Z}d�dӄ Z~� ZS )��CloudStackNodeDrivera3 Driver for the CloudStack API. :cvar host: The host where the API can be reached. :cvar path: The path where the API can be reached. :cvar async_poll_frequency: How often (in seconds) to poll for async job completion. :type async_poll_frequency: ``int``Z CloudStackZ cloudstackzhttp://cloudstack.org/� create_nodeZgenerates_password)ZRunningZStarting� MigratingZStoppedZStoppingZ Destroyed� Expunging�Error) ZCreatingZ Destroyingr� ZDestroyZExpungedZ AllocatedZReadyZ SnapshottingZ UploadErrorr� NTc s� |r`t � |�} | j}| j} | j�d�} t| �dkrJ| j}| dkrDdnd}q|| d }t| d �}n |rh|n| j}|rv|n| j}|dur�|| _|dur�|| _| jt j kr�|r�|s�t d��t t | �j|||||d � dS ) a� :inherits: :class:`NodeDriver.__init__` :param host: The host where the API can be reached. (required) :type host: ``str`` :param path: The path where the API can be reached. (required) :type path: ``str`` :param url: Full URL to the API endpoint. Mutually exclusive with host and path argument. :type url: ``str`` �:� �httpsi� �P r NzdWhen instantiating CloudStack driver directly you also need to provide url or host and path argument)�key�secret�secure�host�port)r �path�scheme�netloc�split�lenr r� r$ r � CLOUDSTACK� Exception�superr� r� ) rx r� r� r� r� r r �url�args�kwargs�parsedr r �r� r r r� � s0 �z CloudStackNodeDriver.__init__c C s� ddi}|d ur|j |d< | jd|dd�}g }|�dg �D ]j}|d |d |d |d d �}|�d d �}|d ur�|�d |d i� |�t|d |d | jj|d�� q:|S )NZtemplatefilter� executabler0 Z listTemplates�GET��command�params�methodr� r5 �format� ostypenamer� �r5 r �osr� r� r� rj �r� rj ru r� )r� � _sync_request�get�update�appendr � connectionru )rx �locationr ZimgsZimages�imgr� r� r r r � list_images( s2 � �� � z CloudStackNodeDriver.list_imagesc C sD | � d�}g }|d D ](}tt|d �|d d| �}|�|� q|S )z: :rtype ``list`` of :class:`NodeLocation` Z listZones�zoner� rj �Unknown)r r r r )rx �locs� locations�locr r r r �list_locationsE s � z#CloudStackNodeDriver.list_locationsc sT i }|r|j |d< |dur$|j |d< | jd|d�}| jd|d�}| �d�}| �d�}i }|�d g �D ]>} d | vrrqdt| d �} | |vr�i || < | d || | d < qdg } |�d g �D �]�} |�t| d �i ��� } t| �} | j| | d�� |�t| d �i ��� }� fdd�|D �}|� jd< g }|D ]^} |�dg �D ]J�t�d �� j k�r4t � �d | �d � � �d �d �}|� |� �q4�q$|� jd< g }|�dg �D ]��t�d �� j k�r�� �fdd�|�d g �D �} t � �d | d �d � � �d �d �d �d �}| d j � jv�r,� j� | d j � |� |� �q�|� jd < | � � � q�| S ) a� @inherits: :class:`NodeDriver.list_nodes` :keyword project: Limit nodes returned to those configured under the defined project. :type project: :class:`.CloudStackProject` :keyword location: Limit nodes returned to those in the defined location. :type location: :class:`.NodeLocation` :rtype: ``list`` of :class:`CloudStackNode` r) Nr0 �listVirtualMachines�r �listPublicIpAddresses�listPortForwardingRules�listIpForwardingRules�publicipaddressr: r� � ipaddress�virtualmachine��data� public_ipsc s g | ]\}}t ||� jd ��qS ��r� r{ ru �r� ru ��.0r{ Z address_idr� r r � <listcomp>� s ��z3CloudStackNodeDriver.list_nodes.<locals>.<listcomp>� ip_addresses�ipforwardingruler| � startport�endport�ip_forwarding_rules�portforwardingrulec s4 g | ],}|d �d krt |d |d � jd��qS )r- r� r3 r4 �r6 �a�rn �rr r r7 � s ��r � publicport� privateport� publicendport�privateendport�port_forwarding_rules)r� r r r �keys�list�_to_node�itemsr� r� �upperr r� r{ r1 )rx r6 r r �vms�addrsrF r< Zpublic_ips_map�addrZvm_id�nodes�vmr1 � addresses�rulesr� r r@ r � list_nodesS sv � � � � z CloudStackNodeDriver.list_nodesc s d|i}i }|r$|j |d< |j |d< | jd|d�}|sBtd| ��|d d }| jd|d�}i }|�d g �D ] } d | vrzql| d || d < ql| j|t|�� �d �� � fd d�|�� D �} | � jd< g } d |i} | D ]f} | jd| d�} | �dg �D ]F�t �d �� j kr�t � �d | �d � � �d �d �}| � |� q�q�| � jd< g } | � � }| jd| d�} | �dg �D ]��t �d �� j k�rj�fdd�|D �} t� �d | d �d � � �d �d �d �d �}| d j� jv�r� j� | d j� | � |� �qj| � jd < � S ) ae Return a Node object based on its ID. :param node_id: The id of the node :type node_id: ``str`` :keyword project: Limit node returned to those configured under the defined project. :type project: :class:`.CloudStackProject` :rtype: :class:`CloudStackNode` r� r) r' r( zNode '%s' not foundr. r r) r, r: r- r/ c s g | ]\}}t ||� jd ��qS r2 r4 r5 r� r r r7 � s ��z4CloudStackNodeDriver.ex_get_node.<locals>.<listcomp>r8 r+ r9 r| r: r; r< r* r= c s g | ]}|j � d kr|�qS �r- r� r> )rA r r r7 � s �rB rC rD rE rF )r� r r r rI rH rG rJ r� r r� rK r �ex_list_public_ipsr� r{ r1 )rx Znode_idr6 Zlist_nodes_argsZ list_ips_argsrL rP rM r1 rN rQ rR Z list_fw_rules�resultr� r r@ r � ex_get_node� sv � � � � � � z CloudStackNodeDriver.ex_get_nodec C sZ | j ddd�}g }|d D ]:}d|d i}|�t|d |d |d d d d | |d �� q|S ) z6 :rtype ``list`` of :class:`NodeSize` ZlistServiceOfferingsr �r r Zserviceoffering�cpuZ cpunumberr� rj Zmemoryr �r� )r r r )rx r Zszs�sizes�szr� r r r � list_sizes� s � � z CloudStackNodeDriver.list_sizesFc C sL | j d|||||||| | | | | ||d�}| jd|dd�d }| j|d�}|S )am Create a new node @inherits: :class:`NodeDriver.create_node` :keyword networks: Optional list of networks to launch the server into. :type networks: ``list`` of :class:`.CloudStackNetwork` :keyword project: Optional project to create the new node under. :type project: :class:`.CloudStackProject` :keyword diskoffering: Optional disk offering to add to the new node. :type diskoffering: :class:`.CloudStackDiskOffering` :keyword ex_keyname: Name of existing keypair :type ex_keyname: ``str`` :keyword ex_userdata: String containing user data :type ex_userdata: ``str`` :keyword ex_security_groups: List of security groups to assign to the node :type ex_security_groups: ``list`` of ``str`` :keyword ex_displayname: String containing instance display name :type ex_displayname: ``str`` :keyword ex_ip_address: String with ipaddress for the default nic :type ex_ip_address: ``str`` :keyword ex_start_vm: Boolean to specify to start VM after creation Default Cloudstack behaviour is to start a VM, if not specified. :type ex_start_vm: ``bool`` :keyword ex_rootdisksize: String with rootdisksize for the template :type ex_rootdisksize: ``str`` :keyword ex_affinity_groups: List of affinity groups to assign to the node :type ex_affinity_groups: ``list`` of :class:`.CloudStackAffinityGroup` :rtype: :class:`.CloudStackNode` N)rn rj r� �imager �networks� diskoffering� ex_keyname� ex_userdata�ex_security_groups�ex_displayname� ex_ip_address� ex_start_vm�ex_rootdisksize�ex_affinity_groupsZdeployVirtualMachiner r r. �r0 )�_create_args_to_params�_async_requestrI )rx rj r� r^ r r_ r6 r` ra rb rc rd re rf rg rh � server_paramsr0 rn r r r r� s$ 7� �� z CloudStackNodeDriver.create_nodec C s( i }|r||d< | r | |d< |r*|j |d< |r8|j |d< |rH|j |d< n| �� d j |d< |rzd�dd � |D ��}||d < |r�|j |d < |r�|j |d < | r�| |d < | r�t�t| ���d�} | |d< | r�d�| �} | |d< | r�| |d< |r�||d< |d u�r||d< |�r$d�dd� |D ��}||d< |S )Nrj � displaynamer4 r3 r0 r �,c S s g | ]}t |j��qS r )r r� )r6 rm r r r r7 e � z?CloudStackNodeDriver._create_args_to_params.<locals>.<listcomp>Z networkidsr) Zdiskofferingidr1 �asciiZuserdataZsecuritygroupnamesr- Z rootdisksizeZstartvmc s s | ] }|j V qd S r� r� �r6 �agr r r � <genexpr>� ro z>CloudStackNodeDriver._create_args_to_params.<locals>.<genexpr>�affinitygroupids)r� r& �join�base64� b64encoder �decode)rx rn rj r� r^ r r_ r6 r` ra rb rc rd re rf rg rh rl Zaffinity_group_idsr r r rj I sJ z+CloudStackNodeDriver._create_args_to_paramsc C s* d|j i}|r||d< | jd|dd� dS )a1 @inherits: :class:`NodeDriver.reboot_node` :type node: :class:`CloudStackNode` :keyword ex_expunge: If true is passed, the vm is expunged immediately. False by default. :type ex_expunge: ``bool`` :rtype: ``bool`` r� ZexpungeZdestroyVirtualMachiner r T�r� rk )rx rn Z ex_expunger r r r � destroy_node� s ��z!CloudStackNodeDriver.destroy_nodec C s | j dd|jidd� dS )z� @inherits: :class:`NodeDriver.reboot_node` :type node: :class:`CloudStackNode` :rtype: ``bool`` ZrebootVirtualMachiner� r r T�rk r� )rx rn r r r � reboot_node� s �z CloudStackNodeDriver.reboot_nodec C s4 d|j i}|r|j |d< | jd|dd�}|d d S )z� Restore virtual machine :param node: Node to restore :type node: :class:`CloudStackNode` :param template: Optional new template :type template: :class:`NodeImage` :rtype ``str`` r: r3 ZrestoreVirtualMachiner r r. ry )rx rn r� r �resr r r r� � s �z CloudStackNodeDriver.ex_restorec C s& | j d|j|jd�dd�}|d d S )z� Change offering/size of a virtual machine :param node: Node to change size :type node: :class:`CloudStackNode` :param offering: The new offering :type offering: :class:`NodeSize` :rtype ``str`` ZscaleVirtualMachine)r� r4 r r r. r4 r{ )rx rn r� r} r r r r� � s ��z(CloudStackNodeDriver.ex_change_node_sizec C s" | j dd|jidd�}|d d S )au Starts/Resumes a stopped virtual machine :type node: :class:`CloudStackNode` :param id: The ID of the virtual machine (required) :type id: ``str`` :param hostid: destination Host ID to deploy the VM to parameter available for root admin only :type hostid: ``str`` :rtype ``str`` ZstartVirtualMachiner� r r r. r! r{ �rx rn r} r r r r� � s �z CloudStackNodeDriver.ex_startc C s" | j dd|jidd�}|d d S )z� Stops/Suspends a running virtual machine :param node: Node to stop. :type node: :class:`CloudStackNode` :rtype: ``str`` ZstopVirtualMachiner� r r r. r! r{ r~ r r r r� � s �z CloudStackNodeDriver.ex_stopc C sN g }| j ddd�}|�dd�D ]*}|�t|d |d |d |d d �� q |S ) z| Fetch a list of all available disk offerings. :rtype: ``list`` of :class:`CloudStackDiskOffering` ZlistDiskOfferingsr rX r` r r� rj ZdisksizeZ iscustomizedr� )r r r r� )rx Z diskOfferingsZdiskOfferResponseZ diskOfferDictr r r �ex_list_disk_offerings� s ���z+CloudStackNodeDriver.ex_list_disk_offeringsc C s� i }|dur|j |d< | jd|dd�}|�dg �}g }td }|D ]Z}| �||�}d|v rl| �|d �|d< |�t|d |d |d |d |d | |d �� qB|S )z� List the available networks :param project: Optional project the networks belongs to. :type project: :class:`.CloudStackProject` :rtype ``list`` of :class:`CloudStackNetwork` Nr) Z listNetworksr r rm rV r� rj r� r� r0 rZ )r� r r � RESOURCE_EXTRA_ATTRIBUTES_MAP�_get_extra_dict�_get_resource_tagsr r� ) rx r6 r r} �netsr_ � extra_map�netr� r r r �ex_list_networks s0 � � z%CloudStackNodeDriver.ex_list_networksc C s^ | j ddd�}|�dg �}g }|D ]6}|�t|d |d |d |d |d |d | �� q"|S ) zu List the available network offerings :rtype ``list`` of :class:`CloudStackNetworkOffering` ZlistNetworkOfferingsr rX Znetworkofferingrj r� Z guestiptyper� r4 Zforvpc)r r r r� )rx r} Z netoffersZnetworkofferingsZnetofferr r r �ex_list_network_offerings3 s � � z.CloudStackNodeDriver.ex_list_network_offeringsc C s� t d } |||j|jd�} |dur*|| d< |dur:|| d< |durJ|| d< |durZ|| d< | durj| | d< | jd | d d �} | d } | �| | �} t|||j| d |j| | d �}|S )a Creates a Network, only available in advanced zones. :param display_text: the display text of the network :type display_text: ``str`` :param name: the name of the network :type name: ``str`` :param network_offering: NetworkOffering object :type network_offering: :class:'CloudStackNetworkOffering` :param location: Zone object :type location: :class:`NodeLocation` :param gateway: Optional, the Gateway of this network :type gateway: ``str`` :param netmask: Optional, the netmask of this network :type netmask: ``str`` :param network_domain: Optional, the DNS domain of the network :type network_domain: ``str`` :param vpc_id: Optional, the VPC id the network belongs to :type vpc_id: ``str`` :param project_id: Optional, the project id the networks belongs to :type project_id: ``str`` :rtype: :class:`CloudStackNetwork` rm )r� rj r� r0 Nr& r' r% r( r) Z createNetworkr r r� rZ )r� r� r r� r� )rx r� rj Znetwork_offeringr r& r' r, r- r. r� r rV r� rm r r r �ex_create_networkK s> &� � �z&CloudStackNodeDriver.ex_create_networkc C s |j |d�}| jd|dd� dS )a Deletes a Network, only available in advanced zones. :param network: The network :type network: :class: 'CloudStackNetwork' :param force: Force deletion of the network? :type force: ``bool`` :rtype: ``bool`` )r� ZforcedZ deleteNetworkr r Try )rx rm �forcer r r r �ex_delete_network� s �z&CloudStackNodeDriver.ex_delete_networkc C sL | j ddd�}|�dg �}g }|D ]$}|�t|d |d |d | �� q"|S )zm List the available vpc offerings :rtype ``list`` of :class:`CloudStackVPCOffering` ZlistVPCOfferingsr rX Z vpcofferingrj r� r� )r r r r� )rx r} Z vpcoffersZ vpcofferingsZvpcofferr r r �ex_list_vpc_offerings� s � �z*CloudStackNodeDriver.ex_list_vpc_offeringsc C sv i }|dur|j |d< | jd|dd�}|�dg �}g }|D ]6}|�t|d |d |d |d | |d |d �� q:|S ) z� List the available VPCs :keyword project: Optional project under which VPCs are present. :type project: :class:`.CloudStackProject` :rtype ``list`` of :class:`CloudStackVPC` Nr) ZlistVPCsr r rp rj r= r� r� r0 r� )r� r r r r� )rx r6 r r} Zvpcsr_ rp r r r r� � s( � � z!CloudStackNodeDriver.ex_list_vpcsc C sn i }|dur||d< | j d|dd�}|�dg �}g }|D ]0}|�t|d |d |d |d |d | �� q8|S ) zT List routers :rtype ``list`` of :class:`CloudStackRouter` Nr( Z listRoutersr r �routerr� rj r! �publicip)r r r r� )rx r- r r} �rtsZroutersr� r r r �ex_list_routers� s& � �z$CloudStackNodeDriver.ex_list_routersc C sh t d }||||j|d�}|dur*||d< | jd|dd�} | �| |�} t||j| d || ||| d �} | S ) a� Creates a VPC, only available in advanced zones. :param cidr: the cidr of the VPC. All VPC guest networks' cidrs should be within this CIDR :type display_text: ``str`` :param display_text: the display text of the VPC :type display_text: ``str`` :param name: the name of the VPC :type name: ``str`` :param vpc_offering: the ID of the VPC offering :type vpc_offering: :class:'CloudStackVPCOffering` :param zone_id: the ID of the availability zone :type zone_id: ``str`` :param network_domain: Optional, the DNS domain of the network :type network_domain: ``str`` :rtype: :class:`CloudStackVPC` rp )r� r� rj r= r0 Nr% Z createVPCr r r� rZ )r� r� r r� r� ) rx r� r� rj Z vpc_offeringr8 r, r� r rV r� rp r r r � ex_create_vpc s0 �� � z"CloudStackNodeDriver.ex_create_vpcc C s d|j i}| jd|dd� dS )z� Deletes a VPC, only available in advanced zones. :param vpc: The VPC :type vpc: :class: 'CloudStackVPC' :rtype: ``bool`` r� Z deleteVPCr r Try )rx rp r r r r � ex_delete_vpcJ s �z"CloudStackNodeDriver.ex_delete_vpcc C s~ | j ddd�}|�dg �}g }td }|D ]N}| �||�}d|v rT| �|d �|d< |�t|d |d |d | |d �� q*|S ) zd List the available projects :rtype ``list`` of :class:`CloudStackProject` Z listProjectsr rX r6 rV r� rj r� r� )r r r� r� r� r r� )rx r} ZprojsZprojectsr� Zprojr� r r r �ex_list_projects] s$ � � z%CloudStackNodeDriver.ex_list_projectsc C s� |du r8| � � D ]}|j|ks$|jr qlqtd| ��n4| � � D ] }|j|kr@|jsZ|j} qlq@td| ��|du r�| �� d }||j|jd�}|jr�||d< | jd|dd �}|d } | �| �} t | d ||| | t | d d �d�S )zN Creates a data volume Defaults to the first location Nz$Disk offering with size=%s not foundz"Volume type with name=%s not foundr )rj ZdiskOfferingIdZzoneIdr� Z createVolumer r ro r� rj �rj �r� rj r� r! ru r� ) r r� r� r rj r& r� rk �_to_volume_stater �dict) rx r� rj r �snapshotZex_volume_typeZ diskOfferingr Z requestResultZvolumeResponser! r r r � create_volumey sH � � �� �z"CloudStackNodeDriver.create_volumec C s | j dd|jidd� dS )�" :rtype: ``bool`` Z deleteVolumer� r r T)r r� �rx ro r r r �destroy_volume� s �z#CloudStackNodeDriver.destroy_volumec C s | j d|j|jd�dd� dS )z� @inherits: :class:`NodeDriver.attach_volume` :type node: :class:`CloudStackNode` :rtype: ``bool`` Z attachVolume)r� ZvirtualMachineIdr r Tr{ )rx rn ro Zdevicer r r � attach_volume� s ��z"CloudStackNodeDriver.attach_volumec C s | j dd|jidd� dS )r� Z detachVolumer� r r Tr{ r� r r r � detach_volume� s �z"CloudStackNodeDriver.detach_volumec C s� |r | j dd|jidd�}n| j ddd�}g }td }|�dg �D ]Z}| �||�}d|v rl| �|d �|d< | �|�}|�t|d |d |d || |d �� qB|S ) z� List all volumes :param node: Only return volumes for the provided node. :type node: :class:`CloudStackNode` :rtype: ``list`` of :class:`StorageVolume` � listVolumesr: r r rX ro rV r� rj r� r� ) r r� r� r r� r� r� r r )rx rn �volumes� list_volumesr� �volr� r! r r r r� � s. �� � z!CloudStackNodeDriver.list_volumesc C s� d|i}|r|j |d< | jd|d�}|s4td| ��|d d }td }| �||�}d|v rn| �|d �|d< | �|�}t|d |d ||d | |d �} | S ) av Return a StorageVolume object based on its ID. :param volume_id: The id of the volume :type volume_id: ``str`` :keyword project: Limit volume returned to those configured under the defined project. :type project: :class:`.CloudStackProject` :rtype: :class:`CloudStackNode` r� r) r� �r r zVolume '%s' not foundro r rV rj r� )r� rj r! r� ru r� )r� r r r� r� r� r� r ) rx � volume_idr6 r r� r� r� r� r! ro r r r � ex_get_volume� s �z"CloudStackNodeDriver.ex_get_volumec K s4 |� � }| jd|dd�}|�dg �}| j|d�}|S )a List registered key pairs. :param projectid: list objects by project :type projectid: ``str`` :param page: The page to list the keypairs from :type page: ``int`` :param keyword: List by keyword :type keyword: ``str`` :param listall: If set to false, list only resources belonging to the command's caller; if set to true - list resources that the caller is authorized to see. Default value is false :type listall: ``bool`` :param pagesize: The number of results per page :type pagesize: ``int`` :param account: List resources by account. Must be used with the domainId parameter :type account: ``str`` :param isrecursive: Defaults to false, but if true, lists all resources from the parent specified by the domainId till leaves. :type isrecursive: ``bool`` :param fingerprint: A public key fingerprint to look for :type fingerprint: ``str`` :param name: A key pair name to look for :type name: ``str`` :param domainid: List only resources belonging to the domain specified :type domainid: ``str`` :return: A list of key par objects. :rtype: ``list`` of :class:`libcloud.compute.base.KeyPair` �listSSHKeyPairsr r � sshkeypairri )�copyr r � _to_key_pairs)rx r � extra_argsr} � key_pairsr r r �list_key_pairs s /� z#CloudStackNodeDriver.list_key_pairsc C sP d|i}| j d|dd�}|�dg �}t|�dkr<t|| d��| j|d d�}|S ) z� Retrieve a single key pair. :param name: Name of the key pair to retrieve. :type name: ``str`` :rtype: :class:`.KeyPair` rj r� r r r� r )rj ru ri )r r r r � _to_key_pair)rx rj r r} r� �key_pairr r r � get_key_pairE s � z!CloudStackNodeDriver.get_key_pairc K s> |� � }d|i}|�|� | jd|dd�}| j|d d�}|S )a Create a new key pair object. :param name: Key pair name. :type name: ``str`` :param name: Name of the keypair (required) :type name: ``str`` :param projectid: An optional project for the ssh key :type projectid: ``str`` :param domainid: An optional domainId for the ssh key. If the account parameter is used, domainId must also be used. :type domainid: ``str`` :param account: An optional account for the ssh key. Must be used with domainId. :type account: ``str`` :return: Created key pair object. :rtype: :class:`libcloud.compute.base.KeyPair` rj ZcreateSSHKeyPairr r r1 ri )r� r r r� )rx rj r r� r r} r� r r r �create_key_pairZ s �z$CloudStackNodeDriver.create_key_pairc C s* | j d||d�dd�}| j|d d�}|S )a1 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`` :return: Imported key pair object. :rtype: :class:`libcloud.compute.base.KeyPair` ZregisterSSHKeyPair)rj � publickeyr r r1 ri )r r� )rx rj � key_materialr} r� r r r �import_key_pair_from_string~ s ��z0CloudStackNodeDriver.import_key_pair_from_stringc K s8 |� � }d|ji}|�|� | jd|dd�}|d dkS )a� Delete an existing key pair. :param key_pair: Key pair object. :type key_pair: :class:`libcloud.compute.base.KeyPair` :param projectid: The project associated with keypair :type projectid: ``str`` :param domainid: The domain ID associated with the keypair :type domainid: ``str`` :param account: The account associated with the keypair. Must be used with the domainId parameter. :type account: ``str`` :return: True of False based on success of Keypair deletion :rtype: ``bool`` rj ZdeleteSSHKeyPairr r �success�true)r� rj r r )rx r� r r� r r} r r r �delete_key_pair� s �z$CloudStackNodeDriver.delete_key_pairc C s` g }| j ddd�}|s|S |d D ]8}|�t|d |d | |�dg �|�d�|�d ��� q"|S ) zh Lists all Public IP Addresses. :rtype: ``list`` of :class:`CloudStackAddress` r) r rX r, r� r- Zassociatednetworkidr( r: )r r r� r )rx �ipsr} �ipr r r rU � s � �z'CloudStackNodeDriver.ex_list_public_ipsc C sz i }|dur|j |d< n| �� d j |d< |dur:||d< |durJ||d< | jd|dd�}|d }t|d |d | �}|S ) aR Allocate a public IP. :param vpc_id: VPC the ip belongs to :type vpc_id: ``str`` :param network_id: Network where this IP is connected to. :type network_id: ''str'' :param location: Zone :type location: :class:`NodeLocation` :rtype: :class:`CloudStackAddress` Nr0 r r( � networkidZassociateIpAddressr r r- r� )r� r& rk r� )rx r- r� r r rN r r r rv � s �z*CloudStackNodeDriver.ex_allocate_public_ipc C s | j dd|jidd�}|d S )z� Release a public IP. :param address: CloudStackAddress which should be used :type address: :class:`CloudStackAddress` :rtype: ``bool`` ZdisassociateIpAddressr� r r r� r{ )rx r{ r} r r r rz � s �z)CloudStackNodeDriver.ex_release_public_ipc s� g }| j ddd�}|i kr�| �� }|d D ]Z� � fdd�|D �}|�t� d |d � d � d � �d �� �d �� �d �� �d��� q*|S )zg Lists all Firewall Rules :rtype: ``list`` of :class:`CloudStackFirewallRule` ZlistFirewallRulesr rX � firewallrulec s g | ]}|j � d kr|�qS rT r� r> r� r r r7 s �z?CloudStackNodeDriver.ex_list_firewall_rules.<locals>.<listcomp>r� r �cidrlistr| �icmpcode�icmptyper: r; )r rU r r� r )rx rR rV r1 rN r r� r �ex_list_firewall_rules� s$ � � z+CloudStackNodeDriver.ex_list_firewall_rulesc C s� |j ||d�}|dur"t|�|d< |dur6t|�|d< |durJt|�|d< |dur^t|�|d< | jd|dd �} t| d d |||||||�} | S ) a� Creates a Firewall Rule :param address: External IP address :type address: :class:`CloudStackAddress` :param cidr_list: cidr list :type cidr_list: ``str`` :param protocol: TCP/IP Protocol (TCP, UDP) :type protocol: ``str`` :param icmp_code: Error code for this icmp message :type icmp_code: ``int`` :param icmp_type: Type of the icmp message being sent :type icmp_type: ``int`` :param start_port: start of port range :type start_port: ``int`` :param end_port: end of port range :type end_port: ``int`` :rtype: :class:`CloudStackFirewallRule` )� ipaddressidr� r| Nr� r� r: r; ZcreateFirewallRuler r r� r� )r� r rk r� ) rx r{ r� r| r� r� r} r~ r rV r� r r r �ex_create_firewall_rule s4 � � �z,CloudStackNodeDriver.ex_create_firewall_rulec C s | j dd|jidd�}|d S )z� Remove a Firewall Rule. :param firewall_rule: Firewall rule which should be used :type firewall_rule: :class:`CloudStackFirewallRule` :rtype: ``bool`` ZdeleteFirewallRuler� r r r� r{ �rx Z firewall_ruler} r r r �ex_delete_firewall_ruleM s �z,CloudStackNodeDriver.ex_delete_firewall_rulec C sh g }| j ddd�}|d D ]H}|�t|d |d |d |d |�d �|�d �|�d �|�d ��� q|S ) zt Lists all egress Firewall Rules :rtype: ``list`` of :class:`CloudStackEgressFirewallRule` ZlistEgressFirewallRulesr rX r� r� r� r� r| r� r� r: r; )r r r� r )rx rR rV r� r r r � ex_list_egress_firewall_rules[ s � � z2CloudStackNodeDriver.ex_list_egress_firewall_rulesc C s� |||d�}|dur t |�|d< |dur4t |�|d< |durHt |�|d< |dur\t |�|d< | jd|dd �} t| d d |||||||�} | S ) a- Creates a Firewall Rule :param network_id: the id network network for the egress firewall services :type network_id: ``str`` :param cidr_list: cidr list :type cidr_list: ``str`` :param protocol: TCP/IP Protocol (TCP, UDP) :type protocol: ``str`` :param icmp_code: Error code for this icmp message :type icmp_code: ``int`` :param icmp_type: Type of the icmp message being sent :type icmp_type: ``int`` :param start_port: start of port range :type start_port: ``int`` :param end_port: end of port range :type end_port: ``int`` :rtype: :class:`CloudStackEgressFirewallRule` )r� r� r| Nr� r� r: r; ZcreateEgressFirewallRuler r r� r� )r rk r� ) rx r� r� r| r� r� r} r~ r rV r� r r r � ex_create_egress_firewall_rulep s4 � � �z3CloudStackNodeDriver.ex_create_egress_firewall_rulec C s | j dd|jidd�}|d S )z� Remove a Firewall rule. :param egress_firewall_rule: Firewall rule which should be used :type egress_firewall_rule: :class:`CloudStackEgressFirewallRule` :rtype: ``bool`` ZdeleteEgressFirewallRuler� r r r� r{ r� r r r � ex_delete_egress_firewall_rule� s �z3CloudStackNodeDriver.ex_delete_egress_firewall_rulec sT i } |dur|| d< |dur$|| d< |dur4|| d< |durD|| d< |durT|| d< |durd|| d< |durt|| d< |dur�|| d < | dur�| | d < | dur�| | d < | dur�| | d < g } | j d | dd�}|i k�rP| �� }| �� }|d D ]d� � fdd�|D �}� fdd�|D �}| �t|d � d |d � d � d � d � d � d �� q�| S )a� Lists all Port Forwarding Rules :param account: List resources by account. Must be used with the domainId parameter :type account: ``str`` :param domain_id: List only resources belonging to the domain specified :type domain_id: ``str`` :param for_display: List resources by display flag (only root admin is eligible to pass this parameter). :type for_display: ``bool`` :param id: Lists rule with the specified ID :type id: ``str`` :param ipaddress_id: list the rule belonging to this public ip address :type ipaddress_id: ``str`` :param is_recursive: Defaults to false, but if true, lists all resources from the parent specified by the domainId till leaves. :type is_recursive: ``bool`` :param keyword: List by keyword :type keyword: ``str`` :param list_all: If set to false, list only resources belonging to the command's caller; if set to true - list resources that the caller is authorized to see. Default value is false :type list_all: ``bool`` :param network_id: list port forwarding rules for certain network :type network_id: ``string`` :param page: The page to list the keypairs from :type page: ``int`` :param page_size: The number of results per page :type page_size: ``int`` :param project_id: list objects by project :type project_id: ``str`` :rtype: ``list`` of :class:`CloudStackPortForwardingRule` Nr@ r< r� r� � isrecursive�keyword�listallr� �page�pagesizer) r* r r r= c s" g | ]}|j t� d �kr|�qS �r: �r� r �r6 �nr� r r r7 s �zFCloudStackNodeDriver.ex_list_port_forwarding_rules.<locals>.<listcomp>c s g | ]}|j � d kr|�qS rT r� r> r� r r r7 s �r r| rB rC rD rE )r rU rS r r� )rx r@ r> r� � ipaddress_id� is_recursiver� �list_allr� r� � page_sizer. r rR rV r1 rO rn rN r r� r � ex_list_port_forwarding_rules� sZ ;� � z2CloudStackNodeDriver.ex_list_port_forwarding_rulesc C s� |j |t|�t|�|j |d�} |r.t|�| d< |r>t|�| d< | rJ| | d< | jd| dd�} t|| d d ||||||| � } |jd �| � |j�|j� | S ) a� Creates a Port Forwarding Rule, used for Source NAT :param address: IP address of the Source NAT :type address: :class:`CloudStackAddress` :param private_port: Port of the virtual machine :type private_port: ``int`` :param protocol: Protocol of the rule :type protocol: ``str`` :param public_port: Public port on the Source NAT address :type public_port: ``int`` :param node: The virtual machine :type node: :class:`CloudStackNode` :param network_id: The network of the vm the Port Forwarding rule will be created for. Required when public Ip address is not associated with any Guest network yet (VPC case) :type network_id: ``string`` :rtype: :class:`CloudStackPortForwardingRule` )r� r| rC rB r: r� rD rE r� ZcreatePortForwardingRuler r r= r� rF )r� r rk r� r� r r1 r{ ) rx rn r{ r� r� r| r� r� r� r� r rV r� r r r r� . s@ "� ��� z3CloudStackNodeDriver.ex_create_port_forwarding_rulec C s> |j d �|� |j�|jj� | jdd|jidd�}|d S )a Remove a Port forwarding rule. :param node: Node used in the rule :type node: :class:`CloudStackNode` :param rule: Forwarding rule which should be used :type rule: :class:`CloudStackPortForwardingRule` :rtype: ``bool`` rF ZdeletePortForwardingRuler� r r r� )r� �remover1 r{ rk r� )rx rn r� r} r r r r� o s �z3CloudStackNodeDriver.ex_delete_port_forwarding_rulec sH i } |dur|| d< |dur$|| d< |dur4|| d< |durD|| d< |durT|| d< |durd|| d< |durt|| d< |dur�|| d < | dur�| | d < | dur�| | d < | dur�| | d < | j d | dd�} g }| i k�rD| �� }| �� }| d D ]X� � fdd�|D �}� fdd�|D �}|�t|d � d |d � d � d � d �� q�|S )a8 Lists all NAT/firewall forwarding rules :param account: List resources by account. Must be used with the domainId parameter :type account: ``str`` :param domain_id: List only resources belonging to the domain specified :type domain_id: ``str`` :param id: Lists rule with the specified ID :type id: ``str`` :param ipaddress_id: list the rule belonging to this public ip address :type ipaddress_id: ``str`` :param is_recursive: Defaults to false, but if true, lists all resources from the parent specified by the domainId till leaves. :type is_recursive: ``bool`` :param keyword: List by keyword :type keyword: ``str`` :param list_all: If set to false, list only resources belonging to the command's caller; if set to true - list resources that the caller is authorized to see. Default value is false :type list_all: ``bool`` :param page: The page to list the keypairs from :type page: ``int`` :param page_size: The number of results per page :type page_size: ``int`` :param project_id: list objects by project :type project_id: ``str`` :param virtualmachine_id: Lists all rules applied to the specified Vm :type virtualmachine_id: ``str`` :rtype: ``list`` of :class:`CloudStackIPForwardingRule` Nr@ r< r� r� r� r� r� r� r� r) r: r+ r r r9 c s" g | ]}|j t� d �kr|�qS r� r� r� r� r r r7 � s �zDCloudStackNodeDriver.ex_list_ip_forwarding_rules.<locals>.<listcomp>c s g | ]}|j � d kr|�qS rT r� r> r� r r r7 � s �r r| r: r; )r rU rS r r� )rx r@ r> r� r� r� r� r� r� r� r. r� r rV rR r1 rO rn rN r r� r �ex_list_ip_forwarding_rules� sV 7� �z0CloudStackNodeDriver.ex_list_ip_forwarding_rulesc C s| |� � }|dvrdS |j|t|�d�}|dur:t|�|d< | jd|dd�}|d }t||d ||||�}|jd �|� |S ) a� "Add a NAT/firewall forwarding rule. :param node: Node which should be used :type node: :class:`CloudStackNode` :param address: CloudStackAddress which should be used :type address: :class:`CloudStackAddress` :param protocol: Protocol which should be used (TCP or UDP) :type protocol: ``str`` :param start_port: Start port which should be used :type start_port: ``int`` :param end_port: End port which should be used :type end_port: ``int`` :rtype: :class:`CloudStackForwardingRule` �ZTCPZUDPN)r� r| r: r; ZcreateIpForwardingRuler r r9 r� r< )rK r� r rk r� r� r ) rx rn r{ r| r} r~ r rV r� r r r r � s& � � �z1CloudStackNodeDriver.ex_create_ip_forwarding_rulec C s* |j d �|� | jdd|jidd� dS )a! Remove a NAT/firewall forwarding rule. :param node: Node which should be used :type node: :class:`CloudStackNode` :param rule: Forwarding rule which should be used :type rule: :class:`CloudStackForwardingRule` :rtype: ``bool`` r< ZdeleteIpForwardingRuler� r r T)r� r� rk r� )rx rn r� r r r r� s �z1CloudStackNodeDriver.ex_delete_ip_forwarding_rulec C s> ||d�}|r||d< | j d|dd�}t|d ||| |�}|S )a� Create an ACL List for a network within a VPC. :param name: Name of the network ACL List :type name: ``string`` :param vpc_id: Id of the VPC associated with this network ACL List :type vpc_id: ``string`` :param description: Description of the network ACL List :type description: ``string`` :rtype: :class:`CloudStackNetworkACLList` )rj r( r� ZcreateNetworkACLListr r r� )r r� )rx rj r- r� r rV Zacl_listr r r �ex_create_network_acllist2 s ���z.CloudStackNodeDriver.ex_create_network_acllistc C s` |||||d�}|r ||d< nd}|r.||d< | j d|dd�} t| d d |||||||�} | S ) a� Creates an ACL rule in the given network (the network has to belong to VPC) :param protocol: the protocol for the ACL rule. Valid values are TCP/UDP/ICMP/ALL or valid protocol number :type protocol: ``string`` :param acl_id: Name of the network ACL List :type acl_id: ``str`` :param cidr_list: the cidr list to allow traffic from/to :type cidr_list: ``str`` :param start_port: the starting port of ACL :type start_port: ``str`` :param end_port: the ending port of ACL :type end_port: ``str`` :param action: scl entry action, allow or deny :type action: ``str`` :param traffic_type: the traffic type for the ACL,can be Ingress or Egress, defaulted to Ingress if not specified :type traffic_type: ``str`` :rtype: :class:`CloudStackNetworkACL` )r| �aclidr� r: r; r� Zallowr ZcreateNetworkACLr r � networkaclr� )rk r� ) rx r| r� r� r} r~ r� r* r rV �aclr r r �ex_create_network_aclT s2 "� � � z*CloudStackNodeDriver.ex_create_network_aclc C sV g }| j ddd�}|s|S |d D ].}|�t|d |d |�dg �| |d �� q"|S ) zg Lists all network ACLs :rtype: ``list`` of :class:`CloudStackNetworkACLList` ZlistNetworkACLListsr rX Znetworkacllistr� rj r( r� )r r r� r )rx ZacllistsrV Zacllistr r r �ex_list_network_acllists� s � �z-CloudStackNodeDriver.ex_list_network_acllistsc C s ||d�}| j d|dd� dS )a` Create an ACL List for a network within a VPC.Replaces ACL associated with a Network or private gateway :param acl_id: the ID of the network ACL :type acl_id: ``string`` :param network_id: the ID of the network :type network_id: ``string`` :rtype: :class:`CloudStackNetworkACLList` )r� r� ZreplaceNetworkACLListr r T�rk )rx r� r� r r r r �ex_replace_network_acllist� s ��z/CloudStackNodeDriver.ex_replace_network_acllistc C sp g }| j ddd�}|s|S |d D ]H}|�t|d |d |d |d |d |�d g �|�d g �|d �� q"|S ) zh Lists all network ACL items :rtype: ``list`` of :class:`CloudStackNetworkACL` ZlistNetworkACLsr rX r� r� r| r� r� r� r: r; r )r r r� r )rx ZaclsrV r� r r r �ex_list_network_acl� s" � � z(CloudStackNodeDriver.ex_list_network_aclc K sH t �d� | jf i |��}g }|D ] }|j|j|jd�}|�|� q"|S )ah List Registered SSH Key Pairs :param projectid: list objects by project :type projectid: ``str`` :param page: The page to list the keypairs from :type page: ``int`` :param keyword: List by keyword :type keyword: ``str`` :param listall: If set to false, list only resources belonging to the command's caller; if set to true - list resources that the caller is authorized to see. Default value is false :type listall: ``bool`` :param pagesize: The number of results per page :type pagesize: ``int`` :param account: List resources by account. Must be used with the domainId parameter :type account: ``str`` :param isrecursive: Defaults to false, but if true, lists all resources from the parent specified by the domainId till leaves. :type isrecursive: ``bool`` :param fingerprint: A public key fingerprint to look for :type fingerprint: ``str`` :param name: A key pair name to look for :type name: ``str`` :param domainid: List only resources belonging to the domain specified :type domainid: ``str`` :return: A list of keypair dictionaries :rtype: ``list`` of ``dict`` zAThis method has been deprecated in favor of list_key_pairs method�rj � fingerprintZ privateKey)�warnings�warnr� rj r� � private_keyr )rx r r� rV r� �itemr r r �ex_list_keypairs� s / � z%CloudStackNodeDriver.ex_list_keypairsc K s4 t �d� | jf d|i|��}|j|j|jd�}|S )a� Creates a SSH KeyPair, returns fingerprint and private key :param name: Name of the keypair (required) :type name: ``str`` :param projectid: An optional project for the ssh key :type projectid: ``str`` :param domainid: An optional domainId for the ssh key. If the account parameter is used, domainId must also be used. :type domainid: ``str`` :param account: An optional account for the ssh key. Must be used with domainId. :type account: ``str`` :return: A keypair dictionary :rtype: ``dict`` zBThis method has been deprecated in favor of create_key_pair methodrj r� )r� r� r� rj r� r� )rx rj r r� rV r r r �ex_create_keypair s �z&CloudStackNodeDriver.ex_create_keypairc C s* t �d� | j||d�}|j|jd�}|S )aA Imports a new public key where the public key is passed in as a string :param name: The name of the public key to import. :type name: ``str`` :param key_material: The contents of a public key file. :type key_material: ``str`` :rtype: ``dict`` zNThis method has been deprecated in favor of import_key_pair_from_string method)rj r� �ZkeyNameZkeyFingerprint)r� r� r� rj r� )rx rj r� r� rV r r r � ex_import_keypair_from_stringA s ��z2CloudStackNodeDriver.ex_import_keypair_from_stringc C s* t �d� | j||d�}|j|jd�}|S )aH Imports a new public key where the public key is passed via a filename :param name: The name of the public key to import. :type name: ``str`` :param keyfile: The filename with path of the public key to import. :type keyfile: ``str`` :rtype: ``dict`` zLThis method has been deprecated in favor of import_key_pair_from_file method)rj Z key_file_pathr� )r� r� Zimport_key_pair_from_filerj r� )rx rj �keyfiler� rV r r r �ex_import_keypairY s ��z&CloudStackNodeDriver.ex_import_keypairc K s& t �d� t|dd| d�}| j|d�S )a{ Deletes an existing SSH KeyPair :param keypair: Name of the keypair (required) :type keypair: ``str`` :param projectid: The project associated with keypair :type projectid: ``str`` :param domainid: The domain ID associated with the keypair :type domainid: ``str`` :param account: The account associated with the keypair. Must be used with the domainId parameter. :type account: ``str`` :return: True of False based on success of Keypair deletion :rtype: ``bool`` zBThis method has been deprecated in favor of delete_key_pair methodN)rj � public_keyr� ru )r� )r� r� r r� )rx r1 r r� r r r �ex_delete_keypairq s �z&CloudStackNodeDriver.ex_delete_keypairc K s( |� � }| jd|dd�}|�dg �}|S )a� Lists Security Groups :param domainid: List only resources belonging to the domain specified :type domainid: ``str`` :param account: List resources by account. Must be used with the domainId parameter. :type account: ``str`` :param listall: If set to false, list only resources belonging to the command's caller; if set to true list resources that the caller is authorized to see. Default value is false :type listall: ``bool`` :param pagesize: Number of entries per page :type pagesize: ``int`` :param keyword: List by keyword :type keyword: ``str`` :param tags: List resources by tags (key/value pairs) :type tags: ``dict`` :param id: list the security group by the id provided :type id: ``str`` :param securitygroupname: lists security groups by name :type securitygroupname: ``str`` :param virtualmachineid: lists security groups by virtual machine id :type virtualmachineid: ``str`` :param projectid: list objects by project :type projectid: ``str`` :param isrecursive: (boolean) defaults to false, but if true, lists all resources from the parent specified by the domainId till leaves. :type isrecursive: ``bool`` :param page: (integer) :type page: ``int`` :rtype ``list`` ZlistSecurityGroupsr r � securitygroup)r� r r )rx r r� r} �security_groupsr r r �ex_list_security_groups� s 1� z,CloudStackNodeDriver.ex_list_security_groupsc K sP |� � }| �� D ]}||d v rtd��qd|i}|�|� | jd|dd�d S )a� Creates a new Security Group :param name: name of the security group (required) :type name: ``str`` :param account: An optional account for the security group. Must be used with domainId. :type account: ``str`` :param domainid: An optional domainId for the security group. If the account parameter is used, domainId must also be used. :type domainid: ``str`` :param description: The description of the security group :type description: ``str`` :param projectid: Deploy vm for the project :type projectid: ``str`` :rtype: ``dict`` rj z'This Security Group name already existsZcreateSecurityGroupr r r� )r� r� r r r )rx rj r r� �sgr r r r �ex_create_security_group� s ��z-CloudStackNodeDriver.ex_create_security_groupc C s | j dd|idd�d S )a� Deletes a given Security Group :param domainid: The domain ID of account owning the security group :type domainid: ``str`` :param id: The ID of the security group. Mutually exclusive with name parameter :type id: ``str`` :param name: The ID of the security group. Mutually exclusive with id parameter :type name: ``str`` :param account: The account of the security group. Must be specified with domain ID :type account: ``str`` :param projectid: The project of the security group :type projectid: ``str`` :rtype: ``bool`` ZdeleteSecurityGrouprj r r r� �r )rx rj r r r �ex_delete_security_group� s ��z-CloudStackNodeDriver.ex_delete_security_groupc K s� |� � } |�� }| �|||d�� |dvrB|dus:|durBtd��|dkrb|dusZ|durbtd��|dv r�|du rztd��|dur�|du r�|}| �||d�� |dkr�|du r�d }|du r�d }| �||d �� | jd | d d �d S )a Creates a new Security Group Ingress rule :param securitygroupname: The name of the security group. Mutually exclusive with securitygroupid. :type securitygroupname: ``str`` :param protocol: Can be TCP, UDP or ICMP. Sometime other protocols can be used like AH, ESP or GRE. :type protocol: ``str`` :param cidrlist: Source address CIDR for which this rule applies. :type cidrlist: ``str`` :param startport: Start port of the range for this ingress rule. Applies to protocols TCP and UDP. :type startport: ``int`` :param endport: End port of the range for this ingress rule. It can be None to set only one port. Applies to protocols TCP and UDP. :type endport: ``int`` :param icmptype: Type of the ICMP packet (eg: 8 for Echo Request). -1 or None means "all types". Applies to protocol ICMP. :type icmptype: ``int`` :param icmpcode: Code of the ICMP packet for the specified type. If the specified type doesn't require a code set this value to 0. -1 or None means "all codes". Applies to protocol ICMP. :type icmpcode: ``int`` :keyword account: An optional account for the security group. Must be used with domainId. :type account: ``str`` :keyword domainid: An optional domainId for the security group. If the account parameter is used, domainId must also be used. :keyword projectid: An optional project of the security group :type projectid: ``str`` :keyword securitygroupid: The ID of the security group. Mutually exclusive with securitygroupname :type securitygroupid: ``str`` :keyword usersecuritygrouplist: User to security group mapping :type usersecuritygrouplist: ``dict`` :rtype: ``dict`` )�securitygroupnamer| r� r� NzB"startport" and "endport" are only valid with protocol TCP or UDP.ZICMPz<"icmptype" and "icmpcode" are only valid with protocol ICMP.z=Protocols TCP and UDP require at least "startport" to be set.)r: r; r )r� r� Z authorizeSecurityGroupIngressr r r� )r� rK r r rk ) rx r� r| r� r: r; r� r� r r r r r �#ex_authorize_security_group_ingress sV =���������z8CloudStackNodeDriver.ex_authorize_security_group_ingressc C s | j dd|idd� dS )z� Revoke/delete an ingress security rule :param id: The ID of the ingress security rule :type id: ``str`` :rtype: ``bool`` ZrevokeSecurityGroupIngressr� r r Tr� )rx r� r r r � ex_revoke_security_group_ingressu s �z5CloudStackNodeDriver.ex_revoke_security_group_ingressc C sJ | � � D ]}||jkrtd��q||jd�}| jd|dd�}| �|d �S )aP Creates a new Affinity Group :param name: Name of the affinity group :type name: ``str`` :param group_type: Type of the affinity group from the available affinity/anti-affinity group types :type group_type: :class:`CloudStackAffinityGroupType` :param description: Optional description of the affinity group :type description: ``str`` :param domainid: domain ID of the account owning the affinity group :type domainid: ``str`` :rtype: :class:`CloudStackAffinityGroup` z'This Affinity Group name already exists)rj r$ ZcreateAffinityGroupr r � affinitygroup)�ex_list_affinity_groupsrj r r$ rk �_to_affinity_group)rx rj r� rr r rV r r r �ex_create_affinity_group� s �z-CloudStackNodeDriver.ex_create_affinity_groupc C s | j dd|jidd�d S )z� Delete an Affinity Group :param affinity_group: Instance of affinity group :type affinity_group: :class:`CloudStackAffinityGroup` :rtype ``bool`` ZdeleteAffinityGroupr� r r r� r{ )rx �affinity_groupr r r �ex_delete_affinity_group� s ��z-CloudStackNodeDriver.ex_delete_affinity_groupc C s< d� dd� |D ��}| jd|j|d�dd�}| j|d d �S ) a� Updates the affinity/anti-affinity group associations of a virtual machine. The VM has to be stopped and restarted for the new properties to take effect. :param node: Node to update. :type node: :class:`CloudStackNode` :param affinity_group_list: List of CloudStackAffinityGroup to associate :type affinity_group_list: ``list`` of :class:`CloudStackAffinityGroup` :rtype :class:`CloudStackNode` rn c s s | ] }|j V qd S r� r� rq r r r rs � ro zECloudStackNodeDriver.ex_update_node_affinity_group.<locals>.<genexpr>ZupdateVMAffinityGroup)r� rt r r r. ri )ru rk r� rI )rx rn Zaffinity_group_list�affinity_groupsrV r r r � ex_update_node_affinity_group� s ��z2CloudStackNodeDriver.ex_update_node_affinity_groupc C sB | j ddd�}|�d�s g S g }|d D ]}|�| �|�� q(|S )zc List Affinity Groups :rtype ``list`` of :class:`CloudStackAffinityGroup` ZlistAffinityGroupsr rX �countr� )r r r r� )rx rV r� rr r r r r� � s z,CloudStackNodeDriver.ex_list_affinity_groupsc C sD | j ddd�}|�d�s g S g }|d D ]}|�t|d �� q(|S )zm List Affinity Group Types :rtype ``list`` of :class:`CloudStackAffinityGroupTypes` ZlistAffinityGroupTypesr rX r� ZaffinityGroupTyper$ )r r r r� )rx rV Zaffinity_group_typesZagtr r r � ex_list_affinity_group_types� s � �z1CloudStackNodeDriver.ex_list_affinity_group_typesc K sj |du r| � � d }||||jd�}|�dd�|d< |d r\|�dd�}|sTtd��||d< | jd|d �S ) ab Registers an existing ISO by URL. :param name: Name which should be used :type name: ``str`` :param url: Url should be used :type url: ``str`` :param location: Location which should be used :type location: :class:`NodeLocation` :rtype: ``str`` Nr )rj r� r r0 ZbootableF�ostypeidz'If bootable=True, ostypeid is required!Z registerIsor� )r& r� �popr r )rx rj r r r r Z os_type_idr r r �ex_register_iso� s � �z$CloudStackNodeDriver.ex_register_isoc C sp | j ddd�}i }dddddd d d d d ddd� }|�dg �D ].}|�t|d �d�}|sZq<t|d �||< q<|S )a� Extra call to get account's resource limits, such as the amount of instances, volumes, snapshots and networks. CloudStack uses integers as the resource type so we will convert them to a more human readable string using the resource map A list of the resource type mappings can be found at http://goo.gl/17C6Gk :return: dict :rtype: ``dict`` ZlistResourceLimitsr rX Z max_instancesZmax_public_ipsZ max_volumesZ max_snapshotsZ max_imagesZ max_projectsZ max_networksZmax_vpcZmax_cpuZ max_memoryZmax_primary_storageZmax_secondary_storage) r r� � � � � � � � � � � Z resourcelimit� resourcetypeN�max)r r r )rx rV ZlimitsZ resource_map�limit�resourcer r r � ex_limits s. ��z CloudStackNodeDriver.ex_limitsc C sR |d� |�d�}t|�D ]$\}}||d| < || |d| < q| jd|dd� dS ) a Create tags for a resource (Node/StorageVolume/etc). A list of resource types can be found at http://goo.gl/6OKphH :param resource_ids: Resource IDs to be tagged. The resource IDs must all be associated with the resource_type. For example, for virtual machines (UserVm) you can only specify a list of virtual machine IDs. :type resource_ids: ``list`` of resource IDs :param resource_type: Resource type (eg: UserVm) :type resource_type: ``str`` :param tags: A dictionary or other mapping of strings to strings, associating tag names with tag values. :type tags: ``dict`` :rtype: ``bool`` rn �r Z resourceidsz tags[%d].keyztags[%d].valueZ createTagsr r T�ru � enumeraterk )rx � resource_ids� resource_typerV r �ir� r r r �ex_create_tags: s � �z#CloudStackNodeDriver.ex_create_tagsc C sB |d� |�d�}t|�D ]\}}||d| < q| jd|dd� dS )a� Delete tags from a resource. :param resource_ids: Resource IDs to be tagged. The resource IDs must all be associated with the resource_type. For example, for virtual machines (UserVm) you can only specify a list of virtual machine IDs. :type resource_ids: ``list`` of resource IDs :param resource_type: Resource type (eg: UserVm) :type resource_type: ``str`` :param tag_keys: A list of keys to delete. CloudStack only requires the keys from the key/value pair. :type tag_keys: ``list`` :rtype: ``bool`` rn r z tags[%s].keyZ deleteTagsr r Tr )rx r r Ztag_keysr r r� r r r �ex_delete_tagsZ s ��z#CloudStackNodeDriver.ex_delete_tagsc C s4 | j ddd�}g }|d D ]}|�| �|�� q|S )z^ Describe all snapshots. :rtype: ``list`` of :class:`VolumeSnapshot` Z listSnapshotsr )r r� )r r � _to_snapshot)rx Z snapshots�list_snapshotsZsnapr r r r y s � z#CloudStackNodeDriver.list_snapshotsc C s$ | j dd|jidd�}| �|d �S )aR Create snapshot from volume :param volume: Instance of ``StorageVolume`` :type volume: ``StorageVolume`` :param name: The name of the snapshot is disregarded by CloudStack drivers :type name: `str` :rtype: :class:`VolumeSnapshot` ZcreateSnapshot�volumeidr r r� )rk r� r )rx ro rj r� r r r �create_volume_snapshot� s �z+CloudStackNodeDriver.create_volume_snapshotc C s | j dd|jidd� dS )NZdeleteSnapshotr� r r Tr{ )rx r� r r r �destroy_volume_snapshot� s �z,CloudStackNodeDriver.destroy_volume_snapshotc C sf |s|}| j d||||jd�d�}|�d�}|d |d |d |d d �}t|d |d | jj|d �S ) a� Create a template from a snapshot :param snapshot: Instance of ``VolumeSnapshot`` :type volume: ``VolumeSnapshot`` :param name: the name of the template :type name: ``str`` :param name: the os type id :type name: ``str`` :param name: the display name of the template :type name: ``str`` :rtype: :class:`NodeImage` ZcreateTemplate)r� rj r Z snapshotidr� r� r5 r r r� r r� rj r )rk r� r r r ru )rx r� rj r r� �respr r� r r r �ex_create_snapshot_template� s( �� ��z0CloudStackNodeDriver.ex_create_snapshot_templatec C s | � d�}|d S )zg List all registered os types (needed for snapshot creation) :rtype: ``list`` Z listOsTypesZostyper� )rx Zostypesr r r �ex_list_os_types� s z%CloudStackNodeDriver.ex_list_os_typesc C s� | j dd|jidd�}|�dg �}g }td }|D ]L}| �||�}|�t|d |d |d |d |d |d |d | |d � � q2|S )z� List the available networks :param vm: Node Object :type vm: :class:`CloudStackNode :rtype ``list`` of :class:`CloudStackNic` ZlistNicsr: r r r7 r� r� r' r& r- Z isdefaultZ macaddressr� )r r� r r� r� r r� )rx rn r} rJ Znicsr� r� r� r r r � ex_list_nics� s* � � z!CloudStackNodeDriver.ex_list_nicsc C s0 |j |j d�}|dur ||d< | jd|d� dS )a_ Add an extra Nic to a VM :param network: NetworkOffering object :type network: :class:'CloudStackNetwork` :param node: Node Object :type node: :class:'CloudStackNode` :param ip_address: Optional, specific IP for this Nic :type ip_address: ``str`` :rtype: ``bool`` )r: r� Nr- ZaddNicToVirtualMachiner� Try )rx rn rm r� r r r r �ex_attach_nic_to_node� s ��z*CloudStackNodeDriver.ex_attach_nic_to_nodec C s | j d|j|jd�d� dS )z� Remove Nic from a VM :param nic: Nic object :type nic: :class:'CloudStackNetwork` :param node: Node Object :type node: :class:'CloudStackNode` :rtype: ``bool`` ZremoveNicFromVirtualMachine)Znicidr: r� Tr{ )rx r7 rn r r r �ex_detach_nic_from_node s ��z,CloudStackNodeDriver.ex_detach_nic_from_nodec C s, i } |dur|| d< |dur$|| d< |dur4|| d< |durD|| d< |durT|| d< |durd|| d< |durt|| d< |dur�|| d < | dur�| | d < | dur�| | d < | dur�| | d < | j d | dd�} | �dg �}g }td }|D ]F}| �||�}|�t|d |d |d |d |d |d | |d�� q�|S )aO List VPN Gateways. :param account: List resources by account (must be used with the domain_id parameter). :type account: ``str`` :param domain_id: List only resources belonging to the domain specified. :type domain_id: ``str`` :param for_display: List resources by display flag (only root admin is eligible to pass this parameter). :type for_display: ``bool`` :param id: ID of the VPN Gateway. :type id: ``str`` :param is_recursive: Defaults to False, but if true, lists all resources from the parent specified by the domain ID till leaves. :type is_recursive: ``bool`` :param keyword: List by keyword. :type keyword: ``str`` :param list_all: If set to False, list only resources belonging to the command's caller; if set to True - list resources that the caller is authorized to see. Default value is False. :type list_all: ``str`` :param page: Start from page. :type page: ``int`` :param page_size: Items per page. :type page_size: ``int`` :param project_id: List objects by project. :type project_id: ``str`` :param vpc_id: List objects by VPC. :type vpc_id: ``str`` :rtype: ``list`` of :class:`CloudStackVpnGateway` Nr@ r< rd r� r� r� r� r� r� r) r( ZlistVpnGatewaysr r rq r; r� r� )r r r� r� r r� )rx r@ r> rf r� r� r� r� r� r� r. r- r r} rJ Z vpn_gatewaysr� r� r� r r r r� ! sV 2� � z)CloudStackNodeDriver.ex_list_vpn_gatewaysc C sp d|j i}|dur||d< | jd|dd�}|d }td }t|d |d |d |d |d |j | | �||�d �S )a- Creates a VPN Gateway. :param vpc: VPC to create the Gateway for (required). :type vpc: :class: `CloudStackVPC` :param for_display: Display the VPC to the end user or not. :type for_display: ``bool`` :rtype: :class: `CloudStackVpnGateway` r( Nrd ZcreateVpnGatewayr r rq r� r@ r; r< r� r� )r� rk r� r� r� )rx rp rf r r} r� r� r r r �ex_create_vpn_gateway� s* ����z*CloudStackNodeDriver.ex_create_vpn_gatewayc C s | j dd|jidd�}|d S )z� Deletes a VPN Gateway. :param vpn_gateway: The VPN Gateway (required). :type vpn_gateway: :class:`CloudStackVpnGateway` :rtype: ``bool`` ZdeleteVpnGatewayr� r r r� r{ )rx r� r} r r r r� � s �z*CloudStackNodeDriver.ex_delete_vpn_gatewayc C s i } |dur|| d< |dur$|| d< |dur4|| d< |durD|| d< |durT|| d< |durd|| d< |durt|| d< |dur�|| d < | dur�| | d < | j d | d d �} | �dg �} g } td }| D ]F}| �||�}| �t|d |d |d |d |d |d | |d�� q�| S )a` List VPN Customer Gateways. :param account: List resources by account (must be used with the domain_id parameter). :type account: ``str`` :param domain_id: List only resources belonging to the domain specified. :type domain_id: ``str`` :param id: ID of the VPN Customer Gateway. :type id: ``str`` :param is_recursive: Defaults to False, but if true, lists all resources from the parent specified by the domain_id till leaves. :type is_recursive: ``bool`` :param keyword: List by keyword. :type keyword: ``str`` :param list_all: If set to False, list only resources belonging to the command's caller; if set to True - list resources that the caller is authorized to see. Default value is False. :type list_all: ``str`` :param page: Start from page. :type page: ``int`` :param page_size: Items per page. :type page_size: ``int`` :param project_id: List objects by project. :type project_id: ``str`` :rtype: ``list`` of :class:`CloudStackVpnCustomerGateway` Nr@ r< r� r� r� r� r� r� r) ZlistVpnCustomerGatewaysr r rr r� � esppolicyr& � ikepolicy�ipsecpskr� )r r r� r� r r� )rx r@ r> r� r� r� r� r� r� r. r r} rJ Zvpn_customer_gatewaysr� r� r� r r r r� � sN ,� � z2CloudStackNodeDriver.ex_list_vpn_customer_gatewaysc C s� |||||d�} |dur || d< |dur0|| d< |dur@|| d< | durP| | d< | dur`| | d< | durp| | d< | j d | d d �} | d }td }t|d |||||| | �||�d�S )a� Creates a VPN Customer Gateway. :param cidr_list: Guest CIDR list of the Customer Gateway (required). :type cidr_list: ``str`` :param esp_policy: ESP policy of the Customer Gateway (required). :type esp_policy: ``str`` :param gateway: Public IP address of the Customer Gateway (required). :type gateway: ``str`` :param ike_policy: IKE policy of the Customer Gateway (required). :type ike_policy: ``str`` :param ipsec_psk: IPsec preshared-key of the Customer Gateway (required). :type ipsec_psk: ``str`` :param account: The associated account with the Customer Gateway (must be used with the domain_id param). :type account: ``str`` :param domain_id: The domain ID associated with the Customer Gateway. If used with the account parameter returns the gateway associated with the account for the specified domain. :type domain_id: ``str`` :param dpd: If DPD is enabled for the VPN connection. :type dpd: ``bool`` :param esp_lifetime: Lifetime of phase 2 VPN connection to the Customer Gateway, in seconds. :type esp_lifetime: ``int`` :param ike_lifetime: Lifetime of phase 1 VPN connection to the Customer Gateway, in seconds. :type ike_lifetime: ``int`` :param name: Name of the Customer Gateway. :type name: ``str`` :rtype: :class: `CloudStackVpnCustomerGateway` )r� r' r& r( r) Nr@ r< rg rh ri rj ZcreateVpnCustomerGatewayr r rr r� r� )rk r� r� r� )rx r� r� r& r� r� r@ r> rg rk rl rj r r} r� r� r r r � ex_create_vpn_customer_gateway sF 3����z3CloudStackNodeDriver.ex_create_vpn_customer_gatewayc C s | j dd|jidd�}|d S )z� Deletes a VPN Customer Gateway. :param vpn_customer_gateway: The VPN Customer Gateway (required). :type vpn_customer_gateway: :class:`CloudStackVpnCustomerGateway` :rtype: ``bool`` ZdeleteVpnCustomerGatewayr� r r r� r{ )rx r� r} r r r r� } s �z3CloudStackNodeDriver.ex_delete_vpn_customer_gatewayc C s& i } |dur|| d< |dur$|| d< |dur4|| d< |durD|| d< |durT|| d< |durd|| d< |durt|| d< |dur�|| d < | dur�| | d < | dur�| | d < | dur�| | d < | j d | dd�} | �dg �}g }td }|D ]@}| �||�}|�t|d |d |d |d |d | |d�� q�|S )aX List VPN Connections. :param account: List resources by account (must be used with the domain_id parameter). :type account: ``str`` :param domain_id: List only resources belonging to the domain specified. :type domain_id: ``str`` :param for_display: List resources by display flag (only root admin is eligible to pass this parameter). :type for_display: ``bool`` :param id: ID of the VPN Connection. :type id: ``str`` :param is_recursive: Defaults to False, but if true, lists all resources from the parent specified by the domain_id till leaves. :type is_recursive: ``bool`` :param keyword: List by keyword. :type keyword: ``str`` :param list_all: If set to False, list only resources belonging to the command's caller; if set to True - list resources that the caller is authorized to see. Default value is False. :type list_all: ``str`` :param page: Start from page. :type page: ``int`` :param page_size: Items per page. :type page_size: ``int`` :param project_id: List objects by project. :type project_id: ``str`` :param vpc_id: List objects by VPC. :type vpc_id: ``str`` :rtype: ``list`` of :class:`CloudStackVpnConnection` Nr@ r< rd r� r� r� r� r� r� r) r( ZlistVpnConnectionsr r rs r� �s2scustomergatewayid�s2svpngatewayidr! r� )r r r� r� r r� )rx r@ r> rf r� r� r� r� r� r� r. r- r r} rJ Zvpn_connectionsr� r� r� r r r �ex_list_vpn_connections� sT 2� � z,CloudStackNodeDriver.ex_list_vpn_connectionsc C s| |j |j d�}|dur ||d< |dur.||d< | jd|dd�}|d }td }t|d |d |j |j |d | | �||�d �S ) aM Creates a VPN Connection. :param vpn_customer_gateway: The VPN Customer Gateway (required). :type vpn_customer_gateway: :class:`CloudStackVpnCustomerGateway` :param vpn_gateway: The VPN Gateway (required). :type vpn_gateway: :class:`CloudStackVpnGateway` :param for_display: Display the Connection to the end user or not. :type for_display: ``str`` :param passive: If True, sets the connection to be passive. :type passive: ``bool`` :rtype: :class: `CloudStackVpnConnection` )r+ r, Nrd r� ZcreateVpnConnectionr r rs r� r! r� )r� rk r� r� r� ) rx r� r� rf r� r r} r� r� r r r �ex_create_vpn_connection� s, �� �z-CloudStackNodeDriver.ex_create_vpn_connectionc C s | j dd|jidd�}|d S )z� Deletes a VPN Connection. :param vpn_connection: The VPN Connection (required). :type vpn_connection: :class:`CloudStackVpnConnection` :rtype: ``bool`` ZdeleteVpnConnectionr� r r r� r{ )rx r� r} r r r r� % s �z-CloudStackNodeDriver.ex_delete_vpn_connectionc C s6 |� dd�|� dd�|� dd�d�}t|d | |d�S )z� Create snapshot object from data :param data: Node data object. :type data: ``dict`` :rtype: :class:`VolumeSnapshot` rV Nrj r )rV rj r� r� )ru r� )r r )rx r0 r� r r r r 4 s �z!CloudStackNodeDriver._to_snapshotc C sV |d }d|v r|d }nd|v r,|d }nd}| j |d }|rF|ng }g }|d D ]8}d|vrdqVt|d �r�|�|d � qV|�|d � qV|�dg �}|r�d d � |D �}|�d g �} | r�d d � | D �} |�d d�} | �|td �} || d< | | d< g | d< g | d< g | d< | | d < d|v �r4| �|d �| d< t|||tt |��|| | d�} | S )z� :param data: Node data object. :type data: ``dict`` :param public_ips: A list of additional IP addresses belonging to this node. (optional) :type public_ips: ``list`` or ``None`` r� rj rm Nr! r7 r- r� c S s g | ] }|d �qS r� r )r6 r� r r r r7 f ro z1CloudStackNodeDriver._to_node.<locals>.<listcomp>r� c S s g | ] }|d �qS r� r rq r r r r7 k ro r9 Frn Zsecurity_groupr� r8 r< rF rV )r� rj r! r1 � private_ipsru r� ) �NODE_STATE_MAPr r r r� r� r� rt rH �set) rx r0 r1 r� rj r! r/ r7 r� r� r9 r� rn r r r rI D sN � �z CloudStackNodeDriver._to_nodec s � fdd�|D �}|S )Nc s g | ]}� j |d ��qS )ri )r� )r6 r� rw r r r7 � ro z6CloudStackNodeDriver._to_key_pairs.<locals>.<listcomp>r )rx r0 r� r rw r r� � s z"CloudStackNodeDriver._to_key_pairsc C s. t |d |d |�dd �|�dd �| d�}|S )Nrj r� r� Z privatekey)rj r� r� r� ru )r r )rx r0 r� r r r r� � s �z!CloudStackNodeDriver._to_key_pairc C sT t |d |d t|d �|�dd�|�dd�|�dd�|�dd�|�d d�d �}|S ) Nr� rj r$ r@ � r; r< r� ZvirtualmachineIds)r� rj r� r@ r; r< r� r� )r� r� r )rx r0 r� r r r r� � s � z'CloudStackNodeDriver._to_affinity_groupc C s* i }|D ] }|d }|d }|||< q|S )z� Parse tags from the provided element and return a dictionary with key/value pairs. :param tag_set: A list of key/value tag pairs :type tag_set: ``list``` :rtype: ``dict`` r� r r )rx Ztag_setrV �tagr� r r r r r� � s z'CloudStackNodeDriver._get_resource_tagsc C sP i }|� � D ]>\}}|d }|�|d d�}|durB||�||< q d||< q |S )aa Extract attributes from the element based on rules provided in the mapping dictionary. :param response: The JSON response to parse the values from. :type response: ``dict`` :param mapping: Dictionary with the extra layout :type mapping: ``dict`` :rtype: ``dict`` r r N)rJ r )rx �response�mappingr� � attribute�valuesr r r r r r� � s z$CloudStackNodeDriver._get_extra_dictc C s0 | j �|d tj�}|tjkr,d|v r,tj}|S )Nr! r: )�VOLUME_STATE_MAPr r �UNKNOWN� AVAILABLEZINUSE)rx r� r! r r r r� � s �z%CloudStackNodeDriver._to_volume_state)NTNNNN)N)NN)N)N) NNNNNNNNNFNN) NNNNNNNNNFNN)F)N)N)NNNNN)N)N)N)N)NNN)N)N)N)NNN)NNNN)NNNN) NNNNNNNNNNN)NNTN) NNNNNNNNNNN)N)N)NN)NNNN)N)N)N)N) NNNNNNNNNNN)N) NNNNNNNNN)NNNNNN) NNNNNNNNNNN)NN)N)�r� r� r� r� rj Zapi_nameZwebsiter r r$ �featuresr ZRUNNINGZ REBOOTINGZ MIGRATINGZSTOPPEDZPENDINGZ TERMINATEDr0 r ZCREATINGZDELETINGZDELETEDr: ZBACKUP�ERRORr8 r� r r& rS rW r] r� rj rz 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� rU rv rz 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 r r r r r r r! r" r# r$ r% r� r& r� r� r* r� r- r. r� r rI r� r� r� r� r� r� � __classcell__r r r r r� � s� � � �3 W K � G � ? ' � X " � < � 0 $ !7$ � % � 7 � : � y � A � q � , # � @@# 9& � k "+ � ' ! � l $ � a � ] � l � . ? r� )7� __future__r rv r� Zlibcloud.utils.py3r r Zlibcloud.compute.providersr Zlibcloud.common.cloudstackr Zlibcloud.compute.baser r r r r r r r Zlibcloud.compute.typesr r r r Zlibcloud.utils.networkingr r r rH �boolr� rt �objectr� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r �<module> s� ���������������������T������������������H���������$���������#�����������������������������������P��������������� �������� � � P)78.?(9 "*8
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка