osm_ro/tests/test_vimconn_vmware.py

# -*- coding: utf-8 -*-

##
# Copyright 2016-2017 VMware Inc.
# This file is part of ETSI OSM
# All Rights Reserved.
#
# Licensed under the Apache License, Version 2.0 (the "License"); you may
# not use this file except in compliance with the License. You may obtain
# a copy of the License at
#
#         http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
# License for the specific language governing permissions and limitations
# under the License.
#
# For those usages not covered by the Apache License, Version 2.0 please
# contact:  osslegalrouting@vmware.com
##


from osm_ro.vimconn_vmware import vimconnector
from osm_ro.vimconn import vimconnUnexpectedResponse,vimconnNotFoundException
from pyvcloud.vcloudair import VCA,VCS
from pyvcloud.vapp import VAPP
from pyvcloud import Http
from pyvcloud.schema.vcd.v1_5.schemas.vcloud import vdcType,networkType,catalogType, \
                                                    vAppType,taskType
import unittest
import mock
import test_vimconn_vmware_xml_response as xml_resp

class TestVimconn_VMware(unittest.TestCase):
    def setUp(self):
        config = { "admin_password": "admin",
                  "admin_username":"user",
                  "nsx_user": "nsx",
                  "nsx_password": "nsx",
                  "nsx_manager":"https://test-nsx" }

        self.vca = VCA(host='test',
                       username='user',
                       service_type='standalone',
                       version='5.9',
                       verify=False,
                       log=False)

        self.session = VCS('https://test/api/session',
                                               'test',
                                               'test',
                                                 None,
                          'https://test/api/org/a93c',
                          'https://test/api/org/a93c',
                                        version='5.9')

        self.vim = vimconnector(uuid='12354',
                                 name='test',
                         tenant_id='abc1234',
                          tenant_name='test',
                          url='https://test',
                               config=config)


    @mock.patch.object(vimconnector,'get_vdc_details')
    @mock.patch.object(vimconnector,'connect')
    @mock.patch.object(VCA,'get_networks')
    def test_get_network_not_found(self,get_networks, connect, get_vdc_details):
        vdc_xml_resp = xml_resp.vdc_xml_response
        # created vdc object
        vdc = vdcType.parseString(vdc_xml_resp,True)
        # assumed return value from VIM connector
        get_vdc_details.return_value = vdc
        self.vim.vca = self.vim.connect()
        network_xml_resp = xml_resp.network_xml_response
        networks = networkType.parseString(network_xml_resp, True)
        (self.vim.vca).get_networks.return_value = [networks]
        # call to VIM connector method with invalid id
        self.assertRaises(vimconnNotFoundException,self.vim.get_network,'mgmt-net')
 
    @mock.patch.object(vimconnector,'get_vdc_details')
    @mock.patch.object(vimconnector,'connect')
    @mock.patch.object(VCA,'get_networks')
    def test_get_network(self,get_networks, connect, get_vdc_details):
        net_id = '5c04dc6d-6096-47c6-b72b-68f19013d491'
        vdc_xml_resp = xml_resp.vdc_xml_response
        # created vdc object
        vdc = vdcType.parseString(vdc_xml_resp,True)
        # created network object
        network_xml_resp = xml_resp.network_xml_response
        networks = networkType.parseString(network_xml_resp, True)
        # assumed return value from VIM connector
        get_vdc_details.return_value = vdc
        self.vim.vca = self.vim.connect()
        # assumed return value from VIM connector
        (self.vim.vca).get_networks.return_value = [networks]
        # call to VIM connector method with network_id
        result = self.vim.get_network(net_id)
        # assert verified expected and return result from VIM connector
        self.assertEqual(net_id, result['id'])

    @mock.patch.object(vimconnector,'get_vdc_details')
    @mock.patch.object(vimconnector,'connect')
    @mock.patch.object(VCA,'get_networks')
    def test_get_network_list_not_found(self,get_networks, connect, get_vdc_details):
        vdc_xml_resp = xml_resp.vdc_xml_response
        # created vdc object
        vdc = vdcType.parseString(vdc_xml_resp,True)
        # assumed return value from VIM connector
        get_vdc_details.return_value = vdc
        self.vim.vca = self.vim.connect()

        network_xml_resp = xml_resp.network_xml_response
        networks = networkType.parseString(network_xml_resp, True)
        (self.vim.vca).get_networks.return_value = [networks]
        # call to VIM connector method with network_id
        result = self.vim.get_network_list({'id':'45hdfg-345nb-345'})

        # assert verified expected and return result from VIM connector
        self.assertEqual(list(), result)

    @mock.patch.object(vimconnector,'get_vdc_details')
    @mock.patch.object(vimconnector,'connect')
    @mock.patch.object(VCA,'get_networks')
    def test_get_network_list(self,get_networks, connect, get_vdc_details):
        vdc_xml_resp = xml_resp.vdc_xml_response
        net_id = '5c04dc6d-6096-47c6-b72b-68f19013d491'
        vdc = vdcType.parseString(vdc_xml_resp,True)
        # created network object
        network_xml_resp = xml_resp.network_xml_response
        networks = networkType.parseString(network_xml_resp, True)
        # assumed return value from VIM connector
        get_vdc_details.return_value = vdc
        self.vim.vca = self.vim.connect()
        # assumed return value from VIM connector
        (self.vim.vca).get_networks.return_value = [networks]

        # call to VIM connector method with network_id
        result = self.vim.get_network_list({'id': net_id})
        # assert verified expected and return result from VIM connector
        for item in result:
            self.assertEqual(item.get('id'), net_id)
            self.assertEqual(item.get('status'), 'ACTIVE')
            self.assertEqual(item.get('shared'), False)

    @mock.patch.object(vimconnector,'create_network_rest')
    def test_new_network(self, create_network_rest):
        create_net_xml_resp = xml_resp.create_network_xml_response
        net_name = 'Test_network'
        net_type = 'bridge'
        # assumed return value from VIM connector
        create_network_rest.return_value = create_net_xml_resp
        # call to VIM connector method with network_id
        result = self.vim.new_network(net_name, net_type)
        # assert verified expected and return result from VIM connector
        self.assertEqual(result, 'df1956fa-da04-419e-a6a2-427b6f83788f')

    @mock.patch.object(vimconnector, 'create_network_rest')
    def test_new_network_not_created(self, create_network_rest):
        # assumed return value from VIM connector
        create_network_rest.return_value = """<?xml version="1.0" encoding="UTF-8"?>
                                              <OrgVdcNetwork></OrgVdcNetwork>"""

        # assert verified expected and return result from VIM connector
        self.assertRaises(vimconnUnexpectedResponse,self.vim.new_network,
                                                              'test_net',
                                                                'bridge')

    @mock.patch.object(vimconnector, 'connect')
    @mock.patch.object(vimconnector, 'get_network_action')
    @mock.patch.object(vimconnector, 'connect_as_admin')
    @mock.patch.object(vimconnector, 'delete_network_action')
    def test_delete_network(self, delete_network_action, connect_as_admin, get_network_action, connect):
        delete_net_xml_resp = xml_resp.delete_network_xml_response
        # assumed return value from VIM connector
        connect.return_value = self.vca
        self.vim.vca = self.vim.connect()
        get_network_action.return_value = delete_net_xml_resp
        connect_as_admin.return_value = self.vca
        delete_network_action.return_value = True
        # call to VIM connector method with network_id
        result = self.vim.delete_network('0a55e5d1-43a2-4688-bc92-cb304046bf87')
        # assert verified expected and return result from VIM connector
        self.assertEqual(result, '0a55e5d1-43a2-4688-bc92-cb304046bf87')

    @mock.patch.object(vimconnector, 'get_vcd_network')
    def test_delete_network_not_found(self, get_vcd_network):
        # assumed return value from VIM connector
        get_vcd_network.return_value = False
        # assert verified expected and return result from VIM connector
        self.assertRaises(vimconnNotFoundException,self.vim.delete_network,
                                    '2a23e5d1-42a2-0648-bc92-cb508046bf87')

    def test_get_flavor(self):
        flavor_data = {'a646eb8a-95bd-4e81-8321-5413ee72b62e': {'disk': 10,
                                                                'vcpus': 1,
                                                               'ram': 1024}}
        vimconnector.flavorlist = flavor_data
        result = self.vim.get_flavor('a646eb8a-95bd-4e81-8321-5413ee72b62e')
        # assert verified expected and return result from VIM connector
        self.assertEqual(result, flavor_data['a646eb8a-95bd-4e81-8321-5413ee72b62e'])

    def test_get_flavor_not_found(self):
        vimconnector.flavorlist = {}
        # assert verified expected and return result from VIM connector
        self.assertRaises(vimconnNotFoundException,self.vim.get_flavor,
                                'a646eb8a-95bd-4e81-8321-5413ee72b62e')

    def test_new_flavor(self):
        flavor_data = {'disk': 10, 'vcpus': 1, 'ram': 1024}
        result = self.vim.new_flavor(flavor_data)
        # assert verified expected and return result from VIM connector
        self.assertIsNotNone(result)

    def test_delete_flavor(self):
        flavor_data = {'2cb3dffb-5c51-4355-8406-28553ead28ac': {'disk': 10,
                                                                'vcpus': 1,
                                                               'ram': 1024}}
        vimconnector.flavorlist = flavor_data
        # return value from VIM connector
        result = self.vim.delete_flavor('2cb3dffb-5c51-4355-8406-28553ead28ac')
        # assert verified expected and return result from VIM connector
        self.assertEqual(result, '2cb3dffb-5c51-4355-8406-28553ead28ac')

    @mock.patch.object(vimconnector,'connect_as_admin')
    @mock.patch.object(vimconnector,'connect')
    @mock.patch.object(Http,'get')
    @mock.patch.object(VCS,'get_vcloud_headers')
    def test_delete_image_not_found(self, get_vcloud_headers, get, connect, connect_as_admin):
        # assumed return value from VIM connector
        connect.return_value = self.vca
        self.vim.vca = self.vim.connect()
        # assumed return value from VIM connector
        connect_as_admin.return_value = self.vca
        self.vca.host = connect_as_admin.return_value.host
        self.vca.vcloud_session = self.session
        get_vcloud_headers.return_value = {'Accept':'application/*+xml;version=5.9',
                       'x-vcloud-authorization': '638bfee6cb5f435abc3480f480817254'}
        get_vcloud_headers.return_value = self.vca.vcloud_session.get_vcloud_headers()
        # assert verified expected and return result from VIM connector
        self.assertRaises(vimconnNotFoundException, self.vim.delete_image, 'invali3453')

    @mock.patch.object(vimconnector,'connect')
    @mock.patch.object(VCA,'get_catalogs')
    def test_get_image_list(self, get_catalogs, connect):
        catalog1 = xml_resp.catalog1_xml_response
        catalog2 = xml_resp.catalog2_xml_response

        catalogs = [catalogType.parseString(cat, True) for cat in catalog1, catalog2]
        connect.return_value = self.vca
        self.vim.vca = self.vim.connect()
        # assumed return value from VIM connector
        self.vim.vca.get_catalogs.return_value = catalogs
        result = self.vim.get_image_list({'id': '32ccb082-4a65-41f6-bcd6-38942e8a3829'})
        # assert verified expected and return result from VIM connector
        for item in result:
            self.assertEqual(item['id'], '32ccb082-4a65-41f6-bcd6-38942e8a3829')

    @mock.patch.object(vimconnector,'get_vapp_details_rest')
    @mock.patch.object(vimconnector,'get_vdc_details')
    def test_get_vminstance(self, get_vdc_details, get_vapp_details_rest):
        vapp_info = {'status': '4',
                   'acquireMksTicket': {'href': 'https://localhost/api/vApp/vm-47d12505-5968-4e16-95a7-18743edb0c8b/screen/action/acquireMksTicket',
                   'type': 'application/vnd.vmware.vcloud.mksTicket+xml', 'rel': 'screen:acquireMksTicket'},
                   'vm_virtual_hardware': {'disk_edit_href': 'https://localhost/api/vApp/vm-47d12505-5968-4e16-95a7-18743edb0c8b/virtualHardwareSection/disks', 'disk_size': '40960'},
                   'name': 'Test1_vm-69a18104-8413-4cb8-bad7-b5afaec6f9fa',
                   'created': '2017-09-21T01:15:31.627-07:00',
                    'IsEnabled': 'true',
                   'EndAddress': '12.16.24.199',
                   'interfaces': [{'MACAddress': '00:50:56:01:12:a2',
                                   'NetworkConnectionIndex': '0',
                                   'network': 'testing_T6nODiW4-68f68d93-0350-4d86-b40b-6e74dedf994d',
                                   'IpAddressAllocationMode': 'DHCP',
                                   'IsConnected': 'true',
                                   'IpAddress': '12.16.24.200'}],
                   'ovfDescriptorUploaded': 'true',
                   'nestedHypervisorEnabled': 'false',
                   'Gateway': '12.16.24.1',
                   'acquireTicket': {'href': 'https://localhost/api/vApp/vm-47d12505-5968-4e16-95a7-18743edb0c8b/screen/action/acquireTicket',
                   'rel': 'screen:acquireTicket'},
                   'vmuuid': '47d12505-5968-4e16-95a7-18743edb0c8b',
                   'Netmask': '255.255.255.0',
                   'StartAddress': '12.16.24.100',
                   'primarynetwork': '0',
                   'networkname': 'External-Network-1074',
                   'IsInherited': 'false',
                   'deployed': 'true'} 
        # created vdc object
        vdc_xml_resp = xml_resp.vdc_xml_response
        vdc = vdcType.parseString(vdc_xml_resp,True)
        # assumed return value from VIM connector
        get_vdc_details.return_value = vdc
        get_vapp_details_rest.return_value = vapp_info

        result = self.vim.get_vminstance('47d12505-5968-4e16-95a7-18743edb0c8b')
        # assert verified expected and return result from VIM connector
        self.assertEqual(result['status'], 'ACTIVE')
        self.assertEqual(result['hostId'], '47d12505-5968-4e16-95a7-18743edb0c8b')

    @mock.patch.object(VCA,'get_vapp')
    @mock.patch.object(vimconnector,'connect')
    @mock.patch.object(vimconnector,'get_namebyvappid')
    @mock.patch.object(vimconnector,'get_vdc_details')
    def test_delete_vminstance(self, get_vdc_details, get_namebyvappid, connect, vapp):
        vm_id = '4f6a9b49-e92d-4935-87a1-0e4dc9c3a069'
        vm_name = 'Test1_vm-69a18104-8413-4cb8-bad7-b5afaec6f9fa'
        # created vdc object
        vdc_xml_resp = xml_resp.vdc_xml_response
        vdc = vdcType.parseString(vdc_xml_resp,True)
        # assumed return value from VIM connector
        connect.return_value = self.vca
        self.vim.vca = self.vim.connect()
        get_namebyvappid.return_name = vm_name
        vapp.return_value = None
        # call to VIM connector method
        result = self.vim.delete_vminstance(vm_id)
        # assert verified expected and return result from VIM connector
        self.assertEqual(result, vm_id)

    @mock.patch.object(vimconnector,'get_network_id_by_name')
    @mock.patch.object(vimconnector,'get_vm_pci_details')
    @mock.patch.object(VCA,'get_vapp')
    @mock.patch.object(vimconnector,'connect')
    @mock.patch.object(vimconnector,'get_namebyvappid')
    @mock.patch.object(vimconnector,'get_vdc_details')
    def test_refresh_vms_status(self, get_vdc_details, get_namebyvappid, connect,
                                                    get_vapp, get_vm_pci_details,
                                                         get_network_id_by_name):
        headers = {'Accept':'application/*+xml;version=5.9',
                       'x-vcloud-authorization': '638bfee6cb5f435abc3480f480817254'}
        vm_id = '05e6047b-6938-4275-8940-22d1ea7245b8'

        vapp_resp = xml_resp.vapp_xml_response
        # created vdc object
        vdc_xml_resp = xml_resp.vdc_xml_response
        vdc = vdcType.parseString(vdc_xml_resp,True)
        # assumed return value from VIM connector
        get_vdc_details.return_value = vdc
        connect.return_value = self.vca

        self.vim.vca = self.vim.connect()
        get_namebyvappid.return_value = 'Test1_vm-69a18104-8413-4cb8-bad7-b5afaec6f9fa'
        get_vm_pci_details.return_value = {'host_name': 'test-esx-1.corp.local', 'host_ip': '12.19.24.31'}
        get_vapp.return_value = VAPP(vAppType.parseString(vapp_resp, True), headers, False)
        get_network_id_by_name.return_value = '47d12505-5968-4e16-95a7-18743edb0c8b'
        # call to VIM connector method
        result = self.vim.refresh_vms_status([vm_id])
        for attr in result[vm_id]:
            if attr == 'status':
                # assert verified expected and return result from VIM connector
                self.assertEqual(result[vm_id][attr], 'ACTIVE')

    @mock.patch.object(vimconnector,'get_vcd_network')
    def test_refresh_nets_status(self, get_vcd_network):
        net_id = 'c2d0f28f-d38b-4588-aecc-88af3d4af58b'
        network_dict = {'status': '1','isShared': 'false','IpScope': '',
                        'EndAddress':'12.19.21.15',
                        'name': 'testing_gwyRXlvWYL1-9ebb6d7b-5c74-472f-be77-963ed050d44d',
                        'Dns1': '12.19.21.10', 'IpRanges': '',
                        'Gateway': '12.19.21.23', 'Netmask': '255.255.255.0',
                        'RetainNetInfoAcrossDeployments': 'false',
                        'IpScopes': '', 'IsEnabled': 'true', 'DnsSuffix': 'corp.local',
                        'StartAddress': '12.19.21.11', 'IpRange': '',
                        'Configuration': '', 'FenceMode': 'bridged',
                        'IsInherited': 'true', 'uuid': 'c2d0f28f-d38b-4588-aecc-88af3d4af58b'}
        # assumed return value from VIM connector
        get_vcd_network.return_value = network_dict
        result = self.vim.refresh_nets_status([net_id])
        # assert verified expected and return result from VIM connector
        for attr in result[net_id]:
            if attr == 'status':
                self.assertEqual(result[net_id][attr], 'ACTIVE')

    @mock.patch.object(VCA,'block_until_completed')
    @mock.patch.object(VCA,'get_vapp')
    @mock.patch.object(vimconnector,'connect')
    @mock.patch.object(vimconnector,'get_namebyvappid')
    @mock.patch.object(vimconnector,'get_vdc_details')
    def test_action_vminstance(self, get_vdc_details, get_namebyvappid, connect, get_vapp, block):
        task_resp = xml_resp.task_xml
        vm_id = '05e6047b-6938-4275-8940-22d1ea7245b8'
        # created vdc object
        vdc_xml_resp = xml_resp.vdc_xml_response
        vdc = vdcType.parseString(vdc_xml_resp,True)
        # assumed return value from VIM connector
        get_vdc_details.return_value = vdc
        get_namebyvappid.return_value = 'Test1_vm-69a18104-8413-4cb8-bad7-b5afaec6f9fa'
        connect.return_value = self.vca
        self.vim.vca = self.vim.connect()
        get_vapp.return_value.undeploy.return_value = taskType.parseString(task_resp, True)
        block.return_value = True
        # call to VIM connector method
        result = self.vim.action_vminstance(vm_id,{'shutdown': None})
        # assert verified expected and return result from VIM connector
        self.assertEqual(result, None)