PacketRepository.java

package com.osroyale.net.packet;
 
import com.google.common.base.Preconditions;
import com.osroyale.game.world.entity.mob.player.Player;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
 
import javax.annotation.Nullable;

 
public final class PacketRepository {
 
    private static final Logger logger = LogManager.getLogger(PacketRepository.class);

    private static final int MAX_CLIENT_PACKETS = 257;

    private static final PacketListener[] packetListeners = new PacketListener[MAX_CLIENT_PACKETS];

    private static final int[] packetTypes = new int[MAX_CLIENT_PACKETS];
 
    public static void sendToListener(Player player, GamePacket packet) {
        final PacketListener listener = packetListeners[packet.getOpcode()];
        if (listener != null) {
            if (packet.getOpcode() != 0) {
                //logger.info("Packet recv Opcode: {} Player name: {} Size: {}", packet.getOpcode(), player.getUsername(), packet.getSize());
            }
            listener.handlePacket(player, packet);
        }
    }

    public static void registerListener(int opcode, PacketListener listener) {
        Preconditions.checkArgument(opcode >= 0 && opcode < packetListeners.length);
        packetListeners[opcode] = listener;
    }

    @Nullable
    public static PacketListener lookupListener(final int opcode) {
        final PacketListener[] packetListeners = PacketRepository.packetListeners;
        if (opcode < 0 || opcode >= packetListeners.length) {
            return null;
        }
        return packetListeners[opcode];
    }

    public static PacketType lookupType(int opcode) {
        if (opcode < 0 || opcode >= packetTypes.length) {
            return PacketType.EMPTY;
        }
 
        final int size = packetTypes[opcode];
 
        if (size == -2) {
            return PacketType.VAR_SHORT;
        } else if (size == -1) {
            return PacketType.VAR_BYTE;
        } else if (size > 0) {
            return PacketType.FIXED;
        } else {
            return PacketType.EMPTY;
        }
    }

    public static int lookupSize(int opcode) {
        if (opcode < 0 || opcode >= packetTypes.length) {
            return 0;
        }
        return packetTypes[opcode];
    }

    public static void registerType(int opcode, int type) {
        Preconditions.checkArgument(opcode >= 0 && opcode < packetListeners.length);
        packetTypes[opcode] = type;
    }
 
}