feat: integrate event server state management and Redis API

- Added `LocalEventServerState` to handle event server states locally.
- Introduced `EventServerBridge` to manage state synchronization with Redis.
- Registered `EventServerStateChangeListener` to handle Redis events for state updates.
- Updated `NavigatorInventory` to provide actions and messages based on event server state.
- Enhanced `PermissionRegistry` with `EVENT_BYPASS` permission.
- Added Redis API and event base API Redis dependencies to `build.gradle.kts`.
- Updated `LobbyConfig` with `redisUrl` configuration.

Author: TheBjoRedCraft

build.gradle.kts

@@ -12,6 +12,8 @@ dependencies {
     compileOnly("surf-hologram:surf-hologram-api:1.21.10-1.0.1-20251011.094119-1")
     compileOnly("dev.slne.surf.npc:surf-npc-api:1.21.10-1.5.0-20251009.154819-1")
     compileOnly("com.nexomc:nexo:1.16.1")
+    implementation("dev.slne.surf:surf-redis:1.0.0-SNAPSHOT")
+    implementation("dev.slne.surf.event:surf-event-base-api-redis:1.21.11-1.0.0-SNAPSHOT")
 }
 
 version = findProperty("version") as String

src/main/kotlin/dev/slne/surf/lobby/PaperMain.kt

@@ -1,14 +1,18 @@
 package dev.slne.surf.lobby
 
 import com.github.shynixn.mccoroutine.folia.SuspendingJavaPlugin
+import com.github.shynixn.mccoroutine.folia.launch
 import dev.slne.surf.lobby.command.lobbyCommand
 import dev.slne.surf.lobby.command.spawnCommand
 import dev.slne.surf.lobby.config.LobbyConfigHolder
+import dev.slne.surf.lobby.event.eventServerBridge
+import dev.slne.surf.lobby.event.listener.EventServerStateChangeListener
 import dev.slne.surf.lobby.hologram.SurfHologramHook
 import dev.slne.surf.lobby.listener.*
 import dev.slne.surf.lobby.manager.PushbackManager
 import dev.slne.surf.lobby.nexo.NexoHook
 import dev.slne.surf.lobby.npc.SurfNpcHook
+import dev.slne.surf.redis.RedisApi
 import dev.slne.surf.surfapi.bukkit.api.event.register
 import org.bukkit.Bukkit
 import org.bukkit.inventory.ItemType
