fix: ensure that requests to the same resource will be properly intercepted even if they are sent in rapid succession

cli/CHANGELOG.md

@@ -6,6 +6,7 @@ _Released 10/1/2024 (PENDING)_
 **Bugfixes:**
 
 - Patched [find-process](https://github.com/yibn2008/find-process) to fix an issue where trying to clean up browser profiles can throw an error on Windows. Addresses [#30378](https://github.com/cypress-io/cypress/issues/30378).
+- Fixed an issue where requests to the same resource in rapid succession may not have the appropriate static response intercept applied if there are multiple intercepts that apply for that resource. 
 
 **Misc:**
 

packages/net-stubbing/lib/server/intercepted-request.ts

@@ -51,8 +51,6 @@ export class InterceptedRequest {
     this._onResponse = opts.onResponse
     this.state = opts.state
     this.socket = opts.socket
-
-    this.addDefaultSubscriptions()
   }
 
   onResponse = (incomingRes: IncomingMessage, resStream: Readable) => {
@@ -65,7 +63,7 @@ export class InterceptedRequest {
     this._onResponse(incomingRes, resStream)
   }
 
-  private addDefaultSubscriptions () {
+  addDefaultSubscriptions () {
     if (this.subscriptionsByRoute.length) {
       throw new Error('cannot add default subscriptions to non-empty array')
     }
@@ -75,6 +73,10 @@ export class InterceptedRequest {
     }
 
     for (const route of this.req.matchingRoutes) {
+      if (route.disabled) {
+        continue
+      }
+
       const subscriptionsByRoute = {
         routeId: route.id,
         immediateStaticResponse: route.staticResponse,

packages/net-stubbing/lib/server/middleware/request.ts

@@ -138,6 +138,8 @@ export const InterceptRequest: RequestMiddleware = async function () {
 
   await ensureBody()
 
+  request.addDefaultSubscriptions()
+
   if (!_.isString(req.body) && !_.isBuffer(req.body)) {
     throw new Error('req.body must be a string or a Buffer')
   }

packages/net-stubbing/test/unit/intercepted-request-spec.ts

@@ -32,6 +32,8 @@ describe('InterceptedRequest', () => {
         socket,
       })
 
+      interceptedRequest.addDefaultSubscriptions()
+
       interceptedRequest.addSubscription({
         routeId: '1',
         eventName: 'before:response',
@@ -60,5 +62,57 @@ describe('InterceptedRequest', () => {
         mergeChanges: _.merge,
       })
     })
+
+    it('ignores disabled subscriptions', async () => {
+      const socket = {
+        toDriver: sinon.stub(),
+      }
+      const state = NetStubbingState()
+      const interceptedRequest = new InterceptedRequest({
+        req: {
+          matchingRoutes: [
+            // @ts-ignore
+            {
+              id: '1',
+              hasInterceptor: true,
+              routeMatcher: {},
+              disabled: true,
+            },
+            // @ts-ignore
+            {
+              id: '2',
+              hasInterceptor: true,
+              routeMatcher: {},
+            },
+          ],
+        },
+        state,
+        socket,
+      })
+
+      interceptedRequest.addDefaultSubscriptions()
+
+      const data = { foo: 'bar' }
+
+      socket.toDriver.callsFake((eventName, subEventName, frame) => {
+        expect(eventName).to.eq('net:stubbing:event')
+        expect(subEventName).to.eq('before:request')
+        expect(frame).to.deep.include({
+          subscription: {
+            eventName: 'before:request',
+            await: true,
+            routeId: '2',
+          },
+        })
+
+        state.pendingEventHandlers[frame.eventId](frame.data)
+      })
+
+      await interceptedRequest.handleSubscriptions({
+        eventName: 'before:request',
+        data,
+        mergeChanges: _.merge,
+      })
+    })
   })
 })