| | | 1 | | using Microsoft.Extensions.DependencyInjection; |
| | | 2 | | using Microsoft.Extensions.DependencyInjection.Extensions; |
| | | 3 | | using Microsoft.Extensions.Options; |
| | | 4 | | using ProjectTemplate.Infrastructure.Data.Auditing; |
| | | 5 | | |
| | | 6 | | namespace ProjectTemplate.Infrastructure.Data.Extensions; |
| | | 7 | | |
| | | 8 | | public static class ApplicationAuditReconciliationServiceExtensions |
| | | 9 | | { |
| | | 10 | | public static IServiceCollection AddApplicationAuditReconciliationCore( |
| | | 11 | | this IServiceCollection services, |
| | | 12 | | Action<ApplicationAuditReconciliationOptions>? configure = null) |
| | | 13 | | { |
| | 2 | 14 | | ArgumentNullException.ThrowIfNull(services); |
| | | 15 | | |
| | 2 | 16 | | OptionsBuilder<ApplicationAuditReconciliationOptions> optionsBuilder = services |
| | 2 | 17 | | .AddOptions<ApplicationAuditReconciliationOptions>() |
| | 2 | 18 | | .Validate(options => options.Interval > TimeSpan.Zero, |
| | 2 | 19 | | "The audit reconciliation interval must be greater than zero.") |
| | 2 | 20 | | .Validate(options => options.MaximumCycleRetryDelay >= options.Interval, |
| | 2 | 21 | | "The maximum audit reconciliation cycle retry delay must not be less than the interval.") |
| | 2 | 22 | | .Validate(options => options.CompletionGracePeriod >= TimeSpan.Zero, |
| | 2 | 23 | | "The completion grace period must not be negative.") |
| | 2 | 24 | | .Validate(options => options.StalePendingThreshold > TimeSpan.Zero, |
| | 2 | 25 | | "The stale pending threshold must be greater than zero.") |
| | 2 | 26 | | .Validate(options => options.StaleRetryReadyThreshold > TimeSpan.Zero, |
| | 2 | 27 | | "The stale retry-ready threshold must be greater than zero.") |
| | 2 | 28 | | .Validate(options => options.MaximumBatchesPerRun is > 0 and <= 10_000, |
| | 2 | 29 | | "Maximum batches per reconciliation run must be between 1 and 10000.") |
| | 2 | 30 | | .Validate(options => options.MaximumMalformedRecordsPerRun is > 0 and <= 10_000, |
| | 2 | 31 | | "Maximum malformed audit records per reconciliation run must be between 1 and 10000.") |
| | 2 | 32 | | .Validate(options => options.HealthWarningFindingCount >= 0, |
| | 2 | 33 | | "The warning finding threshold must not be negative.") |
| | 2 | 34 | | .Validate(options => options.HealthUnhealthyFindingCount >= options.HealthWarningFindingCount, |
| | 2 | 35 | | "The unhealthy finding threshold must not be less than the warning threshold.") |
| | 2 | 36 | | .Validate(options => options.HealthStaleRunThreshold is null || |
| | 2 | 37 | | options.HealthStaleRunThreshold > options.Interval, |
| | 2 | 38 | | "The health stale-run threshold must be greater than the reconciliation interval.") |
| | 2 | 39 | | .ValidateOnStart(); |
| | | 40 | | |
| | 2 | 41 | | if (configure is not null) |
| | | 42 | | { |
| | 1 | 43 | | optionsBuilder.Configure(configure); |
| | | 44 | | } |
| | | 45 | | |
| | 2 | 46 | | services.TryAddSingleton(TimeProvider.System); |
| | 2 | 47 | | services.TryAddSingleton<ApplicationAuditReconciliationMetrics>(); |
| | 2 | 48 | | services.TryAddScoped<ApplicationAuditReconciler>(); |
| | 2 | 49 | | services.TryAddScoped<IApplicationAuditReconciler>(serviceProvider => |
| | 2 | 50 | | serviceProvider.GetRequiredService<ApplicationAuditReconciler>()); |
| | 2 | 51 | | return services; |
| | | 52 | | } |
| | | 53 | | } |