test(infrastructure): add some mongo tests

Author: andrea-acampora

gradle/libs.versions.toml

@@ -6,6 +6,7 @@ kmongo = "4.8.0"
 
 [libraries]
 archunit = { module = "com.tngtech.archunit:archunit-junit5", version = "1.0.1" }
+embed-mongo = { module = "de.flapdoodle.embed:de.flapdoodle.embed.mongo", version = "4.6.1" }
 azure-digital-twins = { module = "com.azure:azure-digitaltwins-core", version = "1.3.6" }
 azure-identity = { module = "com.azure:azure-identity", version = "1.8.0" }
 kmongo = { module = "org.litote.kmongo:kmongo", version.ref = "kmongo" }
@@ -20,10 +21,9 @@ ktor-content-negotiation = { module = "io.ktor:ktor-server-content-negotiation",
 ktor-serialization = { module = "io.ktor:ktor-serialization-kotlinx-json", version.ref = "ktor" }
 ktor-test = { module = "io.ktor:ktor-server-test-host", version.ref = "ktor" }
 logback = { module = "ch.qos.logback:logback-classic", version = "1.4.5" }
-testcontainer = { module = "org.testcontainers:mongodb", version = "1.17.6" }
 
 [bundles]
-kotlin-testing = ["archunit", "testcontainer", "kotest-junit5", "kotest-assertions-core", "kotest-assertions-core-jvm", "ktor-test"]
+kotlin-testing = ["archunit", "embed-mongo", "kotest-junit5", "kotest-assertions-core", "kotest-assertions-core-jvm", "ktor-test"]
 
 [plugins]
 dokka = { id ="org.jetbrains.dokka", version = "1.7.20" }

src/test/kotlin/infrastructure/database/MongoUtility.kt

@@ -0,0 +1,50 @@
+/*
+ * Copyright (c) 2023. Smart Operating Block
+ *
+ * Use of this source code is governed by an MIT-style
+ * license that can be found in the LICENSE file or at
+ * https://opensource.org/licenses/MIT.
+ */
+
+package infrastructure.database
+
+import de.flapdoodle.embed.mongo.config.Net
+import de.flapdoodle.embed.mongo.distribution.Version
+import de.flapdoodle.embed.mongo.transitions.Mongod
+import de.flapdoodle.os.CommonOS
+import de.flapdoodle.os.ImmutablePlatform
+import de.flapdoodle.os.Platform
+import de.flapdoodle.os.linux.LinuxDistribution
+import de.flapdoodle.os.linux.UbuntuVersion
+import de.flapdoodle.reverse.StateID
+import de.flapdoodle.reverse.transitions.Start
+import de.flapdoodle.net.Net as Network
+
+private inline fun <reified T : Any> T.toTransition() = Start.to(StateID.of(T::class.java)).initializedWith(this)
+
+internal fun withMongo(operation: () -> Unit) {
+    if (System.getProperty("os.name").lowercase().contains("win")) {
+        println("Testing with MongoDB is disabled on Windows due to flaky behavior")
+    } else {
+        runCatching { Platform.detect(CommonOS.list()) }
+            .onFailure { println("Failed to detect platform") }
+            .onSuccess { detectedPlatform ->
+                val platform: Platform = detectedPlatform
+                    .takeUnless { it.operatingSystem() == CommonOS.Linux && it.distribution().isEmpty }
+                    ?: ImmutablePlatform.builder()
+                        .from(detectedPlatform)
+                        .distribution(LinuxDistribution.Ubuntu)
+                        .version(UbuntuVersion.Ubuntu_20_10)
+                        .build()
+                val mongod = Mongod.instance()
+                    .withNet(Net.of("localhost", 27017, Network.localhostIsIPv6()).toTransition())
+                    .withPlatform(platform.toTransition())
+                val runningState = mongod.start(Version.Main.V6_0)
+                try {
+                    operation()
+                } finally {
+                    runningState.current().stop()
+                }
+            }
+    }
+}

src/test/kotlin/infrastructure/database/TestMongo.kt

@@ -0,0 +1,35 @@
+/*
+ * Copyright (c) 2023. Smart Operating Block
+ *
+ * Use of this source code is governed by an MIT-style
+ * license that can be found in the LICENSE file or at
+ * https://opensource.org/licenses/MIT.
+ */
+
+package infrastructure.database
+
+import entity.user.User
+import io.kotest.core.spec.style.StringSpec
+import io.kotest.matchers.shouldBe
+import io.kotest.matchers.shouldNotBe
+
+class TestMongo : StringSpec({
+
+    "Test user operations on mongo db" {
+        withMongo {
+            val mockUser = User("1234", "MockPassword!")
+
+            val mongoClient = MongoClient("mongodb://localhost:27017")
+
+            mongoClient.createUser(mockUser) shouldNotBe null
+
+            mongoClient.deleteUser(mockUser.userId) shouldBe true
+
+            mongoClient.createUser(mockUser) shouldNotBe null
+            mongoClient.getUser(mockUser.userId).also {
+                it shouldNotBe null
+                it?.userId shouldBe mockUser.userId
+            }
+        }
+    }
+})