Order Processing - Choreography - Order Service

order_service.kt

class OrderService(private val availableSkus:MutableList<Int> = mutableListOf()) {
    fun submitOrder(order: Order) {
        sendMessage(
            ORDERS,
            order.withStatus(if (availableSkus.containsAll(order.items)) SUBMITTED else ITEMS_UNAVAILABLE)
        )
    }

    @KafkaListener(topics = [SKUS])
    fun onSku(sku: Sku) {
        if (sku.onStock > 0) availableSkus.add(sku.id) else availableSkus.remove(sku.id)
    }
}