From d346c41d98ad2889dfe7e7f6b53be6ecaaafc83d Mon Sep 17 00:00:00 2001 From: Janis Date: Fri, 1 May 2026 20:05:03 +0200 Subject: [PATCH] refactor: improve code formatting and readability --- .../coordinator/service/InstanceRegistry.scala | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/modules/coordinator/src/main/scala/de/nowchess/coordinator/service/InstanceRegistry.scala b/modules/coordinator/src/main/scala/de/nowchess/coordinator/service/InstanceRegistry.scala index 6137ac7..480fbc5 100644 --- a/modules/coordinator/src/main/scala/de/nowchess/coordinator/service/InstanceRegistry.scala +++ b/modules/coordinator/src/main/scala/de/nowchess/coordinator/service/InstanceRegistry.scala @@ -15,7 +15,7 @@ class InstanceRegistry: // scalafix:off DisableSyntax.var @Inject private var redis: ReactiveRedisDataSource = uninitialized - private var redisPrefix = "nowchess" + private var redisPrefix = "nowchess" // scalafix:on DisableSyntax.var private val mapper = ObjectMapper() @@ -32,16 +32,19 @@ class InstanceRegistry: def updateInstanceFromRedis(instanceId: String): Uni[Unit] = val key = s"$redisPrefix:instances:$instanceId" - redis.value(classOf[String]) + redis + .value(classOf[String]) .get(key) - .onItem().transformToUni { value => + .onItem() + .transformToUni { value => try val metadata = mapper.readValue(value, classOf[InstanceMetadata]) instances.put(instanceId, metadata) Uni.createFrom().item(()) catch case _: Exception => Uni.createFrom().item(()) } - .onFailure().recoverWithItem(()) + .onFailure() + .recoverWithItem(()) def markInstanceDead(instanceId: String): Unit = instances.computeIfPresent(instanceId, (_, inst) => inst.copy(state = "DEAD"))