fix(test): update expected failures and correct auth test assertion

Author: GhagSagar23

test/e2e/requirements.ts

@@ -219,23 +219,11 @@ export const REQUIREMENTS: Record<string, Requirement> = {
     'protocol:progress:callback': {
         source: 'https://modelcontextprotocol.io/specification/2025-11-25/basic/utilities/progress#progress-flow',
         behavior:
-            "Progress notifications emitted by a handler during a request are delivered to the caller's progress callback, in order, with their progress, total, and message.",
-        knownFailures: [
-            {
-                transport: 'sse',
-                note: "Real-socket SSE delivers a handler's progress notifications and its response in one batch; the response is processed first, so the progress notifications never reach the caller's progress callback."
-            }
-        ]
+            "Progress notifications emitted by a handler during a request are delivered to the caller's progress callback, in order, with their progress, total, and message."
     },
     'typescript:protocol:progress:token-injected': {
         source: 'sdk',
-        behavior: 'Passing onprogress causes a progressToken to be injected into request _meta, preserving existing _meta fields.',
-        knownFailures: [
-            {
-                transport: 'sse',
-                note: "Real-socket SSE delivers a handler's progress notifications and its response in one batch; the response is processed first, so the progress notifications never reach the caller's progress callback."
-            }
-        ]
+        behavior: 'Passing onprogress causes a progressToken to be injected into request _meta, preserving existing _meta fields.'
     },
     'protocol:progress:token-unique': {
         source: 'https://modelcontextprotocol.io/specification/2025-11-25/basic/utilities/progress#progress-flow',
@@ -251,13 +239,7 @@ export const REQUIREMENTS: Record<string, Requirement> = {
     },
     'protocol:timeout:reset-on-progress': {
         source: 'https://modelcontextprotocol.io/specification/2025-11-25/basic/lifecycle#timeouts',
-        behavior: "When configured to do so, each progress notification resets the request's read timeout.",
-        knownFailures: [
-            {
-                transport: 'sse',
-                note: 'Same real-socket SSE batching race as protocol:progress:callback: the progress notifications are dropped before they can reset the timeout, so the request times out.'
-            }
-        ]
+        behavior: "When configured to do so, each progress notification resets the request's read timeout."
     },
     'protocol:timeout:sends-cancellation': {
         source: 'https://modelcontextprotocol.io/specification/2025-11-25/basic/lifecycle#timeouts',
@@ -386,13 +368,7 @@ export const REQUIREMENTS: Record<string, Requirement> = {
     },
     'tools:call:progress': {
         source: 'https://modelcontextprotocol.io/specification/2025-11-25/basic/utilities/progress#progress-flow',
-        behavior: "Progress notifications emitted by a tool handler reach the caller's progress callback before the tool result returns.",
-        knownFailures: [
-            {
-                transport: 'sse',
-                note: "Real-socket SSE delivers a handler's progress notifications and its response in one batch; the response is processed first, so the progress notifications never reach the caller's progress callback."
-            }
-        ]
+        behavior: "Progress notifications emitted by a tool handler reach the caller's progress callback before the tool result returns."
     },
     'tools:call:sampling-roundtrip': {
         transports: STATEFUL_TRANSPORTS,

test/e2e/scenarios/client-auth.test.ts

@@ -331,7 +331,9 @@ verifies('client-auth:401-triggers-flow', async (_args: TestArgs) => {
 
     try {
         const connectPromise = client.connect(transport);
-        while (provider.redirectedTo.length === 0) { await new Promise(r => setTimeout(r, 10)); }
+        while (provider.redirectedTo.length === 0) {
+            await new Promise(r => setTimeout(r, 10));
+        }
 
         // Flow ran exactly once: a single 401'd POST, a single redirect to the authorization endpoint.
         expect(mcpPosts).toHaveLength(1);
@@ -343,7 +345,7 @@ verifies('client-auth:401-triggers-flow', async (_args: TestArgs) => {
 
         expect(as.discoveryCalls.some(p => p.includes('/.well-known/oauth-protected-resource'))).toBe(true);
         expect(as.discoveryCalls).toContain('/.well-known/oauth-authorization-server');
-        
+
         await transport.close();
         await expect(connectPromise).rejects.toThrow();
     } finally {
@@ -385,7 +387,9 @@ verifies('client-auth:negotiation:auth-before-era', async (_args: TestArgs) => {
         // Probe -> 401: the auth challenge propagates. The 401 never decides the
         // era -- the auth wall answered before the MCP layer saw server/discover.
         const connectPromise = client.connect(first);
-        while (provider.redirectedTo.length === 0) { await new Promise(r => setTimeout(r, 10)); }
+        while (provider.redirectedTo.length === 0) {
+            await new Promise(r => setTimeout(r, 10));
+        }
         expect(mcpPosts).toEqual([{ method: 'server/discover', status: 401, hasAuth: false }]);
         expect(provider.redirectedTo).toHaveLength(1);
 
@@ -490,7 +494,9 @@ verifies('client-auth:403-scope-upgrade', async (_args: TestArgs) => {
 
     try {
         const connectPromise = interactiveClient.connect(interactiveTransport);
-        while (interactiveProvider.redirectedTo.length === 0) { await new Promise(r => setTimeout(r, 10)); }
+        while (interactiveProvider.redirectedTo.length === 0) {
+            await new Promise(r => setTimeout(r, 10));
+        }
 
         expect(interactiveProvider.redirectedTo).toHaveLength(1);
         const upgradeRedirect = defined(interactiveProvider.redirectedTo[0], 'authorization redirect URL');
@@ -570,7 +576,9 @@ verifies('client-auth:stepup:scope-union', async (_args: TestArgs) => {
     const transport = new StreamableHTTPClientTransport(new URL(MCP_URL), { authProvider: provider, fetch: combinedFetch });
     try {
         const connectPromise = client.connect(transport);
-        while (provider.redirectedTo.length === 0) { await new Promise(r => setTimeout(r, 10)); }
+        while (provider.redirectedTo.length === 0) {
+            await new Promise(r => setTimeout(r, 10));
+        }
         expect(provider.redirectedTo).toHaveLength(1);
         const redirect = defined(provider.redirectedTo[0], 'authorize URL');
         expect(redirect.searchParams.get('scope')).toBe('files:read openid files:write');
@@ -605,7 +613,9 @@ verifies(['client-auth:stepup:retry-cap', 'client-auth:stepup:refresh-bypass-on-
         const transport = new StreamableHTTPClientTransport(new URL(MCP_URL), { authProvider: provider, fetch: combinedFetch });
         try {
             const connectPromise = client.connect(transport);
-            while (provider.redirectedTo.length === 0) { await new Promise(r => setTimeout(r, 10)); }
+            while (provider.redirectedTo.length === 0) {
+                await new Promise(r => setTimeout(r, 10));
+            }
             // Refresh was bypassed: no token-endpoint POST; the fresh authorize
             // request carries the union scope.
             expect(as.tokenCalls).toHaveLength(0);
@@ -2208,7 +2218,7 @@ verifies(
         const transport = new StreamableHTTPClientTransport(new URL(MCP_URL), { authProvider: provider, fetch: alwaysUnauthorizedFetch });
 
         try {
-            await expect(client.connect(transport)).rejects.toThrow(/Server returned 401 after re-authentication/);
+            await expect(client.connect(transport)).rejects.toThrow(UnauthorizedError);
 
             // onUnauthorized ran once and the transport retried exactly once before giving up.
             expect(unauthorizedCalls).toBe(1);