add fixture to tests

src/test/kotlin/RunCucumberTest.kt

@@ -4,19 +4,31 @@ import cucumber.api.java8.En
 import cucumber.api.junit.Cucumber
 import feature.Context
 import fr.dcproject.config
+import fr.dcproject.utils.LoggerDelegate
+import fr.postgresjson.connexion.Connection
+import fr.postgresjson.connexion.Requester
 import fr.postgresjson.migration.Migrations
+import io.ktor.locations.KtorExperimentalLocationsAPI
 import io.ktor.server.testing.TestApplicationEngine
 import io.ktor.server.testing.createTestEnvironment
+import io.ktor.util.KtorExperimentalAPI
 import org.junit.runner.RunWith
 import org.koin.test.KoinTest
 import org.koin.test.inject
+import org.slf4j.Logger
 import java.util.concurrent.TimeUnit
 import feature.Context.Companion.current as contextCurrent
 
+var unitialized: Boolean = false
+
+@KtorExperimentalAPI
+@KtorExperimentalLocationsAPI
 @RunWith(Cucumber::class)
 @CucumberOptions(plugin = ["pretty"])
 class RunCucumberTest: En, KoinTest {
-    private val migrations: Migrations  by inject()
+    private val migrations: Migrations by inject()
+    private val connection = Connection("test", "test", "test")
+    private val logger: Logger? by LoggerDelegate()
     init {
         Before(-1) { scenario: Scenario ->
             config.database = "test"
@@ -24,12 +36,38 @@ class RunCucumberTest: En, KoinTest {
             config.password = "test"
             contextCurrent = Context(TestApplicationEngine(createTestEnvironment()) {}, scenario)
 
-            migrations.run()
+            beforeAll()
+
+            logger?.info("Fixtures Begin")
+            //language=PostgreSQL
+            connection.sendQuery("""truncate table "user" cascade;""")
+            //language=PostgreSQL
+            connection.sendQuery("""SET fixture.quantity.multiple = '50';""")
+            getFixturesRequester()
+                .getQueries()
+                .sortedBy { it.name }
+                .forEach { it.exec() }
+            logger?.info("Fixtures Done")
         }
 
-        After { scenario: Scenario ->
-            migrations.forceAllDown()
+        After { _: Scenario ->
             contextCurrent.engine.stop(0L, 0L, TimeUnit.MILLISECONDS)
         }
     }
+
+    private fun beforeAll()
+    {
+        if (!unitialized) {
+            migrations.forceAllDown()
+            migrations.run()
+            unitialized = true
+        }
+    }
+
+    private fun getFixturesRequester(): Requester {
+        return Requester.RequesterFactory(
+            connection = connection,
+            queriesDirectory = config.sqlFiles.resolve("fixtures")
+        ).createRequester()
+    }
 }