Worker.cs

using Microsoft.Extensions.Hosting;
using Microsoft.Extensions.Logging;
using Microsoft.Extensions.Options;
using Polly;

namespace Vultar;

internal sealed class Worker(
    ILogger<Worker> logger,
    IOptionsMonitor<VultarSettings> options,
    ResiliencePipeline pipeline
) : BackgroundService
{
    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        var settings = options.CurrentValue;
        logger.WorkerStarted(settings.Interval);

        using var timer = new PeriodicTimer(settings.Interval);

        options.OnChange(newSettings =>
        {
            logger.WorkerStarted(newSettings.Interval);
        });

        try
        {
            while (await timer.WaitForNextTickAsync(stoppingToken))
            {
                await ExecuteWorkAsync(stoppingToken);
            }
        }
        catch (OperationCanceledException)
        {
            logger.WorkerStopping();
        }
    }

    private async Task ExecuteWorkAsync(CancellationToken stoppingToken)
    {
        try
        {
            await pipeline.ExecuteAsync(async token =>
            {
                await RunAsync(token);
            }, stoppingToken);
        }
        catch (Exception ex)
        {
            logger.ExecutionFailed(ex);
        }
    }

    private async Task RunAsync(CancellationToken token)
    {
        logger.Executing(DateTimeOffset.Now);
        await Task.Delay(100, token);
    }
}