<?php
namespace Auth;

use pocketmine\Player;
use pocketmine\utils\Config;
use pocketmine\event\Listener;
use pocketmine\command\Command;
use pocketmine\utils\TextFormat;
use pocketmine\plugin\PluginBase;
use pocketmine\command\CommandSender;
use pocketmine\event\player\PlayerJoinEvent;
use pocketmine\event\player\PlayerQuitEvent;
use pocketmine\event\player\PlayerCommandPreprocessEvent;

class Auth extends PluginBase implements Listener{

    public $login = [];

    public function onEnable(){
        $this->getServer()->getPluginManager()->registerEvents($this, $this);
        $this->exec();

    }

    public function exec(){
        $this->getLogger()->info(TextFormat::YELLOW."(Multi-Serv) Working...");

        @mkdir($this->getDataFolder());
        @mkdir($this->getDataFolder()."Players");

        $this->saveDefaultConfig();
        $this->getResource("config.yml");

        $this->HOST = $this->getConfig()->get("HOST");

        if($this->getConfig()->get("mysqli.work.?") != false){

            $this->getLogger()->info(TextFormat::GREEN."Mysql is activated.");

            $this->USER = $this->getConfig()->get("USER");
            $this->PASS = $this->getConfig()->get("PASS");

            $this->TABLE = "Auth"."(PLAYER VARCHAR(255), IP VARCHAR(30), PASSWORD VARCHAR(65536))";

            $mysqli = new \mysqli($this->HOST, $this->USER, $this->PASS);
                $mysqli->query("CREATE DATABASE IF NOT EXISTS "."Auth");

            $mysqli = new \mysqli($this->HOST, $this->USER, $this->PASS, "Auth");
                $mysqli->query("CREATE TABLE IF NOT EXISTS ".$this->TABLE);

        }else{
            $this->getLogger()->info(TextFormat::GOLD."Mysql is disabled, check in config.yml if you want activate it.");

        }

    }

    public function Join(PlayerJoinEvent $event){
        $player = $event->getPlayer();

        $this->login[$player->getName()] = false;

        if($this->isRegister($player) == true){ //Player is register ?

            if($this->isLoginIp($player) == true){ // Player is login ip ?
                $this->isLogin($player, true);

                $this->login[$player->getName()] = true;

                $player->sendTitle("You have been", "logged by Ip", 20, 20, 20);


            }else{
                $this->isLogin($player, false);
                $player->sendTitle("Welcome Use", "/login <password>", 20, 20, 20);


            }

        }else{
            $this->isLogin($player, false);
            $player->sendTitle("Welcome Use", "/register <password> to logged in", 20, 20, 20);


        }

    }

    public function onCommand(CommandSender $sender, Command $command, $label, array $args){

        switch($command->getName()){

            case "register": //all
                if($sender instanceOf Player && $this->isRegister($sender) == false && $this->login[$sender->getName()] == false){

                    if(!empty($args[0])){
                        $this->Register($sender, $args[0]);
                        $this->isLogin($sender, true);

                        $this->login[$sender->getName()] = true;

                        $sender->sendTitle("You have been", "logged in", 20, 20, 20);


                    }else{
                        $sender->sendTitle("Use", "/register <password>", 20, 20, 20);


                    }

                }

            break;

            case "login": //all
                if($sender instanceOf Player && $this->isRegister($sender) == true && $this->login[$sender->getName()] == false){

                    if(!empty($args[0]) && $this->Login($sender, $args[0]) == true){
                        $this->isLogin($sender, true);
                        $this->changeIp($sender);

                        $this->login[$sender->getName()] = true;

                        $player->sendTitle("You have been", "logged in", 20, 20, 20);


                    }else{

                         $player->sendTitle("Wrong", "password", 20, 20, 20);


                    }

                }

            break;

            case "unregister": //op
                if($sender->isOp() && !empty($args[0])){

                    if($this->unRegister($args[0]) == true){
                        $sender->sendMessage($this->getConfig()->get("unregister.success.message"));

                    }else{
                        $sender->sendMessage($this->getConfig()->get("unregister.error.message"));

                    }

                }

            break;

        }

    }


