using System;
using System.Collections.Generic;
using System.IO.Pipes;
using System.Linq;
using System.Net.Sockets;
using System.Text;
using DoctorApp.Utils;

namespace Server
{
    class Communication
    {
        private TcpListener listener;
        private List<Client> clients;
        public Client doctor;
        public Communication(TcpListener listener)
        {
            this.listener = listener;
            this.clients = new List<Client>();
        }

        public void Start()
        {
            listener.Start();
            Console.WriteLine($"==========================================================================\n" +
                $"\tstarted accepting clients at {DateTime.Now}\n" +
                $"==========================================================================");
            listener.BeginAcceptTcpClient(new AsyncCallback(OnConnect), null);
        }

        private void OnConnect(IAsyncResult ar)
        {

            var tcpClient = listener.EndAcceptTcpClient(ar);
            Console.WriteLine($"Client connected from {tcpClient.Client.RemoteEndPoint}");
            clients.Add(new Client(this, tcpClient));
            /*if (doctor == null)
            {
                doctor = clients.ElementAt(0);
            }
            else
            {

                doctor.sendMessage(DataParser.getNewConnectionJson("jan"));
            }*/
            listener.BeginAcceptTcpClient(new AsyncCallback(OnConnect), null);
        }

        internal void Disconnect(Client client)
        {
            clients.Remove(client);
        }

        public void NewLogin(Client client)
        {
            if (doctor == null)
            {
                doctor = client;
            }
            else
            {
                doctor.sendMessage(DataParser.getNewConnectionJson(client.username));
            }
            
        }
    }
}