Merge pull request #281 from Clariteia/issue-280-update-minos-common

#280 - update minos common

Author: Sergio García Prado

microservices/authentication/config.yml

@@ -57,5 +57,6 @@ saga:
   storage:
     path: "./auth.lmdb"
 discovery:
+  client: minos.networks.MinosDiscoveryClient
   host: localhost
   port: 5567

microservices/authentication/poetry.lock

@@ -7,10 +7,10 @@ packages = [{ include = "src" }]
 
 [tool.poetry.dependencies]
 python = "^3.9"
-minos-microservice-common = "^0.1.12"
-minos-microservice-networks = ">=0.0.15<0.1"
+minos-microservice-common = "^0.1.13"
+minos-microservice-networks = ">=0.0.16<0.1"
 minos-microservice-saga = ">=0.0.11<0.1"
-minos-microservice-cqrs = ">=0.0.2<0.1"
+minos-microservice-cqrs = ">=0.0.3<0.1"
 typer = "^0.3.2"
 PyJWT = "^2.1.0"
 SQLAlchemy = "1.4.22"

microservices/authentication/pyproject.toml

@@ -57,5 +57,6 @@ saga:
   storage:
     path: "./cart.lmdb"
 discovery:
+  client: minos.networks.MinosDiscoveryClient
   host: localhost
   port: 5567

microservices/cart/config.yml

@@ -8,10 +8,10 @@ packages = [{ include = "src" }]
 [tool.poetry.dependencies]
 python = "^3.9"
 typer = "^0.3.2"
-minos-microservice-common = "^0.1.12"
-minos-microservice-networks = ">=0.0.15<0.1"
+minos-microservice-common = "^0.1.13"
+minos-microservice-networks = ">=0.0.16<0.1"
 minos-microservice-saga = ">=0.0.11<0.1"
-minos-microservice-cqrs = ">=0.0.2<0.1"
+minos-microservice-cqrs = ">=0.0.3<0.1"
 SQLAlchemy = "1.4.22"
 
 [tool.poetry.dev-dependencies]

microservices/cart/poetry.lock

@@ -24,7 +24,7 @@ async def _create_cart_item(context: SagaContext) -> SagaContext:
     cart_id = context["cart_id"]
     product_uuid = context["product_uuid"]
     quantity = context["quantity"]
-    cart = await Cart.get_one(cart_id)
+    cart = await Cart.get(cart_id)
     cart_item = CartEntry(product=product_uuid, quantity=quantity)
     cart.entries.add(cart_item)
     await cart.save()

microservices/cart/pyproject.toml

@@ -28,7 +28,7 @@ async def _reserve_products(context: SagaContext) -> Model:
     product_uuids = [context["product_uuid"]]
     cart_id = context["cart_id"]
     quantities = defaultdict(int)
-    cart = await Cart.get_one(cart_id)
+    cart = await Cart.get(cart_id)
     for product_id in product_uuids:
         quantities[str(product_id)] += get_product_quantity(cart, product_id)
 
@@ -39,7 +39,7 @@ async def _release_products(context: SagaContext) -> Model:
     product_uuids = [context["product_uuid"]]
     cart_id = context["cart_id"]
     quantities = defaultdict(int)
-    cart = await Cart.get_one(cart_id)
+    cart = await Cart.get(cart_id)
     for product_id in product_uuids:
         quantities[str(product_id)] -= get_product_quantity(cart, product_id)
 
@@ -49,7 +49,7 @@ async def _release_products(context: SagaContext) -> Model:
 async def _remove_cart_item(context: SagaContext) -> SagaContext:
     cart_id = context["cart_id"]
     product = context["product"]
-    cart = await Cart.get_one(cart_id)
+    cart = await Cart.get(cart_id)
     cart.entries.discard(product)
 
     await cart.save()

microservices/cart/src/commands/sagas/add_cart_item.py

@@ -31,7 +31,7 @@ async def _release_or_reserve_products(context: SagaContext) -> Model:
     quantity = context["quantity"]
 
     for product_id in product_uuids:
-        prev = await Cart.get_one(cart_id)
+        prev = await Cart.get(cart_id)
 
         prev_quantity = 0
         for key, value in prev.entries.data.items():
@@ -58,7 +58,7 @@ async def _compensation(context: SagaContext) -> Model:
     quantity = context["quantity"]
 
     for product_id in product_uuids:
-        prev = await Cart.get_one(cart_id)
+        prev = await Cart.get(cart_id)
 
         prev_quantity = 0
         for key, value in prev.entries.data.items():
@@ -82,7 +82,7 @@ async def _update_cart_item(context: SagaContext) -> SagaContext:
     cart_id = context["cart_id"]
     product_uuid = context["product_uuid"]
     quantity = context["quantity"]
-    cart = await Cart.get_one(cart_id)
+    cart = await Cart.get(cart_id)
 
     for key, value in cart.entries.data.items():
         if str(value.product) == product_uuid:

microservices/cart/src/commands/sagas/remove_cart_item.py

@@ -112,15 +112,15 @@ async def delete_cart(self, request: Request) -> Response:
         content = await request.content()
 
         cart_id = content["uuid"]
-        cart = await Cart.get_one(cart_id)
+        cart = await Cart.get(cart_id)
 
         saga_execution = await self.saga_manager.run(DELETE_CART, context=SagaContext(cart=cart))
 
         return Response(saga_execution.uuid)
 
     @staticmethod
     async def _get_cart_item(cart_id: UUID, product_uuid: UUID):
-        cart = await Cart.get_one(cart_id)
+        cart = await Cart.get(cart_id)
         for idx, product in enumerate(cart.entries):
             if str(product.product) == product_uuid:
                 return idx, product