fix: snapshot verifier registrations

Informatievlaanderen · Sep 8, 2023 · 312295f · 312295f
1 parent a5e8ea8
commit 312295f
Showing 1 changed file with 15 additions and 7 deletions.
diff --git a/src/Be.Vlaanderen.Basisregisters.SnapshotVerifier/SnapshotVerifierExtensions.cs b/src/Be.Vlaanderen.Basisregisters.SnapshotVerifier/SnapshotVerifierExtensions.cs
@@ -3,29 +3,28 @@
     using System;
     using System.Collections.Generic;
     using AggregateSource;
+    using EventHandling;
     using Microsoft.Extensions.DependencyInjection;
     using Microsoft.Extensions.Hosting;
     using Microsoft.Extensions.Logging;
+    using SqlStreamStore;
 
     public static class SnapshotVerifierExtensions
     {
-        public static IServiceCollection AddSnapshotVerificationServices<TAggregateRoot, TStreamId>(
+        public static IServiceCollection AddSnapshotVerificationServices(
             this IServiceCollection services,
             string snapshotConnectionString,
             string snapshotSchema,
             string snapshotVerificationStatesTableName = "SnapshotVerificationStates")
-            where TAggregateRoot : class, IAggregateRootEntity, ISnapshotable
-            where TStreamId : class
         {
             services.AddSingleton(new MsSqlSnapshotStoreQueries(snapshotConnectionString, snapshotSchema));
             services.AddScoped<ISnapshotVerificationRepository>(_ => new SnapshotVerificationRepository(snapshotConnectionString, snapshotSchema, snapshotVerificationStatesTableName));
-            services.AddScoped<IAggregateSnapshotRepository<TAggregateRoot>, AggregateSnapshotRepository<TAggregateRoot>>();
-            services.AddScoped<IAggregateEventsRepository<TAggregateRoot, TStreamId>, AggregateEventsRepository<TAggregateRoot, TStreamId>>();
             return services;
         }
 
         public static IServiceCollection AddHostedSnapshotVerifierService<TAggregateRoot, TStreamId>(
             this IServiceCollection services,
+            Func<TAggregateRoot> aggregateFactory,
             Func<TAggregateRoot, TStreamId> aggregateIdFactory,
             List<string> membersToIgnoreInVerification)
             where TAggregateRoot : class, IAggregateRootEntity, ISnapshotable
@@ -36,8 +35,17 @@ public static IServiceCollection AddHostedSnapshotVerifierService<TAggregateRoot
                 aggregateIdFactory,
                 membersToIgnoreInVerification,
                 x.GetRequiredService<ISnapshotVerificationRepository>(),
-                x.GetRequiredService<IAggregateSnapshotRepository<TAggregateRoot>>(),
-                x.GetRequiredService<IAggregateEventsRepository<TAggregateRoot, TStreamId>>(),
+                new AggregateSnapshotRepository<TAggregateRoot>(
+                    x.GetRequiredService<MsSqlSnapshotStoreQueries>(),
+                    x.GetRequiredService<EventDeserializer>(),
+                    x.GetRequiredService<EventMapping>(),
+                    aggregateFactory,
+                    x.GetRequiredService<ILoggerFactory>()),
+                new AggregateEventsRepository<TAggregateRoot, TStreamId>(
+                    x.GetRequiredService<EventDeserializer>(),
+                    x.GetRequiredService<EventMapping>(),
+                    x.GetRequiredService<IReadonlyStreamStore>(),
+                    aggregateFactory),
                 x.GetService<ISnapshotVerificationNotifier>(), x.GetRequiredService<ILoggerFactory>()));
 
             return services;