test for request end

listeners/http-server-request-end.js

@@ -1,15 +1,15 @@
 /// http-server-request-end
 
 module.exports =
-function listener(res, time, timeDiff) {
+function listener(req, time, timeDiff) {
   return {
     event: 'http-server-request-end',
     time: time,
     timeDiff: timeDiff,
-    method: res.method,
-    path: res.url,
-    headers: res.headers,
-    host: res.headers.host,
-    bytesRead: res.client.bytesRead
+    method: req.method,
+    path: req.url,
+    headers: req.headers,
+    host: req.headers.host,
+    bytesRead: req.client.bytesRead
   };
 };

listeners/http-server-response-end.js

@@ -2,7 +2,6 @@
 
 module.exports =
 function listener(res, time, timeDiff) {
-  console.log('res.statusCode:', res.statusCode);
   var req = res.__req;
   return {
     event: 'http-server-response-end',

tests/http_server.js

@@ -48,6 +48,49 @@ test('emits http-server-request-begin', function(t) {
   });
 });
 
+test('emits http-server-request-end', function(t) {
+  t.plan(8);
+
+  var server = http.createServer();
+  server.on('request', function(req, res) {
+    var d = domain.create();
+
+    d.add(req);
+    d.add(res);
+
+    req.resume();
+    res.end('Hey');
+  });
+  var port = randomPort();
+  server.listen(port);
+
+  var s = S();
+
+  s.on('readable', function() {
+    var event = s.read();
+    if (event && event.event == 'http-server-request-end') {
+      t.type(event.time, 'number');
+      t.ok(event.timeDiff >= 0);
+      t.equal(event.method, 'GET');
+      t.equal(event.path, '/abcdef?abc=def');
+      t.equal(event.host, 'localhost:' + port);
+      t.type(event.headers, 'object');
+      t.type(event.bytesRead, 'number');
+      t.ok(event.bytesRead > 0);
+    }
+  });
+
+  server.once('listening', function(err) {
+    if (err) throw err;
+    http.get('http://localhost:' + port + '/abcdef?abc=def', function(res) {
+      res.resume();
+      res.once('end', function() {
+        server.close();
+      });
+    });
+  });
+});
+
 test('emits http-server-response-end', function(t) {
   t.plan(7);