feat: add product palletized event to client orders bc

atedeg · Aug 11, 2022 · 4b8474c · 4b8474c
1 parent 24897a3
commit 4b8474c
Show file tree

Hide file tree

Showing 3 changed files with 16 additions and 2 deletions.
diff --git a/client-orders/src/main/scala/dev/atedeg/mdm/clientorders/Actions.scala b/client-orders/src/main/scala/dev/atedeg/mdm/clientorders/Actions.scala
@@ -10,7 +10,7 @@ import cats.syntax.all.*
 
 import dev.atedeg.mdm.clientorders.InProgressOrderLine.*
 import dev.atedeg.mdm.clientorders.OrderCompletionError.*
-import dev.atedeg.mdm.clientorders.OutgoingEvent.OrderProcessed
+import dev.atedeg.mdm.clientorders.OutgoingEvent.{ OrderProcessed, ProductPalletized }
 import dev.atedeg.mdm.clientorders.PalletizationError.*
 import dev.atedeg.mdm.clientorders.utils.*
 import dev.atedeg.mdm.clientorders.utils.QuantityOps.*
@@ -60,7 +60,10 @@ def startPreparingOrder(pricedOrder: PricedOrder): InProgressOrder =
  * where the corresponding [[Order.InProgressOrderLine line]] has been updated with the
  * [[Order.Quantity specified quantity]].
  */
-def palletizeProductForOrder[M[_]: CanRaise[PalletizationError]: Monad](quantity: Quantity, product: Product)(
+def palletizeProductForOrder[M[_]: CanRaise[PalletizationError]: Monad: Emits[ProductPalletized]](
+    quantity: Quantity,
+    product: Product,
+)(
     inProgressOrder: InProgressOrder,
 ): M[InProgressOrder] =
   val InProgressOrder(id, ol, customer, dd, dl, totalPrice) = inProgressOrder
@@ -71,6 +74,7 @@ def palletizeProductForOrder[M[_]: CanRaise[PalletizationError]: Monad](quantity
       case Incomplete(_, _, `product`, _) => updatedLine
       case l @ _ => l
     }
+    _ <- emit(ProductPalletized(product, quantity): ProductPalletized)
   yield InProgressOrder(id, newOrderLines, customer, dd, dl, totalPrice)
 
 private def hasProduct(product: Product)(ol: InProgressOrderLine): Boolean = ol match

diff --git a/client-orders/src/main/scala/dev/atedeg/mdm/clientorders/Events.scala b/client-orders/src/main/scala/dev/atedeg/mdm/clientorders/Events.scala
@@ -42,3 +42,8 @@ enum OutgoingEvent:
    * An event emitted when a new [[IncomingOrder incoming order]] is received and processed.
    */
   case OrderProcessed(incomingOrder: IncomingOrder)
+
+  /**
+   * An event emitted when a [[Product product]] is successfully palletized for an [[Order.InProgressoOrder order]].
+   */
+  case ProductPalletized(product: Product, quantity: Quantity)
diff --git a/client-orders/src/main/scala/dev/atedeg/mdm/clientorders/dto/DTOs.scala b/client-orders/src/main/scala/dev/atedeg/mdm/clientorders/dto/DTOs.scala
@@ -55,3 +55,8 @@ final case class IncomingOrderDTO(
 object OrderProcessedDTO:
   given DTO[OrderProcessed, OrderProcessedDTO] = interCaseClassDTO
   private given DTO[IncomingOrder, IncomingOrderDTO] = interCaseClassDTO
+
+final case class ProductPalletizedDTO(product: ProductDTO, quantity: Int)
+object ProductPalletizedDTO:
+  given DTO[ProductPalletized, ProductPalletizedDTO] = interCaseClassDTO
+  private given DTO[Quantity, Int] = caseClassDTO