Koto.Infrastructure.EFCore

Интеграция EF Core 10: generic-репозиторий, строготипизированные ID, specifications, Wolverine outbox.

Установка

dotnet add package Koto.Infrastructure.EFCore
dotnet add package Npgsql.EntityFrameworkCore.PostgreSQL  # или ваш провайдер

Что внутри

Тип	Назначение
`KotoDbContext`	Абстрактный DbContext; автоматически применяет `StronglyTypedIdConvention`; очищает доменные события после сохранения
`Repository<TAgg, TId>`	Generic-реализация `IRepository` на EF Core
`StronglyTypedIdValueConverter<TId, TRaw>`	`ValueConverter` EF Core для свойств `StronglyTypedId<T>`
`StronglyTypedIdConvention`	Автоматически применяет конвертеры ко всем строготипизированным ID-свойствам
`ISpecification<T>` / `Specification<T>`	Инкапсулирует критерии запроса, include и сортировку
`SpecificationEvaluator`	Применяет specification к `IQueryable<T>`
`AddKotoEFCore<TContext>()`	Регистрирует DbContext через интеграцию Wolverine с EF Core

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

1 — Определите DbContext

public class AppDbContext : KotoDbContext
{
    public AppDbContext(DbContextOptions options) : base(options) { }

    protected override void OnModelCreating(ModelBuilder modelBuilder)
    {
        modelBuilder.ApplyConfigurationsFromAssembly(typeof(AppDbContext).Assembly);
    }
}

StronglyTypedIdConvention применяется автоматически — ручные вызовы HasConversion не нужны.

2 — Регистрация

// Program.cs
builder.Services.AddKotoEFCore<AppDbContext>(opts =>
    opts.UseNpgsql(builder.Configuration.GetConnectionString("Db")));

// Настройка Wolverine — включаем автоматическую доставку доменных событий через outbox
builder.Host.UseWolverine(opts =>
{
    opts.UseEntityFrameworkCoreTransactions();
    opts.PublishDomainEventsFromEntityFrameworkCore<IHasDomainEvents, IDomainEvent>(
        e => e.DomainEvents);
});

3 — Репозиторий

public class OrderRepository : Repository<Order, OrderId>
{
    public OrderRepository(AppDbContext ctx) : base(ctx) { }
}

Либо использовать зарегистрированный IRepository<Order, OrderId> напрямую.

4 — Specifications

public class ActiveOrdersSpec : Specification<Order>
{
    public ActiveOrdersSpec(CustomerId customerId)
    {
        AddCriteria(o => o.CustomerId == customerId && !o.IsCancelled);
        AddInclude(o => o.Items);
        ApplyOrderBy(o => o.PlacedAt);
    }
}

// В репозитории или обработчике запроса:
var query = SpecificationEvaluator.GetQuery(_context.Set<Order>(), new ActiveOrdersSpec(customerId));
var orders = await query.ToListAsync(ct);