Upstream/PlayerBalancer
1
0
Fork 0
mirror of https://github.com/BGHDDevelopment/PlayerBalancer.git synced 2024-11-27 05:05:19 +01:00
Code Issues Projects Releases Wiki Activity

Locking the player on ServerKickEvent to prevent ServerConnectEvent interfering with it

Browse Source
This commit is contained in:
Jaime Martinez Rincon 2017-01-21 14:56:20 +01:00
parent d9ecff0ddd
commit 1813977049
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/me/jaimemartz/lobbybalancer/listener/ServerKickListener.java
View File

@ -5,6 +5,7 @@ import me.jaimemartz.faucet.Replacement;
import me.jaimemartz.lobbybalancer.LobbyBalancer; import me.jaimemartz.lobbybalancer.LobbyBalancer;
import me.jaimemartz.lobbybalancer.configuration.ConfigEntries; import me.jaimemartz.lobbybalancer.configuration.ConfigEntries;
import me.jaimemartz.lobbybalancer.connection.ConnectionIntent; import me.jaimemartz.lobbybalancer.connection.ConnectionIntent;
import me.jaimemartz.lobbybalancer.manager.PlayerLocker;
import me.jaimemartz.lobbybalancer.section.ServerSection; import me.jaimemartz.lobbybalancer.section.ServerSection;
import net.md_5.bungee.api.chat.TextComponent; import net.md_5.bungee.api.chat.TextComponent;
import net.md_5.bungee.api.config.ServerInfo; import net.md_5.bungee.api.config.ServerInfo;
@ -16,6 +17,7 @@ import net.md_5.bungee.event.EventHandler;
import net.md_5.bungee.event.EventPriority; import net.md_5.bungee.event.EventPriority;
import java.util.concurrent.Callable; import java.util.concurrent.Callable;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicBoolean;
public class ServerKickListener implements Listener { public class ServerKickListener implements Listener {
@ -92,12 +94,16 @@ public class ServerKickListener implements Listener {
@Override @Override
public void connect(ServerInfo server) { public void connect(ServerInfo server) {
Messager msgr = new Messager(player); Messager msgr = new Messager(player);
PlayerLocker.lock(player);
msgr.send(ConfigEntries.RECONNECT_KICK_MESSAGE.get(), msgr.send(ConfigEntries.RECONNECT_KICK_MESSAGE.get(),
new Replacement("{from}", from.getName()), new Replacement("{from}", from.getName()),
new Replacement("{to}", server.getName()), new Replacement("{to}", server.getName()),
new Replacement("{reason}", TextComponent.toPlainText(event.getKickReasonComponent()))); new Replacement("{reason}", TextComponent.toPlainText(event.getKickReasonComponent())));
event.setCancelled(true); event.setCancelled(true);
event.setCancelServer(server); event.setCancelServer(server);
plugin.getProxy().getScheduler().schedule(plugin, () -> {
PlayerLocker.unlock(player);
}, 2, TimeUnit.SECONDS);
} }
}; };
} }