BaseAuditPersistence.cs

namespace ServiceControl.Audit.Persistence.Sql.Core.Abstractions;

using Azure.Storage.Blobs;
using Implementation;
using Implementation.UnitOfWork;
using Infrastructure;
using Microsoft.Extensions.DependencyInjection;
using ServiceControl.Audit.Auditing.BodyStorage;
using ServiceControl.Audit.Persistence.UnitOfWork;

public abstract class BaseAuditPersistence
{
    protected static void RegisterDataStores(IServiceCollection services, AuditSqlPersisterSettings settings)
    {
        services.AddSingleton<MinimumRequiredStorageState>();
        if (!string.IsNullOrEmpty(settings.MessageBodyStoragePath))
        {
            services.AddSingleton<IBodyStoragePersistence, FileSystemBodyStoragePersistence>();
        }
        else
        {
            services.AddSingleton<IBodyStoragePersistence, AzureBlobBodyStoragePersistence>();
        }
        services.AddScoped<IBodyStorage, BodyStorageFetcher>();
        services.AddSingleton<IAuditDataStore, EFAuditDataStore>();
        services.AddSingleton<IFailedAuditStorage, EFFailedAuditStorage>();
        services.AddSingleton<IAuditIngestionUnitOfWorkFactory, AuditIngestionUnitOfWorkFactory>();
        services.AddSingleton(TimeProvider.System);
    }
}