Add functional test for resource exposure
These simple tests check that Sahara resources can not be created
and are not listed in the resource-type-list.
If we ever decide to install Sahara on the Heat functional tests gate,
tests should be changed to use other not installed but in principle
supported service and resources, as these tests will be skipped in this
case.
Related blueprint keystone-based-resource-availability
Change-Id: I6e692587f49b6c34c5e99b8d26bb6e60b7ce7af5
diff --git a/functional/test_conditional_exposure.py b/functional/test_conditional_exposure.py
new file mode 100644
index 0000000..c74b297
--- /dev/null
+++ b/functional/test_conditional_exposure.py
@@ -0,0 +1,82 @@
+# 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.
+
+from heatclient import exc
+import keystoneclient
+
+from heat_integrationtests.common import test
+
+
+class ConditionalExposureTestBase(test.HeatIntegrationTest):
+ def setUp(self):
+ super(ConditionalExposureTestBase, self).setUp()
+ self.client = self.orchestration_client
+
+ def _delete(self, stack_name):
+ stacks = self.client.stacks.list()
+ for s in stacks:
+ if s.stack_name == stack_name:
+ self._stack_delete(s.identifier)
+ break
+
+
+class ServiceBasedExposureTest(ConditionalExposureTestBase):
+ # NOTE(pas-ha) if we ever decide to install Sahara on Heat
+ # functional gate, this must be changed to other not-installed
+ # but in principle supported service
+ unavailable_service = 'Sahara'
+ unavailable_template = """
+heat_template_version: 2015-10-15
+resources:
+ not_available:
+ type: OS::Sahara::NodeGroupTemplate
+ properties:
+ plugin_name: fake
+ hadoop_version: 0.1
+ flavor: m1.large
+ node_processes: []
+"""
+
+ def setUp(self):
+ super(ServiceBasedExposureTest, self).setUp()
+ # check that Sahara endpoint is available
+ if self._is_sahara_deployed():
+ self.skipTest("Sahara is actually deployed, "
+ "can not run negative tests on "
+ "Sahara resources availability.")
+
+ def _is_sahara_deployed(self):
+ keystone = self.identity_client
+ try:
+ keystone.service_catalog.url_for(
+ attr='region',
+ filter_value=self.conf.region,
+ service_type='data-processing',
+ endpoint_type='publicURL')
+ except keystoneclient.exceptions.EndpointNotFound:
+ return False
+ return True
+
+ def test_unavailable_resources_not_listed(self):
+ resources = self.client.resource_types.list()
+ self.assertFalse(any(self.unavailable_service in r.resource_type
+ for r in resources))
+
+ def test_unavailable_resources_not_created(self):
+ stack_name = self._stack_rand_name()
+ self.addCleanup(self._delete, stack_name)
+ ex = self.assertRaises(exc.HTTPBadRequest,
+ self.client.stacks.create,
+ stack_name=stack_name,
+ template=self.unavailable_template)
+ self.assertIn('ResourceTypeUnavailable', ex.message)
+ self.assertIn('OS::Sahara::NodeGroupTemplate', ex.message)