fix(ncs-122): authenticate WebSocket connections via first-message auth

Replace header-based auth (not possible with browser WebSocket API) with a
first-message auth protocol: client sends {"type":"auth","token":"<JWT>"}
as the first text frame; server validates and proceeds or closes the connection.

Both GameWebSocketResource and UserWebSocketResource now hold incoming
connections in a pendingAuth set until the auth frame arrives, preventing
any game or event messages from being processed before identity is established.

Also removes the broken Bearer-prefix handling that caused header-based auth
to silently fail even for non-browser clients.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

modules/analytics/CHANGELOG.md

@@ -10,16 +10,3 @@
 ### Bug Fixes
 
 * **analytics:** upgrade Spark to 4.0.3 — 3.5.x has no official Docker image ([46af115](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/46af1154de34a8596cb6cb28c6fad7aba90f597c))
-##  (2026-06-19)
-
-### Features
-
-* **analytics:** add Dockerfile, CI workflow, and stable jar name for K8s deployment ([95215b6](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/95215b6a420fd526df1aa395f9b087556c8ad03b))
-* **analytics:** add PostgreSQL JDBC write-back to all four batch jobs ([0e0ea4c](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/0e0ea4c9893c6efed52e633e55d05ab3ed004502))
-* **analytics:** add Spark batch analytics module ([259b3bb](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/259b3bbb24c0f23326269b93f4b3c84012f727cd))
-* **analytics:** add Structured Streaming, MLlib clustering, GraphX jobs ([e1d80b9](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/e1d80b9331666feea191b1fd08aa762f3581c918))
-* **official-bots:** park expert bot on tournament server at startup ([#76](https://git.janis-eccarius.de/NowChess/NowChessSystems/issues/76)) ([751a58b](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/751a58b6061f7434115e229a7661894c76768bc2))
-
-### Bug Fixes
-
-* **analytics:** upgrade Spark to 4.0.3 — 3.5.x has no official Docker image ([46af115](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/46af1154de34a8596cb6cb28c6fad7aba90f597c))

modules/analytics/build.gradle.kts

@@ -22,9 +22,6 @@
 //   NOWCHESS_JDBC_URL  (default: jdbc:postgresql://localhost:5432/nowchess)
 //   NOWCHESS_DB_USER   (default: nowchess)
 //   NOWCHESS_DB_PASS   (default: nowchess)
-//   NOWCHESS_PGN_PATH  (optional) — file or http(s) URL of a Lichess PGN dump (.pgn or .pgn.zst).
-//                      When set, all batch jobs read games from the dump instead of PostgreSQL and
-//                      skip JDBC write-back (Parquet/CSV output only). Demo data source.
 
 plugins {
     id("scala")
@@ -74,10 +71,6 @@ dependencies {
 
     // PostgreSQL JDBC driver bundled so it is available on executor classpath.
     implementation("org.postgresql:postgresql:42.7.4")
-
-    // zstd-jni: decompress Lichess .pgn.zst dumps in-process. Provided at runtime by Spark
-    // (it uses zstd-jni internally for shuffle/event-log compression), so compile-only here.
-    compileOnly("com.github.luben:zstd-jni:1.5.6-9")
 }
 
 application {

modules/analytics/src/main/scala/de/nowchess/analytics/GameSource.scala

@@ -1,119 +0,0 @@
-package de.nowchess.analytics
-
-import org.apache.spark.SparkFiles
-import org.apache.spark.sql.DataFrame
-import org.apache.spark.sql.SparkSession
-import org.apache.spark.sql.functions as F
-
-/** Normalised game-record source for the batch jobs.
-  *
-  * Every batch job consumes the same five-column shape:
-  *   - white_id, black_id : player identifiers
-  *   - result             : one of "white", "black", "draw"
-  *   - move_count         : number of plies
-  *   - pgn                : full PGN ("[Event …]…\n\n1. e4 …"), header and movetext separated by a blank line
-  *
-  * Two backends, selected by the `NOWCHESS_PGN_PATH` environment variable:
-  *   - unset → PostgreSQL `game_records` table (production)
-  *   - set   → a Lichess PGN dump file/URL (demo). Point it at a `lichess_db_standard_rated_*.pgn[.zst]`
-  *             to drive every batch job from real Lichess games.
-  *
-  * Lichess parsing uses only Spark SQL string functions — no UDFs — so Catalyst can push predicates,
-  * matching the no-UDF approach already used in OpeningBookJob.
-  */
-object GameSource:
-
-  private val PgnPathEnv = "NOWCHESS_PGN_PATH"
-
-  /** True when a Lichess PGN dump is configured; jobs use this to skip JDBC write-back. */
-  def isPgnMode: Boolean = sys.env.contains(PgnPathEnv)
-
-  def load(spark: SparkSession, jdbcUrl: String, dbUser: String, dbPass: String): DataFrame =
-    sys.env.get(PgnPathEnv) match
-      case Some(path) => fromLichessPgn(spark, path)
-      case None       => fromJdbc(spark, jdbcUrl, dbUser, dbPass)
-
-  def fromJdbc(spark: SparkSession, jdbcUrl: String, dbUser: String, dbPass: String): DataFrame =
-    spark.read
-      .format("jdbc")
-      .option("url", jdbcUrl)
-      .option("dbtable", "game_records")
-      .option("user", dbUser)
-      .option("password", dbPass)
-      .option("driver", "org.postgresql.Driver")
-      .option("fetchsize", "10000")
-      .load()
-      .select("white_id", "black_id", "result", "move_count", "pgn")
-
-  /** Parses a Lichess PGN dump into the normalised game shape.
-    *
-    * `path` may be:
-    *   - an http(s)/ftp URL — fetched once via SparkContext.addFile and distributed to executors, then read
-    *     from the local replica (no S3/PVC needed; handy for a staging demo)
-    *   - any Hadoop-readable path (file://, hdfs://, s3a://, …)
-    *
-    * `.zst` dumps (Lichess' native format) are decompressed in-process via zstd-jni; `.gz`/`.bz2` are
-    * handled by Spark's text reader codecs.
-    *
-    * Records are split on the "[Event " tag that opens every game, so each row holds one complete game
-    * (the empty fragment before the first game is filtered out). Header tags are read with regexp_extract;
-    * the movetext (after the blank line) is cleaned of clock/eval comments and move numbers to count plies.
-    */
-  def fromLichessPgn(spark: SparkSession, path: String): DataFrame =
-    val resolved = resolvePath(spark, path)
-    val record   = F.col("value")
-
-    val resultTag = F.regexp_extract(record, "Result \"([^\"]*)\"", 1)
-    val result = F
-      .when(resultTag === "1-0", "white")
-      .when(resultTag === "0-1", "black")
-      .when(resultTag === "1/2-1/2", "draw")
-      .otherwise(F.lit(null).cast("string"))
-
-    val moveText  = F.coalesce(F.split(record, "\n\n").getItem(1), F.lit(""))
-    val noComment = F.regexp_replace(moveText, "\\{[^}]*\\}", "")
-    val noResult  = F.regexp_replace(noComment, "(1-0|0-1|1/2-1/2|\\*)", "")
-    val noNumbers = F.regexp_replace(noResult, "\\d+\\.+", " ")
-    val plies     = F.size(F.filter(F.split(F.trim(noNumbers), "\\s+"), tok => F.length(tok) > 0))
-
-    spark.read
-      .option("lineSep", "[Event ")
-      .text(resolved)
-      .filter(F.length(F.trim(record)) > 0)
-      .select(
-        F.regexp_extract(record, "White \"([^\"]*)\"", 1).as("white_id"),
-        F.regexp_extract(record, "Black \"([^\"]*)\"", 1).as("black_id"),
-        result.as("result"),
-        plies.as("move_count"),
-        F.concat(F.lit("[Event "), record).as("pgn"),
-      )
-      .filter((F.col("white_id") =!= "").and(F.col("black_id") =!= ""))
-
-  /** Turns an http(s)/ftp URL into a cluster-local path by fetching it once with SparkContext.addFile,
-    * which distributes the file to every executor. `.zst` is decompressed in-process and the plain `.pgn`
-    * is redistributed. Non-URL paths are returned unchanged.
-    */
-  private def resolvePath(spark: SparkSession, path: String): String =
-    if !path.matches("^(https?|ftp)://.*") then path
-    else
-      spark.sparkContext.addFile(path)
-      val local = SparkFiles.get(baseName(path))
-      if !local.endsWith(".zst") then "file://" + local
-      else distribute(spark, decompressZstd(local))
-
-  private def baseName(path: String): String = path.substring(path.lastIndexOf('/') + 1)
-
-  private def distribute(spark: SparkSession, localPath: String): String =
-    spark.sparkContext.addFile("file://" + localPath)
-    "file://" + SparkFiles.get(baseName(localPath))
-
-  /** Decompresses a `.zst` file to a temp `.pgn` using zstd-jni (bundled with Spark at runtime). */
-  private def decompressZstd(srcPath: String): String =
-    val out = java.io.File.createTempFile("lichess-", ".pgn")
-    out.deleteOnExit()
-    val in = com.github.luben.zstd.ZstdInputStream(
-      java.io.BufferedInputStream(java.io.FileInputStream(srcPath)),
-    )
-    try java.nio.file.Files.copy(in, out.toPath, java.nio.file.StandardCopyOption.REPLACE_EXISTING)
-    finally in.close()
-    out.getAbsolutePath

modules/analytics/src/main/scala/de/nowchess/analytics/OpeningBookJob.scala

@@ -37,8 +37,15 @@ object OpeningBookJob:
       outputDir: String,
       maxPlies: Int,
   ): Unit =
-    val games = GameSource
+    val games = spark.read
-      .load(spark, jdbcUrl, dbUser, dbPass)
+      .format("jdbc")
+      .option("url", jdbcUrl)
+      .option("dbtable", "game_records")
+      .option("user", dbUser)
+      .option("password", dbPass)
+      .option("driver", "org.postgresql.Driver")
+      .option("fetchsize", "10000")
+      .load()
       .select("pgn", "result")
       .filter(F.col("result").isNotNull.and(F.col("pgn").isNotNull))
 
@@ -72,16 +79,15 @@ object OpeningBookJob:
       .option("header", "true")
       .csv(s"$outputDir/opening_book_top1000")
 
-    if !GameSource.isPgnMode then
+    top1000.write
-      top1000.write
+      .mode("overwrite")
-        .mode("overwrite")
+      .format("jdbc")
-        .format("jdbc")
+      .option("url", jdbcUrl)
-        .option("url", jdbcUrl)
+      .option("dbtable", "analytics_opening_stats")
-        .option("dbtable", "analytics_opening_stats")
+      .option("user", dbUser)
-        .option("user", dbUser)
+      .option("password", dbPass)
-        .option("password", dbPass)
+      .option("driver", "org.postgresql.Driver")
-        .option("driver", "org.postgresql.Driver")
+      .save()
-        .save()
 
   /** Extracts the first `maxPlies` moves from a PGN column as a space-separated string.
     *

modules/analytics/src/main/scala/de/nowchess/analytics/PlayerClusteringJob.scala

@@ -50,8 +50,15 @@ object PlayerClusteringJob:
       outputDir: String,
       k: Int,
   ): Unit =
-    val games = GameSource
+    val games = spark.read
-      .load(spark, jdbcUrl, dbUser, dbPass)
+      .format("jdbc")
+      .option("url", jdbcUrl)
+      .option("dbtable", "game_records")
+      .option("user", dbUser)
+      .option("password", dbPass)
+      .option("driver", "org.postgresql.Driver")
+      .option("fetchsize", "10000")
+      .load()
       .select("white_id", "black_id", "result", "move_count")
       .filter(F.col("result").isNotNull)
 
@@ -119,26 +126,25 @@ object PlayerClusteringJob:
       .option("header", "true")
       .csv(s"$outputDir/cluster_archetypes")
 
-    if !GameSource.isPgnMode then
+    clustersDf.write
-      clustersDf.write
+      .mode("overwrite")
-        .mode("overwrite")
+      .format("jdbc")
-        .format("jdbc")
+      .option("url", jdbcUrl)
-        .option("url", jdbcUrl)
+      .option("dbtable", "analytics_player_clusters")
-        .option("dbtable", "analytics_player_clusters")
+      .option("user", dbUser)
-        .option("user", dbUser)
+      .option("password", dbPass)
-        .option("password", dbPass)
+      .option("driver", "org.postgresql.Driver")
-        .option("driver", "org.postgresql.Driver")
+      .save()
-        .save()
 
-      archetypes.write
+    archetypes.write
-        .mode("overwrite")
+      .mode("overwrite")
-        .format("jdbc")
+      .format("jdbc")
-        .option("url", jdbcUrl)
+      .option("url", jdbcUrl)
-        .option("dbtable", "analytics_cluster_archetypes")
+      .option("dbtable", "analytics_cluster_archetypes")
-        .option("user", dbUser)
+      .option("user", dbUser)
-        .option("password", dbPass)
+      .option("password", dbPass)
-        .option("driver", "org.postgresql.Driver")
+      .option("driver", "org.postgresql.Driver")
-        .save()
+      .save()
 
   private def buildPlayerStats(games: org.apache.spark.sql.DataFrame): org.apache.spark.sql.DataFrame =
     val asWhite = games.select(

modules/analytics/src/main/scala/de/nowchess/analytics/PlayerGraphJob.scala

@@ -53,8 +53,15 @@ object PlayerGraphJob:
       dbPass: String,
       outputDir: String,
   ): Unit =
-    val gamesRdd: RDD[Row] = GameSource
+    val gamesRdd: RDD[Row] = spark.read
-      .load(spark, jdbcUrl, dbUser, dbPass)
+      .format("jdbc")
+      .option("url", jdbcUrl)
+      .option("dbtable", "game_records")
+      .option("user", dbUser)
+      .option("password", dbPass)
+      .option("driver", "org.postgresql.Driver")
+      .option("fetchsize", "10000")
+      .load()
       .select("white_id", "black_id", "result")
       .filter(F.col("result").isNotNull)
       .rdd
@@ -109,16 +116,15 @@ object PlayerGraphJob:
       .mode("overwrite")
       .parquet(s"$outputDir/player_graph")
 
-    if !GameSource.isPgnMode then
+    result.write
-      result.write
+      .mode("overwrite")
-        .mode("overwrite")
+      .format("jdbc")
-        .format("jdbc")
+      .option("url", jdbcUrl)
-        .option("url", jdbcUrl)
+      .option("dbtable", "analytics_player_graph")
-        .option("dbtable", "analytics_player_graph")
+      .option("user", dbUser)
-        .option("user", dbUser)
+      .option("password", dbPass)
-        .option("password", dbPass)
+      .option("driver", "org.postgresql.Driver")
-        .option("driver", "org.postgresql.Driver")
+      .save()
-        .save()
 
     // How many players belong to each connected component?
     // A large dominant component + many singletons is the expected shape.

modules/analytics/src/main/scala/de/nowchess/analytics/PlayerStatsJob.scala

@@ -34,8 +34,15 @@ object PlayerStatsJob:
       dbPass: String,
       outputDir: String,
   ): Unit =
-    val games = GameSource
+    val games = spark.read
-      .load(spark, jdbcUrl, dbUser, dbPass)
+      .format("jdbc")
+      .option("url", jdbcUrl)
+      .option("dbtable", "game_records")
+      .option("user", dbUser)
+      .option("password", dbPass)
+      .option("driver", "org.postgresql.Driver")
+      .option("fetchsize", "10000")
+      .load()
       .select("white_id", "black_id", "result", "move_count")
       .filter(F.col("result").isNotNull)
 
@@ -77,13 +84,12 @@ object PlayerStatsJob:
       .mode("overwrite")
       .parquet(s"$outputDir/player_stats")
 
-    if !GameSource.isPgnMode then
+    stats.write
-      stats.write
+      .mode("overwrite")
-        .mode("overwrite")
+      .format("jdbc")
-        .format("jdbc")
+      .option("url", jdbcUrl)
-        .option("url", jdbcUrl)
+      .option("dbtable", "analytics_player_stats")
-        .option("dbtable", "analytics_player_stats")
+      .option("user", dbUser)
-        .option("user", dbUser)
+      .option("password", dbPass)
-        .option("password", dbPass)
+      .option("driver", "org.postgresql.Driver")
-        .option("driver", "org.postgresql.Driver")
+      .save()
-        .save()

modules/analytics/versions.env

@@ -1,3 +1,3 @@
 MAJOR=0
-MINOR=3
+MINOR=2
 PATCH=0

modules/official-bots/CHANGELOG.md

@@ -310,33 +310,3 @@
 ### Reverts
 
 * Revert "refactor: update metrics paths formatting in application.yml for clarity" ([3870566](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/38705663498d5f47c40dafe2f26198589ede8656))
-##  (2026-06-19)
-
-### Features
-
-* add initialization metrics for various services ([d438e97](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/d438e97f32bdde0bfc63c1b4a8cc810cdd093166))
-* add OpenTelemetry trace configuration with parentbased sampler ([3904d5a](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/3904d5ad8ad4930ddee65287a7bfab785a6148f5))
-* **analytics:** add Spark batch analytics module ([#70](https://git.janis-eccarius.de/NowChess/NowChessSystems/issues/70)) ([39f1657](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/39f1657e1db6e84889af338c43be8cb5c03c3ec3))
-* **config:** update application.yml for PostgreSQL and remove staging/production configurations ([2404e61](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/2404e6164c3b50ffccbea5238d636060d6abe4d6))
-* **config:** update application.yml for staging and production environments ([6113432](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/6113432a14c476a3a0dfc0d449e17d023697f2ba))
-* configure logging and add OpenTelemetry support ([#49](https://git.janis-eccarius.de/NowChess/NowChessSystems/issues/49)) ([d57c488](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/d57c4886612d1d92da0e1b79209fc83e6ef537a1))
-* **docker:** add .dockerignore and .gitignore files for build exclusions ([c987d8e](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/c987d8e258c0e6c4cfbdaa8381c64c410d7a2b83))
-* **docker:** add Dockerfiles for building Quarkus application in native and JVM modes ([3f2d2bb](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/3f2d2bb4c97fa8cddba66e1da4427c54236dfeed))
-* **docker:** add Dockerfiles for Quarkus application in JVM and native modes ([34b9933](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/34b993304670cf2aa62cd2f6460cee7b9864b08e))
-* **events:** migrate game-creation and bot flows to Redis Streams NCS-89 ([#62](https://git.janis-eccarius.de/NowChess/NowChessSystems/issues/62)) ([a24924c](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/a24924c23057db3d700a75dbc4333557789cd991))
-* NCS-78 Add Traceability to the Applications ([#46](https://git.janis-eccarius.de/NowChess/NowChessSystems/issues/46)) ([649566e](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/649566eb3fcf38f91c8896a739f74ea318af312d))
-* NCS-78 Add Traceability to the Applications ([#47](https://git.janis-eccarius.de/NowChess/NowChessSystems/issues/47)) ([87dfc6c](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/87dfc6c2bcce7f7d58fc641bd8d468a2e584c108))
-* NCS-82 add Swiss-system tournament module ([#55](https://git.janis-eccarius.de/NowChess/NowChessSystems/issues/55)) ([c5661de](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/c5661de4a0ebf4b33211f5a391840dcf744656b7))
-* **official-bots:** consume GameOver stream for bot cleanup ([#67](https://git.janis-eccarius.de/NowChess/NowChessSystems/issues/67)) ([db9d153](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/db9d1533912f4b41c4d1ca80ccffdde5d23d6ff6))
-* **official-bots:** park expert bot on tournament server at startup ([#75](https://git.janis-eccarius.de/NowChess/NowChessSystems/issues/75)) ([30295a4](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/30295a4bb95855ee8261c92278bb9ebc80ee12ee))
-* true-microservices ([#40](https://git.janis-eccarius.de/NowChess/NowChessSystems/issues/40)) ([5909242](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/590924254e8a2754de661a57a03e43f89ceb6299))
-
-### Bug Fixes
-
-* enable official bots to connect to external tournament server ([#71](https://git.janis-eccarius.de/NowChess/NowChessSystems/issues/71)) ([688d30e](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/688d30e2b10026923372be5fca3c63eaaee2de2a))
-* **official-bots:** configure JWT verification ([#72](https://git.janis-eccarius.de/NowChess/NowChessSystems/issues/72)) ([98c64fc](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/98c64fc0d56dc542beb31c75f4b9056d91de03cd))
-* **official-bots:** NCS-70-auto-register official bots with account service ([#59](https://git.janis-eccarius.de/NowChess/NowChessSystems/issues/59)) ([7117a93](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/7117a93376272094d0b1a6abf2121254ce396684))
-
-### Reverts
-
-* Revert "refactor: update metrics paths formatting in application.yml for clarity" ([3870566](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/38705663498d5f47c40dafe2f26198589ede8656))

modules/official-bots/src/main/scala/de/nowchess/bot/service/TournamentBotConfig.scala

@@ -20,7 +20,7 @@ object TournamentBotConfig:
       tournamentId <- env.get("TOURNAMENT_ID").filter(_.nonEmpty)
       token        <- env.get("TOURNAMENT_BOT_TOKEN").filter(_.nonEmpty)
       botId        <- jwtSubject(token)
-      serverUrl  = env.getOrElse("TOURNAMENT_SERVER_URL", "http://141.37.123.132:8086")
+      serverUrl  = env.getOrElse("TOURNAMENT_SERVER_URL", "http://localhost:8089")
       difficulty = env.getOrElse("TOURNAMENT_BOT_DIFFICULTY", "medium")
     yield TournamentBotConfig(serverUrl, tournamentId, token, botId, difficulty)
 

modules/official-bots/src/main/scala/de/nowchess/bot/service/TournamentBotGamePlayer.scala

@@ -39,11 +39,10 @@ class TournamentBotGamePlayer:
   // scalafix:on DisableSyntax.var
 
   val defaultServerUrl: String =
-    System.getenv().asScala.getOrElse("TOURNAMENT_SERVER_URL", "http://141.37.123.132:8086")
+    System.getenv().asScala.getOrElse("TOURNAMENT_SERVER_URL", "http://localhost:8089")
 
   @PostConstruct
   def initialize(): Unit =
-    parkOnStartup()
     config match
       case None =>
         log.info("Tournament bot disabled — set TOURNAMENT_ID and TOURNAMENT_BOT_TOKEN to enable")
@@ -51,32 +50,6 @@ class TournamentBotGamePlayer:
         log.infof("Tournament bot enabled — server=%s tournament=%s bot=%s", cfg.serverUrl, cfg.tournamentId, cfg.botId)
         startAsync(cfg)
 
-  private def parkOnStartup(): Unit =
-    park(defaultServerUrl, "expert") match
-      case Some(id) => log.infof("Parked expert bot on %s as id %s", defaultServerUrl, id)
-      case None     => log.warnf("Failed to park expert bot on %s", defaultServerUrl)
-
-  private def park(serverUrl: String, difficulty: String): Option[String] =
-    System.getenv().asScala.get("TOURNAMENT_BOT_TOKEN").filter(_.nonEmpty).flatMap { token =>
-      Try {
-        val body = s"""{"name":"${botName(difficulty)}"}"""
-        val response = client
-          .target(serverUrl)
-          .path("api")
-          .path("bots")
-          .request(MediaType.APPLICATION_JSON)
-          .header("Authorization", s"Bearer $token")
-          .post(Entity.entity(body, MediaType.APPLICATION_JSON))
-        if response.getStatus == 201 || response.getStatus == 200 then
-          val id = objectMapper.readTree(response.readEntity(classOf[String])).path("id").asText()
-          response.close()
-          Option(id).filter(_.nonEmpty)
-        else { log.warnf("Parking bot %s returned status %d", botName(difficulty), response.getStatus); response.close(); None }
-      }.getOrElse(None)
-    }
-
-  private def botName(difficulty: String): String = s"NowChess ${difficulty.capitalize}"
-
   def joinTournament(
       tournamentId: String,
       botToken: String,

modules/official-bots/versions.env

@@ -1,3 +1,3 @@
 MAJOR=0
-MINOR=20
+MINOR=19
 PATCH=0

modules/ws/CHANGELOG.md

@@ -259,32 +259,3 @@
 ### Reverts
 
 * Revert "refactor: update metrics paths formatting in application.yml for clarity" ([3870566](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/38705663498d5f47c40dafe2f26198589ede8656))
-##  (2026-06-19)
-
-### Features
-
-* add initialization metrics for various services ([d438e97](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/d438e97f32bdde0bfc63c1b4a8cc810cdd093166))
-* add OpenTelemetry trace configuration with parentbased sampler ([3904d5a](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/3904d5ad8ad4930ddee65287a7bfab785a6148f5))
-* **config:** update application.yml for PostgreSQL and remove staging/production configurations ([2404e61](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/2404e6164c3b50ffccbea5238d636060d6abe4d6))
-* **config:** update application.yml for staging and production environments ([6113432](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/6113432a14c476a3a0dfc0d449e17d023697f2ba))
-* configure logging and add OpenTelemetry support ([#49](https://git.janis-eccarius.de/NowChess/NowChessSystems/issues/49)) ([d57c488](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/d57c4886612d1d92da0e1b79209fc83e6ef537a1))
-* **docker:** add .dockerignore and .gitignore files for build exclusions ([c987d8e](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/c987d8e258c0e6c4cfbdaa8381c64c410d7a2b83))
-* **docker:** add Dockerfiles for building Quarkus application in native and JVM modes ([3f2d2bb](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/3f2d2bb4c97fa8cddba66e1da4427c54236dfeed))
-* **docker:** add Dockerfiles for Quarkus application in JVM and native modes ([34b9933](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/34b993304670cf2aa62cd2f6460cee7b9864b08e))
-* **docker:** add Dockerfiles for Quarkus application in JVM and native modes ([e5fe7d0](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/e5fe7d07a58e018151bb24f4ee37c06e72608ded))
-* **logging:** add DEBUG/INFO/WARN logging across services (NCS-72) ([#41](https://git.janis-eccarius.de/NowChess/NowChessSystems/issues/41)) ([804a4bf](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/804a4bf179e3dfb19e2be4390e7e543caf5237c6))
-* NCS-78 Add Traceability to the Applications ([#46](https://git.janis-eccarius.de/NowChess/NowChessSystems/issues/46)) ([649566e](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/649566eb3fcf38f91c8896a739f74ea318af312d))
-* NCS-78 Add Traceability to the Applications ([#47](https://git.janis-eccarius.de/NowChess/NowChessSystems/issues/47)) ([87dfc6c](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/87dfc6c2bcce7f7d58fc641bd8d468a2e584c108))
-* **reflection:** add native reflection configuration for tournament classes ([65bc6a7](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/65bc6a759937543df2d29905688bfa9e68d0c9d4))
-* true-microservices ([#40](https://git.janis-eccarius.de/NowChess/NowChessSystems/issues/40)) ([5909242](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/590924254e8a2754de661a57a03e43f89ceb6299))
-* update application.yml with new API root paths and add Micrometer and OpenTelemetry dependencies ([72ce262](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/72ce262bc491f94297700e6002fb5d0812e2cc2a))
-* **ws:** migrate challenge notifications to Redis Streams ([#66](https://git.janis-eccarius.de/NowChess/NowChessSystems/issues/66)) ([55f102c](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/55f102cbaa684be94a158b16aaa42a50b36afaf3))
-
-### Bug Fixes
-
-* NCS-122 authenticate WebSocket connections via first-message auth ([#73](https://git.janis-eccarius.de/NowChess/NowChessSystems/issues/73)) ([343e2bd](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/343e2bdd100649a96d96da8a6d98caad6de4ad14))
-* remove unused HTTP root-path configurations from application.yml ([3ed3e59](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/3ed3e59ee456d54cd3d65ece4f36623e256b9736))
-
-### Reverts
-
-* Revert "refactor: update metrics paths formatting in application.yml for clarity" ([3870566](https://git.janis-eccarius.de/NowChess/NowChessSystems/commit/38705663498d5f47c40dafe2f26198589ede8656))

modules/ws/src/main/scala/de/nowchess/ws/resource/GameWebSocketResource.scala

@@ -66,9 +66,9 @@ class GameWebSocketResource:
   @OnOpen
   def onOpen(connection: WebSocketConnection): Unit =
     activeGauge
-    val gameId                    = connection.pathParam("gameId")
+    val gameId                        = connection.pathParam("gameId")
-    val handler: Consumer[String] = msg => connection.sendText(msg).subscribe().`with`(_ => (), _ => ())
+    val handler: Consumer[String]     = msg => connection.sendText(msg).subscribe().`with`(_ => (), _ => ())
-    val subscriber                = redis.pubsub(classOf[String]).subscribe(s2cTopic(gameId), handler)
+    val subscriber                    = redis.pubsub(classOf[String]).subscribe(s2cTopic(gameId), handler)
     connections.put(connection.id(), ConnectionMeta(gameId, subscriber, None))
     connectionsOpened.increment()
     pendingAuth.add(connection.id())

modules/ws/versions.env

@@ -1,3 +1,3 @@
 MAJOR=0
-MINOR=17
+MINOR=16
 PATCH=0