- Checkpoint: Event Transformation for View Model

Author: NinjaRocks

src/SourceFlow.ConsoleApp/Impl/InMemoryDomianRepository.cs

@@ -6,7 +6,7 @@ public class InMemoryDomianRepository : IDomainRepository
     {
         private readonly ConcurrentDictionary<int, IEntity> _cache = new();
 
-        public Task DeleteAsync<TEntity>(TEntity entity) where TEntity : IEntity
+        public Task Delete<TEntity>(TEntity entity) where TEntity : IEntity
         {
             if (entity?.Id == null)
                 throw new ArgumentNullException(nameof(entity));
@@ -16,7 +16,7 @@ public Task DeleteAsync<TEntity>(TEntity entity) where TEntity : IEntity
             return Task.CompletedTask;
         }
 
-        public Task<TEntity> GetByIdAsync<TEntity>(int id) where TEntity : class, IEntity
+        public Task<TEntity> Get<TEntity>(int id) where TEntity : class, IEntity
         {
             if (id == 0)
                 throw new ArgumentNullException(nameof(id));
@@ -26,7 +26,7 @@ public Task<TEntity> GetByIdAsync<TEntity>(int id) where TEntity : class, IEntit
             return Task.FromResult<TEntity>(success ? (TEntity)entity : null);
         }
 
-        public Task PersistAsync<TEntity>(TEntity entity) where TEntity : IEntity
+        public Task Persist<TEntity>(TEntity entity) where TEntity : IEntity
         {
             if (entity?.Id == null)
                 throw new ArgumentNullException(nameof(entity));

src/SourceFlow.ConsoleApp/Impl/InMemoryEventStore.cs

@@ -6,7 +6,7 @@ public class InMemoryEventStore : IEventStore
     {
         private readonly ConcurrentDictionary<int, List<IEvent>> _store = new();
 
-        public Task AppendAsync(IEvent @event)
+        public Task Append(IEvent @event)
         {
             if (!_store.ContainsKey(@event.Entity.Id))
                 _store[@event.Entity.Id] = new List<IEvent>();
@@ -16,7 +16,7 @@ public Task AppendAsync(IEvent @event)
             return Task.CompletedTask;
         }
 
-        public async Task<IEnumerable<IEvent>> LoadAsync(int aggregateId)
+        public async Task<IEnumerable<IEvent>> Load(int aggregateId)
         {
             return await Task.FromResult(_store.TryGetValue(aggregateId, out var events)
                ? events

src/SourceFlow.ConsoleApp/Impl/InMemoryViewModelRepository.cs

@@ -6,7 +6,7 @@ public class InMemoryViewRepository : IViewModelRepository
     {
         private readonly ConcurrentDictionary<int, IViewModel> _cache = new();
 
-        public Task DeleteAsync<TViewModel>(TViewModel model) where TViewModel : IViewModel
+        public Task Delete<TViewModel>(TViewModel model) where TViewModel : IViewModel
         {
             if (model?.Id == null)
                 throw new ArgumentNullException(nameof(model));
@@ -16,7 +16,7 @@ public Task DeleteAsync<TViewModel>(TViewModel model) where TViewModel : IViewMo
             return Task.CompletedTask;
         }
 
-        public Task<TViewModel> GetByIdAsync<TViewModel>(int id) where TViewModel : class, IViewModel
+        public Task<TViewModel> Get<TViewModel>(int id) where TViewModel : class, IViewModel
         {
             if (id == 0)
                 throw new ArgumentNullException(nameof(id));
@@ -26,7 +26,7 @@ public Task<TViewModel> GetByIdAsync<TViewModel>(int id) where TViewModel : clas
             return Task.FromResult<TViewModel>(success ? (TViewModel)model : null);
         }
 
-        public Task PersistAsync<TViewModel>(TViewModel model) where TViewModel : IViewModel
+        public Task Persist<TViewModel>(TViewModel model) where TViewModel : IViewModel
         {
             if (model?.Id == null)
                 throw new ArgumentNullException(nameof(model));

src/SourceFlow.ConsoleApp/Impl/InMemoryViewRepository.cs

@@ -1,8 +1,8 @@
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Logging;
 using SourceFlow;
-using SourceFlow.ConsoleApp.Projections;
-using SourceFlow.ConsoleApp.Services; // Ensure this using is present
+using SourceFlow.ConsoleApp.Services;
+using SourceFlow.ConsoleApp.ViewModels; // Ensure this using is present
 
 var services = new ServiceCollection();
 

src/SourceFlow.ConsoleApp/Program.cs

@@ -10,7 +10,7 @@ public class AccountSaga : BaseSaga<BankAccount>,
                                IEventHandler<MoneyWithdrawn>,
                                IEventHandler<AccountClosed>
     {
-        public async Task HandleAsync(AccountCreated @event)
+        public async Task Handle(AccountCreated @event)
         {
             logger.LogInformation("Action=Account_Created, Account={AccountId}, Holder={AccountName}, Initial_Balance={InitialBalance}",
                 @event.Entity.Id, @event.Payload.AccountName, @event.Payload.InitialAmount);
@@ -31,7 +31,7 @@ public async Task HandleAsync(AccountCreated @event)
             await PersistAggregate(account);
         }
 
-        public async Task HandleAsync(MoneyDeposited @event)
+        public async Task Handle(MoneyDeposited @event)
         {
             logger.LogInformation("Action=Money_Deposited, Amount={Amount}, Account={AccountId}", @event.Payload.Amount, @event.Entity.Id);
 
@@ -49,7 +49,7 @@ public async Task HandleAsync(MoneyDeposited @event)
             await PersistAggregate(account);
         }
 
-        public async Task HandleAsync(MoneyWithdrawn @event)
+        public async Task Handle(MoneyWithdrawn @event)
         {
             logger.LogInformation("Action=Money_Withdrawn, Amount={Amount}, Account={AccountId}", @event.Payload.Amount, @event.Entity.Id);
 
@@ -67,7 +67,7 @@ public async Task HandleAsync(MoneyWithdrawn @event)
             await PersistAggregate(account);
         }
 
-        public async Task HandleAsync(AccountClosed @event)
+        public async Task Handle(AccountClosed @event)
         {
             logger.LogInformation("Action=Account_Closed, Account={AccountId}, Reason={Reason}", @event.Entity.Id, @event.Payload.ClosureReason);
 

src/SourceFlow.ConsoleApp/Projections/AccountSummaryProjectionHandler.cs

@@ -1,4 +1,4 @@
-using SourceFlow.ConsoleApp.Projections;
+using SourceFlow.ConsoleApp.ViewModels;
 
 namespace SourceFlow.ConsoleApp.Services
 {

src/SourceFlow.ConsoleApp/Projections/AccountView.cs

@@ -1,4 +1,4 @@
-namespace SourceFlow.ConsoleApp.Projections
+namespace SourceFlow.ConsoleApp.ViewModels
 {
     public class AccountViewModel : IViewModel
     {