using System;
using MySql.Data.MySqlClient;
using System.Threading;

namespace JustProject
{
    class Program
    {
        public static MySqlConnection Connection_Handle;
        public static bool Chat_Active = true;

        const int THREAD_TIME = 500; //Время задержки потока после получения сообщений(Минимальное: 500. Рекомендованное: 1000)
        const bool TRUNCATE_TABLES = true; // Очищать таблицу сообщений при подключении к каналу?

        const string SQL_HOSTING = "localhost"; // Хостинг базы
        const string SQL_DATABASE = "sqlsharp"; // Название базы
        const string SQL_USER = "root"; // Пользователь базы
        const string SQL_PASSWORD = ""; // Пароль от базы

        class newThread{
            Thread thread;

            public newThread(string name,int canal){
                thread = new Thread(CheckDataBaseThread);
                thread.Name = name;
                thread.Start(canal);
            }
            void CheckDataBaseThread(object Canal_Stream){
                string sqlquery = "SELECT * FROM `Messages` WHERE `Canal` != '"+(int)Canal_Stream+"' ORDER BY `Id` ASC LIMIT 1";

                while(Chat_Active == true){
                    MySqlCommand command = new MySqlCommand();
                    command.Connection = Connection_Handle;
                    command.CommandText = sqlquery;
                    try{
                        using(MySqlDataReader reader = command.ExecuteReader()){
                            reader.Read();
                            if(reader.HasRows){
                                int row_id = -1;
                                int canal = -1;
                                string row_message = "";

                                if(row_message.Equals("стоп"))break;
                                try{
                                    int message_row = reader.GetOrdinal("Message");
                                    row_message = reader.GetString(message_row);
                                    int id_row = reader.GetOrdinal("Id");
                                    row_id = reader.GetInt32(id_row);
                                    int canal_row = reader.GetOrdinal("Canal");
                                    canal = reader.GetInt32(canal_row);
                                }catch(Exception e){
                                    Console.WriteLine("Ошибка при получении: "+e.Message);
                                }

                                Console.WriteLine("<<--- Собеседник(Канал {1}): {0} --->>",row_message,canal);

                                reader.Close();
                                reader.Dispose();
                                DeleteFromMysql(Connection_Handle,row_id);
                            }else{
                                reader.Close();
                                reader.Dispose();
                            }
                        }
                    }catch(Exception){
                        break;
                    }
                    Thread.Sleep(1000);
                }
            }
        }
        public static void Main(){

            string connection_string = "";
            CreateConnectionString(ref connection_string,SQL_HOSTING,SQL_DATABASE,SQL_USER,SQL_PASSWORD);

            Connection_Handle = new MySqlConnection(connection_string);

            try{
                Console.WriteLine("<<---- Пытаюсь установить соединение... ---->>");
                Connection_Handle.Open();
                Console.WriteLine("<<---- Соединение установлено ---->>");
            }catch(Exception e){
                Console.WriteLine("Ошибка: {0}",e.Message);
                Console.WriteLine("Press any key to continue...");
                Console.ReadKey(true);
                return;
            }

            int Canal = -1;
            while(Canal < 0 || Canal > 99){
                try{
                    Console.WriteLine("Укажите номер канала (Не должен совпадать с другим каналом) 0-99");
                    Canal = Convert.ToInt32(Console.ReadLine());
                    if(Canal < 0 || Canal > 99)continue;
                    break;
                }catch(Exception){
                    continue;
                }
            }
            try{
                MySqlCommand truncate = new MySqlCommand("TRUNCATE TABLE `Messages`",Connection_Handle);
                truncate.ExecuteNonQuery();

                newThread thread_check = new newThread("BaseCheck",Canal);
                ExecuteProgramm(Connection_Handle,Canal);

                Connection_Handle.Close();
            }catch(Exception e){
                Console.WriteLine("Ошибка при выполнении: "+e.Message);
            }
            Console.WriteLine("Разговор окончен");
            Console.WriteLine("Press any key to continue...");
            Console.ReadKey(true);
            return;
        }
        private static void CreateConnectionString(ref string connection_string,string host,string database,string user,string pass,int port = 3306){
            connection_string = "Server="+ host +";Database="+database+";port="+port+";User Id="+user+";password="+pass;
        }
        private static void DeleteFromMysql(MySqlConnection handle,int id){
            string query = "DELETE FROM `Messages` WHERE `Id` = '"+id+"'";
            try{
                MySqlCommand deletecommand = new MySqlCommand(query,handle);

                deletecommand.ExecuteNonQuery();

                deletecommand.Dispose();
            }catch(Exception e){
                Console.WriteLine("Ошибка при выполнении запроса: "+e.Message);
            }
        }
        private static void ExecuteProgramm(MySqlConnection handle,int Canal_Stream){
            string text_insert = "";

            Console.WriteLine("<<------------------------------>>");
            Console.WriteLine("Для остановки введите !стоп");
            Console.WriteLine("Введите первое сообщение");
            while(!text_insert.Equals("!стоп") && Chat_Active == true){
                text_insert = Console.ReadLine();

                if(text_insert.Equals("!стоп")){
                    Chat_Active = false;
                    break;
                }

                string query = "INSERT INTO `Messages` (`Message`,`Canal`) VALUES ('"+ text_insert +"','"+ Canal_Stream +"')";
                try{
                    MySqlCommand command = new MySqlCommand(query,handle);
                    command.ExecuteNonQuery();
                    command.Dispose();
                    Console.WriteLine("<<---- Сообщение отправлено ---->>");
                }catch(Exception e){
                    Console.WriteLine("Ошибка при добавлении: "+e.Message);
                }
            }
        }
    }
}