using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using SocketIOSharp.Common;
using SocketIOSharp.Server;
using SocketIOSharp.Client;
using SocketIOSharp.Server.Client;
using EngineIOSharp.Common.Enum;
using Json.Net;
using System.Net;
using SocketIOSharp.Common.Packet;
using System.Threading;
using PolyChat.Models.Exceptions;

namespace PolyChat.Models
{
    class Client
    {
        private SocketIOClient connection;
        private Boolean connected = false;
        private String ipSelf;

        public Client(SocketIOClient connection, String ip)
        {
            this.ipSelf = ip;
            this.connection = connection;
            InitEventHandlers(this, connection);
        }

        //Sending
        //===================================================================================
        /// <summary>
        /// converts String message into json file and sends it to the server.
        /// </summary>
        /// <remarks>
        /// gets called by gui if someone wants to send Message
        /// </remarks>
        /// <param name="sender">Sender of Message</param>
        /// <param name="chatMessage">the accual text the user wants to send</param>
        /// <param name="timestamp">current time</param>
        public void sendMessage(SendCode code, String chatMessage)
        {
            new Thread(() =>
            {
                //create msg
                ChatMessage msg = new ChatMessage(chatMessage, false, Controller.ip);

                //convert msg
                String petJson = JsonNet.Serialize(msg);

                //wait if not connected and send msg
                int i=0;
                int sleeptimer = 2000;
                while(!this.connected)
                {
                    Thread.Sleep(sleeptimer);
                    i++;
                    if(i>=10)
                    {
                        throw new MessageTimedOutException(i*sleeptimer);
                    }
                }
                connection.Emit(code.ToString(), petJson);
            }).Start();
        }
        /*
        /// <summary>
        /// Sends Message with new name
        /// </summary>
        /// <param name="code"></param>
        /// <param name="nameChange"></param>
        /// <param name="timestamp"></param>
        public void sendNameChange(SendCode code, String nameChange)
        {
            new Thread(() =>
            {
                //create msg
                ChatMessage msg = new ChatMessage( Controller.ip);

                //convert msg
                String petJson = JsonNet.Serialize(msg);

                //send msg
                connection.Emit(code.ToString(), petJson);
            }).Start();
        }
        */

        //==================================================================================
        //EventHandeling
        //===================================================================================
        
        /// <summary>
        /// handles all events of client server communiation
        /// </summary>
        /// <param name="client">self</param>
        /// <param name="connection"></param>
        private static void InitEventHandlers(Client client, SocketIOClient connection)
        {
            connection.On(SendCode.Message.ToString(), (Data) =>
            {
                ChatMessage pet = JsonNet.Deserialize<ChatMessage>(BitConverter.ToString(Data[0].ToObject<byte[]>()));
                //TODO: send message to GUI
            });

            connection.On(SendCode.Command.ToString(), (Data) =>
            {
                Console.WriteLine("Command recieved!" + Data[0]);
            });

            connection.On(SocketIOEvent.CONNECTION, () =>
            {
                client.connected = true;
            });
        }
        //==================================================================================
        //Getter and Setter
        //==================================================================================

        public String getIP()
        {
            return this.ipSelf;
        }

        public Boolean isConnected()
        {
            return this.connected;
        }
    }

}