package de.norch.lobby;

import java.io.ByteArrayOutputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import org.bukkit.Bukkit;
import org.bukkit.entity.Player;
import org.bukkit.plugin.PluginManager;
import org.bukkit.plugin.java.JavaPlugin;

import de.norch.lobby.clicklistener.PlayerhideClickListener;
import de.norch.lobby.gadgets.EnderpearlGadget;
import de.norch.lobby.gadgets.EnterhakenGadget;
import de.norch.lobby.gadgets.FireworkGadget;
import de.norch.lobby.gadgets.Gadgets;
import de.dytanic.cloudnet.api.CloudAPI;
import de.dytanic.cloudnet.bridge.CloudServer;
import de.norch.lobby.clicklistener.LobbywechselClickListener;
import de.norch.lobby.clicklistener.NavigatorClickListener;
import de.norch.lobby.listener.ItemSwitchListener;
import de.norch.lobby.listener.NavigatorListener;
import de.norch.lobby.listener.NoRainListener;
import de.norch.lobby.listener.PlayerInteractListener;
import de.norch.lobby.listener.PlayerJoinListener;
import de.norch.lobby.listener.PlayerMoveListener;
import de.norch.lobby.listener.PlayerQuitListener;
import de.norch.lobby.listener.ProtectionListener;
import de.norch.lobby.manager.InventoryManager;
import de.norch.lobby.manager.RunTask;
import de.norch.lobby.utils.ServerUtils;

public class LobbySystem extends JavaPlugin {

    private static LobbySystem instance;
    public static final String PREFIX = "§2Azyrus §7> ";
    public static final String PREFIXLOBBY = "§6§lLOBBY §7> ";
    public static final String NO_PERMISSION = PREFIX + "§cAccess Denied!";

    private final ExecutorService executorService = Executors.newCachedThreadPool();
    private final InventoryManager inventoryManager = new InventoryManager();
    private final ServerUtils serverutils = new ServerUtils();
    CloudServer cloudServer;
    CloudAPI api;


    @Override
    public void onEnable() {
        instance = this;
        init();
        LobbywechselClickListener.createInventory();
        LobbywechselClickListener.updateLobbys();
        getServer().getMessenger().registerOutgoingPluginChannel(this, "BungeeCord");
    }

    private void init() {
        registerEvents();
        new RunTask();
        this.cloudServer = CloudServer.getInstance();
        this.api = CloudAPI.getInstance();

    }

    private void registerEvents() {
        final PluginManager pluginManager = Bukkit.getPluginManager();
        pluginManager.registerEvents(new ItemSwitchListener(), this);
        pluginManager.registerEvents(new PlayerJoinListener(), this);
        pluginManager.registerEvents(new PlayerQuitListener(), this);
        pluginManager.registerEvents(new ProtectionListener(), this);
        pluginManager.registerEvents(new PlayerInteractListener(), this);
        pluginManager.registerEvents(new PlayerhideClickListener(), this);
        pluginManager.registerEvents(new PlayerMoveListener(), this);
        pluginManager.registerEvents(new NavigatorListener(), this);
        pluginManager.registerEvents(new NavigatorClickListener(), this);
        pluginManager.registerEvents(new LobbywechselClickListener(), this);
        pluginManager.registerEvents(new Gadgets(), this);
        pluginManager.registerEvents(new EnderpearlGadget(), this);
        pluginManager.registerEvents(new FireworkGadget(), this);
        pluginManager.registerEvents(new EnterhakenGadget(), this);
        pluginManager.registerEvents(new NoRainListener(), this);
    }

    public ExecutorService geExecutorService() {
        return executorService;
    }

    public InventoryManager getInventoryManager() {
        return inventoryManager;
    }

    public static LobbySystem getInstance() {
        return instance;
    }

    public ServerUtils getServerutils() {
        return serverutils;
    }

    public static void teleportServers(Player p, String server) {
        ByteArrayOutputStream b = new ByteArrayOutputStream();
        DataOutputStream out = new DataOutputStream(b);
        try {
            out.writeUTF("connect");
            out.writeUTF(server);
        } catch (IOException localIOException) {
            p.sendPluginMessage(getInstance(), "BungeeCord", b.toByteArray());
        }
    }

}