diff --git a/src/main/kotlin/com/android/trisolarisserver/controller/RazorpayWebhookCapture.kt b/src/main/kotlin/com/android/trisolarisserver/controller/RazorpayWebhookCapture.kt index 7246854..be10cf0 100644 --- a/src/main/kotlin/com/android/trisolarisserver/controller/RazorpayWebhookCapture.kt +++ b/src/main/kotlin/com/android/trisolarisserver/controller/RazorpayWebhookCapture.kt @@ -6,6 +6,7 @@ import com.android.trisolarisserver.models.booking.PaymentMethod import com.android.trisolarisserver.models.payment.RazorpayPaymentAttempt import com.android.trisolarisserver.models.payment.RazorpayWebhookLog import com.android.trisolarisserver.component.RazorpayQrEvents +import com.android.trisolarisserver.component.BookingEvents import com.android.trisolarisserver.controller.dto.RazorpayQrEventResponse import com.android.trisolarisserver.repo.PaymentRepo import com.android.trisolarisserver.repo.PropertyRepo @@ -40,6 +41,7 @@ class RazorpayWebhookCapture( private val razorpayQrRequestRepo: RazorpayQrRequestRepo, private val razorpayWebhookLogRepo: RazorpayWebhookLogRepo, private val razorpayQrEvents: RazorpayQrEvents, + private val bookingEvents: BookingEvents, private val objectMapper: ObjectMapper ) { @@ -153,6 +155,19 @@ class RazorpayWebhookCapture( receivedAt = OffsetDateTime.now() ) ) + bookingEvents.emit(propertyId, booking.id!!) + if (qrId != null) { + razorpayQrEvents.emit( + propertyId, + qrId, + RazorpayQrEventResponse( + event = event, + qrId = qrId, + status = qrStatus, + receivedAt = OffsetDateTime.now().toString() + ) + ) + } } private fun verifySignature(payload: String, secret: String, signature: String): Boolean {