automated 9277 9276 9275 9274 9273 9179 9178 9177

Author: shweta agarwal

test/integration/component/maint/test_escalations_instances.py

@@ -0,0 +1,270 @@
+# 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.
+
+#Import Local Modules
+from marvin.cloudstackTestCase import cloudstackTestCase
+from marvin.lib.utils import (cleanup_resources,
+                              validateList,
+                              get_hypervisor_type)
+from marvin.lib.base import (Account,
+                             VirtualMachine,
+                             ServiceOffering,
+                             Volume,
+                             DiskOffering,
+                             Template,
+                             listConfigurations,Configurations)
+from marvin.lib.common import (get_domain,list_isos,
+                               get_zone,
+                               get_template)
+from nose.plugins.attrib import attr
+from ast import literal_eval
+from marvin.codes import PASS
+from marvin.cloudstackException import CloudstackAPIException
+from marvin.sshClient import SshClient
+from marvin.cloudstackException import CloudstackAPIException
+import time
+
+class TestInstance(cloudstackTestCase):
+
+    @classmethod
+    def setUpClass(cls):
+        try:
+            cls._cleanup = []
+            cls.testClient = super(TestInstance, cls).getClsTestClient()
+            cls.api_client = cls.testClient.getApiClient()
+            cls.services = cls.testClient.getParsedTestDataConfig()
+            # Get Domain, Zone, Template
+            cls.domain = get_domain(cls.api_client)
+            cls.zone = get_zone(cls.api_client, cls.testClient.getZoneForTests())
+            cls.template = get_template(
+                cls.api_client,
+                cls.zone.id,
+                cls.services["ostype"]
+            )
+            if cls.zone.localstorageenabled:
+                cls.storagetype = 'local'
+                cls.services["service_offerings"]["tiny"]["storagetype"] = 'local'
+                cls.services["disk_offering"]["storagetype"] = 'local'
+            else:
+                cls.storagetype = 'shared'
+                cls.services["service_offerings"]["tiny"]["storagetype"] = 'shared'
+                cls.services["disk_offering"]["storagetype"] = 'shared'
+
+            cls.services['mode'] = cls.zone.networktype
+            cls.services["virtual_machine"]["hypervisor"] = cls.testClient.getHypervisorInfo()
+            cls.services["virtual_machine"]["zoneid"] = cls.zone.id
+            cls.services["virtual_machine"]["template"] = cls.template.id
+            cls.services["custom_volume"]["zoneid"] = cls.zone.id
+            # Creating Disk offering, Service Offering and Account
+            cls.disk_offering = DiskOffering.create(
+                cls.api_client,
+                cls.services["disk_offering"]
+            )
+            cls.service_offering = ServiceOffering.create(
+                cls.api_client,
+                cls.services["service_offerings"]["small"]
+            )
+            cls.account = Account.create(
+                cls.api_client,
+                cls.services["account"],
+                domainid=cls.domain.id
+            )
+            # Getting authentication for user in newly created Account
+            cls.user = cls.account.user[0]
+            cls.userapiclient = cls.testClient.getUserApiClient(cls.user.username, cls.domain.name)
+            cls._cleanup.append(cls.disk_offering)
+            cls._cleanup.append(cls.service_offering)
+            cls._cleanup.append(cls.account)
+            cls.mgtSvrDetails = cls.config.__dict__["mgtSvr"][0].__dict__
+        except Exception as e:
+            cls.tearDownClass()
+            raise Exception("Warning: Exception in setup : %s" % e)
+        return
+
+    def setUp(self):
+
+        self.apiClient = self.testClient.getApiClient()
+        self.cleanup = []
+
+    def tearDown(self):
+        #Clean up, terminate the created volumes
+        cleanup_resources(self.apiClient, self.cleanup)
+        return
+
+    @classmethod
+    def tearDownClass(cls):
+        try:
+            cleanup_resources(cls.api_client, cls._cleanup)
+        except Exception as e:
+            raise Exception("Warning: Exception during cleanup : %s" % e)
+
+    def RestartServers(self):
+        """ Restart management server and usage server """
+
+        sshClient = SshClient(
+            self.mgtSvrDetails["mgtSvrIp"],
+            22,
+            self.mgtSvrDetails["user"],
+            self.mgtSvrDetails["passwd"]
+        )
+        command = "service cloudstack-management restart"
+        sshClient.execute(command)
+        return
+
+    def updateConfigurAndRestart(self,name, value):
+        Configurations.update(self.apiClient,
+                              name,value )
+        self.RestartServers()
+        time.sleep(self.services["sleep"])
+
+    @attr(tags=["advanced"], required_hardware="true")
+    def test1_attach_volume(self):
+        """
+        @desc: Unable to attach 7th Disk to windows server 2012R2 instance
+        Step1: Set global config vmware.root.disk.controller to 'osdefault'
+        Step2: Deploy a Windows 2012 R2 instance.
+        Step3:  Attach 6 disks to the VM.
+        Step4: Try attaching a 7th disk to the VM
+        Verify that step4 succeeds without any exception
+        """
+        self.hypervisor = str(get_hypervisor_type(self.api_client)).lower()
+        if self.hypervisor != "vmware":
+            self.skipTest("This test can be run only on vmware")
+        self.updateConfigurAndRestart("vmware.root.disk.controller","osdefault")
+
+
+        template = Template.register(
+           self.userapiclient,
+          self.services["Windows Server 2012"],
+            zoneid=self.zone.id,
+           account=self.account.name,
+           domainid=self.account.domainid
+        )
+        self.assertIsNotNone(template,"Failed to register Windows server 2012 R2 template")
+        self.debug(
+           "Registered a template with format {} and id {}".format(
+              self.services["Windows Server 2012"]["format"],template.id)
+        )
+        template.download(self.userapiclient)
+        self.cleanup.append(template)
+
+        # Creating a big service offering for windows VM launch
+        big_service_offering = ServiceOffering.create(
+                self.apiClient,
+                self.services["service_offerings"]["big"]
+            )
+        self.cleanup.append(big_service_offering)
+        vm = VirtualMachine.create(
+            self.userapiclient,
+            self.services["virtual_machine"],
+            accountid=self.account.name,
+            domainid=self.account.domainid,
+            serviceofferingid=big_service_offering.id,
+            templateid=template.id,
+            zoneid=self.zone.id
+        )
+        self.assertIsNotNone(vm,"Failed to deploy virtual machine")
+        self.cleanup.append(vm)
+        response = VirtualMachine.list(self.userapiclient,id=vm.id)
+        status = validateList(response)
+        self.assertEqual(status[0],PASS,"list vm response returned invalid list")
+
+        for i in range(0,7):
+            self.services["volume"]["diskname"]=i
+            disk = Volume.create(
+                self.userapiclient,
+                self.services["volume"],
+                zoneid=self.zone.id,
+                diskofferingid=self.disk_offering.id
+            )
+            self.assertIsNotNone(disk,"Failed to create custom volume")
+            self.cleanup.append(disk)
+            try:
+                vm.attach_volume(self.userapiclient,disk)
+                list_volumes = Volume.list(
+                    self.userapiclient,
+                    listall=self.services["listall"],
+                    id=disk.id
+                )
+
+                attached_volume = list_volumes[0]
+                self.assertEqual(
+                    disk.id,
+                    attached_volume.id,
+                    "list volume response does not match with the volume created and attached to vm"
+                )
+            except Exception as e:
+                self.fail("Failed to attach {} data disk to Windows server 2012 R2 vm ".format(i))
+        return
+    @attr(tags=["advanced"], required_hardware="true")
+    def test_Scale_VM(self):
+        """
+        @desc:
+        1. Enable dynamic scaling in Global settings
+        2. Register an CentOS 7 tempplate(with tools) and tick dynamic scaling
+        3. Deploy VM with this template
+        4.Start the VM and try to change service offering
+
+        """
+        self.hypervisor = str(get_hypervisor_type(self.api_client)).lower()
+        if self.hypervisor != "xenserver":
+            self.skipTest("This test can be run only on xenserver")
+        self.updateConfigurAndRestart("enable.dynamic.scale.vm","true")
+        template = Template.register(
+           self.userapiclient,
+          self.services["CentOS7template"],
+            zoneid=self.zone.id,
+           account=self.account.name,
+           domainid=self.account.domainid
+        )
+        self.assertIsNotNone(template,"Failed to register CentOS 7 template")
+        self.debug(
+           "Registered a template with format {} and id {}".format(
+              self.services["Windows Server 2012"]["format"],template.id)
+        )
+        template.download(self.userapiclient)
+        self.cleanup.append(template)
+        vm = VirtualMachine.create(
+            self.userapiclient,
+            self.services["virtual_machine"],
+            accountid=self.account.name,
+            domainid=self.account.domainid,
+            serviceofferingid=self.service_offering.id,
+            templateid=template.id,
+            zoneid=self.zone.id
+        )
+        self.assertIsNotNone(vm,"Failed to deploy virtual machine")
+        self.cleanup.append(vm)
+        response = VirtualMachine.list(self.userapiclient,id=vm.id)
+        status = validateList(response)
+        self.assertEqual(status[0],PASS,"list vm response returned invalid list")
+        self.assertEqual(status[1].state,"Running", "vm is not running")
+
+        service_offering = ServiceOffering.create(
+                self.apiClient,
+                self.services["service_offerings"]["big"]
+            )
+        time.sleep(self.services["sleep"])
+        vm.scale(self.userapiclient,service_offering.id)
+        scaleresponse = VirtualMachine.list(self.userapiclient,id=vm.id)
+        scalestatus = validateList(scaleresponse)
+        self.assertEqual(scalestatus[0],PASS,"list vm response returned invalid list")
+        self.assertEqual(scalestatus[1].serviceofferingname,service_offering.name, " service offering is not same")
+        self.assertEqual(scalestatus[1].serviceofferingid,service_offering.id, " service offering ids are not same")
+
+
+        return

