using Quartz;

internal static class QuartzScheduling
{
    public static readonly JobKey ScheduleMonitoringChecksJobKey = JobKey.Create(nameof(ScheduleMonitoringChecksJob));

    public static readonly TriggerKey ScheduleMonitoringChecksTriggerKey = new(
        "interval",
        nameof(ScheduleMonitoringChecksJob)
    );
}

internal sealed class IntervalScheduler(ISchedulerFactory schedulerFactory, ScreeningRepository repository)
{
    public async Task ApplyStoredIntervalAsync(CancellationToken cancellationToken = default)
    {
        var settings = await repository.GetAppSettingsAsync(cancellationToken);
        await RescheduleAsync(settings.IntervalSeconds, cancellationToken);
    }

    public async Task RescheduleAsync(int intervalSeconds, CancellationToken cancellationToken = default)
    {
        var scheduler = await schedulerFactory.GetScheduler(cancellationToken);
        var seconds = Math.Max(60, intervalSeconds);
        var trigger = TriggerBuilder
            .Create()
            .ForJob(QuartzScheduling.ScheduleMonitoringChecksJobKey)
            .WithIdentity(QuartzScheduling.ScheduleMonitoringChecksTriggerKey)
            .StartNow()
            .WithSimpleSchedule(s => s.WithIntervalInSeconds(seconds).RepeatForever())
            .Build();

        if (await scheduler.CheckExists(QuartzScheduling.ScheduleMonitoringChecksTriggerKey, cancellationToken))
        {
            await scheduler.RescheduleJob(
                QuartzScheduling.ScheduleMonitoringChecksTriggerKey,
                trigger,
                cancellationToken
            );
        }
    }
}