using System;
using System.Collections.Concurrent;
using System.Net;
using System.Threading.Tasks;

namespace Mistox.Server {

    public class MistoxServer {

        // Class Definitions

        public string ServerName { get; private set; } = "";                    // The name of the server
        public int MaxClients { get; set; } = 10;                               // The max players per server
        public float ConnectionRange { get; set; } = 40;                        // InGame distance for valid conections
        public int ConnectionTimeoutSeconds { get; set; } = 10;                 // If no reply in time kill the connection
        public bool Alive { get; set; } = true;                                 // Is the server running
        public ConcurrentDictionary<string, ServerConnection> Connections;      // All the active connections. key is username

        private readonly ServerListener Listener;                               // The Connection Listener singleton

        public MistoxServer(IPEndPoint ListenerAddress, string serverName) {
            Listener = new ServerListener(ListenerAddress, this);
            Connections = new ConcurrentDictionary<string, ServerConnection>();
            ServerName = serverName;
            Console.WriteLine( "The Server is initilized and waiting for clients to connect at port : " + ListenerAddress.Port );
        }

        // Functions

        public event Action<ServerConnection> onUserConnected;
        public void InvokeUserConnected( ServerConnection user ){
            onUserConnected?.Invoke( user );
        }

        public event Action<dynamic> onDataReceived;
        public void InvokeDataReceived( dynamic data ){
            onDataReceived?.Invoke( data );
        }

        public event Action<ServerConnection> onUserDisconnected;
        public void InvokeUserDisconnected( ServerConnection user ){
            onUserDisconnected?.Invoke( user );
        }

        public async Task SendAllClients<Packet>(Packet data) {
            foreach( ServerConnection cur in Connections.Values ) {
                await cur.Send(data);
            }
        }

        public async Task SendClient<Packet>(string UserName, Packet data) {
            await Connections[UserName].Send( data );
        }
    }

}