- Checkpoint: Renamed to SagaDispatcher

Author: NinjaRocks

src/SourceFlow/ClassDiagram.cd

@@ -26,7 +26,7 @@
   <Class Name="SourceFlow.Impl.EventQueue">
     <Position X="10.25" Y="3.5" Width="1.5" />
     <TypeIdentifier>
-      <HashCode>AABAAAAAAAAAAAACAAAAAAAAAEAAAAAAAAAAAAAAAAA=</HashCode>
+      <HashCode>AABAAAAAAAAAAAACAAAAAABAAAAAAAAAAAAAAAAAAAA=</HashCode>
       <FileName>Impl\EventQueue.cs</FileName>
     </TypeIdentifier>
     <Lollipop Position="0.2" />
@@ -44,7 +44,7 @@
       </MemberNameLabel>
     </AssociationLine>
     <TypeIdentifier>
-      <HashCode>AAgAAAAAABAAAAACAAAAAAAABEAAAAQAAAAAAAAAAAA=</HashCode>
+      <HashCode>AAgAAAAAABAAAAACAAAAAABABAAAAAQAAAAAAAAAAAA=</HashCode>
       <FileName>Impl\CommandBus.cs</FileName>
     </TypeIdentifier>
     <ShowAsAssociation>
@@ -201,67 +201,43 @@
     </ShowAsAssociation>
     <Lollipop Position="0.2" />
   </Class>
-  <Class Name="SourceFlow.Impl.CommandDispatcher">
+  <Class Name="SourceFlow.Impl.SagaDispatcher">
     <Position X="3" Y="7.5" Width="2" />
-    <AssociationLine Name="sagas" Type="SourceFlow.Saga.ISaga" ManuallyRouted="true" FixedFromPoint="true" FixedToPoint="true">
-      <Path>
-        <Point X="5" Y="8.245" />
-        <Point X="5.375" Y="8.245" />
-        <Point X="5.375" Y="4.552" />
-        <Point X="6" Y="4.552" />
-      </Path>
-    </AssociationLine>
     <TypeIdentifier>
       <HashCode>AAgAAAAAAAAAAEACAEAAAAAAAAABAAAAAAAAAAAAAAA=</HashCode>
-      <FileName>Impl\CommandDispatcher.cs</FileName>
+      <FileName>Impl\SagaDispatcher.cs</FileName>
     </TypeIdentifier>
     <ShowAsCollectionAssociation>
       <Field Name="sagas" />
     </ShowAsCollectionAssociation>
     <Lollipop Position="0.2" />
   </Class>
-  <Class Name="SourceFlow.Impl.ProjectionDispatcher">
-    <Position X="12.5" Y="6.25" Width="1.75" />
-    <AssociationLine Name="projections" Type="SourceFlow.ViewModel.IProjection" FixedFromPoint="true" FixedToPoint="true">
-      <Path>
-        <Point X="14.25" Y="6.688" />
-        <Point X="14.625" Y="6.688" />
-        <Point X="14.625" Y="5.938" />
-        <Point X="15.5" Y="5.938" />
-      </Path>
-      <MemberNameLabel ManuallyPlaced="true">
-        <Position X="0.138" Y="0.157" />
-      </MemberNameLabel>
-    </AssociationLine>
+  <Class Name="SourceFlow.Impl.AggregateDispatcher">
+    <Position X="12.5" Y="3.5" Width="1.75" />
     <TypeIdentifier>
-      <HashCode>AAgAAAAAAAAAAAACAAAAAAAAAAAAAAAAACAAAAAAAAA=</HashCode>
-      <FileName>Impl\ProjectionDispatcher.cs</FileName>
+      <HashCode>AAgAAAgAAAAAAAACAAAAAAAAAAAAAAAAAAAAAAAAAAA=</HashCode>
+      <FileName>Impl\AggregateDispatcher.cs</FileName>
     </TypeIdentifier>
     <ShowAsCollectionAssociation>
-      <Field Name="projections" />
+      <Field Name="aggregates" />
     </ShowAsCollectionAssociation>
     <Lollipop Position="0.2" />
   </Class>
-  <Class Name="SourceFlow.Impl.AggregateDispatcher">
-    <Position X="12.5" Y="3.75" Width="1.75" />
-    <AssociationLine Name="aggregates" Type="SourceFlow.Aggregate.IAggregate">
-      <MemberNameLabel ManuallyPlaced="true">
-        <Position X="0.235" Y="0.06" />
-      </MemberNameLabel>
-    </AssociationLine>
+  <Class Name="SourceFlow.Impl.ProjectionDispatcher">
+    <Position X="12.5" Y="5.75" Width="1.75" />
     <TypeIdentifier>
