| # Licensed to the Apache Software Foundation (ASF) under one |
| # or more contributor license agreements. See the NOTICE file |
| # distributed with this work for additional information |
| # regarding copyright ownership. The ASF licenses this file |
| # to you 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. |
| |
| |
| # this script will cover VMdeployment with Userdata tests |
| |
| from marvin.cloudstackTestCase import cloudstackTestCase |
| from marvin.lib.base import * |
| from marvin.lib.utils import (validateList, cleanup_resources) |
| from marvin.lib.common import * |
| from nose.plugins.attrib import attr |
| from marvin.codes import PASS,FAIL |
| |
| _multiprocess_shared_ = True |
| |
| class Services: |
| def __init__(self): |
| self.services = { |
| "virtual_machine": { |
| "displayname": "TesVM1", |
| "username": "root", |
| "password": "password", |
| "ssh_port": 22, |
| "hypervisor": 'XenServer', |
| "privateport": 22, |
| "publicport": 22, |
| "protocol": 'TCP', |
| }, |
| "ostype": 'CentOS 5.5 (64-bit)', |
| "service_offering": { |
| "name": "Tiny Instance", |
| "displaytext": "Tiny Instance", |
| "cpunumber": 1, |
| "cpuspeed": 100, |
| "memory": 256, |
| }, |
| } |
| |
| class TestDeployVmWithMetaData(cloudstackTestCase): |
| @classmethod |
| def setUpClass(cls): |
| cls.testclient = super(TestDeployVmWithMetaData, cls).getClsTestClient() |
| cls.apiclient = cls.testclient.getApiClient() |
| cls._cleanup = [] |
| #cls.services = Services().services |
| cls.services = cls.testclient.getParsedTestDataConfig() |
| cls.zone = get_zone(cls.apiclient, cls.testclient.getZoneForTests()) |
| cls.service_offering = ServiceOffering.create( |
| cls.apiclient, |
| cls.services["service_offering"] |
| ) |
| |
| cls.template = get_template( |
| cls.apiclient, |
| cls.zone.id, |
| cls.services["ostype"] |
| ) |
| |
| |
| @classmethod |
| def tearDownClass(cls): |
| try: |
| cls._cleanup = cls._cleanup[::-1] |
| cleanup_resources(cls.apiclient, cls._cleanup) |
| except Exception as e: |
| raise Exception("Warning: Exception during cleanup : %s" % e) |
| |
| def setUp(self): |
| self.apiclient = self.testClient.getApiClient() |
| self.cleanup = [] |
| |
| def tearDown(self): |
| try: |
| self.cleanup = self.cleanup[::-1] |
| cleanup_resources(self.apiclient, self.cleanup) |
| except Exception as e: |
| raise Exception("Warning: Exception during cleanup : %s" % e) |
| return |
| |
| def migrate_VM(self, vm): |
| """Migrates VM to another host, if available""" |
| self.debug("+++ Migrating one of the VMs in the created " |
| "VPC Tier network to another host, if available...") |
| self.debug("Checking if a host is available for migration...") |
| hosts = Host.listForMigration(self.apiclient, virtualmachineid=vm.id) |
| if hosts: |
| self.assertEqual(isinstance(hosts, list), True, |
| "List hosts should return a valid list" |
| ) |
| host = hosts[0] |
| self.debug("Migrating VM with ID: " |
| "%s to Host: %s" % (vm.id, host.id)) |
| try: |
| vm.migrate(self.apiclient, hostid=host.id) |
| except Exception as e: |
| self.fail("Failed to migrate instance, %s" % e) |
| self.debug("Migrated VM with ID: " |
| "%s to Host: %s" % (vm.id, host.id)) |
| else: |
| self.debug("No host available for migration. " |
| "Test requires at-least 2 hosts") |
| return host |
| |
| def list_nics(self, vm_id): |
| list_vm_res = VirtualMachine.list(self.apiclient, id=vm_id) |
| self.assertEqual(validateList(list_vm_res)[0], PASS, "List vms returned invalid response") |
| nics = list_vm_res[0].nic |
| for nic in nics: |
| if nic.type == "Shared": |
| nic_res = NIC.list( |
| self.apiclient, |
| virtualmachineid=vm_id, |
| nicid=nic.id |
| ) |
| nic_ip = nic_res[0].ipaddress |
| self.assertIsNotNone(nic_ip, "listNics API response does not have the ip address") |
| else: |
| continue |
| return |
| |
| @attr(tags=["advanced"], required_hardware='True') |
| def test_deployVM_verify_metadata_in_VR(self): |
| """ |
| 1. Create a network (VR as a provider) |
| 2. Deploy a VM in the network |
| 3. Verify VM deployment |
| 4. From the VM, curl the gateway of the VR to verify the corresponding metadata - hypervisor host name |
| if the respective Global level and account level flags are set to true |
| """ |
| # Update global setting for "global.allow.expose.host.hostname" |
| Configurations.update(self.apiclient, |
| name="global.allow.expose.host.hostname", |
| value="true" |
| ) |
| |
| # Update Account level setting |
| Configurations.update(self.apiclient, |
| name="account.allow.expose.host.hostname", |
| value="true" |
| ) |
| |
| # Verify that the above mentioned settings are set to true before proceeding |
| if not is_config_suitable( |
| apiclient=self.apiclient, |
| name='global.allow.expose.host.hostname', |
| value='true'): |
| self.skipTest('global.allow.expose.host.hostname should be true. skipping') |
| |
| if not is_config_suitable( |
| apiclient=self.apiclient, |
| name='account.allow.expose.host.hostname', |
| value='true'): |
| self.skipTest('account.allow.expose.host.hostname should be true. skipping') |
| |
| self.no_isolate = NetworkOffering.create( |
| self.apiclient, |
| self.services["isolated_network_offering"] |
| ) |
| self.no_isolate.update(self.apiclient, state='Enabled') |
| self.isolated_network = Network.create( |
| self.apiclient, |
| self.services["network"], |
| networkofferingid=self.no_isolate.id, |
| zoneid=self.zone.id, |
| accountid="admin", |
| domainid=1 |
| ) |
| self.cleanup.append(self.isolated_network) |
| |
| self.vm = VirtualMachine.create( |
| self.apiclient, |
| self.services["virtual_machine"], |
| templateid=self.template.id, |
| accountid="admin", |
| domainid=1, |
| serviceofferingid=self.service_offering.id, |
| zoneid=self.zone.id, |
| networkids=[self.isolated_network.id], |
| ) |
| self.assertIsNotNone( |
| self.vm, |
| "VM creation failed in the isolated network" |
| ) |
| self.cleanup.append(self.vm) |
| |
| ip_addr = self.vm.ipaddress |
| self.debug("VM ip address = %s" % ip_addr) |
| |
| # Verify the retrieved ip address in listNICs API response |
| self.list_nics(self.vm.id) |
| vr_res = Router.list( |
| self.apiclient, |
| networkid=self.isolated_network.id, |
| listAll=True |
| ) |
| self.assertEqual(validateList(vr_res)[0], PASS, "List Routers returned invalid response") |
| vr_ip = vr_res[0].guestipaddress |
| ssh = self.vm.get_ssh_client(ipaddress=ip_addr) |
| cmd = "curl http://%s/latest/hypervisor-host-name" % vr_ip |
| res = ssh.execute(cmd) |
| self.debug("Verifying hypervisor hostname details in the VR") |
| self.assertEqual( |
| str(res), |
| self.vm.hostname, |
| "Failed to get the hypervisor host name from VR in isolated network" |
| ) |
| # Reset configuration values to default values i.e., false |
| Configurations.update(self.apiclient, |
| name="global.allow.expose.host.hostname", |
| value="false" |
| ) |
| |
| # Update Account level setting |
| Configurations.update(self.apiclient, |
| name="account.allow.expose.host.hostname", |
| value="false" |
| ) |
| return |
| |
| @attr(tags=["advanced"], required_hardware='True') |
| def test_deployVM_verify_metadata_in_VR_after_migration(self): |
| """ |
| 1. Create a network (VR as a provider) |
| 2. Deploy a VM in the network |
| 3. Verify VM deployment |
| 4. Migrate VM to another host |
| 4. After migration, from the VM, curl the gateway to verify the corresponding metadata - hypervisor host name |
| if the respective Global level and account level flags are set to true |
| """ |
| # Update global setting for "global.allow.expose.host.hostname" |
| Configurations.update(self.apiclient, |
| name="global.allow.expose.host.hostname", |
| value="true" |
| ) |
| |
| # Update Account level setting |
| Configurations.update(self.apiclient, |
| name="account.allow.expose.host.hostname", |
| value="true" |
| ) |
| |
| # Verify that the above mentioned settings are set to true before proceeding |
| if not is_config_suitable( |
| apiclient=self.apiclient, |
| name='global.allow.expose.host.hostname', |
| value='true'): |
| self.skipTest('global.allow.expose.host.hostname should be true. skipping') |
| |
| if not is_config_suitable( |
| apiclient=self.apiclient, |
| name='account.allow.expose.host.hostname', |
| value='true'): |
| self.skipTest('Account level account.allow.expose.host.hostname should be true. skipping') |
| |
| self.no_isolate = NetworkOffering.create( |
| self.apiclient, |
| self.services["isolated_network_offering"] |
| ) |
| self.no_isolate.update(self.apiclient, state='Enabled') |
| self.isolated_network = Network.create( |
| self.apiclient, |
| self.services["network"], |
| networkofferingid=self.no_isolate.id, |
| zoneid=self.zone.id, |
| accountid="admin", |
| domainid=1 |
| ) |
| self.cleanup.append(self.isolated_network) |
| |
| self.vm = VirtualMachine.create( |
| self.apiclient, |
| self.services["virtual_machine"], |
| templateid=self.template.id, |
| accountid="admin", |
| domainid=1, |
| serviceofferingid=self.service_offering.id, |
| zoneid=self.zone.id, |
| networkids=[self.isolated_network.id], |
| ) |
| self.assertIsNotNone( |
| self.vm, |
| "VM creation failed in the isolated network" |
| ) |
| |
| host = self.migrate_VM(self.vm) |
| |
| self.cleanup.append(self.vm) |
| |
| ip_addr = self.vm.ipaddress |
| self.debug("VM ip address = %s" % ip_addr) |
| |
| # Verify the retrieved ip address in listNICs API response |
| self.list_nics(self.vm.id) |
| vr_res = Router.list( |
| self.apiclient, |
| networkid=self.isolated_network.id, |
| listAll=True |
| ) |
| self.assertEqual(validateList(vr_res)[0], PASS, "List Routers returned invalid response") |
| vr_ip = vr_res[0].guestipaddress |
| ssh = self.vm.get_ssh_client(ipaddress=ip_addr) |
| cmd = "curl http://%s/latest/hypervisor-host-name" % vr_ip |
| res = ssh.execute(cmd) |
| self.debug("Verifying hypervisor hostname details in the VR") |
| self.assertEqual( |
| str(res), |
| host.name, |
| "Failed to get the hypervisor host name from VR in isolated network" |
| ) |
| # Reset configuration values to default values i.e., false |
| Configurations.update(self.apiclient, |
| name="global.allow.expose.host.hostname", |
| value="false" |
| ) |
| |
| # Update Account level setting |
| Configurations.update(self.apiclient, |
| name="account.allow.expose.host.hostname", |
| value="false" |
| ) |
| |
| return |