    public function isRegister(Player $player){
        $name = $player->getName();

        if($this->getConfig()->get("mysqli.work.?") == false){

            if(file_exists($this->getDataFolder()."Players"."/".$name.".yml")){
                return true;

            }else{
                return false;

            }

        }else{
            $mysqli = new \mysqli($this->HOST, $this->USER, $this->PASS, "Auth");

            if($mysqli->query("SELECT * FROM "."Auth"." WHERE PLAYER = '$name'")->num_rows > 0){
                return true;

            }else{
                return false;

            }

        }

    }

    public function isLoginIp(Player $player){
        $address = $player->getAddress();
        $name = $player->getName();

        if($this->getConfig()->get("mysqli.work.?") == false){

            $file = new Config($this->getDataFolder()."Players"."/".$name.".yml", Config::YAML);

            if($address == $file->get("IP")){
                return true;

            }else{
                return false;

            }

        }else{
            $mysqli = new \mysqli($this->HOST, $this->USER, $this->PASS, "Auth");
            $info = mysqli_fetch_row($mysqli->query("SELECT * FROM "."Auth"." WHERE PLAYER = '$name'"));

            if($address == $info[1]){
                return true;

            }else{
                return false;

            }

        }



    }

    public function isLogin(Player $player, $valid){
        $player->setImmobile(false);
        $player->setGamemode(0);

        if($valid == false){
            $player->setImmobile(true);
            $player->setGamemode(0);

        }

    }

    public function changeIp(Player $player){
        $address = $player->getAddress();
        $name = $player->getName();

        if($this->getConfig()->get("mysqli.work.?") == false){

            $file = new Config($this->getDataFolder()."Players"."/".$player->getName().".yml", Config::YAML);

            $file->set("IP", $address);
            $file->save();

        }else{
            $mysqli = new \mysqli($this->HOST, $this->USER, $this->PASS, "Auth");

            $mysqli->query("UPDATE "."Auth"." SET IP = '$address' WHERE PLAYER = '$name'");

        }

    }

    public function Register(Player $player, $password){
        $address = $player->getAddress();
        $name = $player->getName();
        $passmd5 = md5($password);

        if($this->getConfig()->get("mysqli.work.?") == false){

            $file = new Config($this->getDataFolder()."Players"."/".$player->getName().".yml", Config::YAML);

            $file->set("IP", $player->getAddress());
            $file->set("PASSWORD", $passmd5);
            $file->save();

        }else{
            $mysqli = new \mysqli($this->HOST, $this->USER, $this->PASS, "Auth");

            $mysqli->query("INSERT INTO "."Auth"."(PLAYER, IP, PASSWORD) VALUES ('$name', '$address', '$passmd5')");

        }

    }

    public function Login(Player $player, $password){
        $name = $player->getName();
        $passmd5 = md5($password);

        if($this->getConfig()->get("mysqli.work.?") == false){

            $file = new Config($this->getDataFolder()."Players"."/".$name.".yml", Config::YAML);

            if($passmd5 == $file->get("PASSWORD")){
                return true;

            }else{
                return false;

            }

        }else{
            $mysqli = new \mysqli($this->HOST, $this->USER, $this->PASS, "Auth");
            $info = mysqli_fetch_row($mysqli->query("SELECT PLAYER, IP, PASSWORD FROM "."Auth"." WHERE PLAYER = '$name'"));

            if($passmd5 == $info[2]){
                return true;

            }else{
                return false;

            }

        }

    }

    public function unRegister($name){
        $i = $this->getServer()->getPlayer($name);

        if($i){
            $i->kick($this->getConfig()->get("kick.player.message"));

        }

        if($this->getConfig()->get("mysqli.work.?") == false){

            if(file_exists($this->getDataFolder()."Players"."/".$name.".yml")){
                unlink($this->getDataFolder()."Players"."/".$name.".yml");

                return true;

            }else{
                return false;

            }

        }else{
            $mysqli = new \mysqli($this->HOST, $this->USER, $this->PASS, "Auth");

            if($mysqli->query("SELECT * FROM "."Auth"." WHERE PLAYER = '$name'")->num_rows > 0){
                $mysqli->query("DELETE FROM "."Auth"." WHERE PLAYER = '$name'");

                return true;

            }else{
                return false;

            }

        }

    }

    public function logJoin(PlayerJoinEvent $event){ $event->setjoinMessage(null); }

    public function logQuit(PlayerQuitEvent $event){ $event->setquitMessage(null); }

}