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

class="kw">import com.hypixel.hytale.logger.HytaleLogger;
class="kw">import com.hypixel.hytale.protocol.Packet;
class="kw">import com.hypixel.hytale.server.core.io.PacketHandler;
class="kw">import com.hypixel.hytale.server.core.io.handlers.game.GamePacketHandler;
class="kw">import java.util.List;
class="kw">import java.util.concurrent.CopyOnWriteArrayList;
class="kw">import java.util.logging.Level;
class="kw">import javax.annotation.Nonnull;

class="kw">public class PacketAdapters {
   class="kw">private class="kw">static class="kw">final List<PacketFilter> inboundHandlers = new CopyOnWriteArrayList<>();
   class="kw">private class="kw">static class="kw">final List<PacketFilter> outboundHandlers = new CopyOnWriteArrayList<>();

   class="kw">public PacketAdapters() {
   }

   @Nonnull
   class="kw">public class="kw">static PacketFilter registerInbound(@Nonnull PacketWatcher var0) {
      PacketFilter var1 = (var1x, var2) -> {
         var0.accept(var1x, var2);
         class="kw">return false;
      };
      registerInbound(var1);
      class="kw">return var1;
   }

   class="kw">public class="kw">static void registerInbound(PacketFilter var0) {
      inboundHandlers.add(var0);
   }

   @Nonnull
   class="kw">public class="kw">static PacketFilter registerOutbound(@Nonnull PacketWatcher var0) {
      PacketFilter var1 = (var1x, var2) -> {
         var0.accept(var1x, var2);
         class="kw">return false;
      };
      registerOutbound(var1);
      class="kw">return var1;
   }

   class="kw">public class="kw">static void registerOutbound(PacketFilter var0) {
      outboundHandlers.add(var0);
   }

   @Nonnull
   class="kw">public class="kw">static PacketFilter registerInbound(@Nonnull PlayerPacketFilter var0) {
      PacketFilter var1 = (var1x, var2) -> var1x class="kw">instanceof GamePacketHandler && var0.test(((GamePacketHandler)var1x).getPlayerRef(), var2);
      registerInbound(var1);
      class="kw">return var1;
   }

   @Nonnull
   class="kw">public class="kw">static PacketFilter registerOutbound(@Nonnull PlayerPacketFilter var0) {
      PacketFilter var1 = (var1x, var2) -> var1x class="kw">instanceof GamePacketHandler && var0.test(((GamePacketHandler)var1x).getPlayerRef(), var2);
      registerOutbound(var1);
      class="kw">return var1;
   }

   @Nonnull
   class="kw">public class="kw">static PacketFilter registerInbound(@Nonnull PlayerPacketWatcher var0) {
      PacketFilter var1 = (var1x, var2) -> {
         if (var1x class="kw">instanceof GamePacketHandler) {
            var0.accept(((GamePacketHandler)var1x).getPlayerRef(), var2);
         }

         class="kw">return false;
      };
      registerInbound(var1);
      class="kw">return var1;
   }

   @Nonnull
   class="kw">public class="kw">static PacketFilter registerOutbound(@Nonnull PlayerPacketWatcher var0) {
      PacketFilter var1 = (var1x, var2) -> {
         if (var1x class="kw">instanceof GamePacketHandler) {
            var0.accept(((GamePacketHandler)var1x).getPlayerRef(), var2);
         }

         class="kw">return false;
      };
      registerOutbound(var1);
      class="kw">return var1;
   }

   class="kw">public class="kw">static void deregisterInbound(PacketFilter var0) {
      if (!inboundHandlers.remove(var0)) {
         throw new IllegalArgumentException("That handler was not registered to inbound!");
      }
   }

   class="kw">public class="kw">static void deregisterOutbound(PacketFilter var0) {
      if (!outboundHandlers.remove(var0)) {
         throw new IllegalArgumentException("That handler was not registered to outbound!");
      }
   }

   class="kw">public class="kw">static boolean __handleInbound(PacketHandler var0, Packet var1) {
      class="kw">return handle(inboundHandlers, var0, var1);
   }

   class="kw">private class="kw">static <T class="kw">extends Packet> boolean handle(@Nonnull List<PacketFilter> var0, PacketHandler var1, T var2) {
      for (int var3 = 0; var3 < var0.size(); var3++) {
         try {
            if (var0.get(var3).test(var1, var2)) {
               class="kw">return true;
            }
         } catch (Throwable var5) {
            ((HytaleLogger.Api)HytaleLogger.getLogger().at(Level.SEVERE).withCause(var5)).log("Failed to test packet %s against %s:", var2, var1);
         }
      }

      class="kw">return false;
   }

   class="kw">public class="kw">static boolean __handleOutbound(PacketHandler var0, Packet var1) {
      class="kw">return handle(outboundHandlers, var0, var1);
   }
}