Created PacketHandler class to help with decoding fbs packet objects from netty channels

server/netty/src/com/riiablo/server/netty/Main.java

@@ -27,6 +27,7 @@ import com.badlogic.gdx.backends.headless.HeadlessApplicationConfiguration;
 import com.riiablo.Riiablo;
 import com.riiablo.codec.Animation;
 import com.riiablo.net.packet.netty.Header;
+import com.riiablo.net.packet.netty.Netty;
 import com.riiablo.net.packet.netty.NettyData;
 
 public class Main extends ApplicationAdapter {
@@ -72,7 +73,16 @@ public class Main extends ApplicationAdapter {
           .handler(new ChannelInitializer<DatagramChannel>() {
             @Override
             protected void initChannel(DatagramChannel ch) {
-              ch.pipeline().addLast(new EchoServerHandler());
+              ch.pipeline()
+                  .addLast(new PacketHandler() {
+                    final String TAG = "abstract PacketHandler";
+
+                    @Override
+                    protected void processPacket(ChannelHandlerContext ctx, Netty netty) {
+                      Gdx.app.debug(TAG, "Processing packet...");
+                    }
+                  })
+                  ;
             }
           })
           ;
@@ -87,8 +97,8 @@ public class Main extends ApplicationAdapter {
     }
   }
 
-  public static class EchoServerHandler extends SimpleChannelInboundHandler<DatagramPacket> {
+  public static class ServerHandler extends SimpleChannelInboundHandler<DatagramPacket> {
-    EchoServerHandler() {
+    ServerHandler() {
       super(false);
     }
 

server/netty/src/com/riiablo/server/netty/PacketHandler.java

@@ -0,0 +1,128 @@
+package com.riiablo.server.netty;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.ChannelInboundHandler;
+import io.netty.channel.socket.DatagramPacket;
+import io.netty.util.ReferenceCountUtil;
+import io.netty.util.internal.TypeParameterMatcher;
+import java.net.InetSocketAddress;
+import java.nio.ByteBuffer;
+
+import com.badlogic.gdx.Gdx;
+
+import com.riiablo.net.packet.netty.Header;
+import com.riiablo.net.packet.netty.Netty;
+import com.riiablo.net.packet.netty.NettyData;
+
+public abstract class PacketHandler implements ChannelInboundHandler {
+  private static final String TAG = "PacketHandler";
+
+  private final TypeParameterMatcher matcher;
+
+  PacketHandler() {
+    matcher = TypeParameterMatcher.get(DatagramPacket.class);
+  }
+
+  protected boolean acceptInboundMessage(Object msg) throws Exception {
+    return matcher.match(msg);
+  }
+
+  protected void channelRead0(ChannelHandlerContext ctx, DatagramPacket msg) throws Exception {
+    InetSocketAddress sender = msg.sender();
+    Gdx.app.log(TAG, "channelRead0 Packet from " + sender.getHostName() + ":" + sender.getPort());
+    ByteBuf in = msg.content();
+    try {
+      ByteBuffer buffer = in.nioBuffer();
+      Packet packet = Packet.obtain(0, buffer);
+      Gdx.app.log(TAG, "  " + NettyData.name(packet.data.dataType()));
+      processHeader(ctx, packet.data.header());
+      processPacket(ctx, packet.data);
+    } finally {
+//      in.release(); // Automatically released by channelRead() right now
+    }
+  }
+
+  protected void processHeader(ChannelHandlerContext ctx, Header header) throws Exception {
+    Gdx.app.log(TAG, "  " + String.format("SEQ:%d ACK:%d ACK_BITS:%08x", header.sequence(), header.ack(), header.ackBits()));
+  }
+
+  protected abstract void processPacket(ChannelHandlerContext ctx, Netty netty) throws Exception;
+
+  @Override
+  public void channelRegistered(ChannelHandlerContext ctx) throws Exception {
+    Gdx.app.debug(TAG, "channelRegistered");
+    ctx.fireChannelRegistered();
+  }
+
+  @Override
+  public void channelUnregistered(ChannelHandlerContext ctx) throws Exception {
+    Gdx.app.debug(TAG, "channelUnregistered");
+    ctx.fireChannelUnregistered();
+  }
+
+  @Override
+  public void channelActive(ChannelHandlerContext ctx) throws Exception {
+    Gdx.app.debug(TAG, "channelActive");
+    ctx.fireChannelActive();
+  }
+
+  @Override
+  public void channelInactive(ChannelHandlerContext ctx) throws Exception {
+    Gdx.app.debug(TAG, "channelInactive");
+    ctx.fireChannelInactive();
+  }
+
+  @Override
+  public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+    Gdx.app.debug(TAG, "channelRead");
+    boolean release = true;
+    try {
+      if (acceptInboundMessage(msg)) {
+        DatagramPacket imsg = (DatagramPacket) msg;
+        channelRead0(ctx, imsg);
+      } else {
+        release = false;
+        ctx.fireChannelRead(msg);
+      }
+    } finally {
+      if (release) ReferenceCountUtil.release(msg);
+    }
+  }
+
+  @Override
+  public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
+    Gdx.app.debug(TAG, "channelReadComplete");
+    ctx.fireChannelReadComplete();
+  }
+
+  @Override
+  public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
+    Gdx.app.debug(TAG, "userEventTriggered");
+    ctx.fireUserEventTriggered(evt);
+  }
+
+  @Override
+  public void channelWritabilityChanged(ChannelHandlerContext ctx) throws Exception {
+    Gdx.app.debug(TAG, "channelWritabilityChanged");
+    ctx.fireChannelWritabilityChanged();
+  }
+
+  @Override
+  public void handlerAdded(ChannelHandlerContext ctx) throws Exception {
+    Gdx.app.debug(TAG, "handlerAdded");
+
+  }
+
+  @Override
+  public void handlerRemoved(ChannelHandlerContext ctx) throws Exception {
+    Gdx.app.debug(TAG, "handlerRemoved");
+
+  }
+
+  @Override
+  public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
+    Gdx.app.debug(TAG, "exceptionCaught");
+    ctx.fireExceptionCaught(cause);
+  }
+}