@@ -17,6 +21,7 @@ import org.bukkit.plugin.java.JavaPlugin
 val plugin get() = JavaPlugin.getPlugin(PaperMain::class.java)
 
 class PaperMain : SuspendingJavaPlugin() {
+    lateinit var redisApi: RedisApi
     override fun onEnable() {
         if (surfNpcHook) {
             SurfNpcHook.initialize()
@@ -39,6 +44,18 @@ class PaperMain : SuspendingJavaPlugin() {
 
         lobbyCommand()
         spawnCommand()
+
+        redisApi = RedisApi.create(plugin.dataPath)
+        redisApi.registerRequestHandler(EventServerStateChangeListener)
+        redisApi.freezeAndConnect()
+
+        launch {
+            eventServerBridge.requestState()
+        }
+    }
+
+    override fun onDisable() {
+        redisApi.disconnect()
     }
 
     fun getInvisibleItem() =

src/main/kotlin/dev/slne/surf/lobby/config/LobbyConfig.kt

@@ -7,7 +7,9 @@ import org.spongepowered.configurate.objectmapping.ConfigSerializable
 data class LobbyConfig(
     val spawnPoint: LocationConfig = LocationConfig.default(),
     val survivalNpc: LocationConfig = LocationConfig.default(),
-    val eventNpc: LocationConfig = LocationConfig.default()
+    val eventNpc: LocationConfig = LocationConfig.default(),
+
+    val redisUrl: String = "redis://localhost:6379",
 ) {
     @ConfigSerializable
     data class LocationConfig(

src/main/kotlin/dev/slne/surf/lobby/event/EventServerBridge.kt

@@ -0,0 +1,22 @@
+package dev.slne.surf.lobby.event
+
+import dev.slne.surf.event.base.api.redis.request.EventServerStateRequest
+import dev.slne.surf.event.base.api.redis.response.EventServerStateResponse
+import dev.slne.surf.lobby.event.state.LocalEventServerState
+import dev.slne.surf.lobby.plugin
+
+val eventServerBridge = EventServerBridge()
+
+class EventServerBridge {
+    var state: LocalEventServerState = LocalEventServerState.UNKNOWN
+
+    suspend fun requestState() = runCatching {
+        plugin.logger.info("Requesting event server state...")
+        val response =
+            plugin.redisApi.sendRequest<EventServerStateResponse>(EventServerStateRequest())
+        state = LocalEventServerState.ofState(response.state)
+        plugin.logger.info("Received event server state: $state")
+    }.onFailure {
+        state = LocalEventServerState.UNKNOWN
+    }
+}

src/main/kotlin/dev/slne/surf/lobby/event/listener/EventServerStateChangeListener.kt

@@ -0,0 +1,13 @@
+package dev.slne.surf.lobby.event.listener
+
+import dev.slne.surf.event.base.api.redis.event.EventServerStateChangeRedisEvent
+import dev.slne.surf.lobby.event.eventServerBridge
+import dev.slne.surf.lobby.event.state.LocalEventServerState
+import dev.slne.surf.redis.event.OnRedisEvent
+
+object EventServerStateChangeListener {
+    @OnRedisEvent
+    fun onEventServerStateChange(event: EventServerStateChangeRedisEvent) {
+        eventServerBridge.state = LocalEventServerState.ofState(event.to)
+    }
+}

src/main/kotlin/dev/slne/surf/lobby/event/state/LocalEventServerState.kt

@@ -0,0 +1,18 @@
+package dev.slne.surf.lobby.event.state
+
+import dev.slne.surf.event.base.api.common.state.EventServerState
+
+enum class LocalEventServerState {
+    OPEN,
+    CLOSED,
+    UNKNOWN;
+
+    companion object {
+        fun ofState(eventServerState: EventServerState): LocalEventServerState {
+            return when (eventServerState) {
+                EventServerState.OPEN -> OPEN
+                EventServerState.CLOSED -> CLOSED
+            }
+        }
+    }
+}

src/main/kotlin/dev/slne/surf/lobby/inventory/impl/NavigatorInventory.kt

@@ -1,7 +1,10 @@
 package dev.slne.surf.lobby.inventory.impl
 
 import com.github.stefvanschie.inventoryframework.pane.util.Slot
+import dev.slne.surf.lobby.event.eventServerBridge
+import dev.slne.surf.lobby.event.state.LocalEventServerState
 import dev.slne.surf.lobby.plugin
+import dev.slne.surf.lobby.utils.PermissionRegistry
 import dev.slne.surf.surfapi.bukkit.api.builder.displayName
 import dev.slne.surf.surfapi.bukkit.api.event.cancel
 import dev.slne.surf.surfapi.bukkit.api.inventory.dsl.menu
@@ -19,9 +22,31 @@ fun navigatorInventory() = menu(text("<shift:-46><glyph:server_selector>"), 6) {
         fillWith(eventServerItem)
 
         setOnClick {
-            it.whoClicked.sendText {
-                appendPrefix()
-                error("Aktuell findet kein Event statt!")
+            val player = it.whoClicked as? Player ?: return@setOnClick
+
+            when (eventServerBridge.state) {
+                LocalEventServerState.OPEN -> {
+                    surfBukkitApi.sendPlayerToServer(player, "event")
+                    return@setOnClick
+                }
+
+                LocalEventServerState.CLOSED -> {
+                    if (player.hasPermission(PermissionRegistry.EVENT_BYPASS)) {
+                        surfBukkitApi.sendPlayerToServer(player, "event")
+                        return@setOnClick
+                    }
+                    player.sendText {
+                        appendPrefix()
+                        error("Der Event Server ist aktuell geschlossen!")
+                    }
+                }
+
+                LocalEventServerState.UNKNOWN -> {
+                    player.sendText {
+                        appendPrefix()
+                        error("Aktuell findet kein Event statt!")
+                    }
+                }
             }
             it.whoClicked.closeInventory()
         }

src/main/kotlin/dev/slne/surf/lobby/utils/PermissionRegistry.kt

@@ -11,6 +11,8 @@ object PermissionRegistry : PermissionRegistry() {
     val COMMAND_LOBBY = create("$COMMAND_PREFIX.lobby")
     val COMMAND_LOBBY_RELOAD = create("$COMMAND_PREFIX.lobby.reload")
 
+    val EVENT_BYPASS = create("$PREFIX.event.bypass")
+
     val PUSHBACK_ATTACK = create("$PREFIX.pushback.attack")
     val PUSHBACK_ITEM = create("$PREFIX.pushback.item")
     val PROTECTION_BYPASS = create("$PREFIX.bypass")