using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.IO;
using System.Xml.Serialization;
using System.Diagnostics;

namespace BS_6_client
{
    public class Program
    {
        public class FileDetails
        {
            public string FILETYPE = "";
            public long FILESIZE = 0;
        }

        static FileDetails fileDet = new FileDetails();

        static IPAddress remoteIPAddress;
        static int remotePort = 8001;
        static UdpClient sender = new UdpClient();
        static IPEndPoint endPoint;
        static FileStream fs;

        static int localPort = 8002;
        static UdpClient receiver;
        static IPEndPoint RemoteIpEndPoint = null;
        static Byte[] data = new Byte[0];

        static int k = 1;
        static string file = "";
        static Thread receiveThread;

        static void Main(string[] args)
        {
            try
            {
                //IPHostEntry ipHost = Dns.GetHostByName(Dns.GetHostName());
                remoteIPAddress = IPAddress.Parse("192.168.0.2");//ipHost.AddressList[0];
                endPoint = new IPEndPoint(remoteIPAddress, remotePort);

                Console.WriteLine("Клиент подключен к {0} Слушает порт {1}\nВведите команду: ", endPoint, localPort);

                receiveThread = new Thread(new ThreadStart(ReceiveFile));
                receiveThread.IsBackground = true;
                receiveThread.Start();
                SendFile();
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
            finally
            {
                Console.ReadLine();
            }
        }
        private static void SendFile()
        {
            try
            {
                while (true)
                {
                    string command = Console.ReadLine().ToString();
                    if (command.IndexOf("send") == 0)
                    {
                        string message = "";
                        byte[] data = Encoding.Unicode.GetBytes(message);
                        sender.Send(data, data.Length, endPoint);

                        for (int i = 5; i < command.Length; i++)
                        {
                            file += command[i];
                        }
                        for (int i = 0; i < file.Length; i++)
                        {
                            if (file[i] == '.')
                            {
                                k = (file.Length - 1) - i;
                            }
                        }

                        fs = new FileStream(@file, FileMode.Open, FileAccess.Read);
                        file = "";
                        Byte[] bytes = new Byte[fs.Length];
                        fs.Read(bytes, 0, bytes.Length);
                        Console.WriteLine("Отправка файла размером " + fs.Length + " байт");

                        SendFileInfo();
                        Thread.Sleep(2000);
                        sender.Send(bytes, bytes.Length, endPoint);
                        fs.Close();
                    }
                    else if (command.IndexOf("down") == 0)
                    {
                        string message = command;
                        byte[] data = Encoding.Unicode.GetBytes(message);
                        sender.Send(data, data.Length, endPoint);
                    }
                    else if (command.IndexOf("exit") == 0)
                    {
                        string message = "exit";
                        byte[] data = Encoding.Unicode.GetBytes(message);
                        sender.Send(data, data.Length, endPoint);
                        receiveThread.Abort();
                        Console.WriteLine("Сервер завершил соединение с клиентом.");
                        break;
                    }
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
            finally
            {
                sender.Close();
            }
        }

        private static void ReceiveFile()
        {
            receiver = new UdpClient(localPort);
            try
            {
                while (true)
                {
                    GetFileDetails();
                    Console.WriteLine("\n-----------*******Ожидайте получение файла с сервера*******-----------");
                    data = receiver.Receive(ref RemoteIpEndPoint);
                    Console.WriteLine("----Файл получен...Сохраняем...");

                    fs = new FileStream("temp." + fileDet.FILETYPE, FileMode.Create, FileAccess.ReadWrite, FileShare.ReadWrite);
                    fs.Write(data, 0, data.Length);

                    Console.WriteLine("----Файл сохранен...");
                    Console.WriteLine("Введите команду: ");
                    fs.Close();
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
            finally
            {
                receiver.Close();
            }
        }

        private static void GetFileDetails()
        {
            try
            {
                data = receiver.Receive(ref RemoteIpEndPoint);
                Console.WriteLine("----Информация о файле получена!");

                XmlSerializer fileSerializer = new XmlSerializer(typeof(FileDetails));
                MemoryStream stream1 = new MemoryStream();

                stream1.Write(data, 0, data.Length);
                stream1.Position = 0;

                fileDet = (FileDetails)fileSerializer.Deserialize(stream1);
                Console.WriteLine("Получен файл типа ." + fileDet.FILETYPE +
                    " имеющий размер " + fileDet.FILESIZE.ToString() + " байт");
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.ToString());
            }
        }

        public static void SendFileInfo()
        {
            try
            {
                fileDet.FILETYPE = fs.Name.Substring((int)fs.Name.Length - k, k);
                fileDet.FILESIZE = fs.Length;

                XmlSerializer fileSerializer = new XmlSerializer(typeof(FileDetails));
                MemoryStream stream = new MemoryStream();

                fileSerializer.Serialize(stream, fileDet);

                stream.Position = 0;
                Byte[] bytes = new Byte[stream.Length];
                stream.Read(bytes, 0, Convert.ToInt32(stream.Length));

                Console.WriteLine("Отправка деталей файла...");

                sender.Send(bytes, bytes.Length, endPoint);
                Console.WriteLine("Файл отправлен\n\nВведите команду: ");
                stream.Close();
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
        }
    }
}