using Hangfire;

using Hangfire.Dashboard.BasicAuthorization;

using Hangfire.HttpJob;

using Hangfire.MySql;

using System.Configuration;

using System.Transactions;

using static System.Net.WebRequestMethods;

var builder = WebApplication.CreateBuilder(args);

var Config = builder.Configuration;

// Add Hangfire services.

builder.Services.AddHangfire(configuration => configuration

    .SetDataCompatibilityLevel(CompatibilityLevel.Version_170)

    .UseSimpleAssemblyNameTypeSerializer()

    .UseRecommendedSerializerSettings()

    .UseStorage(new MySqlStorage(

        Config["ConnectionStrings:HangfireConnection"],

        new MySqlStorageOptions

        {

            TransactionIsolationLevel = IsolationLevel.ReadCommitted,

            QueuePollInterval = TimeSpan.FromSeconds(15),

            JobExpirationCheckInterval = TimeSpan.FromHours(1),

            CountersAggregateInterval = TimeSpan.FromMinutes(5),

            PrepareSchemaIfNecessary = true,

            DashboardJobListLimit = 50000,

            TransactionTimeout = TimeSpan.FromMinutes(1),

            TablesPrefix = "Hangfire"

        })).UseHangfireHttpJob());

// Add the processing server as IHostedService

builder.Services.AddHangfireServer();

var app = builder.Build();

app.UseHangfireDashboard("/hangfire", new DashboardOptions

{

    Authorization = new[] {new BasicAuthAuthorizationFilter(new BasicAuthAuthorizationFilterOptions

    {

        RequireSsl = false,

        SslRedirect = false,

        LoginCaseSensitive = true,

        Users = new []

        {

            new BasicAuthAuthorizationUser

                    {

                        Login = "admin",

                        PasswordClear =  "admin"

                    }

        }

    })}

});

app.UseRouting();

app.UseEndpoints(endpoints =>

{

    endpoints.MapGet("/", async context =>

    {

        await context.Response.WriteAsync("Hello World!");

    });

});

//app.MapGet("/", () => "Hello World!");

app.Run();