Implements the full tournament lifecycle: create, join, withdraw, start,
round progression, and finish with Buchholz tiebreak standings.

- REST resource covering all 11 endpoints from the OpenAPI spec
- Swiss pairing algorithm with bye support
- Per-bot NDJSON stream with targeted gameStart events (color field)
- Game result ingestion via Redis writeback stream
- H2-backed integration tests for resource and pairing service

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

@@ -51,0 +52,4 @@
+modules/account/src/main/resources/keys/dev-private.pem
+modules/account/src/main/resources/keys/dev-public.pem
+modules/core/src/main/resources/keys/dev-public.pem
+java_pid2736.hprof

@@ -75,4 +75,7 @@ class OfficialBotAccount extends PanacheEntityBase:
   var rating: Int = 1500
 
   var createdAt: Instant = uninitialized
+

@@ -196,3 +196,3 @@
   @POST
   @Path("/official-bots")
-  @RolesAllowed(Array("Admin"))
+  @RolesAllowed(Array("**"))

@@ -219,3 +219,12 @@ class AccountResource:
       rating = bot.rating,
       createdAt = bot.createdAt.toString,
     )
+

@@ -154,3 +154,3 @@
           bot.name = botName
           bot.owner = owner
-          bot.token = generateBotToken(bot.id)
+          bot.token = UUID.randomUUID().toString

@@ -204,6 +205,8 @@ class AccountService:
     bot.name = botName
     bot.createdAt = Instant.now()
     officialBotAccountRepository.persist(bot)
+    bot.token = generateBotToken(bot.id, bot.name)

@@ -232,4 +237,4 @@
     Jwt
       .issuer("nowchess")
       .subject(botId.toString)
       .expiresAt(Long.MaxValue)

@@ -96,3 +100,3 @@
     heartbeatServiceOpt.foreach(_.addGameSubscription(gameId))
 
-    val handler: Consumer[String] = msg => handleC2sMessage(gameId, msg)
+    val executor = c2sExecutors.computeIfAbsent(gameId, _ => Executors.newSingleThreadExecutor())

@@ -99,0 +105,4 @@
+        def run(): Unit =
+          try handleC2sMessage(gameId, msg)
+          catch case ex: Exception => log.warnf(ex, "Error handling c2s message for game %s", gameId)
+      Try(executor.execute(task))

@@ -109,0 +120,4 @@
+  // Notify the official-bots service to start playing a side of a game. Mirrors
+  // the event the tournament service publishes; official-bots subscribes to
+  // "<prefix>:bot:*:events".
+  def publishBotGameStart(gameId: String, botId: String, playingAs: String): Unit =

@@ -113,6 +134,7 @@ class GameRedisSubscriberManager:
     Option(s2cObservers.remove(gameId)).foreach { obs =>
       registry.get(gameId).foreach(_.engine.unsubscribe(obs))
     }
+    Option(c2sExecutors.remove(gameId)).foreach(_.shutdownNow())

@@ -182,0 +185,4 @@
+  // and core notifies the official-bots service to play the bot side.
+  @POST
+  @Path("/vs-bot")
+  @PermitAll

@@ -182,0 +201,4 @@
+    created(GameDtoMapper.toGameFullDto(entry, ioClient))
+
+  private def notifyBotSide(entry: GameEntry): Unit =
+    if entry.black.id.value.startsWith("bot-") then

@@ -56,3 +57,1 @@
-  private def subscribeToEventChannel(botName: String): Unit =
-    val handler: Consumer[String] = msg => handleBotEvent(botName, msg)
-    redis.pubsub(classOf[String]).subscribe(s"${redisConfig.prefix}:bot:$botName:events", handler)
+    val pattern                   = s"${redisConfig.prefix}:bot:*:events"

@@ -81,0 +80,4 @@
+  private def registerColor(gameId: String, playingAs: String, playerId: String): Unit =
+    val fresh    = new ConcurrentHashMap[String, String]()
+    val existing = watchedGames.putIfAbsent(gameId, fresh)
+    val colors   = if existing == null then fresh else existing

@@ -122,1 +98,4 @@
+      subscribers.put(gameId, subscriber)
+      sendConnected(pubsub, gameId)
     }
+    pubsub.subscribe(s2c, handler).subscribe().`with`(onSubscribed, logFailure(s"subscribe to game $gameId"))

@@ -123,0 +120,4 @@
+      if terminalStatuses.contains(status) then stopWatching(gameId)
+      else
+        val colors   = watchedGames.get(gameId)
+        val playerId = if colors == null then null else colors.get(turn)

@@ -123,0 +164,4 @@
+  private def logFailure(what: String): Consumer[Throwable] =
+    err => log.errorf(err, "Failed to %s", what)
+
+  private def engineName: String = "classical"

@@ -0,0 +1,219 @@
+package de.nowchess.bot.service

@@ -0,0 +1,31 @@
+package de.nowchess.tournament.domain