class="kw">package com.hypixel.hytale.server.core.io.stream;

class="kw">import com.hypixel.hytale.logger.HytaleLogger;
class="kw">import com.hypixel.hytale.protocol.Packet;
class="kw">import com.hypixel.hytale.protocol.ToServerPacket;
class="kw">import com.hypixel.hytale.protocol.io.ConnectionHandler;
class="kw">import io.netty.channel.ChannelHandlerContext;
class="kw">import io.netty.channel.SimpleChannelInboundHandler;
class="kw">import java.util.logging.Level;
class="kw">import javax.annotation.Nonnull;

class="kw">public class StreamConnectionHandlerAdapter class="kw">extends SimpleChannelInboundHandler<Packet> {
   class="kw">private class="kw">static class="kw">final HytaleLogger LOGGER = HytaleLogger.forEnclosingClass();
   class="kw">private class="kw">final ConnectionHandler handler;

   class="kw">public StreamConnectionHandlerAdapter(@Nonnull ConnectionHandler var1) {
      this.handler = var1;
   }

   class="kw">public void handlerAdded(@Nonnull ChannelHandlerContext var1) class="kw">throws Exception {
      this.handler.registered(null);
      super.handlerAdded(var1);
   }

   class="kw">protected void channelRead0(@Nonnull ChannelHandlerContext var1, @Nonnull Packet var2) {
      this.handler.handle((ToServerPacket)var2);
   }

   class="kw">public void channelInactive(@Nonnull ChannelHandlerContext var1) class="kw">throws Exception {
      this.handler.closed(null);
      super.channelInactive(var1);
   }

   class="kw">public void exceptionCaught(@Nonnull ChannelHandlerContext var1, @Nonnull Throwable var2) {
      ((HytaleLogger.Api)LOGGER.at(Level.WARNING).withCause(var2)).log("Exception in stream handler adapter");
      var1.close();
   }
}