- Checkpoint: Simplified Saga and Events

Author: NinjaRocks

src/SourceFlow.ConsoleApp/Aggregates/AccountAggregate.cs

@@ -1,11 +1,10 @@
-using Microsoft.Extensions.Logging;
 using SourceFlow.ConsoleApp.Commands;
-using SourceFlow.Events;
+using SourceFlow.ConsoleApp.Events;
 
 namespace SourceFlow.ConsoleApp.Aggregates
 {
     public class AccountAggregate : BaseAggregate<BankAccount>,
-                                    IEventHandler<EntityCreated<BankAccount>>
+                                    IEventHandler<AccountCreated>
 
     {
         public void CreateAccount(int accountId, string holder, decimal amount)
@@ -47,16 +46,13 @@ public void Close(int accountId, string reason)
                               }));
         }
 
-        public Task Handle(EntityCreated<BankAccount> @event)
+        public Task Handle(AccountCreated @event)
         {
-            if (@event.Name != "BankAccountCreated")
-                return Task.CompletedTask;
-
             return PublishAsync(Command.For<BankAccount>(@event.Payload.Id)
-                                   .Create<ActivateAccount, ActivationPayload>(new ActivationPayload
-                                   {
-                                       ActiveOn = DateTime.UtcNow,
-                                   }));
+                                    .Create<ActivateAccount, ActivationPayload>(new ActivationPayload
+                                    {
+                                        ActiveOn = DateTime.UtcNow,
+                                    }));
         }
     }
 }

src/SourceFlow.ConsoleApp/Commands/AccountCommand.cs

@@ -1,6 +1,6 @@
 namespace SourceFlow.ConsoleApp.Commands
 {
-    public class ActivateAccount : AccountCommand<ActivationPayload>
+    public class ActivateAccount : BaseCommand<ActivationPayload>
     {
     }
 }

src/SourceFlow.ConsoleApp/Commands/ActivateAccount.cs

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

src/SourceFlow.ConsoleApp/Commands/CloseAccount.cs

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

src/SourceFlow.ConsoleApp/Commands/CreateAccount.cs

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

src/SourceFlow.ConsoleApp/Commands/DepositMoney.cs

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

src/SourceFlow.ConsoleApp/Commands/WithdrawMoney.cs

@@ -0,0 +1,11 @@
+using SourceFlow.ConsoleApp.Aggregates;
+
+namespace SourceFlow.ConsoleApp.Events
+{
+    public class AccountCreated : BaseEvent<BankAccount>
+    {
+        public AccountCreated(BankAccount payload) : base(payload)
+        {
+        }
+    }
+}

src/SourceFlow.ConsoleApp/Events/AccountCreated.cs

@@ -0,0 +1,11 @@
+using SourceFlow.ConsoleApp.Aggregates;
+
+namespace SourceFlow.ConsoleApp.Events
+{
+    public class AccountUpdated : BaseEvent<BankAccount>
+    {
+        public AccountUpdated(BankAccount payload) : base(payload)
+        {
+        }
+    }
+}

src/SourceFlow.ConsoleApp/Events/AccountUpdated.cs

@@ -2,7 +2,7 @@
 using Microsoft.Extensions.Logging;
 using SourceFlow;
 using SourceFlow.ConsoleApp.Services;
-using SourceFlow.ConsoleApp.ViewModels; // Ensure this using is present
+using SourceFlow.ConsoleApp.Views; // Ensure this using is present
 
 var services = new ServiceCollection();