ISSUE #98

* Increase coverage.

Author: Sergio García Prado

packages/plugins/minos-database-aiopg/tests/test_aiopg/test_factories/test_aggregate/test_queries.py renamed to packages/plugins/minos-database-aiopg/tests/test_aiopg/test_factories/test_aggregate/test_snapshots/test_queries.py

@@ -0,0 +1,29 @@
+import unittest
+
+from minos.common import (
+    LockDatabaseOperationFactory,
+)
+from minos.plugins.aiopg import (
+    AiopgDatabaseOperation,
+    AiopgLockDatabaseOperationFactory,
+)
+
+
+class TestAiopgLockDatabaseOperationFactory(unittest.TestCase):
+    def setUp(self) -> None:
+        self.factory = AiopgLockDatabaseOperationFactory()
+
+    def test_is_subclass(self):
+        self.assertTrue(issubclass(AiopgLockDatabaseOperationFactory, LockDatabaseOperationFactory))
+
+    def test_build_acquire(self):
+        operation = self.factory.build_acquire(56)
+        self.assertIsInstance(operation, AiopgDatabaseOperation)
+
+    def test_build_release(self):
+        operation = self.factory.build_release(56)
+        self.assertIsInstance(operation, AiopgDatabaseOperation)
+
+
+if __name__ == "__main__":
+    unittest.main()

packages/plugins/minos-database-aiopg/tests/test_aiopg/test_factories/test_common/__init__.py

@@ -0,0 +1,29 @@
+import unittest
+
+from minos.common import (
+    ManagementDatabaseOperationFactory,
+)
+from minos.plugins.aiopg import (
+    AiopgDatabaseOperation,
+    AiopgManagementDatabaseOperationFactory,
+)
+
+
+class TestAiopgManagementDatabaseOperationFactory(unittest.TestCase):
+    def setUp(self) -> None:
+        self.factory = AiopgManagementDatabaseOperationFactory()
+
+    def test_is_subclass(self):
+        self.assertTrue(issubclass(AiopgManagementDatabaseOperationFactory, ManagementDatabaseOperationFactory))
+
+    def test_build_create(self):
+        operation = self.factory.build_create("foo")
+        self.assertIsInstance(operation, AiopgDatabaseOperation)
+
+    def test_build_delete(self):
+        operation = self.factory.build_delete("foo")
+        self.assertIsInstance(operation, AiopgDatabaseOperation)
+
+
+if __name__ == "__main__":
+    unittest.main()

packages/plugins/minos-database-aiopg/tests/test_aiopg/test_factories/test_common/test_locks.py

@@ -0,0 +1,31 @@
+import unittest
+
+from minos.networks import (
+    BrokerQueueDatabaseOperationFactory,
+)
+from minos.plugins.aiopg import (
+    AiopgBrokerQueueDatabaseOperationFactory,
+)
+
+
+class _BrokerQueueDatabaseOperationFactory(AiopgBrokerQueueDatabaseOperationFactory):
+    """For testing purposes."""
+
+    def build_table_name(self) -> str:
+        """For testing purposes."""
+        return "foo"
+
+
+class TestAiopgBrokerQueueDatabaseOperationFactory(unittest.TestCase):
+    def setUp(self) -> None:
+        self.factory = _BrokerQueueDatabaseOperationFactory()
+
+    def test_is_subclass(self):
+        self.assertTrue(AiopgBrokerQueueDatabaseOperationFactory, BrokerQueueDatabaseOperationFactory)
+
+    def test_build_table_name(self):
+        self.assertEqual("foo", self.factory.build_table_name())
+
+
+if __name__ == "__main__":
+    unittest.main()

packages/plugins/minos-database-aiopg/tests/test_aiopg/test_factories/test_common/test_managements.py

@@ -6,14 +6,15 @@
 from minos.plugins.aiopg import (
     AiopgBrokerPublisherQueueDatabaseOperationFactory,
     AiopgBrokerQueueDatabaseOperationFactory,
+    AiopgDatabaseOperation,
 )
 
 
 class TestAiopgBrokerPublisherQueueDatabaseOperationFactory(unittest.TestCase):
     def setUp(self) -> None:
         self.factory = AiopgBrokerPublisherQueueDatabaseOperationFactory()
 
