fix(official-bots): NCS-70-auto-register official bots with account service (#59)

Co-authored-by: Janis <janis-e@gmx.de>
Reviewed-on: #59

modules/official-bots/src/main/resources/application.yml

@@ -5,6 +5,9 @@ quarkus:
     name: nowchess-official-bots
   redis:
     hosts: redis://${REDIS_HOST:localhost}:${REDIS_PORT:6379}
+  rest-client:
+    account-service:
+      url: http://localhost:8083
   smallrye-jwt:
     enabled: true
   log:
@@ -15,6 +18,8 @@ nowchess:
     host: localhost
     port: 6379
     prefix: nowchess
+  internal:
+    secret: 123abc
 
 "%deployed":
   quarkus:
@@ -28,8 +33,13 @@ nowchess:
       exporter:
         otlp:
           endpoint: ${OTEL_EXPORTER_OTLP_ENDPOINT:http://localhost:4317}
+    rest-client:
+      account-service:
+        url: ${ACCOUNT_SERVICE_URL}
   nowchess:
     redis:
       host: ${REDIS_HOST:localhost}
       port: ${REDIS_PORT:6379}
       prefix: ${REDIS_PREFIX:nowchess}
+    internal:
+      secret: ${INTERNAL_SECRET}

modules/official-bots/src/main/scala/de/nowchess/bot/client/AccountServiceClient.scala

@@ -0,0 +1,20 @@
+package de.nowchess.bot.client
+
+import de.nowchess.security.{InternalClientHeadersFactory, InternalSecretClientFilter}
+import jakarta.ws.rs.*
+import jakarta.ws.rs.core.MediaType
+import org.eclipse.microprofile.rest.client.annotation.{RegisterClientHeaders, RegisterProvider}
+import org.eclipse.microprofile.rest.client.inject.RegisterRestClient
+
+case class SyncOfficialBotsRequest(bots: List[String])
+
+@Path("/api/account/official-bots")
+@RegisterRestClient(configKey = "account-service")
+@RegisterProvider(classOf[InternalSecretClientFilter])
+@RegisterClientHeaders(classOf[InternalClientHeadersFactory])
+trait AccountServiceClient:
+
+  @POST
+  @Path("/sync")
+  @Consumes(Array(MediaType.APPLICATION_JSON))
+  def syncBots(req: SyncOfficialBotsRequest): Unit

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

@@ -4,6 +4,7 @@ import com.fasterxml.jackson.databind.ObjectMapper
 import de.nowchess.api.move.{Move, MoveType, PromotionPiece}
 import de.nowchess.bot.BotController
 import de.nowchess.bot.BotDifficulty
+import de.nowchess.bot.client.{AccountServiceClient, SyncOfficialBotsRequest}
 import de.nowchess.bot.config.RedisConfig
 import de.nowchess.io.fen.FenParser
 import io.micrometer.core.instrument.MeterRegistry
@@ -13,6 +14,8 @@ import jakarta.annotation.PostConstruct
 import jakarta.enterprise.context.ApplicationScoped
 import jakarta.enterprise.event.Observes
 import jakarta.inject.Inject
+import org.eclipse.microprofile.rest.client.inject.RestClient
+import org.jboss.logging.Logger
 import scala.compiletime.uninitialized
 import java.util.function.Consumer
 import java.util.concurrent.TimeUnit
@@ -20,12 +23,18 @@ import java.util.concurrent.TimeUnit
 @ApplicationScoped
 class OfficialBotService:
 
+  private val log = Logger.getLogger(classOf[OfficialBotService])
+
   // scalafix:off DisableSyntax.var
   @Inject var redis: RedisDataSource       = uninitialized
   @Inject var redisConfig: RedisConfig     = uninitialized
   @Inject var objectMapper: ObjectMapper   = uninitialized
   @Inject var botController: BotController = uninitialized
   @Inject var meterRegistry: MeterRegistry = uninitialized
+
+  @Inject
+  @RestClient
+  var accountServiceClient: AccountServiceClient = uninitialized
   // scalafix:on DisableSyntax.var
 
   private val terminalStatuses =
@@ -39,7 +48,10 @@ class OfficialBotService:
     }
 
   def onStart(@Observes event: StartupEvent): Unit =
-    BotController.listBots.foreach(subscribeToEventChannel)
+    val bots = BotController.listBots
+    try accountServiceClient.syncBots(SyncOfficialBotsRequest(bots))
+    catch case ex: Exception => log.errorf(ex, "Failed to auto-register official bots with account service")
+    bots.foreach(subscribeToEventChannel)
 
   private def subscribeToEventChannel(botName: String): Unit =
     val handler: Consumer[String] = msg => handleBotEvent(botName, msg)