fix: 그룹 스코어 갱신 진행시, 웹소켓 메세지 발송 진행

DDD-Community · Sep 4, 2024 · 9ef529c · 9ef529c
1 parent f34e144
commit 9ef529c
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/main/kotlin/com/hero/alignlab/domain/group/application/GroupUserScoreService.kt b/src/main/kotlin/com/hero/alignlab/domain/group/application/GroupUserScoreService.kt
@@ -5,6 +5,7 @@ import com.hero.alignlab.config.database.TransactionTemplates
 import com.hero.alignlab.domain.group.domain.GroupUser
 import com.hero.alignlab.domain.group.domain.GroupUserScore
 import com.hero.alignlab.domain.group.infrastructure.GroupUserScoreRepository
+import com.hero.alignlab.ws.handler.ReactiveGroupUserWebSocketHandler
 import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.withContext
 import org.springframework.stereotype.Service
@@ -14,6 +15,7 @@ import org.springframework.transaction.annotation.Transactional
 class GroupUserScoreService(
     private val groupUserScoreRepository: GroupUserScoreRepository,
     private val txTemplates: TransactionTemplates,
+    private val wsHandler: ReactiveGroupUserWebSocketHandler,
 ) {
     suspend fun findAllByGroupId(groupId: Long): List<GroupUserScore> {
         return withContext(Dispatchers.IO) {
@@ -78,6 +80,8 @@ class GroupUserScoreService(
         txTemplates.writer.coExecuteOrNull {
             saveSync(createOrUpdateGroupUserScore)
         }
+
+        wsHandler.launchSendEvent(groupUser.groupId)
     }
 
     suspend fun findAllByUids(uids: List<Long>): List<GroupUserScore> {