From 797aa97e19bbb7b9536e2a7da03012e2db018d23 Mon Sep 17 00:00:00 2001
From: Ryan Dahl <ry@tinyclouds.org>
Date: Tue, 21 Dec 2010 22:31:30 -0800
Subject: [PATCH] Fix test-debugger-client

---
 lib/_debugger.js                    |  7 ++-
 test/simple/test-debugger-client.js | 66 +++++++++++++++--------------
 2 files changed, 37 insertions(+), 36 deletions(-)

diff --git a/lib/_debugger.js b/lib/_debugger.js
index 9f95e896ce..5c0dd55501 100644
--- a/lib/_debugger.js
+++ b/lib/_debugger.js
@@ -131,17 +131,16 @@ exports.Client = Client;
 
 
 Client.prototype._onResponse = function(res) {
-  console.error(res);
   for (var i = 0; i < this._reqCallbacks.length; i++) {
     var cb = this._reqCallbacks[i];
     if (this._reqCallbacks[i].request_seq == cb.request_seq) break;
   }
 
-  if (cb) {
+  if (res.headers.Type == 'connect') {
+    // do nothing
+  } else if (cb) {
     this._reqCallbacks.splice(i, 1);
     cb(res.body);
-  } else if (res.headers.Type == 'connect') {
-    // do nothing
   } else {
     console.error("unhandled res: %j", res.body);
   }
diff --git a/test/simple/test-debugger-client.js b/test/simple/test-debugger-client.js
index a070b7aa15..5239430d40 100644
--- a/test/simple/test-debugger-client.js
+++ b/test/simple/test-debugger-client.js
@@ -1,12 +1,12 @@
 var common = require('../common');
 var assert = require('assert');
-var d = require('_debugger');
+var debug = require('_debugger');
 
 var spawn = require('child_process').spawn;
 
 
 var resCount = 0;
-var p = new d.Protocol();
+var p = new debug.Protocol();
 p.onResponse = function (res) {
   resCount++;
 };
@@ -18,46 +18,48 @@ p.execute("Type: connect\r\n" +
           "Content-Length: 0\r\n\r\n");
 assert.equal(1, resCount);
 
-var n = spawn(process.execPath,
-              ['-e', 'setInterval(function () { console.log("blah"); }, 1000);']);
 
+var connectCount = 0;
 
-var connected = false;
+function test(cb) {
+  var nodeProcess = spawn(process.execPath,
+      ['-e', 'setInterval(function () { console.log("blah"); }, 1000);']);
 
-n.stdout.once('data', function () {
-  console.log("new node process: %d", n.pid);
-  process.kill(n.pid, "SIGUSR1");
-  console.log("signaling it with SIGUSR1");
-
-});
+  nodeProcess.stdout.once('data', function () {
+    console.log("new node process: %d", nodeProcess.pid);
+    process.kill(nodeProcess.pid, "SIGUSR1");
+    console.log("signaling it with SIGUSR1");
+  });
 
-var didTryConnect = false;
-n.stderr.setEncoding('utf8');
-n.stderr.on('data', function (d) {
-  if (didTryConnect == false && /debugger/.test(d)) {
-    didTryConnect = true;
-    tryConnect();
-  }
-})
-
-
-function tryConnect() {
-  // Wait for some data before trying to connect
-  var c = new d.Client();
-  process.stdout.write("connecting...");
-  c.connect(d.port, function () {
-    connected = true;
-    console.log("connected!");
+  var didTryConnect = false;
+  nodeProcess.stderr.setEncoding('utf8');
+  nodeProcess.stderr.on('data', function (data) {
+    if (didTryConnect == false && /debugger/.test(data)) {
+      didTryConnect = true;
+
+      // Wait for some data before trying to connect
+      var c = new debug.Client();
+      process.stdout.write("connecting...");
+      c.connect(debug.port, function () {
+        connectCount++;
+        console.log("connected!");
+        cb(c, nodeProcess);
+      });
+    }
   });
+}
 
-  c.reqVersion(function (v) {
+
+test(function (client, nodeProcess) {
+  client.reqVersion(function (v) {
+    console.log("version: %s", v);
     assert.equal(process.versions.v8, v);
-    n.kill();
+    nodeProcess.kill();
   });
-}
+});
 
 
 process.on('exit', function() {
-  assert.ok(connected);
+  assert.equal(1, connectCount);
 });