AugusteVN.Worker 1.1.9

WorkerService

Re-usables for my multiple worker service setup that supports saving success or failure run to database.

WIP*

builder.Services
    .AddOptions<WorkerConfig>
    .BindConfiguration(nameof(WorkerConfig));

builder.Services.AddWorkerRunners(builder.Configuration, provider => provider.GetRequiredService<YourDbContext>());

// Or register separately

builder.Services.AddScoped<IWorkerDbContext>(provider => provider.GetRequiredService<YourDbContext>());

builder.Services.AddSingleton<IWorkerRunner, WorkerRunner>();
builder.Services.AddSingleton<IServiceRunner, ServiceRunner>();

protected override async Task ExecuteAsync(CancellationToken stoppingToken)
{
    var delayInMinutes = new AmountOfHours {Amount = _workerConfig.DelayInHours}.ToMinutes();
    var delayInMs = delayInMinutes * 1000;
    
    var weekDays = new HashSet<DayOfWeek> {DayOfWeek.Wednesday};

    while (!stoppingToken.IsCancellationRequested)
    {
        // Create scope, treat every run cycle as a request cycle.
        using var scope = _serviceProvider.CreateScope();

        await _workerRunner.RunWorkerOnScheduleAsync(new WorkerRunSettings
        {
            ServiceProvider = scope.ServiceProvider,
            WorkerName = WorkerName,
            WeekDays = weekDays,
            FrequencyInMinutes = delayInMinutes // To make sure it doesn't run constantly on specified week days.
        }, new[]
        {
            new ServiceRunSettings
            {
                WeekDays = weekDays,
                RunnableService = _animalSummaryMailer
            },
            new ServiceRunSettings
            {
                RunnableService = _sheltersSubscribersSync
            }
        });

        await Task.Delay(delayInMs, stoppingToken);
    }
}

To see it in action: Multiple Worker Services Setup in C# .NET