test/integration/component/test_escalations_instances.py

@@ -42,7 +42,7 @@
 from marvin.sshClient import SshClient
 from nose.plugins.attrib import attr
 import time
-
+from marvin.cloudstackException import CloudstackAPIException
 
 class TestListInstances(cloudstackTestCase):
     @classmethod
@@ -2068,6 +2068,94 @@ def test_13_vm_nics(self):
                 "VM NIC is not same as expected"
             )
         return
+    @attr(tags=["advanced", "basic"], required_hardware="true")
+    def test_14_Create_vm_with_same_sshkey(self):
+        """
+        @Desc: Test to verify API call Register ssh key pair fails when uses same public key for differnet key name
+        """
+
+
+        # Listing all the SSH Key pairs
+        list_keypairs_before = SSHKeyPair.list(
+            self.userapiclient
+        )
+        list_keypairs_before_size = 0
+        if list_keypairs_before is not None:
+            list_keypairs_before_size = len(list_keypairs_before)
+
+        # Registering first Key pair
+        new_keypair1 = SSHKeyPair.register(
+            self.userapiclient,
+            name="keypair1",
+            publickey="ssh-rsa: e6:9a:1e:b5:98:75:88:5d:56:bc:92:7b:43:48:05:b2")
+        self.assertIsNotNone(
+            new_keypair1,
+            "New Key pair generation failed"
+        )
+        self.assertEquals(
+            "keypair1",
+            new_keypair1.name,
+            "Key Pair not created with given name"
+        )
+        # Listing all the SSH Key pairs again
+        list_keypairs_after = SSHKeyPair.list(
+            self.userapiclient
+        )
+        status = validateList(list_keypairs_after)
+        self.assertEquals(
+            PASS,
+            status[0],
+            "Listing of Key pairs failed"
+        )
+        # Verifying that list size is increased by 1
+        self.assertEquals(
+            list_keypairs_before_size + 1,
+            len(list_keypairs_after),
+            "List count is not matching"
+        )
+        try:
+
+            # Registering second key pair using same public key
+            new_keypair2 = SSHKeyPair.register(
+                self.userapiclient,
+                name="keypair2",
+                publickey="ssh-rsa: e6:9a:1e:b5:98:75:88:5d:56:bc:92:7b:43:48:05:b2")
+            self.fail("SSH Key creation passed using same public key ")
+        except CloudstackAPIException  as e:
+            self.assertRaises("Exception Raised : %s" % e)
+
+        # Deploying a VM with keypair 1
+        first_vm_created = VirtualMachine.create(
+            self.userapiclient,
+            self.services["virtual_machine"],
+            accountid=self.account.name,
+            domainid=self.account.domainid,
+            serviceofferingid=self.service_offering.id,
+            keypair=new_keypair1.name
+        )
+        self.assertIsNotNone(
+            first_vm_created,
+            "VM creation failed"
+        )
+        # Listing all the VMs for a user again
+        list_vms_after = VirtualMachine.list(
+            self.userapiclient,id=first_vm_created.id,
+            listall=True,
+        )
+        status = validateList(list_vms_after)
+        self.assertEquals(
+            PASS,
+            status[0],
+            "VM creation failed"
+        )
+        vm = list_vms_after[0]
+        self.assertEqual(
+            vm.state,
+            "Running",
+            "VM state should be running after deployment")
+        self.assertEqual(vm.keypair , new_keypair1.name , "VM keypair name is not keypair1")
+
+        return
 
 
 class TestInstances(cloudstackTestCase):