TriliumMind/Workers/TriliumWorker.cs

using Microsoft.Extensions.Options;
using Serilog;
using System.Threading.Channels;
using TriliumMind.Data.Entities;
using TriliumMind.Models;
using TriliumMind.Services;

namespace TriliumMind.Workers;

public class TriliumWorker : BackgroundService
{
    private readonly Serilog.ILogger _log;
    private readonly AppConfigs _config;
    private readonly IServiceScopeFactory _scopeFactory; // Singleton services cannot directly inject Scoped services.
    private readonly TriliumService _trilium;
    private readonly Channel<Issue> _issueChannel;

    public TriliumWorker(AppConfigs configs, IServiceScopeFactory serviceScopeFactory,
        TriliumService triliumService, Channel<Issue> issueChannel)
    {
        _log = Log.ForContext<TriliumWorker>();
        _config = configs;
        _scopeFactory = serviceScopeFactory;
        _trilium = triliumService;
        _issueChannel = issueChannel;
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        while (!stoppingToken.IsCancellationRequested)
        {
            _log.Debug("Worker running at: {time}", DateTimeOffset.Now);

            using var scope = _scopeFactory.CreateScope();
            var db = scope.ServiceProvider.GetRequiredService<AppDbService>();
            var unpublishedIssues = await db.GetUnpublishedJiraIssuesAsync(stoppingToken);
            if (unpublishedIssues != null)
                await _trilium.PublishNotesAsync(unpublishedIssues);

            await Task.Delay(10 *1000, stoppingToken);
        }
    }
}