Move

2026-03-21 20:33:15 +01:00
parent 8306211f49
commit 2ed2974ab4
39 changed files with 92 additions and 88 deletions
@@ -0,0 +1,53 @@
+using Ardalis.Result;
+using DispatchR.Abstractions.Send;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.Extensions.Logging;
+using Musify.Application.Contracts.Infrastructure;
+using Musify.Application.Users.Commands;
+using Musify.Application.Users.Responses;
+using Musify.Domain.Entities;
+
+namespace Musify.Application.Users.Handlers
+{
+    public class CreateUserCommandHandler(IDatabase database, IKeycloakUserService keycloakUserClient, ILogger<CreateUserCommandHandler> logger)
+        : IRequestHandler<CreateUserCommand, Task<Result<UserResponse> >>
+    {
+        public async Task<Result<UserResponse>> Handle(CreateUserCommand request, CancellationToken cancellationToken)
+        {
+            logger.LogDebug("Handling {CommandName} with Id: {UserId}", nameof(CreateUserCommand), request.Id);
+
+            var existingUser = await database.Users.SingleOrDefaultAsync(u => u.Id == request.Id, cancellationToken);
+
+            if (existingUser is not null)
+            {
+                logger.LogInformation("User with Id={UserId} already exists.", request.Id);
+                return Result<UserResponse>.Conflict($"A user with Id {request.Id} already exists.");
+            }
+
+            var keycloakUser = await keycloakUserClient.GetUserByIdAsync(request.Id.ToString(), cancellationToken);
+
+            if (!keycloakUser.IsSuccess)
+            {
+                logger.LogWarning("Keycloak user with Id={UserId} was not found.", request.Id);
+                return Result.NotFound("Keycloak user not found.");
+            }
+
+            var newUser = new User
+            {
+                Id = request.Id
+            };
+
+            await database.Users.AddAsync(newUser, cancellationToken);
+            await database.SaveChangesAsync(cancellationToken);
+
+            logger.LogInformation("User with Id={UserId} created successfully.", newUser.Id);
+            return Result.Created(new UserResponse(
+                newUser.Id.ToString(),
+                keycloakUser.Value.Name,
+                keycloakUser.Value.FirstName,
+                keycloakUser.Value.SecondName,
+                newUser.CreatedAt,
+                newUser.UpdatedAt));
+        }
+    }
+}
@@ -0,0 +1,24 @@
+using Ardalis.Result;
+using DispatchR.Abstractions.Send;
+using Musify.Application.Contracts.Infrastructure;
+
+namespace Musify.Application.Users.Commands
+{
+    public class DeleteUserCommandHandler(IDatabase database)
+        : IRequestHandler<DeleteUserCommand, Task<Result>>
+    {
+        public async Task<Result> Handle(DeleteUserCommand request, CancellationToken cancellationToken)
+        {
+            var existingUser = await database.Users.FindAsync(request.Id, cancellationToken);
+
+            if (existingUser is null)
+                return Result.NotFound();
+
+            database.Users.Remove(existingUser);
+
+            await database.SaveChangesAsync(cancellationToken);
+
+            return Result.NoContent();
+        }
+    }
+}
@@ -0,0 +1,36 @@
+using Ardalis.Result;
+using DispatchR.Abstractions.Send;
+using Microsoft.EntityFrameworkCore;
+using Musify.Application.Contracts.Infrastructure;
+using Musify.Application.Users.Queries;
+using Musify.Application.Users.Responses;
+
+namespace Musify.Application.Users.Handlers
+{
+    public class GetUserByIdQueryHandler(IDatabase database, IKeycloakUserService keycloakUserClient)
+        : IRequestHandler<GetUserByIdQuery, Task<Result<UserResponse> >>
+    {
+        public async Task<Result<UserResponse>> Handle(GetUserByIdQuery request, CancellationToken cancellationToken)
+        {
+            var user = await database.Users
+                .AsNoTracking()
+                .SingleOrDefaultAsync(u => u.Id == request.Id, cancellationToken);
+
+            if (user is null)
+                return Result.NotFound("User not found.");
+
+            var keycloakUser = await keycloakUserClient.GetUserByIdAsync(user.Id.ToString(), cancellationToken);
+
+            if (!keycloakUser.IsSuccess)
+                return Result.NotFound("Keycloak user not found.");
+
+            return Result.Success(new UserResponse(
+                user.Id.ToString(),
+                keycloakUser.Value.Name,
+                keycloakUser.Value.FirstName,
+                keycloakUser.Value.SecondName,
+                user.CreatedAt,
+                user.UpdatedAt));
+        }
+    }
+}
@@ -0,0 +1,36 @@
+using Ardalis.Result;
+using DispatchR.Abstractions.Send;
+using Microsoft.EntityFrameworkCore;
+using Musify.Application.Contracts.Infrastructure;
+using Musify.Application.Users.Queries;
+using Musify.Application.Users.Responses;
+
+namespace Musify.Application.Users.Handlers
+{
+    public class GetUserByKeycloakQueryHandler(IDatabase database, IKeycloakUserService keycloakUserClient)
+        : IRequestHandler<GetUserByKeycloakQuery, Task<Result<UserResponse> >>
+    {
+        public async Task<Result<UserResponse>> Handle(GetUserByKeycloakQuery request, CancellationToken cancellationToken)
+        {
+            var user = await database.Users
+                .AsNoTracking()
+                .SingleOrDefaultAsync(u => u.Id == request.Id, cancellationToken);
+
+            if (user is null)
+                return Result.NotFound("User not found.");
+
+            var keycloakUser = await keycloakUserClient.GetUserByIdAsync(user.Id.ToString(), cancellationToken);
+
+            if (!keycloakUser.IsSuccess)
+                return Result.NotFound("Keycloak user not found.");
+
+            return Result.Success(new UserResponse(
+                user.Id.ToString(),
+                keycloakUser.Value.Name,
+                keycloakUser.Value.FirstName,
+                keycloakUser.Value.SecondName,
+                user.CreatedAt,
+                user.UpdatedAt));
+        }
+    }
+}
@@ -0,0 +1,61 @@
+using Ardalis.Result;
+using DispatchR.Abstractions.Send;
+using Microsoft.EntityFrameworkCore;
+using Musify.Application.Contracts.Application;
+using Musify.Application.Contracts.Infrastructure;
+using Musify.Application.Users.Queries;
+using Musify.Application.Users.Responses;
+using X.PagedList;
+using X.PagedList.Extensions;
+
+namespace Musify.Application.Users.Handlers
+{
+    public class GetUsersQueryHandler(IDatabase database, IKeycloakUserService keycloakUserClient)
+        : IRequestHandler<GetUsersQuery, Task<Result<PaginatedResponse<UserResponse> > >>
+    {
+        public async Task<Result<PaginatedResponse<UserResponse> >> Handle(GetUsersQuery request, CancellationToken cancellationToken)
+        {
+            var pageNumber = request.PageNumber < 1 ? 1 : request.PageNumber;
+            var pageSize = request.PageSize < 1 ? 10 : request.PageSize;
+            var first = (pageNumber - 1) * pageSize;
+
+            var keycloakUsers = await keycloakUserClient.GetUsersAsync(
+                cancellationToken,
+                first: first,
+                max: pageSize,
+                search: request.UsernameSearch);
+
+            var keycloakIds = keycloakUsers.Select(u => u.Id).ToList();
+
+            var databaseUsers = await database.Users
+                .Where(u => keycloakIds.Contains(u.Id))
+                .ToListAsync(cancellationToken);
+
+            var users = databaseUsers
+                .Join(keycloakUsers, db => db.Id, kc => kc.Id,
+                    (databaseSource, keycloakSource) => new UserResponse(
+                        keycloakSource.Id.ToString(),
+                        keycloakSource.Name,
+                        keycloakSource.FirstName,
+                        keycloakSource.SecondName,
+                        databaseSource.CreatedAt,
+                        databaseSource.UpdatedAt))
+                .ToArray();
+
+            var totalItemCount = await keycloakUserClient.GetUsersCountAsync(cancellationToken, search: request.UsernameSearch);
+
+            var pagedUsers = new StaticPagedList<UserResponse>(users, pageNumber, pageSize, totalItemCount);
+
+            var response = new PaginatedResponse<UserResponse>(
+                pagedUsers.ToArray(),
+                pagedUsers.PageNumber,
+                pagedUsers.PageSize,
+                pagedUsers.PageCount,
+                pagedUsers.TotalItemCount,
+                pagedUsers.HasNextPage,
+                pagedUsers.HasPreviousPage);
+
+            return Result.Success(response);
+        }
+    }
+}