using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using UnityEngine;
using Riptide;
using Harmony;
using System.Reflection;
using KCM.Packets.Handlers;
using KCM.Packets.Lobby;
using KCM.ServerLobby;
using KCM.Packets;
using KCM.Packets.Network;
using Riptide.Demos.Steam.PlayerHosted;

namespace KCM
{
    public class KCServer : MonoBehaviour
    {
        public static Server server = new Server(Main.steamServer);
        public static bool started = false;

        static KCServer()
        {
            //server.registerMessageHandler(typeof(KCServer).GetMethod("ClientJoined"));

            server.MessageReceived += PacketHandler.HandlePacketServer;
        }

        public static void StartServer()
        {
            server = new Server(Main.steamServer);
            server.MessageReceived += PacketHandler.HandlePacketServer;

            server.Start(0, 25, useMessageHandlers: false);

            server.ClientConnected += (obj, ev) =>
            {
                Main.helper.Log("Client connected");

                if (server.ClientCount > LobbyHandler.ServerSettings.MaxPlayers)
                {
                    ShowModal showModal = new ShowModal() { title = "Failed to connect", message = "Server is full." };

                    showModal.Send(ev.Client.Id);

                    server.DisconnectClient(ev.Client.Id); //, PacketHandler.SerialisePacket(showModal)
                    return;
                }

                ev.Client.CanQualityDisconnect = false;

                Main.helper.Log("Client ID is: " + ev.Client.Id);

                new ServerHandshake() { clientId = ev.Client.Id, loadingSave = LobbyManager.loadingSave }.Send(ev.Client.Id);
            };

            server.ClientDisconnected += (obj, ev) =>
            {
                try
                {
                    var playerName = $"Client {ev.Client.Id}";
                    if (Main.clientSteamIds.TryGetValue(ev.Client.Id, out var steamId) && !string.IsNullOrEmpty(steamId))
                    {
                        if (Main.kCPlayers.TryGetValue(steamId, out var player) && player != null && !string.IsNullOrEmpty(player.name))
                            playerName = player.name;

                        Main.kCPlayers.Remove(steamId);
                    }

                    Main.clientSteamIds.Remove(ev.Client.Id);

                    new ChatSystemMessage()
                    {
                        Message = $"{playerName} has left the server.",
                    }.SendToAll();

                    var entry = LobbyHandler.playerEntries
                        .Select(x => x != null ? x.GetComponent<PlayerEntryScript>() : null)
                        .FirstOrDefault(x => x != null && x.Client == ev.Client.Id);

                    if (entry != null)
                        Destroy(entry.gameObject);

                    Main.helper.Log($"Client disconnected. {ev.Reason}");
                }
                catch (Exception ex)
                {
                    Main.helper.Log("Error handling client disconnect");
                    Main.helper.Log(ex.ToString());
                }
            };

            Main.helper.Log($"Listening on port 7777. Max {LobbyHandler.ServerSettings.MaxPlayers} clients.");


            //Main.kCPlayers.Add(1, new KCPlayer(1, Player.inst));

            //Player.inst = Main.GetPlayer();
        }

        /*[MessageHandler(25)]
        public static void ClientJoined(ushort id, Message message)
        {
            var name = message.GetString();

            Main.helper.Log(id.ToString());
            Main.helper.Log($"User connected: {name}");

            if (id == 1)
            {
                players.Add(id, new KCPlayer(name, id, Player.inst));
            }
            else
            {
                players.Add(id, new KCPlayer(name, id));
            }
        }*/

        public static bool IsRunning { get { return server.IsRunning; } }

        private void Update()
        {
            server.Update();
        }

        private void OnApplicationQuit()
        {
            server.Stop();
        }

        private void Preload(KCModHelper helper)
        {
            helper.Log("server?");

            helper.Log("Preload run in server");
        }

        private void SceneLoaded(KCModHelper helper)
        {
        }
    }
}