fixed disconnection packet

Author: Andcool-Systems

src/main/java/com/andcool/OAuthServer.java

@@ -58,9 +58,7 @@ public static void main(String[] args) throws Exception {
                         public void initChannel(SocketChannel ch) {
                             ch.pipeline()
                                     .addLast(new SessionHandler())
-                                    .addLast("encryption", NoopHandler.INSTANCE)
-                                    .addLast(new LengthFieldBasedFrameDecoder(8192, 0, 4, 0, 4))
-                                    .addLast(new LengthFieldPrepender(4));
+                                    .addLast("encryption", NoopHandler.INSTANCE);
                         }
                     });
 

src/main/java/com/andcool/bytebuf/ByteBufUtils.java

@@ -63,4 +63,12 @@ public static void sendPacket(ChannelHandlerContext ctx, ByteBuf data) {
             data.release();
         }
     }
+
+    public static ByteBuf addSize(ChannelHandlerContext ctx, ByteBuf data) {
+        ByteBuf packet = ctx.alloc().buffer();
+        ByteBufUtils.writeVarInt(packet, data.readableBytes());
+        packet.writeBytes(data);
+
+        return packet;
+    }
 }

src/main/java/com/andcool/session/SessionHandler.java

@@ -87,6 +87,7 @@ public static void disconnect(ChannelHandlerContext ctx, String reason) throws I
         response.put("text", "");
         response.put("extra", OAuthServer.MOTD_FORMATTER.format(reason));
         ByteBufUtils.writeUTF8(out, response.toString());
-        ctx.channel().writeAndFlush(out).addListener(ChannelFutureListener.CLOSE);
+        ByteBuf packet = ByteBufUtils.addSize(ctx, out);
+        ctx.channel().writeAndFlush(packet).addListener(ChannelFutureListener.CLOSE);
     }
 }