ConnectionsAPI/Events/PuzzleSyncEvent.cs

using ConnectionsAPI.Database;
using ConnectionsAPI.Utility;
using System.Diagnostics;

namespace ConnectionsAPI.Events;

public class ConnectionsSyncEvent : IEvent { }

public class ConnectionsSyncHandler(ILogger<ConnectionsSyncHandler> logger,
                                    IServiceScopeFactory scopeFactory) : IEventHandler<ConnectionsSyncEvent>
{
    private readonly ILogger<ConnectionsSyncHandler> _logger = logger;
    private readonly IServiceScopeFactory _scopeFactory = scopeFactory;

    public async Task HandleAsync(ConnectionsSyncEvent eventModel, CancellationToken ct)
    {
        Stopwatch stopwatch = Stopwatch.StartNew();
        _logger.LogInformation("Received Connections Sync Event");
        try
        {
            // construct scope 
            using var scope = _scopeFactory.CreateScope();
            // get dependencies
            ConnectionsContext db = scope.ServiceProvider.GetRequiredService<ConnectionsContext>();
            HttpClient http = scope.ServiceProvider.GetRequiredService<IHttpClientFactory>().CreateClient();
            ILogger<SyncUtility> syncLogger = scope.ServiceProvider.GetRequiredService<ILogger<SyncUtility>>();
            // do the work
            await new SyncUtility(db, syncLogger, http).SyncPuzzlesAsync(ct);
        }
        catch (Exception ex)
        {
            _logger.LogError(ex, "Error while executing Connections sync event");
        }
        finally
        {
            stopwatch.Stop();
        }
        _logger.LogInformation("Connections Sync Event finished in {ts}", stopwatch.Elapsed);
    }
}