Add a Mediator to Brighter

Brighter.sln

@@ -315,6 +315,8 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Salutation_Sweeper", "sampl
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Paramore.Brighter.Locking.MsSql", "src\Paramore.Brighter.Locking.MsSql\Paramore.Brighter.Locking.MsSql.csproj", "{758EE237-C722-4A0A-908C-2D08C1E59025}"
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Paramore.Brighter.MediatorWorkflow", "src\Paramore.Brighter.MediatorWorkflow\Paramore.Brighter.MediatorWorkflow.csproj", "{F00B137A-C187-4C33-A37B-22AD40B71600}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -1765,6 +1767,18 @@ Global
 		{758EE237-C722-4A0A-908C-2D08C1E59025}.Release|Mixed Platforms.Build.0 = Release|Any CPU
 		{758EE237-C722-4A0A-908C-2D08C1E59025}.Release|x86.ActiveCfg = Release|Any CPU
 		{758EE237-C722-4A0A-908C-2D08C1E59025}.Release|x86.Build.0 = Release|Any CPU
+		{F00B137A-C187-4C33-A37B-22AD40B71600}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{F00B137A-C187-4C33-A37B-22AD40B71600}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{F00B137A-C187-4C33-A37B-22AD40B71600}.Debug|Mixed Platforms.ActiveCfg = Debug|Any CPU
+		{F00B137A-C187-4C33-A37B-22AD40B71600}.Debug|Mixed Platforms.Build.0 = Debug|Any CPU
+		{F00B137A-C187-4C33-A37B-22AD40B71600}.Debug|x86.ActiveCfg = Debug|Any CPU
+		{F00B137A-C187-4C33-A37B-22AD40B71600}.Debug|x86.Build.0 = Debug|Any CPU
+		{F00B137A-C187-4C33-A37B-22AD40B71600}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{F00B137A-C187-4C33-A37B-22AD40B71600}.Release|Any CPU.Build.0 = Release|Any CPU
+		{F00B137A-C187-4C33-A37B-22AD40B71600}.Release|Mixed Platforms.ActiveCfg = Release|Any CPU
+		{F00B137A-C187-4C33-A37B-22AD40B71600}.Release|Mixed Platforms.Build.0 = Release|Any CPU
+		{F00B137A-C187-4C33-A37B-22AD40B71600}.Release|x86.ActiveCfg = Release|Any CPU
+		{F00B137A-C187-4C33-A37B-22AD40B71600}.Release|x86.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE

docs/adr/0020-reduce-esb-complexity.md

@@ -1,6 +1,6 @@
 # 20. Reduce External Service Bus Complexity
 
-Date: 2019-08-01
+Date: 2024-08-01
 
 ## Status
 

docs/adr/0022-add-a-mediator.md

