Reo.Core.BaseDomainModels.MediatR 10.0.191

Reo.Core.BaseDomainModels.MediatR

Описание пакета

Пакет Reo.Core.BaseDomainModels.MediatR предоставляет набор базовых классов и интерфейсов для построения приложений на основе Domain-Driven Design (DDD) с интеграцией MediatR. Он решает задачи структурирования бизнес-логики, управления доменными событиями и командами, а также обеспечивает удобный способ взаимодействия с репозиториями.

Основные функции:

• Поддержка доменных моделей (агрегатов) с идентификаторами.
• Интеграция с MediatR для обработки команд и событий.
• Абстракции для репозиториев (чтение и запись данных).
• Упрощение реализации паттернов CQRS и Event Sourcing.

Основные компоненты

1. IReoAggregateRoot<TId>

Интерфейс для агрегатов доменной модели. Определяет обязательные свойства и методы, такие как Id и методы для обработки команд и событий.

2. IReoDomainCommand / IReoDomainCommandWithResult

Интерфейсы для команд, которые могут быть обработаны через MediatR. IReoDomainCommand используется для команд без возвращаемого значения, а IReoDomainCommandWithResult — для команд, возвращающих bool.

3. IReoDomainEvent

Интерфейс для доменных событий, реализующих INotification из MediatR. Используется для публикации событий после изменения состояния агрегата.

4. IReoDomainCommandsExecutor / IReoDomainEventsExecutor

Интерфейсы для исполнения команд и событий. Реализуются в базовых классах, таких как ReoAggregateRoot, и обеспечивают интеграцию с MediatR.

5. IReoDomainReadOnlyRepository<TAggregateRoot> / IReoDomainWriteOnlyRepository<TAggregateRoot>

Абстракции для репозиториев. Предоставляют методы для чтения и записи агрегатов в хранилище данных.

6. ReoAggregateRoot<TId>

Базовый класс для реализации агрегатов. Реализует IReoAggregateRoot<TId>, IReoDomainCommandsExecutor, IReoDomainEventsExecutor и предоставляет методы для добавления команд и событий.

Требования

• .NET: 8.0 и выше.
• Зависимости:
  • MediatR.
  • Microsoft.Extensions.DependencyInjection.Abstractions.

Установка

NuGet Package Manager

Install-Package Reo.Core.BaseDomainModels.MediatR

.NET CLI

dotnet add package Reo.Core.BaseDomainModels.MediatR

Настройка

Регистрация в DI-контейнере (ASP.NET Core)

Добавьте сервисы в ConfigureServices в Startup.cs или Program.cs:

services.AddMediatR(cfg => {
 cfg.RegisterServicesFromAssembly(typeof(Startup).Assembly);
});

Пример регистрации репозиториев

services.AddScoped<IReoDomainReadOnlyRepository<MyAggregateRoot>, MyRepository>();
services.AddScoped<IReoDomainWriteOnlyRepository<MyAggregateRoot>, MyRepository>();

Использование

Пример 1: Создание агрегата и обработка команды

public class CreateOrderCommand : IReoDomainCommand
{
 public Guid CustomerId { get; set; }
 public List<OrderItem> Items { get; set; }
}

public class OrderAggregate : ReoAggregateRoot<Guid>
{
 public Guid CustomerId { get; private set; }
 public List<OrderItem> Items { get; private set; }

 public void Apply(CreateOrderCommand command)
 {
 CustomerId = command.CustomerId;
 Items = command.Items;
 AddDomainEvent(new OrderCreatedEvent { OrderId = Id });
 }
}

public class OrderCreatedEvent : IReoDomainEvent
{
 public Guid OrderId { get; set; }
}

Пример 2: Обработчик команды

public class CreateOrderCommandHandler : IRequestHandler<CreateOrderCommand>
{
 private readonly IReoDomainWriteOnlyRepository<OrderAggregate> _repository;

 public CreateOrderCommandHandler(IReoDomainWriteOnlyRepository<OrderAggregate> repository)
 {
 _repository = repository;
 }

 public async Task Handle(CreateOrderCommand command, CancellationToken token)
 {
 var aggregate = new OrderAggregate();
 aggregate.Apply(command);
 await _repository.SaveAsync(aggregate, token);
 }
}

Пример 3: Обработчик события

public class OrderCreatedEventHandler : INotificationHandler<OrderCreatedEvent>
{
 public async Task Handle(OrderCreatedEvent notification, CancellationToken token)
 {
 // Логика обработки события (например, отправка уведомления).
 Console.WriteLine($"Order created: {notification.OrderId}");
 }
}

Лицензия

Данный пакет распространяется под лицензией MIT.