Create unit tests for the policy drivers

This change adds unit tests for the current version of the policy
abstract driver.

Change-Id: I8795999753424fdda512e5a1a8b0b6e522a39b1a

keystone/tests/unit/policy/backends/test_base.py

@@ -0,0 +1,61 @@
+# 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 uuid
+
+from keystone import exception
+
+
+class DriverTestCase(object):
+    """Test cases to validate the current policy driver behavior."""
+
+    def setUp(self):
+        super(DriverTestCase, self).setUp()
+
+        self.policy = {'id': uuid.uuid4().hex,
+                       'blob': '{"identity:create_user": "role:domain_admin"}',
+                       'type': 'application/json'}
+        self.driver.create_policy(self.policy['id'], self.policy)
+
+    @property
+    def driver(self):
+        raise exception.NotImplemented()
+
+    def test_list_policies(self):
+        another_policy = {'id': uuid.uuid4().hex,
+                          'blob': '{"compute:create": "role:project_member"}',
+                          'type': 'application/json'}
+        self.driver.create_policy(another_policy['id'], another_policy)
+
+        policies = self.driver.list_policies()
+
+        self.assertItemsEqual([self.policy, another_policy], policies)
+
+    def test_get_policy(self):
+        self.assertEqual(self.policy,
+                         self.driver.get_policy(self.policy['id']))
+
+    def test_update_policy(self):
+        self.policy['blob'] = ('{"identity:create_user": "role:domain_admin",'
+                               '"identity:update_user": "role:domain_admin"}')
+
+        self.driver.update_policy(self.policy['id'], self.policy)
+
+        self.assertEqual(self.policy,
+                         self.driver.get_policy(self.policy['id']))
+
+    def test_delete_policy(self):
+        self.driver.delete_policy(self.policy['id'])
+
+        self.assertRaises(exception.PolicyNotFound,
+                          self.driver.get_policy,
+                          self.policy['id'])

keystone/tests/unit/policy/backends/test_sql.py

@@ -0,0 +1,44 @@
+# 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 keystone.common import sql
+from keystone.policy.backends import sql as sql_driver
+from keystone.tests import unit
+from keystone.tests.unit.backend import core_sql
+from keystone.tests.unit.ksfixtures import database
+from keystone.tests.unit.policy.backends import test_base
+
+
+class SQLModelTestCase(core_sql.BaseBackendSqlModels):
+    """Test cases to validate the table structure."""
+
+    def test_policy_model(self):
+        cols = (('id', sql.String, 64),
+                ('blob', sql.JsonBlob, None),
+                ('type', sql.String, 255),
+                ('extra', sql.JsonBlob, None))
+
+        self.assertExpectedSchema('policy', cols)
+
+
+class SQLDriverTestCase(test_base.DriverTestCase, unit.TestCase):
+
+    def setUp(self):
+        # Load database first since parent's setUp will use it
+        self.useFixture(database.Database())
+        super(SQLDriverTestCase, self).setUp()
+
+    @property
+    def driver(self):
+        if not hasattr(self, '_driver'):
+            self._driver = sql_driver.Policy()
+        return self._driver