Attach thread event reasons and thread ids

Author: fwcd

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

@@ -146,6 +146,9 @@ class KotlinDebugAdapter(
 		eventBus.exceptionListeners.add {
 			exceptionsPool.store(it.threadID, it.exception)
 			sendStopEvent(it.threadID, StoppedEventArgumentsReason.EXCEPTION)
+		}
+		eventBus.threadListeners.add {
+			
 		}
 		stdoutAsync.execute {
 			debuggee.stdout?.let { pipeStreamToOutput(it, OutputEventArgumentsCategory.STDOUT) }

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

@@ -1,3 +1,3 @@
 package org.javacs.ktda.core.event
 
-class ExitEvent
+object ExitEvent

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

@@ -1,3 +1,6 @@
 package org.javacs.ktda.core.event
 
-object ThreadEvent
+class ThreadEvent(
+    val threadID: Long,
+    val reason: ThreadEventReason
+)

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

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

adapter/src/main/kotlin/org/javacs/ktda/jdi/event/VMEventBus.kt

@@ -10,6 +10,7 @@ import org.javacs.ktda.core.event.BreakpointStopEvent
 import org.javacs.ktda.core.event.ExceptionStopEvent
 import org.javacs.ktda.core.event.StepStopEvent
 import org.javacs.ktda.core.event.ThreadEvent
+import org.javacs.ktda.core.event.ThreadEventReason
 import org.javacs.ktda.jdi.exception.JDIException
 import com.sun.jdi.VirtualMachine
 import com.sun.jdi.VMDisconnectedException
@@ -71,7 +72,7 @@ class VMEventBus(private val vm: VirtualMachine): DebuggeeEventBus {
 			} catch (e: VMDisconnectedException) {
 				LOG.info("VMEventBus event poller terminated by disconnect: {}", e.message)
 			}
-			exitListeners.fire(ExitEvent())
+			exitListeners.fire(ExitEvent)
 		}, "eventBus").start()
 	}
 
@@ -96,10 +97,16 @@ class VMEventBus(private val vm: VirtualMachine): DebuggeeEventBus {
 			it.resumeThreads = false
 		}
 		subscribe(JDIThreadStartEvent::class) {
-			threadListeners.fire(ThreadEvent)
+			threadListeners.fire(ThreadEvent(
+				threadID = it.jdiEvent.thread().uniqueID(),
+				reason = ThreadEventReason.STARTED
+			))
 		}
 		subscribe(JDIThreadDeathEvent::class) {
-			threadListeners.fire(ThreadEvent)
+			threadListeners.fire(ThreadEvent(
+				threadID = it.jdiEvent.thread().uniqueID(),
+				reason = ThreadEventReason.STOPPED
+			))
 		}
 	}