Package org.geysermc.floodgate.core.addon.data

Class CommonNettyDataHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

org.geysermc.floodgate.core.addon.data.CommonNettyDataHandler

All Implemented Interfaces:

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

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	CommonNettyDataHandler.HandleResultType

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

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field	Description
protected final PacketBlocker	blocker
protected final FloodgateConfig	config
protected final io.netty.util.AttributeKey<org.geysermc.api.connection.Connection>	connectionAttribute
protected io.netty.channel.ChannelHandlerContext	ctx
protected final DataSeeker	dataSeeker
protected final FloodgateDataHandler	handshakeHandler
protected Object	handshakePacket
protected final io.netty.util.AttributeKey<String>	kickMessageAttribute
protected final FloodgateLogger	logger
protected final Queue<Object>	packetQueue

Constructor Summary

Constructors

Constructor	Description
CommonNettyDataHandler(DataSeeker dataSeeker, FloodgateDataHandler handshakeHandler, FloodgateConfig config, FloodgateLogger logger, io.netty.util.AttributeKey<org.geysermc.api.connection.Connection> connectionAttribute, io.netty.util.AttributeKey<String> kickMessageAttribute, PacketBlocker blocker)

Method Summary

Modifier and Type	Method	Description
void	channelRead(io.netty.channel.ChannelHandlerContext ctx, Object packet)
protected abstract boolean	channelRead(Object packet)
protected void	disablePacketQueue(boolean removeSelf)
protected void	disablePacketQueue(FloodgateDataHandler.HandleResult result)
void	exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
protected final 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 final void	setKickMessage(@NonNull String message)
protected abstract void	setNewIp(io.netty.channel.Channel channel, InetSocketAddress newIp)
protected boolean	shouldCallFireRead(Object queuedPacket)
protected boolean	shouldRemoveHandler(FloodgateDataHandler.HandleResult 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 Details

dataSeeker

protected final DataSeeker dataSeeker

handshakeHandler

protected final FloodgateDataHandler handshakeHandler

config

protected final FloodgateConfig config

logger

protected final FloodgateLogger logger

connectionAttribute

protected final io.netty.util.AttributeKey<org.geysermc.api.connection.Connection> connectionAttribute

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 Details

CommonNettyDataHandler

public CommonNettyDataHandler(DataSeeker dataSeeker,
 FloodgateDataHandler handshakeHandler,
 FloodgateConfig config,
 FloodgateLogger logger,
 io.netty.util.AttributeKey<org.geysermc.api.connection.Connection> connectionAttribute,
 io.netty.util.AttributeKey<String> kickMessageAttribute,
 PacketBlocker blocker)

Method Details

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(FloodgateDataHandler.HandleResult result)

shouldCallFireRead

protected boolean shouldCallFireRead(Object queuedPacket)

handle

protected void handle(Object handshakePacket,
 String hostname)

disablePacketQueue

protected void disablePacketQueue(FloodgateDataHandler.HandleResult result)

disablePacketQueue

protected void disablePacketQueue(boolean removeSelf)

removeSelf

protected void removeSelf()

setKickMessage

protected final void setKickMessage(@NonNull
 @NonNull 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