using JSMR.Application.Enums;
using JSMR.Application.Scanning;
using JSMR.Application.Scanning.Ports;
using JSMR.Infrastructure.Common.Time;
using JSMR.Worker.Options;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;
using System.Globalization;

namespace JSMR.Worker.Services;

public sealed class PagedScanRunner(
    ILogger<PagedScanRunner> log,
    IServiceProvider serviceProvider,
    ICheckpointStore checkpoints)
{
    public async Task RunAsync(ScanOptions options, CancellationToken cancellationToken)
    {
        if (Enum.TryParse(options.Locale, ignoreCase: true, out Locale locale) == false)
            throw new ArgumentException($"Unknown locale '{options.Locale}'.");

        int pageSize = options.PageSize ?? 100;

        int startPage = options.StartPage
            ?? (await checkpoints.GetLastPageAsync(options.Locale, cancellationToken)).GetValueOrDefault(0) + 1;

        ITimeProvider timeProvider = serviceProvider.GetRequiredService<ITimeProvider>();

        log.LogInformation("Scanning on {ScanTime}...", timeProvider.Now().DateTime.ToString(CultureInfo.CurrentCulture));

        while (!cancellationToken.IsCancellationRequested)
        {
            int currentPage = startPage;
            int? end = options.EndPage;

            // Iterate until empty page or end reached
            for (; !cancellationToken.IsCancellationRequested && (!end.HasValue || currentPage <= end.Value); currentPage++)
            {
                using var scope = serviceProvider.CreateScope();
                ScanVoiceWorksHandler handler = scope.ServiceProvider.GetRequiredService<ScanVoiceWorksHandler>();

                log.LogInformation("Scanning page {Page} (size {Size}, locale {Locale})…", currentPage, pageSize, locale);

                ScanVoiceWorksRequest request = new(
                    PageNumber: currentPage,
                    PageSize: 100,
                    Locale: locale
                );

                ScanVoiceWorksResponse response = await handler.HandleAsync(request, cancellationToken);

                //int newUpcoming = response.Results.Where(x => x.IsNewUpcoming == true).Count();

                //if (newUpcoming > 0)
                //    updatedInfo.Add($"{newUpcoming} new upcoming work(s)");

                //int newOnSale = result.ScannedVoiceWorks.Where(x => x.IsNewOnSale == true).Count();

                //if (newOnSale > 0)
                //    updatedInfo.Add($"{newOnSale} new work(s) on sale");

                IEnumerable<VoiceWorkUpsertResult> resultsWithIssues = response.Results.Where(x => x.Issues.Count > 0);

                //foreach (VoiceWorkUpsertResult resultWithIssues in resultsWithIssues)
                //{
                //    log.LogWarning($"PRoblem with {resultWithIssues.}")
                //    string messageToDisplay = $"{scannedVoiceWork.ProductId} - {scannedVoiceWork.ProductName} -- {message}";

                //    Console.WriteLine(messageToDisplay);
                //    messages.Add(messageToDisplay);
                //}

                // Save checkpoint
                await checkpoints.SaveLastPageAsync(options.Locale, currentPage, cancellationToken);
            }

            if (!options.Watch) break;

            log.LogInformation("Watch mode: sleeping {Interval}…", options.Interval);
            await Task.Delay(options.Interval, cancellationToken);

            // Compute next “start” for next cycle:
            // - If you want to re-scan the latest N pages every loop to catch late updates,
            //   modify logic here (e.g., start = Math.Max(1, current - 2))
            startPage = currentPage; // continue from where we left off
        }
    }
}