86 lines
2.4 KiB
C#
86 lines
2.4 KiB
C#
using Femto.Common.Domain;
|
|
using Femto.Modules.Auth.Application.Dto;
|
|
using Femto.Modules.Auth.Data;
|
|
using Femto.Modules.Auth.Infrastructure;
|
|
using Femto.Modules.Auth.Models;
|
|
using Microsoft.EntityFrameworkCore;
|
|
|
|
namespace Femto.Modules.Auth.Application.Services;
|
|
|
|
internal class AuthService(AuthContext context, SessionStorage storage) : IAuthService
|
|
{
|
|
public async Task<UserInfo?> GetUserWithCredentials(
|
|
string username,
|
|
string password,
|
|
CancellationToken cancellationToken = default
|
|
)
|
|
{
|
|
var user = await context
|
|
.Users.Where(u => u.Username == username)
|
|
.SingleOrDefaultAsync(cancellationToken);
|
|
|
|
if (user is null)
|
|
return null;
|
|
|
|
if (!user.HasPassword(password))
|
|
return null;
|
|
|
|
return new UserInfo(user.Id, user.Username, user.Roles.Select(r => r.Role).ToList());
|
|
}
|
|
|
|
public Task<UserInfo?> GetUserWithId(Guid? userId, CancellationToken cancellationToken)
|
|
{
|
|
return context
|
|
.Users.Where(u => u.Id == userId)
|
|
.Select(u => new UserInfo(u.Id, u.Username, u.Roles.Select(r => r.Role).ToList()))
|
|
.SingleOrDefaultAsync(cancellationToken);
|
|
}
|
|
|
|
public async Task<Session> CreateStrongSession(Guid userId)
|
|
{
|
|
var session = new Session(userId, true);
|
|
|
|
await storage.AddSession(session);
|
|
|
|
return session;
|
|
}
|
|
|
|
public async Task<Session> CreateWeakSession(Guid userId)
|
|
{
|
|
var session = new Session(userId, false);
|
|
|
|
await storage.AddSession(session);
|
|
|
|
return session;
|
|
}
|
|
|
|
public Task<Session?> GetSession(string sessionId)
|
|
{
|
|
return storage.GetSession(sessionId);
|
|
}
|
|
|
|
public async Task DeleteSession(string sessionId)
|
|
{
|
|
await storage.DeleteSession(sessionId);
|
|
}
|
|
|
|
public async Task<LongTermSession> CreateLongTermSession(Guid userId, bool isStrong)
|
|
{
|
|
throw new NotImplementedException();
|
|
}
|
|
|
|
public async Task<LongTermSession> DeleteLongTermSession(string sessionId)
|
|
{
|
|
throw new NotImplementedException();
|
|
}
|
|
|
|
public async Task<LongTermSession> RefreshLongTermSession(string sessionId)
|
|
{
|
|
throw new NotImplementedException();
|
|
}
|
|
|
|
public async Task<ValidateSessionResult> ValidateLongTermSession(string sessionId)
|
|
{
|
|
throw new NotImplementedException();
|
|
}
|
|
}
|