feat: allow connecting players to other servers registered to the proxy via pub/sub

Author: byPixelTV

src/main/kotlin/dev/bypixel/redivelocity/RediVelocity.kt

@@ -33,6 +33,7 @@ import dev.bypixel.redivelocity.election.ElectionScheduler
 import dev.bypixel.redivelocity.event.*
 import dev.bypixel.redivelocity.feature.globalPlayercount.PlayercountScheduler
 import dev.bypixel.redivelocity.heartbeat.HeartbeatScheduler
+import dev.bypixel.redivelocity.pubsub.ConnectListener
 import dev.bypixel.redivelocity.pubsub.KickListener
 import dev.bypixel.redivelocity.pubsub.LeaderElectionListener
 import dev.bypixel.redivelocity.pubsub.PlayercountListener
@@ -263,6 +264,7 @@ class RediVelocity @Inject constructor(val proxy: ProxyServer) {
             }
 
             KickListener
+            ConnectListener
             LeaderElectionListener
             PlayercountListener
 
@@ -332,6 +334,7 @@ class RediVelocity @Inject constructor(val proxy: ProxyServer) {
             CommandAPI.onDisable()
 
             RedisListener.unregisterListener(KickListener)
+            RedisListener.unregisterListener(ConnectListener)
             RedisListener.unregisterListener(LeaderElectionListener)
             RedisListener.unregisterListener(PlayercountListener)
             ElectionScheduler.job.cancelAndJoin()

src/main/kotlin/dev/bypixel/redivelocity/pubsub/ConnectListener.kt

@@ -0,0 +1,25 @@
+package dev.bypixel.redivelocity.pubsub
+
+import dev.bypixel.lettucewrapper.listener.RedisListener
+import dev.bypixel.redivelocity.RediVelocity
+import org.json.JSONObject
+import java.util.*
+
+object ConnectListener : RedisListener("redivelocity-connect") {
+    override fun onMessage(message: String) {
+        val jMsg = JSONObject(message)
+
+        if (jMsg.has("uuid") && jMsg.has("server")) {
+            val uuid = UUID.fromString(jMsg.getString("uuid"))
+            val server = jMsg.getString("server")
+
+            RediVelocity.instance.proxy.allPlayers.find { it.uniqueId == uuid }?.let { player ->
+                player.createConnectionRequest(
+                    RediVelocity.instance.proxy.getServer(server).orElseThrow {
+                        IllegalArgumentException("Server $server not found")
+                    }
+                )
+            }
+        }
+    }
+}