SagaSpec
Abstract base class for writing stateless saga specification tests using JUnit 5.
This class provides a DSL-based framework for testing stateless sagas by defining scenarios with events and expected command outcomes. It uses JUnit 5's @TestFactory to generate dynamic tests from the specification.
The primary purpose is to facilitate behavior-driven testing of sagas, allowing developers to specify expected command emissions in response to domain events. It enables testing saga logic in isolation without requiring full infrastructure setup.
Example usage:
class CartSagaSpec : SagaSpec<CartSaga>({
on {
val ownerId = generateGlobalId()
val orderItem = OrderItem(
id = generateGlobalId(),
productId = generateGlobalId(),
price = BigDecimal.valueOf(10),
quantity = 10,
)
whenEvent(
event = mockk<OrderCreated> {
every { items } returns listOf(orderItem)
every { fromCart } returns true
},
ownerId = ownerId
) {
expectCommandType(RemoveCartItem::class)
expectCommand<RemoveCartItem> {
aggregateId.id.assert().isEqualTo(ownerId)
body.productIds.assert().hasSize(1)
body.productIds.assert().first().isEqualTo(orderItem.productId)
}
}
}
})Parameters
The test specification block that defines the saga test scenarios. This is a lambda with receiver of type StatelessSagaDsl
Type Parameters
The type of the saga being tested, must be a class that implements the saga logic.