add thread support

Author: rebornix

src/main.ts

@@ -113,20 +113,11 @@ class MockDebugSession extends DebugSession {
 		for (var i = 0; i < clientLines.length; i++) {
 			var l = this.convertClientLineToDebugger(clientLines[i]);
 			var verified = false;
+
 			if (l < lines.length) {
-				const line = lines[l-1].trim();
-				// if a line is empty or starts with '+' we don't allow to set a breakpoint but move the breakpoint down
-				if (line.length == 0 || line.indexOf("+") == 0)
-					l++;
-				// if a line starts with '-' we don't allow to set a breakpoint but move the breakpoint up
-				if (line.indexOf("-") == 0)
-					l--;
-				// don't set 'verified' to true if the line contains the word 'lazy'
-				// in this case the breakpoint will be verified 'lazy' after hitting it once.
-				if (line.indexOf("lazy") < 0) {
-					verified = true;    // this breakpoint has been validated
-				}
+				verified = true;    // this breakpoint has been validated
 			}
+
 			const bp = <DebugProtocol.Breakpoint> new Breakpoint(verified, this.convertDebuggerLineToClient(l));
 			bp.id = this._breakpointId++;
 			var command = ["break", "test.rb:"+bp.line];
@@ -144,13 +135,23 @@ class MockDebugSession extends DebugSession {
 
 	protected threadsRequest(response: DebugProtocol.ThreadsResponse): void {
 
-		// return the default thread
-		response.body = {
-			threads: [
-				new Thread(MockDebugSession.THREAD_ID, "thread 1")
-			]
-		};
-		this.sendResponse(response);
+		this.rubyProcess.Enqueue("thread list\n").then((xml: XMLDocument) => {
+			if (xml.documentElement.nodeName !== "threads") {
+				return;
+			}
+
+			var threads = new Array<Thread>();
+			for(let i= 0; i < xml.documentElement.childNodes.length; i++) {
+				var threadNode = xml.documentElement.childNodes.item(i);
+				var threadId = threadNode.attributes.getNamedItem("id");
+
+				threads.push(new Thread(+threadId.value, "thread_"+threadId.value));
+			}
+			response.body = {
+				threads: threads
+			};
+			this.sendResponse(response);
+		});
 	}
 
 	// Called by VS Code after a StoppedEvent

src/ruby.ts

@@ -99,7 +99,8 @@ export class RubyProcess extends EventEmitter {
 				(/^<variables>/.test(chunk) && !/<\/variables>$/.test(chunk)) ||
 				(/^<variable .*?\/>$/.test(chunk) && this.buffer !== "") ||
 				(/^<breakpoints>/.test(chunk) && !/<\/breakpoints>$/.test(chunk)) ||
-				(/^<breakpoint .*?\/>$/.test(chunk) && this.buffer !== "")
+				(/^<breakpoint .*?\/>$/.test(chunk) && this.buffer !== "") ||
+				(/^<threads>/.test(chunk) && !/\/threads>$/.test(chunk))
 			) {
 				that.buffer += chunk;
 				return;
@@ -110,10 +111,17 @@ export class RubyProcess extends EventEmitter {
 				that.buffer += chunk;
 				return;
 			}
+			else if (
+				(/^<thread .*?>$/.test(chunk) && !/<\/threads>$/.test(chunk)) ||
+				/<\/thread>$/.test(chunk)
+			) {
+				that.buffer += chunk;
+			}
 			else if (
 				/<\/frames>$/.test(chunk) ||
 				/<\/variables>$/.test(chunk) ||
-				/<\/breakpoints>$/.test(chunk)
+				/<\/breakpoints>$/.test(chunk) ||
+				/<\/threads>$/.test(chunk)
 			) {
 				that.buffer = that.buffer + chunk;
 				if (/<\/frames>$/.test(chunk)) {
@@ -124,6 +132,10 @@ export class RubyProcess extends EventEmitter {
 					document = that.parser.parseFromString(that.buffer, 'application/xml');
 					that.FinishCmd(document);
 				}
+				else if (/<\/threads>$/.test(chunk)) {
+					document = that.parser.parseFromString(that.buffer, 'application/xml');
+					that.FinishCmd(document);
+				}
 				that.buffer = "";
 			}
 		});