Inject packets at channel start

Author: NichtStudioCode

invui/src/main/java/xyz/xenondevs/invui/internal/menu/CustomContainerMenu.java

@@ -205,8 +205,7 @@ public void sendChangesToRemote() {
             }
         }
 
-        var bundle = new ClientboundBundlePacket(packets);
-        PacketListener.getInstance().injectOutgoing(player, bundle);
+        PacketListener.getInstance().injectOutgoing(player, packets);
     }
 
     /**

invui/src/main/java/xyz/xenondevs/invui/internal/network/ForceChannelPromise.java

@@ -0,0 +1,15 @@
+package xyz.xenondevs.invui.internal.network;
+
+import io.netty.channel.Channel;
+import io.netty.channel.DefaultChannelPromise;
+
+/**
+ * A channel promise for outgoing packets that directs {@link PacketListener} to not intercept the packet.
+ */
+class ForceChannelPromise extends DefaultChannelPromise {
+    
+    ForceChannelPromise(Channel channel) {
+        super(channel);
+    }
+    
+}

invui/src/main/java/xyz/xenondevs/invui/internal/network/PacketListener.java

@@ -48,12 +48,14 @@ public void stopDiscard(Player player, Class<? extends Packet<ClientGamePacketLi
         getPacketHandler(player.getUniqueId()).discardRules.remove(clazz);
     }
 
-    public void injectOutgoing(Player player, Packet<ClientGamePacketListener> packet) {
-        getPacketHandler(player.getUniqueId()).injectOutgoing(packet);
+    public void injectOutgoing(Player player, List<Packet<? super ClientGamePacketListener>> packets) {
+        if (packets.isEmpty())
+            return;
+        injectOutgoing(player, new ClientboundBundlePacket(packets));
     }
 
-    public void injectOutgoing(Player player, List<Packet<? super ClientGamePacketListener>> packets) {
-        getPacketHandler(player.getUniqueId()).injectOutgoing(new ClientboundBundlePacket(packets));
+    public void injectOutgoing(Player player, Packet<ClientGamePacketListener> packet) {
+        getPacketHandler(player.getUniqueId()).injectOutgoing(packet);
     }
 
     @SuppressWarnings("unchecked")
@@ -116,7 +118,7 @@ public void injectOutgoing(Packet<ClientGamePacketListener> packet) {
 
             try {
                 print(packet, "injected");
-                super.write(channel.pipeline().context(this), packet, channel.newPromise());
+                channel.writeAndFlush(packet, new ForceChannelPromise(channel));
             } catch (Exception e) {
                 throw new RuntimeException(e);
             }
@@ -125,7 +127,7 @@ public void injectOutgoing(Packet<ClientGamePacketListener> packet) {
         @SuppressWarnings("unchecked")
         @Override
         public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) {
-            if (msg instanceof Packet<?> packet) {
+            if (msg instanceof Packet<?> packet && !(promise instanceof ForceChannelPromise)) {
                 if (packet instanceof ClientboundBundlePacket bundle) {
                     var subPackets = StreamSupport.stream(bundle.subPackets().spliterator(), false)
                         .<Packet<? super ClientGamePacketListener>>map(this::singleWrite)