AMessanger-Server/AMessanger.DataAccess/Repositories/UsersRepository.cs

using AMessanger.Core;
using AMessanger.Core.Abstraction;
using AMessanger.Core.DTO;
using AMessanger.Core.Models;
using AMessanger.DataAccess.Entities;

namespace AMessanger.DataAccess.Repositories;

public class UsersRepository : IUsersRepository
{
    private static readonly List<UserEntity> sUsers = [];

    public Task<Result<Guid>> AddAsync(User user, CancellationToken cancellationToken = default)
    {
        sUsers.Add(new(user.Id, user.Name, user.HashedPassword));

        return Task.FromResult(Result<Guid>.Success(user.Id));
    }

    public Task<Result<Guid>> DeleteAsync(Guid id, CancellationToken cancellationToken = default)
    {
        var user = sUsers.Find(u => u.Id == id);
        if (user == null)
            return Task.FromResult(Result<Guid>.Error("Not found"));
        
        sUsers.Remove(user);
        return Task.FromResult(Result<Guid>.Success(user.Id));
    }

    public Task<Result<IEnumerable<User>>> GetAllAsync(CancellationToken cancellationToken = default)
    {
        return Task.FromResult(
            Result<IEnumerable<User>>.Success(
                sUsers.Select(u => new User(u.Id, u.Name, u.HashedPassword))
            )
        );
    }

    public Task<Result<User>> GetByIdAsync(Guid id, CancellationToken cancellationToken = default)
    {
        var user = sUsers.Find(u => u.Id == id);
        if (user == null)
            return Task.FromResult(Result<User>.Error("Not found"));

        return Task.FromResult(
            Result<User>.Success(new User(user.Id, user.Name, user.HashedPassword))
        );
    }

    public Task<Result<User>> GetByUserNameAsync(string userName, CancellationToken cancellationToken = default)
    {
        var user = sUsers.Find(u => u.Name.Equals(userName, StringComparison.InvariantCultureIgnoreCase));
        if (user == null)
            return Task.FromResult(Result<User>.Error("Not found"));

        return Task.FromResult(
            Result<User>.Success(new User(user.Id, user.Name, user.HashedPassword))
        );
    }

    public Task<Result<User>> UpdateAsync(Guid id, UpdateUserDto dto, CancellationToken cancellationToken = default)
    {
        throw new NotImplementedException();
    }
}