#323 - update to minos-*@0.5

microservices/authentication/config.yml

@@ -4,8 +4,8 @@ service:
   injections:
     lock_pool: minos.common.PostgreSqlLockPool
     postgresql_pool: minos.common.PostgreSqlPool
-    broker_publisher: minos.networks.PostgreSqlQueuedKafkaBrokerPublisher
-    broker_subscriber_builder: minos.networks.PostgreSqlQueuedKafkaBrokerSubscriberBuilder
+    broker_publisher: minos.plugins.kafka.InMemoryQueuedKafkaBrokerPublisher
+    broker_subscriber_builder: minos.plugins.kafka.InMemoryQueuedKafkaBrokerSubscriberBuilder
     broker_pool: minos.networks.BrokerClientPool
     transaction_repository: minos.aggregate.PostgreSqlTransactionRepository
     event_repository: minos.aggregate.PostgreSqlEventRepository
@@ -55,6 +55,6 @@ saga:
   storage:
     path: "./auth.lmdb"
 discovery:
-  client: minos.networks.MinosDiscoveryClient
+  client: minos.plugins.minos_discovery.MinosDiscoveryClient
   host: localhost
   port: 5567

microservices/authentication/pyproject.toml

@@ -7,11 +7,13 @@ packages = [{ include = "src" }]
 
 [tool.poetry.dependencies]
 python = "^3.9"
-minos-microservice-common = "^0.4.0"
-minos-microservice-networks = "^0.4.0"
-minos-microservice-aggregate = "^0.4.0"
-minos-microservice-saga = "^0.4.0"
-minos-microservice-cqrs = "^0.4.0"
+minos-microservice-common = "^0.5.0"
+minos-microservice-networks = "^0.5.0"
+minos-microservice-aggregate = "^0.5.0"
+minos-microservice-saga = "^0.5.0"
+minos-microservice-cqrs = "^0.5.0"
+minos-broker-kafka = "^0.5.0"
+minos-discovery-minos = "^0.5.0"
 typer = "^0.3.2"
 PyJWT = "^2.1.0"
 SQLAlchemy = "1.4.22"

microservices/authentication/src/aggregates.py

@@ -3,23 +3,23 @@
 )
 
 from minos.aggregate import (
-    Aggregate,
-    AggregateRef,
     Condition,
-    ModelRef,
+    ExternalEntity,
+    Ref,
+    RootEntity,
 )
 
 
-class Credentials(Aggregate):
-    """Credentials Aggregate class.
+class Credentials(RootEntity):
+    """Credentials RootEntity class.
 
     The purpose of this aggregate is to store the needed information to be authenticated.
     """
 
     username: str
     password: str
     active: bool
-    user: ModelRef[Customer]
+    user: Ref[Customer]
 
     @classmethod
     async def exists_username(cls, username: str) -> bool:
@@ -35,5 +35,5 @@ async def exists_username(cls, username: str) -> bool:
             return False
 
 
-class Customer(AggregateRef):
-    """Customer Aggregate-Reference class."""
+class Customer(ExternalEntity):
+    """Customer ExternalEntity class."""

microservices/authentication/src/commands/services.py

@@ -75,7 +75,7 @@ async def delete_credentials(self, request: Request) -> None:
     async def user_deleted(self, request: Request) -> None:
         """Delete the associated credentials to the already deleted user.
 
-        :param request: A ``Request`` containing a ``AggregateDiff`` instance.
+        :param request: A ``Request`` containing a ``Event`` instance.
         :return: This method does not return anything.
         """
 

microservices/authentication/src/queries/services.py

@@ -10,7 +10,7 @@
     InvalidTokenError,
 )
 from minos.aggregate import (
-    AggregateDiff,
+    Event,
 )
 from minos.cqrs import (
     QueryService,
@@ -124,8 +124,8 @@ async def unique_username(self, request: Request) -> Response:
     async def credentials_created(self, request: Request) -> None:
         """Handle the ``CredentialsCreated`` domain event.
 
-        :param request: A ``Request`` instance containing the ``AggregateDiff``.
+        :param request: A ``Request`` instance containing the ``Event``.
         :return: This method does not return anything.
         """
-        diff: AggregateDiff = await request.content()
+        diff: Event = await request.content()
         await self.repository.create_credentials(diff.uuid, diff.username, diff.password, diff.active, diff.user)

microservices/cart/config.yml

@@ -4,8 +4,8 @@ service:
   injections:
     lock_pool: minos.common.PostgreSqlLockPool
     postgresql_pool: minos.common.PostgreSqlPool
-    broker_publisher: minos.networks.PostgreSqlQueuedKafkaBrokerPublisher
-    broker_subscriber_builder: minos.networks.PostgreSqlQueuedKafkaBrokerSubscriberBuilder
+    broker_publisher: minos.plugins.kafka.InMemoryQueuedKafkaBrokerPublisher
+    broker_subscriber_builder: minos.plugins.kafka.InMemoryQueuedKafkaBrokerSubscriberBuilder
     broker_pool: minos.networks.BrokerClientPool
     transaction_repository: minos.aggregate.PostgreSqlTransactionRepository
     event_repository: minos.aggregate.PostgreSqlEventRepository
@@ -55,6 +55,6 @@ saga:
   storage:
     path: "./cart.lmdb"
 discovery:
-  client: minos.networks.MinosDiscoveryClient
+  client: minos.plugins.minos_discovery.MinosDiscoveryClient
   host: localhost
   port: 5567