package net.ME1312.SubServers.Bungee.Network;

import net.ME1312.Galaxi.Library.Version.Version;
import net.ME1312.SubData.Server.SubDataProtocol;
import net.ME1312.SubData.Server.SubDataServer;
import net.ME1312.SubServers.Bungee.Event.SubNetworkConnectEvent;
import net.ME1312.SubServers.Bungee.Event.SubNetworkDisconnectEvent;
import net.ME1312.SubServers.Bungee.Network.Packet.*;
import net.ME1312.SubServers.Bungee.SubAPI;
import net.ME1312.SubServers.Bungee.SubPlugin;
import net.md_5.bungee.api.ProxyServer;

import java.io.IOException;
import java.net.InetAddress;
import java.util.logging.Handler;
import java.util.logging.LogRecord;
import java.util.logging.Logger;

public class SubProtocol extends SubDataProtocol {
    private static SubProtocol instance;
    private SubProtocol(Logger logger) {
        super(logger);
    }

    @SuppressWarnings("deprecation")
    public static SubProtocol get() {
        if (instance == null) {
            Logger log = Logger.getAnonymousLogger();
            log.setUseParentHandlers(false);
            log.addHandler(new Handler() {
                private boolean open = true;

                @Override
                public void publish(LogRecord record) {
                    if (open)
                        ProxyServer.getInstance().getLogger().log(record.getLevel(), "SubData > " + record.getMessage(), record.getParameters());
                }

                @Override
                public void flush() {

                }

                @Override
                public void close() throws SecurityException {
                    open = false;
                }
            });
            instance = new SubProtocol(log);
            SubPlugin plugin = SubAPI.getInstance().getInternals();
            plugin.getPluginManager().registerListener(null, new PacketOutExRunEvent(plugin));

            instance.setName("SubServers 2");
            instance.setVersion(new Version("2.13.2a+"));


         // 00-09: Object Link Packets
            instance.registerPacket(0x0000, PacketLinkProxy.class);
            instance.registerPacket(0x0001, PacketLinkExHost.class);
            instance.registerPacket(0x0002, PacketLinkServer.class);

            instance.registerPacket(0x0000, new PacketLinkProxy(plugin));
            instance.registerPacket(0x0001, new PacketLinkExHost(plugin));
            instance.registerPacket(0x0002, new PacketLinkServer(plugin));


         // 10-29: Download Packets
            instance.registerPacket(0x0010, PacketDownloadLang.class);
            instance.registerPacket(0x0011, PacketDownloadPlatformInfo.class);
            instance.registerPacket(0x0012, PacketDownloadProxyInfo.class);
            instance.registerPacket(0x0013, PacketDownloadHostInfo.class);
            instance.registerPacket(0x0014, PacketDownloadGroupInfo.class);
            instance.registerPacket(0x0015, PacketDownloadServerInfo.class);
            instance.registerPacket(0x0016, PacketDownloadPlayerList.class);

            instance.registerPacket(0x0010, new PacketDownloadLang(plugin));
            instance.registerPacket(0x0011, new PacketDownloadPlatformInfo(plugin));
            instance.registerPacket(0x0012, new PacketDownloadProxyInfo(plugin));
            instance.registerPacket(0x0013, new PacketDownloadHostInfo(plugin));
            instance.registerPacket(0x0014, new PacketDownloadGroupInfo(plugin));
            instance.registerPacket(0x0015, new PacketDownloadServerInfo(plugin));
            instance.registerPacket(0x0016, new PacketDownloadPlayerList(plugin));


         // 30-49: Control Packets
          //instance.registerPacket(0x0030, PacketInReload.class);     TODO
            instance.registerPacket(0x0031, PacketCreateServer.class);
          //instance.registerPacket(0x0032, PacketAddServer.class);    TODO
            instance.registerPacket(0x0033, PacketStartServer.class);
          //instance.registerPacket(0x0034, PacketEditServer.class);   TODO
            instance.registerPacket(0x0035, PacketRestartServer.class);
            instance.registerPacket(0x0036, PacketCommandServer.class);
            instance.registerPacket(0x0037, PacketStopServer.class);
          //instance.registerPacket(0x0038, PacketRemoveServer.class); TODO
          //instance.registerPacket(0x0039, PacketDeleteServer.class); TODO

          //instance.registerPacket(0x0030, new PacketInReload(plugin));     TODO
            instance.registerPacket(0x0031, new PacketCreateServer(plugin));
          //instance.registerPacket(0x0032, new PacketAddServer(plugin));    TODO
            instance.registerPacket(0x0033, new PacketStartServer(plugin));
          //instance.registerPacket(0x0034, new PacketEditServer(plugin));   TODO
            instance.registerPacket(0x0035, new PacketRestartServer(plugin));
            instance.registerPacket(0x0036, new PacketCommandServer(plugin));
            instance.registerPacket(0x0037, new PacketStopServer(plugin));
          //instance.registerPacket(0x0038, new PacketRemoveServer(plugin)); TODO
          //instance.registerPacket(0x0039, new PacketDeleteServer(plugin)); TODO


         // 50-69: External Host Packets
            instance.registerPacket(0x0050, PacketExConfigureHost.class);
            instance.registerPacket(0x0051, PacketExDownloadTemplates.class);
          //instance.registerPacket(0x0052, PacketInExRequestQueue.class);
            instance.registerPacket(0x0053, PacketExCreateServer.class);
            instance.registerPacket(0x0054, PacketExAddServer.class);
            instance.registerPacket(0x0055, PacketExUpdateServer.class);
          //instance.registerPacket(0x0056, PacketInExLogMessage.class);
            instance.registerPacket(0x0057, PacketExDeleteServer.class);
            instance.registerPacket(0x0058, PacketExRemoveServer.class);

            instance.registerPacket(0x0050, new PacketExConfigureHost(plugin));
            instance.registerPacket(0x0051, new PacketExDownloadTemplates(plugin));
            instance.registerPacket(0x0052, new PacketInExRequestQueue(plugin));
            instance.registerPacket(0x0053, new PacketExCreateServer(null));
            instance.registerPacket(0x0054, new PacketExAddServer());
            instance.registerPacket(0x0055, new PacketExUpdateServer(plugin));
            instance.registerPacket(0x0056, new PacketInExLogMessage());
            instance.registerPacket(0x0057, new PacketExDeleteServer());
            instance.registerPacket(0x0058, new PacketExRemoveServer());


         // 70-79: External Misc Packets
            instance.registerPacket(0x0070, PacketOutExRunEvent.class);
            instance.registerPacket(0x0071, PacketOutExReset.class);
            instance.registerPacket(0x0072, PacketOutExReload.class);
            instance.registerPacket(0x0073, PacketOutExUpdateWhitelist.class);

          //instance.registerPacket(0x0070, new PacketOutRunEvent());
          //instance.registerPacket(0x0071, new PacketOutReset());
          //instance.registerPacket(0x0072, new PacketOutReload());
          //instance.registerPacket(0x0073, new PacketOutExUpdateWhitelist());
        }

        return instance;
    }

    @SuppressWarnings("deprecation")
    @Override
    public SubDataServer open(InetAddress address, int port, String cipher) throws IOException {
        SubDataServer subdata = super.open(address, port, cipher);
        SubPlugin plugin = SubAPI.getInstance().getInternals();

        subdata.on.closed(server -> plugin.subdata = null);
        subdata.on.connect(client -> {
            if (!plugin.getPluginManager().callEvent(new SubNetworkConnectEvent(client.getServer(), client)).isCancelled()) {
                client.on.closed(c -> plugin.getPluginManager().callEvent(new SubNetworkDisconnectEvent(c.get().getServer(), c.get(), c.name())));
                return true;
            } else return false;
        });

        return subdata;
    }
}