Add AMessanger.DataAccess

AMessanger.Application/AMessanger.Application.csproj

@@ -8,6 +8,7 @@
 
   <ItemGroup>
     <ProjectReference Include="../AMessanger.Core/AMessanger.Core.csproj" />
+    <ProjectReference Include="../AMessanger.DataAccess/AMessanger.DataAccess.csproj" />
   </ItemGroup>
 
   <ItemGroup>

AMessanger.Core/Abstraction/IAccountService.cs

@@ -0,0 +1,11 @@
+using AMessanger.Core.DTO;
+using AMessanger.Core.Models;
+
+namespace AMessanger.Core.Abstraction;
+
+public interface IAccountService
+{
+    public Task<Result<Guid>> RegisterAsync(CreateUserDto dto, CancellationToken cancellationToken = default);
+
+    public Task<Result<string>> LoginAsync(string userName, string password, CancellationToken cancellationToken = default);
+}

AMessanger.Core/Abstraction/IUserService.cs

@@ -0,0 +1,19 @@
+using AMessanger.Core.DTO;
+using AMessanger.Core.Models;
+
+namespace AMessanger.Core.Abstraction;
+
+public interface IUserService
+{
+    public Task<Result<User>> CreateAsync(CreateUserDto dto, CancellationToken cancellationToken = default);
+
+    public Task<Result<User>> GetByIdAsync(Guid id, CancellationToken cancellationToken = default);
+
+    public Task<Result<User>> GetByUserNameAsync(string userName, CancellationToken cancellationToken = default);
+
+    public Task<Result<IEnumerable<User>>> GetAllAsync(CancellationToken cancellationToken = default);
+
+    public Task<Result<User>> UpdateAsync(Guid id, UpdateUserDto dto, CancellationToken cancellationToken = default);
+
+    public Task<Result<Guid>> DeleteAsync(Guid id, CancellationToken cancellationToken = default);
+}

AMessanger.Core/Abstraction/IUsersRepository.cs

@@ -0,0 +1,19 @@
+using AMessanger.Core.Models;
+using AMessanger.Core.DTO;
+
+namespace AMessanger.Core.Abstraction;
+
+public interface IUsersRepository
+{
+    public Task<Result<Guid>> AddAsync(User user, CancellationToken cancellationToken = default);
+
+    public Task<Result<User>> GetByIdAsync(Guid id, CancellationToken cancellationToken = default);
+
+    public Task<Result<User>> GetByUserNameAsync(string userName, CancellationToken cancellationToken = default);
+
+    public Task<Result<IEnumerable<User>>> GetAllAsync(CancellationToken cancellationToken = default);
+
+    public Task<Result<User>> UpdateAsync(Guid id, UpdateUserDto dto, CancellationToken cancellationToken = default);
+
+    public Task<Result<Guid>> DeleteAsync(Guid id, CancellationToken cancellationToken = default);
+}

AMessanger.Core/DTO/CreateUserDto.cs

@@ -0,0 +1,6 @@
+namespace AMessanger.Core.DTO;
+
+public record class CreateUserDto(
+    string Name,
+    string Password
+);

AMessanger.Core/DTO/UpdateUserDto.cs

@@ -0,0 +1,6 @@
+namespace AMessanger.Core.DTO;
+
+public record class UpdateUserDto(
+    string? Name,
+    string? Password
+);

AMessanger.Core/Result.cs

@@ -0,0 +1,21 @@
+namespace AMessanger.Core;
+
+public class Result<T>
+{
+    public T? Value { get; }
+
+    public string? ErrorMessage { get; }
+
+    public bool IsSuccess { get; }
+
+    private Result(T? value, bool isSuccess, string? message)
+    {
+        Value = value;
+        IsSuccess = isSuccess;
+        ErrorMessage = message;
+    }
+
+    public static Result<T> Error(string message) => new(default, false, message);
+
+    public static Result<T> Success(T value) => new(value, true, null);
+}

AMessanger.DataAccess/AMessanger.DataAccess.csproj

@@ -0,0 +1,13 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>net10.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="../AMessanger.Core/AMessanger.Core.csproj" />
+  </ItemGroup>
+
+</Project>

AMessanger.DataAccess/Entities/UserEntity.cs

@@ -0,0 +1,8 @@
+namespace AMessanger.DataAccess.Entities;
+
+public class UserEntity(Guid id, string name, string hashedPassword)
+{
+    public Guid Id { get; set; } = id;
+    public string Name { get; set; } = name;
+    public string HashedPassword { get; set; } = hashedPassword;
+}

AMessanger.DataAccess/Repositories/UsersRepository.cs

@@ -0,0 +1,65 @@
+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();
+    }
+}

AMessanger.slnx

@@ -6,4 +6,5 @@
   <ItemGroup>
     <PackageReference Include="Microsoft.AspNetCore.SignalR" />
   </ItemGroup>
+  <Project Path="AMessanger.DataAccess/AMessanger.DataAccess.csproj" />
 </Solution>