Propagate thread events to the client

Author: fwcd

adapter/src/main/kotlin/org/javacs/ktda/adapter/DAPConverter.kt

@@ -18,6 +18,7 @@ private typealias DAPExceptionBreakpointsFilter = org.eclipse.lsp4j.debug.Except
 private typealias DAPCompletionItem = org.eclipse.lsp4j.debug.CompletionItem
 private typealias DAPCompletionItemType = org.eclipse.lsp4j.debug.CompletionItemType
 private typealias DAPExceptionDetails = org.eclipse.lsp4j.debug.ExceptionDetails
+private typealias DAPThreadEventReason = org.eclipse.lsp4j.debug.ThreadEventArgumentsReason
 private typealias InternalSource = org.javacs.ktda.core.Source
 private typealias InternalSourceBreakpoint = org.javacs.ktda.core.breakpoint.SourceBreakpoint
 private typealias InternalExceptionBreakpoint = org.javacs.ktda.core.breakpoint.ExceptionBreakpoint
@@ -26,6 +27,7 @@ private typealias InternalStackFrame = org.javacs.ktda.core.stack.StackFrame
 private typealias InternalCompletionItem = org.javacs.ktda.core.completion.CompletionItem
 private typealias InternalCompletionItemType = org.javacs.ktda.core.completion.CompletionItemType
 private typealias InternalException = org.javacs.ktda.core.exception.DebuggeeException
+private typealias InternalThreadEventReason = org.javacs.ktda.core.event.ThreadEventReason
 
 /**
  * Handles conversions between debug adapter types
@@ -137,4 +139,9 @@ class DAPConverter(
 		stackTrace = internalException.stackTrace
 		innerException = internalException.innerException?.let(::toDAPExceptionDetails)?.let { arrayOf(it) }
 	}
+
+	fun toDAPThreadEventReason(reason: InternalThreadEventReason): String = when (reason) {
+		InternalThreadEventReason.STARTED -> DAPThreadEventReason.STARTED
+		InternalThreadEventReason.STOPPED -> DAPThreadEventReason.EXITED
+	}
 }

adapter/src/main/kotlin/org/javacs/ktda/adapter/KotlinDebugAdapter.kt

@@ -148,7 +148,7 @@ class KotlinDebugAdapter(
 			sendStopEvent(it.threadID, StoppedEventArgumentsReason.EXCEPTION)
 		}
 		eventBus.threadListeners.add {
-			
+			sendThreadEvent(it.threadID, converter.toDAPThreadEventReason(it.reason))
 		}
 		stdoutAsync.execute {
 			debuggee.stdout?.let { pipeStreamToOutput(it, OutputEventArgumentsCategory.STDOUT) }
@@ -171,6 +171,13 @@ class KotlinDebugAdapter(
 			}
 		}
 	}
+
+	private fun sendThreadEvent(threadId: Long, reason: String) {
+		client!!.thread(ThreadEventArguments().also {
+			it.reason = reason
+			it.threadId = threadId
+		})
+	}
 
 	private fun sendStopEvent(threadId: Long, reason: String) {
 		client!!.stopped(StoppedEventArguments().also {

adapter/src/main/kotlin/org/javacs/ktda/core/event/ThreadEventReason.kt

@@ -1,6 +1,6 @@
 package org.javacs.ktda.core.event
 
-enum class ThreadEventReason(val value: String) {
-    STARTED("started"),
-    STOPPED("stopped")
+enum class ThreadEventReason {
+    STARTED,
+    STOPPED
 }