103 lines
3.5 KiB
C#
103 lines
3.5 KiB
C#
using Microsoft.AspNetCore.Hosting;
|
|
using Microsoft.AspNetCore.Mvc.Testing;
|
|
using Microsoft.EntityFrameworkCore;
|
|
using Microsoft.Extensions.Configuration;
|
|
using Microsoft.Extensions.DependencyInjection;
|
|
using Persistence.Database.Model;
|
|
using Persistence.Database.Postgres;
|
|
using Persistence.API;
|
|
using Refit;
|
|
using System.Text.Json;
|
|
using System.Net.Http.Headers;
|
|
|
|
namespace Persistence.IntegrationTests;
|
|
public class WebAppFactoryFixture : WebApplicationFactory<Startup>
|
|
{
|
|
private static readonly JsonSerializerOptions JsonSerializerOptions = new()
|
|
{
|
|
PropertyNamingPolicy = JsonNamingPolicy.CamelCase,
|
|
PropertyNameCaseInsensitive = true,
|
|
//Converters = { new ValidationResultConverter() }
|
|
};
|
|
|
|
private static readonly RefitSettings RefitSettings = new(new SystemTextJsonContentSerializer(JsonSerializerOptions));
|
|
|
|
private readonly string connectionString;
|
|
|
|
public WebAppFactoryFixture()
|
|
{
|
|
var configuration = new ConfigurationBuilder()
|
|
.AddJsonFile("appsettings.Tests.json")
|
|
.Build();
|
|
|
|
var dbConnection = configuration.GetSection("DbConnection").Get<DbConnection>()!;
|
|
connectionString = dbConnection.GetConnectionString();
|
|
}
|
|
|
|
protected override void ConfigureWebHost(IWebHostBuilder builder)
|
|
{
|
|
builder.ConfigureServices(services =>
|
|
{
|
|
var descriptor = services.SingleOrDefault(d => d.ServiceType == typeof(DbContextOptions<PersistenceDbContext>));
|
|
|
|
if (descriptor != null)
|
|
services.Remove(descriptor);
|
|
|
|
services.AddDbContext<PersistenceDbContext>(options =>
|
|
options.UseNpgsql(connectionString));
|
|
|
|
var serviceProvider = services.BuildServiceProvider();
|
|
|
|
using var scope = serviceProvider.CreateScope();
|
|
var scopedServices = scope.ServiceProvider;
|
|
var dbContext = scopedServices.GetRequiredService<PersistenceDbContext>();
|
|
|
|
dbContext.Database.EnsureCreatedAndMigrated();
|
|
//dbContext.Deposits.AddRange(Data.Defaults.Deposits);
|
|
dbContext.SaveChanges();
|
|
});
|
|
}
|
|
|
|
public override async ValueTask DisposeAsync()
|
|
{
|
|
var dbContext = new PersistenceDbContext(
|
|
new DbContextOptionsBuilder<PersistenceDbContext>()
|
|
.UseNpgsql(connectionString)
|
|
.Options);
|
|
|
|
await dbContext.Database.EnsureDeletedAsync();
|
|
}
|
|
|
|
public T GetHttpClient<T>(string uriSuffix)
|
|
{
|
|
var httpClient = CreateClient();
|
|
if (string.IsNullOrEmpty(uriSuffix))
|
|
return RestService.For<T>(httpClient, RefitSettings);
|
|
|
|
if (httpClient.BaseAddress is not null)
|
|
httpClient.BaseAddress = new Uri(httpClient.BaseAddress, uriSuffix);
|
|
|
|
return RestService.For<T>(httpClient, RefitSettings);
|
|
}
|
|
|
|
public T GetAuthorizedHttpClient<T>(string uriSuffix)
|
|
{
|
|
var httpClient = GetAuthorizedHttpClient();
|
|
if (string.IsNullOrEmpty(uriSuffix))
|
|
return RestService.For<T>(httpClient, RefitSettings);
|
|
|
|
if (httpClient.BaseAddress is not null)
|
|
httpClient.BaseAddress = new Uri(httpClient.BaseAddress, uriSuffix);
|
|
|
|
return RestService.For<T>(httpClient, RefitSettings);
|
|
}
|
|
|
|
private HttpClient GetAuthorizedHttpClient()
|
|
{
|
|
var httpClient = CreateClient();
|
|
////var jwtToken = ApiTokenHelper.GetAdminUserToken();
|
|
//httpClient.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", jwtToken);
|
|
return httpClient;
|
|
}
|
|
}
|