using System;
using System.Collections.Generic;
using System.Data;
using Microsoft.Data.Sqlite;
using System.IO;
using System.Threading.Tasks;

namespace DiscordBotCore.Database;

public class SqlDatabase
{
    private readonly SqliteConnection _Connection;

    /// <summary>
    ///     Initialize a SQL connection by specifying its private path
    /// </summary>
    /// <param name="fileName">The path to the database (it is starting from ./Data/Resources/)</param>
    public SqlDatabase(string fileName)
    {
        var connectionString = $"Data Source={fileName}";
        _Connection = new SqliteConnection(connectionString);
        
    }


    /// <summary>
    ///     Open the SQL Connection. To close use the Stop() method
    /// </summary>
    /// <returns></returns>
    public async Task Open()
    {
        await _Connection.OpenAsync();
    }

    /// <summary>
    ///     <para>
    ///         Insert into a specified table some values
    ///     </para>
    /// </summary>
    /// <param name="tableName">The table name</param>
    /// <param name="values">The values to be inserted (in the correct order and number)</param>
    /// <returns></returns>
    public async Task InsertAsync(string tableName, params string[] values)
    {
        var query = $"INSERT INTO {tableName} VALUES (";
        for (var i = 0; i < values.Length; i++)
        {
            query += $"'{values[i]}'";
            if (i != values.Length - 1)
                query += ", ";
        }

        query += ")";

        var command = new SqliteCommand(query, _Connection);
        await command.ExecuteNonQueryAsync();
    }

    /// <summary>
    ///     <para>
    ///         Insert into a specified table some values
    ///     </para>
    /// </summary>
    /// <param name="tableName">The table name</param>
    /// <param name="values">The values to be inserted (in the correct order and number)</param>
    /// <returns></returns>
    public void Insert(string tableName, params string[] values)
    {
        var query = $"INSERT INTO {tableName} VALUES (";
        for (var i = 0; i < values.Length; i++)
        {
            query += $"'{values[i]}'";
            if (i != values.Length - 1)
                query += ", ";
        }

        query += ")";

        var command = new SqliteCommand(query, _Connection);
        command.ExecuteNonQuery();
    }

    /// <summary>
    ///     Remove every row in a table that has a certain propery
    /// </summary>
    /// <param name="tableName">The table name</param>
    /// <param name="KeyName">The column name that the search is made by</param>
    /// <param name="KeyValue">The value that is searched in the specified column</param>
    /// <returns></returns>
    public async Task RemoveKeyAsync(string tableName, string KeyName, string KeyValue)
    {
        var query = $"DELETE FROM {tableName} WHERE {KeyName} = '{KeyValue}'";

        var command = new SqliteCommand(query, _Connection);
        await command.ExecuteNonQueryAsync();
    }

    /// <summary>
    ///     Remove every row in a table that has a certain propery
    /// </summary>
    /// <param name="tableName">The table name</param>
    /// <param name="KeyName">The column name that the search is made by</param>
    /// <param name="KeyValue">The value that is searched in the specified column</param>
    /// <returns></returns>
    public void RemoveKey(string tableName, string KeyName, string KeyValue)
    {
        var query = $"DELETE FROM {tableName} WHERE {KeyName} = '{KeyValue}'";

        var command = new SqliteCommand(query, _Connection);
        command.ExecuteNonQuery();
    }

    /// <summary>
    ///     Check if the key exists in the table
    /// </summary>
    /// <param name="tableName">The table name</param>
    /// <param name="keyName">The column that the search is made by</param>
    /// <param name="KeyValue">The value that is searched in the specified column</param>
    /// <returns></returns>
    public async Task<bool> KeyExistsAsync(string tableName, string keyName, string KeyValue)
    {
        var query = $"SELECT * FROM {tableName} where {keyName} = '{KeyValue}'";

        if (await ReadDataAsync(query) is not null)
            return true;

        return false;
    }

    /// <summary>
    ///     Check if the key exists in the table
    /// </summary>
    /// <param name="tableName">The table name</param>
    /// <param name="keyName">The column that the search is made by</param>
    /// <param name="KeyValue">The value that is searched in the specified column</param>
    /// <returns></returns>
    public bool KeyExists(string tableName, string keyName, string KeyValue)
    {
        var query = $"SELECT * FROM {tableName} where {keyName} = '{KeyValue}'";

        if (ReadData(query) is not null)
            return true;

        return false;
    }

