package fr.xephi.authme.process.quit;

import org.bukkit.Bukkit;
import org.bukkit.Location;
import org.bukkit.entity.Player;
import org.bukkit.inventory.ItemStack;
import org.bukkit.scheduler.BukkitTask;

import fr.xephi.authme.AuthMe;
import fr.xephi.authme.Utils;
import fr.xephi.authme.cache.auth.PlayerAuth;
import fr.xephi.authme.cache.auth.PlayerCache;
import fr.xephi.authme.cache.backup.FileCache;
import fr.xephi.authme.cache.limbo.LimboCache;
import fr.xephi.authme.cache.limbo.LimboPlayer;
import fr.xephi.authme.datasource.DataSource;
import fr.xephi.authme.listener.AuthMePlayerListener;
import fr.xephi.authme.plugin.manager.CombatTagComunicator;
import fr.xephi.authme.settings.Settings;

public class AsyncronousQuit {

    protected AuthMe plugin;
    protected DataSource database;
    protected Player p;
    protected Utils utils = Utils.getInstance();
    private String name;
    private FileCache playerBackup;
    private ItemStack[] armor = null;
    private ItemStack[] inv = null;
    private boolean isOp = false;
    private boolean isFlying = false;
    private boolean needToChange = false;
    private boolean isKick = false;

    public AsyncronousQuit(Player p, AuthMe plugin, DataSource database,
            boolean isKick) {
        this.p = p;
        this.plugin = plugin;
        this.database = database;
        this.name = p.getName().toLowerCase();
        this.playerBackup = new FileCache(plugin);
        this.isKick = isKick;
    }

    public void process() {
        final Player player = p;
        if (plugin.getCitizensCommunicator().isNPC(player) || Utils.getInstance().isUnrestricted(player) || CombatTagComunicator.isNPC(player)) {
            return;
        }

        Location loc = player.getLocation();
        String ip = plugin.getIP(player);

        if (PlayerCache.getInstance().isAuthenticated(name) && !player.isDead()) {
            if (Settings.isSaveQuitLocationEnabled && database.isAuthAvailable(name)) {
                final PlayerAuth auth = new PlayerAuth(name, loc.getX(), loc.getY(), loc.getZ(), loc.getWorld().getName());
                try {
                    database.updateQuitLoc(auth);
                } catch (NullPointerException npe) {
                }
            }
            PlayerAuth auth = new PlayerAuth(name, ip, System.currentTimeMillis());
            database.updateSession(auth);
        }

        if (LimboCache.getInstance().hasLimboPlayer(name)) {
            LimboPlayer limbo = LimboCache.getInstance().getLimboPlayer(name);
            if (Settings.protectInventoryBeforeLogInEnabled && player.hasPlayedBefore()) {
                inv = limbo.getInventory();
                armor = limbo.getArmour();
            }
            utils.addNormal(player, limbo.getGroup());
            needToChange = true;
            isOp = limbo.getOperator();
            isFlying = limbo.isFlying();
            if (limbo.getTimeoutTaskId() != null)
                limbo.getTimeoutTaskId().cancel();
            if (limbo.getMessageTaskId() != null)
                limbo.getMessageTaskId().cancel();
            LimboCache.getInstance().deleteLimboPlayer(name);
            if (playerBackup.doesCacheExist(player)) {
                playerBackup.removeCache(player);
            }
        }
        if (Settings.isSessionsEnabled && !isKick) {
            BukkitTask task = plugin.getServer().getScheduler().runTaskLaterAsynchronously(plugin, new Runnable() {

                @Override
                public void run() {
                    PlayerCache.getInstance().removePlayer(name);
                    if (database.isLogged(name))
                        database.setUnlogged(name);
                    plugin.sessions.remove(name);
                }

            }, Settings.getSessionTimeout * 20 * 60);
            plugin.sessions.put(name, task);
        } else {
            PlayerCache.getInstance().removePlayer(name);
            database.setUnlogged(name);
        }
        AuthMePlayerListener.gameMode.remove(name);
        Bukkit.getScheduler().scheduleSyncDelayedTask(plugin, new ProcessSyncronousPlayerQuit(plugin, player, inv, armor, isOp, isFlying, needToChange));
    }
}