org.geysermc.floodgate.addon.data

Class CommonDataHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

org.geysermc.floodgate.addon.data.CommonDataHandler

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler

public abstract class CommonDataHandler
extends io.netty.channel.ChannelInboundHandlerAdapter

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field and Description
protected PacketBlocker	blocker
protected FloodgateConfig	config
protected io.netty.channel.ChannelHandlerContext	ctx
protected FloodgateHandshakeHandler	handshakeHandler
protected Object	handshakePacket
protected io.netty.util.AttributeKey<String>	kickMessageAttribute
protected Queue<Object>	packetQueue

Constructor Summary

Constructors

Constructor and Description
CommonDataHandler(FloodgateHandshakeHandler handshakeHandler, FloodgateConfig config, io.netty.util.AttributeKey<String> kickMessageAttribute, PacketBlocker blocker)

Method Summary

Modifier and Type	Method and Description
void	channelRead(io.netty.channel.ChannelHandlerContext ctx, Object packet)
protected abstract boolean	channelRead(Object packet)
protected void	disablePacketQueue(boolean removeSelf)
void	exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
protected String	getKickMessage()
protected void	handle(Object handshakePacket, String hostname)
void	handlerAdded(io.netty.channel.ChannelHandlerContext ctx)
protected void	removeSelf()
protected abstract Object	setHostname(Object handshakePacket, String hostname)
protected void	setKickMessage(String message)
protected abstract void	setNewIp(io.netty.channel.Channel channel, InetSocketAddress newIp)
protected boolean	shouldCallFireRead(Object queuedPacket)
protected boolean	shouldRemoveHandler(FloodgateHandshakeHandler.HandshakeResult result)

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.netty.channel.ChannelHandler

handlerRemoved

Field Detail

handshakeHandler

protected final FloodgateHandshakeHandler handshakeHandler

config

protected final FloodgateConfig config

kickMessageAttribute

protected final io.netty.util.AttributeKey<String> kickMessageAttribute

blocker

protected final PacketBlocker blocker

packetQueue

protected final Queue<Object> packetQueue

handshakePacket

protected Object handshakePacket

ctx

protected io.netty.channel.ChannelHandlerContext ctx

Constructor Detail

CommonDataHandler

public CommonDataHandler(FloodgateHandshakeHandler handshakeHandler,
                         FloodgateConfig config,
                         io.netty.util.AttributeKey<String> kickMessageAttribute,
                         PacketBlocker blocker)

Method Detail

setNewIp

protected abstract void setNewIp(io.netty.channel.Channel channel,
                                 InetSocketAddress newIp)

setHostname

protected abstract Object setHostname(Object handshakePacket,
                                      String hostname)

channelRead

protected abstract boolean channelRead(Object packet)
                                throws Exception

Throws:

Exception

shouldRemoveHandler

protected boolean shouldRemoveHandler(FloodgateHandshakeHandler.HandshakeResult result)

shouldCallFireRead

protected boolean shouldCallFireRead(Object queuedPacket)

handle

protected void handle(Object handshakePacket,
                      String hostname)

disablePacketQueue

protected void disablePacketQueue(boolean removeSelf)

removeSelf

protected void removeSelf()

setKickMessage

protected final void setKickMessage(String message)

getKickMessage

protected final String getKickMessage()

handlerAdded

public void handlerAdded(io.netty.channel.ChannelHandlerContext ctx)
                  throws Exception

Specified by:

handlerAdded in interface io.netty.channel.ChannelHandler

Overrides:

handlerAdded in class io.netty.channel.ChannelHandlerAdapter

Throws:

Exception

channelRead

public void channelRead(io.netty.channel.ChannelHandlerContext ctx,
                        Object packet)

Specified by:

channelRead in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelRead in class io.netty.channel.ChannelInboundHandlerAdapter

exceptionCaught

public void exceptionCaught(io.netty.channel.ChannelHandlerContext ctx,
                            Throwable cause)
                     throws Exception

Specified by:

exceptionCaught in interface io.netty.channel.ChannelHandler

Specified by:

exceptionCaught in interface io.netty.channel.ChannelInboundHandler

Overrides:

exceptionCaught in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception