Session.java

package com.osroyale.net.session;
 
import com.osroyale.Config;
import io.netty.channel.Channel;
import io.netty.channel.ChannelFuture;
 
import java.net.InetSocketAddress;

 
public class Session {

    protected final Channel channel;

    protected final String host;

    public Session(Channel channel) {
        this.channel = channel;
        this.host = ((InetSocketAddress) channel.remoteAddress()).getAddress().getHostAddress();
    }

    public final void close() {
        onClose(channel.close());
    }

    protected void onClose(ChannelFuture future) {
 
    }

    public void handleClientPacket(Object o) {
 
    }

    public Channel getChannel() {
        return channel;
    }

    public String getHost() {
        final Channel channel = getChannel();
        if (channel != null && channel.hasAttr(Config.SOURCE_ADDRESS)) {
            return channel.attr(Config.SOURCE_ADDRESS).get();
        }
        return host;
    }
 
}