WebFactory освобождается до начала всяких тестов, не заходя в DisposeAsync

Question

У меня есть интеграционный тест, для которого я определил фабрику, где поднимаю контейнер Postgres

public class IntegrationTestsWebFactory: WebApplicationFactory<Program>,IAsyncLifetime
{
    private readonly PostgreSqlContainer _dbContainer = new PostgreSqlBuilder()
        .WithImage("postgres:alpine")
        .WithDatabase("animalAllies_tests")
        .WithUsername("postgres")
        .WithPassword("345890")
        .Build();

    protected override void ConfigureWebHost(IWebHostBuilder builder)
    {
        Environment.SetEnvironmentVariable("ADMIN__USERNAME", "Admin");
        Environment.SetEnvironmentVariable("ADMIN__EMAIL", "[email protected]");
        Environment.SetEnvironmentVariable("ADMIN__PASSWORD", "Admin123");
        
        builder.ConfigureTestServices(ConfigureDefaultServices);
    }

    protected virtual void ConfigureDefaultServices(IServiceCollection services)
    {
        var writeContext = services.SingleOrDefault(s =>
            s.ServiceType == typeof(WriteDbContext));
        
        var readContext = services.SingleOrDefault(s =>
            s.ServiceType == typeof(ReadDbContext));
        
        if(writeContext is not null)
            services.Remove(writeContext);
        
        if(readContext is not null)
            services.Remove(readContext);

        var configuration = new ConfigurationBuilder()
            .AddInMemoryCollection(new Dictionary<string, string>
            {
                { "ConnectionStrings:DefaultConnection", _dbContainer.GetConnectionString() }
            }!)
            .Build();
        
        services.AddScoped<WriteDbContext>(_ => new WriteDbContext(configuration));
        services.AddScoped<IReadDbContext>(_ => new ReadDbContext(configuration));
    }

    public async Task InitializeAsync()
    {
        await _dbContainer.StartAsync();

        using var scope = Services.CreateScope();
        
        var dbContext = scope.ServiceProvider.GetRequiredService<WriteDbContext>();
        await dbContext.Database.EnsureDeletedAsync();
        await dbContext.Database.EnsureCreatedAsync();
    }

    public new async Task DisposeAsync()
    {
        await _dbContainer.StopAsync();
        await _dbContainer.DisposeAsync();
    }
}

Есть базовый класс, в котором я инициализирую все зависимости для теста. Ошибка возникает в нём, когда я пытаюсь создать скоуп через уже освобождённый объект фабрики System.ObjectDisposedException: Cannot access a disposed object. Object name: 'IServiceProvider'. В чём может быть проблема? На каком этапе у меня могла освобождаться фабрика? Я пытался отладить выполнение, но в отладке не заходил в DisposeAsync, реализуемый IAsyncLifetime.

public class VolunteerTestsBase: IClassFixture<IntegrationTestsWebFactory>, IAsyncLifetime
{
    protected readonly IntegrationTestsWebFactory _factory;
    protected readonly IServiceScope _scope;
    protected readonly WriteDbContext _context;
    protected readonly Fixture _fixture;

    protected VolunteerTestsBase(IntegrationTestsWebFactory factory)
    {
        _factory = factory;
        _scope = factory.Services.CreateScope();
        _context = _scope.ServiceProvider.GetRequiredService<WriteDbContext>();
        _fixture = new Fixture();
    }

    public Task InitializeAsync()
    {
        return Task.CompletedTask;
    }

    public Task DisposeAsync()
    {
        _scope.Dispose();
        
        return Task.CompletedTask;
    }
}

И сам класс с тестом

public class CreateVolunteerTests : VolunteerTestsBase
{
    private ICommandHandler<CreateVolunteerCommand, VolunteerId> _sut;
    
    public CreateVolunteerTests(IntegrationTestsWebFactory factory) : base(factory)
    {
        _sut = _scope.ServiceProvider.GetRequiredService<ICommandHandler<CreateVolunteerCommand, VolunteerId>>();
    }
    
    [Fact]
    public async Task Create_volunteer()
    {
        //Arrange
        var command = _fixture.CreateVolunteerCommand();
        
        //Act
        var result = await _sut.Handle(command, CancellationToken.None);
        
        //Assert
        result.IsSuccess.Should().BeTrue();
        result.Value.Should().NotBeNull();
        
        var volunteer = await _context.Volunteers.FirstOrDefaultAsync(v => v.Id == result.Value);
        
        volunteer.Should().NotBeNull();
        volunteer.Id.Should().Be(result.Value);
    }
}

