diff --git a/src/BuildingBlocks/BuildingBlocks.csproj b/src/BuildingBlocks/BuildingBlocks.csproj
index c8dd0c0..27e8d73 100644
--- a/src/BuildingBlocks/BuildingBlocks.csproj
+++ b/src/BuildingBlocks/BuildingBlocks.csproj
@@ -67,7 +67,7 @@
-
+
diff --git a/src/BuildingBlocks/EventStoreDB/Extensions.cs b/src/BuildingBlocks/EventStoreDB/Extensions.cs
index 6253391..046c8e9 100644
--- a/src/BuildingBlocks/EventStoreDB/Extensions.cs
+++ b/src/BuildingBlocks/EventStoreDB/Extensions.cs
@@ -6,6 +6,7 @@ namespace BuildingBlocks.EventStoreDB;
public static class Extensions
{
+ // ref: https://github.com/oskardudycz/EventSourcing.NetCore/tree/main/Sample/EventStoreDB/ECommerce
public static IServiceCollection AddEventStore(
this IServiceCollection services,
IConfiguration configuration,
diff --git a/src/Services/Booking/src/Booking.Api/Program.cs b/src/Services/Booking/src/Booking.Api/Program.cs
index 2c8555e..674b2e2 100644
--- a/src/Services/Booking/src/Booking.Api/Program.cs
+++ b/src/Services/Booking/src/Booking.Api/Program.cs
@@ -53,7 +53,7 @@ builder.Services.AddCustomOpenTelemetry();
builder.Services.AddTransient();
SnowFlakIdGenerator.Configure(3);
-// EventStoreDB Configuration
+// ref: https://github.com/oskardudycz/EventSourcing.NetCore/tree/main/Sample/EventStoreDB/ECommerce
builder.Services.AddEventStore(configuration, typeof(BookingRoot).Assembly)
.AddEventStoreDBSubscriptionToAll();
diff --git a/src/Services/Flight/tests/Flight/CreateFlightTests.cs b/src/Services/Flight/tests/Flight/CreateFlightTests.cs
index aa52366..cd7a3b8 100644
--- a/src/Services/Flight/tests/Flight/CreateFlightTests.cs
+++ b/src/Services/Flight/tests/Flight/CreateFlightTests.cs
@@ -1,6 +1,5 @@
using System.Threading.Tasks;
using BuildingBlocks.Contracts.EventBus.Messages;
-using Flight.Flights.Features.CreateFlight;
using FluentAssertions;
using Integration.Test.Fakes;
using Xunit;
diff --git a/src/Services/Flight/tests/TestFixture.cs b/src/Services/Flight/tests/TestFixture.cs
index ed48014..e1447e4 100644
--- a/src/Services/Flight/tests/TestFixture.cs
+++ b/src/Services/Flight/tests/TestFixture.cs
@@ -1,12 +1,10 @@
using System;
using System.Net.Http;
using System.Threading.Tasks;
-using BuildingBlocks.Contracts.EventBus.Messages;
using BuildingBlocks.Domain.Model;
using BuildingBlocks.EFCore;
using BuildingBlocks.MassTransit;
using BuildingBlocks.Web;
-using Flight;
using Flight.Data;
using Flight.Data.Seed;
using MassTransit;
@@ -19,10 +17,11 @@ using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.DependencyInjection.Extensions;
using Microsoft.Extensions.Hosting;
-using Microsoft.Extensions.Logging;
using NSubstitute;
using Respawn;
+using Serilog;
using Xunit;
+using Xunit.Abstractions;
namespace Integration.Test;
@@ -37,15 +36,11 @@ public class TestFixtureCollection : ICollectionFixture
public class TestFixture : IAsyncLifetime
{
private Checkpoint _checkpoint;
- private HttpClient _client;
private IConfiguration _configuration;
private WebApplicationFactory _factory;
private ITestHarness _harness;
private IServiceScopeFactory _scopeFactory;
-
- public ILogger Logger =>
- _scopeFactory.CreateScope().ServiceProvider.GetRequiredService>();
-
+ private HttpClient _httpClient;
public async Task InitializeAsync()
{
@@ -81,7 +76,7 @@ public class TestFixture : IAsyncLifetime
_configuration = _factory.Services.GetRequiredService();
_scopeFactory = _factory.Services.GetRequiredService();
- _client = _factory.CreateClient(new WebApplicationFactoryClientOptions {AllowAutoRedirect = false});
+ _httpClient = _factory.CreateClient(new WebApplicationFactoryClientOptions {AllowAutoRedirect = false});
_checkpoint = new Checkpoint {TablesToIgnore = new[] {"__EFMigrationsHistory"}};
@@ -95,6 +90,20 @@ public class TestFixture : IAsyncLifetime
await _checkpoint.Reset(_configuration.GetConnectionString("DefaultConnection"));
}
+ // ref: https://github.com/trbenning/serilog-sinks-xunit
+ public ILogger CreateLogger(ITestOutputHelper output)
+ {
+ if (output != null)
+ {
+ return new LoggerConfiguration()
+ .WriteTo.TestOutput(output)
+ .CreateLogger();
+ }
+
+ return null;
+ }
+
+ public HttpClient CreateClient() => _httpClient;
public async Task ExecuteScopeAsync(Func action)
{