feat: add an abort operation on aggregate handlers to facilitate the …

…implementation of distributed commit protocols
Whaally · Dec 10, 2024 · 0a5408f · 0a5408f
1 parent 7559d11
commit 0a5408f
Show file tree

Hide file tree

Showing 4 changed files with 29 additions and 6 deletions.
diff --git a/src/Whaally.Domain.Infrastructure.OrleansHost/Grains/AbstractAggregateHandlerGrain.cs b/src/Whaally.Domain.Infrastructure.OrleansHost/Grains/AbstractAggregateHandlerGrain.cs
@@ -1,4 +1,5 @@
-using FluentResults;
+using System.Diagnostics;
+using FluentResults;
 using Microsoft.Extensions.Logging;
 using Orleans.Concurrency;
 using Orleans.EventSourcing;
@@ -97,6 +98,11 @@ public async Task<IResultBase> Apply(IEventEnvelope eventEnvelope)
         return Result.Ok();
     }
 
+    public Task Abort(ActivityContext context)
+    {
+        throw new NotImplementedException();
+    }
+
     [ReadOnly]
     public Task<TSnapshot> Snapshot<TSnapshot>() where TSnapshot : ISnapshot
     {

diff --git a/src/Whaally.Domain/Abstractions/Aggregate/IAggregateHandler.cs b/src/Whaally.Domain/Abstractions/Aggregate/IAggregateHandler.cs
@@ -1,4 +1,5 @@
-using FluentResults;
+using System.Diagnostics;
+using FluentResults;
 
 namespace Whaally.Domain.Abstractions;
 
@@ -51,6 +52,13 @@ public Task<IResultBase> Apply(params IEvent[] events)
         => Apply(new EventEnvelope(
             new EventMetadata(),
             events));
+
+    /// <summary>
+    ///     Allows abortion of a running transaction based on the context it is part of
+    /// </summary>
+    /// <param name="context"></param>
+    /// <returns></returns>
+    public Task Abort(ActivityContext context);
 
     public Task<TSnapshot> Snapshot<TSnapshot>()
         where TSnapshot : ISnapshot;

diff --git a/src/Whaally.Domain/Aggregate/DefaultAggregateHandler.cs b/src/Whaally.Domain/Aggregate/DefaultAggregateHandler.cs
@@ -1,4 +1,5 @@
-using FluentResults;
+using System.Diagnostics;
+using FluentResults;
 using Microsoft.Extensions.DependencyInjection;
 using Whaally.Domain.Abstractions;
 
@@ -150,6 +151,11 @@ public async Task<IResultBase> Apply(IEventEnvelope eventEnvelope)
         return Result.Ok();
     }
 
+    public Task Abort(ActivityContext context)
+    {
+        throw new NotImplementedException();
+    }
+
     public Task<TSnapshot> Snapshot<TSnapshot>()
         where TSnapshot : ISnapshot =>
         Task.FromResult(

diff --git a/tests/Whaally.Domain.Tests/Scenarios/_0004__aggregate_interfaces.cs b/tests/Whaally.Domain.Tests/Scenarios/_0004__aggregate_interfaces.cs
@@ -1,3 +1,4 @@
+using System.Diagnostics;
 using FluentAssertions;
 using FluentResults;
 using Microsoft.Extensions.DependencyInjection;
@@ -8,12 +9,12 @@ namespace Whaally.Domain.Tests.Scenarios;
 public class _0004__aggregate_interfaces
 {
     public interface ITestAggregate : IAggregate;
-
+    
     public class TestImplementation : ITestAggregate;
 
     // Commands
     public class TestCommand : ICommand;
-
+    
     public class TestCommandHandler : ICommandHandler<ITestAggregate, TestCommand>
     {
         public IResultBase Evaluate(ICommandHandlerContext<ITestAggregate> context, TestCommand command)
@@ -40,6 +41,8 @@ public Task<IResult<IEventEnvelope[]>> Evaluate(params ICommandEnvelope[] comman
             => throw new NotImplementedException();
         public Task<IResultBase> Apply(params IEventEnvelope[] events)
             => throw new NotImplementedException();
+        public Task Abort(ActivityContext context) 
+            => throw new NotImplementedException();
         public Task<TSnapshot> Snapshot<TSnapshot>() where TSnapshot : ISnapshot
             => throw new NotImplementedException();
     }
@@ -90,4 +93,4 @@ public void CanCreateNewDefaultAggregateHandler()
                     config.AggregateFactory = _ => new TestAggregateFactory();
                 })
                 .BuildServiceProvider(), "");
-}
+}