RCommon.ApplicationServices

Provides a CQRS (Command Query Responsibility Segregation) implementation with dedicated command and query buses, handler registration, and optional validation integration for the RCommon framework.

Features

• Command Bus -- dispatches commands to a single registered ICommandHandler<TResult, TCommand> and returns an IExecutionResult
• Query Bus -- dispatches queries to a single registered IQueryHandler<TQuery, TResult> and returns a typed result
• Validation pipeline -- optionally validates commands and/or queries before handler execution via IValidationService
• Handler registration -- register handlers individually or scan assemblies with automatic decorator exclusion
• Expression caching -- dynamically compiled handler delegates can be cached for improved dispatch performance
• Fluent builder API -- integrates with the AddRCommon() builder pattern for clean DI configuration

Installation

dotnet add package RCommon.ApplicationServices

Usage

using RCommon; using RCommon.ApplicationServices; // Configure CQRS in your DI setup services.AddRCommon(config => { config.WithCQRS<CqrsBuilder>(cqrs => { // Register handlers individually cqrs.AddCommandHandler<CreateOrderHandler, CreateOrderCommand, CommandResult>(); cqrs.AddQueryHandler<GetOrderHandler, GetOrderQuery, OrderDto>(); // Or scan an assembly for all handlers cqrs.AddCommandHandlers(typeof(CreateOrderHandler).Assembly); cqrs.AddQueryHandlers(typeof(GetOrderHandler).Assembly); }); }); // Dispatch a command from your application layer public class OrderService { private readonly ICommandBus _commandBus; private readonly IQueryBus _queryBus; public OrderService(ICommandBus commandBus, IQueryBus queryBus) { _commandBus = commandBus; _queryBus = queryBus; } public async Task<CommandResult> CreateOrderAsync(CreateOrderCommand command) { return await _commandBus.DispatchCommandAsync(command); } public async Task<OrderDto> GetOrderAsync(GetOrderQuery query) { return await _queryBus.DispatchQueryAsync(query); } }