feat: Add logging to Gateway for pod synchronization and startup events
This commit is contained in:
Submodule knockoutwhistfrontend updated: d8b3904cbc...352b7fd3ff
@@ -4,6 +4,7 @@ import de.knockoutwhist.data.Pod
|
||||
import de.knockoutwhist.data.redis.RedisManager
|
||||
import org.apache.pekko.actor.ActorSystem
|
||||
import org.redisson.config.Config
|
||||
import play.api.Logger
|
||||
import play.api.inject.ApplicationLifecycle
|
||||
|
||||
import java.util.UUID
|
||||
@@ -17,6 +18,8 @@ class Gateway @Inject()(
|
||||
actorSystem: ActorSystem
|
||||
)(implicit ec: ExecutionContext) {
|
||||
|
||||
private val logger = Logger(getClass.getName)
|
||||
|
||||
val redis: RedisManager = {
|
||||
val config: Config = Config()
|
||||
config.useSingleServer.setAddress("valkey://" + sys.env.getOrElse("VALKEY_HOST", "localhost") + ":" + sys.env.getOrElse("VALKEY_PORT", "6379"))
|
||||
@@ -24,9 +27,12 @@ class Gateway @Inject()(
|
||||
}
|
||||
|
||||
redis.continuousSyncPod(() => {
|
||||
logger.info("Syncing pod with Redis")
|
||||
createPod()
|
||||
})
|
||||
|
||||
logger.info("Gateway started")
|
||||
|
||||
def syncPod(): Unit = {
|
||||
redis.syncPod(createPod())
|
||||
}
|
||||
|
||||
@@ -1,9 +1,10 @@
|
||||
package modules
|
||||
|
||||
import com.google.inject.AbstractModule
|
||||
import logic.Gateway
|
||||
|
||||
class GatewayModule extends AbstractModule {
|
||||
override def configure(): Unit = {
|
||||
bind(classOf[GatewayModule]).asEagerSingleton()
|
||||
bind(classOf[Gateway]).asEagerSingleton()
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user