11// Copyright (C) Ubiquitous AS. All rights reserved
22// Licensed under the Apache License, Version 2.0.
33
4- using Eventuous . Tools ;
5- using static Eventuous . Diagnostics . ApplicationEventSource ;
6-
7- // ReSharper disable MemberCanBePrivate.Global
8-
94namespace Eventuous ;
105
6+ using Tools ;
7+ using static Diagnostics . ApplicationEventSource ;
8+
119/// <summary>
12- /// Application service base class. A derived class should be scoped to handle commands for one aggregate type only.
10+ /// Command service base class. A derived class should be scoped to handle commands for one aggregate type only.
1311/// </summary>
1412/// <typeparam name="TAggregate">The aggregate type</typeparam>
1513/// <typeparam name="TState">The aggregate state type</typeparam>
1614/// <typeparam name="TId">The aggregate identity type</typeparam>
1715// [PublicAPI]
18- public abstract class ApplicationService < TAggregate , TState , TId >
19- : IApplicationService < TAggregate , TState , TId > , IApplicationService < TAggregate >
16+ public abstract class CommandService < TAggregate , TState , TId >
17+ : ICommandService < TAggregate , TState , TId > , ICommandService < TAggregate >
2018 where TAggregate : Aggregate < TState > , new ( )
2119 where TState : State < TState > , new ( )
2220 where TId : AggregateId {
21+ [ PublicAPI ]
2322 protected IAggregateStore Store { get ; }
2423
2524 readonly HandlersMap < TAggregate > _handlers = new ( ) ;
@@ -28,7 +27,7 @@ public abstract class ApplicationService<TAggregate, TState, TId>
2827 readonly StreamNameMap _streamNameMap ;
2928 readonly TypeMapper _typeMap ;
3029
31- protected ApplicationService (
30+ protected CommandService (
3231 IAggregateStore store ,
3332 AggregateFactoryRegistry ? factoryRegistry = null ,
3433 StreamNameMap ? streamNameMap = null ,
@@ -196,19 +195,17 @@ protected void OnAsync<TCommand>(ArbitraryActAsync<TCommand> action)
196195 /// <exception cref="Exceptions.CommandHandlerNotFound{TCommand}"></exception>
197196 public async Task < Result < TState > > Handle < TCommand > ( TCommand command , CancellationToken cancellationToken )
198197 where TCommand : class {
199- var commandType = Ensure . NotNull ( command ) . GetType ( ) ;
200-
201- if ( ! _handlers . TryGetValue ( commandType , out var registeredHandler ) ) {
202- Log . CommandHandlerNotFound ( commandType ) ;
203- var exception = new Exceptions . CommandHandlerNotFound ( commandType ) ;
198+ if ( ! _handlers . TryGet < TCommand > ( out var registeredHandler ) ) {
199+ Log . CommandHandlerNotFound < TCommand > ( ) ;
200+ var exception = new Exceptions . CommandHandlerNotFound < TCommand > ( ) ;
204201 return new ErrorResult < TState > ( exception ) ;
205202 }
206203
207- var hasGetIdFunction = _idMap . TryGetValue ( commandType , out var getId ) ;
204+ var hasGetIdFunction = _idMap . TryGet < TCommand > ( out var getId ) ;
208205
209206 if ( ! hasGetIdFunction || getId == null ) {
210- Log . CannotCalculateAggregateId ( commandType ) ;
211- var exception = new Exceptions . CommandHandlerNotFound ( commandType ) ;
207+ Log . CannotCalculateAggregateId < TCommand > ( ) ;
208+ var exception = new Exceptions . CommandHandlerNotFound < TCommand > ( ) ;
212209 return new ErrorResult < TState > ( exception ) ;
213210 }
214211
@@ -238,37 +235,41 @@ public async Task<Result<TState>> Handle<TCommand>(TCommand command, Cancellatio
238235 if ( result . Changes . Count == 0 ) return new OkResult < TState > ( result . State , Array . Empty < Change > ( ) , 0 ) ;
239236
240237 var storeResult = await Store . Store (
241- streamName != default ? streamName : GetAggregateStreamName ( ) ,
238+ streamName != default
239+ ? streamName
240+ : GetAggregateStreamName ( ) ,
242241 result ,
243242 cancellationToken
244243 )
245244 . NoContext ( ) ;
246245
247246 var changes = result . Changes . Select ( x => new Change ( x , _typeMap . GetTypeName ( x ) ) ) ;
248247
249- Log . CommandHandled ( commandType ) ;
248+ Log . CommandHandled < TCommand > ( ) ;
250249
251250 return new OkResult < TState > ( result . State , changes , storeResult . GlobalPosition ) ;
252251 }
253252 catch ( Exception e ) {
254- Log . ErrorHandlingCommand ( commandType , e ) ;
253+ Log . ErrorHandlingCommand < TCommand > ( e ) ;
255254
256- return new ErrorResult < TState > ( $ "Error handling command { commandType . Name } ", e ) ;
255+ return new ErrorResult < TState > ( $ "Error handling command { typeof ( TCommand ) . Name } ", e ) ;
257256 }
258257
259- TAggregate Create ( ) => _factoryRegistry . CreateInstance < TAggregate , TState > ( ) ;
258+ TAggregate Create ( )
259+ => _factoryRegistry . CreateInstance < TAggregate , TState > ( ) ;
260260
261- StreamName GetAggregateStreamName ( ) => _streamNameMap . GetStreamName < TAggregate , TId > ( aggregateId ) ;
261+ StreamName GetAggregateStreamName ( )
262+ => _streamNameMap . GetStreamName < TAggregate , TId > ( aggregateId ) ;
262263 }
263264
264- async Task < Result > IApplicationService . Handle < TCommand > ( TCommand command , CancellationToken cancellationToken )
265+ async Task < Result > ICommandService . Handle < TCommand > ( TCommand command , CancellationToken cancellationToken )
265266 where TCommand : class {
266267 var result = await Handle ( command , cancellationToken ) . NoContext ( ) ;
267268
268269 return result switch {
269- OkResult < TState > ( var aggregateState , var enumerable , _ ) => new OkResult ( aggregateState , enumerable ) ,
270- ErrorResult < TState > error => new ErrorResult ( error . Message , error . Exception ) ,
271- _ => throw new ApplicationException ( "Unknown result type" )
270+ OkResult < TState > ( var state , var enumerable , _ ) => new OkResult ( state , enumerable ) ,
271+ ErrorResult < TState > error => new ErrorResult ( error . Message , error . Exception ) ,
272+ _ => throw new ApplicationException ( "Unknown result type" )
272273 } ;
273274 }
274275
0 commit comments