feat: integration tests (#56)

Author: ZaoralJ

.github/workflows/tests.yaml

@@ -13,33 +13,6 @@ jobs:
     runs-on: ubuntu-20.04
     timeout-minutes: 5
 
-    services:
-      postgres:
-        image: postgres:13.1
-        ports:
-          - 5432:5432
-        env:
-          POSTGRES_USER: test
-          POSTGRES_PASSWORD: test
-          POSTGRES_DB: test
-      mysql:
-        image: mysql:8.0
-        env:
-          MYSQL_DATABASE: test
-          MYSQL_USER: test
-          MYSQL_PASSWORD: test
-          MYSQL_ROOT_PASSWORD: test
-        ports:
-          - 33306:3306
-        options: --health-cmd="mysqladmin ping" --health-interval=10s --health-timeout=5s --health-retries=3
-      sqlserver:
-        image: mcr.microsoft.com/azure-sql-edge:latest
-        ports:
-          - 1433:1433
-        env:
-          ACCEPT_EULA: Y
-          SA_PASSWORD: Test12@.
-
     steps:
       - name: Tests | Checkout
         uses: actions/checkout@v2

.gitignore

@@ -2,3 +2,11 @@
 **/obj
 **/bin
 /.vs/AppAny.Quartz.EntityFrameworkCore.Migrations
+
+# ReSharper is a .NET coding add-in
+_ReSharper*/
+*.[Rr]e[Ss]harper
+*.DotSettings.user
+
+# Ignore mac folder settings
+.DS_Store

AppAny.Quartz.EntityFrameworkCore.Migrations.sln.DotSettings

@@ -0,0 +1,2 @@
+<wpf:ResourceDictionary xml:space="preserve" xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml" xmlns:s="clr-namespace:System;assembly=mscorlib" xmlns:ss="urn:shemas-jetbrains-com:settings-storage-xaml" xmlns:wpf="http://schemas.microsoft.com/winfx/2006/xaml/presentation">
+	<s:Boolean x:Key="/Default/UserDictionary/Words/=Postgre/@EntryIndexedValue">True</s:Boolean></wpf:ResourceDictionary>

AppAny.Quartz.EntityFrameworkCore.Migrations.sln.DotSettings.user

@@ -2,7 +2,7 @@ namespace AppAny.Quartz.EntityFrameworkCore.Migrations.PostgreSQL
 {
   public static class QuartzModelBuilderPostgreSqlExtensions
   {
-    public static QuartzModelBuilder UsePostgreSql(this QuartzModelBuilder builder, string prefix = "qrtz_", string schema = "quartz")
+    public static QuartzModelBuilder UsePostgreSql(this QuartzModelBuilder builder, string prefix = "qrtz_", string? schema = "quartz")
     {
       builder.UseEntityTypeConfigurations(context =>
       {

src/AppAny.Quartz.EntityFrameworkCore.Migrations.PostgreSQL/QuartzModelBuilderPostgreSQLExtensions.cs

@@ -2,7 +2,7 @@ namespace AppAny.Quartz.EntityFrameworkCore.Migrations.SqlServer
 {
   public static class QuartzModelBuilderSqlServerExtensions
   {
-    public static QuartzModelBuilder UseSqlServer(this QuartzModelBuilder builder, string prefix = "QRTZ_", string schema = "quartz")
+    public static QuartzModelBuilder UseSqlServer(this QuartzModelBuilder builder, string prefix = "QRTZ_", string? schema = "quartz")
     {
       builder.UseEntityTypeConfigurations(context =>
       {

src/AppAny.Quartz.EntityFrameworkCore.Migrations.SqlServer/QuartzModelBuilderSqlServerExtensions.cs

@@ -22,8 +22,11 @@
 
   <ItemGroup Label="xUnit">
     <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.1.0-preview-20211130-02" />
+    <PackageReference Include="MySql.Data" Version="8.0.31" />
     <PackageReference Include="Quartz" Version="3.5.0" />
     <PackageReference Include="Quartz.Serialization.Json" Version="3.5.0" />
+    <PackageReference Include="TestEnvironment.Docker.Containers.Postgres" Version="2.1.5" />
+    <PackageReference Include="TestEnvironment.Docker.Containers.Mssql" Version="2.1.6" />
     <PackageReference Include="xunit" Version="2.4.2-pre.12" />
     <PackageReference Include="xunit.runner.visualstudio" Version="2.4.3">
       <PrivateAssets>all</PrivateAssets>

tests/AppAny.Quartz.EntityFrameworkCore.Migrations.Tests/AppAny.Quartz.EntityFrameworkCore.Migrations.Tests.csproj

@@ -0,0 +1,74 @@
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using TestEnvironment.Docker;
+using TestEnvironment.Docker.Containers.Mssql;
+using TestEnvironment.Docker.Containers.Postgres;
+using Xunit;
+
+namespace AppAny.Quartz.EntityFrameworkCore.Migrations.Tests.Base
+{
+  public class TestFixture : IAsyncLifetime
+  {
+    private const string SQL_SA_PASSWORD = "Admin1234.";
+    private const string MYSQL_ROOT_PASSWORD = "password";
+
+    private readonly IDockerEnvironment _dockerEnvironment = new DockerEnvironmentBuilder()
+      .AddPostgresContainer(
+        p => p with
+        {
+          Name = "postgres"
+        })
+      .AddContainer(
+        p => p with
+        {
+          ImageName = "mysql",
+          Name = "mysql",
+          EnvironmentVariables = new Dictionary<string, string>
+          {
+            { "MYSQL_ROOT_PASSWORD", MYSQL_ROOT_PASSWORD }
+          },
+          ExposedPorts = new List<ushort>
+          {
+            3306
+          }
+        })
+      .AddMssqlContainer(
+        p => p with
+        {
+          Name = "sqlserver",
+          ImageName = "mcr.microsoft.com/azure-sql-edge",
+          SAPassword = SQL_SA_PASSWORD
+        })
+      .Build();
+
+    public string PostgreSqlConnectionString { get; private set; } = null!;
+    public string SqlServerConnectionString { get; private set; } = null!;
+    public string MySqlConnectionString { get; private set; } = null!;
+
+    public async Task InitializeAsync()
+    {
+      await _dockerEnvironment.UpAsync();
+
+      // set connection string for integration tests
+      PostgreSqlConnectionString =
+        _dockerEnvironment.GetContainer<PostgresContainer>("postgres")!.GetConnectionString();
+
+      MySqlConnectionString =
+        $"server=localhost; port={_dockerEnvironment.GetContainer("mysql")!.Ports![3306]}; database=test; uid=root; pwd=password;";
+
+      SqlServerConnectionString =
+        $"{_dockerEnvironment.GetContainer<MssqlContainer>("sqlserver")!.GetConnectionString()}Initial catalog=test";
+    }
+
+    public async Task DisposeAsync()
+    {
+      await _dockerEnvironment.DownAsync();
+      await _dockerEnvironment.DisposeAsync();
+    }
+
+    [CollectionDefinition(nameof(ClientCollection))]
+    public class ClientCollection : ICollectionFixture<TestFixture>
+    {
+    }
+  }
+}

tests/AppAny.Quartz.EntityFrameworkCore.Migrations.Tests/Base/ConnectionStrings.cs

@@ -0,0 +1,64 @@
+using System;
+using System.Threading.Tasks;
+using AppAny.Quartz.EntityFrameworkCore.Migrations.Tests.Base;
+using Microsoft.EntityFrameworkCore;
+using Quartz;
+using Xunit;
+
+namespace AppAny.Quartz.EntityFrameworkCore.Migrations.Tests.MySQL
+{
+  [Collection(nameof(TestFixture.ClientCollection))]
+  public class MySqlIntegrationDbContextIntegrationTests : IDisposable
+  {
+    private readonly MySqlIntegrationDbContext _dbContext;
+    private readonly string _connectionString;
+
+    public MySqlIntegrationDbContextIntegrationTests(TestFixture testFixture)
+    {
+      _connectionString = testFixture.MySqlConnectionString;
+
+      var options = new DbContextOptionsBuilder<MySqlIntegrationDbContext>()
+        .UseMySql(
+          _connectionString,
+          ServerVersion.AutoDetect(testFixture.MySqlConnectionString))
+        .Options;
+
+      _dbContext = new MySqlIntegrationDbContext(options);
+    }
+
+    [Fact]
+    public async Task ShouldBuildScheduler()
+    {
+      // Arrange
+      await _dbContext.Database.EnsureCreatedAsync();
+      await _dbContext.Database.MigrateAsync();
+
+      // Act
+      var scheduler = await SchedulerBuilder.Create()
+        .UseDefaultThreadPool(x => x.MaxConcurrency = 5)
+        .UsePersistentStore(
+          x =>
+          {
+            x.PerformSchemaValidation = true;
+            x.UseMySql(_connectionString);
+            x.UseJsonSerializer();
+          })
+        .BuildScheduler();
+
+      var exception = await Record.ExceptionAsync(async () => await scheduler.Start());
+
+      // Assert
+      Assert.Null(exception);
+      Assert.True(scheduler.IsStarted);
+
+      await scheduler.Shutdown();
+      Assert.True(scheduler.IsShutdown);
+    }
+
+    public void Dispose()
+    {
+      _dbContext.Database.EnsureDeleted();
+      _dbContext.Dispose();
+    }
+  }
+}