mirror of https://github.com/apache/cloudstack.git
test: Added Marvin test for domain specific offerings
Signed-off-by: Abhishek Kumar <abhishek.kumar@shapeblue.com>
This commit is contained in:
Abhishek Kumar
Abhishek Kumar
parent
7c7237eec1
commit
15efa1b88d
|
|
@ -0,0 +1,363 @@
|
|||
# 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.
|
||||
""" BVT tests for Disk offerings"""
|
||||
|
||||
#Import Local Modules
|
||||
from marvin.codes import FAILED
|
||||
from marvin.cloudstackTestCase import cloudstackTestCase
|
||||
from marvin.cloudstackAPI import updateDiskOffering
|
||||
from marvin.lib.utils import (isAlmostEqual,
|
||||
cleanup_resources,
|
||||
random_gen)
|
||||
from marvin.lib.base import (Domain,
|
||||
DiskOffering,
|
||||
Account,
|
||||
Volume)
|
||||
from marvin.lib.common import (list_disk_offering,
|
||||
get_domain,
|
||||
get_zone,
|
||||
list_hosts)
|
||||
from nose.plugins.attrib import attr
|
||||
|
||||
import time
|
||||
from marvin.sshClient import SshClient
|
||||
from marvin.cloudstackException import CloudstackAPIException
|
||||
from marvin.lib.decoratorGenerators import skipTestIf
|
||||
|
||||
|
||||
_multiprocess_shared_ = True
|
||||
|
||||
class TestCreateDomainsDiskOffering(cloudstackTestCase):
|
||||
|
||||
def setUp(self):
|
||||
self.services = self.testClient.getParsedTestDataConfig()
|
||||
self.apiclient = self.testClient.getApiClient()
|
||||
self.dbclient = self.testClient.getDbConnection()
|
||||
self.cleanup = []
|
||||
return
|
||||
|
||||
def tearDown(self):
|
||||
try:
|
||||
#Clean up, terminate the created templates
|
||||
cleanup_resources(self.apiclient, self.cleanup)
|
||||
|
||||
except Exception as e:
|
||||
raise Exception("Warning: Exception during cleanup : %s" % e)
|
||||
return
|
||||
|
||||
@classmethod
|
||||
def setUpClass(cls):
|
||||
testClient = super(TestCreateDomainsDiskOffering, cls).getClsTestClient()
|
||||
cls.apiclient = testClient.getApiClient()
|
||||
cls.services = testClient.getParsedTestDataConfig()
|
||||
# Create domains
|
||||
cls.domain_1 = Domain.create(
|
||||
cls.apiclient,
|
||||
cls.services["acl"]["domain1"]
|
||||
)
|
||||
cls.domain_11 = Domain.create(
|
||||
cls.apiclient,
|
||||
cls.services["acl"]["domain11"],
|
||||
parentdomainid=cls.domain_1.id
|
||||
)
|
||||
cls.domain_2 = Domain.create(
|
||||
cls.apiclient,
|
||||
cls.services["acl"]["domain2"]
|
||||
)
|
||||
cls._cleanup = [
|
||||
cls.domain_11,
|
||||
cls.domain_1,
|
||||
cls.domain_2
|
||||
]
|
||||
return
|
||||
|
||||
@classmethod
|
||||
def tearDownClass(cls):
|
||||
try:
|
||||
cls.apiclient = super(
|
||||
TestCreateDomainsDiskOffering,
|
||||
cls).getClsTestClient().getApiClient()
|
||||
# Clean up, terminate the created templates
|
||||
cleanup_resources(cls.apiclient, cls._cleanup)
|
||||
|
||||
except Exception as e:
|
||||
raise
|
||||
|
||||
@attr(
|
||||
tags=[
|
||||
"advanced",
|
||||
"basic",
|
||||
"eip",
|
||||
"sg",
|
||||
"advancedns",
|
||||
"smoke"],
|
||||
required_hardware="false")
|
||||
def test_01_create_disk_offering(self):
|
||||
"""Test to create disk offering
|
||||
|
||||
# Validate the following:
|
||||
# 1. createDiskOfferings should return valid info for new offering
|
||||
# 2. The Cloud Database contains the valid information
|
||||
"""
|
||||
offering_data_domainid = "{0},{1}".format(self.domain_11.id, self.domain_2.id)
|
||||
|
||||
disk_offering = DiskOffering.create(
|
||||
self.apiclient,
|
||||
self.services["disk_offering"],
|
||||
domainid=offering_data_domainid
|
||||
)
|
||||
self.cleanup.append(disk_offering)
|
||||
|
||||
self.debug("Created Disk offering with ID: %s" % disk_offering.id)
|
||||
|
||||
list_disk_response = list_disk_offering(
|
||||
self.apiclient,
|
||||
id=disk_offering.id
|
||||
)
|
||||
self.assertEqual(
|
||||
isinstance(list_disk_response, list),
|
||||
True,
|
||||
"Check list response returns a valid list"
|
||||
)
|
||||
self.assertNotEqual(
|
||||
len(list_disk_response),
|
||||
0,
|
||||
"Check Disk offering is created"
|
||||
)
|
||||
disk_response = list_disk_response[0]
|
||||
|
||||
self.assertEqual(
|
||||
disk_response.displaytext,
|
||||
self.services["disk_offering"]["displaytext"],
|
||||
"Check server displaytext in createDiskOffering"
|
||||
)
|
||||
self.assertEqual(
|
||||
disk_response.name,
|
||||
self.services["disk_offering"]["name"],
|
||||
"Check name in createDiskOffering"
|
||||
)
|
||||
self.assertItemsEqual(
|
||||
disk_response.domainid.split(","),
|
||||
offering_data_domainid.split(","),
|
||||
"Check domainid in createDiskOffering"
|
||||
)
|
||||
return
|
||||
|
||||
class TestDomainsDiskOfferings(cloudstackTestCase):
|
||||
|
||||
def setUp(self):
|
||||
self.apiclient = self.testClient.getApiClient()
|
||||
self.dbclient = self.testClient.getDbConnection()
|
||||
self.cleanup = []
|
||||
|
||||
def tearDown(self):
|
||||
|
||||
try:
|
||||
#Clean up, terminate the created templates
|
||||
cleanup_resources(self.apiclient, self.cleanup)
|
||||
|
||||
except Exception as e:
|
||||
raise Exception("Warning: Exception during cleanup : %s" % e)
|
||||
return
|
||||
|
||||
@classmethod
|
||||
def setUpClass(cls):
|
||||
testClient = super(TestDomainsDiskOfferings, cls).getClsTestClient()
|
||||
cls.apiclient = cls.testClient.getApiClient()
|
||||
cls.services = cls.testClient.getParsedTestDataConfig()
|
||||
# Create domains
|
||||
cls.domain_1 = Domain.create(
|
||||
cls.apiclient,
|
||||
cls.services["acl"]["domain1"]
|
||||
)
|
||||
cls.domain_11 = Domain.create(
|
||||
cls.apiclient,
|
||||
cls.services["acl"]["domain11"],
|
||||
parentdomainid=cls.domain_1.id
|
||||
)
|
||||
cls.domain_2 = Domain.create(
|
||||
cls.apiclient,
|
||||
cls.services["acl"]["domain2"]
|
||||
)
|
||||
cls.domain_3 = Domain.create(
|
||||
cls.apiclient,
|
||||
cls.services["acl"]["domain12"]
|
||||
)
|
||||
|
||||
cls.zone = get_zone(cls.apiclient, testClient.getZoneForTests())
|
||||
|
||||
cls.disk_offering = DiskOffering.create(
|
||||
cls.apiclient,
|
||||
cls.services["disk_offering"],
|
||||
domainid=cls.domain_1.id
|
||||
)
|
||||
cls._cleanup = [
|
||||
cls.disk_offering,
|
||||
cls.domain_11,
|
||||
cls.domain_1,
|
||||
cls.domain_2,
|
||||
cls.domain_3
|
||||
]
|
||||
return
|
||||
|
||||
@classmethod
|
||||
def tearDownClass(cls):
|
||||
try:
|
||||
cls.apiclient = super(TestDomainsDiskOfferings, cls).getClsTestClient().getApiClient()
|
||||
cleanup_resources(cls.apiclient, cls._cleanup)
|
||||
except Exception as e:
|
||||
raise Exception("Warning: Exception during cleanup : %s" % e)
|
||||
return
|
||||
|
||||
@attr(tags=["advanced", "basic", "eip", "sg", "advancedns", "smoke"], required_hardware="false")
|
||||
def test_02_edit_disk_offering(self):
|
||||
"""Test to update existing disk offering"""
|
||||
|
||||
# 1. updateDiskOffering should return a valid information for the updated offering
|
||||
# 2. updateDiskOffering should fail while tring to add child domain but parent domain
|
||||
# is already present
|
||||
# 3. updateDiskOffering should be able to add new domain to the offering
|
||||
self.debug("Updating disk offering with ID: %s" %
|
||||
self.disk_offering.id)
|
||||
|
||||
cmd = updateDiskOffering.updateDiskOfferingCmd()
|
||||
# Add parameters for API call
|
||||
cmd.id = self.disk_offering.id
|
||||
cmd.domainid = self.domain_11.id
|
||||
try:
|
||||
self.apiclient.updateDiskOffering(cmd)
|
||||
self.fail("Child domain added to offering when parent domain already exist. Must be an error.")
|
||||
except CloudstackAPIException:
|
||||
self.debug("Child domain check")
|
||||
|
||||
|
||||
cmd = updateDiskOffering.updateDiskOfferingCmd()
|
||||
cmd.id = self.disk_offering.id
|
||||
cmd.domainid = self.domain_2.id
|
||||
self.apiclient.updateDiskOffering(cmd)
|
||||
|
||||
list_disk_response = list_disk_offering(
|
||||
self.apiclient,
|
||||
id=self.disk_offering.id
|
||||
)
|
||||
self.assertEqual(
|
||||
isinstance(list_disk_response, list),
|
||||
True,
|
||||
"Check list response returns a valid list"
|
||||
)
|
||||
|
||||
self.assertNotEqual(
|
||||
len(list_disk_response),
|
||||
0,
|
||||
"Check Disk offering is updated"
|
||||
)
|
||||
|
||||
domainid = "{0},{1}".format(self.domain_1.id, self.domain_2.id)
|
||||
self.assertItemsEqual(
|
||||
list_disk_response[0].domainid.split(","),
|
||||
domainid.split(","),
|
||||
"Check domainid in createDiskOffering"
|
||||
)
|
||||
return
|
||||
|
||||
@attr(
|
||||
tags=[
|
||||
"advanced",
|
||||
"basic",
|
||||
"eip",
|
||||
"sg",
|
||||
"advancedns",
|
||||
"smoke"],
|
||||
required_hardware="false")
|
||||
def test_03_create_volume_domain_disk_offering(self):
|
||||
"""Test to creating volume for an existing domain specified disk offering"""
|
||||
|
||||
# Validate the following:
|
||||
# 1. Volume creation should fail for the user from a different domain
|
||||
# 2. Volume creation should work for users from domains for which offering is specified
|
||||
self.debug("Deploying VM using disk offering with ID: %s" %
|
||||
self.disk_offering.id)
|
||||
|
||||
self.invalid_account = Account.create(
|
||||
self.apiclient,
|
||||
self.services["account"],
|
||||
domainid=self.domain_3.id
|
||||
)
|
||||
self.cleanup.append(self.invalid_account)
|
||||
|
||||
try:
|
||||
Volume.create(
|
||||
self.apiclient,
|
||||
self.services["volume"],
|
||||
zoneid=self.zone.id,
|
||||
account=self.invalid_account.name,
|
||||
domainid=self.invalid_account.domainid,
|
||||
diskofferingid=self.disk_offering.id
|
||||
)
|
||||
self.fail("Volume created for a user from domain which has not been specified for service offering. Must be an error.")
|
||||
except CloudstackAPIException:
|
||||
self.debug("Volume creation for invalid user check")
|
||||
|
||||
self.valid_account_1 = Account.create(
|
||||
self.apiclient,
|
||||
self.services["account"],
|
||||
domainid=self.domain_1.id
|
||||
)
|
||||
self.cleanup.append(self.valid_account_1)
|
||||
Volume.create(
|
||||
self.apiclient,
|
||||
self.services["volume"],
|
||||
zoneid=self.zone.id,
|
||||
account=self.valid_account_1.name,
|
||||
domainid=self.valid_account_1.domainid,
|
||||
diskofferingid=self.disk_offering.id
|
||||
)
|
||||
self.debug("Volume created for first subdomain %s" % self.valid_account_1.domainid)
|
||||
|
||||
self.valid_account_2 = Account.create(
|
||||
self.apiclient,
|
||||
self.services["account2"],
|
||||
domainid=self.domain_2.id
|
||||
)
|
||||
self.cleanup.append(self.valid_account_2)
|
||||
Volume.create(
|
||||
self.apiclient,
|
||||
self.services["volume"],
|
||||
zoneid=self.zone.id,
|
||||
account=self.valid_account_2.name,
|
||||
domainid=self.valid_account_2.domainid,
|
||||
diskofferingid=self.disk_offering.id
|
||||
)
|
||||
self.debug("Volume created for second subdomain %s" % self.valid_account_2.domainid)
|
||||
|
||||
self.valid_account_3 = Account.create(
|
||||
self.apiclient,
|
||||
self.services["user"],
|
||||
domainid=self.domain_11.id
|
||||
)
|
||||
self.cleanup.append(self.valid_account_3)
|
||||
Volume.create(
|
||||
self.apiclient,
|
||||
self.services["volume"],
|
||||
zoneid=self.zone.id,
|
||||
account=self.valid_account_3.name,
|
||||
domainid=self.valid_account_3.domainid,
|
||||
diskofferingid=self.disk_offering.id
|
||||
)
|
||||
self.debug("Volume created for first child subdomain %s" % self.valid_account_3.domainid)
|
||||
|
||||
return
|
||||
|
|
@ -0,0 +1,358 @@
|
|||
# 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.
|
||||
""" BVT tests for Network offerings"""
|
||||
|
||||
#Import Local Modules
|
||||
from marvin.codes import FAILED
|
||||
from marvin.cloudstackTestCase import cloudstackTestCase
|
||||
from marvin.cloudstackAPI import (listNetworkOfferings,
|
||||
updateNetworkOffering)
|
||||
from marvin.lib.utils import (isAlmostEqual,
|
||||
cleanup_resources,
|
||||
random_gen)
|
||||
from marvin.lib.base import (Domain,
|
||||
NetworkOffering,
|
||||
Account,
|
||||
Network)
|
||||
from marvin.lib.common import (get_domain,
|
||||
get_zone,
|
||||
list_hosts)
|
||||
from nose.plugins.attrib import attr
|
||||
|
||||
import time
|
||||
from marvin.sshClient import SshClient
|
||||
from marvin.cloudstackException import CloudstackAPIException
|
||||
from marvin.lib.decoratorGenerators import skipTestIf
|
||||
|
||||
|
||||
_multiprocess_shared_ = True
|
||||
|
||||
class TestCreateDomainsNetworkOffering(cloudstackTestCase):
|
||||
|
||||
def setUp(self):
|
||||
self.services = self.testClient.getParsedTestDataConfig()
|
||||
self.apiclient = self.testClient.getApiClient()
|
||||
self.dbclient = self.testClient.getDbConnection()
|
||||
self.cleanup = []
|
||||
return
|
||||
|
||||
def tearDown(self):
|
||||
try:
|
||||
#Clean up, terminate the created templates
|
||||
cleanup_resources(self.apiclient, self.cleanup)
|
||||
|
||||
except Exception as e:
|
||||
raise Exception("Warning: Exception during cleanup : %s" % e)
|
||||
return
|
||||
|
||||
@classmethod
|
||||
def setUpClass(cls):
|
||||
testClient = super(TestCreateDomainsNetworkOffering, cls).getClsTestClient()
|
||||
cls.apiclient = testClient.getApiClient()
|
||||
cls.services = testClient.getParsedTestDataConfig()
|
||||
# Create domains
|
||||
cls.domain_1 = Domain.create(
|
||||
cls.apiclient,
|
||||
cls.services["acl"]["domain1"]
|
||||
)
|
||||
cls.domain_11 = Domain.create(
|
||||
cls.apiclient,
|
||||
cls.services["acl"]["domain11"],
|
||||
parentdomainid=cls.domain_1.id
|
||||
)
|
||||
cls.domain_2 = Domain.create(
|
||||
cls.apiclient,
|
||||
cls.services["acl"]["domain2"]
|
||||
)
|
||||
cls._cleanup = [
|
||||
cls.domain_11,
|
||||
cls.domain_1,
|
||||
cls.domain_2
|
||||
]
|
||||
return
|
||||
|
||||
@classmethod
|
||||
def tearDownClass(cls):
|
||||
try:
|
||||
cls.apiclient = super(
|
||||
TestCreateDomainsNetworkOffering,
|
||||
cls).getClsTestClient().getApiClient()
|
||||
# Clean up, terminate the created templates
|
||||
cleanup_resources(cls.apiclient, cls._cleanup)
|
||||
|
||||
except Exception as e:
|
||||
raise
|
||||
|
||||
@attr(
|
||||
tags=[
|
||||
"advanced",
|
||||
"basic",
|
||||
"eip",
|
||||
"sg",
|
||||
"advancedns",
|
||||
"smoke"],
|
||||
required_hardware="false")
|
||||
def test_01_create_network_offering(self):
|
||||
"""Test to create network offering
|
||||
|
||||
# Validate the following:
|
||||
# 1. createNetworkOfferings should return valid info for new offering
|
||||
# 2. The Cloud Database contains the valid information
|
||||
"""
|
||||
offering_data_domainid = "{0},{1}".format(self.domain_11.id, self.domain_2.id)
|
||||
|
||||
network_offering = NetworkOffering.create(
|
||||
self.apiclient,
|
||||
self.services["network_offering"],
|
||||
domainid=offering_data_domainid
|
||||
)
|
||||
self.cleanup.append(network_offering)
|
||||
|
||||
self.debug("Created Network offering with ID: %s" % network_offering.id)
|
||||
|
||||
cmd = listNetworkOfferings.listNetworkOfferingsCmd()
|
||||
cmd.id = network_offering.id
|
||||
list_network_response = self.apiclient.listNetworkOfferings(cmd)
|
||||
self.assertEqual(
|
||||
isinstance(list_network_response, list),
|
||||
True,
|
||||
"Check list response returns a valid list"
|
||||
)
|
||||
self.assertNotEqual(
|
||||
len(list_network_response),
|
||||
0,
|
||||
"Check Network offering is created"
|
||||
)
|
||||
network_response = list_network_response[0]
|
||||
|
||||
self.assertEqual(
|
||||
network_response.id,
|
||||
network_offering.id,
|
||||
"Check server id in createNetworkOffering"
|
||||
)
|
||||
self.assertItemsEqual(
|
||||
network_response.domainid.split(","),
|
||||
offering_data_domainid.split(","),
|
||||
"Check domainid in createNetworkOffering"
|
||||
)
|
||||
return
|
||||
|
||||
class TestDomainsNetworkOfferings(cloudstackTestCase):
|
||||
|
||||
def setUp(self):
|
||||
self.apiclient = self.testClient.getApiClient()
|
||||
self.dbclient = self.testClient.getDbConnection()
|
||||
self.cleanup = []
|
||||
|
||||
def tearDown(self):
|
||||
|
||||
try:
|
||||
#Clean up, terminate the created templates
|
||||
cleanup_resources(self.apiclient, self.cleanup)
|
||||
|
||||
except Exception as e:
|
||||
raise Exception("Warning: Exception during cleanup : %s" % e)
|
||||
return
|
||||
|
||||
@classmethod
|
||||
def setUpClass(cls):
|
||||
testClient = super(TestDomainsNetworkOfferings, cls).getClsTestClient()
|
||||
cls.apiclient = cls.testClient.getApiClient()
|
||||
cls.services = cls.testClient.getParsedTestDataConfig()
|
||||
# Create domains
|
||||
cls.domain_1 = Domain.create(
|
||||
cls.apiclient,
|
||||
cls.services["acl"]["domain1"]
|
||||
)
|
||||
cls.domain_11 = Domain.create(
|
||||
cls.apiclient,
|
||||
cls.services["acl"]["domain11"],
|
||||
parentdomainid=cls.domain_1.id
|
||||
)
|
||||
cls.domain_2 = Domain.create(
|
||||
cls.apiclient,
|
||||
cls.services["acl"]["domain2"]
|
||||
)
|
||||
cls.domain_3 = Domain.create(
|
||||
cls.apiclient,
|
||||
cls.services["acl"]["domain12"]
|
||||
)
|
||||
|
||||
cls.zone = get_zone(cls.apiclient, testClient.getZoneForTests())
|
||||
|
||||
cls.network_offering = NetworkOffering.create(
|
||||
cls.apiclient,
|
||||
cls.services["network_offering"],
|
||||
domainid=cls.domain_1.id
|
||||
)
|
||||
# Enable Network offering
|
||||
cls.network_offering.update(cls.apiclient, state='Enabled')
|
||||
cls._cleanup = [
|
||||
cls.network_offering,
|
||||
cls.domain_11,
|
||||
cls.domain_1,
|
||||
cls.domain_2,
|
||||
cls.domain_3
|
||||
]
|
||||
return
|
||||
|
||||
@classmethod
|
||||
def tearDownClass(cls):
|
||||
try:
|
||||
cls.apiclient = super(TestDomainsNetworkOfferings, cls).getClsTestClient().getApiClient()
|
||||
cleanup_resources(cls.apiclient, cls._cleanup)
|
||||
except Exception as e:
|
||||
raise Exception("Warning: Exception during cleanup : %s" % e)
|
||||
return
|
||||
|
||||
@attr(tags=["advanced", "basic", "eip", "sg", "advancedns", "smoke"], required_hardware="false")
|
||||
def test_02_edit_network_offering(self):
|
||||
"""Test to update existing network offering"""
|
||||
|
||||
# 1. updateNetworkOffering should return a valid information for the updated offering
|
||||
# 2. updateNetworkOffering should fail while tring to add child domain but parent domain
|
||||
# is already present
|
||||
# 3. updateNetworkOffering should be able to add new domain to the offering
|
||||
self.debug("Updating network offering with ID: %s" %
|
||||
self.network_offering.id)
|
||||
|
||||
cmd = updateNetworkOffering.updateNetworkOfferingCmd()
|
||||
# Add parameters for API call
|
||||
cmd.id = self.network_offering.id
|
||||
cmd.domainid = self.domain_11.id
|
||||
try:
|
||||
self.apiclient.updateNetworkOffering(cmd)
|
||||
self.fail("Child domain added to offering when parent domain already exist. Must be an error.")
|
||||
except CloudstackAPIException:
|
||||
self.debug("Child domain check")
|
||||
|
||||
|
||||
cmd = updateNetworkOffering.updateNetworkOfferingCmd()
|
||||
cmd.id = self.network_offering.id
|
||||
cmd.domainid = self.domain_2.id
|
||||
self.apiclient.updateNetworkOffering(cmd)
|
||||
|
||||
cmd = listNetworkOfferings.listNetworkOfferingsCmd()
|
||||
cmd.id = self.network_offering.id
|
||||
list_network_response = self.apiclient.listNetworkOfferings(cmd)
|
||||
self.assertEqual(
|
||||
isinstance(list_network_response, list),
|
||||
True,
|
||||
"Check list response returns a valid list"
|
||||
)
|
||||
|
||||
self.assertNotEqual(
|
||||
len(list_network_response),
|
||||
0,
|
||||
"Check Network offering is updated"
|
||||
)
|
||||
|
||||
domainid = "{0},{1}".format(self.domain_1.id, self.domain_2.id)
|
||||
self.assertItemsEqual(
|
||||
list_network_response[0].domainid.split(","),
|
||||
domainid.split(","),
|
||||
"Check domainid in createNetworkOffering"
|
||||
)
|
||||
return
|
||||
|
||||
@attr(
|
||||
tags=[
|
||||
"advanced",
|
||||
"basic",
|
||||
"eip",
|
||||
"sg",
|
||||
"advancedns",
|
||||
"smoke"],
|
||||
required_hardware="false")
|
||||
def test_03_create_network_domain_network_offering(self):
|
||||
"""Test to creating network for an existing domain specified network offering"""
|
||||
|
||||
# Validate the following:
|
||||
# 1. Network creation should fail for the user from a different domain
|
||||
# 2. Network creation should work for users from domains for which offering is specified
|
||||
self.debug("Deploying VM using network offering with ID: %s" %
|
||||
self.network_offering.id)
|
||||
|
||||
self.invalid_account = Account.create(
|
||||
self.apiclient,
|
||||
self.services["account"],
|
||||
domainid=self.domain_3.id
|
||||
)
|
||||
self.cleanup.append(self.invalid_account)
|
||||
|
||||
try:
|
||||
Network.create(
|
||||
self.apiclient,
|
||||
self.services["network"],
|
||||
self.invalid_account.name,
|
||||
self.invalid_account.domainid,
|
||||
zoneid=self.zone.id,
|
||||
networkofferingid=self.network_offering.id
|
||||
)
|
||||
self.fail("Network created for a user from domain which has not been specified for service offering. Must be an error.")
|
||||
except CloudstackAPIException:
|
||||
self.debug("Network creation for invalid user check")
|
||||
|
||||
self.valid_account_1 = Account.create(
|
||||
self.apiclient,
|
||||
self.services["account"],
|
||||
domainid=self.domain_1.id
|
||||
)
|
||||
self.cleanup.append(self.valid_account_1)
|
||||
Network.create(
|
||||
self.apiclient,
|
||||
self.services["network"],
|
||||
self.valid_account_1.name,
|
||||
self.valid_account_1.domainid,
|
||||
zoneid=self.zone.id,
|
||||
networkofferingid=self.network_offering.id
|
||||
)
|
||||
self.debug("Network created for first subdomain %s" % self.valid_account_1.domainid)
|
||||
|
||||
self.valid_account_2 = Account.create(
|
||||
self.apiclient,
|
||||
self.services["account2"],
|
||||
domainid=self.domain_2.id
|
||||
)
|
||||
self.cleanup.append(self.valid_account_2)
|
||||
Network.create(
|
||||
self.apiclient,
|
||||
self.services["network"],
|
||||
self.valid_account_2.name,
|
||||
self.valid_account_2.domainid,
|
||||
zoneid=self.zone.id,
|
||||
networkofferingid=self.network_offering.id
|
||||
)
|
||||
self.debug("Network created for second subdomain %s" % self.valid_account_2.domainid)
|
||||
|
||||
self.valid_account_3 = Account.create(
|
||||
self.apiclient,
|
||||
self.services["user"],
|
||||
domainid=self.domain_11.id
|
||||
)
|
||||
self.cleanup.append(self.valid_account_3)
|
||||
Network.create(
|
||||
self.apiclient,
|
||||
self.services["network"],
|
||||
self.valid_account_3.name,
|
||||
self.valid_account_3.domainid,
|
||||
zoneid=self.zone.id,
|
||||
networkofferingid=self.network_offering.id
|
||||
)
|
||||
self.debug("Network created for first child subdomain %s" % self.valid_account_3.domainid)
|
||||
|
||||
return
|
||||
|
|
@ -0,0 +1,409 @@
|
|||
# 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.
|
||||
""" BVT tests for Service offerings"""
|
||||
|
||||
# Import Local Modules
|
||||
from marvin.codes import FAILED
|
||||
from marvin.cloudstackTestCase import cloudstackTestCase
|
||||
from marvin.cloudstackAPI import updateServiceOffering
|
||||
from marvin.lib.utils import (isAlmostEqual,
|
||||
cleanup_resources,
|
||||
random_gen)
|
||||
from marvin.lib.base import (Domain,
|
||||
ServiceOffering,
|
||||
Account,
|
||||
VirtualMachine)
|
||||
from marvin.lib.common import (list_service_offering,
|
||||
list_virtual_machines,
|
||||
get_domain,
|
||||
get_zone,
|
||||
get_test_template,
|
||||
list_hosts)
|
||||
from nose.plugins.attrib import attr
|
||||
|
||||
import time
|
||||
from marvin.sshClient import SshClient
|
||||
from marvin.cloudstackException import CloudstackAPIException
|
||||
from marvin.lib.decoratorGenerators import skipTestIf
|
||||
|
||||
_multiprocess_shared_ = True
|
||||
|
||||
|
||||
class TestCreateDomainsServiceOffering(cloudstackTestCase):
|
||||
|
||||
def setUp(self):
|
||||
self.apiclient = self.testClient.getApiClient()
|
||||
self.dbclient = self.testClient.getDbConnection()
|
||||
self.cleanup = []
|
||||
self.services = self.testClient.getParsedTestDataConfig()
|
||||
|
||||
def tearDown(self):
|
||||
try:
|
||||
# Clean up, terminate the created templates
|
||||
cleanup_resources(self.apiclient, self.cleanup)
|
||||
|
||||
except Exception as e:
|
||||
raise Exception("Warning: Exception during cleanup : %s" % e)
|
||||
|
||||
return
|
||||
|
||||
@classmethod
|
||||
def setUpClass(cls):
|
||||
testClient = super(TestCreateDomainsServiceOffering, cls).getClsTestClient()
|
||||
cls.apiclient = testClient.getApiClient()
|
||||
cls.services = testClient.getParsedTestDataConfig()
|
||||
# Create domains
|
||||
cls.domain_1 = Domain.create(
|
||||
cls.apiclient,
|
||||
cls.services["acl"]["domain1"]
|
||||
)
|
||||
cls.domain_11 = Domain.create(
|
||||
cls.apiclient,
|
||||
cls.services["acl"]["domain11"],
|
||||
parentdomainid=cls.domain_1.id
|
||||
)
|
||||
cls.domain_2 = Domain.create(
|
||||
cls.apiclient,
|
||||
cls.services["acl"]["domain2"]
|
||||
)
|
||||
cls._cleanup = [
|
||||
cls.domain_11,
|
||||
cls.domain_1,
|
||||
cls.domain_2
|
||||
]
|
||||
return
|
||||
|
||||
@classmethod
|
||||
def tearDownClass(cls):
|
||||
try:
|
||||
cls.apiclient = super(
|
||||
TestCreateDomainsServiceOffering,
|
||||
cls).getClsTestClient().getApiClient()
|
||||
# Clean up, terminate the created templates
|
||||
cleanup_resources(cls.apiclient, cls._cleanup)
|
||||
|
||||
except Exception as e:
|
||||
raise
|
||||
|
||||
@attr(
|
||||
tags=[
|
||||
"advanced",
|
||||
"advancedns",
|
||||
"smoke",
|
||||
"basic",
|
||||
"eip",
|
||||
"sg"],
|
||||
required_hardware="false")
|
||||
def test_01_create_domain_service_offering(self):
|
||||
"""Test to create service offering for specified domain"""
|
||||
|
||||
# Validate the following:
|
||||
# 1. createServiceOfferings should return a valid information
|
||||
# for newly created offering
|
||||
# 2. The Cloud Database contains the valid information
|
||||
offering_data_domainid = "{0},{1}".format(self.domain_11.id, self.domain_2.id)
|
||||
|
||||
service_offering = ServiceOffering.create(
|
||||
self.apiclient,
|
||||
self.services["service_offerings"]["tiny"],
|
||||
domainid=offering_data_domainid
|
||||
)
|
||||
self.cleanup.append(service_offering)
|
||||
|
||||
self.debug(
|
||||
"Created service offering with ID: %s" %
|
||||
service_offering.id)
|
||||
|
||||
list_service_response = list_service_offering(
|
||||
self.apiclient,
|
||||
id=service_offering.id
|
||||
)
|
||||
self.assertEqual(
|
||||
isinstance(list_service_response, list),
|
||||
True,
|
||||
"Check list response returns a valid list"
|
||||
)
|
||||
|
||||
self.assertNotEqual(
|
||||
len(list_service_response),
|
||||
0,
|
||||
"Check Service offering is created"
|
||||
)
|
||||
|
||||
self.assertEqual(
|
||||
list_service_response[0].cpunumber,
|
||||
self.services["service_offerings"]["tiny"]["cpunumber"],
|
||||
"Check cpunumber in createServiceOffering"
|
||||
)
|
||||
self.assertEqual(
|
||||
list_service_response[0].cpuspeed,
|
||||
self.services["service_offerings"]["tiny"]["cpuspeed"],
|
||||
"Check cpuspeed in createServiceOffering"
|
||||
)
|
||||
self.assertEqual(
|
||||
list_service_response[0].displaytext,
|
||||
self.services["service_offerings"]["tiny"]["displaytext"],
|
||||
"Check server displaytext in createServiceOfferings"
|
||||
)
|
||||
self.assertEqual(
|
||||
list_service_response[0].memory,
|
||||
self.services["service_offerings"]["tiny"]["memory"],
|
||||
"Check memory in createServiceOffering"
|
||||
)
|
||||
self.assertEqual(
|
||||
list_service_response[0].name,
|
||||
self.services["service_offerings"]["tiny"]["name"],
|
||||
"Check name in createServiceOffering"
|
||||
)
|
||||
self.assertItemsEqual(
|
||||
list_service_response[0].domainid.split(","),
|
||||
offering_data_domainid.split(","),
|
||||
"Check domainid in createServiceOffering"
|
||||
)
|
||||
return
|
||||
|
||||
|
||||
class TestDomainsServiceOfferings(cloudstackTestCase):
|
||||
|
||||
def setUp(self):
|
||||
self.apiclient = self.testClient.getApiClient()
|
||||
self.dbclient = self.testClient.getDbConnection()
|
||||
self.cleanup = []
|
||||
|
||||
def tearDown(self):
|
||||
try:
|
||||
# Clean up, terminate the created templates
|
||||
cleanup_resources(self.apiclient, self.cleanup)
|
||||
|
||||
except Exception as e:
|
||||
raise Exception("Warning: Exception during cleanup : %s" % e)
|
||||
|
||||
return
|
||||
|
||||
@classmethod
|
||||
def setUpClass(cls):
|
||||
testClient = super(TestDomainsServiceOfferings, cls).getClsTestClient()
|
||||
cls.apiclient = testClient.getApiClient()
|
||||
cls.services = testClient.getParsedTestDataConfig()
|
||||
cls.hypervisor = testClient.getHypervisorInfo()
|
||||
# Create domains
|
||||
cls.domain_1 = Domain.create(
|
||||
cls.apiclient,
|
||||
cls.services["acl"]["domain1"]
|
||||
)
|
||||
cls.domain_11 = Domain.create(
|
||||
cls.apiclient,
|
||||
cls.services["acl"]["domain11"],
|
||||
parentdomainid=cls.domain_1.id
|
||||
)
|
||||
cls.domain_2 = Domain.create(
|
||||
cls.apiclient,
|
||||
cls.services["acl"]["domain2"]
|
||||
)
|
||||
cls.domain_3 = Domain.create(
|
||||
cls.apiclient,
|
||||
cls.services["acl"]["domain12"]
|
||||
)
|
||||
cls.zone = get_zone(cls.apiclient, testClient.getZoneForTests())
|
||||
cls.services['mode'] = cls.zone.networktype
|
||||
|
||||
cls.service_offering = ServiceOffering.create(
|
||||
cls.apiclient,
|
||||
cls.services["service_offerings"]["tiny"],
|
||||
domainid=cls.domain_1.id
|
||||
)
|
||||
template = get_test_template(
|
||||
cls.apiclient,
|
||||
cls.zone.id,
|
||||
cls.hypervisor
|
||||
)
|
||||
if template == FAILED:
|
||||
assert False, "get_test_template() failed to return template"
|
||||
|
||||
# Set Zones and disk offerings
|
||||
cls.services["small"]["zoneid"] = cls.zone.id
|
||||
cls.services["small"]["template"] = template.id
|
||||
|
||||
cls._cleanup = [
|
||||
cls.service_offering,
|
||||
cls.domain_11,
|
||||
cls.domain_1,
|
||||
cls.domain_2,
|
||||
cls.domain_3
|
||||
]
|
||||
return
|
||||
|
||||
@classmethod
|
||||
def tearDownClass(cls):
|
||||
try:
|
||||
cls.apiclient = super(
|
||||
TestDomainsServiceOfferings,
|
||||
cls).getClsTestClient().getApiClient()
|
||||
# Clean up, terminate the created templates
|
||||
cleanup_resources(cls.apiclient, cls._cleanup)
|
||||
|
||||
except Exception as e:
|
||||
raise Exception("Warning: Exception during cleanup : %s" % e)
|
||||
return
|
||||
|
||||
@attr(
|
||||
tags=[
|
||||
"advanced",
|
||||
"advancedns",
|
||||
"smoke",
|
||||
"basic",
|
||||
"eip",
|
||||
"sg"],
|
||||
required_hardware="false")
|
||||
def test_02_edit_domain_service_offering(self):
|
||||
"""Test to update existing service offering"""
|
||||
|
||||
# Validate the following:
|
||||
# 1. updateServiceOffering should return a valid information for the updated offering
|
||||
# 2. updateServiceOffering should fail when try t add child domain but parent domain is
|
||||
# already present
|
||||
# 3. updateServiceOffering should be able to add new domain to the offering
|
||||
self.debug("Updating service offering with ID: %s" %
|
||||
self.service_offering.id)
|
||||
|
||||
cmd = updateServiceOffering.updateServiceOfferingCmd()
|
||||
# Add parameters for API call
|
||||
cmd.id = self.service_offering.id
|
||||
cmd.domainid = self.domain_11.id
|
||||
try:
|
||||
self.apiclient.updateServiceOffering(cmd)
|
||||
self.fail("Child domain added to offering when parent domain already exist. Must be an error.")
|
||||
except CloudstackAPIException:
|
||||
self.debug("Child domain check")
|
||||
|
||||
|
||||
cmd = updateServiceOffering.updateServiceOfferingCmd()
|
||||
cmd.id = self.service_offering.id
|
||||
cmd.domainid = self.domain_2.id
|
||||
self.apiclient.updateServiceOffering(cmd)
|
||||
|
||||
list_service_response = list_service_offering(
|
||||
self.apiclient,
|
||||
id=self.service_offering.id
|
||||
)
|
||||
self.assertEqual(
|
||||
isinstance(list_service_response, list),
|
||||
True,
|
||||
"Check list response returns a valid list"
|
||||
)
|
||||
|
||||
self.assertNotEqual(
|
||||
len(list_service_response),
|
||||
0,
|
||||
"Check Service offering is updated"
|
||||
)
|
||||
|
||||
domainid = "{0},{1}".format(self.domain_1.id, self.domain_2.id)
|
||||
self.assertItemsEqual(
|
||||
list_service_response[0].domainid.split(","),
|
||||
domainid.split(","),
|
||||
"Check domainid in createServiceOffering"
|
||||
)
|
||||
|
||||
return
|
||||
|
||||
@attr(
|
||||
tags=[
|
||||
"advanced",
|
||||
"advancedns",
|
||||
"smoke",
|
||||
"basic",
|
||||
"eip",
|
||||
"sg"],
|
||||
required_hardware="false")
|
||||
def test_03_deploy_vm_domain_service_offering(self):
|
||||
"""Test to deploying VM for an existing domain specified service offering"""
|
||||
|
||||
# Validate the following:
|
||||
# 1. VM deployment should fail for the user from a different domain
|
||||
# 2. VM deployment should work for users from domains for which offering is specified
|
||||
self.debug("Deploying VM using service offering with ID: %s" %
|
||||
self.service_offering.id)
|
||||
|
||||
self.invalid_account = Account.create(
|
||||
self.apiclient,
|
||||
self.services["account"],
|
||||
domainid=self.domain_3.id
|
||||
)
|
||||
self.cleanup.append(self.invalid_account)
|
||||
|
||||
try:
|
||||
VirtualMachine.create(
|
||||
self.apiclient,
|
||||
self.services["small"],
|
||||
accountid=self.invalid_account.name,
|
||||
domainid=self.invalid_account.domainid,
|
||||
serviceofferingid=self.service_offering.id,
|
||||
mode=self.services["mode"]
|
||||
)
|
||||
self.fail("VM deployed for a user from domain which has not been specified for service offering. Must be an error.")
|
||||
except CloudstackAPIException:
|
||||
self.debug("VM deployment for invalid user check")
|
||||
|
||||
self.valid_account_1 = Account.create(
|
||||
self.apiclient,
|
||||
self.services["account"],
|
||||
domainid=self.domain_1.id
|
||||
)
|
||||
self.cleanup.append(self.valid_account_1)
|
||||
self.vm_1 = VirtualMachine.create(
|
||||
self.apiclient,
|
||||
self.services["small"],
|
||||
accountid=self.valid_account_1.name,
|
||||
domainid=self.valid_account_1.domainid,
|
||||
serviceofferingid=self.service_offering.id,
|
||||
mode=self.services["mode"]
|
||||
)
|
||||
self.debug("VM deployed for first subdomain %s" % self.valid_account_1.domainid)
|
||||
|
||||
self.valid_account_2 = Account.create(
|
||||
self.apiclient,
|
||||
self.services["account2"],
|
||||
domainid=self.domain_2.id
|
||||
)
|
||||
self.cleanup.append(self.valid_account_2)
|
||||
self.vm_2 = VirtualMachine.create(
|
||||
self.apiclient,
|
||||
self.services["small"],
|
||||
accountid=self.valid_account_2.name,
|
||||
domainid=self.valid_account_2.domainid,
|
||||
serviceofferingid=self.service_offering.id,
|
||||
mode=self.services["mode"]
|
||||
)
|
||||
self.debug("VM deployed for second subdomain %s" % self.valid_account_2.domainid)
|
||||
|
||||
self.valid_account_3 = Account.create(
|
||||
self.apiclient,
|
||||
self.services["user"],
|
||||
domainid=self.domain_11.id
|
||||
)
|
||||
self.cleanup.append(self.valid_account_3)
|
||||
self.vm_3 = VirtualMachine.create(
|
||||
self.apiclient,
|
||||
self.services["small"],
|
||||
accountid=self.valid_account_3.name,
|
||||
domainid=self.valid_account_3.domainid,
|
||||
serviceofferingid=self.service_offering.id,
|
||||
mode=self.services["mode"]
|
||||
)
|
||||
self.debug("VM deployed for first child subdomain %s" % self.valid_account_3.domainid)
|
||||
|
||||
return
|
||||
Loading…
Reference in New Issue