diff --git a/src/main/java/com/moulberry/axiom/VersionHelper.java b/src/main/java/com/moulberry/axiom/VersionHelper.java new file mode 100644 index 0000000..2729968 --- /dev/null +++ b/src/main/java/com/moulberry/axiom/VersionHelper.java @@ -0,0 +1,14 @@ +package com.moulberry.axiom; + +import com.moulberry.axiom.packet.CustomByteArrayPayload; +import net.minecraft.network.protocol.common.ClientboundCustomPayloadPacket; +import net.minecraft.resources.ResourceLocation; +import net.minecraft.server.level.ServerPlayer; + +public class VersionHelper { + + public static void sendCustomPayload(ServerPlayer serverPlayer, ResourceLocation id, byte[] data) { + serverPlayer.connection.send(new ClientboundCustomPayloadPacket(new CustomByteArrayPayload(id, data))); + } + +} diff --git a/src/main/java/com/moulberry/axiom/blueprint/ServerBlueprintManager.java b/src/main/java/com/moulberry/axiom/blueprint/ServerBlueprintManager.java index 6d5bf87..daec893 100644 --- a/src/main/java/com/moulberry/axiom/blueprint/ServerBlueprintManager.java +++ b/src/main/java/com/moulberry/axiom/blueprint/ServerBlueprintManager.java @@ -1,10 +1,9 @@ package com.moulberry.axiom.blueprint; import com.moulberry.axiom.AxiomPaper; -import com.moulberry.axiom.packet.CustomByteArrayPayload; +import com.moulberry.axiom.VersionHelper; import io.netty.buffer.Unpooled; import net.minecraft.network.FriendlyByteBuf; -import net.minecraft.network.protocol.common.ClientboundCustomPayloadPacket; import net.minecraft.resources.ResourceLocation; import net.minecraft.server.level.ServerPlayer; import org.bukkit.craftbukkit.v1_20_R3.entity.CraftPlayer; @@ -55,9 +54,8 @@ public class ServerBlueprintManager { buf.writeUtf(""); byte[] bytes = new byte[buf.writerIndex()]; buf.getBytes(0, bytes); - var payload = new CustomByteArrayPayload(PACKET_BLUEPRINT_MANIFEST_IDENTIFIER, bytes); for (ServerPlayer serverPlayer : sendTo) { - serverPlayer.connection.send(new ClientboundCustomPayloadPacket(payload)); + VersionHelper.sendCustomPayload(serverPlayer, PACKET_BLUEPRINT_MANIFEST_IDENTIFIER, bytes); } // Continue @@ -69,9 +67,8 @@ public class ServerBlueprintManager { buf.writeUtf(""); byte[] bytes = new byte[buf.writerIndex()]; buf.getBytes(0, bytes); - var payload = new CustomByteArrayPayload(PACKET_BLUEPRINT_MANIFEST_IDENTIFIER, bytes); for (ServerPlayer serverPlayer : sendTo) { - serverPlayer.connection.send(new ClientboundCustomPayloadPacket(payload)); + VersionHelper.sendCustomPayload(serverPlayer, PACKET_BLUEPRINT_MANIFEST_IDENTIFIER, bytes); } } } diff --git a/src/main/java/com/moulberry/axiom/packet/BlueprintRequestPacketListener.java b/src/main/java/com/moulberry/axiom/packet/BlueprintRequestPacketListener.java index 991ef19..10dc711 100644 --- a/src/main/java/com/moulberry/axiom/packet/BlueprintRequestPacketListener.java +++ b/src/main/java/com/moulberry/axiom/packet/BlueprintRequestPacketListener.java @@ -1,6 +1,7 @@ package com.moulberry.axiom.packet; import com.moulberry.axiom.AxiomPaper; +import com.moulberry.axiom.VersionHelper; import com.moulberry.axiom.blueprint.RawBlueprint; import com.moulberry.axiom.blueprint.ServerBlueprintManager; import com.moulberry.axiom.blueprint.ServerBlueprintRegistry; @@ -54,8 +55,7 @@ public class BlueprintRequestPacketListener implements PluginMessageListener { byte[] bytes = new byte[buf.writerIndex()]; buf.getBytes(0, bytes); - var payload = new CustomByteArrayPayload(RESPONSE_PACKET_IDENTIFIER, bytes); - ((CraftPlayer)player).getHandle().connection.send(new ClientboundCustomPayloadPacket(payload)); + VersionHelper.sendCustomPayload(((CraftPlayer)player).getHandle(), RESPONSE_PACKET_IDENTIFIER, bytes); } } diff --git a/src/main/java/com/moulberry/axiom/packet/RequestChunkDataPacketListener.java b/src/main/java/com/moulberry/axiom/packet/RequestChunkDataPacketListener.java index db44993..3132625 100644 --- a/src/main/java/com/moulberry/axiom/packet/RequestChunkDataPacketListener.java +++ b/src/main/java/com/moulberry/axiom/packet/RequestChunkDataPacketListener.java @@ -2,6 +2,7 @@ package com.moulberry.axiom.packet; import com.moulberry.axiom.AxiomConstants; import com.moulberry.axiom.AxiomPaper; +import com.moulberry.axiom.VersionHelper; import com.moulberry.axiom.buffer.CompressedBlockEntity; import com.moulberry.axiom.event.AxiomModifyWorldEvent; import com.moulberry.axiom.integration.plotsquared.PlotSquaredIntegration; @@ -179,7 +180,7 @@ public class RequestChunkDataPacketListener implements PluginMessageListener { buf.writeBoolean(false); byte[] bytes = new byte[buf.writerIndex()]; buf.getBytes(0, bytes); - player.connection.send(new ClientboundCustomPayloadPacket(new CustomByteArrayPayload(RESPONSE_ID, bytes))); + VersionHelper.sendCustomPayload(player, RESPONSE_ID, bytes); // Continuation packet buf = new FriendlyByteBuf(Unpooled.buffer()); @@ -199,7 +200,7 @@ public class RequestChunkDataPacketListener implements PluginMessageListener { buf.writeBoolean(false); byte[] bytes = new byte[buf.writerIndex()]; buf.getBytes(0, bytes); - player.connection.send(new ClientboundCustomPayloadPacket(new CustomByteArrayPayload(RESPONSE_ID, bytes))); + VersionHelper.sendCustomPayload(player, RESPONSE_ID, bytes); // Continuation packet buf = new FriendlyByteBuf(Unpooled.buffer()); @@ -235,7 +236,7 @@ public class RequestChunkDataPacketListener implements PluginMessageListener { buf.writeBoolean(false); byte[] bytes = new byte[buf.writerIndex()]; buf.getBytes(0, bytes); - player.connection.send(new ClientboundCustomPayloadPacket(new CustomByteArrayPayload(RESPONSE_ID, bytes))); + VersionHelper.sendCustomPayload(player, RESPONSE_ID, bytes); // Continuation packet buf = new FriendlyByteBuf(Unpooled.buffer()); @@ -255,7 +256,7 @@ public class RequestChunkDataPacketListener implements PluginMessageListener { buf.writeBoolean(false); byte[] bytes = new byte[buf.writerIndex()]; buf.getBytes(0, bytes); - player.connection.send(new ClientboundCustomPayloadPacket(new CustomByteArrayPayload(RESPONSE_ID, bytes))); + VersionHelper.sendCustomPayload(player, RESPONSE_ID, bytes); // Continuation packet buf = new FriendlyByteBuf(Unpooled.buffer()); @@ -275,7 +276,7 @@ public class RequestChunkDataPacketListener implements PluginMessageListener { buf.writeBoolean(true); byte[] bytes = new byte[buf.writerIndex()]; buf.getBytes(0, bytes); - player.connection.send(new ClientboundCustomPayloadPacket(new CustomByteArrayPayload(RESPONSE_ID, bytes))); + VersionHelper.sendCustomPayload(player, RESPONSE_ID, bytes); } private void sendEmptyResponse(ServerPlayer player, long id) { @@ -287,7 +288,7 @@ public class RequestChunkDataPacketListener implements PluginMessageListener { byte[] bytes = new byte[buf.writerIndex()]; buf.getBytes(0, bytes); - player.connection.send(new ClientboundCustomPayloadPacket(new CustomByteArrayPayload(RESPONSE_ID, bytes))); + VersionHelper.sendCustomPayload(player, RESPONSE_ID, bytes); } }