CleanArchitecture/CleanArchitecture.Domain/Commands/Users/CreateUser/CreateUserCommandHandler.cs

using System.Threading;
using System.Threading.Tasks;
using CleanArchitecture.Domain.Entities;
using CleanArchitecture.Domain.Enums;
using CleanArchitecture.Domain.Errors;
using CleanArchitecture.Domain.Events.User;
using CleanArchitecture.Domain.Interfaces;
using CleanArchitecture.Domain.Interfaces.Repositories;
using CleanArchitecture.Domain.Notifications;
using MediatR;
using BC = BCrypt.Net.BCrypt;

namespace CleanArchitecture.Domain.Commands.Users.CreateUser;

public sealed class CreateUserCommandHandler : CommandHandlerBase,
    IRequestHandler<CreateUserCommand>
{
    private readonly IUserRepository _userRepository;

    public CreateUserCommandHandler(
        IMediatorHandler bus,
        IUnitOfWork unitOfWork,
        INotificationHandler<DomainNotification> notifications,
        IUserRepository userRepository) : base(bus, unitOfWork, notifications)
    {
        _userRepository = userRepository;
    }

    public async Task Handle(CreateUserCommand request, CancellationToken cancellationToken)
    {
        if (!await TestValidityAsync(request))
        {
            return;
        }

        var existingUser = await _userRepository.GetByIdAsync(request.UserId);

        if (existingUser != null)
        {
            await _bus.RaiseEventAsync(
                new DomainNotification(
                    request.MessageType,
                    $"There is already a User with Id {request.UserId}",
                    DomainErrorCodes.UserAlreadyExists));
            return;
        }

        existingUser = await _userRepository.GetByEmailAsync(request.Email);

        if (existingUser != null)
        {
            await _bus.RaiseEventAsync(
                new DomainNotification(
                    request.MessageType,
                    $"There is already a User with Email {request.Email}",
                    DomainErrorCodes.UserAlreadyExists));
            return;
        }

        var passwordHash = BC.HashPassword(request.Password);

        var user = new User(
            request.UserId,
            request.Email,
            request.Surname,
            request.GivenName,
            passwordHash,
            UserRole.User);

        _userRepository.Add(user);

        if (await CommitAsync())
        {
            await _bus.RaiseEventAsync(new UserCreatedEvent(user.Id));
        }
    }
}