Increase the maximum size of PacketBuf to 1 MB

DancingSnow0517 · Feb 4, 2023 · 3ad4503 · 3ad4503
1 parent 62e2ddc
commit 3ad4503
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 8 deletions.
diff --git a/src/main/java/cn/dancingsnow/mcdrc/client/MCDRCommandClient.java b/src/main/java/cn/dancingsnow/mcdrc/client/MCDRCommandClient.java
@@ -15,23 +15,22 @@
 
 import java.util.ArrayList;
 import java.util.Collection;
-import java.util.Optional;
 
 @Environment(EnvType.CLIENT)
 public class MCDRCommandClient implements ClientModInitializer {
     public static final String MOD_ID = "mcdrc";
     public static final Gson GSON = new GsonBuilder().disableHtmlEscaping().create();
     public static Logger LOGGER = LogManager.getLogger();
 
-    public static Optional<NodeData> nodeData = Optional.empty();
+    public static NodeData nodeData = null;
 
 
     @Override
     public void onInitializeClient() {
 
         ClientPlayNetworking.registerGlobalReceiver(CommandNetwork.COMMAND_PACKET_ID, ((client, handler, buf, responseSender) -> {
             try {
-                nodeData = Optional.ofNullable(GSON.fromJson(buf.readString(), NodeData.class));
+                nodeData = GSON.fromJson(buf.readString(1 << 20), NodeData.class);
             } catch (Exception e) {
                 e.printStackTrace();
                 LOGGER.error("fail to receiver command packet: ", e);
@@ -41,18 +40,18 @@ public void onInitializeClient() {
     }
 
     public static Collection<String> getSuggestion(String text) {
-        if (nodeData.isPresent()) {
+        if (nodeData != null) {
             Collection<String> rt = new ArrayList<>();
             String[] args = text.split(" ");
             int word = args.length;
             if (word == 1 && !text.endsWith(" ")) {
-                for (Node node : nodeData.get().data) {
+                for (Node node : nodeData.data) {
                     if (node.type.equals(NodeType.LITERAL)) rt.add(node.name);
                 }
                 return rt;
             } else {
                 Node currNode = null;
-                for (Node node : nodeData.get().data) {
+                for (Node node : nodeData.data) {
                     if (node.name.equalsIgnoreCase(args[0])) {
                         currNode = node;
                     }

diff --git a/src/main/java/cn/dancingsnow/mcdrc/networking/CommandNetwork.java b/src/main/java/cn/dancingsnow/mcdrc/networking/CommandNetwork.java
@@ -1,7 +1,6 @@
 package cn.dancingsnow.mcdrc.networking;
 
 import cn.dancingsnow.mcdrc.client.MCDRCommandClient;
-
 import cn.dancingsnow.mcdrc.command.NodeData;
 import cn.dancingsnow.mcdrc.server.MCDRCommandServer;
 import net.fabricmc.fabric.api.networking.v1.PacketByteBufs;
@@ -16,7 +15,7 @@ public class CommandNetwork {
 
     public static void sendNodeDataToClient(ServerPlayNetworkHandler handler, NodeData nodeData) {
         PacketByteBuf buf = PacketByteBufs.create();
-        buf.writeString(MCDRCommandServer.GSON.toJson(nodeData));
+        buf.writeString(MCDRCommandServer.GSON.toJson(nodeData), 1 << 20);
         ServerPlayNetworking.getSender(handler).sendPacket(COMMAND_PACKET_ID, buf);
     }