fixup! Introduce Kotlin integration tests

Signed-off-by: Sergey Karpov <[email protected]>

Author: skarpovdev

kotlin-sdk-test/src/jvmTest/kotlin/io/modelcontextprotocol/kotlin/sdk/integration/typescript/KotlinClientTypeScriptServerEdgeCasesTest.kt

@@ -51,7 +51,7 @@ class KotlinClientTypeScriptServerEdgeCasesTest : TypeScriptTestBase() {
         if (::tsServerProcess.isInitialized) {
             try {
                 println("Stopping TypeScript server")
-                stopProcess(tsServerProcess, 3, "TypeScript server")
+                stopProcess(tsServerProcess)
             } catch (e: Exception) {
                 println("Warning: Error during TypeScript server stop: ${e.message}")
             }

kotlin-sdk-test/src/jvmTest/kotlin/io/modelcontextprotocol/kotlin/sdk/integration/typescript/KotlinClientTypeScriptServerTest.kt

@@ -56,7 +56,7 @@ class KotlinClientTypeScriptServerTest : TypeScriptTestBase() {
         if (::tsServerProcess.isInitialized) {
             try {
                 println("Stopping TypeScript server")
-                stopProcess(tsServerProcess, 3, "TypeScript server")
+                stopProcess(tsServerProcess)
             } catch (e: Exception) {
                 println("Warning: Error during TypeScript server stop: ${e.message}")
             }

kotlin-sdk-test/src/jvmTest/kotlin/io/modelcontextprotocol/kotlin/sdk/integration/typescript/TypeScriptClientKotlinServerTest.kt

@@ -22,7 +22,7 @@ class TypeScriptClientKotlinServerTest : TypeScriptTestBase() {
         killProcessOnPort(port)
         httpServer = KotlinServerForTypeScriptClient()
         httpServer?.start(port)
-        if (!waitForPort("localhost", port, 10)) {
+        if (!waitForPort(port = port)) {
             throw IllegalStateException("Kotlin test server did not become ready on localhost:$port within timeout")
         }
         println("Kotlin server started on port $port")

kotlin-sdk-test/src/jvmTest/kotlin/io/modelcontextprotocol/kotlin/sdk/integration/typescript/TypeScriptEdgeCasesTest.kt

@@ -23,7 +23,7 @@ class TypeScriptEdgeCasesTest : TypeScriptTestBase() {
         killProcessOnPort(port)
         httpServer = KotlinServerForTypeScriptClient()
         httpServer?.start(port)
-        if (!waitForPort("localhost", port, 10)) {
+        if (!waitForPort(port = port)) {
             throw IllegalStateException("Kotlin test server did not become ready on localhost:$port within timeout")
         }
         println("Kotlin server started on port $port")

kotlin-sdk-test/src/jvmTest/kotlin/io/modelcontextprotocol/kotlin/sdk/integration/typescript/TypeScriptTestBase.kt

@@ -107,7 +107,7 @@ abstract class TypeScriptTestBase {
         return true
     }
 
-    protected fun createProcessOutputReader(process: Process, prefix: String): Thread {
+    protected fun createProcessOutputReader(process: Process, prefix: String = "TS-SERVER"): Thread {
         val outputReader = Thread {
             try {
                 process.inputStream.bufferedReader().useLines { lines ->
@@ -123,7 +123,7 @@ abstract class TypeScriptTestBase {
         return outputReader
     }
 
-    protected fun waitForPort(host: String, port: Int, timeoutSeconds: Long = 10): Boolean {
+    protected fun waitForPort(host: String = "localhost", port: Int, timeoutSeconds: Long = 10): Boolean {
         val deadline = System.currentTimeMillis() + timeoutSeconds * 1000
         while (System.currentTimeMillis() < deadline) {
             try {
@@ -145,14 +145,14 @@ abstract class TypeScriptTestBase {
             .directory(sdkDir)
             .redirectErrorStream(true)
         val process = processBuilder.start()
-        if (!waitForPort("localhost", port, 10)) {
+        if (!waitForPort(port = port)) {
             throw IllegalStateException("TypeScript server did not become ready on localhost:$port within timeout")
         }
-        createProcessOutputReader(process, "TS-SERVER").start()
+        createProcessOutputReader(process).start()
         return process
     }
 
-    protected fun stopProcess(process: Process, waitSeconds: Long = 3, name: String = "process") {
+    protected fun stopProcess(process: Process, waitSeconds: Long = 3, name: String = "TypeScript server") {
         process.destroy()
         if (waitForProcessTermination(process, waitSeconds)) {
             println("$name stopped gracefully")