Files
fiscalos/tests/FiscalOS.API.Tests/Integration/IntegrationTest.cs
T

53 lines
1.7 KiB
C#

namespace FiscalOS.API.Tests.Integration;
public abstract class IntegrationTest(TestApi testApi) : IClassFixture<TestApi>, IAsyncLifetime
{
public HttpClient Client => testApi.CreateClient();
public async ValueTask InitializeAsync()
{
await ExecuteDbContextAsync(static async context =>
{
await context.Database.EnsureCreatedAsync();
});
}
protected async Task ExecuteDbContextAsync(Func<DbContext, Task> action)
{
await using var scope = testApi.Services.CreateAsyncScope();
var context = scope.ServiceProvider.GetRequiredService<AppDbContext>();
await action(context);
}
protected async Task ExecuteDbContextAsync(Func<DbContext, IServiceProvider, Task> action)
{
await using var scope = testApi.Services.CreateAsyncScope();
var context = scope.ServiceProvider.GetRequiredService<AppDbContext>();
await action(context, scope.ServiceProvider);
}
protected async Task<T> ExecuteDbContextAsync<T>(Func<DbContext, Task<T>> action)
{
await using var scope = testApi.Services.CreateAsyncScope();
var context = scope.ServiceProvider.GetRequiredService<AppDbContext>();
return await action(context);
}
protected async Task<T> ExecuteDbContextAsync<T>(Func<DbContext, IServiceProvider, Task<T>> action)
{
await using var scope = testApi.Services.CreateAsyncScope();
var context = scope.ServiceProvider.GetRequiredService<AppDbContext>();
return await action(context, scope.ServiceProvider);
}
public async ValueTask DisposeAsync()
{
await ExecuteDbContextAsync(static async context =>
{
await context.Database.EnsureDeletedAsync();
});
GC.SuppressFinalize(this);
}
}