using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Net.Sockets;
using System.Net;
using System.Threading;

namespace server
{
    class Program
    {
        private static TcpListener server;
        private static Thread thread1;
        private static Thread thread2;
        private static Socket serverSocket;
        private static Socket clientSocket;

        static void startServer()
        {
            server = new TcpListener(IPAddress.Parse("127.0.0.1"), 2222);
            server.Start();

            while (true)
            {
                serverSocket = server.AcceptSocket();

                Byte[] odebraneBajty = new Byte[100];
                int ret = serverSocket.Receive(odebraneBajty, odebraneBajty.Length, 0);
                string tmp = null;
                tmp = System.Text.Encoding.ASCII.GetString(odebraneBajty);
                tmp = tmp.Trim();
                Console.WriteLine(string.Compare(tmp, "quit") != 0);
                if (tmp.Length > 0 && string.Compare(tmp, "quit") != 0)
                {
                    Console.WriteLine("Odebrałem komunikat:");
                    Console.WriteLine(tmp);
                }
                else
                {

                    thread2.Abort();
                    thread1.Abort();
                    server.Stop();
                    break;
                }
            }
        }

        static void startClient()
        {
            clientSocket  = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            IPAddress hostadd = IPAddress.Parse("127.0.0.1");
            int port = 2223;
            IPEndPoint EPhost = new IPEndPoint(hostadd, port);
            clientSocket.Connect(EPhost);
            string message;
            while (true)
            {
                Console.WriteLine("podaj wiadomość:");
                message = Console.ReadLine();
                Console.WriteLine(" ");
                Byte[] byteData = Encoding.ASCII.GetBytes(message.ToCharArray());
                clientSocket.Send(byteData, byteData.Length, 0);

                if (string.Compare(message, "quit") == 0)
                {
                    thread1.Abort();
                    thread2.Abort();
                }
            }
        }



        static void Main(string[] args)
        {
            Console.WriteLine("user1");

            thread1 = new Thread(new ThreadStart(startServer));
            thread2 = new Thread(new ThreadStart(startClient));

            thread1.Start();
            thread2.Start();

            thread1.Join();
            thread2.Join();
        }
    }
}