Merge "implement the resource list API"

vitrage_tempest_tests/tests/api/resources/test_resources.py

@@ -0,0 +1,154 @@
+# Copyright 2017 ZTE, Nokia
+#
+#    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 json
+import traceback
+
+from oslo_log import log as logging
+
+from vitrage.datasources import CINDER_VOLUME_DATASOURCE
+from vitrage.datasources import NOVA_INSTANCE_DATASOURCE
+from vitrage_tempest_tests.tests.api.base import BaseApiTest
+import vitrage_tempest_tests.tests.utils as utils
+
+
+LOG = logging.getLogger(__name__)
+
+
+class TestResource(BaseApiTest):
+    """Test class for Vitrage resource API tests."""
+
+    @classmethod
+    def setUpClass(cls):
+        super(TestResource, cls).setUpClass()
+
+    @utils.tempest_logger
+    def test_compare_cli_vs_api_resource_list(self):
+        """resource list """
+        try:
+            instances = self._create_instances(num_instances=1)
+            self.assertNotEqual(len(instances), 0,
+                                'The instances list is empty')
+            api_resources = self.vitrage_client.resource.list()
+            cli_resources = utils.run_vitrage_command(
+                'vitrage resource list -f json', self.conf)
+
+            self._compare_resources(api_resources, cli_resources)
+        except Exception as e:
+            LOG.exception(e)
+            traceback.print_exc()
+            raise
+        finally:
+            self._delete_instances()
+
+    @utils.tempest_logger
+    def test_default_resource_list(self):
+        """resource list with default query
+
+        get the resources: cluster, zone, host and one instance
+        """
+        try:
+            instances = self._create_instances(num_instances=1)
+            self.assertNotEqual(len(instances), 0,
+                                'The instances list is empty')
+            resources = self.vitrage_client.resource.list()
+            self.assertEqual(4, len(resources))
+        except Exception as e:
+            LOG.exception(e)
+            traceback.print_exc()
+            raise
+        finally:
+            self._delete_instances()
+
+    @utils.tempest_logger
+    def test_resource_list_with_all_tenants(self):
+        """resource list with all tenants
+
+        get the resources:
+        cluster, zone, host and one instance(no other tenants)
+        """
+        try:
+            instances = self._create_instances(num_instances=1)
+            self.assertNotEqual(len(instances), 0,
+                                'The instances list is empty')
+            resources = self.vitrage_client.resource.list(all_tenants=True)
+            self.assertEqual(4, len(resources))
+        except Exception as e:
+            LOG.exception(e)
+            traceback.print_exc()
+            raise
+        finally:
+            self._delete_instances()
+
+    @utils.tempest_logger
+    def test_resource_list_with_existing_type(self):
+        """resource list with existing type
+
+        get the resource: one instance
+        """
+        try:
+            instances = self._create_instances(num_instances=1)
+            self.assertNotEqual(len(instances), 0,
+                                'The instances list is empty')
+            resources = self.vitrage_client.resource.list(
+                resource_type=NOVA_INSTANCE_DATASOURCE,
+                all_tenants=False)
+            self.assertEqual(1, len(resources))
+        except Exception as e:
+            LOG.exception(e)
+            traceback.print_exc()
+            raise
+        finally:
+            self._delete_instances()
+
+    @utils.tempest_logger
+    def test_resource_list_with_no_existing_type(self):
+        """resource list with no existing type"""
+        try:
+            instances = self._create_instances(num_instances=1)
+            self.assertNotEqual(len(instances), 0,
+                                'The instances list is empty')
+            resources = self.vitrage_client.resource.list(
+                resource_type=CINDER_VOLUME_DATASOURCE,
+                all_tenants=False)
+            self.assertEqual(0, len(resources))
+        except Exception as e:
+            LOG.exception(e)
+            traceback.print_exc()
+            raise
+        finally:
+            self._delete_instances()
+
+    def _compare_resources(self, api_resources, cli_resources):
+        self.assertNotEqual(len(api_resources), 0,
+                            'The resources taken from rest api is empty')
+        self.assertNotEqual(len(cli_resources), 0,
+                            'The resources taken from terminal is empty')
+
+        sorted_cli_resources = sorted(
+            json.loads(cli_resources),
+            key=lambda resource: resource["vitrage_id"])
+        sorted_api_resources = sorted(
+            api_resources,
+            key=lambda resource: resource["vitrage_id"])
+
+        self.assertEqual(len(sorted_cli_resources),
+                         len(sorted_api_resources))
+
+        properties = ('vitrage_id', 'type', 'id', 'state',
+                      'aggregated_state', 'operational_state')
+        for cli_resource, api_resource in \
+                zip(sorted_cli_resources, sorted_api_resources):
+            for item in properties:
+                self.assertEqual(cli_resource.get(item),
+                                 api_resource.get(item))