fix: finish paused HTTP/1 parser on socket end

Signed-off-by: marko1olo <barsukdana@gmail.com>

Author: marko1olo

lib/dispatcher/client-h1.js

@@ -371,10 +371,14 @@ class Parser {
   finish () {
     assert(currentParser === null)
     assert(this.ptr != null)
-    assert(!this.paused)
 
     const { llhttp } = this
 
+    if (this.paused) {
+      llhttp.llhttp_resume(this.ptr)
+      this.paused = false
+    }
+
     let ret
 
     try {

test/client.js

@@ -3,6 +3,7 @@
 const { tspl } = require('@matteo.collina/tspl')
 const { readFileSync, createReadStream } = require('node:fs')
 const { createServer } = require('node:http')
+const { createServer: createNetServer } = require('node:net')
 const { Readable, PassThrough } = require('node:stream')
 const { test, after } = require('node:test')
 const { Client, errors } = require('..')
@@ -1190,6 +1191,52 @@ test('ignore request header mutations', async (t) => {
   await t.completed
 })
 
+test('socket end completes response when body is paused by backpressure', async (t) => {
+  t = tspl(t, { plan: 2 })
+
+  const payload = Buffer.from('aa')
+  const server = createNetServer((socket) => {
+    socket.once('data', () => {
+      socket.write(
+        'HTTP/1.1 200 OK\r\n' +
+        `Content-Length: ${payload.length}\r\n` +
+        'Connection: close\r\n\r\n'
+      )
+      socket.write(payload)
+      socket.end()
+    })
+  })
+  after(() => server.close())
+
+  server.listen(0, '127.0.0.1', () => {
+    const client = new Client(`http://127.0.0.1:${server.address().port}`)
+    after(() => client.close())
+
+    client.request({
+      path: '/',
+      method: 'GET',
+      highWaterMark: 1
+    }, (err, data) => {
+      t.ifError(err)
+
+      let body = ''
+      data.body.setEncoding('utf8')
+      data.body.on('data', (chunk) => {
+        body += chunk
+      })
+      data.body.on('end', () => {
+        t.strictEqual(body, payload.toString())
+      })
+
+      setImmediate(() => {
+        data.body.resume()
+      })
+    })
+  })
+
+  await t.completed
+})
+
 test('url-like url', async (t) => {
   t = tspl(t, { plan: 1 })