LoginSession.java

package com.gie.core.login;

import com.gie.core.channel.SessionHandler;
import com.gie.core.login.game.GameDecoder;
import com.gie.game.World;
import com.gie.game.entity.player.Player;
import io.netty.channel.Channel;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelFutureListener;
import io.netty.channel.socket.SocketChannel;

import java.util.concurrent.ExecutionException;

/**
 * Created by Adam on 09/10/2016.
 */
public class LoginSession extends SessionHandler {


    private Player player;

    public LoginSession(Channel channel) {
        super(channel);
        this.player = new Player(this);
    }

    public Player getPlayer() {
        return player;
    }


    private World world = new World();

    private LoginResponses responses = LoginResponses.LOGIN_SUCCESSFUL;

    @Override
    public void receieveMessage(Object o) throws ExecutionException, InterruptedException {
        if (!(o instanceof LoginHandler)) {
            return;
        }

        LoginHandler details = (LoginHandler) o;
        SocketChannel channel = (SocketChannel) details.getChannel().channel();

        String username = details.getUsername();
        String password = details.getPassword();
        String address = channel.remoteAddress().getAddress().getHostAddress();

        player.setUsername(username);
        player.setPassword(password);
        player.setAddress(address);

        if (world.isUpdating()) {
            responses = LoginResponses.SERVER_IS_BEING_UPDATED;
        }

        if (world.getPlayers().isFull()) {
            responses = LoginResponses.WORLD_IS_FULL;
        }

        if (password != player.getPassword()) {
            responses = LoginResponses.FALSE_CREDENTIALS;
        }

        ChannelFuture future = channel.writeAndFlush(new LoginResponseHandler(responses, 0, false));

        if (responses != LoginResponses.LOGIN_SUCCESSFUL) {
            future.addListener(ChannelFutureListener.CLOSE);
            return;
        }

        future.awaitUninterruptibly();
        channel.pipeline().replace("login-decoder", "incoming-decoder", new GameDecoder(details.getOut()));
        world.addPlayer(player);
        System.out.println("Registered " + player.getUsername());

    }
}