-      <HashCode>AAgAAAgAAAAAAAACAAAAAAAAAAAAAAAAAAAAAAAAAAA=</HashCode>
-      <FileName>Impl\AggregateDispatcher.cs</FileName>
+      <HashCode>AAgAAAAAAAAAAAACAAAAAAAAAAAAAAAAACAAAAAAAAA=</HashCode>
+      <FileName>Impl\ProjectionDispatcher.cs</FileName>
     </TypeIdentifier>
     <ShowAsCollectionAssociation>
-      <Field Name="aggregates" />
+      <Field Name="projections" />
     </ShowAsCollectionAssociation>
     <Lollipop Position="0.2" />
   </Class>
   <Interface Name="SourceFlow.Messaging.Bus.IEventQueue">
     <Position X="10.25" Y="1.5" Width="1.5" />
     <TypeIdentifier>
-      <HashCode>AABAAAAAAAAAAAAAAAAAAAAAAEAAAAAAAAAAAAAAAAA=</HashCode>
+      <HashCode>AABAAAAAAAAAAAAAAAAAAABAAAAAAAAAAAAAAAAAAAA=</HashCode>
       <FileName>Messaging\Bus\IEventQueue.cs</FileName>
     </TypeIdentifier>
   </Interface>
@@ -338,7 +314,7 @@
   <Interface Name="SourceFlow.Messaging.Bus.ICommandBus" Collapsed="true">
     <Position X="0.5" Y="3" Width="1.5" />
     <TypeIdentifier>
-      <HashCode>AAAAAAAAAAAAAAAAAEAAAAAAAEAAAAAAAQAAAAAAAAA=</HashCode>
+      <HashCode>AAAAAAAAAAAAAAAAAEAAAABAAAAAAAAAAQAAAAAAAAA=</HashCode>
       <FileName>Messaging\Bus\ICommandBus.cs</FileName>
     </TypeIdentifier>
   </Interface>

src/SourceFlow/Impl/CommandBus.cs

@@ -25,7 +25,7 @@ internal class CommandBus : ICommandBus
         /// <summary>
         /// Represents command dispathers that can handle the publishing of commands.
         /// </summary>
-        public event EventHandler<ICommand> Handlers;
+        public event EventHandler<ICommand> Dispatchers;
 
         /// <summary>
         /// Initializes a new instance of the <see cref="CommandBus"/> class.
@@ -60,7 +60,7 @@ private async Task Dispatch<TCommand>(TCommand command) where TCommand : IComman
                 ((IMetadata)command).Metadata.SequenceNo = await commandStore.GetNextSequenceNo(command.Payload.Id);
 
             // 2. Dispatch command to handlers.
