Saga Test

OrderPreparationSagaTest.kt

@Test
fun `should start food preparation saga on OrderQueuedEvent`() {
    val orderQueuedEvent = orderQueuedEvent()
    fixture
      .givenNoPriorActivity()
      .whenAggregate(ORDER_QUEUE_ID.toString()).publishes(orderQueuedEvent)
      .expectActiveSagas(1)
      .expectAssociationWith("cookId", COOK_ID)
      .expectDispatchedCommands(
        PrepareOrderCommand(
          cookId = COOK_ID,
          orderId = orderQueuedEvent.orderId,
          waiterId = orderQueuedEvent.waiterId,
          items = orderQueuedEvent.items
        )
      )
}