AgileWebs/Core.Thalos.Service.API
6
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Add tenant services, change id by _id and include delete endpoint for all entities

Browse Source
This commit is contained in:
Sergio Matias Urquin
2025-08-07 18:27:06 -06:00
parent f3d63ca0e3
commit 296aff13fe
47 changed files with 1183 additions and 118 deletions
Download Patch File Download Diff File Expand all files Collapse all files

223
Core.Thalos.Application/UseCases/Tenants/TenantHandler.cs Normal file
View File

@@ -0,0 +1,223 @@
using Core.Thalos.Application.UseCases.Tenants.Input;
using Core.Thalos.Application.UseCases.Tenants.Ports;
using Core.Thalos.BuildingBlocks;
using Core.Thalos.External.Clients;
using FluentValidation;
using Lib.Architecture.BuildingBlocks;
using Lib.Architecture.BuildingBlocks.Helpers;
namespace Core.Thalos.Application.UseCases.Tenants
{
public class TenantHandler :
IComponentHandler<ChangeTenantStatusRequest>,
IComponentHandler<GetAllTenantsRequest>,
IComponentHandler<UpdateTenantRequest>,
IComponentHandler<GetTenantRequest>,
IComponentHandler<DeleteTenantRequest>,
IComponentHandler<CreateTenantRequest>
{
private readonly ITenantPort _port;
private readonly IValidator<ChangeTenantStatusRequest> _changeTenantStatusValidator;
private readonly IValidator<CreateTenantRequest> _registerTenantValidator;
private readonly IValidator<UpdateTenantRequest> _updateTenantValidator;
private readonly IThalosServiceClient _thalosDALService;
public TenantHandler(
ITenantPort port,
IValidator<ChangeTenantStatusRequest> changeTenantStatusValidator,
IValidator<CreateTenantRequest> registerTenantValidator,
IValidator<UpdateTenantRequest> updateTenantValidator,
IThalosServiceClient thalosDALService)
{
_port = port ?? throw new ArgumentNullException(nameof(port));
_changeTenantStatusValidator = changeTenantStatusValidator ?? throw new ArgumentNullException(nameof(changeTenantStatusValidator));
_registerTenantValidator = registerTenantValidator ?? throw new ArgumentNullException(nameof(registerTenantValidator));
_updateTenantValidator = updateTenantValidator ?? throw new ArgumentNullException(nameof(updateTenantValidator));
_thalosDALService = thalosDALService ?? throw new ArgumentNullException(nameof(thalosDALService));
}
public async ValueTask ExecuteAsync(GetTenantRequest command, CancellationToken cancellationToken = default)
{
try
{
ArgumentNullException.ThrowIfNull(command);
var result = await _thalosDALService.GetTenantByIdAsync(command._Id, cancellationToken).ConfigureAwait(false);
if (result == null)
{
_port.NoContentSuccess();
return;
}
_port.Success(result);
}
catch (Exception ex)
{
ApiResponseHelper.EvaluatePort(ex, _port);
}
}
public async ValueTask ExecuteAsync(DeleteTenantRequest command, CancellationToken cancellationToken = default)
{
try
{
ArgumentNullException.ThrowIfNull(command);
var result = await _thalosDALService.DeleteTenantAsync(command._Id, cancellationToken).ConfigureAwait(false);
if (result == null)
{
_port.NoContentSuccess();
return;
}
_port.Success(result);
}
catch (Exception ex)
{
ApiResponseHelper.EvaluatePort(ex, _port);
}
}
public async ValueTask ExecuteAsync(GetAllTenantsRequest command, CancellationToken cancellationToken = default)
{
try
{
ArgumentNullException.ThrowIfNull(command);
var _result = await _thalosDALService.GetAllTenantsAsync().ConfigureAwait(false);
if (!_result.Any())
{
_port.NoContentSuccess();
return;
}
_port.Success(_result.ToList());
}
catch (Exception ex)
{
ApiResponseHelper.EvaluatePort(ex, _port);
}
}
public async ValueTask ExecuteAsync(ChangeTenantStatusRequest command, CancellationToken cancellationToken = default)
{
try
{
ArgumentNullException.ThrowIfNull(command);
if (!command.IsValid(_changeTenantStatusValidator))
{
_port.ValidationErrors(command.Notifications);
return;
}
var result = await _thalosDALService.ChangeStatusTenantAsync(command._Id, command.Status, cancellationToken).ConfigureAwait(false);
if (result == null)
{
_port.NoContentSuccess();
return;
}
_port.Success(result);
}
catch (Exception ex)
{
ApiResponseHelper.EvaluatePort(ex, _port);
}
}
public async ValueTask ExecuteAsync(CreateTenantRequest command, CancellationToken cancellationToken = default)
{
try
{
ArgumentNullException.ThrowIfNull(command);
if (!command.IsValid(_registerTenantValidator))
{
_port.ValidationErrors(command.Notifications);
return;
}
var request = new TenantRequest
{
Name = command.Name,
AddressLine1 = command.AddressLine1,
AddressLine2 = command.AddressLine2,
TaxIdentifier = command.TaxIdentifier,
City = command.City,
State = command.State,
Country = command.Country,
PostalCode = command.PostalCode,
ContactEmail = command.ContactEmail,
ContactPhone = command.ContactPhone,
Website = command.Website,
ConnectionString = command.ConnectionString,
Isolated = command.Isolated
};
var result = await _thalosDALService.CreateTenantAsync(request, cancellationToken).ConfigureAwait(false);
if (result == null)
{
_port.NoContentSuccess();
return;
}
_port.Success(result);
}
catch (Exception ex)
{
ApiResponseHelper.EvaluatePort(ex, _port);
}
}
public async ValueTask ExecuteAsync(UpdateTenantRequest command, CancellationToken cancellationToken = default)
{
try
{
ArgumentNullException.ThrowIfNull(command);
if (!command.IsValid(_updateTenantValidator))
{
_port.ValidationErrors(command.Notifications);
return;
}
var request = new TenantAdapter
{
_Id = command._Id,
Name = command.Name,
AddressLine1 = command.AddressLine1,
AddressLine2 = command.AddressLine2,
TaxIdentifier = command.TaxIdentifier,
City = command.City,
State = command.State,
Country = command.Country,
PostalCode = command.PostalCode,
ContactEmail = command.ContactEmail,
ContactPhone = command.ContactPhone,
Website = command.Website,
ConnectionString = command.ConnectionString,
Isolated = command.Isolated
};
string id = command._Id;
var result = await _thalosDALService.UpdateTenantAsync(request, id, cancellationToken).ConfigureAwait(false);
if (result == null)
{
_port.NoContentSuccess();
return;
}
_port.Success(result);
}
catch (Exception ex)
{
ApiResponseHelper.EvaluatePort(ex, _port);
}
}
}
}