diff --git a/gradle/wrapper/gradle-wrapper.properties b/gradle/wrapper/gradle-wrapper.properties index ffed3a2..aa991fc 100644 --- a/gradle/wrapper/gradle-wrapper.properties +++ b/gradle/wrapper/gradle-wrapper.properties @@ -1,5 +1,5 @@ distributionBase=GRADLE_USER_HOME distributionPath=wrapper/dists -distributionUrl=https\://services.gradle.org/distributions/gradle-7.2-bin.zip +distributionUrl=https\://services.gradle.org/distributions/gradle-7.4.2-bin.zip zipStoreBase=GRADLE_USER_HOME zipStorePath=wrapper/dists diff --git a/src/main/java/org/adde0109/ambassador/Ambassador.java b/src/main/java/org/adde0109/ambassador/Ambassador.java index 8b99206..577f640 100644 --- a/src/main/java/org/adde0109/ambassador/Ambassador.java +++ b/src/main/java/org/adde0109/ambassador/Ambassador.java @@ -13,17 +13,17 @@ import com.velocitypowered.api.proxy.server.RegisteredServer; import net.kyori.adventure.text.Component; import net.kyori.adventure.text.format.NamedTextColor; -import org.adde0109.ambassador.Forge.ForgeConnection; -import org.adde0109.ambassador.Forge.ForgeHandshakeHandler; -import org.adde0109.ambassador.Forge.ForgeHandshakeUtils; -import org.adde0109.ambassador.Forge.ForgeServerConnection; +import org.adde0109.ambassador.forge.ForgeConnection; +import org.adde0109.ambassador.forge.ForgeHandshakeHandler; +import org.adde0109.ambassador.forge.ForgeHandshakeUtils; +import org.adde0109.ambassador.forge.ForgeServerConnection; import org.bstats.velocity.Metrics; import org.slf4j.Logger; import java.nio.file.Path; import java.util.*; -@Plugin(id = "ambassador", name = "Ambassador", version = "0.2.0-SNAPSHOT", url = "", description = "", authors = {"adde0109"}) +@Plugin(id = "ambassador", name = "Ambassador", version = "0.2.0-SNAPSHOT", authors = {"adde0109"}) public class Ambassador { private final ProxyServer server; @@ -47,7 +47,7 @@ public class Ambassador { @Subscribe public void onProxyInitialization(ProxyInitializeEvent event) { - Metrics metrics = metricsFactory.make(this, 15655); + metricsFactory.make(this, 15655); config = AmbassadorConfig.readOrCreateConfig(dataDirectory,server,logger); if(config != null) { diff --git a/src/main/java/org/adde0109/ambassador/AmbassadorConfig.java b/src/main/java/org/adde0109/ambassador/AmbassadorConfig.java index 3bfb033..87281ad 100644 --- a/src/main/java/org/adde0109/ambassador/AmbassadorConfig.java +++ b/src/main/java/org/adde0109/ambassador/AmbassadorConfig.java @@ -55,7 +55,7 @@ public class AmbassadorConfig { } catch (IOException e) { - logger.error("Config related error: " + e.toString()); + logger.error("Config related error: " + e); return null; } @@ -78,7 +78,7 @@ public class AmbassadorConfig { return ambassadorConfig; } catch (Exception e) { - logger.error("Config related error: " + e.toString()); + logger.error("Config related error: " + e); return null; } } @@ -115,7 +115,7 @@ public class AmbassadorConfig { if (config != null) { String serverName = config.getOrElse("forge-server", ""); if (!Objects.equals(serverName, "")) - handshakeServer = server.getServer(serverName) + handshakeServer = server.getServer(serverName) .orElseThrow(() -> new Exception(serverName + "is not a registered server!")); this.forced = config.getOrElse("forced",forced); } diff --git a/src/main/java/org/adde0109/ambassador/Forge/ForgeConnection.java b/src/main/java/org/adde0109/ambassador/forge/ForgeConnection.java similarity index 93% rename from src/main/java/org/adde0109/ambassador/Forge/ForgeConnection.java rename to src/main/java/org/adde0109/ambassador/forge/ForgeConnection.java index b19d3fb..748b999 100644 --- a/src/main/java/org/adde0109/ambassador/Forge/ForgeConnection.java +++ b/src/main/java/org/adde0109/ambassador/forge/ForgeConnection.java @@ -1,4 +1,4 @@ -package org.adde0109.ambassador.Forge; +package org.adde0109.ambassador.forge; import com.velocitypowered.api.event.Continuation; import com.velocitypowered.api.proxy.LoginPhaseConnection; @@ -22,7 +22,7 @@ public class ForgeConnection { public static CompletableFuture sync(LoginPhaseConnection connection, ForgeServerConnection forgeServerConnection, Continuation continuation) { - CompletableFuture future = new CompletableFuture(); + CompletableFuture future = new CompletableFuture<>(); ForgeConnection forgeConnection = new ForgeConnection(connection); forgeServerConnection.getHandshake().whenComplete((msg,ex) -> { if (ex != null) { @@ -53,7 +53,7 @@ public class ForgeConnection { } public CompletableFuture sendModlist(byte[] modListPacket) { - CompletableFuture future = new CompletableFuture(); + CompletableFuture future = new CompletableFuture<>(); connection.sendLoginPluginMessage(MinecraftChannelIdentifier.create("fml","loginwrapper"), modListPacket, responseBody -> { recivedClientModlist = responseBody; @@ -63,7 +63,7 @@ public class ForgeConnection { } CompletableFuture sendOther(List otherPackets) { - CompletableFuture future = new CompletableFuture(); + CompletableFuture future = new CompletableFuture<>(); for (int i = 0;i {} : responseBody -> { diff --git a/src/main/java/org/adde0109/ambassador/Forge/ForgeHandshakeHandler.java b/src/main/java/org/adde0109/ambassador/forge/ForgeHandshakeHandler.java similarity index 92% rename from src/main/java/org/adde0109/ambassador/Forge/ForgeHandshakeHandler.java rename to src/main/java/org/adde0109/ambassador/forge/ForgeHandshakeHandler.java index 7e8c416..8982d4e 100644 --- a/src/main/java/org/adde0109/ambassador/Forge/ForgeHandshakeHandler.java +++ b/src/main/java/org/adde0109/ambassador/forge/ForgeHandshakeHandler.java @@ -1,4 +1,4 @@ -package org.adde0109.ambassador.Forge; +package org.adde0109.ambassador.forge; import com.velocitypowered.api.event.Continuation; import com.velocitypowered.api.event.Subscribe; @@ -21,9 +21,9 @@ public class ForgeHandshakeHandler { private final ProxyServer server; private final Logger logger; - private Map - forgeServerConnectionMap = new HashMap(); - private Map incomingForgeConnections = new HashMap(); + private final Map + forgeServerConnectionMap = new HashMap<>(); + private final Map incomingForgeConnections = new HashMap<>(); public ForgeHandshakeHandler(AmbassadorConfig config, ProxyServer server, Logger logger) { diff --git a/src/main/java/org/adde0109/ambassador/Forge/ForgeHandshakeUtils.java b/src/main/java/org/adde0109/ambassador/forge/ForgeHandshakeUtils.java similarity index 95% rename from src/main/java/org/adde0109/ambassador/Forge/ForgeHandshakeUtils.java rename to src/main/java/org/adde0109/ambassador/forge/ForgeHandshakeUtils.java index a1a9c7d..1d63f92 100644 --- a/src/main/java/org/adde0109/ambassador/Forge/ForgeHandshakeUtils.java +++ b/src/main/java/org/adde0109/ambassador/forge/ForgeHandshakeUtils.java @@ -1,4 +1,4 @@ -package org.adde0109.ambassador.Forge; +package org.adde0109.ambassador.forge; import com.google.common.io.ByteArrayDataInput; import com.velocitypowered.api.proxy.server.RegisteredServer; @@ -60,7 +60,7 @@ public class ForgeHandshakeUtils { public static CompletableFuture downloadHandshake(RegisteredServer forgeServer) { - CompletableFuture future = new CompletableFuture(); + CompletableFuture future = new CompletableFuture<>(); forgeServer.ping().whenComplete((msg,ex) -> { if (ex != null) { future.completeExceptionally(ex); @@ -78,7 +78,7 @@ public class ForgeHandshakeUtils { } public static CompletableFuture downloadHandshake(RegisteredServer forgeServer, CachedServerHandshake oldHandshake) { - CompletableFuture future = new CompletableFuture(); + CompletableFuture future = new CompletableFuture<>(); forgeServer.ping().whenComplete((msg,ex) -> { if (ex != null) { future.completeExceptionally(ex); @@ -127,7 +127,7 @@ public class ForgeHandshakeUtils { int recivedPartNr = Integer.parseInt((pair.getVersion().split(":")[0].split("-"))[0]); placePartInArray(pair.getId().getBytes(StandardCharsets.ISO_8859_1), recivedPartNr - 1); - logger.info("Downloaded part " + String.valueOf(numberOfRecivedParts) + " out of " + String.valueOf(numberOfParts)); + logger.info("Downloaded part " + numberOfRecivedParts + " out of " + numberOfParts); } @@ -164,7 +164,7 @@ public class ForgeHandshakeUtils { } public static class CachedServerHandshake { - private long fingerprint; + private final long fingerprint; public byte[] modListPacket; public List otherPackets; diff --git a/src/main/java/org/adde0109/ambassador/Forge/ForgeServerConnection.java b/src/main/java/org/adde0109/ambassador/forge/ForgeServerConnection.java similarity index 96% rename from src/main/java/org/adde0109/ambassador/Forge/ForgeServerConnection.java rename to src/main/java/org/adde0109/ambassador/forge/ForgeServerConnection.java index b9e6df0..1d76d1b 100644 --- a/src/main/java/org/adde0109/ambassador/Forge/ForgeServerConnection.java +++ b/src/main/java/org/adde0109/ambassador/forge/ForgeServerConnection.java @@ -1,4 +1,4 @@ -package org.adde0109.ambassador.Forge; +package org.adde0109.ambassador.forge; import com.google.common.io.ByteArrayDataInput; import com.velocitypowered.api.event.Continuation; @@ -34,9 +34,7 @@ public class ForgeServerConnection { } else { future = ForgeHandshakeUtils.HandshakeReceiver.downloadHandshake(handshakeServer,handshake); } - future.thenAccept(p -> { - handshake = p; - }); + future.thenAccept(p -> handshake = p); return future; }