File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/__pycache__/vcloud.cpython-310.pyc
Back
o ;j%f � @ sT d Z ddlZddlZddlZddlZddlZddlZddlmZ ddl m Z m Z m Z m Z mZmZ ddlmZmZ ddlmZmZ ddlmZmZmZmZmZ ddl m Z dd l m Z dd l m!Z! ejZ d gd d � e"dd�D � Z#dZ$dZ% dd � e"dd�D �Z&g d�Z'g d�Z(e�)dej*�Z+dd� Z,dd� Z-G dd� d�Z.G d d � d �Z/G d d � d �Z0G d d!� d!�Z1G d"d#� d#�Z2G d$d%� d%�Z3G d&d'� d'e�Z4G d(d)� d)e�Z5G d*d+� d+e�Z6G d,d-� d-e5�Z7G d.d/� d/e6�Z8G d0d1� d1e5�Z9G d2d3� d3e6�Z:G d4d5� d5e5�Z;G d6d7� d7e;�Z<G d8d9� d9�Z=G d:d;� d;e6�Z>G d<d=� d=e>�Z?G d>d?� d?e?�Z@dS )@z VMware vCloud driver. � N)� ExpatError)�ET�b�next�httplib�urlparse� urlencode)� XmlResponse�ConnectionUserAndKey)� LibcloudError�InvalidCredsError)�Node�NodeSize� NodeImage� NodeDriver� NodeLocation)� NodeState)� parse_date)�Provideri c C s g | ]}d | �qS )� � ��.0�ir r �S/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/vcloud.py� <listcomp>* s r � � iX �0.8c C � g | ]}|�qS r r r r r r r 4 � )Zbridged�isolatedZ natRouted)ZPOOLZDHCP�MANUALZNONEz^(?!-)[A-Z\d-]{1,63}(?<!-)$c s< | j dd� �dd�\� }d�� fdd�|�d�D ��}|S )z@ElementTree wants namespaces in its xpaths, so here we add them.r N�}�/c s g | ]}d � � |��qS )z{{{}}}{})�format)r �e�� namespacer r r ? s z fixxpath.<locals>.<listcomp>)�tag�split�join)�root�xpathZroot_tagZ fixed_xpathr r' r �fixxpath< s r. c C s t | �� �jS �N)r �strip�path)�urlr r r � get_url_pathD s r3 c @ s* e Zd ZdZ ddd�Zdd� ZdS )�Vdcz1 Virtual datacenter (vDC) representation Nc C s. || _ || _|| _|| _|| _|| _|| _d S r/ ��id�name�driver�allocation_model�cpu�memory�storage)�selfr6 r7 r8 r9 r: r; r< r r r �__init__M s z Vdc.__init__c C s d� | j| j| jj�S )Nz%<Vdc: id={}, name={}, driver={} ...>)r% r6 r7 r8 �r= r r r �__repr___ s �z Vdc.__repr__�NNNN��__name__� __module__� __qualname__�__doc__r> r@ r r r r r4 H s � r4 c @ s e Zd ZdZdd� Zdd� ZdS )�Capacityz< Represents CPU, Memory or Storage capacity of vDC. c C s || _ || _|| _d S r/ )�limit�used�units)r= rH rI rJ r r r r> l s zCapacity.__init__c C � d� | j| j| j�S )Nz'<Capacity: limit={}, used={}, units={}>)r% rH rI rJ r? r r r r@ q � �zCapacity.__repr__NrB r r r r rG g s rG c @ s0 e Zd ZdZG dd� d�Zd dd�Zdd� ZdS ) � ControlAccessz6 Represents control access settings of a node c @ s e Zd ZdZdZdZdS )zControlAccess.AccessLevelZReadOnlyZChangeZ FullControlN)rC rD rE Z READ_ONLYZCHANGEZ FULL_CONTROLr r r r � AccessLevel~ s rN Nc C s || _ || _|s g }|| _d S r/ ��node�everyone_access_level�subjects)r= rP rQ rR r r r r> � s zControlAccess.__init__c C s d| j | j| jf S )Nz?<ControlAccess: node=%s, everyone_access_level=%s, subjects=%s>rO r? r r r r@ � s �zControlAccess.__repr__r/ )rC rD rE rF rN r> r@ r r r r rM y s rM c @ s" e Zd ZdZddd�Zdd� ZdS )�Subjectz User or group subject Nc C s || _ || _|| _|| _d S r/ ��typer7 � access_levelr6 )r= rU r7 rV r6 r r r r> � s zSubject.__init__c C rK )Nz,<Subject: type={}, name={}, access_level={}>)r% rU r7 rV r? r r r r@ � rL zSubject.__repr__r/ rB r r r r rS � s rS c @ sN e Zd ZdZ ddd�Zedd� �Zdd� Zd d � Zd d � Z d d� Z dS )�Leasez� Lease information for vApps. More info at: 'https://www.vmware.com/support/vcd/doc/ rest-api-doc-1.5-html/types/LeaseSettingsSectionType.html' Nc C s" || _ || _|| _|| _|| _dS )a� :param lease_id: ID (link) to the lease settings section of a vApp. :type lease_id: ``str`` :param deployment_lease: Deployment lease time in seconds :type deployment_lease: ``int`` or ``None`` :param storage_lease: Storage lease time in seconds :type storage_lease: ``int`` or ``None`` :param deployment_lease_expiration: Deployment lease expiration time :type deployment_lease_expiration: ``datetime.datetime`` or ``None`` :param storage_lease_expiration: Storage lease expiration time :type storage_lease_expiration: ``datetime.datetime`` or ``None`` N��lease_id�deployment_lease� storage_lease�deployment_lease_expiration�storage_lease_expiration)r= rY rZ r[ r\ r] r r r r> � s zLease.__init__c C s| |� d�}|�t|d��}|�t|d��}|�t|d��}|�t|d��}dd� }| |||t�||t�||t�||t�d�S ) z� Convert lease settings element to lease instance. :param lease_element: "LeaseSettingsSection" XML element :type lease_element: ``ET.Element`` :return: Lease instance :rtype: :class:`Lease` �hrefZDeploymentLeaseInSecondsZStorageLeaseInSecondsZDeploymentLeaseExpirationZStorageLeaseExpirationc S s | d ur || j �S d S r/ ��text)�elem�functionr r r �apply_if_elem_not_none� s z.Lease.to_lease.<locals>.apply_if_elem_not_nonerX )�get�findr. �intr )�clsZ lease_elementrY rZ r[ r\ r] rc r r r �to_lease� s& ����zLease.to_leasec C sX | j dur| jdur| jtj| j d� S | jdur(| jdur(| jtj| jd� S td��)a< Gets the date and time a vApp was deployed. Time is inferred from the deployment lease and expiration or the storage lease and expiration. :return: Date and time the vApp was deployed or None if unable to calculate :rtype: ``datetime.datetime`` or ``None`` N)�secondszLCannot get time deployed. Missing complete lease and expiration information.)rZ r\ �datetime� timedeltar[ r] � Exceptionr? r r r �get_deployment_time� s ��zLease.get_deployment_timec C s dj | j| j| j| j| jd�S )Nz�<Lease: id={lease_id}, deployment_lease={deployment_lease}, storage_lease={storage_lease}, deployment_lease_expiration={deployment_lease_expiration}, storage_lease_expiration={storage_lease_expiration}>rX )r% rY rZ r[ r\ r] r? r r r r@ s ��zLease.__repr__c C sJ t |t�sdS | j|jko$| j|jko$| j|jko$| j|jko$| j|jkS )NF)� isinstancerW rY rZ r[ r\ r] �r= �otherr r r �__eq__ s � � � �z Lease.__eq__c C s | |k S r/ r ro r r r �__ne__ � z Lease.__ne__rA ) rC rD rE rF r> � classmethodrh rm r@ rq rr r r r r rW � s � ! rW c @ s� e Zd Z d dd�Zdd� Zdd� Zdd � Zd d � Zd d � Zdd� Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zd d � ZdS ) �InstantiateVAppXMLNc C s< || _ || _|| _|| _|| _|| _|| _|| _| �� d S r/ ) r7 �template�net_href�cpusr; �password�row�group�_build_xmltree) r= r7 rv rw rx r; ry rz r{ r r r r> # s zInstantiateVAppXML.__init__c C � t �| j�S r/ �r �tostringr, r? r r r r 9 � zInstantiateVAppXML.tostringc C s^ | � � | _| �| j� t�| jd�}| �|� | �|� t�|d�}t�|d�}| �|� d S )N�InstantiationParams�NetworkConfigSection� NetworkConfig)�_make_instantiation_rootr, �_add_vapp_templater � SubElement�_make_product_section�_make_virtual_hardware�_add_network_association�r= Zinstantiation_paramsZnetwork_config_sectionZnetwork_configr r r r| < s z!InstantiateVAppXML._build_xmltreec C s t �d| jdddd��S )N� InstantiateVAppTemplateParams�en�!http://www.vmware.com/vcloud/v0.8�)http://www.w3.org/2001/XMLSchema-instance)r7 �xml:lang�xmlns� xmlns:xsi�r �Elementr7 r? r r r r� K s ��z+InstantiateVAppXML._make_instantiation_rootc C � t �|dd| ji�S )NZ VAppTemplater^ �r r� rv �r= �parentr r r r� V � z%InstantiateVAppXML._add_vapp_templatec C sZ t �|dddd��}| jr| �|d| j� | jr | �|d| j� | jr+| �|d| j� |S )NZProductSectionr� �&http://schemas.dmtf.org/ovf/envelope/1)�xmlns:q1� xmlns:ovfry rz r{ )r r� ry � _add_propertyrz r{ )r= r� Z prod_sectionr r r r� Y s �� z(InstantiateVAppXML._make_product_sectionc C s t �|dd||d��S )NZPropertyr� )r� zovf:keyz ovf:value)r r� )r= r� ZovfkeyZovfvaluer r r r� n s ��z InstantiateVAppXML._add_propertyc C s* t �|dddi�}| �|� | �|� |S )NZVirtualHardwareSectionr� r� )r r� �_add_cpu� _add_memory)r= r� Zvhr r r r� y s � z)InstantiateVAppXML._make_virtual_hardwarec C �< t �|dddi�}| �|d� | �|d� | �|| j� |S )N�Itemr� r� �1�3)r r� �_add_instance_id�_add_resource_type�_add_virtual_quantityrx )r= r� Zcpu_itemr r r r� � � � zInstantiateVAppXML._add_cpuc C r� )Nr� r� r� �2�4)r r� r� r� r� r; )r= r� Zmem_itemr r r r� � r� z InstantiateVAppXML._add_memoryc C � t �|dddi�}||_|S )NZ InstanceIDr� �Shttp://schemas.dmtf.org/wbem/wscim/1/cim-schema/2/CIM_ResourceAllocationSettingData�r r� r` )r= r� r6 �elmr r r r� � � ��z#InstantiateVAppXML._add_instance_idc C r� )NZ ResourceTyper� r� r� )r= r� rU r� r r r r� � r� z%InstantiateVAppXML._add_resource_typec C r� )NZVirtualQuantityr� r� r� )r= r� �amountr� r r r r� � r� z(InstantiateVAppXML._add_virtual_quantityc C r� )NZNetworkAssociationr^ )r r� rw r� r r r r� � r� z+InstantiateVAppXML._add_network_association�NNN)rC rD rE r> r r| r� r� r� r� r� r� r� r� r� r� r� r r r r ru " s$ � ru c @ s e Zd Zdd� ZdS )�VCloudResponsec C s | j tjtjtjtjfv S r/ )�statusr �OK�CREATED� NO_CONTENT�ACCEPTEDr? r r r �success� s �zVCloudResponse.successN)rC rD rE r� r r r r r� � s r� c sL e Zd ZdZeZdZdZ� fdd�Zdd� Z dd� Z d d � Z d d � Z � Z S ) �VCloudConnectionz0 Connection class for the vCloud driver Nc s | � � t� j|i |��S r/ )�_get_auth_token�super�request)r= �args�kwargs�� __class__r r r� � s zVCloudConnection.requestc C s | � � d S r/ )r� r? r r r � check_org� s zVCloudConnection.check_orgc C �, dt �td�| j| j����d� ddd�S )z1Some providers need different headers than others�Basic %s�{}:{}�utf-8�0�application/*+xml�Z Authorization�Content-Length�Accept��base64� b64encoder r% �user_id�key�decoder? r r r �_get_auth_headers� � ��z"VCloudConnection._get_auth_headersc C s� | j s?| jjdd| �� d� | j�� }|j}t�|j�}z|d | _ W n t y- t � �w t |� t |d���d��| j_d S d S )N�POSTz/api/v0.8/login��methodr2 �headersz set-cookie�Orgr^ )�token� connectionr� r� � getresponser� r �XMLr` �KeyErrorr r3 re r. rd r8 �org)r= �respr� �bodyr r r r� � s � �"�z VCloudConnection._get_auth_tokenc C s | j |d< d|d< |S )NZCookier� r� �r� �r= r� r r r �add_default_headers� s z$VCloudConnection.add_default_headers)rC rD rE rF r� Z responseClsr� �hostr� r� r� r� r� � __classcell__r r r� r r� � s r� c s$ e Zd ZdZejZdZdZe Z dZ dZ e je je je je jd�ZddgiZddddef� fd d � Zed d � �Zd d� Zdd� Zedd� �Zdd� Zdd� Zdd� Ze fdd�Z dd � Z d d � Z d d � Z d2d!d"�Z!d#d$� Z"d2d%d&�Z#d'd(� Z$d)d*� Z%d2d+d,�Z&d2d-d.�Z' / d3d0d1�Z(� Z)S )4�VCloudNodeDriverz vCloud node driver ZvCloudz&http://www.vmware.com/products/vcloud/N)r� r� r� r� r� � create_nodery Tc sX | t u r&|dkr t } n|dkrt} n|dkrt} n |dkr t} ntd| ��t� �| �S )Nr z1.5z5.1z5.5z,No VCloudNodeDriver found for API version %s)r� �VCloud_1_5_NodeDriver�VCloud_5_1_NodeDriver�VCloud_5_5_NodeDriver�NotImplementedErrorr� �__new__)rg r� ZsecretZsecurer� �port� api_versionr� r� r r r� s � zVCloudNodeDriver.__new__c sH � j s!� j�� � j�� j�}� fdd�|j�t|jd��D �� _ � j S )z� vCloud virtual data centers (vDCs). :return: list of vDC objects :rtype: ``list`` of :class:`Vdc` c s8 g | ]}|� d �dkr� �� j�t|� d���j��qS )rU �%application/vnd.vmware.vcloud.vdc+xmlr^ )rd �_to_vdcr� r� r3 �objectr r? r r r > s �z)VCloudNodeDriver.vdcs.<locals>.<listcomp>�Link)�_vdcsr� r� r� r� r� �findallr. )r= �resr r? r �vdcs2 s �zVCloudNodeDriver.vdcsc C s t |�d�|�d�| �S )Nr^ r7 )r4 rd )r= �vdc_elmr r r r� F s zVCloudNodeDriver._to_vdcc C sR d }|s | j d }|S | j D ]}|j|ks|j|kr |}q|d u r'td| ��|S )Nr z)%s virtual data centre could not be found)r� r7 r6 � ValueError)r= Zvdc_name�vdc�vr r r �_get_vdcI s �� zVCloudNodeDriver._get_vdcc C sH g }| j D ] }| j�t|j��j}|�dd� |�t|d��D �� q|S )Nc S r r r )r �networkr r r r ` r z-VCloudNodeDriver.networks.<locals>.<listcomp>zAvailableNetworks/Network) r� r� r� r3 r6 r� �extendr� r. )r= �networksr� r� r r r r� Y s �zVCloudNodeDriver.networksc C s" t |�d�|�d�| jjd�}|S )Nr^ r7 )r6 r7 r8 )r rd r� r8 )r= �imager r r � _to_imagee s �zVCloudNodeDriver._to_imagec C s� | j |�d� }|�d�}g }g }|�ddt|d�f �}|s'|�t|d��}|D ]!}dd� |�t|d ��D �}|�d �d krE|�|� q)|�|� q)t|�d �||||| jjd �} | S )Nr� r7 z%s/%sz@{http://schemas.dmtf.org/ovf/envelope/1}NetworkConnectionSection�NetworkConnectionz6Children/Vm/NetworkConnectionSection/NetworkConnectionc S s g | ]}|j �qS r r_ )r �ipr r r r � s z-VCloudNodeDriver._to_node.<locals>.<listcomp>� IpAddressZNetworkZInternalr^ )r6 r7 �state� public_ips� private_ipsr8 )�NODE_STATE_MAPrd r� r. r� r r� r8 ) r= r� r r7 r r Z connectionsr� �ipsrP r r r �_to_nodel s: ���� � zVCloudNodeDriver._to_nodec C s0 | j �| j�}dd� |j�t|jd��D �}|S )Nc S �$ g | ]}|� d �dkr|� d��qS )rU �)application/vnd.vmware.vcloud.catalog+xmlr^ �rd r r r r r � � �z7VCloudNodeDriver._get_catalog_hrefs.<locals>.<listcomp>r� )r� r� r� r� r� r. )r= r� Zcatalogsr r r �_get_catalog_hrefs� s �z#VCloudNodeDriver._get_catalog_hrefsc C s� t � � }| j�t|��}|j�d�}|dkrj|dkr7|j�t|jd��}d}|d ur/|�d�}td� ||���|dkrAtd | ��t � � | |krQtd � ||���t � d � | j�t|��}|j�d�}|dksd S d S ) Nr� r� �error�Errorz Unknown error�messagez%Error status returned by task {}.: {}Zcanceledz$Canceled status returned by task %s.z+Timeout ({} sec) while waiting for task {}.� ) �timer� r� r3 r� rd re r. rl r% �sleep)r= � task_href�timeoutZ start_timer� r� Z error_elemZ error_msgr r r �_wait_for_task_completion� s, � � �z*VCloudNodeDriver._wait_for_task_completionc C s� t |j�}z| jjd| dd�}| �|j�d�� W n ty# Y nw z| jjd| dd�}| �|j�d�� W n tyB Y n tyJ Y nw | jj|dd�}|j t j kS )Nz%s/power/action/poweroffr� �r� r^ �%s/action/undeploy�DELETE) r3 r6 r� r� r r� rd rl r r� r r� )r= rP Z node_pathr� r r r � destroy_node� s" � � z VCloudNodeDriver.destroy_nodec C s, | j jdt|j� dd�}|jtjtjfv S )N�%s/power/action/resetr� r )r� r� r3 r6 r� r r� r� �r= rP r� r r r � reboot_node� s �z VCloudNodeDriver.reboot_nodec C s | � � S r/ )� ex_list_nodesr? r r r � list_nodes� s zVCloudNodeDriver.list_nodesc C s� |s| j }t|ttf�s|g}g }|D ]`}| j�t|j��}|j� t |jd��}dd� |D �}|D ]A\}}z| jjt|�ddid�}|� | � |j�� W q1 t yr } z| jd j�d�rg| jd �d �d ksh� W Y d } ~ q1d } ~ ww q|S ) a3 List all nodes across all vDCs. Using 'vdcs' you can specify which vDCs should be queried. :param vdcs: None, vDC or a list of vDCs to query. If None all vDCs will be queried. :type vdcs: :class:`Vdc` :rtype: ``list`` of :class:`Node` � ResourceEntities/ResourceEntityc S s8 g | ]}|� d �dkr|� d�r|� d�|� d�f�qS )rU �&application/vnd.vmware.vcloud.vApp+xmlr7 r^ r r r r r r � s �z2VCloudNodeDriver.ex_list_nodes.<locals>.<listcomp>� Content-Typer �r� r r ZminorErrorCodeZ ACCESS_TO_RESOURCE_IS_FORBIDDENN)r� rn �list�tupler� r� r3 r6 r� r� r. �appendr rl r� r) �endswithrd ) r= r� Znodesr� r� ZelmsZvapps� vapp_name� vapp_hrefr& r r r r � s8 � �� ����z VCloudNodeDriver.ex_list_nodesc C s" t d d| |d d d | jjd�}|S )Nz%s Ram)r6 r7 �ramZdiskZ bandwidthZpricer8 )r r� r8 )r= r( �nsr r r �_to_size s � zVCloudNodeDriver._to_sizec s � fdd�t D �}|S )Nc s g | ]}� � |��qS r )r* r r? r r r s z/VCloudNodeDriver.list_sizes.<locals>.<listcomp>)�VIRTUAL_MEMORY_VALS)r= �locationZsizesr r? r � list_sizes s zVCloudNodeDriver.list_sizesc C s< | j jt|�ddid�j}|�t|d��}dd� |D �}|S )z9Given a catalog href returns contained catalog item hrefsr r r! zCatalogItems/CatalogItemc S r )rU �-application/vnd.vmware.vcloud.catalogItem+xmlr^ r r r r r r & r z<VCloudNodeDriver._get_catalogitems_hrefs.<locals>.<listcomp>)r� r� r3 r� r� r. )r= �catalogr� Z cat_itemsZcat_item_hrefsr r r �_get_catalogitems_hrefs s ���z(VCloudNodeDriver._get_catalogitems_hrefsc C s | j jt|�ddid�j}|S )z,Given a catalog item href returns elementreer r. r! )r� r� r3 r� )r= Z catalog_itemr� r r r �_get_catalogitem. s ��z!VCloudNodeDriver._get_catalogitemc s� g }� j D ] }� j�t|j��j}|�t|d��}|� fdd�|D �7 }q� �� D ]"}� � |�D ]}� � |�}|�t|d��}|� fdd�|D �7 }q0q)dd� }� � ||�S )Nr c �$ g | ]}|� d �dkr� �|��qS �rU z.application/vnd.vmware.vcloud.vAppTemplate+xml�rd r� r r? r r r = r z0VCloudNodeDriver.list_images.<locals>.<listcomp>ZEntityc r2 r3 r4 r r? r r r G r c S s | j S r/ �r6 )r� r r r �idfunM s z+VCloudNodeDriver.list_images.<locals>.idfun) r� r� r� r3 r6 r� r� r. r r0 r1 �_uniquer) r= r, Zimagesr� r� Zres_entsr/ Zcat_itemr6 r r? r � list_images7 s" � �� z VCloudNodeDriver.list_imagesc C sJ |d u rdd� }i }g }|D ]}||�}||v rqd||< |� |� q|S )Nc S s | S r/ r )�xr r r r6 U s z(VCloudNodeDriver._uniquer.<locals>.idfunr )r$ )r= �seqr6 �seen�result�item�markerr r r r7 R s zVCloudNodeDriver._uniquerr c C s z |p | j d �d�} W n ty d} Y nw d} | �|�}|j} t||j| t|�t|j�| || d�} | � |�} d}| j j dt | j� | � � dd |id �}t |j�d��}| j j d | dd �}| �|j�d�� | j j d | dd �}| j � |�}| �|j�}t|dd�r�|j|jd< |S )a3 Creates and returns node. :keyword ex_network: link to a "Network" e.g., ``https://services.vcloudexpress...`` :type ex_network: ``str`` :keyword ex_vdc: Name of organisation's virtual data center where vApp VMs will be deployed. :type ex_vdc: ``str`` :keyword ex_cpus: number of virtual cpus (limit depends on provider) :type ex_cpus: ``int`` :type ex_row: ``str`` :type ex_group: ``str`` r r^ � N)r7 rv rw rx r; ry rz r{ �?application/vnd.vmware.vcloud.instantiateVAppTemplateParams+xml�!%s/action/instantiateVAppTemplater� r ��datar� r� �%s/action/deployr z%s/power/action/powerOnZ generatedFry )r� rd � IndexErrorZ_get_and_check_authry ru r6 �strr( r� r� r� r3 r r� r r �getattr�extra)r= r7 �sizer� Zauth� ex_network�ex_vdcZex_cpusZex_rowZex_groupr� ry �instantiate_xmlr� � content_typer� Z vapp_pathrP r r r r� e sF � � � z VCloudNodeDriver.create_noder/ )NNNr NN)*rC rD rE rF r ZVCLOUDrU r7 Zwebsiter� � connectionClsr� r� r �PENDING�RUNNINGr Zfeatures�DEFAULT_API_VERSIONr� �propertyr� r� r� r� r� r r � DEFAULT_TASK_COMPLETION_TIMEOUTr r r r r r* r- r0 r1 r8 r7 r� r� r r r� r r� s` � � ' 0 �r� c @ s e Zd ZdZdZdd� ZdS )�HostingComConnectionz4 vCloud connection subclass for Hosting.com zvcloud.safesecureweb.comc C s t �td�| j| j���dd�S )zAhosting.com doesn't follow the standard vCloud authentication APIr� r� )ZAuthenticationr� )r� r� r r% r� r� r? r r r r� � s �z&HostingComConnection._get_auth_headersN)rC rD rE rF r� r� r r r r rT � � rT c @ s e Zd ZdZeZdS )�HostingComDriverz, vCloud node driver for Hosting.com N)rC rD rE rF rT rN r r r r rV � � rV c @ s e Zd ZdZdZdS )�TerremarkConnectionz2 vCloud connection subclass for Terremark z$services.vcloudexpress.terremark.comN)rC rD rE rF r� r r r r rX � rW rX c @ s e Zd ZdZeZdd� ZdS )�TerremarkDriverz* vCloud node driver for Terremark c C s t ddd| �gS )Nr zTerremark TexasZUS)r r? r r r �list_locations� s z TerremarkDriver.list_locationsN)rC rD rE rF rX rN rZ r r r r rY � rU rY c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�VCloud_1_5_Connectionc C r� )z:Compatibility for using v1.5 API under vCloud Director 5.1r� r� r� r� � application/*+xml;version=1.5r� r� r? r r r r� � r� z'VCloud_1_5_Connection._get_auth_headersc s � j s�� jjdd� �� d� � j�� }|j}z|d � _ W n ty' t� �w t� |j �}|� d�� _ t tdd� |�t|d��D ��� d ��}� jd urT� j�� j� � jjd |� �i �d� t� � j�� j �}t t� fd d�|�t|d ��D ��� d ��� j_d S d S ) Nr� z /api/sessionsr� �x-vcloud-authorizationr� c s s" � | ] }|� d �dkr|V qdS )rU z)application/vnd.vmware.vcloud.orgList+xmlNr �r �linkr r r � <genexpr> s � ��z8VCloud_1_5_Connection._get_auth_token.<locals>.<genexpr>r� r^ ZGETc 3 s$ � | ] }|� d �� jkr|V qdS )r7 N)rd �org_name)r r� r? r r r` s � ��r� )r� r� r� r� r� r� r� r r r� r` rd ra r3 r r� r. Z proxy_urlZset_http_proxyr� r8 r� )r= r� r� r� Z org_list_urlr r? r r� � s@ � � �� � � ��z%VCloud_1_5_Connection._get_auth_tokenc C � d|d< | j |d< |S )Nr\ r� r] r� r� r r r r� � z)VCloud_1_5_Connection.add_default_headersN)rC rD rE r� r� r� r r r r r[ � s -r[ c s$ e Zd Z� fdd�Zdd� Z� ZS )�VCloud_5_5_Connectionc s t � �� }d|d< |S )z'Compatibility for using v5.5 of the API� application/*+xml;version=5.5r� )r� r� )r= Z auth_headersr� r r r� s z'VCloud_5_5_Connection._get_auth_headersc C rb )Nre r� r] r� r� r r r r� ' rc z)VCloud_5_5_Connection.add_default_headers)rC rD rE r� r� r� r r r� r rd s rd c @ s> e Zd Zddd�Zdd� Zdd� Zdd � Zd d � Zd d � ZdS )�Instantiate_1_5_VAppXMLNc C s0 || _ || _|| _|| _|| _|| _| �� d S r/ )r7 rv r� � vm_network�vm_fence� descriptionr| )r= r7 rv r� rg rh ri r r r r> / s z Instantiate_1_5_VAppXML.__init__c C r} r/ r~ r? r r r r 8 r� z Instantiate_1_5_VAppXML.tostringc C s� | � � | _| jd ur+t�| jd�}t�|d�}t�|dddi� t�|d�}| �|� | jd ur9| jt�| jd�_| �| j� d S )Nr� r� ZInfor� r� r� � Description) r� r, r� r r� r� ri r` r� r� r r r r| ; s � z&Instantiate_1_5_VAppXML._build_xmltreec C s t �d| jdddddd��S )Nr� �falser� �!http://www.vmware.com/vcloud/v1.5r� )r7 �deploy�powerOnr� r� r� r� r? r r r r� N s ��z0Instantiate_1_5_VAppXML._make_instantiation_rootc C r� )N�Sourcer^ r� r� r r r r� [ r� z*Instantiate_1_5_VAppXML._add_vapp_templatec C s� | j d u r|�d| j�d�� n|�d| j � t�|d�}t�|dd| j�d�i� | jd u r;| j�t| jd��j }n| j}|t�|d�_ d S )NZ networkNamer7 Z ConfigurationZ ParentNetworkr^ zConfiguration/FenceModeZ FenceMode) rg �setr� rd r r� rh re r. r` )r= r� Z configurationZ fencemoder r r r� ^ s z0Instantiate_1_5_VAppXML._add_network_associationr� ) rC rD rE r> r r| r� r� r� r r r r rf . s rf c @ s� e Zd ZeZejejejejejejejejejej ejejd� Z dd� Z dddd�Z dedd �Z dfd d �Zd d� Zdgdd�Zdgdd�Zdfdd�Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zdhd*d+�Z d,d-� Z ddd.d/�Z d0d1� Z d2d3� Z d4d5� Z!d6d7� Z"e#d8d9� �Z$e#d:d;� �Z%e#d<d=� �Z&e#d>d?� �Z'e#d@dA� �Z(e#dBdC� �Z)e#dDdE� �Z*dFdG� Z+dHdI� Z,dJdK� Z-dLdM� Z.dddNdO�Z/dPdQ� Z0e#dRdS� �Z1dTdU� Z2dVdW� Z3dXdY� Z4dZd[� Z5d\d]� Z6d^d_� Z7d`da� Z8dbdc� Z9dS )ir� ) z-1r� r� r� r� r� �5�6�7�8�9�10c C s t | jj| jjd| d�gS )NzN/A)r6 r7 Zcountryr8 )r r� r� r? r r r rZ � s ��z$VCloud_1_5_NodeDriver.list_locationsNc C s� |s| j }t|dd�s|g}|D ]8}| j�t|j��}t|jd�}|j�|�}|D ] }|� d�dkrG|� d�|krG|� d�}| � |� S q)qdS ) a� Searches for node across specified vDCs. This is more effective than querying all nodes to get a single instance. :param node_name: The name of the node to search for :type node_name: ``str`` :param vdcs: None, vDC or a list of vDCs to search in. If None all vDCs will be searched. :type vdcs: :class:`Vdc` :return: node instance or None if not found :rtype: :class:`Node` or ``None`` �__iter__Fr rU r r7 r^ N) r� rG r� r� r3 r6 r. r� r� rd � _ex_get_node) r= Z node_namer� r� r� r- Z entity_elemsZ entity_elemr1 r r r � ex_find_node� s �� z"VCloud_1_5_NodeDriver.ex_find_node�2 c s, � j ddj|d�d|d�}� fdd�|D �S )aS Finds nodes that contain a VM with the specified name. :param vm_name: The VM name to find nodes for :type vm_name: ``str`` :param max_results: Maximum number of results up to 128 :type max_results: ``int`` :return: List of node instances :rtype: `list` of :class:`Node` �vmzname=={vm_name})�vm_namer )�filter�page� page_sizec s g | ] }� � |d ��qS )� container)rx )r r{ r? r r r � s z:VCloud_1_5_NodeDriver.ex_find_vm_nodes.<locals>.<listcomp>)�ex_queryr% )r= r| Z max_results�vmsr r? r �ex_find_vm_nodes� s �z&VCloud_1_5_NodeDriver.ex_find_vm_nodesTc C sH z | j ||d� W n ty Y nw | jjt|j�dd�}|jtjkS )N)�shutdownr r ) �ex_undeploy_noderl r� r� r3 r6 r� r r� )r= rP r� r� r r r r � s � z"VCloud_1_5_NodeDriver.destroy_nodec C sF | j jdt|j� dd�}|jtjtjfv r!| �|j � d�� dS dS )Nr r� r r^ TF) r� r� r3 r6 r� r r� r� r r� rd r r r r r � s �z!VCloud_1_5_NodeDriver.reboot_nodeFc C sZ |r| � |j�}|D ] }| j|�d�dd� q n| �|j� | j�t|j��}| �|j�S )a� Deploys existing node. Equal to vApp "start" operation. :param node: The node to be deployed :type node: :class:`Node` :param ex_force_customization: Used to specify whether to force customization on deployment, if not set default value is False. :type ex_force_customization: ``bool`` :rtype: :class:`Node` r^ T)�ex_force_customization) �_get_vm_elementsr6 �_ex_deploy_node_or_vmrd r� r� r3 r r� )r= rP r� r� r{ r� r r r �ex_deploy_node� s � z$VCloud_1_5_NodeDriver.ex_deploy_nodec C sd dt |��� dd�}t�d|�}t|�}ddi}| jjd| t�|�d|d �}| �|j � d �� d S ) N�truerl )rn ZforceCustomizationr� ZDeployVAppParamsr z2application/vnd.vmware.vcloud.deployVAppParams+xmlrD r� rB r^ ) rF �lowerr r� r3 r� r� r r r� rd )r= Zvapp_or_vm_pathr� rC Z deploy_xmlr1 r� r� r r r r� � s � �z+VCloud_1_5_NodeDriver._ex_deploy_node_or_vmc s� ddi}t �d|��t ��d��ddi� � ����fdd�}|r4z|d � W n ty3 |d � Y nw |d � �j�t�j��}��|j �S ) aF Undeploys existing node. Equal to vApp "stop" operation. :param node: The node to be deployed :type node: :class:`Node` :param shutdown: Whether to shutdown or power off the guest when undeploying :type shutdown: ``bool`` :rtype: :class:`Node` r� rl ZUndeployVAppParamsZUndeployPowerActionr z4application/vnd.vmware.vcloud.undeployVAppParams+xmlc s@ | �_ �jjdt�j� t���d� d�}��|j� d�� d S )Nr r� rB r^ ) r` r� r� r3 r6 r r r r� rd )�actionZ undeploy_res�r� rP r= Zundeploy_power_action_xmlZ undeploy_xmlr r �undeploy! s �z8VCloud_1_5_NodeDriver.ex_undeploy_node.<locals>.undeployr� �powerOff) r r� r� rl r� r� r3 r6 r r� )r= rP r� rC r� r� r r� r r� s � z&VCloud_1_5_NodeDriver.ex_undeploy_nodec C � | � |d�S )a Powers on all VMs under specified node. VMs need to be This operation is allowed only when the vApp/VM is powered on. :param node: The node to be powered off :type node: :class:`Node` :rtype: :class:`Node` r� ��_perform_power_operation�r= rP r r r �ex_power_off_node7 � z'VCloud_1_5_NodeDriver.ex_power_off_nodec C r� )a Powers on all VMs under specified node. This operation is allowed only when the vApp/VM is powered off or suspended. :param node: The node to be powered on :type node: :class:`Node` :rtype: :class:`Node` rn r� r� r r r �ex_power_on_nodeD r� z&VCloud_1_5_NodeDriver.ex_power_on_nodec C r� )z� Shutdowns all VMs under specified node. This operation is allowed only when the vApp/VM is powered on. :param node: The node to be shut down :type node: :class:`Node` :rtype: :class:`Node` r� r� r� r r r �ex_shutdown_nodeQ r� z&VCloud_1_5_NodeDriver.ex_shutdown_nodec C r� )z� Suspends all VMs under specified node. This operation is allowed only when the vApp/VM is powered on. :param node: The node to be suspended :type node: :class:`Node` :rtype: :class:`Node` Zsuspendr� r� r r r �ex_suspend_node^ r� z%VCloud_1_5_NodeDriver.ex_suspend_nodec C sN | j jd�t|j�|�dd�}| �|j�d�� | j �t|j��}| �|j�S )Nz{}/power/action/{}r� r r^ ) r� r� r% r3 r6 r r� rd r )r= rP � operationr� r r r r� k s � z.VCloud_1_5_NodeDriver._perform_power_operationc C s | j �dt|j� �}d}|j�t|jd��}|dur+|jdkr+|j�t|jd��j}g }t|jd�}|j�|�D ]D}|�t|jd��j}|�t|jd��} | � d �d krXd } nd } t| � d ��} | j �| �}|j� d�} t | | || � d �d�} |� | � q9t |||�S )z� Returns the control access settings for specified node. :param node: node to get the control access for :type node: :class:`Node` :rtype: :class:`ControlAccess` z%s/controlAccessN�IsSharedToEveryoner� �EveryoneAccessLevelz AccessSettings/AccessSettingrN rS rU z&application/vnd.vmware.admin.group+xmlr{ �userr^ r7 rT ) r� r� r3 r6 r� re r. r` r� rd rS r$ rM )r= rP r� rQ Zis_shared_elemrR r- ra rV Z subject_elemZ subj_typer1 r7 �subjectr r r �ex_get_control_accesst s8 �� � z+VCloud_1_5_NodeDriver.ex_get_control_accessc C s t �dddi�}t �|d�}|jr d|_t �|d�}|j|_nd|_|jrlt �|d�}|jD ]=}t �|d �}|jr=|j} n | j|jd |j d �} | sTt d � |j|j ���| d d } t �|dd| i� |j t �|d�_q.ddi} | j jdt|j� t �|�| dd� dS )a Sets control access for the specified node. :param node: node :type node: :class:`Node` :param control_access: control access settings :type control_access: :class:`ControlAccess` :rtype: ``None`` ZControlAccessParamsr� rl r� r� r� rk ZAccessSettingsZ AccessSettingzname==)rU r} z$Specified subject "{} {}" not found r r^ rS rN r z/application/vnd.vmware.vcloud.controlAccess+xmlz%s/action/controlAccessr� �rC r� r� N)r r� r� rQ r` rR r6 r� rU r7 r r% rV r� r� r3 r ) r= rP Zcontrol_accessZxmlZshared_to_everyonerQ Zaccess_settings_elemr� Zsettingr^ r� r� r r r �ex_set_control_access� s< �� �z+VCloud_1_5_NodeDriver.ex_set_control_accessc C sl | j �dt|j� �}t|jd�}|j�|�}i }|D ]}|�t|jd��}|�t|jd��}|||< q|S )z� :param node: node :type node: :class:`Node` :return: dictionary mapping metadata keys to metadata values :rtype: dictionary mapping ``str`` to ``str`` � %s/metadata� MetadataEntry�Key�Value)r� r� r3 r6 r. r� r� �findtext) r= rP r� r- Zmetadata_entriesZres_dict�entryr� �valuer r r �ex_get_metadata� s z%VCloud_1_5_NodeDriver.ex_get_metadatac C s� t �dddd��}t �|d�}t �|d�}||_t �|d�}||_| jjdt|j� t �|�d d id d �}| � |j � d �� dS )z� :param node: node :type node: :class:`Node` :param key: metadata key to be set :type key: ``str`` :param value: metadata value to be set :type value: ``str`` :rtype: ``None`` ZMetadatarl r� )r� r� r� r� r� r� r z*application/vnd.vmware.vcloud.metadata+xmlr� r� r^ N) r r� r� r` r� r� r3 r6 r r r� rd ) r= rP r� r� Z metadata_elemr� Zkey_elemZ value_elemr� r r r �ex_set_metadata_entry� s$ �� �z+VCloud_1_5_NodeDriver.ex_set_metadata_entryr �d c C s� |||d�}|r ||d< |r||d< dt |� }|r/|�d�s%d| d }|d|�dd � 7 }g } | j�|�} | jD ]} | j�d �sT| j} | j� d �d | d < | � | � q:| S )a! Queries vCloud for specified type. See http://www.vmware.com/pdf/vcd_15_api_guide.pdf for details. Each element of the returned list is a dictionary with all attributes from the record. :param type: type to query (r.g. user, group, vApp etc.) :type type: ``str`` :param filter: filter expression (see documentation for syntax) :type filter: ``str`` :param page: page number :type page: ``int`` :param page_size: page size :type page_size: ``int`` :param sort_asc: sort in ascending order by specified field :type sort_asc: ``str`` :param sort_desc: sort in descending order by specified field :type sort_desc: ``str`` :rtype: ``list`` of dict )rU ZpageSizer~ ZsortAscZsortDescz /api/query?�(�)z&filter=� �+r� r# r rU ) r � startswith�replacer� r� r� r) r% �attribr* r$ ) r= rU r} r~ r Zsort_ascZ sort_desc�paramsr2 �resultsr� ra r< r r r r� s, � �z VCloud_1_5_NodeDriver.ex_queryc K sF |d }|d }|� d�}|� d�}|� d�}|� d�}|� dd�}|� d d�} |� d d�} |� d d�} |� d d�} |� d d�} |� dd�}|� dd�}|� dt�}|� dd�}|� dd�}| �|� | �|� | �|� | �| � | �| � | �|�}| r�| �| �}| j � t |��j }nd}| � |�}| �|�r�| �||||�\}}n| j||||| | ||d�\}}| �||� | �||� | �||� | �|||� | �|| � |dur�| �||� | �r| j � t |��}| �|j �}d} z| �||� W n t�y |dk�r� |d8 }t�d� Y nw q�| j � t |��}| �|j �}|S )a� Creates and returns node. If the source image is: - vApp template - a new vApp is instantiated from template - existing vApp - a new vApp is cloned from the source vApp. Can not clone more vApps is parallel otherwise resource busy error is raised. @inherits: :class:`NodeDriver.create_node` :keyword image: OS Image to boot on node. (required). Can be a NodeImage or existing Node that will be cloned. :type image: :class:`NodeImage` or :class:`Node` :keyword ex_network: Organisation's network name for attaching vApp VMs to. :type ex_network: ``str`` :keyword ex_vdc: Name of organisation's virtual data center where vApp VMs will be deployed. :type ex_vdc: ``str`` :keyword ex_vm_names: list of names to be used as a VM and computer name. The name must be max. 15 characters long and follow the host name requirements. :type ex_vm_names: ``list`` of ``str`` :keyword ex_vm_cpu: number of virtual CPUs/cores to allocate for each vApp VM. :type ex_vm_cpu: ``int`` :keyword ex_vm_memory: amount of memory in MB to allocate for each vApp VM. :type ex_vm_memory: ``int`` :keyword ex_vm_script: full path to file containing guest customisation script for each vApp VM. Useful for creating users & pushing out public SSH keys etc. :type ex_vm_script: ``str`` :keyword ex_vm_script_text: content of guest customisation script for each vApp VM. Overrides ex_vm_script parameter. :type ex_vm_script_text: ``str`` :keyword ex_vm_network: Override default vApp VM network name. Useful for when you've imported an OVF originating from outside of the vCloud. :type ex_vm_network: ``str`` :keyword ex_vm_fence: Fence mode for connecting the vApp VM network (ex_vm_network) to the parent organisation network (ex_network). :type ex_vm_fence: ``str`` :keyword ex_vm_ipmode: IP address allocation mode for all vApp VM network connections. :type ex_vm_ipmode: ``str`` :keyword ex_deploy: set to False if the node shouldn't be deployed (started) after creation :type ex_deploy: ``bool`` :keyword ex_force_customization: Used to specify whether to force customization on deployment, if not set default value is False. :type ex_force_customization: ``bool`` :keyword ex_clone_timeout: timeout in seconds for clone/instantiate VM operation. Cloning might be a time consuming operation especially when linked clones are disabled or VMs are created on different datastores. Overrides the default task completion value. :type ex_clone_timeout: ``int`` :keyword ex_admin_password: set the node admin password explicitly. :type ex_admin_password: ``str`` :keyword ex_description: Set a description for the vApp. :type ex_description: ``str`` r7 r� � ex_vm_names� ex_vm_cpu� ex_vm_memory� ex_vm_script�ex_vm_script_textN� ex_vm_fencerJ � ex_vm_network� ex_vm_ipmode� ex_deployTr� FrK �ex_clone_timeout�ex_admin_password�ex_description)ri � r r � ) rd rS �_validate_vm_names�_validate_vm_cpu�_validate_vm_memory�_validate_vm_fence�_validate_vm_ipmode�_validate_vm_script�_get_network_hrefr� r� r3 r� r� �_is_node� _clone_node�_instantiate_node�_change_vm_names�_change_vm_cpu�_change_vm_memory�_change_vm_script�_change_vm_ipmode�ex_change_vm_admin_passwordr r� rl r r )r= r� r7 r� r� r� r� r� r� r� rJ r� r� r� r� rK r� r� r� � network_href� network_elemr� r& r' r� rP Zretryr r r r� H s� V � �� z!VCloud_1_5_NodeDriver.create_nodec C s� t ||j||||d�} ddi} | jjdt|j� | �� d| d�} | j�d�} | j�d�} | j�t | jd ���d�}| � ||� | | fS ) N)r7 rv r� rg rh ri r r@ rA r� rB r7 r^ � Tasks/Task) rf r6 r� r� r3 r r� rd re r. r )r= r7 r� r� r� rg rh Zinstantiate_timeoutri rL r� r� r& r' r r r r r� � s* � � � z'VCloud_1_5_NodeDriver._instantiate_nodec C s� t �d|ddddd��}d|j t �|d�_t �|dd |ji� d d i}| jjd t|j� t � |�d |d�}|j � d�}|j � d �} |j � t |j d��� d �} | �| |� | j�t| ��}|j �t |j d��} t| �D ]�\} } t �ddddd��}dt �|d�_d di}| jjdt| � d �� t � |�d|d�}| �|j � d �� | � t | d��}|� t |d��}|�dd � |�|� t |d ��� |�|� t |d ��� d di}| jjdt| � d �� t � |�d|d�}| �|j � d �� qk|| fS ) NZCloneVAppParamsrk rl r� )r7 rm rn r� r� z Clone of rj ro r^ r z1application/vnd.vmware.vcloud.cloneVAppParams+xmlz%s/action/cloneVAppr� rB r7 r� � Children/VmZNetworkConnectionSectionr� )z ovf:requiredr� r� z.Specifies the available VM network connectionszovf:Info�:application/vnd.vmware.vcloud.networkConnectionSection+xml�%s/networkConnectionSection�PUTr� ZneedsCustomizationr� r Z MACAddress)r r� r7 r� r` r6 r� r� r3 r r� rd re r. r r� � enumeraterp �remove)r= r7 Z sourceNoder� Z clone_timeoutZ clone_xmlr� r� r& r' r r� r r{ Z network_xmlZnetwork_conn_xmlr r r r� sp �� � �� �� �z!VCloud_1_5_NodeDriver._clone_nodec C � | � |� | �||� dS )a) Sets the number of virtual CPUs for the specified VM or VMs under the vApp. If the vapp_or_vm_id param represents a link to an vApp all VMs that are attached to this vApp will be modified. Please ensure that hot-adding a virtual CPU is enabled for the powered on virtual machines. Otherwise use this method on undeployed vApp. :keyword vapp_or_vm_id: vApp or VM ID that will be modified. If a vApp ID is used here all attached VMs will be modified :type vapp_or_vm_id: ``str`` :keyword vm_cpu: number of virtual CPUs/cores to allocate for specified VMs :type vm_cpu: ``int`` :rtype: ``None`` N)r� r� )r= � vapp_or_vm_id�vm_cpur r r � ex_set_vm_cpua � z#VCloud_1_5_NodeDriver.ex_set_vm_cpuc C r� )aB Sets the virtual memory in MB to allocate for the specified VM or VMs under the vApp. If the vapp_or_vm_id param represents a link to an vApp all VMs that are attached to this vApp will be modified. Please ensure that hot-change of virtual memory is enabled for the powered on virtual machines. Otherwise use this method on undeployed vApp. :keyword vapp_or_vm_id: vApp or VM ID that will be modified. If a vApp ID is used here all attached VMs will be modified :type vapp_or_vm_id: ``str`` :keyword vm_memory: virtual memory in MB to allocate for the specified VM or VMs :type vm_memory: ``int`` :rtype: ``None`` N)r� r� )r= r� � vm_memoryr r r �ex_set_vm_memoryy r� z&VCloud_1_5_NodeDriver.ex_set_vm_memoryc C r� )a� Adds a virtual disk to the specified VM or VMs under the vApp. If the vapp_or_vm_id param represents a link to an vApp all VMs that are attached to this vApp will be modified. :keyword vapp_or_vm_id: vApp or VM ID that will be modified. If a vApp ID is used here all attached VMs will be modified :type vapp_or_vm_id: ``str`` :keyword vm_disk_size: the disk capacity in GB that will be added to the specified VM or VMs :type vm_disk_size: ``int`` :rtype: ``None`` N)�_validate_vm_disk_size� _add_vm_disk)r= r� Z vm_disk_sizer r r �ex_add_vm_disk� s z$VCloud_1_5_NodeDriver.ex_add_vm_diskc C sX | d u rd S | D ]!}t |�dkrtd| d ��t�|�s)td| d | d ��qdS )N� z The VM name "z;" is too long for the computer name (max 15 chars allowed).z" can not be used. "z*" is not a valid computer name for the VM.T)�lenr� � HOSTNAME_RE�match)�namesr7 r r r r� � s" � ����z(VCloud_1_5_NodeDriver._validate_vm_namesc C �$ | d u rd S | t vrtd| ��d S )N�&%s is not a valid vApp VM memory value)r+ r� �r� r r r r� � � �z)VCloud_1_5_NodeDriver._validate_vm_memoryc C r� )Nz#%s is not a valid vApp VM CPU value)�VIRTUAL_CPU_VALS_1_5r� )r� r r r r� � r� z&VCloud_1_5_NodeDriver._validate_vm_cpuc C s& | d u rd S t | �dk rtd| ��d S )Nr z*%s is not a valid vApp VM disk space value)rf r� )�vm_diskr r r r� � s �z,VCloud_1_5_NodeDriver._validate_vm_disk_sizec C sl | d u rd S t j�| �st j�| �} t j�| �} t j�| �s$td| ��z t| ��� W | S t y5 � w )Nz$%s the VM script file does not exist) �osr1 �isabs� expanduser�abspath�isfiler �open�readrl )� vm_scriptr r r r� � s ��z)VCloud_1_5_NodeDriver._validate_vm_scriptc C r� )Nz$%s is not a valid fencing mode value)�FENCE_MODE_VALS_1_5r� )rh r r r r� � r� z(VCloud_1_5_NodeDriver._validate_vm_fencec C s4 | d u rd S | dkrt d��| tvrtd| ��d S )Nr" zHMANUAL IP mode: The interface for supplying IPAddress does not exist yetz2%s is not a valid IP address allocation mode value)r� �IP_MODE_VALS_1_5r� )� vm_ipmoder r r r� � s � �z)VCloud_1_5_NodeDriver._validate_vm_ipmodec C s |d u rd S | � |�}t|�D ]w\}}t|�|kr d S | j�dt|�d�� �}|| |j�t |jd��_ | � |j� ddi}| jjdt|�d�� t � |j�d|d�}| �|j�d�� t �d|| d d ��}| jjt|�d��t � |�ddd id�}| �|j�d�� qd S ) N� %s/guestCustomizationSectionr^ Z ComputerNamer �;application/vnd.vmware.vcloud.guestCustomizationSection+xmlr� rB �Vmrl )r7 r� z$application/vnd.vmware.vcloud.vm+xml)r� r� r� r� r� r3 rd r� re r. r` �_remove_admin_passwordr r r r� ) r= r� Zvm_namesr� r r{ r� r� Zreq_xmlr r r r� � s@ � � � � ��z&VCloud_1_5_NodeDriver._change_vm_namesc C � |d u rd S | � |�}|D ]<}| j�dt|�d�� �}d}t|�|j�|�_ddi}| jjdt|�d�� t � |j�d|d�}| � |j�d�� q d S )Nz %s/virtualHardwareSection/cpur^ �d{http://schemas.dmtf.org/wbem/wscim/1/cim-schema/2/CIM_ResourceAllocationSettingData}VirtualQuantityr �*application/vnd.vmware.vcloud.rasdItem+xmlr� rB � r� r� r� r3 rd rF r� re r` r r r )r= r� r� r� r{ r� r- r� r r r r� ! �& �� ��z$VCloud_1_5_NodeDriver._change_vm_cpuc C r� )Nz %s/virtualHardwareSection/memoryr^ r r r r� rB r )r= r� r� r� r{ r� r- r� r r r r� = r z'VCloud_1_5_NodeDriver._change_vm_memoryc C s| |d u rd S d}| � |�}|D ]�}| j�dt|�d�� �}g }d }|j�t|jd��D ]1} | D ]!} | jd| krA|� t | j �� | jd| d| fv rQ| � | � q0| � d| �d ur]| }q,t�|�}t|�d } t| �|� d| �_ d t| � |� d | �_ |� d| ��t|d �tt |�d �� |j� |� ddi} | jjdt|�d�� t�|j�d| d�}| �|j�d�� qd S )NzU{http://schemas.dmtf.org/wbem/wscim/1/cim-schema/2/CIM_ResourceAllocationSettingData}z %s/virtualHardwareSection/disksr^ r� z %sInstanceIDz%sAddressOnParentz%sParentz%sHostResourcer z Hard Disk z %sElementNameZcapacityr r z/application/vnd.vmware.vcloud.rasditemslist+xmlr� rB )r� r� r� r3 rd r� r� r. r) r$ rf r` r� re �copy�deepcopy�maxrF rp r r r ) r= r� r� Zrasd_nsr� r{ r� Z existing_idsZnew_diskr= ra Zdisk_idr� r r r r� Y sR � �� �� � ��z"VCloud_1_5_NodeDriver._add_vm_diskc C s\ |d u r |d u r d S |d ur|}n%zt |�� }|�� }W d � n1 s%w Y W n ty5 Y d S w | �|�}|D ]n}| j�dt|�d�� �}z ||j� t |jd��_ W n) ty� t |j�D ] \} } | j dkrp nqet�d�} || _ |j�| | � Y nw | �|j� ddi} | jjdt|�d�� t�|j�d| d �}| �|j�d�� q=d S ) Nr� r^ ZCustomizationScriptz/{http://www.vmware.com/vcloud/v1.5}ComputerNamez6{http://www.vmware.com/vcloud/v1.5}CustomizationScriptr r� r� rB )r� r� rl r� r� r� r3 rd r� re r. r` r� r) r r� �insertr� r r ) r= r� r� Zvm_script_textZscript�fpr� r{ r� r r& r� r r r r� � sN �� � � � � � ��z'VCloud_1_5_NodeDriver._change_vm_scriptc C s� |d u rd S | � |�}|D ]I}| j�dt|�d�� �}|j�t|jd��}|D ] }||�t|d��_ q(ddi}| jjdt|�d�� t � |j�d|d�}| � |j�d�� q d S ) Nr� r^ r� ZIpAddressAllocationModer r� r� rB ) r� r� r� r3 rd r� r� r. re r` r r r ) r= r� r� r� r{ r� Z net_conns�cr� r r r r� � s& � ��z'VCloud_1_5_NodeDriver._change_vm_ipmodec C sr | � t| d��}| � t| d��}| � t| d��}|dur5|du s.|jdks.|du s.|jdkr7| �|� dS dS dS )a� Remove AdminPassword element from GuestCustomizationSection if it would be invalid to include it. This was originally done unconditionally due to an "API quirk" of unknown origin or effect. When AdminPasswordEnabled is set to true and AdminPasswordAuto is false, the admin password must be set or an error will ensue, and vice versa. :param guest_customization_section: GuestCustomizationSection element to remove password from (if valid to do so) :type guest_customization_section: ``ET.Element`` �AdminPasswordEnabled�AdminPasswordAuto� AdminPasswordNr� rk )re r. r` r� )Zguest_customization_sectionZadmin_pass_enabledZadmin_pass_autoZ admin_passr r r r� � s" ��� �z,VCloud_1_5_NodeDriver._remove_admin_passwordc C s~ z||j �t|j |��_W |S ty> t|j �D ]\}}d| }|j|kr) nqt�d| �}||_|j � ||� Y |S w )Nz%{http://www.vmware.com/vcloud/v1.5}%s) r� re r. r` rl r� r) r r� r )r= r� �sectionZ prev_sectionr` r r& r) r r r �_update_or_insert_section s � ��z/VCloud_1_5_NodeDriver._update_or_insert_sectionc C s� |du rdS | � |�}|D ]d}| j�dt|�d�� �}ddi}|j�t|jd��}|dur;|jdkr;| � |dd d � | � |d d d� | � |d d d� | � |d d|� | jjdt|�d�� t � |j�d|d�}| � |j�d�� q dS )aV Changes the admin (or root) password of VM or VMs under the vApp. If the vapp_or_vm_id param represents a link to an vApp all VMs that are attached to this vApp will be modified. :keyword vapp_or_vm_id: vApp or VM ID that will be modified. If a vApp ID is used here all attached VMs will be modified :type vapp_or_vm_id: ``str`` :keyword ex_admin_password: admin password to be used. :type ex_admin_password: ``str`` :rtype: ``None`` Nr� r^ r r� ZAdminAutoLogonEnabledrk ZAdminAutoLogonCountZResetPasswordRequiredr� r r r r� r� rB ) r� r� r� r3 rd r� re r. r` r r r r )r= r� r� r� r{ r� r� Z auto_logonr r r r� s6 �� �� ��z1VCloud_1_5_NodeDriver.ex_change_vm_admin_passwordc C sn d }| j �| j�}|j�t|jd��}|D ]}|jd dkr*|jd |kr*|jd }q|d u r5td| ��|S )Nr� rU z,application/vnd.vmware.vcloud.orgNetwork+xmlr7 r^ z+%s is not a valid organisation network name)r� r� r� r� r� r. r� r� )r= Z network_namer� r� Zlinksr_ r r r r� S s � z'VCloud_1_5_NodeDriver._get_network_hrefc C s$ | j jt|�ddid�}| �|j�S )z� Get a node instance from a node ID. :param node_id: ID of the node :type node_id: ``str`` :return: node instance or None if not found :rtype: :class:`Node` or ``None`` r r r! )r� r� r3 r r� )r= Znode_idr� r r r rx f s � z"VCloud_1_5_NodeDriver._ex_get_nodec C sX | j �t|��}|jj�d�r|j�t|jd��}|S |jj�d�r(|jg}|S td��)NZVAppr� r� z8Specified ID value is not a valid VApp or Vm identifier.) r� r� r3 r� r) r% r� r. r� )r= r� r� r� r r r r� w s ��z&VCloud_1_5_NodeDriver._get_vm_elementsc C s t |t�S r/ )rn r )r= Z node_or_imager r r r� � rs z VCloud_1_5_NodeDriver._is_nodec sb |� t|d��d u r d }n g }|�t|d��D ]}|�|�d�|�d�|�d�d�� qg }|�t|d��D ]o}g }g }t|d�}|�|�D ]1} | � t| d ��} | d urZ|�| j� | � t| d ��} | d urm|�| j� qF| d urw|�| j� qFd }|� |�} | d ur�| �d �} nd } |�d �|�d�| j|�d� ||| d�}|�|� q6g }g }|D ]}|�|d � |�|d � q�tdd� |�t|d��D ��� t� fdd�| j D ��}|j |d�}|� t|d��}|d ur�|j|d< nd|d< |� t|d��}|d u�r t � |�|d < nd |d < |d u�r||d < t |�d �|�d�| j|�d� ||| jj|d �}|S ) NZSnapshotSectionzSnapshotSection/Snapshot�created� poweredOnrI )r r rI r� z*NetworkConnectionSection/NetworkConnectionr ZExternalIpAddressz>{http://schemas.dmtf.org/ovf/envelope/1}OperatingSystemSectionz({http://www.vmware.com/schema/ovf}osTyper^ r7 r� )r6 r7 r r r �os_typer r c s s( � | ]}|� d �dkr|� d�V qdS )rU r� r^ Nr r^ r r r r` � s � ��z1VCloud_1_5_NodeDriver._to_node.<locals>.<genexpr>r� c 3 s � | ] }|j � kr|V qd S r/ r5 )r r� �Zvdc_idr r r` � s � )r� r� rj ri r? ZLeaseSettingsSection�lease_settings� snapshots)r6 r7 r r r r8 rH )re r. r� r$ rd r` r r� r r� r7 rW rh r r� r8 )r= Znode_elmr Z snapshot_elemr� Zvm_elemr r r- r� r� Z external_ipZ os_type_elemr r{ r� rH ri r rP r r r r � s� �� � � � � z VCloud_1_5_NodeDriver._to_nodec C sr dd� }||� t|d���}||� t|d���}||� t|d���}t|�d�|�d�| |�t|d��|||d �S ) Nc S sP | d u rd S t | �t| d���}t | �t| d���}| �t| d��}t|||�S )NZLimitZUsedZUnits)rf r� r. rG )Z capacity_elmrH rI rJ r r r �get_capacity_values� s z:VCloud_1_5_NodeDriver._to_vdc.<locals>.get_capacity_valueszComputeCapacity/CpuzComputeCapacity/MemoryZStorageCapacityr^ r7 ZAllocationModelr5 )re r. r4 rd r� )r= r� r r: r; r< r r r r� � s �z VCloud_1_5_NodeDriver._to_vdcr/ )rz )T)F)Nr r� NN):rC rD rE r[ rN r �UNKNOWNrO rP ZSTOPPEDr rZ ry r� r r r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� � staticmethodr� r� r� r� r� r� r� r� r� r� r� r� r� r� r r� r� rx r� r� r r� r r r r r� o s� � & ) ,5 #< 3 �&J - 68 @ er� c @ s e Zd Zedd� �ZdS )r� c C s( | d u rd S | d dkrt d| ��d S )N� r r� )r� r� r r r r� s �z)VCloud_5_1_NodeDriver._validate_vm_memoryN)rC rD rE r r� r r r r r� s r� c @ s> e Zd ZdZeZdd� Zdd� Zdd� Zdd � Z dd d �Z d S )r� zYUse 5.5 Connection class to explicitly set 5.5 for the version in Accept headers c C sB t �ddddddd��}dt �|d�_d}d |i}| �|d ||�S ) aZ Creates new snapshot of a virtual machine or of all the virtual machines in a vApp. Prior to creation of the new snapshots, any existing user created snapshots associated with the virtual machines are removed. :param node: node :type node: :class:`Node` :rtype: :class:`Node` ZCreateSnapshotParamsr� r7 rl r� )r; r7 Zquiescer� r� rj z6application/vnd.vmware.vcloud.createSnapshotParams+xmlr ZcreateSnapshot)r r� r� r` �_perform_snapshot_operation)r= rP Z snapshot_xmlrM r� r r r �ex_create_snapshot s �� z(VCloud_5_5_NodeDriver.ex_create_snapshotc C � | � |ddd�S )z� Removes all user created snapshots for a vApp or virtual machine. :param node: node :type node: :class:`Node` :rtype: :class:`Node` ZremoveAllSnapshotsN�r r� r r r �ex_remove_snapshots2 � z)VCloud_5_5_NodeDriver.ex_remove_snapshotsc C r )z� Reverts a vApp or virtual machine to the current snapshot, if any. :param node: node :type node: :class:`Node` :rtype: :class:`Node` ZrevertToCurrentSnapshotNr r� r r r �ex_revert_to_snapshot> r z+VCloud_5_5_NodeDriver.ex_revert_to_snapshotc C sd | j jd�t|j�|�|d urt�|�nd d|d�}| �|j� d�� | j �t|j��}| � |j�S )Nz {}/action/{}r� rB r^ ) r� r� r% r3 r6 r r r r� rd r )r= rP r� Zxml_datar� r� r r r r J s � z1VCloud_5_5_NodeDriver._perform_snapshot_operationr c C s� | � |�| }z=| jjdt|�d�� dd�}|j�t|jd��j|j�t|jd��j|j�t|jd��j|j�t|jd��jd �}|W S t yN Y d S w ) aM Retrieve a mks ticket that you can use to gain access to the console of a running VM. If successful, returns a dict with the following keys: - host: host (or proxy) through which the console connection is made - vmx: a reference to the VMX file of the VM for which this ticket was issued - ticket: screen ticket to use to authenticate the client - port: host port to be used for console access :param vapp_or_vm_id: vApp or VM ID you want to connect to. :type vapp_or_vm_id: ``str`` :param vm_num: If a vApp ID is provided, vm_num is position in the vApp VM list of the VM you want to get a screen ticket. Default is 0. :type vm_num: ``int`` :rtype: ``dict`` z!%s/screen/action/acquireMksTicketr^ r� r �HostZVmxZTicketZPort)r� ZvmxZticketr� N) r� r� r� r3 rd r� re r. r` rl )r= r� Zvm_numr{ r� �outputr r r �ex_acquire_mks_ticketV s �� �z+VCloud_5_5_NodeDriver.ex_acquire_mks_ticketN)r ) rC rD rE rF rd rN r r r r r" r r r r r� s r� )ArF r� �rer r r� rj Zxml.parsers.expatr Zlibcloud.utils.py3r r r r r r Zlibcloud.common.baser r Zlibcloud.common.typesr r Zlibcloud.compute.baser r r r r Zlibcloud.compute.typesr Zlibcloud.utils.iso8601r Zlibcloud.compute.providersr �ranger+ rS rQ r� r� r� �compile� IGNORECASEr� r. r3 r4 rG rM rS rW ru r� r� r� rT rV rX rY r[ rd rf r� r� r� r r r r �<module> sz | # 4 6 ?A
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings