NowChess/NowChessSystems
4
0
Fork 0
Code Issues Pull Requests 2 Packages Projects Releases Wiki Activity

fix: NCS-122 authenticate WebSocket connections via first-message auth #73

Merged
Janis merged 2 commits from fix/NCS-122-ws-token-auth into main 2026-06-17 10:42:54 +02:00
Conversation 0 Commits 2 Files Changed 2
+3 -3
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit e8ff9cd6e6 - Show all commits
modules/ws/src/main/scala/de/nowchess/ws/resource/GameWebSocketResource.scala
+3 -3
View File
@@ -66,9 +66,9 @@ class GameWebSocketResource:
@OnOpen
def onOpen(connection: WebSocketConnection): Unit =
activeGauge
val gameId = connection.pathParam("gameId")
val handler: Consumer[String] = msg => connection.sendText(msg).subscribe().`with`(_ => (), _ => ())
val subscriber = redis.pubsub(classOf[String]).subscribe(s2cTopic(gameId), handler)
val gameId = connection.pathParam("gameId")
val handler: Consumer[String] = msg => connection.sendText(msg).subscribe().`with`(_ => (), _ => ())
val subscriber = redis.pubsub(classOf[String]).subscribe(s2cTopic(gameId), handler)
connections.put(connection.id(), ConnectionMeta(gameId, subscriber, None))
connectionsOpened.increment()
pendingAuth.add(connection.id())