package engine.net.client.handlers;

import engine.InterestManagement.InterestManager;
import engine.InterestManagement.WorldGrid;
import engine.db.archive.CharacterRecord;
import engine.db.archive.DataWarehouse;
import engine.db.archive.PvpRecord;
import engine.exception.MsgSendException;
import engine.gameManager.SessionManager;
import engine.math.Vector3fImmutable;
import engine.mbEnums;
import engine.mbEnums.DispatchChannel;
import engine.net.Dispatch;
import engine.gameManager.DispatchManager;
import engine.net.client.ClientConnection;
import engine.net.client.msg.*;
import engine.objects.Account;
import engine.objects.PlayerCharacter;
import engine.server.MBServerStatics;
import engine.server.world.WorldServer;
import engine.session.Session;
import org.pmw.tinylog.Logger;

/*
 * @Author:
 * @Summary: Processes application protocol message which requests
 * that a character enters the game world from login screen
 */

public class RequestEnterWorldHandler extends AbstractClientMsgHandler {

    public RequestEnterWorldHandler() {
        super();
    }

    @Override
    protected boolean _handleNetMsg(ClientNetMsg baseMsg, ClientConnection origin) throws MsgSendException {

        RequestEnterWorldMsg msg;

        msg = (RequestEnterWorldMsg) baseMsg;

        Session session = SessionManager.getSession(origin);

        if (session == null)
            return true;

        PlayerCharacter player = origin.getPlayerCharacter();

        WorldGrid.RemoveWorldObject(player);
        Dispatch dispatch;

        if (player == null) {
            Logger.error("Unable to find player for session" + session.getSessionID());
            origin.kickToLogin(MBServerStatics.LOGINERROR_UNABLE_TO_LOGIN, "Player not found.");
            return true;
        }

        player.setEnteredWorld(false);

        Account acc = SessionManager.getAccount(origin);

        if (acc.status.ordinal() < WorldServer.worldAccessLevel.ordinal() || MBServerStatics.blockLogin) {
            origin.disconnect();
            return true;
        }

        // Brand new character.  Send the city select screen

        if (player.getLevel() == 1 && player.getBindBuildingID() == -1) {
            SelectCityMsg scm = new SelectCityMsg(player, true);
            dispatch = Dispatch.borrow(player, scm);
            DispatchManager.dispatchMsgDispatch(dispatch, DispatchChannel.SECONDARY);
            return true;
        }

        player.resetRegenUpdateTime();

        // Map Data

        try {
            WorldDataMsg wdm = new WorldDataMsg();
            dispatch = Dispatch.borrow(player, wdm);
            DispatchManager.dispatchMsgDispatch(dispatch, DispatchChannel.PRIMARY);
        } catch (Exception e) {
            // TODO Auto-generated catch block
            Logger.error("WORLDDATAMESSAGE" + e.getMessage());
        }

        // Realm Data

        try {
            WorldRealmMsg wrm = new WorldRealmMsg();
            dispatch = Dispatch.borrow(player, wrm);
            DispatchManager.dispatchMsgDispatch(dispatch, DispatchChannel.PRIMARY);
        } catch (Exception e) {
            // TODO Auto-generated catch block
            Logger.error("REALMMESSAGE" + e.getMessage());
        }

        // Object Data
        CityDataMsg wom = new CityDataMsg(session, true);
        dispatch = Dispatch.borrow(player, wom);
        DispatchManager.dispatchMsgDispatch(dispatch, DispatchChannel.PRIMARY);

        player.getTimestamps().put("EnterWorld", System.currentTimeMillis());

        if (player.getLoc().equals(Vector3fImmutable.ZERO) || System.currentTimeMillis() > player.getTimeStamp("logout") + (15 * 60 * 1000)) {
            player.stopMovement(player.getBindLoc());
            player.setSafeMode();
            player.updateLocation();
        }

        player.setTimeStamp("logout", 0);
        player.respawnLock.writeLock().lock();
        try {
            if (!player.isAlive()) {
                Logger.info("respawning player on enter world.");
                player.respawn(true, true, true);
            }

        } catch (Exception e) {
            Logger.error(e);
        } finally {
            player.respawnLock.writeLock().unlock();
        }


        player.resetDataAtLogin();

        InterestManager.INTERESTMANAGER.HandleLoadForEnterWorld(player);

        // If this is a brand new character...
        // when they enter world is a great time to write their
        // character record to the data warehouse.

        if (player.getHash() == null) {

            if (DataWarehouse.recordExists(mbEnums.DataRecordType.CHARACTER, player.getObjectUUID()) == false) {
                CharacterRecord characterRecord = CharacterRecord.borrow(player);
                DataWarehouse.pushToWarehouse(characterRecord);
            }
            player.setHash();
        }

        //
        // We will load the kill/death lists here as data is only pertinent
        // to characters actually logged into the game.
        //

        player.pvpKills = PvpRecord.getCharacterPvPHistory(player.getObjectUUID(), mbEnums.PvpHistoryType.KILLS);
        player.pvpDeaths = PvpRecord.getCharacterPvPHistory(player.getObjectUUID(), mbEnums.PvpHistoryType.DEATHS);

        SendOwnPlayerMsg sopm = new SendOwnPlayerMsg(SessionManager.getSession(origin));
        dispatch = Dispatch.borrow(player, sopm);
        DispatchManager.dispatchMsgDispatch(dispatch, DispatchChannel.PRIMARY);

        return true;
    }

}