forked from stefatorus/LagAssist
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
44 lines
1.0 KiB
44 lines
1.0 KiB
package cx.sfy.LagAssist.packets;
|
|
|
|
import org.bukkit.entity.Player;
|
|
|
|
import cx.sfy.LagAssist.client.ClientPacket;
|
|
import cx.sfy.LagAssist.safety.SafetyAnticrash;
|
|
import io.netty.channel.ChannelDuplexHandler;
|
|
import io.netty.channel.ChannelHandlerContext;
|
|
import io.netty.channel.ChannelPromise;
|
|
|
|
public class PacketHandler extends ChannelDuplexHandler {
|
|
private Player p;
|
|
|
|
public PacketHandler(final Player p) {
|
|
this.p = p;
|
|
}
|
|
|
|
// OUTPUT MANGLER
|
|
@Override
|
|
public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
|
|
if (SafetyAnticrash.isDropped(ctx.channel())) {
|
|
return;
|
|
}
|
|
|
|
if (ClientPacket.hidePacket(p, ctx, msg, promise)) {
|
|
return;
|
|
}
|
|
super.write(ctx, msg, promise);
|
|
}
|
|
|
|
// INPUT MANGLER
|
|
@Override
|
|
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
|
|
if (SafetyAnticrash.isDropped(ctx.channel())) {
|
|
return;
|
|
}
|
|
|
|
if (SafetyAnticrash.isBlocked(p, msg, ctx.channel())) {
|
|
return;
|
|
}
|
|
|
|
super.channelRead(ctx, msg);
|
|
}
|
|
}
|