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

class="kw">import com.hypixel.hytale.protocol.ToServerPacket;
class="kw">import com.hypixel.hytale.protocol.io.ChannelConnection;
class="kw">import com.hypixel.hytale.server.core.io.PacketHandler;
class="kw">import com.hypixel.hytale.server.core.io.ProtocolVersion;
class="kw">import it.unimi.dsi.fastutil.objects.ObjectArrayList;
class="kw">import java.util.List;
class="kw">import java.util.function.Consumer;
class="kw">import javax.annotation.Nonnull;
class="kw">import javax.annotation.Nullable;

class="kw">public class="kw">abstract class GenericPacketHandler class="kw">extends PacketHandler {
   class="kw">private class="kw">static class="kw">final Consumer<ToServerPacket> EMPTY_CONSUMER = var0 -> {};
   @Nonnull
   class="kw">protected class="kw">final List<SubPacketHandler> packetHandlers = new ObjectArrayList();
   class="kw">private Consumer<ToServerPacket>[] handlers = newHandlerArray(0);

   @Nonnull
   class="kw">public class="kw">static Consumer<ToServerPacket>[] newHandlerArray(int var0) {
      class="kw">return new Consumer[var0];
   }

   class="kw">public GenericPacketHandler(@Nonnull ChannelConnection var1, @Nonnull ProtocolVersion var2) {
      super(var1, var2);
   }

   class="kw">public void registerSubPacketHandler(SubPacketHandler var1) {
      this.packetHandlers.add(var1);
   }

   @Nullable
   class="kw">public <T class="kw">extends SubPacketHandler> T getSubPacketHandler(@Nonnull Class<T> var1) {
      for (SubPacketHandler var3 : this.packetHandlers) {
         if (var1.isInstance(var3)) {
            class="kw">return var1.cast(var3);
         }
      }

      class="kw">return null;
   }

   class="kw">public void registerHandler(int var1, @Nonnull Consumer<ToServerPacket> var2) {
      if (var1 >= this.handlers.length) {
         Consumer[] var3 = newHandlerArray(var1 + 1);
         System.arraycopy(this.handlers, 0, var3, 0, this.handlers.length);
         this.handlers = var3;
      }

      this.handlers[var1] = var2;
   }

   class="kw">public void registerNoOpHandlers(@Nonnull int... var1) {
      for (int var5 : var1) {
         this.registerHandler(var5, EMPTY_CONSUMER);
      }
   }

   @Override
   class="kw">public class="kw">final void accept(@Nonnull ToServerPacket var1) {
      int var2 = var1.getId();
      Consumer var3 = this.handlers.length > var2 ? this.handlers[var2] : null;
      if (var3 != null) {
         try {
            var3.accept(var1);
         } catch (Throwable var5) {
            throw new RuntimeException("Could not handle packet (" + var2 + "): " + var1, var5);
         }
      } else {
         throw new RuntimeException("No handler is registered for (" + var2 + "): " + var1);
      }
   }
}