Tempest: add basic test
Change-Id: I7155e797fecf18b867eeb7c63ebbcb35d3cbb9c3
Co-Authored-By: dparalen <vetrisko@gmail.com>
Depends-On: Ibf0c73aa6795aaa52e945fd6baa821de20a599e7
Depends-On: I067504e49f68929298c91e61819aa9a61169fe52
diff --git a/ironic_tempest_plugin/tests/manager.py b/ironic_tempest_plugin/tests/manager.py
new file mode 100644
index 0000000..dd2a18e
--- /dev/null
+++ b/ironic_tempest_plugin/tests/manager.py
@@ -0,0 +1,140 @@
+# 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.
+
+
+import os
+import time
+
+from tempest import config
+
+from ironic_inspector.test.inspector_tempest_plugin import exceptions
+from ironic_inspector.test.inspector_tempest_plugin.services import \
+ introspection_client
+from ironic_tempest_plugin.tests.scenario.baremetal_manager import \
+ BaremetalScenarioTest
+
+
+CONF = config.CONF
+
+
+class InspectorScenarioTest(BaremetalScenarioTest):
+ """Provide harness to do Inspector scenario tests."""
+
+ credentials = ['primary', 'admin']
+
+ @classmethod
+ def setup_clients(cls):
+ super(InspectorScenarioTest, cls).setup_clients()
+ inspector_manager = introspection_client.Manager()
+ cls.introspection_client = inspector_manager.introspection_client
+
+ def setUp(self):
+ super(InspectorScenarioTest, self).setUp()
+ self.flavor = self.baremetal_flavor()
+
+ def item_filter(self, list_method, show_method,
+ filter=lambda item: True, items=None):
+ if items is None:
+ items = [show_method(item['uuid']) for item in
+ list_method()]
+ return [item for item in items if filter(item)]
+
+ def node_list(self):
+ return self.baremetal_client.list_nodes()[1]['nodes']
+
+ def node_update(self, uuid, patch):
+ return self.baremetal_client.update_node(uuid, **patch)
+
+ def node_show(self, uuid):
+ return self.baremetal_client.show_node(uuid)[1]
+
+ def node_filter(self, filter=lambda node: True, nodes=None):
+ return self.item_filter(self.node_list, self.node_show,
+ filter=filter, items=nodes)
+
+ def hypervisor_stats(self):
+ return (self.admin_manager.hypervisor_client.
+ show_hypervisor_statistics())
+
+ def server_show(self, uuid):
+ self.servers_client.show_server(uuid)
+
+ def rule_purge(self):
+ self.introspection_client.purge_rules()
+
+ def rule_import(self, rule_path):
+ self.introspection_client.import_rule(rule_path)
+
+ def introspection_status(self, uuid):
+ return self.introspection_client.get_status(uuid)[1]
+
+ def introspection_data(self, uuid):
+ return self.introspection_client.get_data(uuid)[1]
+
+ def baremetal_flavor(self):
+ flavor_id = CONF.compute.flavor_ref
+ flavor = self.flavors_client.show_flavor(flavor_id)['flavor']
+ flavor['properties'] = self.flavors_client.list_flavor_extra_specs(
+ flavor_id)['extra_specs']
+ return flavor
+
+ def get_rule_path(self, rule_file):
+ base_path = os.path.split(
+ os.path.dirname(os.path.abspath(__file__)))[0]
+ base_path = os.path.split(base_path)[0]
+ return os.path.join(base_path, "inspector_tempest_plugin",
+ "rules", rule_file)
+
+ # TODO(aarefiev): switch to call_until_true
+ def wait_for_introspection_finished(self, node_ids):
+ """Waits for introspection of baremetal nodes to finish.
+
+ """
+ start = int(time.time())
+ not_introspected = {node_id for node_id in node_ids}
+
+ while not_introspected:
+ time.sleep(CONF.baremetal_introspection.introspection_sleep)
+ for node_id in node_ids:
+ status = self.introspection_status(node_id)
+ if status['finished']:
+ if status['error']:
+ message = ('Node %(node_id)s introspection failed '
+ 'with %(error)s.' %
+ {'node_id': node_id,
+ 'error': status['error']})
+ raise exceptions.IntrospectionFailed(message)
+ not_introspected = not_introspected - {node_id}
+
+ if (int(time.time()) - start >=
+ CONF.baremetal_introspection.introspection_timeout):
+ message = ('Introspection timed out for nodes: %s' %
+ not_introspected)
+ raise exceptions.IntrospectionTimeout(message)
+
+ def wait_for_nova_aware_of_bvms(self):
+ start = int(time.time())
+ while True:
+ time.sleep(CONF.baremetal_introspection.hypervisor_update_sleep)
+ stats = self.hypervisor_stats()
+ expected_cpus = self.baremetal_flavor()['vcpus']
+ if int(stats['hypervisor_statistics']['vcpus']) >= expected_cpus:
+ break
+
+ timeout = CONF.baremetal_introspection.hypervisor_update_timeout
+ if (int(time.time()) - start >= timeout):
+ message = (
+ 'Timeout while waiting for nova hypervisor-stats: '
+ '%(stats)s required time (%(timeout)s s).' %
+ {'stats': stats,
+ 'timeout': timeout})
+ raise exceptions.HypervisorUpdateTimeout(message)