Rewrite StreamGobbler

diktat-test-framework/build.gradle.kts

@@ -11,6 +11,7 @@ dependencies {
     implementation(libs.apache.commons.cli)
     implementation(libs.apache.commons.io)
     implementation(libs.kotlin.logging)
+    implementation(libs.kotlinx.coroutines.core)
     implementation(libs.kotlin.multiplatform.diff)
     testImplementation(libs.junit.jupiter)
     testImplementation(libs.assertj.core)

diktat-test-framework/src/main/kotlin/com/saveourtool/diktat/test/framework/common/LocalCommandExecutor.kt

@@ -1,8 +1,15 @@
 package com.saveourtool.diktat.test.framework.common
 
 import mu.KotlinLogging
-
 import java.io.IOException
+import java.io.InputStream
+import java.nio.charset.Charset
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.flow
+import kotlinx.coroutines.flow.flowOn
+import kotlinx.coroutines.flow.toList
+import kotlinx.coroutines.runBlocking
 
 /**
  * Class that wraps shell [command] and can execute it
@@ -18,17 +25,12 @@ class LocalCommandExecutor internal constructor(private val command: String) {
             log.info { "Executing command: $command" }
             val process = Runtime.getRuntime().exec(command)
             process.outputStream.close()
-            val inputStream = process.inputStream
-            val outputGobbler = StreamGobbler(inputStream, "OUTPUT") { msg, ex ->
-                log.error(ex, msg)
-            }
-            outputGobbler.start()
-            val errorStream = process.errorStream
-            val errorGobbler = StreamGobbler(errorStream, "ERROR") { msg, ex ->
-                log.error(ex, msg)
+            return runBlocking(Dispatchers.IO) {
+                ExecutionResult(
+                    process.inputStream.readLinesAsync("OUTPUT").toList(),
+                    process.errorStream.readLinesAsync("ERROR").toList(),
+                )
             }
-            errorGobbler.start()
-            return ExecutionResult(outputGobbler.content, errorGobbler.content)
         } catch (ex: IOException) {
             log.error("Execution of $command failed", ex)
         }
@@ -37,5 +39,17 @@ class LocalCommandExecutor internal constructor(private val command: String) {
 
     companion object {
         private val log = KotlinLogging.logger {}
+
+        fun InputStream.readLinesAsync(streamType: String): Flow<String> = flow {
+                try {
+                    val bufferedReader = [email protected](Charset.defaultCharset())
+                    while (true) {
+                        val line = bufferedReader.readLine() ?: break
+                        emit(line)
+                    }
+                } catch (ex: IOException) {
+                    log.error(ex) { "Failed to consume and display the input stream of type $streamType." }
+                }
+            }.flowOn(Dispatchers.IO)
     }
 }

gradle/libs.versions.toml

@@ -39,7 +39,7 @@ save-cli = "0.3.9"
 ktor = "2.2.4"
 okio = "3.3.0"
 kotlinx-datetime = "0.4.0"
-kotlinx-coroutines = "1.6.4"
+kotlinx-coroutines = "1.7.1"
 assertj = "3.24.2"
 diktat = "2.0.0"
 jgit = "6.5.0.202303070854-r"
@@ -102,6 +102,9 @@ kotlinx-serialization-json-jvm = { module = "org.jetbrains.kotlinx:kotlinx-seria
 # another serialization
 kaml = { module = "com.charleskorn.kaml:kaml", version.ref = "kaml" }
 
+# kotlinx coroutines
+kotlinx-coroutines-core = { module = "org.jetbrains.kotlinx:kotlinx-coroutines-core", version.ref = "kotlinx-coroutines" }
+
 #kotlin libs
 kotlin-multiplatform-diff = { module = "io.github.petertrr:kotlin-multiplatform-diff", version.ref = "kotlin-multiplatform-diff" }