Added dynamic endstream (#96)

lib/http2/request.js

@@ -164,7 +164,7 @@ class Http2Request extends EventEmitter {
     return this.stream.write(chunk)
   }
 
-  _flushHeaders () {
+  _flushHeaders (endStream = false) {
     if (this[kHeadersFlushed]) {
       throw new Error('Headers already flushed')
     }
@@ -174,7 +174,7 @@ class Http2Request extends EventEmitter {
         .filter(([key]) => !connectionHeaders.includes(key.toLowerCase()))
     )
 
-    this.stream = this._client.request(this.requestHeaders, { endStream: false })
+    this.stream = this._client.request(this.requestHeaders, {endStream})
 
     this.registerListeners()
 
@@ -210,7 +210,7 @@ class Http2Request extends EventEmitter {
 
   end () {
     if (!this[kHeadersFlushed]) {
-      this._flushHeaders()
+      this._flushHeaders(true)
     }
     this.stream.end()
 
@@ -317,7 +317,7 @@ class ResponseProxy extends EventEmitter {
   }
 
   get headers () {
-    return this.response
+    return Object.fromEntries(Object.entries(this.response))
   }
 
   pause () {

request.js

@@ -2008,6 +2008,10 @@ Request.prototype.end = function (chunk) {
     // Reference to request, so if _reqResInfo is updated (in case of redirects), we still can update the headers
     const request = self._reqResInfo.request
     Promise.resolve(self.req._header).then(function (header) {
+      if (!header) {
+        request.headers = []
+        return
+      }
       request.headers = parseRequestHeaders(header)
     })
   }

tests/test-body-http2.js

@@ -153,6 +153,69 @@ addTest('testPutMultipartPostambleCRLF', {
   ]
 })
 
+tape('test Delete Request', function (t) {
+  s.on('/', function (req, res) {
+    req.pipe(res)
+  })
+
+  request(
+    {
+      uri: 'https://localhost:' + s.port,
+      method: 'DELETE',
+      strictSSL: false,
+      protocolVersion: 'http2',
+      body: 'test-data'
+    },
+    function (err, res, body) {
+      t.error(err) // defaults to 'application/octet-stream' content-type
+      t.equal(res.statusCode, 200)
+      t.equal(body.toString(), 'test-data')
+      s.removeAllListeners('/')
+      t.end()
+    }
+  )
+})
+
+tape('test HEAD Request', function (t) {
+  request(
+    {
+      uri: 'https://github.com',
+      method: 'HEAD',
+      strictSSL: false,
+      protocolVersion: 'http2',
+      body: 'test-data'
+    },
+    function (err, res, body) {
+      t.error(err)
+      t.equal(res.statusCode, 400)
+      t.end()
+    }
+  )
+})
+
+tape('test GET Request with body', function (t) {
+  s.on('/', function (req, res) {
+    req.pipe(res)
+  })
+
+  request(
+    {
+      uri: 'https://localhost:' + s.port,
+      method: 'GET',
+      strictSSL: false,
+      protocolVersion: 'http2',
+      body: 'test-data'
+    },
+    function (err, res, body) {
+      t.error(err)
+      t.equal(res.statusCode, 200)
+      t.equal(body.toString(), 'test-data')
+      s.removeAllListeners('/')
+      t.end()
+    }
+  )
+})
+
 tape('testBinaryFile', function (t) {
   s.on('/', function (req, res) {
     req.pipe(res)