This project is an example of architecture using new technologies and best practices.
The goal is to share knowledge and use it as reference for new projects.
Thanks for enjoying!
Source: https://github.com/rafaelfgx/DotNetCore
Published: https://www.nuget.org/profiles/rafaelfgx
Web: Frontend and API.
Application: Flow control.
Domain: Business rules and domain logic.
Model: Data transfer objects.
Database: Data persistence.
export class AppCustomerService {
constructor(
private readonly http: HttpClient,
private readonly gridService: GridService) { }
add(model: CustomerModel) {
return this.http.post<number>("customers", model);
}
delete(id: number) {
return this.http.delete(`customers/${id}`);
}
get(id: number) {
return this.http.get<CustomerModel>(`customers/${id}`);
}
grid(parameters: GridParametersModel) {
return this.gridService.get<CustomerModel>("customers/grid", parameters);
}
inactivate(id: number) {
return this.http.patch(`customers/${id}/inactivate`, {});
}
list() {
return this.http.get<CustomerModel[]>("customers");
}
update(model: CustomerModel) {
return this.http.put(`customers/${model.id}`, model);
}
}
export class AppGuard implements CanActivate {
constructor(private readonly appAuthService: AppAuthService) { }
canActivate() {
if (this.appAuthService.authenticated()) { return true; }
this.appAuthService.signin();
return false;
}
}
export class AppErrorHandler implements ErrorHandler {
constructor(private readonly appModalService: AppModalService) { }
handleError(error: any) {
if (error instanceof HttpErrorResponse) {
switch (error.status) {
case 422: {
this.appModalService.alert(error.error);
return;
}
}
}
console.error(error);
}
}
export class AppHttpInterceptor implements HttpInterceptor {
constructor(private readonly appAuthService: AppAuthService) { }
intercept(request: HttpRequest<any>, next: HttpHandler) {
request = request.clone({
setHeaders: { Authorization: `Bearer ${this.appAuthService.token()}` }
});
return next.handle(request);
}
}
public sealed class Startup
{
public void Configure(IApplicationBuilder application)
{
application.UseException();
application.UseHttps();
application.UseRouting();
application.UseResponseCompression();
application.UseAuthentication();
application.UseAuthorization();
application.UseEndpoints();
application.UseSpa();
}
public void ConfigureServices(IServiceCollection services)
{
services.AddSecurity();
services.AddResponseCompression();
services.AddControllersMvcJsonOptions();
services.AddSpa();
services.AddContext();
services.AddServices();
}
}
[ApiController]
[Route("customers")]
public sealed class CustomerController : ControllerBase
{
private readonly ICustomerService _customerService;
public CustomerController(ICustomerService customerService)
{
_customerService = customerService;
}
[HttpPost]
public Task<IActionResult> AddAsync(CustomerModel model)
{
return _customerService.AddAsync(model).ResultAsync();
}
[HttpDelete("{id}")]
public Task<IActionResult> DeleteAsync(long id)
{
return _customerService.DeleteAsync(id).ResultAsync();
}
[HttpGet("{id}")]
public Task<IActionResult> GetAsync(long id)
{
return _customerService.GetAsync(id).ResultAsync();
}
[HttpGet("grid")]
public Task<IActionResult> GridAsync([FromQuery] GridParameters parameters)
{
return _customerService.GridAsync(parameters).ResultAsync();
}
[HttpPatch("{id}/inactivate")]
public Task InactivateAsync(long id)
{
return _customerService.InactivateAsync(id);
}
[HttpGet]
public Task<IActionResult> ListAsync()
{
return _customerService.ListAsync().ResultAsync();
}
[HttpPut("{id}")]
public Task<IActionResult> UpdateAsync(CustomerModel model)
{
return _customerService.UpdateAsync(model).ResultAsync();
}
}
public sealed class CustomerService : ICustomerService
{
private readonly ICustomerFactory _customerFactory;
private readonly ICustomerRepository _customerRepository;
private readonly IUnitOfWork _unitOfWork;
public CustomerService
(
ICustomerFactory customerFactory,
ICustomerRepository customerRepository,
IUnitOfWork unitOfWork
)
{
_customerFactory = customerFactory;
_customerRepository = customerRepository;
_unitOfWork = unitOfWork;
}
public async Task<IResult<long>> AddAsync(CustomerModel model)
{
var validation = await new AddCustomerModelValidator().ValidationAsync(model);
if (validation.Failed)
{
return Result<long>.Fail(validation.Message);
}
var customer = _customerFactory.Create(model);
await _customerRepository.AddAsync(customer);
await _unitOfWork.SaveChangesAsync();
return Result<long>.Success(customer.Id);
}
public async Task<IResult> DeleteAsync(long id)
{
await _customerRepository.DeleteAsync(id);
await _unitOfWork.SaveChangesAsync();
return Result.Success();
}
public Task<CustomerModel> GetAsync(long id)
{
return _customerRepository.GetModelAsync(id);
}
public Task<Grid<CustomerModel>> GridAsync(GridParameters parameters)
{
return _customerRepository.GridAsync(parameters);
}
public async Task InactivateAsync(long id)
{
var customer = new Customer(id);
customer.Inactivate();
await _customerRepository.InactivateAsync(customer);
await _unitOfWork.SaveChangesAsync();
}
public Task<IEnumerable<CustomerModel>> ListAsync()
{
return _customerRepository.ListModelAsync();
}
public async Task<IResult> UpdateAsync(CustomerModel model)
{
var validation = await new UpdateCustomerModelValidator().ValidationAsync(model);
if (validation.Failed)
{
return Result.Fail(validation.Message);
}
var customer = _customerFactory.Create(model);
await _customerRepository.UpdateAsync(customer.Id, customer);
await _unitOfWork.SaveChangesAsync();
return Result.Success();
}
}
public sealed class CustomerFactory : ICustomerFactory
{
public Customer Create(CustomerModel model)
{
return new Customer
(
model.Id,
new Name(model.FirstName, model.LastName),
new Email(model.Email)
);
}
}
public sealed class Customer : Entity<long>
{
public Customer(long id) : base(id) { }
public Customer
(
long id,
Name name,
Email email
)
: base(id)
{
Name = name;
Email = email;
Activate();
}
public Name Name { get; private set; }
public Email Email { get; private set; }
public Status Status { get; private set; }
public void Activate()
{
Status = Status.Active;
}
public void Inactivate()
{
Status = Status.Inactive;
}
}
public sealed record Name(string FirstName, string LastName);
public sealed record CustomerModel
{
public long Id { get; init; }
public string FirstName { get; init; }
public string LastName { get; init; }
public string Email { get; init; }
}
public abstract class CustomerModelValidator : AbstractValidator<CustomerModel>
{
public CustomerModelValidator Id()
{
RuleFor(customer => customer.Id).NotEmpty();
return this;
}
public CustomerModelValidator FirstName()
{
RuleFor(customer => customer.FirstName).NotEmpty();
return this;
}
public CustomerModelValidator LastName()
{
RuleFor(customer => customer.LastName).NotEmpty();
return this;
}
public CustomerModelValidator Email()
{
RuleFor(customer => customer.Email).EmailAddress();
return this;
}
}
public sealed class AddCustomerModelValidator : CustomerModelValidator
{
public AddCustomerModelValidator() => FirstName().LastName().Email();
}
public sealed class UpdateCustomerModelValidator : CustomerModelValidator
{
public UpdateCustomerModelValidator() => Id().FirstName().LastName().Email();
}
public sealed class DeleteCustomerModelValidator : CustomerModelValidator
{
public DeleteCustomerModelValidator() => Id();
}
public sealed class Context : DbContext
{
public Context(DbContextOptions options) : base(options) { }
protected override void OnModelCreating(ModelBuilder builder)
{
builder.ApplyConfigurationsFromAssembly(typeof(Context).Assembly).Seed();
}
}
public sealed class CustomerConfiguration : IEntityTypeConfiguration<Customer>
{
public void Configure(EntityTypeBuilder<Customer> builder)
{
builder.ToTable(nameof(Customer), nameof(Customer));
builder.HasKey(customer => customer.Id);
builder.Property(customer => customer.Id).ValueGeneratedOnAdd().IsRequired();
builder.Property(customer => customer.Status).IsRequired();
builder.OwnsOne(customer => customer.Name, customerName =>
{
customerName.Property(name => name.FirstName).HasColumnName(nameof(Name.FirstName)).HasMaxLength(100).IsRequired();
customerName.Property(name => name.LastName).HasColumnName(nameof(Name.LastName)).HasMaxLength(200).IsRequired();
});
builder.OwnsOne(customer => customer.Email, customerEmail =>
{
customerEmail.Property(email => email.Value).HasColumnName(nameof(User.Email)).HasMaxLength(300).IsRequired();
customerEmail.HasIndex(email => email.Value).IsUnique();
});
}
}
public sealed class CustomerRepository : EFRepository<Customer>, ICustomerRepository
{
public CustomerRepository(Context context) : base(context) { }
public Task<CustomerModel> GetModelAsync(long id)
{
return Queryable.Where(CustomerExpression.Id(id)).Select(CustomerExpression.Model).SingleOrDefaultAsync();
}
public Task<Grid<CustomerModel>> GridAsync(GridParameters parameters)
{
return Queryable.Select(CustomerExpression.Model).GridAsync(parameters);
}
public Task InactivateAsync(Customer customer)
{
return UpdatePartialAsync(customer.Id, new { customer.Status });
}
public async Task<IEnumerable<CustomerModel>> ListModelAsync()
{
return await Queryable.Select(CustomerExpression.Model).ToListAsync();
}
}
public static class CustomerExpression
{
public static Expression<Func<Customer, CustomerModel>> Model => customer => new CustomerModel
{
Id = user.Id,
FirstName = user.Name.FirstName,
LastName = user.Name.LastName,
Email = user.Email.Value
};
public static Expression<Func<Customer, bool>> Id(long id)
{
return customer => customer.Id == id;
}
}