Merge pull request #233 from meysamhadeli/develop

Develop

.github/workflows/ci.yml

@@ -12,7 +12,7 @@ on:
 concurrency:
   group: ${{ github.workflow }}-${{ github.head_ref || github.sha }}
   cancel-in-progress: true
-  
+
 jobs:
   ci:
     runs-on: ubuntu-latest

src/BuildingBlocks/EventStoreDB/Config.cs

@@ -1,6 +1,5 @@
 using System.Reflection;
 using BuildingBlocks.EventStoreDB.BackgroundWorkers;
-using BuildingBlocks.EventStoreDB.Events;
 using BuildingBlocks.EventStoreDB.Projections;
 using BuildingBlocks.EventStoreDB.Repository;
 using BuildingBlocks.EventStoreDB.Subscriptions;
@@ -11,26 +10,30 @@
 
 namespace BuildingBlocks.EventStoreDB;
 
-public class EventStoreDBConfig
+using Web;
+
+public class EventStoreOptions
 {
     public string ConnectionString { get; set; } = default!;
 }
 
+
 public record EventStoreDBOptions(
     bool UseInternalCheckpointing = true
 );
 
 public static class EventStoreDBConfigExtensions
 {
-    private const string DefaultConfigKey = "EventStore";
-
     public static IServiceCollection AddEventStoreDB(this IServiceCollection services, IConfiguration config,
         EventStoreDBOptions? options = null)
     {
-        var eventStoreDBConfig = config.GetSection(DefaultConfigKey).Get<EventStoreDBConfig>();
 
         services
-            .AddSingleton(new EventStoreClient(EventStoreClientSettings.Create(eventStoreDBConfig.ConnectionString)))
+            .AddSingleton(x=>
+            {
+                var eventStoreOptions = services.GetOptions<EventStoreOptions>(nameof(EventStoreOptions));
+                return new EventStoreClient(EventStoreClientSettings.Create(eventStoreOptions.ConnectionString));
+            })
             .AddScoped(typeof(IEventStoreDBRepository<>), typeof(EventStoreDBRepository<>))
             .AddTransient<EventStoreDBSubscriptionToAll, EventStoreDBSubscriptionToAll>();
 

src/BuildingBlocks/EventStoreDB/Extensions.cs

@@ -4,6 +4,8 @@
 
 namespace BuildingBlocks.EventStoreDB;
 
+using Web;
+
 public static class Extensions
 {
     // ref: https://github.com/oskardudycz/EventSourcing.NetCore/tree/main/Sample/EventStoreDB/ECommerce
@@ -13,6 +15,8 @@ public static IServiceCollection AddEventStore(
         params Assembly[] assemblies
     )
     {
+        services.AddValidateOptions<EventStoreOptions>();
+
         var assembliesToScan = assemblies.Length > 0 ? assemblies : new[] { Assembly.GetEntryAssembly()! };
 
         return services

src/BuildingBlocks/PersistMessageProcessor/Extensions.cs

@@ -5,10 +5,8 @@
 
 namespace BuildingBlocks.PersistMessageProcessor;
 
-using EFCore;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Hosting;
-using Microsoft.Extensions.Hosting;
 
 public static class Extensions
 {
@@ -39,38 +37,17 @@ public static IServiceCollection AddPersistMessageProcessor(this IServiceCollect
         return services;
     }
 
-    public static IApplicationBuilder UseMigration<TContext>(this IApplicationBuilder app, IWebHostEnvironment env)
+    public static IApplicationBuilder UseMigrationPersistMessage<TContext>(this IApplicationBuilder app, IWebHostEnvironment env)
         where TContext : DbContext, IPersistMessageDbContext
     {
-        MigrateDatabaseAsync<TContext>(app.ApplicationServices).GetAwaiter().GetResult();
-
-        if (!env.IsEnvironment("test"))
-        {
-            SeedDataAsync(app.ApplicationServices).GetAwaiter().GetResult();
-        }
-
-        return app;
-    }
-
-    private static async Task MigrateDatabaseAsync<TContext>(IServiceProvider serviceProvider)
-        where TContext : DbContext, IPersistMessageDbContext
-    {
-        using var scope = serviceProvider.CreateScope();
+        using var scope = app.ApplicationServices.CreateScope();
 
         var persistMessageContext = scope.ServiceProvider.GetRequiredService<PersistMessageDbContext>();
-        await persistMessageContext.Database.MigrateAsync();
+        persistMessageContext.Database.Migrate();
 
         var context = scope.ServiceProvider.GetRequiredService<TContext>();
-        await context.Database.MigrateAsync();
-    }
+        context.Database.Migrate();
 
-    private static async Task SeedDataAsync(IServiceProvider serviceProvider)
-    {
-        using var scope = serviceProvider.CreateScope();
-        var seeders = scope.ServiceProvider.GetServices<IDataSeeder>();
-        foreach (var seeder in seeders)
-        {
-            await seeder.SeedAllAsync();
-        }
+        return app;
     }
 }

src/BuildingBlocks/TestBase/TestBase.cs

@@ -278,7 +278,7 @@ private void AddCustomAppSettings(IConfigurationBuilder configuration)
                     .ToString(NumberFormatInfo.InvariantInfo)),
             new("MongoOptions:ConnectionString", MongoDbTestContainer.GetConnectionString()),
             new("MongoOptions:DatabaseName", TestContainers.MongoContainerConfiguration.Name),
-            new("EventStore:ConnectionString", EventStoreDbTestContainer.GetConnectionString())
+            new("EventStoreOptions:ConnectionString", EventStoreDbTestContainer.GetConnectionString())
         });
     }
 

