LenzEng.Utilities.Cqrs.Rest 0.3.0

LenzEng.Utilities.Cqrs.Rest

ASP.NET Core integration for LenzEng.Utilities.Cqrs. Converts the raw results your command/query handlers return into IActionResult, so controllers never construct HTTP responses by hand.

What It Provides

Key Behaviour

• 404 Not Found happens automatically when a handler returns LenzEng.Utilities.Cqrs.NotFoundMarker instead of a result — no exception needed.
• 400 Bad Request happens automatically if LenzEng.Utilities.Cqrs.FluentValidation's ValidateCommandException is thrown, with the validation errors in the response body — this package doesn't reference that one, it just catches the exception type by name from the core package.
• Conversion functions are typed as Func<object, object> rather than Func<TDomain, TDto> on purpose, so the generic handlers stay decoupled from your domain/DTO types — the cast happens inside the converter you supply.

Quick Start

// 1. Register the core CQRS processors (from LenzEng.Utilities.Cqrs) and this package's
builder.Services.AddCqrs(typeof(CreateOrderCommandHandler).Assembly);
builder.Services.AddCqrsRest();

// 2. Configure each command/query
builder.Services.AddCreatedAtRouteControllerCommand<CreateOrderCommand, Order>(opts =>
{
    opts.RouteName = "GetOrderById";
    opts.IdProperty = o => o.Id;
});
builder.Services.AddCNoContentControllerCommand<CancelOrderCommand>();
builder.Services.AddControllerQuery<GetOrderByIdQuery>();

// 3. Controllers just dispatch — no manual IActionResult construction
public class OrdersController : ControllerBase
{
    private readonly IControllerCommandProcessor _commands;
    private readonly IControllerQueryProcessor _queries;

    public OrdersController(IControllerCommandProcessor commands, IControllerQueryProcessor queries)
    {
        _commands = commands;
        _queries = queries;
    }

    [HttpPost]
    public Task<IActionResult> Create(CreateOrderCommand command, CancellationToken ct)
        => _commands.ProcessAsync(command, ct);

    [HttpGet("{id:guid}", Name = "GetOrderById")]
    public Task<IActionResult> GetById(Guid id, CancellationToken ct)
        => _queries.ProcessAsync(new GetOrderByIdQuery { OrderId = id }, ct);
}

Technical Documentation

Full reference and worked examples: src/LenzEng.Utilities.Cqrs.Rest — GitLab

See the Packages Work Together

The sample project's README is the best place to go next: a small, runnable movie-catalog API built on all three packages — LenzEng.Utilities.Cqrs, this one, and LenzEng.Utilities.Cqrs.FluentValidation — together. It's a genuinely good, step-by-step guide to how the three fit together in practice: how a request flows through every layer, what each line of DI registration actually does, and two worked recipes for adding a new endpoint from scratch. Written to be followable even if you're fairly new to the pattern.