@@ -17,8 +17,8 @@ public class QuitSessionCommandHandler : IRequestHandler<QuitSessionRequest>
1717 private readonly IClientsGroupsService _clientsGroupsService ;
1818 private readonly IInvokeClientsService _invokeClientsService ;
1919
20- public QuitSessionCommandHandler ( ICloudSessionsRepository cloudSessionsRepository , IInventoryRepository inventoryRepository ,
21- ISynchronizationRepository synchronizationRepository , ICacheService cacheService , ISessionMemberMapper sessionMemberMapper ,
20+ public QuitSessionCommandHandler ( ICloudSessionsRepository cloudSessionsRepository , IInventoryRepository inventoryRepository ,
21+ ISynchronizationRepository synchronizationRepository , ICacheService cacheService , ISessionMemberMapper sessionMemberMapper ,
2222 IClientsGroupsService clientsGroupsService , IInvokeClientsService invokeClientsService )
2323 {
2424 _cloudSessionsRepository = cloudSessionsRepository ;
@@ -29,22 +29,22 @@ public QuitSessionCommandHandler(ICloudSessionsRepository cloudSessionsRepositor
2929 _clientsGroupsService = clientsGroupsService ;
3030 _invokeClientsService = invokeClientsService ;
3131 }
32-
32+
3333 public async Task Handle ( QuitSessionRequest request , CancellationToken cancellationToken )
3434 {
3535 CloudSessionData ? innerCloudSessionData = null ;
3636 SessionMemberData ? innerQuitter = null ;
3737
3838 var transaction = _cacheService . OpenTransaction ( ) ;
39-
39+
4040 var updateSessionResult = await _cloudSessionsRepository . Update ( request . SessionId , cloudSessionData =>
4141 {
4242 var quitter = cloudSessionData . SessionMembers . FirstOrDefault ( m => m . ClientInstanceId . Equals ( request . ClientInstanceId ) ) ;
43-
43+
4444 if ( quitter != null )
4545 {
4646 cloudSessionData . SessionMembers . Remove ( quitter ) ;
47-
47+
4848 if ( cloudSessionData . SessionMembers . Count == 0 )
4949 {
5050 cloudSessionData . IsSessionRemoved = true ;
@@ -66,13 +66,13 @@ await _inventoryRepository.UpdateIfExists(request.SessionId, inventoryData =>
6666 {
6767 inventoryData . InventoryMembers . Remove ( inventoryMember ) ;
6868 }
69-
69+
7070 inventoryData . RecodePathItems ( innerCloudSessionData ! ) ;
7171
7272 return true ;
7373 } , transaction ) ;
7474 }
75-
75+
7676 if ( updateSessionResult . IsWaitingForTransaction )
7777 {
7878 await _synchronizationRepository . UpdateIfExists ( request . SessionId , synchronizationData =>
@@ -93,11 +93,11 @@ await _synchronizationRepository.UpdateIfExists(request.SessionId, synchronizati
9393 if ( updateSessionResult . IsWaitingForTransaction )
9494 {
9595 await _clientsGroupsService . RemoveSessionSubscription ( request . Client , request . SessionId , transaction ) ;
96-
96+
9797 await transaction . ExecuteAsync ( ) ;
98-
98+
9999 await _clientsGroupsService . RemoveFromSessionGroup ( request . Client , request . SessionId ) ;
100-
100+
101101 var sessionMemberInfo = await _sessionMemberMapper . Convert ( innerQuitter ! ) ;
102102 await _invokeClientsService . SessionGroup ( request . SessionId ) . MemberQuittedSession ( sessionMemberInfo ) ;
103103 }
0 commit comments