DD.WellWorkover.Cloud/AsbCloudWebApi.IntegrationTests/WebAppFactoryFixture.cs

using AsbCloudDb.Model;
using Microsoft.AspNetCore.Hosting;
using Microsoft.AspNetCore.Mvc.Testing;
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Refit;
using System.Net.Http.Headers;
using System.Text.Json;
using AsbCloudDb;
using AsbCloudWebApi.IntegrationTests.Converters;

namespace AsbCloudWebApi.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<AsbCloudDbContext>));

         if (descriptor != null)
            services.Remove(descriptor);

         services.AddDbContext<AsbCloudDbContext>(options =>
            options.UseNpgsql(connectionString));

         var serviceProvider = services.BuildServiceProvider();

         using var scope = serviceProvider.CreateScope();
         var scopedServices = scope.ServiceProvider;
         var dbContext = scopedServices.GetRequiredService<AsbCloudDbContext>();

         dbContext.Database.EnsureCreatedAndMigrated();
         dbContext.Deposits.AddRange(Data.Defaults.Deposits);
         dbContext.SaveChanges();
      });
   }

   public override async ValueTask DisposeAsync()
   {
      var dbContext = new AsbCloudDbContext(
         new DbContextOptionsBuilder<AsbCloudDbContext>()
            .UseNpgsql(connectionString)
            .Options);

      await dbContext.Database.EnsureDeletedAsync();
   }

   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;
   }
}