http2: add http2stream.endAfterHeaders property

Indicates is the END_STREAM flag was set on the received HEADERS frame
Backport-PR-URL: #22850
PR-URL: #22843Fixes: #22497
Reviewed-By: Matteo Collina <matteo.collina@gmail.com>
Reviewed-By: Anna Henningsen <anna@addaleax.net>
Reviewed-By: Trivikram Kamat <trivikr.dev@gmail.com>
Reviewed-By: Colin Ihrig <cjihrig@gmail.com>

Author: jasnell

doc/api/http2.md

@@ -952,6 +952,17 @@ added: v8.4.0
 Set to `true` if the `Http2Stream` instance has been destroyed and is no longer
 usable.
 
+#### http2stream.endAfterHeaders
+<!-- YAML
+added: REPLACEME
+-->
+
+* {boolean}
+
+Set the `true` if the `END_STREAM` flag was set in the request or response
+HEADERS frame received, indicating that no additional data should be received
+and the readable side of the `Http2Stream` will be closed.
+
 #### http2stream.pending
 <!-- YAML
 added: v8.11.2

lib/internal/http2/core.js

@@ -219,6 +219,8 @@ function onSessionHeaders(handle, id, cat, flags, headers) {
 }else{
 stream=newClientHttp2Stream(session,handle,id,opts);
 }
+if(endOfStream)
+stream[kState].endAfterHeaders=true;
 process.nextTick(emit,session,'stream',stream,obj,flags,headers);
 }else{
 letevent;
@@ -1557,7 +1559,8 @@ class Http2Stream extends Duplex {
 flags: STREAM_FLAGS_PENDING,
 rstCode: NGHTTP2_NO_ERROR,
 writeQueueSize: 0,
-trailersReady: false
+trailersReady: false,
+endAfterHeaders: false
 };
 
 this.on('pause',streamOnPause);
@@ -1602,6 +1605,10 @@ class Http2Stream extends Duplex {
 return`Http2Stream ${util.format(obj)}`;
 }
 
+getendAfterHeaders(){
+returnthis[kState].endAfterHeaders;
+}
+
 getsentHeaders(){
 returnthis[kSentHeaders];
 }

test/parallel/test-http2-endafterheaders.js

@@ -0,0 +1,50 @@
+'use strict';
+
+constcommon=require('../common');
+if(!common.hasCrypto)
+common.skip('missing crypto');
+constassert=require('assert');
+consthttp2=require('http2');
+constCountdown=require('../common/countdown');
+
+constserver=http2.createServer();
+server.on('stream',common.mustCall((stream,headers)=>{
+constcheck=headers[':method']==='GET' ? true : false;
+assert.strictEqual(stream.endAfterHeaders,check);
+stream.on('data',common.mustNotCall());
+stream.on('end',common.mustCall());
+stream.respond();
+stream.end('ok');
+},2));
+
+constcountdown=newCountdown(2,()=>server.close());
+
+server.listen(0,common.mustCall(()=>{
+{
+constclient=http2.connect(`http://localhost:${server.address().port}`);
+constreq=client.request();
+
+req.resume();
+req.on('response',common.mustCall(()=>{
+assert.strictEqual(req.endAfterHeaders,false);
+}));
+req.on('end',common.mustCall(()=>{
+client.close();
+countdown.dec();
+}));
+}
+{
+constclient=http2.connect(`http://localhost:${server.address().port}`);
+constreq=client.request({':method': 'POST'});
+
+req.resume();
+req.end();
+req.on('response',common.mustCall(()=>{
+assert.strictEqual(req.endAfterHeaders,false);
+}));
+req.on('end',common.mustCall(()=>{
+client.close();
+countdown.dec();
+}));
+}
+}));