Merge pull request #322 from minos-framework/0.0.5

0.0.5
minos-framework · Feb 1, 2022 · 9e3cdcc · 9e3cdcc
2 parents 473ae51 + 72c6c11
commit 9e3cdcc
Show file tree

Hide file tree

Showing 25 changed files with 3,777 additions and 4,304 deletions.
diff --git a/microservices/authentication/.dockerignore b/microservices/authentication/.dockerignore
@@ -0,0 +1,3 @@
+.venv
+*.lmdb
+dist/
diff --git a/microservices/authentication/config.yml b/microservices/authentication/config.yml
@@ -4,18 +4,16 @@ service:
   injections:
     lock_pool: minos.common.PostgreSqlLockPool
     postgresql_pool: minos.common.PostgreSqlPool
-    broker_publisher: minos.networks.BrokerPublisher
-    broker_consumer: minos.networks.BrokerConsumer
-    broker_pool: minos.networks.DynamicBrokerPool
+    broker_publisher: minos.networks.PostgreSqlQueuedKafkaBrokerPublisher
+    broker_subscriber_builder: minos.networks.PostgreSqlQueuedKafkaBrokerSubscriberBuilder
+    broker_pool: minos.networks.BrokerClientPool
     transaction_repository: minos.aggregate.PostgreSqlTransactionRepository
     event_repository: minos.aggregate.PostgreSqlEventRepository
     snapshot_repository: minos.aggregate.PostgreSqlSnapshotRepository
     saga_manager: minos.saga.SagaManager
     discovery: minos.networks.DiscoveryConnector
     credentials_repository: src.CredentialsQueryRepository
   services:
-    - minos.networks.BrokerProducerService
-    - minos.networks.BrokerConsumerService
     - minos.networks.BrokerHandlerService
     - minos.networks.RestService
     - minos.networks.PeriodicTaskSchedulerService

diff --git a/microservices/authentication/poetry.lock b/microservices/authentication/poetry.lock
diff --git a/microservices/authentication/pyproject.toml b/microservices/authentication/pyproject.toml
@@ -7,11 +7,11 @@ packages = [{ include = "src" }]
 
 [tool.poetry.dependencies]
 python = "^3.9"
-minos-microservice-common = "^0.3.2"
-minos-microservice-networks = "^0.3.2"
-minos-microservice-aggregate = "^0.2.2"
-minos-microservice-saga = "^0.3.5"
-minos-microservice-cqrs = "^0.2.1"
+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"
 typer = "^0.3.2"
 PyJWT = "^2.1.0"
 SQLAlchemy = "1.4.22"

diff --git a/microservices/cart/config.yml b/microservices/cart/config.yml
@@ -4,18 +4,16 @@ service:
   injections:
     lock_pool: minos.common.PostgreSqlLockPool
     postgresql_pool: minos.common.PostgreSqlPool
-    broker_publisher: minos.networks.BrokerPublisher
-    broker_consumer: minos.networks.BrokerConsumer
-    broker_pool: minos.networks.DynamicBrokerPool
+    broker_publisher: minos.networks.PostgreSqlQueuedKafkaBrokerPublisher
+    broker_subscriber_builder: minos.networks.PostgreSqlQueuedKafkaBrokerSubscriberBuilder
+    broker_pool: minos.networks.BrokerClientPool
     transaction_repository: minos.aggregate.PostgreSqlTransactionRepository
     event_repository: minos.aggregate.PostgreSqlEventRepository
     snapshot_repository: minos.aggregate.PostgreSqlSnapshotRepository
     saga_manager: minos.saga.SagaManager
     discovery: minos.networks.DiscoveryConnector
     cart_repository: src.CartQueryRepository
   services:
-    - minos.networks.BrokerProducerService
-    - minos.networks.BrokerConsumerService
     - minos.networks.BrokerHandlerService
     - minos.networks.RestService
     - minos.networks.PeriodicTaskSchedulerService

diff --git a/microservices/cart/poetry.lock b/microservices/cart/poetry.lock
diff --git a/microservices/cart/pyproject.toml b/microservices/cart/pyproject.toml
@@ -7,11 +7,11 @@ packages = [{ include = "src" }]
 
 [tool.poetry.dependencies]
 python = "^3.9"
-minos-microservice-common = "^0.3.2"
-minos-microservice-networks = "^0.3.2"
-minos-microservice-aggregate = "^0.2.2"
-minos-microservice-saga = "^0.3.5"
-minos-microservice-cqrs = "^0.2.1"
+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"
 typer = "^0.3.2"
 SQLAlchemy = "1.4.22"
 

diff --git a/microservices/customer/config.yml b/microservices/customer/config.yml
@@ -4,17 +4,15 @@ service:
   injections:
     lock_pool: minos.common.PostgreSqlLockPool
     postgresql_pool: minos.common.PostgreSqlPool
-    broker_publisher: minos.networks.BrokerPublisher
-    broker_consumer: minos.networks.BrokerConsumer
-    broker_pool: minos.networks.DynamicBrokerPool
+    broker_publisher: minos.networks.PostgreSqlQueuedKafkaBrokerPublisher
+    broker_subscriber_builder: minos.networks.PostgreSqlQueuedKafkaBrokerSubscriberBuilder
+    broker_pool: minos.networks.BrokerClientPool
     transaction_repository: minos.aggregate.PostgreSqlTransactionRepository
     event_repository: minos.aggregate.PostgreSqlEventRepository
     snapshot_repository: minos.aggregate.PostgreSqlSnapshotRepository
     saga_manager: minos.saga.SagaManager
     discovery: minos.networks.DiscoveryConnector
   services:
-    - minos.networks.BrokerProducerService
-    - minos.networks.BrokerConsumerService
     - minos.networks.BrokerHandlerService
     - minos.networks.RestService
     - minos.networks.PeriodicTaskSchedulerService
-Original file line number
+Diff line change
@@ -0,0 +1,3 @@
+    .venv
+    *.lmdb
+    dist/