88 lines
3.7 KiB
C#
88 lines
3.7 KiB
C#
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
|
|
}
|
|
}
|
|
} |