From 9ef529cf7750f8b1669538d54cc0b3b303733cc6 Mon Sep 17 00:00:00 2001 From: DongGeon0908 Date: Wed, 4 Sep 2024 22:05:42 +0900 Subject: [PATCH] =?UTF-8?q?fix:=20=EA=B7=B8=EB=A3=B9=20=EC=8A=A4=EC=BD=94?= =?UTF-8?q?=EC=96=B4=20=EA=B0=B1=EC=8B=A0=20=EC=A7=84=ED=96=89=EC=8B=9C,?= =?UTF-8?q?=20=EC=9B=B9=EC=86=8C=EC=BC=93=20=EB=A9=94=EC=84=B8=EC=A7=80=20?= =?UTF-8?q?=EB=B0=9C=EC=86=A1=20=EC=A7=84=ED=96=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../domain/group/application/GroupUserScoreService.kt | 4 ++++ 1 file changed, 4 insertions(+) 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 index caad4f2..5b17b7e 100644 --- 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 { return withContext(Dispatchers.IO) { @@ -78,6 +80,8 @@ class GroupUserScoreService( txTemplates.writer.coExecuteOrNull { saveSync(createOrUpdateGroupUserScore) } + + wsHandler.launchSendEvent(groupUser.groupId) } suspend fun findAllByUids(uids: List): List {