Removed "flush strategy" concept again.

nbarnwell · nbarnwell · commit 417d93511b03 · 2025-08-26T23:51:54.000+01:00
diff --git a/Inforigami.Regalo.EventSourcing.Tests.Unit/FullStackTests.cs b/Inforigami.Regalo.EventSourcing.Tests.Unit/FullStackTests.cs
@@ -116,7 +116,6 @@ private EventSourcingRepository<SalesOrder> CreateRepository()
                 new EventSourcingRepository<SalesOrder>(
                     _eventStore,
                     new StrictConcurrencyMonitor(),
-                    new AutomaticFlushStrategy(_eventStore),
                     new ConsoleLogger());
             return repository;
         }
@@ -158,7 +157,7 @@ public RavenTestDriverAdapter()
                 ConfigureServer(new TestServerOptions
                 {
                     ServerUrl        = "http://localhost:8080",
-                    FrameworkVersion = "6.0.11",
+                    FrameworkVersion = "6.0.12",
                     CommandLineArgs  = new[] { "Security.UnsecuredAccessAllowed=PublicNetwork" }.ToList()
                 });
             }
diff --git a/Inforigami.Regalo.EventSourcing/IFlushStrategy.cs b/Inforigami.Regalo.EventSourcing/IFlushStrategy.cs
diff --git a/Inforigami.Regalo.RavenDB.Tests.Unit/PersistenceTests.cs b/Inforigami.Regalo.RavenDB.Tests.Unit/PersistenceTests.cs
@@ -21,7 +21,7 @@ public PersistenceTests()
             ConfigureServer(new TestServerOptions
                     {
                         ServerUrl        = "http://localhost:8080",
-                        FrameworkVersion = "6.0.11",
+                        FrameworkVersion = "6.0.12",
                         CommandLineArgs  = new[] { "Security.UnsecuredAccessAllowed=PublicNetwork" }.ToList()
                     });
         }
diff --git a/Inforigami.Regalo.SqlServer.Tests.Unit/PersistenceTests.cs b/Inforigami.Regalo.SqlServer.Tests.Unit/PersistenceTests.cs
@@ -176,7 +176,7 @@ public void GivenAggregateWithMultipleEvents_WhenLoadingSpecificVersionThatNoEve
             // Arrange
             IEventStore store = new SqlServerEventStoreTestDataBuilder().Build();
             var customerId = Guid.NewGuid();
-            var storedEvents = new IEvent[]
+            var storedEvents = new EventChain
                               {
                                   new CustomerSignedUp(customerId), 
                                   new SubscribedToNewsletter("latest"), 
@@ -194,7 +194,7 @@ public void GivenAggregateWithMultipleEvents_WhenLoadingSpecialNoStreamVersion_T
             // Arrange
             IEventStore store = new SqlServerEventStoreTestDataBuilder().Build();
             var customerId = Guid.NewGuid();
-            var storedEvents = new IEvent[]
+            var storedEvents = new EventChain
                               {
                                   new CustomerSignedUp(customerId), 
                                   new SubscribedToNewsletter("latest"), 
diff --git a/Inforigami.Regalo.Testing/ApplicationServiceTestBase.cs b/Inforigami.Regalo.Testing/ApplicationServiceTestBase.cs
@@ -13,7 +13,7 @@ public class ApplicationServiceTestBase<TEntity>
         public virtual void SetUp()
         {
             var eventStore = new InMemoryEventStore(new ConsoleLogger());
-            var repository = new EventSourcingRepository<TEntity>(eventStore, new StrictConcurrencyMonitor(), new AutomaticFlushStrategy(eventStore), new ConsoleLogger());
+            var repository = new EventSourcingRepository<TEntity>(eventStore, new StrictConcurrencyMonitor(), new ConsoleLogger());
             var eventBus = new FakeEventBus();
             Context = new TestingMessageHandlerContext<TEntity>(repository, eventBus);
         }

Original file line number	Diff line number	Diff line change
`@@ -116,7 +116,6 @@ private EventSourcingRepository<SalesOrder> CreateRepository()`
`116`	`116`	`new EventSourcingRepository<SalesOrder>(`
`117`	`117`	`_eventStore,`
`118`	`118`	`new StrictConcurrencyMonitor(),`
`119`		`- new AutomaticFlushStrategy(_eventStore),`
`120`	`119`	`new ConsoleLogger());`
`121`	`120`	`return repository;`
`122`	`121`	`}`
`@@ -158,7 +157,7 @@ public RavenTestDriverAdapter()`
`158`	`157`	`ConfigureServer(new TestServerOptions`
`159`	`158`	`{`
`160`	`159`	`ServerUrl = "http://localhost:8080",`
`161`		`- FrameworkVersion = "6.0.11",`
	`160`	`+ FrameworkVersion = "6.0.12",`
`162`	`161`	`CommandLineArgs = new[] { "Security.UnsecuredAccessAllowed=PublicNetwork" }.ToList()`
`163`	`162`	`});`
`164`	`163`	`}`
Original file line number	Diff line number	Diff line change
`@@ -21,7 +21,7 @@ public PersistenceTests()`
`21`	`21`	`ConfigureServer(new TestServerOptions`
`22`	`22`	`{`
`23`	`23`	`ServerUrl = "http://localhost:8080",`
`24`		`- FrameworkVersion = "6.0.11",`
	`24`	`+ FrameworkVersion = "6.0.12",`
`25`	`25`	`CommandLineArgs = new[] { "Security.UnsecuredAccessAllowed=PublicNetwork" }.ToList()`
`26`	`26`	`});`
`27`	`27`	`}`
Original file line number	Diff line number	Diff line change
`@@ -13,7 +13,7 @@ public class ApplicationServiceTestBase<TEntity>`
`13`	`13`	`public virtual void SetUp()`
`14`	`14`	`{`
`15`	`15`	`var eventStore = new InMemoryEventStore(new ConsoleLogger());`
`16`		`- var repository = new EventSourcingRepository<TEntity>(eventStore, new StrictConcurrencyMonitor(), new AutomaticFlushStrategy(eventStore), new ConsoleLogger());`
	`16`	`+ var repository = new EventSourcingRepository<TEntity>(eventStore, new StrictConcurrencyMonitor(), new ConsoleLogger());`
`17`	`17`	`var eventBus = new FakeEventBus();`
`18`	`18`	`Context = new TestingMessageHandlerContext<TEntity>(repository, eventBus);`
`19`	`19`	`}`