    /// <summary>
    ///     Set value of a column in a table
    /// </summary>
    /// <param name="tableName">The table name</param>
    /// <param name="keyName">The column that the search is made by</param>
    /// <param name="KeyValue">The value that is searched in the column specified</param>
    /// <param name="ResultColumnName">The column that has to be modified</param>
    /// <param name="ResultColumnValue">The new value that will replace the old value from the column specified</param>
    public async Task SetValueAsync(
        string tableName, string keyName, string KeyValue, string ResultColumnName,
        string ResultColumnValue)
    {
        if (!await TableExistsAsync(tableName))
            throw new Exception($"Table {tableName} does not exist");

        await ExecuteAsync(
            $"UPDATE {tableName} SET {ResultColumnName}='{ResultColumnValue}' WHERE {keyName}='{KeyValue}'"
        );
    }

    /// <summary>
    ///     Set value of a column in a table
    /// </summary>
    /// <param name="tableName">The table name</param>
    /// <param name="keyName">The column that the search is made by</param>
    /// <param name="KeyValue">The value that is searched in the column specified</param>
    /// <param name="ResultColumnName">The column that has to be modified</param>
    /// <param name="ResultColumnValue">The new value that will replace the old value from the column specified</param>
    public void SetValue(
        string tableName, string keyName, string KeyValue, string ResultColumnName,
        string ResultColumnValue)
    {
        if (!TableExists(tableName))
            throw new Exception($"Table {tableName} does not exist");

        Execute($"UPDATE {tableName} SET {ResultColumnName}='{ResultColumnValue}' WHERE {keyName}='{KeyValue}'");
    }

    /// <summary>
    ///     Get value from a column in a table
    /// </summary>
    /// <param name="tableName">The table name</param>
    /// <param name="keyName">The column that the search is made by</param>
    /// <param name="KeyValue">The value that is searched in the specified column</param>
    /// <param name="ResultColumnName">The column that has the result</param>
    /// <returns>A string that has the requested value (can be null if nothing found)</returns>
    public async Task<string?> GetValueAsync(
        string tableName, string keyName, string KeyValue,
        string ResultColumnName)
    {
        if (!await TableExistsAsync(tableName))
            throw new Exception($"Table {tableName} does not exist");

        return await ReadDataAsync($"SELECT {ResultColumnName} FROM {tableName} WHERE {keyName}='{KeyValue}'");
    }

    /// <summary>
    ///     Get value from a column in a table
    /// </summary>
    /// <param name="tableName">The table name</param>
    /// <param name="keyName">The column that the search is made by</param>
    /// <param name="KeyValue">The value that is searched in the specified column</param>
    /// <param name="ResultColumnName">The column that has the result</param>
    /// <returns>A string that has the requested value (can be null if nothing found)</returns>
    public string? GetValue(string tableName, string keyName, string KeyValue, string ResultColumnName)
    {
        if (!TableExists(tableName))
            throw new Exception($"Table {tableName} does not exist");

        return ReadData($"SELECT {ResultColumnName} FROM {tableName} WHERE {keyName}='{KeyValue}'");
    }

    /// <summary>
    ///     Stop the connection to the SQL Database
    /// </summary>
    /// <returns></returns>
    public async void Stop()
    {
        await _Connection.CloseAsync();
    }

    /// <summary>
    ///     Change the structure of a table by adding new columns
    /// </summary>
    /// <param name="tableName">The table name</param>
    /// <param name="columns">The columns to be added</param>
    /// <param name="TYPE">The type of the columns (TEXT, INTEGER,  FLOAT, etc)</param>
    /// <returns></returns>
    public async Task AddColumnsToTableAsync(string tableName, string[] columns, string TYPE = "TEXT")
    {
        var command = _Connection.CreateCommand();
        command.CommandText = $"SELECT * FROM {tableName}";
        var reader       = await command.ExecuteReaderAsync();
        var tableColumns = new List<string>();
        for (var i = 0; i < reader.FieldCount; i++)
            tableColumns.Add(reader.GetName(i));

        foreach (var column in columns)
            if (!tableColumns.Contains(column))
            {
                command.CommandText = $"ALTER TABLE {tableName} ADD COLUMN {column} {TYPE}";
                await command.ExecuteNonQueryAsync();
            }
    }

