Skip to content

Commit da3e1bf

Browse files
committed
fix: group poc
1 parent 61377cb commit da3e1bf

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

src/main/kotlin/com/hero/alignlab/ws/handler/ReactiveConcurrentUserWebSocketHandler.kt

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,8 @@ class ReactiveConcurrentUserWebSocketHandler(
4040
private val concurrentUserByMap: ConcurrentMap<Long, ConcurrentMap<Long, WebSocketSession>> = ConcurrentHashMap()
4141

4242
override fun handle(session: WebSocketSession): Mono<Void> {
43+
println(">> 접속함")
44+
4345
val groupId = session.handshakeInfo.uri.path
4446
.split("/")
4547
.lastOrNull { it.matches(Regex("\\d+")) }
@@ -57,6 +59,8 @@ class ReactiveConcurrentUserWebSocketHandler(
5759

5860
val user = authFacade.resolveAuthUser(authUserToken)
5961

62+
println("concurrent user : ${user.uid}")
63+
6064
val groupUsers = groupUserService.findAllByUidSync(user.uid)
6165

6266
groupUsers.forEach { groupUser ->
@@ -67,6 +71,7 @@ class ReactiveConcurrentUserWebSocketHandler(
6771
concurrentUserByMap[groupUser.groupId] = cuser
6872
}
6973

74+
7075
logger.info { "concurrent user ${user.uid}" }
7176

7277
concurrentUserByMap.forEach { (groupId, uidBySession) ->

0 commit comments

Comments
 (0)