fix: writing failed events

src/Fluss.UnitTest/Core/UnitOfWork/UnitOfWorkTest.cs

@@ -35,7 +35,7 @@ public UnitOfWorkTest()
 
         _unitOfWorkFactory = new UnitOfWorkFactory(
             new ServiceCollection()
-                .AddScoped(_ => GetUnitOfWork())
+                .AddTransient(_ => GetUnitOfWork())
                 .BuildServiceProvider());
     }
 
@@ -332,6 +332,33 @@ await Assert.ThrowsAsync<InvalidOperationException>(async () =>
         });
     }
 
+    [Fact]
+    public async Task FailingCommitDoesNotCacheEventsToWrite()
+    {
+        _policies.Add(new AllowAllPolicy());
+
+        try
+        {
+            await _unitOfWorkFactory.Commit(async unitOfWork =>
+            {
+                var aggregate = await unitOfWork.GetAggregate<TestAggregate, int>(100);
+                await aggregate.Create();
+
+                throw new Exception();
+            });
+        }
+        catch
+        {
+        }
+
+        await _unitOfWorkFactory.Commit(_ => ValueTask.CompletedTask);
+
+        var unitOfWork = GetUnitOfWork();
+        var aggregate = await unitOfWork.GetAggregate<TestAggregate, int>(100);
+
+        Assert.False(aggregate.Exists);
+    }
+
     private record TestRootReadModel : RootReadModel
     {
         public int GotEvents { get; private init; }

src/Fluss/UnitOfWork/UnitOfWork.cs

@@ -105,6 +105,8 @@ public ValueTask Return()
         _validator = null;
         _userIdProvider = null;
         _consistentVersion = null;
+
+        PublishedEventEnvelopes.Clear();
         _readModels.Clear();
         _isInstantiated = false;