GeyserMC/Geyser
GeyserMC/Geyser
4
4
Fork 3
mirror of https://github.com/GeyserMC/Geyser.git synced 2024-08-14 23:57:35 +00:00
Code Issues 103 Projects Releases Wiki Activity

п

Browse source
This commit is contained in:
OurLobanov 2024-06-26 20:40:14 +03:00
parent ac51ec1bc6
commit c682c5a7b0
2 changed files with 6 additions and 26 deletions
Download patch file Download diff file Expand all files Collapse all files

12
core/src/main/java/org/geysermc/geyser/network/LoggingPacketHandler.java
View file

@ -47,18 +47,8 @@ public class LoggingPacketHandler implements BedrockPacketHandler {
this.cooldownHandler = new PacketCooldownManager(session);
}
public boolean handleLimit(BedrockPacket packet) {
boolean safePacket = this.cooldownHandler.handle(packet);
if (!safePacket) {
session.disconnect("many Packets " + packet.getClass().getSimpleName());
}
return !safePacket;
}
PacketSignal defaultHandler(BedrockPacket packet) {
if (handleLimit(packet)) {
return PacketSignal.HANDLED;
}
this.cooldownHandler.handle(packet);
geyser.getLogger().debug("Handled packet: " + packet.getClass().getSimpleName());
return PacketSignal.HANDLED;
}

20
core/src/main/java/org/geysermc/geyser/network/UpstreamPacketHandler.java
View file

@ -85,9 +85,7 @@ public class UpstreamPacketHandler extends LoggingPacketHandler {
@Override
PacketSignal defaultHandler(BedrockPacket packet) {
if (handleLimit(packet)) {
return PacketSignal.HANDLED;
}
this.cooldownHandler.handle(packet);
return translateAndDefault(packet);
}
@ -156,9 +154,7 @@ public class UpstreamPacketHandler extends LoggingPacketHandler {
@Override
public PacketSignal handle(LoginPacket loginPacket) {
if(this.handleLimit(loginPacket)){
return PacketSignal.HANDLED;
}
this.cooldownHandler.handle(loginPacket);
if (geyser.isShuttingDown() || geyser.isReloading()) {
// Don't allow new players in if we're no longer operating
session.disconnect(GeyserLocale.getLocaleStringLog("geyser.core.shutdown.kick.message"));
@ -210,9 +206,7 @@ public class UpstreamPacketHandler extends LoggingPacketHandler {
@Override
public PacketSignal handle(ResourcePackClientResponsePacket packet) {
if (this.handleLimit(packet)) {
return PacketSignal.HANDLED;
}
this.cooldownHandler.handle(packet);
if (packet.getPackIds().size() > this.resourcePackLoadEvent.getPacks().size()) {
session.disconnect("Packet " + packet.getClass().getSimpleName() + " PackIds max count");
return PacketSignal.HANDLED;
@ -281,9 +275,7 @@ public class UpstreamPacketHandler extends LoggingPacketHandler {
@Override
public PacketSignal handle(ModalFormResponsePacket packet) {
if(this.handleLimit(packet)){
return PacketSignal.HANDLED;
}
this.cooldownHandler.handle(packet);
session.executeInEventLoop(() -> session.getFormCache().handleResponse(packet));
return PacketSignal.HANDLED;
}
@ -324,9 +316,7 @@ public class UpstreamPacketHandler extends LoggingPacketHandler {
@Override
public PacketSignal handle(ResourcePackChunkRequestPacket packet) {
if (this.handleLimit(packet)) {
return PacketSignal.HANDLED;
}
this.cooldownHandler.handle(packet);
ResourcePackChunkDataPacket data = new ResourcePackChunkDataPacket();
ResourcePack pack = this.resourcePackLoadEvent.getPacks().get(packet.getPackId().toString());
if (pack == null) {