    /// <summary>
    ///     Change the structure of a table by adding new columns
    /// </summary>
    /// <param name="tableName">The table name</param>
    /// <param name="columns">The columns to be added</param>
    /// <param name="TYPE">The type of the columns (TEXT, INTEGER,  FLOAT, etc)</param>
    /// <returns></returns>
    public void AddColumnsToTable(string tableName, string[] columns, string TYPE = "TEXT")
    {
        var command = _Connection.CreateCommand();
        command.CommandText = $"SELECT * FROM {tableName}";
        var reader       = command.ExecuteReader();
        var tableColumns = new List<string>();
        for (var i = 0; i < reader.FieldCount; i++)
            tableColumns.Add(reader.GetName(i));

        foreach (var column in columns)
            if (!tableColumns.Contains(column))
            {
                command.CommandText = $"ALTER TABLE {tableName} ADD COLUMN {column} {TYPE}";
                command.ExecuteNonQuery();
            }
    }

    /// <summary>
    ///     Check if a table exists
    /// </summary>
    /// <param name="tableName">The table name</param>
    /// <returns>True if the table exists, false if not</returns>
    public async Task<bool> TableExistsAsync(string tableName)
    {
        var cmd = _Connection.CreateCommand();
        cmd.CommandText = $"SELECT name FROM sqlite_master WHERE type='table' AND name='{tableName}'";
        var result = await cmd.ExecuteScalarAsync();

        if (result == null)
            return false;
        return true;
    }

    /// <summary>
    ///     Check if a table exists
    /// </summary>
    /// <param name="tableName">The table name</param>
    /// <returns>True if the table exists, false if not</returns>
    public bool TableExists(string tableName)
    {
        var cmd = _Connection.CreateCommand();
        cmd.CommandText = $"SELECT name FROM sqlite_master WHERE type='table' AND name='{tableName}'";
        var result = cmd.ExecuteScalar();

        if (result == null)
            return false;
        return true;
    }

    /// <summary>
    ///     Create a table
    /// </summary>
    /// <param name="tableName">The table name</param>
    /// <param name="columns">The columns of the table</param>
    /// <returns></returns>
    public async Task CreateTableAsync(string tableName, params string[] columns)
    {
        var cmd = _Connection.CreateCommand();
        cmd.CommandText = $"CREATE TABLE IF NOT EXISTS {tableName} ({string.Join(", ", columns)})";
        await cmd.ExecuteNonQueryAsync();
    }

    /// <summary>
    ///     Create a table
    /// </summary>
    /// <param name="tableName">The table name</param>
    /// <param name="columns">The columns of the table</param>
    /// <returns></returns>
    public void CreateTable(string tableName, params string[] columns)
    {
        var cmd = _Connection.CreateCommand();
        cmd.CommandText = $"CREATE TABLE IF NOT EXISTS {tableName} ({string.Join(", ", columns)})";
        cmd.ExecuteNonQuery();
    }

    /// <summary>
    ///     Execute a custom query
    /// </summary>
    /// <param name="query">The query</param>
    /// <returns>The number of rows that the query modified</returns>
    public async Task<int> ExecuteAsync(string query)
    {
        if (!_Connection.State.HasFlag(ConnectionState.Open))
            await _Connection.OpenAsync();
        var command = new SqliteCommand(query, _Connection);
        var answer  = await command.ExecuteNonQueryAsync();
        return answer;
    }

    /// <summary>
    ///     Execute a custom query
    /// </summary>
    /// <param name="query">The query</param>
    /// <returns>The number of rows that the query modified</returns>
    public int Execute(string query)
    {
        if (!_Connection.State.HasFlag(ConnectionState.Open))
            _Connection.Open();
        var command = new SqliteCommand(query, _Connection);
        var r       = command.ExecuteNonQuery();

        return r;
    }

    /// <summary>
    ///     Read data from the result table and return the first row
    /// </summary>
    /// <param name="query">The query</param>
    /// <returns>The result is a string that has all values separated by space character</returns>
    public async Task<string?> ReadDataAsync(string query)
    {
        if (!_Connection.State.HasFlag(ConnectionState.Open))
            await _Connection.OpenAsync();
        var command = new SqliteCommand(query, _Connection);
        var reader  = await command.ExecuteReaderAsync();

        var values = new object[reader.FieldCount];
        if (reader.Read())
        {
            reader.GetValues(values);
            return string.Join<object>(" ", values);
        }

        return null;
    }

    /// <summary>
    ///     Read data from the result table and return the first row
    /// </summary>
    /// <param name="query">The query</param>
    /// <param name="parameters">The parameters of the query</param>
    /// <returns>The result is a string that has all values separated by space character</returns>
    public async Task<string?> ReadDataAsync(string query, params KeyValuePair<string, object>[] parameters)
    {
        if (!_Connection.State.HasFlag(ConnectionState.Open))
            await _Connection.OpenAsync();

        var command = new SqliteCommand(query, _Connection);
        foreach (var parameter in parameters)
        {
            var p = CreateParameter(parameter);
            if (p is not null)
                command.Parameters.Add(p);
        }

        var reader = await command.ExecuteReaderAsync();

        var values = new object[reader.FieldCount];
        if (reader.Read())
        {
            reader.GetValues(values);
            return string.Join<object>(" ", values);
        }

        return null;
    }

