diff --git a/bukkit/pom.xml b/bukkit/pom.xml index 63b54ca4..13621414 100644 --- a/bukkit/pom.xml +++ b/bukkit/pom.xml @@ -20,7 +20,7 @@ org.apache.maven.plugins maven-shade-plugin - 3.1.0 + 3.1.1 false false diff --git a/bukkit/src/main/java/com/github/games647/fastlogin/bukkit/FastLoginBukkit.java b/bukkit/src/main/java/com/github/games647/fastlogin/bukkit/FastLoginBukkit.java index 4a1cccfc..25c9a42d 100644 --- a/bukkit/src/main/java/com/github/games647/fastlogin/bukkit/FastLoginBukkit.java +++ b/bukkit/src/main/java/com/github/games647/fastlogin/bukkit/FastLoginBukkit.java @@ -11,6 +11,7 @@ import com.github.games647.fastlogin.bukkit.task.DelayedAuthHook; import com.github.games647.fastlogin.core.CommonUtil; import com.github.games647.fastlogin.core.PremiumStatus; import com.github.games647.fastlogin.core.message.ChannelMessage; +import com.github.games647.fastlogin.core.message.LoginActionMessage; import com.github.games647.fastlogin.core.shared.FastLoginCore; import com.github.games647.fastlogin.core.shared.PlatformPlugin; import com.google.common.io.ByteArrayDataOutput; @@ -29,6 +30,9 @@ import org.bukkit.plugin.java.JavaPlugin; import org.bukkit.plugin.messaging.PluginMessageRecipient; import org.slf4j.Logger; +import static com.github.games647.fastlogin.core.message.ChangePremiumMessage.CHANGE_CHANNEL; +import static com.github.games647.fastlogin.core.message.SuccessMessage.SUCCESS_CHANNEL; + /** * This plugin checks if a player has a paid account and if so tries to skip offline mode authentication. */ @@ -66,9 +70,13 @@ public class FastLoginBukkit extends JavaPlugin implements PlatformPlugin org.apache.maven.plugins maven-shade-plugin - 3.1.0 + 3.1.1 false false diff --git a/bungee/src/main/java/com/github/games647/fastlogin/bungee/FastLoginBungee.java b/bungee/src/main/java/com/github/games647/fastlogin/bungee/FastLoginBungee.java index a7caa528..e4cbf02a 100644 --- a/bungee/src/main/java/com/github/games647/fastlogin/bungee/FastLoginBungee.java +++ b/bungee/src/main/java/com/github/games647/fastlogin/bungee/FastLoginBungee.java @@ -4,7 +4,9 @@ import com.github.games647.fastlogin.bungee.hook.BungeeAuthHook; import com.github.games647.fastlogin.bungee.listener.ConnectListener; import com.github.games647.fastlogin.bungee.listener.MessageListener; import com.github.games647.fastlogin.core.CommonUtil; +import com.github.games647.fastlogin.core.message.ChangePremiumMessage; import com.github.games647.fastlogin.core.message.ChannelMessage; +import com.github.games647.fastlogin.core.message.SuccessMessage; import com.github.games647.fastlogin.core.shared.FastLoginCore; import com.github.games647.fastlogin.core.shared.PlatformPlugin; import com.google.common.collect.MapMaker; @@ -50,8 +52,9 @@ public class FastLoginBungee extends Plugin implements PlatformPlugin readMessage(forPlayer, data)); + ProxyServer.getInstance().getScheduler().runAsync(plugin, () -> readMessage(forPlayer, channel, data)); } - private void readMessage(ProxiedPlayer forPlayer, byte[] data) { + private void readMessage(ProxiedPlayer forPlayer, String channel, byte[] data) { FastLoginCore core = plugin.getCore(); ByteArrayDataInput dataInput = ByteStreams.newDataInput(data); - String subChannel = dataInput.readUTF(); - if ("Success".equals(subChannel)) { + if (successChannel.equals(channel)) { onSuccessMessage(forPlayer); - } else if ("ChangeStatus".equals(subChannel)) { + } else if (changeChannel.equals(channel)) { ChangePremiumMessage changeMessage = new ChangePremiumMessage(); changeMessage.readFrom(dataInput); diff --git a/core/src/main/java/com/github/games647/fastlogin/core/message/ChangePremiumMessage.java b/core/src/main/java/com/github/games647/fastlogin/core/message/ChangePremiumMessage.java index 9851163a..f9bdedfa 100644 --- a/core/src/main/java/com/github/games647/fastlogin/core/message/ChangePremiumMessage.java +++ b/core/src/main/java/com/github/games647/fastlogin/core/message/ChangePremiumMessage.java @@ -5,6 +5,8 @@ import com.google.common.io.ByteArrayDataOutput; public class ChangePremiumMessage implements ChannelMessage { + public static final String CHANGE_CHANNEL = "ChStatus"; + private String playerName; private boolean willEnable; private boolean isSourceInvoker; @@ -33,7 +35,7 @@ public class ChangePremiumMessage implements ChannelMessage { @Override public String getChannelName() { - return "ChangeStatus"; + return CHANGE_CHANNEL; } @Override diff --git a/core/src/main/java/com/github/games647/fastlogin/core/message/LoginActionMessage.java b/core/src/main/java/com/github/games647/fastlogin/core/message/LoginActionMessage.java index 8f679d94..b29523ca 100644 --- a/core/src/main/java/com/github/games647/fastlogin/core/message/LoginActionMessage.java +++ b/core/src/main/java/com/github/games647/fastlogin/core/message/LoginActionMessage.java @@ -7,6 +7,8 @@ import java.util.UUID; public class LoginActionMessage implements ChannelMessage { + public static final String FORCE_CHANNEL = "ForceAct"; + private Type type; private String playerName; @@ -60,7 +62,7 @@ public class LoginActionMessage implements ChannelMessage { @Override public String getChannelName() { - return "LoginAction"; + return FORCE_CHANNEL; } @Override diff --git a/core/src/main/java/com/github/games647/fastlogin/core/message/SuccessMessage.java b/core/src/main/java/com/github/games647/fastlogin/core/message/SuccessMessage.java index 250130a8..bafceec5 100644 --- a/core/src/main/java/com/github/games647/fastlogin/core/message/SuccessMessage.java +++ b/core/src/main/java/com/github/games647/fastlogin/core/message/SuccessMessage.java @@ -5,9 +5,11 @@ import com.google.common.io.ByteArrayDataOutput; public class SuccessMessage implements ChannelMessage { + public static final String SUCCESS_CHANNEL = "Success"; + @Override public String getChannelName() { - return "Success"; + return SUCCESS_CHANNEL; } @Override