Хранилища

authServer.ConfigureTransactionEngine(te =>
{
    // Разработка / тесты — в памяти:
    te.UseInMemoryStore();

    // Продакшн — EF Core (провайдер и строка подключения принадлежат хосту):
    // te.UseEfCoreStore(ef => ef.UseNpgsql(connectionString,
    //     npgsql => npgsql.MigrationsAssembly("Veriqa.Core.TransactionEngine.Migrations.PostgreSql")));
    // …или на SQL Server:
    // te.UseEfCoreStore(ef => ef.UseSqlServer(connectionString,
    //     sql => sql.MigrationsAssembly("Veriqa.Core.TransactionEngine.Migrations.SqlServer")));

    // Redis (нативное истечение по TTL):
    // te.UseRedisStore(redis =>
    // {
    //     redis.Configuration = "localhost:6379";
    //     redis.KeyPrefix = "veriqa:tx:";
    // });
});

authServer.AddChannelAdapters(adapters =>
{
    adapters.AddEmail();

    adapters.UseRedisChannelStores(redis =>
    {
        // Пусто — переиспользовать IConnectionMultiplexer, уже зарегистрированный
        // в контейнере (например, сателлитом движка транзакций).
        redis.Configuration = "localhost:6379";
    });
});

builder.Services.AddSingleton<IChannelIdentityRepository, MyChannelIdentityRepository>();

{
  "Veriqa": {
    "CollectedClaims": {
      "Store": { "Enabled": true }
    }
  }
}

authServer.ConfigureTransactionEngine(te =>
{
    te.UseEfCoreStore(ef => ef.UseNpgsql(connectionString,
        npgsql => npgsql.MigrationsAssembly("Veriqa.Core.TransactionEngine.Migrations.PostgreSql")));

    te.UseEfCoreCollectedClaimsStore(ef => ef.UseNpgsql(connectionString, npgsql => npgsql
        .MigrationsAssembly("Veriqa.Core.TransactionEngine.Migrations.PostgreSql")
        .MigrationsHistoryTable(CollectedClaimsMigrationDefaults.MigrationsHistoryTable)));
});

{
  "Veriqa": {
    "ClaimCompletion": {
      "CollectedClaims": { "RetentionDays": 365 }
    }
  }
}

{
  "Veriqa": {
    "OpenIddict": {
      "Database": {
        "Provider": "PostgreSQL",
        "ConnectionString": "Host=…;Database=…;Username=…;Password=…"
      }
    }
  }
}

{
  "Veriqa": {
    "OpenIddict": {
      "Database": { "Provider": "InMemory" }
    }
  }
}

public sealed class TransactionDbContextDesignTimeFactory
    : IDesignTimeDbContextFactory<TransactionDbContext>
{
    public TransactionDbContext CreateDbContext(string[] args)
    {
        var options = new DbContextOptionsBuilder<TransactionDbContext>()
            // UseXxx — ваш провайдер EF Core.
            .UseXxx(Environment.GetEnvironmentVariable("TRANSACTION_DB_CONNECTION_STRING"),
                db => db.MigrationsAssembly(typeof(TransactionDbContextDesignTimeFactory).Assembly.GetName().Name))
            // Только если вы правите модель — та же подмена, что в рантайме (см. ниже).
            .ReplaceService<IModelCustomizer, VeriqaModelCustomizer>()
            .Options;

        return new TransactionDbContext(options);
    }
}

public sealed class VeriqaModelCustomizer(ModelCustomizerDependencies dependencies)
    : RelationalModelCustomizer(dependencies)
{
    public override void Customize(ModelBuilder modelBuilder, DbContext context)
    {
        // Выполняет OnModelCreating контекста: сущности и конфигурацию Veriqa.
        base.Customize(modelBuilder, context);

        // Ваши изменения поверх — например, собственная схема:
        modelBuilder.HasDefaultSchema("veriqa");
    }
}

authServer.ConfigureTransactionEngine(te =>
    te.UseEfCoreStore(ef => ef
        .UseXxx(connectionString, db => db.MigrationsAssembly("MyCompany.Veriqa.Migrations"))
        .ReplaceService<IModelCustomizer, VeriqaModelCustomizer>()));

authServer.UseOpenIddictDatabase(ef => ef
    .UseXxx(connectionString, db => db.MigrationsAssembly("MyCompany.Veriqa.Migrations"))
    .ReplaceService<IModelCustomizer, VeriqaModelCustomizer>());

services.AddVeriqaAuditTrail(audit =>
    audit.UseEfCoreSink(ef => ef
        .UseXxx(connectionString, db =>
        {
            db.MigrationsAssembly("MyCompany.Veriqa.Migrations");
            db.MigrationsHistoryTable(AuditMigrationDefaults.MigrationsHistoryTable);
        })
        .ReplaceService<IModelCustomizer, VeriqaModelCustomizer>()));

authServer.ConfigureTransactionEngine(te =>
{
    te.UseEfCoreStore(ef => ef.UseNpgsql(connectionString));

    // Опционально — параметры in-process диспетчеризации (ёмкость очереди):
    // te.UseChannelsPublisher(ch => ch.Capacity = 1000);

    // Наружу — RabbitMQ (для распределённых систем и внешних потребителей).
    // Дополняет, а не заменяет: in-process обработчики продолжают получать события.
    // te.UseRabbitMqPublisher(mq =>
    // {
    //     mq.ConnectionString = "amqp://user:pass@host:5672/";
    //     mq.ExchangeName = "veriqa.transactions";
    // });
});