Merge pull request #1035 from eventflow/rasmus/explicit-persistence-selection

Fix: Proper registration of event persistence layer

Author: rasmus

RELEASE_NOTES.md

@@ -1,3 +1,12 @@
+### New in 1.1.1 (working version, not released yet)
+
+* Fix: Invoking `UseEventPersistence` now removes any previously registered event persistence. This
+  fixes a service ordering issue in the following event store configurations
+  - MongoDB
+  - MSSQL
+  - PostgreSQL
+
+
 ### New in 1.1.0 (released 2024-12-16)
 
 * New: More control of event naming by introducing the interface `IEventNamingStrategy`, see the

Source/EventFlow.PostgreSql.Tests/EventFlow.PostgreSql.Tests.csproj

@@ -3,6 +3,11 @@
     <TargetFrameworks>netcoreapp3.1;net6.0</TargetFrameworks>
     <IsPackable>False</IsPackable>
   </PropertyGroup>
+  <ItemGroup>
+    <Compile Remove="Properties\**" />
+    <EmbeddedResource Remove="Properties\**" />
+    <None Remove="Properties\**" />
+  </ItemGroup>
 
   <ItemGroup>
     <None Remove="IntegrationTests\ReadStores\Scripts\0001 - Create table ReadModel-ThingyAggregate.sql" />
@@ -14,10 +19,6 @@
     <EmbeddedResource Include="IntegrationTests\ReadStores\Scripts\0002 - Create table ReadModel-ThingyMessage.sql" />
   </ItemGroup>
 
-  <ItemGroup>
-    <Folder Include="Properties\" />
-  </ItemGroup>
-
   <ItemGroup>
     <PackageReference Include="Microsoft.NET.Test.Sdk" Version="16.6.1" />
     <PackageReference Include="NUnit" Version="3.13.2" />

Source/EventFlow.PostgreSql/Extensions/EventFlowOptionsPostgresSqlEventStoreExtensions.cs

@@ -20,18 +20,16 @@
 // IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
 // CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 
-using EventFlow.EventStores;
 using EventFlow.Extensions;
 using EventFlow.PostgreSql.EventStores;
-using Microsoft.Extensions.DependencyInjection.Extensions;
 
 namespace EventFlow.PostgreSql.Extensions
 {
     public static class EventFlowOptionsPostgreSqlEventStoreExtensions
     {
         public static IEventFlowOptions UsePostgreSqlEventStore(this IEventFlowOptions eventFlowOptions)
         {
-            return eventFlowOptions.RegisterServices(f => f.TryAddTransient<IEventPersistence, PostgreSqlEventPersistence>());
+            return eventFlowOptions.UseEventPersistence<PostgreSqlEventPersistence>();
         }
     }
 }

Source/EventFlow/Extensions/EventFlowOptionsEventStoresExtensions.cs

@@ -24,6 +24,7 @@
 using EventFlow.EventStores;
 using EventFlow.EventStores.Files;
 using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.DependencyInjection.Extensions;
 
 namespace EventFlow.Extensions
 {
@@ -34,8 +35,7 @@ public static IEventFlowOptions UseEventPersistence(
             Func<IServiceProvider, IEventPersistence> eventPersistenceResolver,
             ServiceLifetime serviceLifetime = ServiceLifetime.Transient)
         {
-            eventFlowOptions.ServiceCollection
-                .Add(new ServiceDescriptor(typeof(IEventStore), eventPersistenceResolver, serviceLifetime));
+            eventFlowOptions.ServiceCollection.Add(new ServiceDescriptor(typeof(IEventStore), eventPersistenceResolver, serviceLifetime));
             return eventFlowOptions;
         }
 
@@ -44,8 +44,8 @@ public static IEventFlowOptions UseEventPersistence<TEventPersistence>(
             ServiceLifetime serviceLifetime = ServiceLifetime.Transient)
             where TEventPersistence : class, IEventPersistence
         {
-            eventFlowOptions.ServiceCollection
-                .Add(new ServiceDescriptor(typeof(IEventPersistence), typeof(TEventPersistence), serviceLifetime));
+            eventFlowOptions.ServiceCollection.RemoveAll<IEventPersistence>();
+            eventFlowOptions.ServiceCollection.Add(new ServiceDescriptor(typeof(IEventPersistence), typeof(TEventPersistence), serviceLifetime));
             return eventFlowOptions;
         }