fix(ClientRequest): destroy socket when destroying IncomingMessage

src/interceptors/ClientRequest/MockHttpSocket.ts

@@ -140,6 +140,11 @@ export class MockHttpSocket extends MockSocket {
     // Normally, we shoud listen to the "close" event but it
     // can be suppressed by using the "emitClose: false" option.
     this.responseParser.free()
+
+    if (error) {
+      this.emit('error', error)
+    }
+
     return super.destroy(error)
   }
 
@@ -153,6 +158,12 @@ export class MockHttpSocket extends MockSocket {
     }
 
     const socket = this.createConnection()
+
+    // If the developer destroys the socket, destroy the original connection.
+    this.once('error', (error) => {
+      socket.destroy(error)
+    })
+
     this.address = socket.address.bind(socket)
 
     // Flush the buffered "socket.write()" calls onto
@@ -308,6 +319,11 @@ export class MockHttpSocket extends MockSocket {
     serverResponse.removeHeader('connection')
     serverResponse.removeHeader('date')
 
+    // If the developer destroy the socket, gracefully destroy the response.
+    this.once('error', () => {
+      serverResponse.destroy()
+    })
+
     // Get the raw headers stored behind the symbol to preserve name casing.
     const headers = getRawFetchHeaders(response.headers) || response.headers
     for (const [name, value] of headers) {

test/modules/http/compliance/http-res-destroy.test.ts

@@ -0,0 +1,68 @@
+// @vitest-environment node
+import { vi, it, expect, beforeAll, afterEach, afterAll } from 'vitest'
+import http from 'node:http'
+import { ClientRequestInterceptor } from '../../../../src/interceptors/ClientRequest'
+import { HttpServer } from '@open-draft/test-server/lib/http'
+import { waitForClientRequest } from '../../../helpers'
+
+const httpServer = new HttpServer((app) => {
+  app.get('/', (req, res) => res.sendStatus(200))
+})
+
+const interceptor = new ClientRequestInterceptor()
+
+beforeAll(async () => {
+  interceptor.apply()
+  await httpServer.listen()
+})
+
+afterEach(() => {
+  interceptor.removeAllListeners()
+})
+
+afterAll(async () => {
+  interceptor.dispose()
+  await httpServer.close()
+})
+
+it('emits the "error" event when a bypassed response is destroyed', async () => {
+  const socketErrorListener = vi.fn()
+
+  const request = http
+    .get(httpServer.http.url('/'))
+    .on('socket', (socket) => {
+      socket.on('error', socketErrorListener)
+    })
+    .on('response', (response) => {
+      response.destroy(new Error('reason'))
+    })
+
+  const { res } = await waitForClientRequest(request)
+
+  expect(res.destroyed).toBe(true)
+  expect(socketErrorListener).toHaveBeenCalledOnce()
+  expect(socketErrorListener).toHaveBeenCalledWith(new Error('reason'))
+})
+
+it('emits the "error" event when a mocked response is destroyed', async () => {
+  interceptor.on('request', ({ request }) => {
+    request.respondWith(new Response('hello world'))
+  })
+
+  const socketErrorListener = vi.fn()
+
+  const request = http
+    .get(httpServer.http.url('/'))
+    .on('socket', (socket) => {
+      socket.on('error', socketErrorListener)
+    })
+    .on('response', (response) => {
+      response.destroy(new Error('reason'))
+    })
+
+  const { res } = await waitForClientRequest(request)
+
+  expect(res.destroyed).toBe(true)
+  expect(socketErrorListener).toHaveBeenCalledOnce()
+  expect(socketErrorListener).toHaveBeenCalledWith(new Error('reason'))
+})