Fixed Handlers in doobie cqrs

hnaderi · Nov 14, 2023 · 80dbf9b · 80dbf9b
1 parent 930c502
commit 80dbf9b
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/modules/doobie/src/main/scala/DoobieCQRSRepository.scala b/modules/doobie/src/main/scala/DoobieCQRSRepository.scala
@@ -85,6 +85,8 @@ private final class DoobieCQRSRepository[F[_]: Concurrent: Clock, S, N](
         .fromFoldable(events.map((_, ctx.address, now, ctx.metadata)))
         .fold(FC.unit)(n => o.insertAll(n.toList).assertInserted(n.size))
 
+      _ <- NonEmptyChain.fromChain(events).fold(FC.unit)(handler)
+
       _ <- cmds.insert(ctx).run.assertInserted
 
     } yield ()