- Checkpoint: Split Events vs Commands

Author: NinjaRocks

src/SourceFlow.ConsoleApp/Aggregates/AccountAggregate.cs

@@ -1,13 +1,13 @@
-using SourceFlow.ConsoleApp.Events;
+using SourceFlow.ConsoleApp.Commands;
 
 namespace SourceFlow.ConsoleApp.Aggregates
 {
     public class AccountAggregate : BaseAggregate<BankAccount>
     {
         public void CreateAccount(int accountId, string holder, decimal amount)
         {
-            PublishAsync(Event.For<BankAccount>(accountId)
-                              .Create<AccountCreated, AccountPayload>(new AccountPayload
+            PublishAsync(Command.For<BankAccount>(accountId)
+                              .Create<CreateAccount, AccountPayload>(new AccountPayload
                               {
                                   AccountName = holder,
                                   InitialAmount = amount
@@ -16,8 +16,8 @@ public void CreateAccount(int accountId, string holder, decimal amount)
 
         public void Deposit(int accountId, decimal amount)
         {
-            PublishAsync(Event.For<BankAccount>(accountId)
-                              .Create<MoneyDeposited, TransactPayload>(new TransactPayload
+            PublishAsync(Command.For<BankAccount>(accountId)
+                              .Create<DepositMoney, TransactPayload>(new TransactPayload
                               {
                                   Amount = amount,
                                   Type = TransactionType.Deposit
@@ -26,8 +26,8 @@ public void Deposit(int accountId, decimal amount)
 
         public void Withdraw(int accountId, decimal amount)
         {
-            PublishAsync(Event.For<BankAccount>(accountId)
-                              .Create<MoneyWithdrawn, TransactPayload>(new TransactPayload
+            PublishAsync(Command.For<BankAccount>(accountId)
+                              .Create<WithdrawMoney, TransactPayload>(new TransactPayload
                               {
                                   Amount = amount,
                                   Type = TransactionType.Withdrawal
@@ -36,8 +36,8 @@ public void Withdraw(int accountId, decimal amount)
 
         public void Close(int accountId, string reason)
         {
-            PublishAsync(Event.For<BankAccount>(accountId)
-                              .Create<AccountClosed, ClosurePayload>(new ClosurePayload
+            PublishAsync(Command.For<BankAccount>(accountId)
+                              .Create<CloseAccount, ClosurePayload>(new ClosurePayload
                               {
                                   ClosureReason = reason
                               }));

src/SourceFlow.ConsoleApp/Aggregates/BankAccount.cs

@@ -3,6 +3,7 @@ namespace SourceFlow.ConsoleApp.Aggregates
     public class BankAccount : IEntity
     {
         public int Id { get; set; }
+        public DateTime CreatedOn { get; set; } = DateTime.UtcNow;
         public string AccountName { get; set; } = string.Empty;
         public decimal Balance { get; set; }
         public bool IsClosed { get; set; }

src/SourceFlow.ConsoleApp/Commands/AccountCommand.cs

@@ -0,0 +1,6 @@
+namespace SourceFlow.ConsoleApp.Commands
+{
+    public abstract class AccountCommand<TPayload> : BaseCommand<TPayload> where TPayload : class, IPayload, new()
+    {
+    }
+}

src/SourceFlow.ConsoleApp/Events/AccountPayload.cs renamed to src/SourceFlow.ConsoleApp/Commands/AccountPayload.cs

@@ -1,21 +1,21 @@
 using SourceFlow.ConsoleApp.Aggregates;
 
-namespace SourceFlow.ConsoleApp.Events
+namespace SourceFlow.ConsoleApp.Commands
 {
-    public class AccountPayload : IEventPayload
+    public class AccountPayload : IPayload
     {
         public decimal InitialAmount { get; set; }
         public string AccountName { get; set; }
     }
 
-    public class TransactPayload : IEventPayload
+    public class TransactPayload : IPayload
     {
         public TransactionType Type { get; set; }
         public decimal Amount { get; set; }
         public decimal CurrentBalance { get; set; }
     }
 
-    public class ClosurePayload : IEventPayload
+    public class ClosurePayload : IPayload
     {
         public bool IsClosed { get; set; }
         public string ClosureReason { get; set; } = string.Empty;

src/SourceFlow.ConsoleApp/Commands/CloseAccount.cs

@@ -0,0 +1,6 @@
+namespace SourceFlow.ConsoleApp.Commands
+{
+    public class CloseAccount : AccountCommand<ClosurePayload>
+    {
+    }
+}

src/SourceFlow.ConsoleApp/Commands/CreateAccount.cs

@@ -0,0 +1,6 @@
+namespace SourceFlow.ConsoleApp.Commands
+{
+    public class CreateAccount : AccountCommand<AccountPayload>
+    {
+    }
+}

src/SourceFlow.ConsoleApp/Commands/DepositMoney.cs

@@ -0,0 +1,6 @@
+namespace SourceFlow.ConsoleApp.Commands
+{
+    public class DepositMoney : AccountCommand<TransactPayload>
+    {
+    }
+}

src/SourceFlow.ConsoleApp/Commands/WithdrawMoney.cs

@@ -0,0 +1,6 @@
+namespace SourceFlow.ConsoleApp.Commands
+{
+    public class WithdrawMoney : AccountCommand<TransactPayload>
+    {
+    }
+}

src/SourceFlow.ConsoleApp/Events/AccountClosed.cs

@@ -1,6 +1,10 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using SourceFlow.ConsoleApp.Aggregates;
+
 namespace SourceFlow.ConsoleApp.Events
 {
-    public class AccountCreated : AccountEvent<AccountPayload>
-    {
-    }
 }