mirror of
https://github.com/ryzij/AMessanger-Server.git
synced 2026-09-18 19:25:38 +00:00
Add AMessanger.DataAccess
This commit is contained in:
@@ -8,6 +8,7 @@
|
||||
|
||||
<ItemGroup>
|
||||
<ProjectReference Include="../AMessanger.Core/AMessanger.Core.csproj" />
|
||||
<ProjectReference Include="../AMessanger.DataAccess/AMessanger.DataAccess.csproj" />
|
||||
</ItemGroup>
|
||||
|
||||
<ItemGroup>
|
||||
|
||||
@@ -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>
|
||||
@@ -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;
|
||||
}
|
||||
@@ -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();
|
||||
}
|
||||
}
|
||||
@@ -6,4 +6,5 @@
|
||||
<ItemGroup>
|
||||
<PackageReference Include="Microsoft.AspNetCore.SignalR" />
|
||||
</ItemGroup>
|
||||
<Project Path="AMessanger.DataAccess/AMessanger.DataAccess.csproj" />
|
||||
</Solution>
|
||||
|
||||
Reference in New Issue
Block a user