Add Rusty Connector support

.gitignore

@@ -15,4 +15,7 @@
 /plugin/universal/test-environment/
 gradle-app.setting
 !gradle-wrapper.jar
-.gradletasknamecache
+.gradletasknamecache
+
+# VS Code Gradle
+bin

build.gradle

@@ -64,6 +64,7 @@ subprojects {
         maven { url 'https://repo.onarandombox.com/content/groups/public'  }
         maven { url 'https://repo.codemc.org/repository/maven-public/'  }
         maven { url 'https://repo.alessiodp.com/releases/'  }
+        maven { url "https://maven.mrnavastar.rocks/releases" }
     }
 
     shadowJar {

plugin/common/build.gradle

@@ -1,9 +1,14 @@
 apply plugin: "com.github.gmazzo.buildconfig"
 
+repositories {
+    maven { url "https://maven.mrnavastar.rocks/releases" }
+}
+
 dependencies {
     /* PROVIDED */
     compileOnly libs.multiverse
     compileOnly libs.parties.api
+    compileOnly "group.aelysium:rustyconnector-toolkit:0.8.0"
 
     /* SHADED */
     implementation 'org.screamingsandals.language.bedwars:BedWarsLanguage:' + (project.version =~ /^\d+.\d+/).findAll()?.first() + '-SNAPSHOT'

plugin/common/src/main/java/org/screamingsandals/bedwars/BedWarsPlugin.java

@@ -19,6 +19,9 @@
 
 package org.screamingsandals.bedwars;
 
+import group.aelysium.rustyconnector.toolkit.RustyConnector;
+import group.aelysium.rustyconnector.toolkit.mc_loader.central.IMCLoaderFlame;
+import group.aelysium.rustyconnector.toolkit.mc_loader.central.IMCLoaderTinder;
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;
 import org.jetbrains.annotations.NotNull;
@@ -28,10 +31,7 @@
 import org.screamingsandals.bedwars.config.RecordSave;
 import org.screamingsandals.bedwars.database.DatabaseManager;
 import org.screamingsandals.bedwars.entities.EntitiesManagerImpl;
-import org.screamingsandals.bedwars.game.GameManagerImpl;
-import org.screamingsandals.bedwars.game.GroupManagerImpl;
-import org.screamingsandals.bedwars.game.ItemSpawnerTypeImpl;
-import org.screamingsandals.bedwars.game.LocalGameLoaderImpl;
+import org.screamingsandals.bedwars.game.*;
 import org.screamingsandals.bedwars.holograms.LeaderboardHolograms;
 import org.screamingsandals.bedwars.holograms.StatisticsHolograms;
 import org.screamingsandals.bedwars.inventories.GamesInventory;
@@ -72,10 +72,7 @@
 
 import java.io.IOException;
 import java.nio.file.Files;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Objects;
+import java.util.*;
 import java.util.stream.Collectors;
 
 @Plugin(
@@ -95,7 +92,8 @@
         "PerWorldInventory",
         "SlimeWorldManager",
         "My_Worlds",
-        "Parties"
+        "Parties",
+        "rustyconnector-paper"
 })
 @Init(
         services = {
@@ -151,6 +149,8 @@ public class BedWarsPlugin implements BedwarsAPI {
     @Getter
     private final HashMap<String, ItemSpawnerTypeImpl> spawnerTypes = new HashMap<>();
 
+    private IMCLoaderFlame<?> flame;
+
     public static BedWarsPlugin getInstance() {
         return instance;
     }
@@ -335,6 +335,19 @@ public void enable() {
         Server.getConsoleSender().sendMessage(Component.text("https://www.patreon.com/screamingsandals", Color.WHITE));
 
         HologramManager.setPreferDisplayEntities(MainConfig.getInstance().node("prefer-1-19-4-display-entities").getBoolean());
+
+        if (GameImpl.isRustyConnectorEnabled()) {
+            Optional<IMCLoaderTinder> tinderHolder = RustyConnector.Toolkit.mcLoader();
+            if (tinderHolder.isPresent()) {
+                IMCLoaderTinder tinder = tinderHolder.get();
+                tinder.onStart(flame -> {
+                    this.flame = flame;
+                    Server.getConsoleSender().sendMessage(Component.text("Rusty Connector's Tinder found!", Color.GREEN));
+                });
+            } else {
+                Server.getConsoleSender().sendMessage(Component.text("Rusty Connector's Tinder not found!", Color.RED));
+            }
+        }
     }
 
     @OnDisable
@@ -414,4 +427,8 @@ public static boolean isDisabling() {
     public void saveResource(@NotNull String resourcePath, boolean replace) {
         PluginUtils.saveResource(pluginDescription, logger, resourcePath, replace);
     }
+
+    public IMCLoaderFlame<?> getFlame() {
+        return flame;
+    }
 }

plugin/common/src/main/java/org/screamingsandals/bedwars/config/MainConfig.java

@@ -195,6 +195,10 @@ public void load() {
                         .key("rebuilding").defValue("%name%: Rebuilding...")
                         .key("disabled").defValue("%name%: Game is disabled")
                         .back()
+                    .section("rustyConnector")
+                        .key("enabled").defValue(false)
+                        .key("family").defValue("hub")
+                        .back()
                     .back()
                 .section("ignored-blocks")
                     .key("enabled").migrateOldAbsoluteKey("farmBlocks", "enable").defValue(false)

plugin/common/src/main/java/org/screamingsandals/bedwars/game/GameImpl.java

@@ -234,6 +234,10 @@ public static boolean isBungeeEnabled() {
         return MainConfig.getInstance().node("bungee", "enabled").getBoolean();
     }
 
+    public static boolean isRustyConnectorEnabled() {
+        return MainConfig.getInstance().node("bungee", "rustyConnector", "enabled").getBoolean();
+    }
+
     public void setWorld(World world) {
         if (this.world == null) {
             this.world = world;

plugin/common/src/main/java/org/screamingsandals/bedwars/utils/BungeeUtils.java

@@ -19,10 +19,17 @@
 
 package org.screamingsandals.bedwars.utils;
 
+import group.aelysium.rustyconnector.toolkit.RustyConnector;
+import group.aelysium.rustyconnector.toolkit.core.packet.Packet;
+import group.aelysium.rustyconnector.toolkit.core.packet.PacketIdentification;
+import group.aelysium.rustyconnector.toolkit.mc_loader.central.IMCLoaderTinder;
 import lombok.experimental.UtilityClass;
+import org.screamingsandals.bedwars.BedWarsPlugin;
 import org.screamingsandals.bedwars.config.MainConfig;
+import org.screamingsandals.bedwars.game.GameImpl;
 import org.screamingsandals.bedwars.lib.debug.Debug;
 import org.screamingsandals.lib.CustomPayload;
+import org.screamingsandals.lib.Server;
 import org.screamingsandals.lib.player.Player;
 import org.screamingsandals.lib.spectator.Component;
 import org.screamingsandals.lib.tasker.DefaultThreads;
@@ -63,24 +70,53 @@ public void sendPlayerBungeeMessage(Player player, String string) {
 
     private void internalMove(Player player, boolean restart) {
         var server = MainConfig.getInstance().node("bungee", "server").getString("hub");
-        var out = new ByteArrayOutputStream();
-        var dout = new DataOutputStream(out);
+        var rustySuccess = true;
 
-        try {
-            dout.writeUTF("Connect");
-            dout.writeUTF(server);
+        if (GameImpl.isRustyConnectorEnabled()) {
+            if (BedWarsPlugin.getInstance().getFlame() != null) {
+                var familyName = MainConfig.getInstance().node("bungee", "rustyConnector", "family").getString("hub");
 
-            CustomPayload.send(player, "BungeeCord", out.toByteArray());
-        } catch (IOException e) {
-            e.printStackTrace();
-        }
-        Debug.info("Player " + player.getName() + " has been moved to hub server.");
-        if (!restart && MainConfig.getInstance().node("bungee", "kick-when-proxy-too-slow").getBoolean(true)) {
-            Tasker.runDelayed(DefaultThreads.GLOBAL_THREAD, () -> {
-                if (player.isOnline()) {
-                    player.kick(Component.text("BedWars can't properly transfer player through bungee network. Contact server admin."));
+                try {
+                    Packet message = BedWarsPlugin.getInstance().getFlame().services().packetBuilder().newBuilder()
+                            .identification(PacketIdentification.from("RC", "SP"))
+                            .sendingToProxy()
+                            .parameter("f", familyName)
+                            .parameter("p", player.getUniqueId().toString())
+                            .build();
+
+                    BedWarsPlugin.getInstance().getFlame().services().magicLink().connection().orElseThrow().publish(message);
+                    Debug.info("Player " + player.getName() + " has been moved to hub server.");
+                } catch (Exception e) {
+                    rustySuccess = false;
+                    Debug.warn("Rusty Connector transfer failed, falling back to Bungee.");
+                    e.printStackTrace();
                 }
-            }, 20, TaskerTime.TICKS);
+            } else {
+                rustySuccess = false;
+            }
+        }
+
+        if (!rustySuccess) {
+
+            var out = new ByteArrayOutputStream();
+            var dout = new DataOutputStream(out);
+
+            try {
+                dout.writeUTF("Connect");
+                dout.writeUTF(server);
+
+                CustomPayload.send(player, "BungeeCord", out.toByteArray());
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+            Debug.info("Player " + player.getName() + " has been moved to hub server.");
+            if (!restart && MainConfig.getInstance().node("bungee", "kick-when-proxy-too-slow").getBoolean(true)) {
+                Tasker.runDelayed(DefaultThreads.GLOBAL_THREAD, () -> {
+                    if (player.isOnline()) {
+                        player.kick(Component.text("BedWars can't properly transfer player through bungee network. Contact server admin."));
+                    }
+                }, 20, TaskerTime.TICKS);
+            }
         }
     }
 }

settings.gradle

@@ -5,7 +5,7 @@ pluginManagement {
         maven {
             url = "https://repo.screamingsandals.org/public/"
         }
-
+        maven { url "https://maven.mrnavastar.rocks/releases" }
     }
 }