fix: add "address()" on mock Socket

src/interceptors/ClientRequest/MockHttpSocket.ts

@@ -205,10 +205,10 @@ export class MockHttpSocket extends MockSocket {
       return
     }
 
+    this.responseType = 'mock'
     // First, emit all the connection events
     // to emulate a successful connection.
     this.mockConnect()
-    this.responseType = 'mock'
 
     // Flush the write buffer to trigger write callbacks
     // if it hasn't been flushed already (e.g. someone started reading request stream).
@@ -374,6 +374,7 @@ export class MockHttpSocket extends MockSocket {
       credentials: 'same-origin',
       // @ts-expect-error Undocumented Fetch property.
       duplex: canHaveBody ? 'half' : undefined,
+      // @ts-ignore
       body: canHaveBody ? (Readable.toWeb(this.requestStream!) as any) : null,
     })
 
@@ -435,6 +436,7 @@ export class MockHttpSocket extends MockSocket {
     }
 
     const response = new Response(
+      // @ts-ignore
       canHaveBody ? (Readable.toWeb(this.responseStream!) as any) : null,
       {
         status,

src/interceptors/Socket/MockSocket.ts

@@ -35,6 +35,19 @@ export class MockSocket extends net.Socket {
     return this
   }
 
+  public address(): {} | net.AddressInfo {
+    // @ts-ignore
+    if (this.responseType === 'mock') {
+      return {
+        address: '::1', // should be this.connectionOptions.host?
+        family: 'IPv4',
+        port: 1,
+      }
+    }
+
+    return super.address()
+  }
+
   public write(...args: Array<unknown>): boolean {
     const [chunk, encoding, callback] = normalizeWriteArgs(args as WriteArgs)
     this.options.write(chunk, encoding, callback)

test/modules/http/compliance/http.test.ts

@@ -163,3 +163,40 @@ it('mocks response to a non-existing host', async () => {
   expect(await text()).toBe('howdy, john')
   expect(requestListener).toHaveBeenCalledTimes(1)
 })
+
+it('returns mocked socket address', async () => {
+  interceptor.on('request', async ({ request }) => {
+    request.respondWith(new Response())
+  })
+
+  const connectPromise = new DeferredPromise<object>()
+  const req = http.get('http://example.com')
+  req.once('socket', socket => {
+    socket.once('connect', () => {
+      connectPromise.resolve(socket.address())
+    })
+  })
+
+  await expect(connectPromise).resolves.toEqual({
+    address: '::1',
+    family: 'IPv4',
+    port: 1,
+  })
+});
+
+
+it.only('returns real socket address', async () => {
+  const connectPromise = new DeferredPromise<object>()
+  const req = http.get(httpServer.http.url('/user'))
+  req.once('socket', socket => {
+    socket.once('connect', () => {
+      connectPromise.resolve(socket.address())
+    })
+  })
+
+  await expect(connectPromise).resolves.toEqual({
+    address: '::1',
+    family: 'IPv4',
+    port: 2,
+  })
+});