package me.Danker.handlers;

import io.netty.channel.ChannelDuplexHandler;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelPromise;
import me.Danker.events.PacketReadEvent;
import me.Danker.events.PacketWriteEvent;
import net.minecraft.network.Packet;
import net.minecraftforge.common.MinecraftForge;

public class PacketHandler extends ChannelDuplexHandler {

	@Override
	public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
		if (msg instanceof Packet) {
			if (MinecraftForge.EVENT_BUS.post(new PacketReadEvent((Packet) msg))) return;
		}

		super.channelRead(ctx, msg);
	}

	@Override
	public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
		if (msg instanceof Packet) {
			if (MinecraftForge.EVENT_BUS.post(new PacketWriteEvent((Packet) msg))) return;
		}

		super.write(ctx, msg, promise);
	}
	
}