12
0

Force tinyprotocol injection #177

Zusammengeführt
Lixfel hat 1 Commits von forceInjection nach master 2022-03-05 22:12:19 +01:00 zusammengeführt
Nur Änderungen aus Commit 705aafca3a werden angezeigt - Alle Commits anzeigen

Datei anzeigen

@ -92,15 +92,18 @@ public class TinyProtocol {
@EventHandler(priority = EventPriority.LOWEST) @EventHandler(priority = EventPriority.LOWEST)
public void onPlayerLogin(PlayerLoginEvent e) { public void onPlayerLogin(PlayerLoginEvent e) {
if (closed) injectPlayerOnLogin(
return; e.getPlayer(),
() -> Bukkit.getScheduler().runTask(plugin, () -> injectPlayerOnLogin(
Channel channel = getChannel(e.getPlayer()); e.getPlayer(),
() -> Bukkit.getScheduler().runTaskLater(plugin, () -> injectPlayerOnLogin(
// Don't inject players that have been explicitly uninjected e.getPlayer(),
if (!uninjectedChannels.contains(channel)) { () -> {
injectPlayer(e.getPlayer()); //Give up
} }
), 1)
))
);
} }
@EventHandler @EventHandler
@ -130,6 +133,23 @@ public class TinyProtocol {
} }
} }
private void injectPlayerOnLogin(Player player, Runnable errorHandler) {
if (closed)
return;
try {
Channel channel = getChannel(player);
// Don't inject players that have been explicitly uninjected
if (!uninjectedChannels.contains(channel)) {
injectPlayer(player);
}
} catch (NullPointerException ex) {
Bukkit.getLogger().log(Level.WARNING, player.getName() + " without playerConnection, retrying");
errorHandler.run();
}
}
private void createServerChannelHandler() { private void createServerChannelHandler() {
// Handle connected channels // Handle connected channels
endInitProtocol = new ChannelInitializer<Channel>() { endInitProtocol = new ChannelInitializer<Channel>() {