-    def test_subclass(self):
+    def test_is_subclass(self):
         self.assertTrue(
             AiopgBrokerPublisherQueueDatabaseOperationFactory,
             (BrokerPublisherQueueDatabaseOperationFactory, AiopgBrokerQueueDatabaseOperationFactory),
@@ -22,6 +23,34 @@ def test_subclass(self):
     def test_build_table_name(self):
         self.assertEqual("broker_publisher_queue", self.factory.build_table_name())
 
+    def test_build_create_table(self):
+        operation = self.factory.build_create_table()
+        self.assertIsInstance(operation, AiopgDatabaseOperation)
+
+    def test_build_update_not_processed(self):
+        operation = self.factory.build_update_not_processed(id_=56)
+        self.assertIsInstance(operation, AiopgDatabaseOperation)
+
+    def test_build_delete_processed(self):
+        operation = self.factory.build_delete_processed(id_=56)
+        self.assertIsInstance(operation, AiopgDatabaseOperation)
+
+    def test_build_mark_processing(self):
+        operation = self.factory.build_mark_processing(ids={56, 78})
+        self.assertIsInstance(operation, AiopgDatabaseOperation)
+
+    def test_build_count_not_processed(self):
+        operation = self.factory.build_count_not_processed(retry=3)
+        self.assertIsInstance(operation, AiopgDatabaseOperation)
+
+    def test_build_insert(self):
+        operation = self.factory.build_insert(topic="foo", data=bytes())
+        self.assertIsInstance(operation, AiopgDatabaseOperation)
+
+    def test_build_select_not_processed(self):
+        operation = self.factory.build_select_not_processed(retry=3, records=1000)
+        self.assertIsInstance(operation, AiopgDatabaseOperation)
+
 
 if __name__ == "__main__":
     unittest.main()

packages/plugins/minos-database-aiopg/tests/test_aiopg/test_factories/test_networks/test_collections/__init__.py

@@ -1,17 +1,38 @@
 import unittest
 
+from minos.networks import (
+    BrokerSubscriberQueueDatabaseOperationFactory,
+)
 from minos.plugins.aiopg import (
+    AiopgBrokerQueueDatabaseOperationFactory,
     AiopgBrokerSubscriberQueueDatabaseOperationFactory,
+    AiopgDatabaseOperation,
 )
 
 
 class TestAiopgBrokerSubscriberQueueDatabaseOperationFactory(unittest.TestCase):
     def setUp(self) -> None:
         self.factory = AiopgBrokerSubscriberQueueDatabaseOperationFactory()
 
+    def test_is_subclass(self):
+        self.assertTrue(
+            issubclass(
+                AiopgBrokerSubscriberQueueDatabaseOperationFactory,
+                (BrokerSubscriberQueueDatabaseOperationFactory, AiopgBrokerQueueDatabaseOperationFactory),
+            )
+        )
+
     def test_build_table_name(self):
         self.assertEqual("broker_subscriber_queue", self.factory.build_table_name())
 
+    def test_build_count_not_processed(self):
+        operation = self.factory.build_count_not_processed(retry=3, topics={"foo", "bar"})
+        self.assertIsInstance(operation, AiopgDatabaseOperation)
+
+    def test_build_select_not_processed(self):
+        operation = self.factory.build_select_not_processed(retry=3, records=100, topics={"foo", "bar"})
+        self.assertIsInstance(operation, AiopgDatabaseOperation)
+
 
 if __name__ == "__main__":
     unittest.main()

packages/plugins/minos-database-aiopg/tests/test_aiopg/test_factories/test_networks/test_collections/test_queues.py

@@ -0,0 +1,46 @@
+import unittest
+from uuid import (
+    uuid4,
+)
+
+from minos.common import (
+    ComposedDatabaseOperation,
+)
+from minos.networks import (
+    BrokerSubscriberDuplicateValidatorDatabaseOperationFactory,
+)
+from minos.plugins.aiopg import (
+    AiopgBrokerSubscriberDuplicateValidatorDatabaseOperationFactory,
+    AiopgDatabaseOperation,
+)
+
+
+class TestAiopgBrokerSubscriberDuplicateValidatorDatabaseOperationFactory(unittest.TestCase):
+    def setUp(self) -> None:
+        self.factory = AiopgBrokerSubscriberDuplicateValidatorDatabaseOperationFactory()
+
+    def test_is_subclass(self):
+        self.assertTrue(
+            issubclass(
+                AiopgBrokerSubscriberDuplicateValidatorDatabaseOperationFactory,
+                BrokerSubscriberDuplicateValidatorDatabaseOperationFactory,
+            )
+        )
+
+    def test_build_table_name(self):
+        self.assertEqual("broker_subscriber_processed_messages", self.factory.build_table_name())
+
+    def test_build_create_table(self):
+        operation = self.factory.build_create_table()
+        self.assertIsInstance(operation, ComposedDatabaseOperation)
+        self.assertEqual(2, len(operation.operations))
+        for sub in operation.operations:
+            self.assertIsInstance(sub, AiopgDatabaseOperation)
+
+    def test_build_insert_row(self):
+        operation = self.factory.build_insert_row("foo", uuid4())
+        self.assertIsInstance(operation, AiopgDatabaseOperation)
+
+
+if __name__ == "__main__":
+    unittest.main()