src/BuildingBlocks/TestBase/TestContainers.cs

@@ -97,7 +97,6 @@ public static EventStoreDbContainer EventStoreTestContainer()
         var builder = baseBuilder
             .WithImage(EventStoreContainerConfiguration.ImageName)
             .WithName(EventStoreContainerConfiguration.Name)
-            .WithPortBinding(EventStoreContainerConfiguration.Port, true)
             .Build();
 
         return builder;

src/Services/Booking/src/Booking.Api/appsettings.docker.json

@@ -11,7 +11,7 @@
     "Enabled": true,
     "ConnectionString": "Server=postgres;Port=5432;Database=persist_message;User Id=postgres;Password=postgres;Include Error Detail=true"
   },
-  "EventStore": {
+  "EventStoreOptions": {
     "ConnectionString": "esdb://eventstore:2113?tls=false"
   },
   "MongoOptions": {

src/Services/Booking/src/Booking.Api/appsettings.json

@@ -48,7 +48,7 @@
      "BreakDuration" : 30
     }
   },
-  "EventStore": {
+  "EventStoreOptions": {
     "ConnectionString": "esdb://localhost:2113?tls=false"
   },
   "MongoOptions": {

src/Services/Booking/src/Booking.Api/appsettings.test.json

@@ -18,9 +18,6 @@
     "ConnectionString": "mongodb://localhost:27017",
     "DatabaseName": "booking-db-test"
   },
-  "EventStore": {
-    "ConnectionString": "esdb://localhost:2113?tls=false"
-  },
   "PersistMessageOptions": {
     "Interval": 30,
     "Enabled": true,

src/Services/Booking/src/Booking/Extensions/Infrastructure/InfrastructureExtensions.cs

@@ -100,7 +100,7 @@ public static WebApplication UseInfrastructure(this WebApplication app)
         });
         app.UseCorrelationId();
         app.UseHttpMetrics();
-        app.UseMigration<PersistMessageDbContext>(env);
+        app.UseMigrationPersistMessage<PersistMessageDbContext>(env);
         app.UseCustomHealthCheck();
         app.MapMetrics();
         app.MapGet("/", x => x.Response.WriteAsync(appOptions.Name));

src/Services/Flight/src/Flight/Extensions/Infrastructure/InfrastructureExtensions.cs

@@ -30,6 +30,7 @@
 
 namespace Flight.Extensions.Infrastructure;
 
+using BuildingBlocks.PersistMessageProcessor.Data;
 using Microsoft.AspNetCore.HttpOverrides;
 
 public static class InfrastructureExtensions
@@ -105,6 +106,7 @@ public static WebApplication UseInfrastructure(this WebApplication app)
         });
         app.UseCorrelationId();
         app.UseHttpMetrics();
+        app.UseMigrationPersistMessage<PersistMessageDbContext>(env);
         app.UseMigration<FlightDbContext>(env);
         app.MapMetrics();
         app.UseCustomHealthCheck();

src/Services/Identity/src/Identity/Extensions/Infrastructure/InfrastructureExtensions.cs

@@ -26,6 +26,7 @@
 
 namespace Identity.Extensions.Infrastructure;
 
+using BuildingBlocks.PersistMessageProcessor.Data;
 using Configurations;
 using Microsoft.AspNetCore.HttpOverrides;
 
@@ -101,6 +102,7 @@ public static WebApplication UseInfrastructure(this WebApplication app)
         {
             options.EnrichDiagnosticContext = LogEnrichHelper.EnrichFromRequest;
         });
+        app.UseMigrationPersistMessage<PersistMessageDbContext>(env);
         app.UseMigration<IdentityContext>(env);
         app.UseCorrelationId();
         app.UseHttpMetrics();

src/Services/Passenger/src/Passenger/Extensions/Infrastructure/InfrastructureExtensions.cs

@@ -28,6 +28,8 @@
 
 namespace Passenger.Extensions.Infrastructure;
 
+using BuildingBlocks.PersistMessageProcessor.Data;
+
 public static class InfrastructureExtensions
 {
     public static WebApplicationBuilder AddInfrastructure(this WebApplicationBuilder builder)
@@ -95,6 +97,7 @@ public static WebApplication UseInfrastructure(this WebApplication app)
         {
             options.EnrichDiagnosticContext = LogEnrichHelper.EnrichFromRequest;
         });
+        app.UseMigrationPersistMessage<PersistMessageDbContext>(env);
         app.UseMigration<PassengerDbContext>(env);
         app.UseCorrelationId();
         app.UseHttpMetrics();