Answer 1

В твоем коде основная проблема заключается в методе DisposeAsync класса IntegrationTestsWebFactory. Ты использовал ключевое слово new в объявлении этого метода DisposeAsync В результате происходит следующее: ты освобождаешь контейнер Postgres, но базовая инфраструктура WebApplicationFactory остается неосвобожденной должным образом. При этом, через другие механизмы освобождения ресурсов (которые встроены в xUnit и .NET), базовый WebApplicationFactory все-таки освобождает свои ресурсы - включая IServiceProvider. А дальше происходит путаница: ты думаешь, что твоя фабрика еще полностью функциональна, и пытаешься использовать её для создания сервисов через factory.Services.CreateScope() в классе VolunteerTestsBase, но сервис-провайдер уже освобожден. Поэтому решение простое - удали ключевое слово new из метода DisposeAsync и добавь вызов базового метода

public async Task DisposeAsync()
{
    await _dbContainer.StopAsync();
    await _dbContainer.DisposeAsync();
    await base.DisposeAsync();
}

Это позволит освободить ресурсы в правильном порядке - сначала твои собственные (контейнер Postgres), а затем базовые ресурсы WebApplicationFactory. Таким образом всё будет освобождаться координированно и без путаницы о том, что и когда можно использовать.

Ещё момент: твоя ошибка не появлялась при отладке, потому что xUnit по-другому управляет жизненным циклом объектов в режиме отладки, и порядок вызовов может отличаться. Вот почему в отладке ты не видел вызов DisposeAsync - он мог происходить позже или через другой интерфейс.

Answer 2

Помогло решить проблему удаление всех фоновых служб в конфигурации

public class IntegrationTestsWebFactory: WebApplicationFactory<Program>,IAsyncLifetime
{
    private readonly PostgreSqlContainer _dbContainer = new PostgreSqlBuilder()
        .WithImage("postgres")
        .WithDatabase("animalAllies_tests")
        .WithUsername("postgres")
        .WithPassword("postgres")
        .Build();

    private Respawner _respawner = null!;
    private DbConnection _dbConnection = null!;

    protected override void ConfigureWebHost(IWebHostBuilder builder)
    {
        Environment.SetEnvironmentVariable("ADMIN__USERNAME", "Admin");
        Environment.SetEnvironmentVariable("ADMIN__EMAIL", "[email protected]");
        Environment.SetEnvironmentVariable("ADMIN__PASSWORD", "Admin123");
        
        builder.ConfigureTestServices(ConfigureDefaultServices);
    }

    protected virtual void ConfigureDefaultServices(IServiceCollection services)
    {
        services.RemoveAll(typeof(IHostedService));
        
        services.RemoveAll(typeof(WriteDbContext));

        var connectionString = _dbContainer.GetConnectionString();
        
        var configuration = new ConfigurationBuilder()
            .AddInMemoryCollection(new Dictionary<string, string>
            {
                { "ConnectionStrings:DefaultConnection", connectionString }
            }!)
            .Build();

        services.AddScoped<WriteDbContext>(_ =>
            new WriteDbContext(configuration));
    }

    public async Task InitializeAsync()
    {
        await _dbContainer.StartAsync();

        using var scope = Services.CreateScope();
        var dbContext = scope.ServiceProvider.GetRequiredService<WriteDbContext>();
        await dbContext.Database.MigrateAsync();
        
        _dbConnection = new NpgsqlConnection(_dbContainer.GetConnectionString());
        await InitializeRespawner();
    }

    private async Task InitializeRespawner()
    {
        await _dbConnection.OpenAsync();
        _respawner = await Respawner.CreateAsync(_dbConnection, new RespawnerOptions
            {
                DbAdapter = DbAdapter.Postgres,
                SchemasToInclude = ["public"]
            }
        );
    }
    
    public async Task ResetDatabaseAsync()
    {
        await _respawner.ResetAsync(_dbConnection); 
    }
    
    public new async Task DisposeAsync()
    {
        await _dbContainer.StopAsync();
        await _dbContainer.DisposeAsync();
        await base.DisposeAsync();
    }
}

БЛОГ НА HUSL

WebFactory освобождается до начала всяких тестов, не заходя в DisposeAsync

Ответы (2 шт):