import cucumber.api.CucumberOptions
import cucumber.api.Scenario
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 connection = Connection("test", "test", "test")
    private val logger: Logger? by LoggerDelegate()
    init {
        Before(-1) { scenario: Scenario ->
            config.database = "test"
            config.username = "test"
            config.password = "test"
            contextCurrent = Context(TestApplicationEngine(createTestEnvironment()) {}, scenario)

            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.sendQuery() }
            logger?.info("Fixtures Done")
        }

        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()
    }
}