UserSession namespace was changed

Govor.Application/Interfaces/UserSession/IUserSessionReader.cs

@@ -2,5 +2,5 @@ namespace Govor.Application.Interfaces.UserSession;
 
 public interface IUserSessionReader
 {
-    Task<List<Core.Models.UserSession>> GetAllSessionsAsync(Guid userId);
+    Task<List<Core.Models.Users.UserSession>> GetAllSessionsAsync(Guid userId);
 }

Govor.Application/Services/UserSessions/UserSessionOpener.cs

@@ -7,83 +7,84 @@ using Govor.Data.Repositories.Exceptions;
 using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Options;
 
-namespace Govor.Application.Services.UserSessions;
-
-public class UserSessionOpener : IUserSessionOpener
+namespace Govor.Application.Services.UserSessions
 {
-    private readonly IUserSessionsRepository _repository;
-    private readonly ILogger<UserSessionOpener> _logger;
-    private readonly JwtRefreshOption _options;
-    private readonly IJwtService _jwtService;
-
-    public UserSessionOpener(
-        IUserSessionsRepository repository,
-        IJwtService jwtService,
-        IOptions<JwtRefreshOption> options,
-        ILogger<UserSessionOpener> logger)
+    public class UserSessionOpener : IUserSessionOpener
     {
-        _jwtService = jwtService;
-        _repository = repository;
-        _logger = logger;
-        _options = options.Value;
-    }
+        private readonly IUserSessionsRepository _repository;
+        private readonly ILogger<UserSessionOpener> _logger;
+        private readonly JwtRefreshOption _options;
+        private readonly IJwtService _jwtService;
 
-    public async Task<RefreshResult> OpenSessionAsync(User user, string deviceInfo)
-    {
-        _logger.LogInformation($"Opening session for user {user.Id} on device '{deviceInfo}'");
-
-        try
+        public UserSessionOpener(
+            IUserSessionsRepository repository,
+            IJwtService jwtService,
+            IOptions<JwtRefreshOption> options,
+            ILogger<UserSessionOpener> logger)
         {
-            var sessions = await _repository.GetByUserIdAsync(user.Id);
-            var session = sessions.FirstOrDefault(s => s.DeviceInfo == deviceInfo);
+            _jwtService = jwtService;
+            _repository = repository;
+            _logger = logger;
+            _options = options.Value;
+        }
 
-            var newRefreshToken = await _jwtService.GenerateRefreshTokenAsync(user);
-            var accessToken = await _jwtService.GenerateAccessTokenAsync(user);
-            
-            var newExpiresAt = DateTime.UtcNow.AddDays(_options.RefreshTokenLifetimeDays);
+        public async Task<RefreshResult> OpenSessionAsync(User user, string deviceInfo)
+        {
+            _logger.LogInformation($"Opening session for user {user.Id} on device '{deviceInfo}'");
 
-            if (session is not null)
+            try
             {
-                // Всегда обновляем токен и дату
-                session.RefreshToken = newRefreshToken;
-                session.ExpiresAt = newExpiresAt;
-                session.CreatedAt = DateTime.UtcNow;
-                session.IsRevoked = false;
+                var sessions = await _repository.GetByUserIdAsync(user.Id);
+                var session = sessions.FirstOrDefault(s => s.DeviceInfo == deviceInfo);
 
-                await _repository.UpdateAsync(session);
-                _logger.LogInformation($"Updated session for user {user.Id} on device '{deviceInfo}'");
+                var newRefreshToken = await _jwtService.GenerateRefreshTokenAsync(user);
+                var accessToken = await _jwtService.GenerateAccessTokenAsync(user);
+            
+                var newExpiresAt = DateTime.UtcNow.AddDays(_options.RefreshTokenLifetimeDays);
 
-                return new RefreshResult(session.RefreshToken, accessToken);
+                if (session is not null)
+                {
+                    // Всегда обновляем токен и дату
+                    session.RefreshToken = newRefreshToken;
+                    session.ExpiresAt = newExpiresAt;
+                    session.CreatedAt = DateTime.UtcNow;
+                    session.IsRevoked = false;
+
+                    await _repository.UpdateAsync(session);
+                    _logger.LogInformation($"Updated session for user {user.Id} on device '{deviceInfo}'");
+
+                    return new RefreshResult(session.RefreshToken, accessToken);
+                }
+            
+                return await OpenNewSession();
             }
-            
-            return await OpenNewSession();
-        }
-        catch (NotFoundByKeyException<Guid> ex)
-        {
-            return await OpenNewSession();
-        }
-        
-        async Task<RefreshResult> OpenNewSession()
-        {
-            var newRefreshToken = await _jwtService.GenerateRefreshTokenAsync(user);
-            var accessToken = await _jwtService.GenerateAccessTokenAsync(user);
-            
-            var newSession = new Core.Models.UserSession
+            catch (NotFoundByKeyException<Guid> ex)
             {
-                UserId = user.Id,
-                DeviceInfo = deviceInfo,
-                RefreshToken = newRefreshToken,
-                CreatedAt = DateTime.UtcNow,
-                ExpiresAt = DateTime.UtcNow.AddDays(_options.RefreshTokenLifetimeDays),
-                IsRevoked = false
-            };
-
-            await _repository.AddAsync(newSession);
+                return await OpenNewSession();
+            }
+        
+            async Task<RefreshResult> OpenNewSession()
+            {
+                var newRefreshToken = await _jwtService.GenerateRefreshTokenAsync(user);
+                var accessToken = await _jwtService.GenerateAccessTokenAsync(user);
             
-            _logger.LogInformation($"Created new session for user {user.Id} on device '{deviceInfo}'");
+                var newSession = new UserSession
+                {
+                    UserId = user.Id,
+                    DeviceInfo = deviceInfo,
+                    RefreshToken = newRefreshToken,
+                    CreatedAt = DateTime.UtcNow,
+                    ExpiresAt = DateTime.UtcNow.AddDays(_options.RefreshTokenLifetimeDays),
+                    IsRevoked = false
+                };
 
-            return new RefreshResult(newRefreshToken, accessToken);
+                await _repository.AddAsync(newSession);
+            
+                _logger.LogInformation($"Created new session for user {user.Id} on device '{deviceInfo}'");
+
+                return new RefreshResult(newRefreshToken, accessToken);
+            }
         }
     }
 }
-    
+

Govor.Application/Services/UserSessions/UserSessionReader.cs

@@ -1,5 +1,4 @@
 using Govor.Application.Interfaces.UserSession;
-using Govor.Core.Models;
 using Govor.Core.Repositories.UserSessionsRepository;
 using Govor.Data.Repositories.Exceptions;
 using Microsoft.Extensions.Logging;
@@ -17,7 +16,7 @@ public class UserSessionReader : IUserSessionReader
         _logger = logger;
     }
     
-    public async Task<List<UserSession>> GetAllSessionsAsync(Guid userId)
+    public async Task<List<Govor.Core.Models.Users.UserSession>> GetAllSessionsAsync(Guid userId)
     {
         try
         {

Govor.Application/Services/UserSessions/UserSessionRefresher.cs

@@ -1,7 +1,7 @@
 using Govor.Application.Interfaces.Authentication;
 using Govor.Application.Interfaces.UserSession;
 using Govor.Application.Services.Authentication;
-using Govor.Core.Models;
+using Govor.Core.Models.Users;
 using Govor.Core.Repositories.Users;
 using Govor.Core.Repositories.UserSessionsRepository;
 using Govor.Data.Repositories.Exceptions;