ASP.NET Core - Minimal APIs com CQRS

Este código é usado para criar um endpoint GET para uma API chamada "produto/getall";

O endpoint permite que os usuários possam recuperar todos os produtos cadastrados no sistema. A lógica para isso está contida no bloco de código dentro da função lambda que é passada para o método MapGet. O método MapGet é um método de extensão do objeto IEndpointRouteBuilder e é usado para mapear um endpoint GET para uma determinada rota.

A primeira coisa que o endpoint faz é criar uma instância da classe GetProdutosQuery. Esta classe é uma classe de consulta (query) que é usada para solicitar uma lista de produtos. Em seguida, a instância da classe é passada para o objeto Mediator, que é responsável por gerenciar todas as solicitações de comando e consulta na aplicação. O método Send do objeto Mediator é usado para enviar a solicitação de consulta para o manipulador de consulta correspondente.

Se a solicitação for bem-sucedida, o manipulador de consulta retornará uma lista de produtos, que é então usada para gerar uma resposta HTTP 200 OK usando o método estático Results.Ok. Se a solicitação não retornar nenhum resultado, o endpoint retornará uma resposta HTTP 404 Not Found usando o método Results.NotFound.

Se ocorrer uma exceção durante a execução do endpoint, a mensagem de erro da exceção será capturada e retornada ao cliente como uma resposta HTTP 400 Bad Request usando o método Results.BadRequest.

2- Retorna um produto pelo Id

app.MapGet("produto/getbyid", async (IMediator _mediator, int id) =>
{
   try
   {
     var command = new GetProdutoPorIdQuery() { Id = id };
     var response = await _mediator.Send(command);
     return response is not null ? Results.Ok(response) : Results.NotFound();
   }
   catch (Exception ex)
   {
      return Results.BadRequest(ex.Message);
   }
});

Aqui a rota do endpoint contém um parâmetro {id}, que é usado para passar o valor do identificador na URL.

O primeiro parâmetro da função lambda é um objeto IMediator, que é usado para enviar a solicitação de consulta para o manipulador de consulta correspondente. O segundo parâmetro é o valor do identificador que é passado na URL.

Estou usando o bloco try-catch para tratar os erros nos endpoints mas existe uma alternativa mais elegante e eficaz que seria o uso de middleware de tratamento de erros. O middleware de tratamento de erros é um componente da pipeline de execução da aplicação que é responsável por lidar com exceções que ocorrem durante o processamento de solicitações.

O middleware de tratamento de erros é adicionado à pipeline de execução da aplicação usando o método UseExceptionHandler. Este método permite que a aplicação defina um manipulador de exceções global que pode ser usado para capturar exceções em qualquer lugar da pipeline de execução da aplicação.

Quando ocorre uma exceção, o middleware de tratamento de erros captura a exceção e executa o manipulador de exceções global definido pela aplicação. O manipulador de exceções global pode ser usado para personalizar a resposta HTTP de erro que é enviada ao cliente.

O uso do middleware de tratamento de erros tem várias vantagens em relação ao bloco try-catch em endpoints de API.

Primeiro, ele pode ser usado em toda a pipeline de execução da aplicação, garantindo que todas as exceções sejam tratadas de forma consistente em todos os endpoints.
Em segundo lugar, ele permite que a aplicação defina uma resposta HTTP de erro personalizada para cada tipo de exceção que pode ocorrer, tornando a aplicação mais robusta e fácil de depurar.
E, finalmente, o uso do middleware de tratamento de erros pode ajudar a separar a lógica de tratamento de erros da lógica de negócios do endpoint, tornando o código mais limpo e mais fácil de manter.

Um exemplo básico de implementação seria o seguinte:

app.UseExceptionHandler(options =>
{
    options.Run(async context =>
    {
      // Obter a exceção que ocorreu
      var exception = context.Features.Get<IExceptionHandlerFeature>()?.Error;
      // Definir a resposta HTTP de erro
      context.Response.StatusCode = 500;
      context.Response.ContentType = "text/plain";
      await context.Response.WriteAsync("Ocorreu um erro na aplicação...");
    });
});

3- Criar um novo produto

app.MapPost("produto/create", async (IMediator _mediator, Produto produto) =>
{
   try
   {
     var command = new CreateProdutoCommand()
     {
       Nome = produto.Nome,
       Descricao = produto.Descricao,
       Categoria = produto.Categoria,
       Preco = produto.Preco,
       Ativo = produto.Ativo,
      };
      var response = await _mediator.Send(command);
      return response is not null ? Results.Ok(response) : Results.NotFound();
    }
    catch (Exception ex)
    {
       return Results.BadRequest(ex.Message);
    }
});

ASP .NET Core - Usando CQRS com MediatR

ASP .NET Core 3.1 - Entendendo CQRS

ASP .NET Core - CQRS e Mediator

ASP .NET Core 5 - Implementando CQRS com Mediator - II