Add a simple test for state

Author: chrissearle

build.gradle.kts

@@ -42,6 +42,7 @@ dependencies {
     implementation(libs.bundles.search)
     testImplementation(libs.ktor.server.test.host)
     testImplementation(libs.kotlin.test.junit)
+    testImplementation(libs.mockk)
 }
 
 tasks {

gradle/libs.versions.toml

@@ -12,6 +12,7 @@ arrow_version = "1.2.4"
 search_client_version = "2.3.1"
 kotlinx_serialization_version = "1.7.3"
 node_version = "7.1.0"
+mockk_version = "1.13.13"
 
 [libraries]
 arrow-core = { group = "io.arrow-kt", name = "arrow-core", version.ref = "arrow_version" }
@@ -35,6 +36,7 @@ ktor-client-cio = { group = "io.ktor", name = "ktor-client-cio", version.ref = "
 search-client = { group = "com.jillesvangurp", name = "search-client", version.ref = "search_client_version" }
 kotlinx-serialization = { group = "org.jetbrains.kotlinx", name = "kotlinx-serialization-json", version.ref = "kotlinx_serialization_version" }
 ktor-serialization = { group = "io.ktor", name = "ktor-serialization-kotlinx-json", version.ref = "ktor_version" }
+mockk = { group = "io.mockk", name="mockk", version.ref = "mockk_version" }
 
 [bundles]
 monitoring = ["ktor-server-metrics-micrometer", "micrometer-registry-prometheus", "ktor-server-call-id", "ktor-server-call-logging"]

src/main/kotlin/no/java/conf/plugins/Monitoring.kt

@@ -2,7 +2,6 @@ package no.java.conf.plugins
 
 import io.ktor.http.HttpHeaders
 import io.ktor.server.application.Application
-import io.ktor.server.application.call
 import io.ktor.server.application.install
 import io.ktor.server.metrics.micrometer.MicrometerMetrics
 import io.ktor.server.plugins.callid.CallId

src/test/kotlin/no/java/conf/ApplicationTest.kt

@@ -0,0 +1,104 @@
+package no.java.conf
+
+import com.jillesvangurp.ktsearch.SearchClient
+import io.ktor.client.request.get
+import io.ktor.client.statement.bodyAsText
+import io.ktor.http.HttpStatusCode
+import io.ktor.server.testing.testApplication
+import io.mockk.every
+import io.mockk.mockk
+import kotlinx.coroutines.runBlocking
+import no.java.conf.plugins.configureSearchRouting
+import no.java.conf.service.SearchService
+import kotlin.test.Test
+import kotlin.test.assertEquals
+import kotlin.test.assertTrue
+
+class StateTest {
+    @Test
+    fun testNewState() {
+        val searchClient = mockk<SearchClient>()
+
+        val service = SearchService(searchClient, false)
+
+        testApplication {
+
+            application {
+                configureSearchRouting(service)
+            }
+
+            client.get("/api/search/state").apply {
+                assertEquals(HttpStatusCode.OK, status)
+                assertEquals(bodyAsText(), "NEW")
+            }
+        }
+    }
+
+
+    @Test
+    fun testSkipIndex() {
+        val searchClient = mockk<SearchClient>()
+
+        val service = SearchService(searchClient, true)
+
+        testApplication {
+
+            application {
+                configureSearchRouting(service)
+            }
+
+            client.get("/api/search/state").apply {
+                assertEquals(HttpStatusCode.OK, status)
+                assertEquals(bodyAsText(), "NEW")
+            }
+        }
+    }
+
+    @Test
+    fun testSkipIndexMapped() {
+        val searchClient = mockk<SearchClient>()
+
+        val service = SearchService(searchClient, true)
+
+        runBlocking {
+            service.setup()
+        }
+
+        testApplication {
+
+            application {
+                configureSearchRouting(service)
+            }
+
+            client.get("/api/search/state").apply {
+                assertEquals(HttpStatusCode.OK, status)
+                assertEquals(bodyAsText(), "MAPPED")
+            }
+        }
+    }
+
+
+    @Test
+    fun testSkipIndexIndexed() {
+        val searchClient = mockk<SearchClient>()
+
+        val service = SearchService(searchClient, true)
+
+        runBlocking {
+            service.setup()
+            service.ingest(emptyList())
+        }
+
+        testApplication {
+
+            application {
+                configureSearchRouting(service)
+            }
+
+            client.get("/api/search/state").apply {
+                assertEquals(HttpStatusCode.OK, status)
+                assertEquals(bodyAsText(), "INDEXED")
+            }
+        }
+    }
+}