* Rename BrokerHandlerPort as BrokerPort.

* Rename `PeriodicTaskSchedulerPort` as `PeriodicPort`.

Author: Sergio García Prado

README.md

@@ -176,7 +176,7 @@ databases:
     path: "./foo.lmdb"
 interfaces:
   broker:
-    port: minos.networks.BrokerHandlerPort
+    port: minos.networks.BrokerPort
     publisher:
       client: minos.plugins.kafka.KafkaBrokerPublisher
       queue: minos.networks.PostgreSqlBrokerPublisherQueue
@@ -190,7 +190,7 @@ interfaces:
       client: minos.plugins.aiohttp.AioHttpConnector
       port: 4545
   periodic:
-    port: minos.networks.PeriodicTaskSchedulerPort
+    port: minos.networks.PeriodicPort
 pools:
   lock: minos.common.PostgreSqlLockPool
   databasse: minos.common.PostgreSqlPool
@@ -992,7 +992,7 @@ databases:
     path: "./foobar.lmdb"
 interfaces:
   broker:
-    port: minos.networks.BrokerHandlerPort
+    port: minos.networks.BrokerPort
     publisher:
       client: minos.plugins.kafka.KafkaBrokerPublisher
       queue: minos.networks.PostgreSqlBrokerPublisherQueue
@@ -1006,7 +1006,7 @@ interfaces:
       client: minos.plugins.aiohttp.AioHttpConnector
       port: 4546
   periodic:
-    port: minos.networks.PeriodicTaskSchedulerPort
+    port: minos.networks.PeriodicPort
 pools:
   lock: minos.common.PostgreSqlLockPool
   databasse: minos.common.PostgreSqlPool

packages/core/minos-microservice-networks/minos/networks/__init__.py

@@ -9,7 +9,7 @@
     BrokerClientPool,
     BrokerDispatcher,
     BrokerHandler,
-    BrokerHandlerPort,
+    BrokerPort,
     BrokerHandlerService,
     BrokerMessage,
     BrokerMessageV1,
@@ -123,7 +123,7 @@
     CronTab,
     PeriodicTask,
     PeriodicTaskScheduler,
-    PeriodicTaskSchedulerPort,
+    PeriodicPort,
     PeriodicTaskSchedulerService,
     ScheduledRequest,
     ScheduledRequestContent,

packages/core/minos-microservice-networks/minos/networks/brokers/__init__.py

@@ -15,7 +15,7 @@
 )
 from .handlers import (
     BrokerHandler,
-    BrokerHandlerPort,
+    BrokerPort,
     BrokerHandlerService,
 )
 from .messages import (

packages/core/minos-microservice-networks/minos/networks/brokers/handlers/__init__.py

@@ -2,6 +2,6 @@
     BrokerHandler,
 )
 from .ports import (
-    BrokerHandlerPort,
+    BrokerPort,
     BrokerHandlerService,
 )

packages/core/minos-microservice-networks/minos/networks/brokers/handlers/ports.py

@@ -16,8 +16,8 @@
 logger = logging.getLogger(__name__)
 
 
-class BrokerHandlerPort(Port):
-    """Broker Handler Service class."""
+class BrokerPort(Port):
+    """Broker Port class."""
 
     def __init__(self, **kwargs):
         super().__init__(**kwargs)
@@ -45,11 +45,11 @@ def handler(self) -> BrokerHandler:
         return BrokerHandler.from_config(**self._init_kwargs)
 
 
-class BrokerHandlerService(BrokerHandlerPort):
+class BrokerHandlerService(BrokerPort):
     """Broker Handler Service class."""
 
     def __init__(self, **kwargs):
         warnings.warn(
-            f"{BrokerHandlerService!r} has been deprecated. Use {BrokerHandlerPort} instead.", DeprecationWarning
+            f"{BrokerHandlerService!r} has been deprecated. Use {BrokerPort} instead.", DeprecationWarning
         )
         super().__init__(**kwargs)

packages/core/minos-microservice-networks/minos/networks/scheduling/__init__.py

