From cc308050b8e50516c50b02d99934d5ea14304ac4 Mon Sep 17 00:00:00 2001 From: shweta agarwal Date: Fri, 21 Aug 2015 18:04:19 +0530 Subject: [PATCH] CLOUDSTACK-8757:FTP modules are not loaded in VR --- .../component/test_escalations_routers.py | 196 ++++++++++++++++++ 1 file changed, 196 insertions(+) create mode 100644 test/integration/component/test_escalations_routers.py diff --git a/test/integration/component/test_escalations_routers.py b/test/integration/component/test_escalations_routers.py new file mode 100644 index 00000000000..73e4bc75789 --- /dev/null +++ b/test/integration/component/test_escalations_routers.py @@ -0,0 +1,196 @@ +# 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. +""" P1 tests for alert receiving from VR on service failure in VR +""" +# Import Local Modules +# import marvin +from marvin.cloudstackTestCase import cloudstackTestCase +from marvin.lib.utils import (get_process_status, validateList, + cleanup_resources) +from marvin.lib.base import (Account, + ServiceOffering, + VirtualMachine) +from marvin.lib.common import (list_hosts, + list_routers, + get_zone, + get_domain, + get_template) +from nose.plugins.attrib import attr +from marvin.codes import FAILED +from marvin.codes import PASS + +_multiprocess_shared_ = True + + +class TestVR(cloudstackTestCase): + + @classmethod + def setUpClass(cls): + cls._cleanup = [] + cls.testClient = super( + TestVR, + cls).getClsTestClient() + cls.api_client = cls.testClient.getApiClient() + cls.services = cls.testClient.getParsedTestDataConfig() + + # Get Zone, Domain and templates + cls.zone = get_zone(cls.api_client, cls.testClient.getZoneForTests()) + domain = get_domain(cls.api_client) + cls.services['mode'] = cls.zone.networktype + + template = get_template( + cls.api_client, + cls.zone.id, + cls.services["ostype"] + ) + + if template == FAILED: + assert False, "get_template() failed to return template with \ + description %s" % cls.services["ostype"] + # Set Zones and disk offerings ?? + cls.services["small"]["zoneid"] = cls.zone.id + cls.services["small"]["template"] = template.id + + # Create account, service offerings, vm. + cls.account = Account.create( + cls.api_client, + cls.services["account"], + domainid=domain.id + ) + + cls.small_offering = ServiceOffering.create( + cls.api_client, + cls.services["service_offerings"]["small"] + ) + cls._cleanup.append(cls.small_offering) + cls._cleanup.append(cls.account) + return + + @classmethod + def tearDownClass(cls): + cls.api_client = super( + TestVR, + cls).getClsTestClient().getApiClient() + cleanup_resources(cls.api_client, cls._cleanup) + return + + def setUp(self): + self.apiclient = self.testClient.getApiClient() + self.hypervisor = self.testClient.getHypervisorInfo() + self.cleanup = [] + + def tearDown(self): + # Clean up, terminate the created ISOs + cleanup_resources(self.apiclient, self.cleanup) + return + + @attr(tags=["advanced"], required_hardware="true") + def test_01_FTPModulesInVR(self): + """ + @desc: Verify FTP modules are loaded in VR of advance zone + step1 : create a VR in advance zone + step2: Verify FTP modules are there in created VR + """ + if self.zone.networktype == "Basic": + self.skipTest("This test can be run only in advance zone") + + # create a virtual machine + vm = VirtualMachine.create( + self.api_client, + self.services["small"], + accountid=self.account.name, + domainid=self.account.domainid, + serviceofferingid=self.small_offering.id, + mode=self.services["mode"] + ) + self.assertIsNotNone(vm, "Failed to deploy virtual machine") + self.cleanup.append(vm) + response = VirtualMachine.list(self.api_client, id=vm.id) + status = validateList(response) + self.assertEqual( + status[0], + PASS, + "list vm response returned invalid list") + list_router_response = list_routers( + self.apiclient, + account=self.account.name, + domainid=self.account.domainid + ) + status = validateList(list_router_response) + self.assertEqual( + status[0], PASS, "Check list response returns a valid list") + router = list_router_response[0] + + self.debug("Router ID: %s, state: %s" % (router.id, router.state)) + + self.assertEqual( + router.state, + 'Running', + "Check list router response for router state" + ) + + if self.hypervisor.lower() in ('vmware', 'hyperv'): + result = get_process_status( + self.apiclient.connection.mgtSvr, + 22, + self.apiclient.connection.user, + self.apiclient.connection.passwd, + router.linklocalip, + "lsmod | grep ftp", + hypervisor=self.hypervisor + ) + else: + try: + hosts = list_hosts( + self.apiclient, + zoneid=router.zoneid, + type='Routing', + state='Up', + id=router.hostid + ) + + self.assertEqual( + isinstance(hosts, list), + True, + "Check list host returns a valid list" + ) + + host = hosts[0] + result = get_process_status( + host.ipaddress, + 22, + self.services["configurableData"]["host"]["username"], + self.services["configurableData"]["host"]["password"], + router.linklocalip, + "lsmod | grep ftp" + ) + + except Exception as e: + raise Exception("Exception raised in getting host\ + credentials: %s " % e) + + res = str(result) + self.debug("lsmod | grep ftp: %s" % res) + if "nf_nat_ftp" in res and "nf_conntrack_ftp" in res: + ismoduleinstalled = True + else: + ismoduleinstalled = False + self.assertEqual( + ismoduleinstalled, + True, + "nf_conntrack_ftp and nf_nat_ftp modules not installed on routers") + return