    /// <summary>
    ///     Read data from the result table and return the first row
    /// </summary>
    /// <param name="query">The query</param>
    /// <returns>The result is a string that has all values separated by space character</returns>
    public string? ReadData(string query)
    {
        if (!_Connection.State.HasFlag(ConnectionState.Open))
            _Connection.Open();
        var command = new SqliteCommand(query, _Connection);
        var reader  = command.ExecuteReader();

        var values = new object[reader.FieldCount];
        if (reader.Read())
        {
            reader.GetValues(values);
            return string.Join<object>(" ", values);
        }

        return null;
    }

    /// <summary>
    ///     Read data from the result table and return the first row
    /// </summary>
    /// <param name="query">The query</param>
    /// <returns>The first row as separated items</returns>
    public async Task<object[]?> ReadDataArrayAsync(string query)
    {
        if (!_Connection.State.HasFlag(ConnectionState.Open))
            await _Connection.OpenAsync();
        var command = new SqliteCommand(query, _Connection);
        var reader  = await command.ExecuteReaderAsync();

        var values = new object[reader.FieldCount];
        if (reader.Read())
        {
            reader.GetValues(values);
            return values;
        }

        return null;
    }

    public async Task<object[]?> ReadDataArrayAsync(string query, params KeyValuePair<string, object>[] parameters)
    {
        if (!_Connection.State.HasFlag(ConnectionState.Open))
            await _Connection.OpenAsync();

        var command = new SqliteCommand(query, _Connection);
        foreach (var parameter in parameters)
        {
            var p = CreateParameter(parameter);
            if (p is not null)
                command.Parameters.Add(p);
        }

        var reader = await command.ExecuteReaderAsync();

        var values = new object[reader.FieldCount];
        if (reader.Read())
        {
            reader.GetValues(values);
            return values;
        }

        return null;

    }
    
    /// <summary>
    ///     Read data from the result table and return the first row
    /// </summary>
    /// <param name="query">The query</param>
    /// <returns>The first row as separated items</returns>
    public object[]? ReadDataArray(string query)
    {
        if (!_Connection.State.HasFlag(ConnectionState.Open))
            _Connection.Open();
        var command = new SqliteCommand(query, _Connection);
        var reader  = command.ExecuteReader();

        var values = new object[reader.FieldCount];
        if (reader.Read())
        {
            reader.GetValues(values);
            return values;
        }

        return null;
    }

    /// <summary>
    ///     Read all rows from the result table and return them as a list of string arrays. The string arrays contain the
    ///     values of each row
    /// </summary>
    /// <param name="query">The query</param>
    /// <returns>A list of string arrays representing the values that the query returns</returns>
    public async Task<List<string[]>?> ReadAllRowsAsync(string query)
    {
        if (!_Connection.State.HasFlag(ConnectionState.Open))
            await _Connection.OpenAsync();
        var command = new SqliteCommand(query, _Connection);
        var reader  = await command.ExecuteReaderAsync();

        if (!reader.HasRows)
            return null;

        List<string[]> rows = new();
        while (await reader.ReadAsync())
        {
            var values = new string[reader.FieldCount];
            reader.GetValues(values);
            rows.Add(values);
        }

        if (rows.Count == 0) return null;

        return rows;
    }

    /// <summary>
    /// Create a parameter for a query
    /// </summary>
    /// <param name="name">The name of the parameter</param>
    /// <param name="value">The value of the parameter</param>
    /// <returns>The SQLiteParameter that has the name, value and DBType set according to your inputs</returns>
    private static SqliteParameter? CreateParameter(string name, object value)
    {
        var parameter = new SqliteParameter();
        parameter.ParameterName = name;
        parameter.Value = value;

        if (value is string)
            parameter.DbType = DbType.String;
        else if (value is int)
            parameter.DbType = DbType.Int32;
        else if (value is long)
            parameter.DbType = DbType.Int64;
        else if (value is float)
            parameter.DbType = DbType.Single;
        else if (value is double)
            parameter.DbType = DbType.Double;
        else if (value is bool)
            parameter.DbType = DbType.Boolean;
        else if (value is DateTime)
            parameter.DbType = DbType.DateTime;
        else if (value is byte[])
            parameter.DbType = DbType.Binary;
        else if (value is Guid)
            parameter.DbType = DbType.Guid;
        else if (value is decimal)
            parameter.DbType = DbType.Decimal;
        else if (value is TimeSpan)
            parameter.DbType = DbType.Time;
        else if (value is DateTimeOffset)
            parameter.DbType = DbType.DateTimeOffset;
        else if (value is ushort)
            parameter.DbType = DbType.UInt16;
        else if (value is uint)
            parameter.DbType = DbType.UInt32;
        else if (value is ulong)
            parameter.DbType = DbType.UInt64;
        else if (value is sbyte)
            parameter.DbType = DbType.SByte;
        else if (value is short)
            parameter.DbType = DbType.Int16;
        else if (value is byte)
            parameter.DbType = DbType.Byte;
        else if (value is char)
            parameter.DbType = DbType.StringFixedLength;
        else if (value is char[])
            parameter.DbType = DbType.StringFixedLength;
        else
            return null;

        return parameter;
    }


