RCommon.ApplicationServices 2.3.2-alpha.0.2

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);
    }
}

Enabling Validation

services.AddRCommon(config =>
{
    config.WithValidation<FluentValidationBuilder>(validation =>
    {
        validation.UseWithCqrs(options =>
        {
            options.ValidateCommands = true;
            options.ValidateQueries = true;
        });
    });
});

Key Types

Documentation

For full documentation, visit rcommon.com.

Related Packages

• RCommon.Core - Core abstractions and builder infrastructure
• RCommon.FluentValidation - FluentValidation-based IValidationProvider for CQRS pipeline integration
• RCommon.Models - ICommand, IQuery, and IExecutionResult model contracts

License

Licensed under the Apache License, Version 2.0.