chore: pipeline

atmina · Mar 15, 2024 · 6a61399 · 6a61399
1 parent ccf7d7c
commit 6a61399
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 4 deletions.
diff --git a/src/Fluss.Testing/AggregateTestBed.cs b/src/Fluss.Testing/AggregateTestBed.cs
@@ -18,7 +18,7 @@ public AggregateTestBed()
     {
         var validator = new Mock<IRootValidator>();
         validator.Setup(v => v.ValidateEvent(It.IsAny<EventEnvelope>(), It.IsAny<IReadOnlyList<EventEnvelope>?>()))
-            .Returns<EventEnvelope>(_ => Task.CompletedTask);
+            .Returns<EventEnvelope, IReadOnlyList<EventEnvelope>?>((_, _) => Task.CompletedTask);
         validator.Setup(v => v.ValidateAggregate(It.IsAny<AggregateRoot>(), It.IsAny<UnitOfWork.UnitOfWork>()))
             .Returns<AggregateRoot, UnitOfWork.UnitOfWork>((_, _) => Task.CompletedTask);
 

diff --git a/src/Fluss.UnitTest/Core/UnitOfWork/UnitOfWorkTest.cs b/src/Fluss.UnitTest/Core/UnitOfWork/UnitOfWorkTest.cs
@@ -29,7 +29,7 @@ public UnitOfWorkTest()
 
         _validator = new Mock<IRootValidator>(MockBehavior.Strict);
         _validator.Setup(v => v.ValidateEvent(It.IsAny<EventEnvelope>(), It.IsAny<IReadOnlyList<EventEnvelope>?>()))
-            .Returns<EventEnvelope>(_ => Task.CompletedTask);
+            .Returns<EventEnvelope, IReadOnlyList<EventEnvelope>?>((_, _) => Task.CompletedTask);
         _validator.Setup(v => v.ValidateAggregate(It.IsAny<AggregateRoot>(), It.IsAny<Fluss.UnitOfWork.UnitOfWork>()))
             .Returns<AggregateRoot, Fluss.UnitOfWork.UnitOfWork>((_, _) => Task.CompletedTask);
 

diff --git a/src/Fluss/UnitOfWork/UnitOfWork.Aggregates.cs b/src/Fluss/UnitOfWork/UnitOfWork.Aggregates.cs
@@ -94,7 +94,8 @@ internal async ValueTask CommitInternal()
         using var activity = FlussActivitySource.Source.StartActivity();
 
         var validatedEnvelopes = new List<EventEnvelope>();
-        foreach (var envelope in PublishedEventEnvelopes) {
+        foreach (var envelope in PublishedEventEnvelopes)
+        {
             await _validator.ValidateEvent(envelope, validatedEnvelopes);
             validatedEnvelopes.Add(envelope);
         }

diff --git a/src/Fluss/Validation/RootValidator.cs b/src/Fluss/Validation/RootValidator.cs
@@ -61,7 +61,8 @@ public async Task ValidateEvent(EventEnvelope envelope, IReadOnlyList<EventEnvel
         var willBePublishedEnvelopes = previousEnvelopes ?? new List<EventEnvelope>();
 
         var versionedUnitOfWork = unitOfWork.WithPrefilledVersion(envelope.Version - willBePublishedEnvelopes.Count - 1);
-        foreach (var willBePublishedEnvelope in willBePublishedEnvelopes) {
+        foreach (var willBePublishedEnvelope in willBePublishedEnvelopes)
+        {
             versionedUnitOfWork.PublishedEventEnvelopes.Enqueue(willBePublishedEnvelope);
         }