-            Handlers?.Invoke(this, command);
+            Dispatchers?.Invoke(this, command);
 
             // 3. Log event.
             logger?.LogInformation("Action=Command_Dispatched, Command={Command}, Payload={Payload}, SequenceNo={No}, Saga={Saga}",

src/SourceFlow/Impl/EventQueue.cs

@@ -21,7 +21,7 @@ internal class EventQueue : IEventQueue
         /// <summary>
         /// Represents event dispathers that can handle the dequeuing of events.
         /// </summary>
-        public event EventHandler<IEvent> Handlers;
+        public event EventHandler<IEvent> Dispatchers;
 
         /// <summary>
         /// Initializes a new instance of the <see cref="EventQueue"/> class with the specified logger.
@@ -45,7 +45,7 @@ public async Task Enqueue<TEvent>(TEvent @event)
             if (@event == null)
                 throw new ArgumentNullException(nameof(@event));
 
-            Handlers?.Invoke(this, @event);
+            Dispatchers?.Invoke(this, @event);
 
             logger?.LogInformation("Action=Event_Enqueue, Event={Event}, Payload={Payload}",
                 @event.GetType().Name, @event.Payload.GetType().Name);

src/SourceFlow/Impl/CommandDispatcher.cs renamed to src/SourceFlow/Impl/SagaDispatcher.cs

@@ -10,9 +10,9 @@
 namespace SourceFlow.Impl
 {
     /// <summary>
-    /// CommandDispatcher is responsible for dispatching commands to registered sagas in an event-driven architecture.
+    /// This dispatcher is responsible for dispatching commands to registered sagas in an event-driven architecture.
     /// </summary>
-    internal class CommandDispatcher : ICommandDispatcher
+    internal class SagaDispatcher : ICommandDispatcher
     {
         /// <summary>
         /// Collection of sagas registered with the dispatcher.
@@ -25,10 +25,10 @@ internal class CommandDispatcher : ICommandDispatcher
         private readonly ILogger<ICommandDispatcher> logger;
 
         /// <summary>
-        /// Initializes a new instance of the <see cref="CommandDispatcher"/> class with the specified logger.
+        /// Initializes a new instance of the <see cref="SagaDispatcher"/> class with the specified logger.
         /// </summary>
         /// <param name="logger"></param>
-        public CommandDispatcher(ILogger<ICommandDispatcher> logger)
+        public SagaDispatcher(ILogger<ICommandDispatcher> logger)
         {
             this.logger = logger;
             sagas = new List<ISaga>();

src/SourceFlow/IocExtensions.cs

@@ -47,7 +47,7 @@ public static void UseSourceFlow(this IServiceCollection services, Action<ISourc
             services.AddAsImplementationsOfInterface<ICommandStore>(lifetime: ServiceLifetime.Singleton);
             services.AddAsImplementationsOfInterface<IProjection>(lifetime: ServiceLifetime.Singleton);
 
-            services.AddSingleton<ICommandDispatcher, CommandDispatcher>(c => new CommandDispatcher(
+            services.AddSingleton<SagaDispatcher>(c => new SagaDispatcher(
                 c.GetService<ILogger<ICommandDispatcher>>()));
 
             services.AddSingleton<ICommandBus, CommandBus>(c =>
@@ -56,8 +56,8 @@ public static void UseSourceFlow(this IServiceCollection services, Action<ISourc
                 c.GetService<ICommandStore>(),
                 c.GetService<ILogger<ICommandBus>>());
 
-                var dispatcher = c.GetService<ICommandDispatcher>();
-                commandBus.Handlers += dispatcher.Dispatch;
+                var dispatcher = c.GetService<SagaDispatcher>();
+                commandBus.Dispatchers += dispatcher.Dispatch;
 
                 return commandBus;
             });
@@ -78,10 +78,10 @@ public static void UseSourceFlow(this IServiceCollection services, Action<ISourc
                 c.GetService<ILogger<IEventQueue>>());
                 // need to register event handlers for the projection before aggregates
                 var projectionDispatcher = c.GetService<ProjectionDispatcher>();
-                queue.Handlers += projectionDispatcher.Dispatch;
+                queue.Dispatchers += projectionDispatcher.Dispatch;
                 // need to register event handlers for the aggregates after projections
                 var aggregateDispatcher = c.GetService<AggregateDispatcher>();
-                queue.Handlers += aggregateDispatcher.Dispatch;
+                queue.Dispatchers += aggregateDispatcher.Dispatch;
 
                 return queue;
             });

src/SourceFlow/Messaging/Bus/ICommandBus.cs

@@ -28,6 +28,6 @@ Task Publish<TCommand>(TCommand command)
         /// <summary>
         /// Represents command dispathers that can handle the publishing of commands.
         /// </summary>
-        event EventHandler<ICommand> Handlers;
+        event EventHandler<ICommand> Dispatchers;
     }
 }

src/SourceFlow/Messaging/Bus/IEventQueue.cs

@@ -6,9 +6,9 @@ namespace SourceFlow.Messaging.Bus
     public interface IEventQueue
     {
         /// <summary>
-        /// Handlers that are invoked to dispatch an event that is dequeued from the event queue.
+        /// Dispatchers that are invoked to publish an event that is dequeued from the event queue.
         /// </summary>
-        event EventHandler<IEvent> Handlers;
+        event EventHandler<IEvent> Dispatchers;
 
         /// <summary>
         /// Enqueues an event in order to publish to subcribers.

tests/SourceFlow.Core.Tests/SampleSagaTests.cs

@@ -35,7 +35,7 @@
 //            public Task Handle<TEvent>(TEvent @event) where TEvent : ICommand
 //            {
 //                // Example: just call all handlers for the event type
-//                foreach (var handler in Handlers)
+//                foreach (var handler in Dispatchers)
 //                {
 //                    if (handler.EventType == typeof(TEvent))
 //                        ((IHandles<TEvent>)handler.Handler).Handle(@event);