using Eis.Infrastructure.Authentication;
using Eis.Infrastructure.Data;
using Microsoft.Data.Sqlite;

namespace Eis.Infrastructure.Tests.Data;

public sealed class DatabaseInitializerTests
{
    [Fact]
    public async Task InitializeAsync_CreatesFreshDatabaseAndIsIdempotent()
    {
        var root = Path.Combine(Path.GetTempPath(), $"eis-fresh-init-{Guid.NewGuid():N}");
        var path = Path.Combine(root, "eis.sqlite");
        Directory.CreateDirectory(root);
        try
        {
            var options = DatabaseOptions.CreateSqliteForTests(path);
            var factory = new RelationalConnectionFactory(options);
            var passwords = new PasswordCompatibilityService();
            var initializer = new DatabaseInitializer(factory, options, passwords);

            await initializer.InitializeAsync(CancellationToken.None);
            await initializer.InitializeAsync(CancellationToken.None);

            await using var connection = new SqliteConnection($"Data Source={path}");
            await connection.OpenAsync();
            Assert.True(await ScalarAsync(connection,
                "SELECT COUNT(*) FROM sqlite_master WHERE type = 'table' AND name NOT LIKE 'sqlite_%'") >= 32);
            Assert.Equal(20, await ScalarAsync(connection,
                "SELECT schema_version FROM schema_metadata WHERE id = 1"));
            Assert.Equal(1, await ScalarAsync(connection,
                "SELECT COUNT(*) FROM users WHERE id = 'usr_admin' AND role = 'admin' AND admin_level = 'super'"));
            Assert.Equal(5, await ScalarAsync(connection,
                "SELECT COUNT(*) FROM workflow_definitions WHERE active = 1"));
            Assert.Equal(4, await ScalarAsync(connection,
                "SELECT COUNT(*) FROM admission_number_rules WHERE active = 1"));
            await connection.DisposeAsync();
            SqliteConnection.ClearAllPools();
        }
        finally
        {
            if (Directory.Exists(root)) Directory.Delete(root, recursive: true);
        }
    }

    private static async Task<long> ScalarAsync(SqliteConnection connection, string sql)
    {
        await using var command = connection.CreateCommand();
        command.CommandText = sql;
        return Convert.ToInt64(await command.ExecuteScalarAsync());
    }
}