Add tenant application layer slice

Author: beyondnetPeru

src/apps/app-api-dotnet/Ums.Application/Abstractions/Messaging/ICommand.cs

@@ -0,0 +1,12 @@
+namespace Ums.Application.Abstractions.Messaging;
+
+using MediatR;
+using Ums.Domain.Kernel;
+
+public interface ICommand : IRequest<Result>
+{
+}
+
+public interface ICommand<TResponse> : IRequest<Result<TResponse>>
+{
+}

src/apps/app-api-dotnet/Ums.Application/Abstractions/Messaging/ICommandHandler.cs

@@ -0,0 +1,14 @@
+namespace Ums.Application.Abstractions.Messaging;
+
+using MediatR;
+using Ums.Domain.Kernel;
+
+public interface ICommandHandler<in TCommand> : IRequestHandler<TCommand, Result>
+    where TCommand : ICommand
+{
+}
+
+public interface ICommandHandler<in TCommand, TResponse> : IRequestHandler<TCommand, Result<TResponse>>
+    where TCommand : ICommand<TResponse>
+{
+}

src/apps/app-api-dotnet/Ums.Application/Abstractions/Messaging/IQuery.cs

@@ -0,0 +1,8 @@
+namespace Ums.Application.Abstractions.Messaging;
+
+using MediatR;
+using Ums.Domain.Kernel;
+
+public interface IQuery<TResponse> : IRequest<Result<TResponse>>
+{
+}

src/apps/app-api-dotnet/Ums.Application/Abstractions/Messaging/IQueryHandler.cs

@@ -0,0 +1,9 @@
+namespace Ums.Application.Abstractions.Messaging;
+
+using MediatR;
+using Ums.Domain.Kernel;
+
+public interface IQueryHandler<in TQuery, TResponse> : IRequestHandler<TQuery, Result<TResponse>>
+    where TQuery : IQuery<TResponse>
+{
+}

src/apps/app-api-dotnet/Ums.Application/Abstractions/Persistence/ITenantRepository.cs

@@ -0,0 +1,12 @@
+namespace Ums.Application.Abstractions.Persistence;
+
+using Ums.Domain.Identity.Tenant;
+using Ums.Domain.Kernel.ValueObjects;
+
+public interface ITenantRepository
+{
+    Task<Tenant?> FindByIdAsync(TenantId tenantId, CancellationToken cancellationToken = default);
+    Task<Tenant?> FindByCodeAsync(Code code, CancellationToken cancellationToken = default);
+    Task AddAsync(Tenant tenant, CancellationToken cancellationToken = default);
+    Task UpdateAsync(Tenant tenant, CancellationToken cancellationToken = default);
+}

src/apps/app-api-dotnet/Ums.Application/Abstractions/Persistence/IUnitOfWork.cs

@@ -0,0 +1,6 @@
+namespace Ums.Application.Abstractions.Persistence;
+
+public interface IUnitOfWork
+{
+    Task<int> SaveChangesAsync(CancellationToken cancellationToken = default);
+}

src/apps/app-api-dotnet/Ums.Application/Common/Behaviors/ValidationBehavior.cs

@@ -0,0 +1,66 @@
+namespace Ums.Application.Common.Behaviors;
+
+using FluentValidation;
+using MediatR;
+using Ums.Domain.Kernel;
+
+public sealed class ValidationBehavior<TRequest, TResponse> : IPipelineBehavior<TRequest, TResponse>
+    where TRequest : notnull
+{
+    private readonly IEnumerable<IValidator<TRequest>> _validators;
+
+    public ValidationBehavior(IEnumerable<IValidator<TRequest>> validators)
+    {
+        _validators = validators;
+    }
+
+    public async Task<TResponse> Handle(
+        TRequest request,
+        RequestHandlerDelegate<TResponse> next,
+        CancellationToken cancellationToken)
+    {
+        if (!_validators.Any())
+        {
+            return await next();
+        }
+
+        var context = new ValidationContext<TRequest>(request);
+        var validationResults = await Task.WhenAll(
+            _validators.Select(validator => validator.ValidateAsync(context, cancellationToken)));
+
+        var errors = validationResults
+            .SelectMany(result => result.Errors)
+            .Where(error => error is not null)
+            .Select(error => $"{error.PropertyName}: {error.ErrorMessage}")
+            .Distinct()
+            .ToArray();
+
+        if (errors.Length == 0)
+        {
+            return await next();
+        }
+
+        return CreateValidationResult<TResponse>(string.Join("; ", errors));
+    }
+
+    private static TResult CreateValidationResult<TResult>(string error)
+    {
+        if (typeof(TResult) == typeof(Result))
+        {
+            return (TResult)(object)Result.Failure(error);
+        }
+
+        if (typeof(TResult).IsGenericType &&
+            typeof(TResult).GetGenericTypeDefinition() == typeof(Result<>))
+        {
+            var valueType = typeof(TResult).GetGenericArguments()[0];
+            var failureMethod = typeof(Result<>)
+                .MakeGenericType(valueType)
+                .GetMethod(nameof(Result.Failure), new[] { typeof(string) });
+
+            return (TResult)failureMethod!.Invoke(null, new object[] { error })!;
+        }
+
+        throw new InvalidOperationException($"ValidationBehavior cannot create a failure result for '{typeof(TResult).Name}'.");
+    }
+}

src/apps/app-api-dotnet/Ums.Application/Common/DomainEnumerationParser.cs

@@ -0,0 +1,19 @@
+namespace Ums.Application.Common;
+
+using Ums.Shell.Ddd;
+
+internal static class DomainEnumerationParser
+{
+    public static T? FromName<T>(string? name)
+        where T : DomainEnumeration
+    {
+        if (string.IsNullOrWhiteSpace(name))
+        {
+            return null;
+        }
+
+        return DomainEnumeration
+            .GetAll<T>()
+            .FirstOrDefault(value => string.Equals(value.Name, name.Trim(), StringComparison.OrdinalIgnoreCase));
+    }
+}

src/apps/app-api-dotnet/Ums.Application/DependencyInjection.cs

@@ -0,0 +1,20 @@
+namespace Ums.Application;
+
+using FluentValidation;
+using MediatR;
+using Microsoft.Extensions.DependencyInjection;
+using Ums.Application.Common.Behaviors;
+
+public static class DependencyInjection
+{
+    public static IServiceCollection AddApplication(this IServiceCollection services)
+    {
+        var assembly = typeof(DependencyInjection).Assembly;
+
+        services.AddMediatR(configuration => configuration.RegisterServicesFromAssembly(assembly));
+        services.AddValidatorsFromAssembly(assembly);
+        services.AddTransient(typeof(IPipelineBehavior<,>), typeof(ValidationBehavior<,>));
+
+        return services;
+    }
+}

src/apps/app-api-dotnet/Ums.Application/Tenants/ActivateTenant/ActivateTenantCommand.cs

@@ -0,0 +1,5 @@
+namespace Ums.Application.Tenants.ActivateTenant;
+
+using Ums.Application.Abstractions.Messaging;
+
+public sealed record ActivateTenantCommand(Guid TenantId) : ICommand;