    /// <summary>
    /// Create a parameter for a query. The function automatically detects the type of the value.
    /// </summary>
    /// <param name="parameterValues">The parameter raw inputs. The Key is name and the Value is the value of the parameter</param>
    /// <returns>The SQLiteParameter that has the name, value and DBType set according to your inputs</returns>
    private static SqliteParameter? CreateParameter(KeyValuePair<string, object> parameterValues)
    {
        return CreateParameter(parameterValues.Key, parameterValues.Value);
    }

    /// <summary>
    /// Execute a query with parameters
    /// </summary>
    /// <param name="query">The query to execute</param>
    /// <param name="parameters">The parameters of the query</param>
    /// <returns>The number of rows that the query modified in the database</returns>
    public async Task<int> ExecuteNonQueryAsync(string query, params KeyValuePair<string, object>[] parameters)
    {
        if (!_Connection.State.HasFlag(ConnectionState.Open))
            await _Connection.OpenAsync();

        var command = new SqliteCommand(query, _Connection);
        foreach (var parameter in parameters)
        {
            var p = CreateParameter(parameter);
            if (p is not null)
                command.Parameters.Add(p);
        }

        return await command.ExecuteNonQueryAsync();
    }

    /// <summary>
    /// Execute a query with parameters that returns a specific type of object. The function will return the first row of the result transformed into the specified type.
    /// </summary>
    /// <param name="query">The query to execute</param>
    /// <param name="convertor">The convertor function that will convert each row of the response into an object of <typeparamref name="T"/></param>
    /// <param name="parameters">The parameters of the query</param>
    /// <typeparam name="T">The return object type</typeparam>
    /// <returns>An object of type T that represents the output of the convertor function based on the array of objects that the first row of the result has</returns>
    public async Task<T?> ReadObjectOfTypeAsync<T>(string query, Func<object[], T> convertor, params KeyValuePair<string, object>[] parameters)
    {
        if (!_Connection.State.HasFlag(ConnectionState.Open))
            await _Connection.OpenAsync();

        var command = new SqliteCommand(query, _Connection);
        foreach (var parameter in parameters)
        {
            var p = CreateParameter(parameter);
            if (p is not null)
                command.Parameters.Add(p);
        }

        var reader = await command.ExecuteReaderAsync();
        var values = new object[reader.FieldCount];
        if (reader.Read())
        {
            reader.GetValues(values);
            return convertor(values);
        }

        return default;
    }


    /// <summary>
    /// Execute a query with parameters that returns a specific type of object. The function will return a list of objects of the specified type.
    /// </summary>
    /// <param name="query">The query to execute</param>
    /// <param name="convertor">The convertor from object[] to T</param>
    /// <param name="parameters">The parameters of the query</param>
    /// <typeparam name="T">The expected object type</typeparam>
    /// <returns>A list of objects of type T that represents each line of the output of the specified query, converted to T</returns>
    public async Task<List<T>> ReadListOfTypeAsync<T>(string query, Func<object[], T> convertor,
        params KeyValuePair<string, object>[] parameters)
    {
        if (!_Connection.State.HasFlag(ConnectionState.Open))
            await _Connection.OpenAsync();

        var command = new SqliteCommand(query, _Connection);
        foreach (var parameter in parameters)
        {
            var p = CreateParameter(parameter);
            if (p is not null)
                command.Parameters.Add(p);
        }

        var reader = await command.ExecuteReaderAsync();
        //
        if (!reader.HasRows)
            return null;

        List<T> rows = new();
        while (await reader.ReadAsync())
        {
            var values = new object[reader.FieldCount];
            reader.GetValues(values);
            rows.Add(convertor(values));
        }

        return rows;
    }
}