package fr.xephi.authme.process.register;

import java.security.NoSuchAlgorithmException;
import java.util.Date;

import org.bukkit.entity.Player;

import fr.xephi.authme.AuthMe;
import fr.xephi.authme.ConsoleLogger;
import fr.xephi.authme.cache.auth.PlayerAuth;
import fr.xephi.authme.cache.auth.PlayerCache;
import fr.xephi.authme.datasource.DataSource;
import fr.xephi.authme.security.PasswordSecurity;
import fr.xephi.authme.settings.Messages;
import fr.xephi.authme.settings.Settings;

public class AsyncronousRegister {
    protected Player player;
    protected String name;
    protected String password;
    protected String realName;
    protected String email = "";
    protected boolean allowRegister;
    private AuthMe plugin;
    private DataSource database;
    private Messages m = Messages.getInstance();

    public AsyncronousRegister(Player player, String password, String email, AuthMe plugin, DataSource data) {
        this.player = player;
        this.password = password;
        name = player.getName().toLowerCase();
        realName = player.getName();
        this.email = email;
        this.plugin = plugin;
        this.database = data;
        this.allowRegister = true;
    }

    protected String getIp() {
        String ip = player.getAddress().getAddress().getHostAddress();

        if (Settings.bungee) {
        	if (plugin.realIp.containsKey(name))
        		ip = plugin.realIp.get(name);
        }
        return ip;
    }

    protected void preRegister() {
    	if (PlayerCache.getInstance().isAuthenticated(name)) {
            m._(player, "logged_in");
            allowRegister = false;
        }

        if (!Settings.isRegistrationEnabled) {
            m._(player, "reg_disabled");
            allowRegister = false;
        }

        if (database.isAuthAvailable(player.getName().toLowerCase())) {
            m._(player, "user_regged");
            if (plugin.pllog.getStringList("players").contains(player.getName())) {
           	 plugin.pllog.getStringList("players").remove(player.getName());
            }
            allowRegister = false;
        }

        if(Settings.getmaxRegPerIp > 0 ){
        	if(!plugin.authmePermissible(player, "authme.allow2accounts") && database.getAllAuthsByIp(getIp()).size() >= Settings.getmaxRegPerIp && !getIp().equalsIgnoreCase("127.0.0.1") && !getIp().equalsIgnoreCase("localhost")) {
        		m._(player, "max_reg");
                allowRegister =  false;
        	}
        }
        
    }

    public void process() {
    	preRegister();
    	if(!allowRegister) return;
    	if(!email.isEmpty() && email != "") {
        	if(Settings.getmaxRegPerEmail > 0) {
        		if (!plugin.authmePermissible(player, "authme.allow2accounts") && database.getAllAuthsByEmail(email).size() >= Settings.getmaxRegPerEmail) {
        			m._(player, "max_reg");
        			return;
        		}
        	}
    		emailRegister();
    		return;
    	}
    	passwordRegister();
    }

    protected void emailRegister() {
    	if(Settings.getmaxRegPerEmail > 0) {
    		if (!plugin.authmePermissible(player, "authme.allow2accounts") && database.getAllAuthsByEmail(email).size() >= Settings.getmaxRegPerEmail) {
    			m._(player, "max_reg");
    			return;
    		}
    	}
    	PlayerAuth auth = null;
		try {
			final String hashnew = PasswordSecurity.getHash(Settings.getPasswordHash, password, name);
    		auth = new PlayerAuth(name, hashnew, getIp(), new Date().getTime(), (int) player.getLocation().getX() , (int) player.getLocation().getY(), (int) player.getLocation().getZ(), player.getLocation().getWorld().getName(), email, realName);
		} catch (NoSuchAlgorithmException e) {
			ConsoleLogger.showError(e.getMessage());
			m._(player, "error");
			return;
		}
		if (PasswordSecurity.userSalt.containsKey(name)) {
    		auth.setSalt(PasswordSecurity.userSalt.get(name));
    	}
        database.saveAuth(auth);
		database.updateEmail(auth);
		database.updateSession(auth);
		plugin.mail.main(auth, password);
		ProcessSyncronousEmailRegister syncronous = new ProcessSyncronousEmailRegister(player, plugin);
		plugin.getServer().getScheduler().scheduleSyncDelayedTask(plugin, syncronous);
		return;
    }

    protected void passwordRegister() {
        if(password.length() < Settings.getPasswordMinLen || password.length() > Settings.passwordMaxLength) {
        	m._(player, "pass_len");
            return;
        }
        if(!Settings.unsafePasswords.isEmpty()) {
        	if (Settings.unsafePasswords.contains(password.toLowerCase())) {
       	 		m._(player, "password_error");
       	 		return;
        	}
        }
        PlayerAuth auth = null;
        String hash = "";
		try {
			hash = PasswordSecurity.getHash(Settings.getPasswordHash, password, name);
		} catch (NoSuchAlgorithmException e) {
			ConsoleLogger.showError(e.getMessage());
			m._(player, "error");
			return;
		}
        if (Settings.getMySQLColumnSalt.isEmpty() && !PasswordSecurity.userSalt.containsKey(name))
        {
        	auth = new PlayerAuth(name, hash, getIp(), new Date().getTime(), "your@email.com",  player.getName());
        } else {
        	auth = new PlayerAuth(name, hash, PasswordSecurity.userSalt.get(name), getIp(), new Date().getTime(), player.getName());
        }
        if (!database.saveAuth(auth)) {
        	m._(player, "error");
            return;
        }
        PlayerCache.getInstance().addPlayer(auth);
		ProcessSyncronousPasswordRegister syncronous = new ProcessSyncronousPasswordRegister(player, plugin);
		plugin.getServer().getScheduler().scheduleSyncDelayedTask(plugin, syncronous);
        return;
    }
}