@@ -2,7 +2,7 @@
     CronTab,
 )
 from .ports import (
-    PeriodicTaskSchedulerPort,
+    PeriodicPort,
     PeriodicTaskSchedulerService,
 )
 from .requests import (

packages/core/minos-microservice-networks/minos/networks/scheduling/ports.py

@@ -16,8 +16,8 @@
 logger = logging.getLogger(__name__)
 
 
-class PeriodicTaskSchedulerPort(Port):
-    """Task Scheduler Service class."""
+class PeriodicPort(Port):
+    """Periodic Port class."""
 
     def __init__(self, **kwargs):
         super().__init__(**kwargs)
@@ -46,12 +46,12 @@ def scheduler(self) -> PeriodicTaskScheduler:
         return PeriodicTaskScheduler.from_config(**self._init_kwargs)
 
 
-class PeriodicTaskSchedulerService(PeriodicTaskSchedulerPort):
+class PeriodicTaskSchedulerService(PeriodicPort):
     """Periodic Task Scheduler Service class."""
 
     def __init__(self, **kwargs):
         warnings.warn(
-            f"{PeriodicTaskSchedulerService!r} has been deprecated. Use {PeriodicTaskSchedulerPort} instead.",
+            f"{PeriodicTaskSchedulerService!r} has been deprecated. Use {PeriodicPort} instead.",
             DeprecationWarning,
         )
         super().__init__(**kwargs)

packages/core/minos-microservice-networks/tests/test_config.yml

@@ -3,8 +3,8 @@ service:
     aggregate: tests.utils.Order
     services:
       - minos.networks.HttpPort
-      - minos.networks.BrokerHandlerPort
-      - minos.networks.PeriodicTaskSchedulerPort
+      - minos.networks.BrokerPort
+      - minos.networks.PeriodicPort
 routers:
     - minos.networks.BrokerRouter
     - minos.networks.PeriodicRouter

packages/core/minos-microservice-networks/tests/test_networks/test_brokers/test_handlers/test_ports.py

@@ -12,7 +12,7 @@
 )
 from minos.networks import (
     BrokerHandler,
-    BrokerHandlerPort,
+    BrokerPort,
     BrokerHandlerService,
     InMemoryBrokerPublisher,
     InMemoryBrokerSubscriberBuilder,
@@ -22,7 +22,7 @@
 )
 
 
-class TestBrokerHandlerPort(PostgresAsyncTestCase):
+class TestBrokerPort(PostgresAsyncTestCase):
     CONFIG_FILE_PATH = CONFIG_FILE_PATH
 
     def setUp(self) -> None:
@@ -31,17 +31,17 @@ def setUp(self) -> None:
         self.subscriber_builder = InMemoryBrokerSubscriberBuilder()
 
     def test_is_instance(self):
-        service = BrokerHandlerPort(config=self.config, publisher=self.publisher)
+        service = BrokerPort(config=self.config, publisher=self.publisher)
         self.assertIsInstance(service, Port)
 
     def test_handler(self):
-        service = BrokerHandlerPort(
+        service = BrokerPort(
             config=self.config, publisher=self.publisher, subscriber_builder=self.subscriber_builder
         )
         self.assertIsInstance(service.handler, BrokerHandler)
 
     async def test_start_stop(self):
-        service = BrokerHandlerPort(
+        service = BrokerPort(
             config=self.config, publisher=self.publisher, subscriber_builder=self.subscriber_builder
         )
 
@@ -72,13 +72,13 @@ async def test_start_stop(self):
 
 class TestBrokerHandlerService(unittest.TestCase):
     def test_is_subclass(self):
-        self.assertTrue(issubclass(BrokerHandlerService, BrokerHandlerPort))
+        self.assertTrue(issubclass(BrokerHandlerService, BrokerPort))
 
     def test_warnings(self):
         with warnings.catch_warnings():
             warnings.simplefilter("ignore", DeprecationWarning)
             port = BrokerHandlerService(config=CONFIG_FILE_PATH)
-            self.assertIsInstance(port, BrokerHandlerPort)
+            self.assertIsInstance(port, BrokerPort)
 
 
 if __name__ == "__main__":

packages/core/minos-microservice-networks/tests/test_networks/test_scheduling/test_ports.py

@@ -12,27 +12,27 @@
 )
 from minos.networks import (
     PeriodicTaskScheduler,
-    PeriodicTaskSchedulerPort,
+    PeriodicPort,
     PeriodicTaskSchedulerService,
 )
 from tests.utils import (
     CONFIG_FILE_PATH,
 )
 
 
-class TestPeriodicTaskSchedulerPort(PostgresAsyncTestCase):
+class TestPeriodicPort(PostgresAsyncTestCase):
     CONFIG_FILE_PATH = CONFIG_FILE_PATH
 
     def test_is_instance(self):
-        service = PeriodicTaskSchedulerPort(config=self.config)
+        service = PeriodicPort(config=self.config)
         self.assertIsInstance(service, Port)
 
     def test_dispatcher(self):
-        service = PeriodicTaskSchedulerPort(config=self.config)
+        service = PeriodicPort(config=self.config)
         self.assertIsInstance(service.scheduler, PeriodicTaskScheduler)
 
     async def test_start_stop(self):
-        service = PeriodicTaskSchedulerPort(config=self.config)
+        service = PeriodicPort(config=self.config)
 
         setup_mock = AsyncMock()
         destroy_mock = AsyncMock()
@@ -66,13 +66,13 @@ async def test_start_stop(self):
 
 class TestPeriodicTaskSchedulerService(unittest.TestCase):
     def test_is_subclass(self):
-        self.assertTrue(issubclass(PeriodicTaskSchedulerService, PeriodicTaskSchedulerPort))
+        self.assertTrue(issubclass(PeriodicTaskSchedulerService, PeriodicPort))
 
     def test_warnings(self):
         with warnings.catch_warnings():
             warnings.simplefilter("ignore", DeprecationWarning)
             port = PeriodicTaskSchedulerService(config=CONFIG_FILE_PATH)
-            self.assertIsInstance(port, PeriodicTaskSchedulerPort)
+            self.assertIsInstance(port, PeriodicPort)
 
 
 if __name__ == "__main__":