http: added closed property

doc/api/http.md

@@ -553,6 +553,15 @@ changes:
 The `request.aborted` property will be `true` if the request has
 been aborted.
 
+### request.closed
+<!-- YAML
+added: CHANGEME
+-->
+
+* {boolean}
+
+The `request.closed` property indicates whether the request has been closed.
+
 ### request.connection
 <!-- YAML
 added: v0.3.0
@@ -1130,6 +1139,15 @@ response.end();
 Attempting to set a header field name or value that contains invalid characters
 will result in a [`TypeError`][] being thrown.
 
+### response.closed
+<!-- YAML
+added: CHANGEME
+-->
+
+* {boolean}
+
+The `response.closed` property indicates whether the response has been closed.
+
 ### response.connection
 <!-- YAML
 added: v0.3.0

lib/_http_client.js

@@ -191,6 +191,7 @@ function ClientRequest(input, options, cb) {
   this._ended = false;
   this.res = null;
   this.aborted = false;
+  this.closed = false;
   this.timeoutCb = null;
   this.upgradeOrConnect = false;
   this.parser = null;
@@ -358,14 +359,12 @@ function socketCloseListener() {
       res.aborted = true;
       res.emit('aborted');
     }
-    req.emit('close');
+    emitClose.call(req);
     if (res.readable) {
-      res.on('end', function() {
-        this.emit('close');
-      });
+      res.on('end', emitClose);
       res.push(null);
     } else {
-      res.emit('close');
+      emitClose.call(res);
     }
   } else {
     if (!req.socket._hadError) {
@@ -375,7 +374,7 @@ function socketCloseListener() {
       req.socket._hadError = true;
       req.emit('error', connResetException('socket hang up'));
     }
-    req.emit('close');
+    emitClose.call(req);
   }
 
   // Too bad.  That output wasn't getting written.
@@ -417,6 +416,11 @@ function socketErrorListener(err) {
   socket.destroy();
 }
 
+function emitClose() {
+  this.closed = true;
+  this.emit('close');
+}
+
 function freeSocketErrorListener(err) {
   const socket = this;
   debug('SOCKET ERROR on FREE socket:', err.message, err.stack);
@@ -487,6 +491,7 @@ function socketOnData(d) {
       socket.readableFlowing = null;
 
       req.emit(eventName, res, socket, bodyHead);
+      req.closed = true;
       req.emit('close');
     } else {
       // Requested Upgrade or used CONNECT method, but have no handler.

lib/_http_incoming.js

@@ -56,6 +56,7 @@ function IncomingMessage(socket) {
   this.readable = true;
 
   this.aborted = false;
+  this.closed = false;
 
   this.upgrade = null;
 

lib/_http_outgoing.js

@@ -96,6 +96,7 @@ function OutgoingMessage() {
   this._trailer = '';
 
   this.finished = false;
+  this.closed = false;
   this._headerSent = false;
   this[kIsCorked] = false;
 

lib/_http_server.js

@@ -178,7 +178,9 @@ function onServerResponseClose() {
   // Ergo, we need to deal with stale 'close' events and handle the case
   // where the ServerResponse object has already been deconstructed.
   // Fortunately, that requires only a single if check. :-)
-  if (this._httpMessage) this._httpMessage.emit('close');
+  if (this._httpMessage) {
+    emitClose.call(this._httpMessage);
+  }
 }
 
 ServerResponse.prototype.assignSocket = function assignSocket(socket) {
@@ -469,7 +471,7 @@ function abortIncoming(incoming) {
     var req = incoming.shift();
     req.aborted = true;
     req.emit('aborted');
-    req.emit('close');
+    emitClose.call(req);
   }
   // Abort socket._httpMessage ?
 }
@@ -594,6 +596,11 @@ function onParserExecuteCommon(server, socket, parser, state, ret, d) {
   }
 }
 
+function emitClose() {
+  this.closed = true;
+  this.emit('close');
+}
+
 function resOnFinish(req, res, socket, state, server) {
   // Usually the first incoming element should be our request.  it may
   // be that in the case abortIncoming() was called that the incoming
@@ -609,7 +616,8 @@ function resOnFinish(req, res, socket, state, server) {
     req._dump();
 
   res.detachSocket(socket);
-  req.emit('close');
+  res.closed = true;
+  emitClose.call(req);
   process.nextTick(emitCloseNT, res);
 
   if (res._last) {

lib/internal/http2/compat.js

@@ -297,6 +297,10 @@ class Http2ServerRequest extends Readable {
     this.on('resume', onRequestResume);
   }
 
+  get closed() {
+    return this[kState].closed;
+  }
+
   get aborted() {
     return this[kAborted];
   }
@@ -446,6 +450,10 @@ class Http2ServerResponse extends Stream {
     stream.on('timeout', onStreamTimeout(kResponse));
   }
 
+  get closed() {
+    return this[kState].closed;
+  }
+
   // User land modules such as finalhandler just check truthiness of this
   // but if someone is actually trying to use this for more than that
   // then we simply can't support such use cases

test/parallel/test-http-client-close-event.js

@@ -23,6 +23,7 @@ server.listen(0, common.mustCall(() => {
 
   req.on('close', common.mustCall(() => {
     assert.strictEqual(errorEmitted, true);
+    assert.strictEqual(req.closed, true);
     server.close();
   }));
 

test/parallel/test-http-connect-req-res.js

@@ -33,9 +33,14 @@ server.listen(0, common.mustCall(function() {
     path: 'example.com:443'
   }, common.mustNotCall());
 
-  req.on('close', common.mustCall());
+  assert.strictEqual(req.closed, false);
+  req.on('close', common.mustCall(() => {
+    assert.strictEqual(req.closed, true);
+  }));
 
   req.on('connect', common.mustCall(function(res, socket, firstBodyChunk) {
+    assert.strictEqual(req.closed, false);
+
     console.error('Client got CONNECT request');
 
     // Make sure this request got removed from the pool.
@@ -54,10 +59,20 @@ server.listen(0, common.mustCall(function() {
     // Test that the firstBodyChunk was not parsed as HTTP
     assert.strictEqual(data, 'Head');
 
+    let closeEmitted = false;
+
+    req.on('close', common.mustCall(() => {
+      closeEmitted = true;
+    }));
+
     socket.on('data', function(buf) {
+      assert.strictEqual(req.closed, true); // TODO: This should be false
+      assert.strictEqual(closeEmitted, true); // TODO: This should be false
       data += buf.toString();
     });
     socket.on('end', function() {
+      assert.strictEqual(req.closed, true); // TODO: This should be false
+      assert.strictEqual(closeEmitted, true); // TODO: This should be false
       assert.strictEqual(data, 'HeadRequestEnd');
       server.close();
     });

test/parallel/test-http-req-res-close.js

@@ -5,16 +5,15 @@ const http = require('http');
 const assert = require('assert');
 
 const server = http.Server(common.mustCall((req, res) => {
-  let resClosed = false;
-
   res.end();
   res.on('finish', common.mustCall(() => {
-    assert.strictEqual(resClosed, false);
+    assert.strictEqual(res.closed, false);
   }));
   res.on('close', common.mustCall(() => {
-    resClosed = true;
+    assert.strictEqual(res.closed, true);
   }));
   req.on('close', common.mustCall(() => {
+    assert.strictEqual(req.closed, true);
     assert.strictEqual(req._readableState.ended, true);
   }));
   res.socket.on('close', () => server.close());

test/parallel/test-http-response-close.js

@@ -22,6 +22,7 @@
 'use strict';
 const common = require('../common');
 const http = require('http');
+const assert = require('assert');
 
 {
   const server = http.createServer(
@@ -40,6 +41,7 @@ const http = require('http');
             res.destroy();
           }));
           res.on('close', common.mustCall(() => {
+            assert.strictEqual(res.closed, true);
             server.close();
           }));
         })