Upstream/Minestom
1
0
Fork 0
mirror of https://github.com/Minestom/Minestom.git synced 2024-09-28 14:37:31 +02:00
Code Issues Projects Releases Wiki Activity

KeepAliveListener cleanup

Browse Source 
Signed-off-by: TheMode <themode@outlook.fr>
This commit is contained in:
TheMode 2021-10-10 03:29:51 +02:00
parent 6e16fb7b13
commit 022ec237ba
1 changed files with 5 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/main/java/net/minestom/server/listener/KeepAliveListener.java
View File

@ -5,21 +5,18 @@ import net.kyori.adventure.text.format.NamedTextColor;
import net.minestom.server.entity.Player; import net.minestom.server.entity.Player;
import net.minestom.server.network.packet.client.play.ClientKeepAlivePacket; import net.minestom.server.network.packet.client.play.ClientKeepAlivePacket;
public class KeepAliveListener { public final class KeepAliveListener {
private static final Component KICK_MESSAGE = Component.text("Bad Keep Alive packet", NamedTextColor.RED);
public static void listener(ClientKeepAlivePacket packet, Player player) { public static void listener(ClientKeepAlivePacket packet, Player player) {
final long packetId = packet.id; final long packetId = packet.id;
final long playerId = player.getLastKeepAlive(); if (packetId != player.getLastKeepAlive()) {
final boolean equals = packetId == playerId; player.kick(KICK_MESSAGE);
if (!equals) {
player.kick(Component.text("Bad Keep Alive packet", NamedTextColor.RED));
return; return;
} }
player.refreshAnswerKeepAlive(true); player.refreshAnswerKeepAlive(true);
// Update latency // Update latency
final int latency = (int) (System.currentTimeMillis() - packet.id); final int latency = (int) (System.currentTimeMillis() - packetId);
player.refreshLatency(latency); player.refreshLatency(latency);
} }
} }