add file lock test

Signed-off-by: imanushin <[email protected]>

gradle/libs.versions.toml

@@ -27,6 +27,8 @@ spekDsl = { module = "org.spekframework.spek2:spek-dsl-jvm", version.ref = "spek
 spekRunner = { module = "org.spekframework.spek2:spek-runner-junit5", version.ref = "spek" }
 junitEngine = { module = "org.junit.jupiter:junit-jupiter-engine", version.ref = "junit" }
 junit = { module = "org.junit.jupiter:junit-jupiter", version.ref = "junit" }
+coroutinesCore = { module = "org.jetbrains.kotlinx:kotlinx-coroutines-core", version = "1.7.3" }
+
 
 [plugins]
 detekt = { id = "io.gitlab.arturbosch.detekt", version = "1.23.0" }

helm-plugin/build.gradle.kts

@@ -22,6 +22,7 @@ dependencies {
 
     testImplementation(libs.okHttpMockWebServer)
 
+    testImplementation(libs.coroutinesCore)
     testImplementation(libs.unbrokenDomeTestUtils)
     testImplementation(libs.bundles.defaultTests)
     testRuntimeOnly(libs.junitEngine)

helm-plugin/src/test/kotlin/com/citi/gradle/plugins/helm/util/FileLockTest.kt

@@ -0,0 +1,55 @@
+package com.citi.gradle.plugins.helm.util
+
+import io.kotest.matchers.equals.shouldBeEqual
+import java.io.File
+import kotlinx.coroutines.CompletableDeferred
+import kotlinx.coroutines.async
+import kotlinx.coroutines.awaitAll
+import kotlinx.coroutines.runBlocking
+import org.junit.jupiter.api.BeforeEach
+import org.junit.jupiter.api.Disabled
+import org.junit.jupiter.api.Test
+import org.junit.jupiter.api.io.TempDir
+
+internal class FileLockTest {
+    @TempDir
+    private lateinit var tempFolder: File
+
+    private lateinit var fileToLock: File
+
+    @BeforeEach
+    fun setup() {
+        tempFolder.mkdirs()
+        fileToLock = File(tempFolder, "text.txt")
+        fileToLock.createNewFile()
+    }
+
+    @Test
+    @Disabled
+    fun twoFunctionsArentAbleToUpdateFile() {
+        runBlocking {
+            val thread2IsReady = CompletableDeferred<Unit>()
+
+            val taskIndices = 0..99
+
+            val parallelTasks = taskIndices.map { taskIndex ->
+                async {
+                    withLockFile(fileToLock) {
+                        // don't start until all tasks have been created
+                        runBlocking {
+                            thread2IsReady.await()
+                        }
+
+                        taskIndex
+                    }
+                }
+            }
+
+            thread2IsReady.complete(Unit)
+
+            val taskResults = parallelTasks.awaitAll().toSet()
+
+            taskResults shouldBeEqual taskIndices.toSet()
+        }
+    }
+}