refactor(snapshot): clean up modules

src/BuildingRegistry.Producer.Snapshot.Oslo/Infrastructure/Modules/ProducerModule.cs

@@ -12,11 +12,13 @@ namespace BuildingRegistry.Producer.Snapshot.Oslo.Infrastructure.Modules
     using Be.Vlaanderen.Basisregisters.GrAr.Oslo.SnapshotProducer;
     using Be.Vlaanderen.Basisregisters.MessageHandling.Kafka;
     using Be.Vlaanderen.Basisregisters.MessageHandling.Kafka.Producer;
+    using Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner.SqlServer.MigrationExtensions;
     using Be.Vlaanderen.Basisregisters.ProjectionHandling.SqlStreamStore.Autofac;
     using Be.Vlaanderen.Basisregisters.Projector;
     using Be.Vlaanderen.Basisregisters.Projector.ConnectedProjections;
     using Be.Vlaanderen.Basisregisters.Projector.Modules;
     using BuildingRegistry.Infrastructure;
+    using Microsoft.EntityFrameworkCore;
     using Microsoft.Extensions.Configuration;
     using Microsoft.Extensions.DependencyInjection;
     using Microsoft.Extensions.Logging;
@@ -64,19 +66,33 @@ private void RegisterProjectionSetup(ContainerBuilder builder)
                 .RegisterEventstreamModule(_configuration)
                 .RegisterModule(new ProjectorModule(_configuration));
 
+            var logger = _loggerFactory.CreateLogger<ProducerModule>();
+            var connectionString = _configuration.GetConnectionString("ProducerSnapshotProjections");
+
+            var hasConnectionString = !string.IsNullOrWhiteSpace(connectionString);
+            if (hasConnectionString)
+            {
+                RunOnSqlServer(_services, _loggerFactory, connectionString);
+            }
+            else
+            {
+                RunInMemoryDb(_services, _loggerFactory, logger);
+            }
+
+            logger.LogInformation(
+                "Added {Context} to services:" +
+                Environment.NewLine +
+                "\tSchema: {Schema}" +
+                Environment.NewLine +
+                "\tTableName: {TableName}",
+                nameof(ProducerContext), Schema.ProducerSnapshotOslo, MigrationTables.ProducerSnapshotOslo);
+
             RegisterProjections(builder);
             //RegisterReproducers();
         }
 
         private void RegisterProjections(ContainerBuilder builder)
         {
-            builder
-                .RegisterModule(
-                    new ProducerModule(
-                        _configuration,
-                        _services,
-                        _loggerFactory));
-
             var connectedProjectionSettings = ConnectedProjectionSettings.Configure(x =>
             {
                 x.ConfigureCatchUpPageSize(ConnectedProjectionSettings.Default.CatchUpPageSize);
@@ -231,5 +247,34 @@ private ProducerOptions CreateBuildingUnitProducerOptions()
 
             return producerOptions;
         }
+
+        private static void RunOnSqlServer(
+            IServiceCollection services,
+            ILoggerFactory loggerFactory,
+            string producerSnapshotConnectionString)
+        {
+            services
+                .AddDbContext<ProducerContext>((_, options) => options
+                    .UseLoggerFactory(loggerFactory)
+                    .UseSqlServer(producerSnapshotConnectionString, sqlServerOptions =>
+                    {
+                        sqlServerOptions.EnableRetryOnFailure();
+                        sqlServerOptions.MigrationsHistoryTable(MigrationTables.ProducerSnapshotOslo, Schema.ProducerSnapshotOslo);
+                    })
+                    .UseExtendedSqlServerMigrations());
+        }
+
+        private static void RunInMemoryDb(
+            IServiceCollection services,
+            ILoggerFactory loggerFactory,
+            ILogger logger)
+        {
+            services
+                .AddDbContext<ProducerContext>(options => options
+                    .UseLoggerFactory(loggerFactory)
+                    .UseInMemoryDatabase(Guid.NewGuid().ToString(), sqlServerOptions => { }));
+
+            logger.LogWarning("Running InMemory for {Context}!", nameof(ProducerContext));
+        }
     }
 }

src/BuildingRegistry.Producer.Snapshot.Oslo/BuildingSnapshotProducer.cs → src/BuildingRegistry.Producer.Snapshot.Oslo/SnapshotProducers.cs

@@ -27,6 +27,7 @@ protected override async Task ExecuteAsync(CancellationToken stoppingToken)
         {
             try
             {
+                _logger.LogInformation("Starting snapshot projections");
                 await _projectionsManager.Start(stoppingToken);
             }
             catch (Exception exception)

src/BuildingRegistry.Producer/Infrastructure/Modules/ProducerModule.cs

@@ -97,26 +97,6 @@ private void RegisterProjections(ContainerBuilder builder)
                 .RegisterProjectionMigrator<ProducerContextMigrationFactory>(
                     _configuration,
                     _loggerFactory)
-                // TODO: see if we still need to implements this
-                // .RegisterProjections<ProducerProjections, ProducerContext>(() =>
-                // {
-                //     var topic = $"{_configuration[ProducerProjections.TopicKey]}" ?? throw new ArgumentException($"Configuration has no value for {ProducerProjections.TopicKey}");
-                //     var producerOptions = new ProducerOptions(
-                //         new BootstrapServers(bootstrapServers),
-                //         new Topic(topic),
-                //         true,
-                //         EventsJsonSerializerSettingsProvider.CreateSerializerSettings())
-                //         .ConfigureEnableIdempotence();
-                //     if (!string.IsNullOrEmpty(saslUserName)
-                //         && !string.IsNullOrEmpty(saslPassword))
-                //     {
-                //         producerOptions.ConfigureSaslAuthentication(new SaslAuthentication(
-                //             saslUserName,
-                //             saslPassword));
-                //     }
-                //
-                //     return new ProducerProjections(new Producer(producerOptions));
-                // }, connectedProjectionSettings)
                 .RegisterProjections<ProducerMigrateProjections, ProducerContext>(() =>
                 {
                     var topic = $"{_configuration[ProducerMigrateProjections.TopicKey]}" ?? throw new ArgumentException($"Configuration has no value for {ProducerMigrateProjections.TopicKey}");