UserSessionRevoker

Govor.Application/Services/UserSessions/UserSessionReader.cs

@@ -23,11 +23,12 @@ public class UserSessionReader : IUserSessionReader
         {
             _logger.LogInformation($"Getting all sessions for user {userId}");
             var sessions = await _repository.GetByUserIdAsync(userId);
-            return sessions;
+            
+            return sessions.Where(f => !f.IsRevoked).ToList() ?? [];
         }
         catch (NotFoundByKeyException<Guid> ex)
         {
-            _logger.LogWarning("The user has no active sessions.");
+            _logger.LogWarning("The user has no sessions.");
             return [];
         }
     }

Govor.Application/Services/UserSessions/UserSessionRevoker.cs

@@ -0,0 +1,63 @@
+using Govor.Application.Interfaces.UserSession;
+using Govor.Core.Repositories.UserSessionsRepository;
+using Govor.Data.Repositories.Exceptions;
+using Microsoft.Extensions.Logging;
+
+namespace Govor.Application.Services.UserSessions;
+
+public class UserSessionRevoker : IUserSessionRevoker
+{
+    private readonly IUserSessionsRepository _sessionsRepository;
+    private readonly ILogger<UserSessionRevoker> _logger;
+
+    public UserSessionRevoker(IUserSessionsRepository sessionsRepository, ILogger<UserSessionRevoker> logger)
+    {
+        _sessionsRepository = sessionsRepository;
+        _logger = logger;
+    }
+
+    public async Task CloseSessionByIdAsync(Guid sessionId, Guid userId)
+    {
+        try
+        {
+            var session = await _sessionsRepository.GetByIdAsync(sessionId);
+
+            if (session.UserId != userId)
+            {
+                _logger.LogWarning("User {userId} does not belong to this session {sessionId}", userId, sessionId);
+                throw new UnauthorizedAccessException($"User {userId} does not belong to this session {sessionId}");
+            }
+            
+            if(session.IsRevoked) return;
+            
+            session.IsRevoked = true;
+            await _sessionsRepository.UpdateAsync(session);
+        }
+        catch (NotFoundByKeyException<Guid> ex)
+        {
+            _logger.LogWarning("User {userId} tried close unreal session!", userId);
+            throw new NotFoundException("Session not found", ex);
+        }
+    }
+
+    public async Task CloseAllSessionsAsync(Guid userId)
+    {
+        try
+        {
+            var sessions = await _sessionsRepository.GetByUserIdAsync(userId);
+
+            foreach (var session in sessions)
+            {
+                if(session.IsRevoked) continue;
+                
+                session.IsRevoked = true;
+                await _sessionsRepository.UpdateAsync(session);
+            }
+        }
+        catch (NotFoundByKeyException<Guid> ex)
+        {
+            _logger.LogWarning("User {userId} has not sessions", userId);
+            throw new NotFoundException("Session not found", ex);
+        }
+    }
+}