// Copyright (c) .NET Foundation and contributors. All rights reserved.
// Licensed under the MIT license. See LICENSE file in the project root for full license information.

using System;
using System.Threading.Tasks;
using FluentAssertions;
using Microsoft.Data.Sqlite;
using Microsoft.DotNet.Interactive.App;
using Microsoft.DotNet.Interactive.CSharp;
using Microsoft.DotNet.Interactive.Events;
using Microsoft.DotNet.Interactive.Formatting;
using Microsoft.DotNet.Interactive.Tests.Utility;
using Xunit;

namespace Microsoft.DotNet.Interactive.SQLite.Tests;

[Trait("Databases", "Data query tests")]
public class SQLiteConnectionTests
{
   
    [WindowsFact]
    public async Task It_can_connect_and_query_data()
    {
        using var kernel = new CompositeKernel
        {
            new CSharpKernel().UseNugetDirective(),
            new KeyValueStoreKernel()
        };

        kernel.AddConnectDirective(new ConnectSQLiteDirective());

        using var _ = CreateInMemorySQLiteDb(out var connectionString);

        var result = await kernel.SubmitCodeAsync(
                         $"""
                          #!connect sqlite --kernel-name mydb  "{connectionString}"
                          """);

        result.Events
            .Should()
            .NotContainErrors();

        result = await kernel.SubmitCodeAsync(@"
#!sql-mydb
SELECT * FROM fruit
");

        result.Events.Should().NotContainErrors();

        result.Events.Should()
              .ContainSingle<DisplayedValueProduced>()
              .Which
              .FormattedValues
              .Should()
              .ContainSingle(f => f.MimeType == HtmlFormatter.MimeType);
    }

    internal static IDisposable CreateInMemorySQLiteDb(out string connectionString)
    {
        connectionString = $"Data Source=InMemorySample_{Guid.NewGuid():N};Mode=Memory;Cache=Shared";
        var topLevelConnection = new SqliteConnection(connectionString);
        topLevelConnection.Open();

        var createCommand = topLevelConnection.CreateCommand();
        createCommand.CommandText =
            @"
DROP TABLE IF EXISTS fruit;  
CREATE TABLE fruit (
    id INTEGER PRIMARY KEY,
    name TEXT NOT NULL,
    color TEXT NOT NULL,
    deliciousness INT NOT NULL 
);
            ";
        var result = createCommand.ExecuteNonQuery();

        using var connection = new SqliteConnection(connectionString);

        connection.Open();

        var updateCommand = connection.CreateCommand();
        updateCommand.CommandText =
            @"
INSERT INTO fruit (name, color, deliciousness)
VALUES ('apple', 'green', 10);

INSERT INTO fruit (name, color, deliciousness)
VALUES ('banana', 'red', 11);

INSERT INTO fruit (name, color, deliciousness)
VALUES ('cherry', 'red', 9000);
                ";
        result = updateCommand.ExecuteNonQuery();

        return topLevelConnection;
    }
}