From d842c080ee22d44426341c48578d70579d1f1fc0 Mon Sep 17 00:00:00 2001
From: Joshua Castle <26531652+Kas-tle@users.noreply.github.com>
Date: Fri, 3 May 2024 20:10:49 -0700
Subject: [PATCH] Update network/protocol subs & more closely simulate client
 MTU decrement

Signed-off-by: Joshua Castle <26531652+Kas-tle@users.noreply.github.com>
---
 network                                                 | 2 +-
 protocol                                                | 2 +-
 src/main/java/org/cloudburstmc/proxypass/ProxyPass.java | 3 +++
 3 files changed, 5 insertions(+), 2 deletions(-)

diff --git a/network b/network
index f28b809..13ba1e5 160000
--- a/network
+++ b/network
@@ -1 +1 @@
-Subproject commit f28b80977405348e54ea38359977993385c91220
+Subproject commit 13ba1e504844878e63003ec644315e8524e2cd2f
diff --git a/protocol b/protocol
index e720fba..10ccba4 160000
--- a/protocol
+++ b/protocol
@@ -1 +1 @@
-Subproject commit e720fba064a8d38aceb35f624903847130d1fe30
+Subproject commit 10ccba419425931d2e11e2d6b9327a28f4eccd24
diff --git a/src/main/java/org/cloudburstmc/proxypass/ProxyPass.java b/src/main/java/org/cloudburstmc/proxypass/ProxyPass.java
index 21fc962..071ab8c 100644
--- a/src/main/java/org/cloudburstmc/proxypass/ProxyPass.java
+++ b/src/main/java/org/cloudburstmc/proxypass/ProxyPass.java
@@ -24,6 +24,7 @@
 import org.cloudburstmc.nbt.*;
 import org.cloudburstmc.netty.channel.raknet.RakChannelFactory;
 import org.cloudburstmc.netty.channel.raknet.config.RakChannelOption;
+import org.cloudburstmc.netty.handler.codec.raknet.server.RakServerRateLimiter;
 import org.cloudburstmc.protocol.bedrock.BedrockPeer;
 import org.cloudburstmc.protocol.bedrock.BedrockPong;
 import org.cloudburstmc.protocol.bedrock.codec.BedrockCodec;
@@ -215,6 +216,7 @@ protected void initSession(ProxyServerSession session) {
                 .bind(this.proxyAddress)
                 .awaitUninterruptibly()
                 .channel();
+        this.server.pipeline().remove(RakServerRateLimiter.NAME);
         log.info("Bedrock server started on {}", proxyAddress);
 
         loop();
@@ -226,6 +228,7 @@ public void newClient(InetSocketAddress socketAddress, Consumer<ProxyClientSessi
                 .channelFactory(RakChannelFactory.client(NioDatagramChannel.class))
                 .option(RakChannelOption.RAK_PROTOCOL_VERSION, ProxyPass.CODEC.getRaknetProtocolVersion())
                 .option(RakChannelOption.RAK_COMPATIBILITY_MODE, true)
+                .option(RakChannelOption.RAK_MTU, 1492)
                 .handler(new BedrockChannelInitializer<ProxyClientSession>() {
 
                     @Override