@@ -0,0 +1,57 @@
+# 22. Add a Mediator to Brighter 
+
+Date: 2024-10-22
+
+## Status
+
+Proposed
+
+## Context
+We have two approaches to a workflow: orchestration and choreography. In choreography the workflow emerges from the interaction of the participants. In orchestration, one participant executes the workflow, calling other participants as needed. Whilst choreography has low-coupling, it also has low-cohesion. At scale this can lead to the Pinball anti-pattern, where it is difficult to maintain the workflow.
+
+The [Mediator](https://www.oodesign.com/mediator-pattern) pattern provides an orchestrator that manages a workflow that involves multiple objects. In its simplest form, instead of talking to each other, objects talk to the mediator, which then calls other objects as required to execute the workflow.
+
+Brighter provides `IHandleRequests<>` to provide a handler for an individual request, either a command or an event. It is possible to have an emergent workflow, within Brighter, through the choreography of these handlers. However, Brighter provides no model for an orchestrator that manages a workflow that involves multiple handlers. In particular, Brighter does not support a class that can listen to multiple requests and then call other handlers as required to execute the workflow.
+
+In principle, nothing stops an end user from implementing a `Mediator` class that listens to multiple requests and then calls other handlers as required to execute the workflow.  So orchestration has always been viable, but left as an exercise to the user. However, competing OSS projects provide popular workflow functionality, suggesting there is demand for an off-the-shelf solution.
+
+Other dotnet messaging platforms erroneously conflate the Saga and Mediator patterns. A Saga is a long-running transaction that spans multiple services. A Mediator is an orchestrator that manages a workflow that involves multiple objects. One aspect of those implementations is typically the ability to store workflow state. 
+
+A particular reference for the requirements for this work is [AWS step functions](https://states-language.net/spec.html). AWS Step functions provide a state machine that mediates calls to AWS Lambda functions. When thinking about Brighter's `IHandleRequests` it is attractive to compare them to Lambda functions in the Step functions model :
+
+  1.  The AWS Step funcions state machine does not hold the business logic, that is located in the functions called; the Step function handles calling the Lambda functions and state transitions (as well as error paths)
+  2.  We want to use the Mediator to orchestrate both internal bus and external bus hosted workflows. Step functions provide a useful model of requirements for the latter.
+
+This approach is intended to enable flexible, event-driven workflows that can handle various business processes and requirements, including asynchronous event handling and conditional branching.
+
+We are also influenced by the [Arazzo Specification](https://github.com/OAI/Arazzo-Specification/blob/main/versions/1.0.0.md) for defining workflows from AsyncAPI.
+
+
+## Decision
+
+We will add a `Mediator` class to Brighter that will: 
+
+	1.	Manages and tracks a WorkflowState object representing the current step in the workflow.
+	2.	Supports multiple process states, including:
+	•	StartState: Initiates the workflow.
+	•	FireAndForgetProcessState: Dispatches a `Command` and immediately advances to the next state.
+	•	RequestReactionProcessState: Dispatches a `Command` and waits for an event response before advancing.
+	•	ChoiceProcessState: Evaluates conditions using the `Specification` Pattern and chooses the next `Command` to Dispatch based on the evaluation.
+	•	WaitState: Suspends execution for a specified TimeSpan before advancing.
+	3.	Uses a CommandProcessor for routing commands and events to appropriate handlers.
+	4.	Can be passed events, and uses the correlation IDs to match events to specific workflow instances and advance the workflow accordingly.
+
+The Specification Pattern in ChoiceProcessState allows flexible conditional logic by combining specifications with And and Or conditions, enabling complex branching decisions within the workflow.
+
+We assume that the initial V10 of Brighter will contain a minimum viable product version of the `Mediator`. Additional functionality, such as process states, UIs for workflows will be a feature of later releases.
+
+## Consequences
+
+Positive Consequences
+
+	1.	Simplicity: Providing orchestration for a workflow, which is easier to understand 
+	2.	Modularity: It is possible to extend the `Mediator' relativey easy by adding new process states.
+
+Negative Consequences
+
+    1.  Increased Brighter scope: Previously we had assumed that developers would use an off-the-shelf workflow solution like [Stateless](https://github.com/nblumhardt/stateless) or [Workflow Core]. The decision to provide our own workflow, to orchestrate via CommandProcessor means that we increase our scope to include the complexity of workflow management.

samples/TaskQueue/ASBTaskQueue/Greetings/Ports/Events/GreetingAsyncEvent.cs

@@ -5,13 +5,13 @@ namespace Greetings.Ports.Events
 {
     public class GreetingAsyncEvent : Event
     {
-        public GreetingAsyncEvent() : base(Guid.NewGuid()) { }
+        public GreetingAsyncEvent() : base(Guid.NewGuid().ToString()) { }
 
-        public GreetingAsyncEvent(string greeting) : base(Guid.NewGuid())
+        public GreetingAsyncEvent(string greeting) : base(Guid.NewGuid().ToString())
         {
             Greeting = greeting;
         }
 
-        public string Greeting { get; set; }
+        public string? Greeting { get; set; }
     }
 }

samples/TaskQueue/ASBTaskQueue/Greetings/Ports/Events/GreetingEvent.cs

@@ -5,13 +5,13 @@ namespace Greetings.Ports.Events
 {
     public class GreetingEvent : Event
     {
-        public GreetingEvent() : base(Guid.NewGuid()) { }
+        public GreetingEvent() : base(Guid.NewGuid().ToString()) { }
 
-        public GreetingEvent(string greeting) : base(Guid.NewGuid())
+        public GreetingEvent(string greeting) : base(Guid.NewGuid().ToString())
         {
             Greeting = greeting;
         }
 
-        public string Greeting { get; set; }
+        public string? Greeting { get; set; }
     }
 }

samples/TaskQueue/AWSTaskQueue/Greetings/Ports/Commands/GreetingEvent.cs

@@ -29,9 +29,9 @@ namespace Greetings.Ports.Commands
 {
     public class GreetingEvent : Event
     {
-        public GreetingEvent() : base(Guid.NewGuid()) { }
+        public GreetingEvent() : base(Guid.NewGuid().ToString()) { }
 
-        public GreetingEvent(string greeting) : base(Guid.NewGuid())
+        public GreetingEvent(string greeting) : base(Guid.NewGuid().ToString())
         {
             Greeting = greeting;
         }

samples/TaskQueue/KafkaSchemaRegistry/Greetings/Ports/Commands/GreetingEvent.cs

@@ -29,9 +29,9 @@ namespace Greetings.Ports.Commands
 {
     public class GreetingEvent : Event
     {
-        public GreetingEvent() : base(Guid.NewGuid()) { }
+        public GreetingEvent() : base(Guid.NewGuid().ToString()) { }
 
-        public GreetingEvent(string greeting) : base(Guid.NewGuid())
+        public GreetingEvent(string greeting) : base(Guid.NewGuid().ToString())
         {
             Greeting = greeting;
         }

samples/TaskQueue/KafkaTaskQueue/Greetings/Ports/Commands/GreetingEvent.cs

@@ -29,9 +29,9 @@ namespace Greetings.Ports.Commands
 {
     public class GreetingEvent : Event
     {
-        public GreetingEvent() : base(Guid.NewGuid()) { }
+        public GreetingEvent() : base(Guid.NewGuid().ToString()) { }
 
-        public GreetingEvent(string greeting) : base(Guid.NewGuid())
+        public GreetingEvent(string greeting) : base(Guid.NewGuid().ToString())
         {
             Greeting = greeting;
         }

samples/TaskQueue/MsSqlMessagingGateway/Events/Ports/Commands/GreetingEvent.cs

@@ -29,9 +29,9 @@ namespace Events.Ports.Commands
 {
     public class GreetingEvent : Event
     {
-        public GreetingEvent() : base(Guid.NewGuid()) { }
+        public GreetingEvent() : base(Guid.NewGuid().ToString()) { }
 
-        public GreetingEvent(string greeting) : base(Guid.NewGuid())
+        public GreetingEvent(string greeting) : base(Guid.NewGuid().ToString())
         {
             Greeting = greeting;
         }

samples/TaskQueue/RMQTaskQueue/Greetings/Ports/Commands/FarewellEvent.cs

@@ -5,17 +5,8 @@
 namespace Greetings.Ports.Commands
 {
     [MessagePackObject(keyAsPropertyName: true)]
-    public class FarewellEvent : Event
+    public class FarewellEvent(string farewell) : Event(Guid.NewGuid().ToString())
     {
-        public FarewellEvent() : base(Guid.NewGuid())
-        {
-        }
-
-        public FarewellEvent(string farewell) : base(Guid.NewGuid())
-        {
-            Farewell = farewell;
-        }
-
-        public string Farewell { get; set; }
+        public string Farewell { get; set; } = farewell;
     }
 }

samples/TaskQueue/RMQTaskQueue/Greetings/Ports/Commands/GreetingEvent.cs

@@ -29,13 +29,13 @@ namespace Greetings.Ports.Commands
 {
     public class GreetingEvent : Event
     {
-        public GreetingEvent() : base(Guid.NewGuid()) { }
+        public GreetingEvent() : base(Guid.NewGuid().ToString()) { }
 
-        public GreetingEvent(string greeting) : base(Guid.NewGuid())
+        public GreetingEvent(string greeting) : base(Guid.NewGuid().ToString())
         {
             Greeting = greeting;
         }
 
-        public string Greeting { get; set; }
+        public string? Greeting { get; }
     }
 }

samples/TaskQueue/RedisTaskQueue/Greetings/Ports/Events/GreetingEvent.cs

@@ -29,9 +29,9 @@ namespace Greetings.Ports.Events
 {
     public class GreetingEvent : Event
     {
-        public GreetingEvent() : base(Guid.NewGuid()) { }
+        public GreetingEvent() : base(Guid.NewGuid().ToString()) { }
 
-        public GreetingEvent(string greeting) : base(Guid.NewGuid())
+        public GreetingEvent(string greeting) : base(Guid.NewGuid().ToString())
         {
             Greeting = greeting;
         }

samples/Transforms/AWSTransfomers/ClaimCheck/Greetings/Ports/Commands/GreetingEvent.cs

@@ -29,9 +29,9 @@ namespace Greetings.Ports.Commands
 {
     public class GreetingEvent : Event
     {
-        public GreetingEvent() : base(Guid.NewGuid()) { }
+        public GreetingEvent() : base(Guid.NewGuid().ToString()) { }
 
-        public GreetingEvent(string greeting) : base(Guid.NewGuid())
+        public GreetingEvent(string greeting) : base(Guid.NewGuid().ToString())
         {
             Greeting = greeting;
         }

samples/Transforms/AWSTransfomers/Compression/Greetings/Ports/Commands/GreetingEvent.cs

@@ -29,9 +29,9 @@ namespace Greetings.Ports.Commands
 {
     public class GreetingEvent : Event
     {
-        public GreetingEvent() : base(Guid.NewGuid()) { }
+        public GreetingEvent() : base(Guid.NewGuid().ToString()) { }
 
-        public GreetingEvent(string greeting) : base(Guid.NewGuid())
+        public GreetingEvent(string greeting) : base(Guid.NewGuid().ToString())
         {
             Greeting = greeting;
         }

samples/WebAPI/WebAPI_Dapper/GreetingsApp/Requests/GreetingMade.cs

@@ -5,7 +5,7 @@ namespace GreetingsApp.Requests;
 
 public class GreetingMade : Event
 {
-    public GreetingMade(string greeting) : base(Guid.NewGuid())
+    public GreetingMade(string greeting) : base(Guid.NewGuid().ToString())
     {
         Greeting = greeting;
     }

samples/WebAPI/WebAPI_Dapper/SalutationApp/Requests/GreetingMade.cs

@@ -5,7 +5,7 @@ namespace SalutationApp.Requests;
 
 public class GreetingMade : Event
 {
-    public GreetingMade(string greeting) : base(Guid.NewGuid())
+    public GreetingMade(string greeting) : base(Guid.NewGuid().ToString())
     {
         Greeting = greeting;
     }

samples/WebAPI/WebAPI_Dapper/SalutationApp/Requests/SalutationReceived.cs

@@ -5,7 +5,7 @@ namespace SalutationApp.Requests;
 
 public class SalutationReceived : Event
 {
-    public SalutationReceived(DateTimeOffset receivedAt) : base(Guid.NewGuid())
+    public SalutationReceived(DateTimeOffset receivedAt) : base(Guid.NewGuid().ToString())
     {
         ReceivedAt = receivedAt;
     }

samples/WebAPI/WebAPI_Dynamo/GreetingsApp/Requests/GreetingMade.cs

@@ -7,7 +7,7 @@ public class GreetingMade : Event
     {
         public string Greeting { get; set; }
 
-        public GreetingMade(string greeting) : base(Guid.NewGuid())
+        public GreetingMade(string greeting) : base(Guid.NewGuid().ToString())
         {
             Greeting = greeting;
         }

samples/WebAPI/WebAPI_Dynamo/SalutationApp/Requests/GreetingMade.cs

@@ -7,7 +7,7 @@ public class GreetingMade : Event
     {
         public string Greeting { get; set; }
 
-        public GreetingMade(string greeting) : base(Guid.NewGuid())
+        public GreetingMade(string greeting) : base(Guid.NewGuid().ToString())
         {
             Greeting = greeting;
         }

samples/WebAPI/WebAPI_Dynamo/SalutationApp/Requests/SalutationReceived.cs

@@ -7,7 +7,7 @@ public class SalutationReceived : Event
     {
         public DateTimeOffset ReceivedAt { get; }
 
-        public SalutationReceived(DateTimeOffset receivedAt) : base(Guid.NewGuid())
+        public SalutationReceived(DateTimeOffset receivedAt) : base(Guid.NewGuid().ToString())
         {
             ReceivedAt = receivedAt;
         }

samples/WebAPI/WebAPI_EFCore/GreetingsApp/Requests/GreetingMade.cs

@@ -7,7 +7,7 @@ public class GreetingMade : Event
     {
         public string Greeting { get; set; }
 
-        public GreetingMade(string greeting) : base(Guid.NewGuid())
+        public GreetingMade(string greeting) : base(Guid.NewGuid().ToString())
         {
             Greeting = greeting;
         }

samples/WebAPI/WebAPI_EFCore/SalutationApp/Requests/GreetingMade.cs

@@ -3,13 +3,8 @@
 
 namespace SalutationApp.Requests
 {
-    public class GreetingMade : Event
+    public class GreetingMade(string greeting) : Event(Guid.NewGuid().ToString())
     {
-        public string Greeting { get; set; }
-
-        public GreetingMade(string greeting) : base(Guid.NewGuid())
-        {
-            Greeting = greeting;
-        }
+        public string Greeting { get; init; } = greeting;
     }
 }

samples/WebAPI/WebAPI_EFCore/SalutationApp/Requests/SalutationReceived.cs

@@ -3,13 +3,8 @@
 
 namespace SalutationApp.Requests
 {
-    public class SalutationReceived : Event
+    public class SalutationReceived(DateTimeOffset receivedAt) : Event(Guid.NewGuid().ToString())
     {
-        public DateTimeOffset ReceivedAt { get; }
-
-        public SalutationReceived(DateTimeOffset receivedAt) : base(Guid.NewGuid())
-        {
-            ReceivedAt = receivedAt;
-        }
+        public DateTimeOffset ReceivedAt { get; } = receivedAt;
     }
 }

src/Paramore.Brighter.MediatorWorkflow/IAmAWorkflowStore.cs

@@ -0,0 +1,46 @@
+#region Licence
+/* The MIT License (MIT)
+Copyright © 2024 Ian Cooper <ian_hammond_cooper@yahoo.co.uk>
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the “Software”), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in
+all copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED “AS IS”, WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER 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. */
+
+#endregion
+
+using System;
+
+namespace Paramore.Brighter.MediatorWorkflow;
+
+/// <summary>
+/// Used to store the state of a workflow
+/// </summary>
+public interface IAmAWorkflowStore
+{
+    /// <summary>
+    /// Saves the workflow 
+    /// </summary>
+    /// <param name="workflow">The workflow</param>
+    void SaveWorkflow<TData>(Workflow<TData> workflow) where TData : IAmTheWorkflowData;
+
+    /// <summary>
+    /// Retrieves a workflow via its Id
+    /// </summary>
+    /// <param name="id">The id of the workflow</param>
+    /// <returns>if found, the workflow, otherwise null</returns>
+    Workflow? GetWorkflow(string? id) ;
+}