fix : add log on matching service

Author: s0o0bn

matching-service/matching-application/app-api/src/main/kotlin/com/grepp/quizy/matching/api/sse/SseSender.kt

@@ -5,6 +5,7 @@ import com.grepp.quizy.matching.domain.match.MatchingEventSender
 import com.grepp.quizy.matching.domain.match.MatchingPoolManager
 import com.grepp.quizy.matching.domain.match.PersonalMatchingSucceedEvent
 import com.grepp.quizy.matching.domain.user.UserId
+import io.github.oshai.kotlinlogging.KotlinLogging
 import org.springframework.stereotype.Component
 import org.springframework.web.servlet.mvc.method.annotation.SseEmitter
 import java.io.IOException
@@ -16,6 +17,8 @@ class SseSender(
     private val objectMapper: ObjectMapper
 ) : MatchingEventSender {
 
+    private val log = KotlinLogging.logger {}
+
     override fun send(event: PersonalMatchingSucceedEvent) {
         val emitter = emitterRepository.findById(event.userId) ?: return
 
@@ -26,11 +29,12 @@ class SseSender(
                     .name("MATCHING")
                     .data(objectMapper.writeValueAsString(MatchingSucceed(event.gameRoomId)))
             )
-            emitter.complete()
+            log.info { "SSE event sent to ${event.userId}" }
             closeEmitter(event.userId)
+            emitter.complete()
         } catch (e: IOException) {
             closeEmitter(event.userId)
-            emitter.completeWithError(e)
+            emitter.complete()
         }
     }
 

matching-service/matching-infra/src/main/kotlin/com/grepp/quizy/matching/infra/match/pubsub/MatchingRedisSubscriber.kt

@@ -3,6 +3,7 @@ package com.grepp.quizy.matching.infra.match.pubsub
 import com.fasterxml.jackson.databind.ObjectMapper
 import com.grepp.quizy.matching.domain.match.MatchingEventSender
 import com.grepp.quizy.matching.domain.match.PersonalMatchingSucceedEvent
+import io.github.oshai.kotlinlogging.KotlinLogging
 import org.springframework.data.redis.connection.Message
 import org.springframework.data.redis.connection.MessageListener
 import org.springframework.stereotype.Component
@@ -13,15 +14,19 @@ class MatchingRedisSubscriber(
     private val objectMapper: ObjectMapper,
 ) : MessageListener {
 
+    private val log = KotlinLogging.logger {}
+
     override fun onMessage(message: Message, pattern: ByteArray?) {
         try {
             val event = objectMapper.readValue(
                 message.body,
                 PersonalMatchingSucceedEvent::class.java
             )
 
+            log.info { "Matching succeeded event: $event" }
             matchingEventSender.send(event)
         } catch (e: Exception) {
+            log.error(e) { "Matching failed" }
             throw IllegalArgumentException("Failed to send event to Redis", e.cause)
         }
     }