chore: lint/format fixes; update integration discoverRoundtrip for A11 discharge

The integration discoverRoundtrip test asserted the OLD A11-rider behavior
(advertisement excludes listChanged); updated to assert the discharged
behavior (a designed existing-test modification — the rider's own
acceptance criterion, same mandate as discover.test.ts).

Author: felixweinberger

examples/client/src/subscriptionsListenClient.ts

@@ -44,7 +44,10 @@ async function autoOpenLeg(): Promise<void> {
         }
     });
     await client.connect(new StreamableHTTPClientTransport(new globalThis.URL(URL)));
-    console.log(`[client] (auto) connected (${client.getNegotiatedProtocolVersion()}); auto-opened filter:`, client.autoOpenedSubscription?.honoredFilter);
+    console.log(
+        `[client] (auto) connected (${client.getNegotiatedProtocolVersion()}); auto-opened filter:`,
+        client.autoOpenedSubscription?.honoredFilter
+    );
     await finished;
     await client.autoOpenedSubscription?.close();
     await client.close();

examples/server/src/subscriptionsListen.ts

@@ -26,11 +26,9 @@ let extraToolEnabled = false;
 function buildServer(): McpServer {
     const server = new McpServer({ name: 'subscriptions-listen-example', version: '1.0.0' });
 
-    server.registerTool(
-        'greet',
-        { description: 'Returns a greeting', inputSchema: z.object({ name: z.string() }) },
-        async ({ name }) => ({ content: [{ type: 'text', text: `hello, ${name}` }] })
-    );
+    server.registerTool('greet', { description: 'Returns a greeting', inputSchema: z.object({ name: z.string() }) }, async ({ name }) => ({
+        content: [{ type: 'text', text: `hello, ${name}` }]
+    }));
     if (extraToolEnabled) {
         server.registerTool(
             'farewell',

packages/client/src/client/client.ts

@@ -64,7 +64,6 @@ import {
     ListChangedOptionsBaseSchema,
     mergeCapabilities,
     parseSchema,
-    PROTOCOL_VERSION_META_KEY,
     Protocol,
     PROTOCOL_VERSION_META_KEY,
     ProtocolError,
@@ -1217,7 +1216,7 @@ export class Client extends Protocol<ClientContext> {
         }
 
         const requestAbort = new AbortController();
-        const transportKind = this.transport !== undefined ? detectProbeTransportKind(this.transport) : 'http';
+        const transportKind = this.transport === undefined ? 'http' : detectProbeTransportKind(this.transport);
 
         let closed = false;
         let parked!: ReturnType<typeof this._parkRequest>;
@@ -1279,10 +1278,10 @@ export class Client extends Protocol<ClientContext> {
                     reject(error ?? new Error('subscriptions/listen failed'));
                 }
             });
-            parked.sent.catch(err => {
+            parked.sent.catch(error => {
                 clearTimeout(timer);
                 void close();
-                reject(err instanceof Error ? err : new Error(String(err)));
+                reject(error instanceof Error ? error : new Error(String(error)));
             });
         });
 

packages/client/test/client/listen.test.ts

@@ -110,9 +110,7 @@ describe('Client.listen()', () => {
         const client = new Client({ name: 'c', version: '1' }, { versionNegotiation: { mode: 'auto' } });
         await client.connect(clientTx);
         const sub = await client.listen({ toolsListChanged: true });
-        const listenId = (
-            written.find(m => (m as { method?: string }).method === 'subscriptions/listen') as { id: number | string }
-        ).id;
+        const listenId = (written.find(m => (m as { method?: string }).method === 'subscriptions/listen') as { id: number | string }).id;
         written.length = 0;
         await sub.close();
         expect(written).toEqual([{ jsonrpc: '2.0', method: 'notifications/cancelled', params: { requestId: listenId } }]);
@@ -147,7 +145,12 @@ describe('Client.listen()', () => {
                 void serverTx.send({
                     jsonrpc: '2.0',
                     id: req.id,
-                    result: { resultType: 'complete', supportedVersions: [MODERN], capabilities: {}, serverInfo: { name: 's', version: '1' } }
+                    result: {
+                        resultType: 'complete',
+                        supportedVersions: [MODERN],
+                        capabilities: {},
+                        serverInfo: { name: 's', version: '1' }
+                    }
                 });
             }
             if (req.method === 'subscriptions/listen' && req.id !== undefined) {

test/e2e/scenarios/subscriptions.test.ts

@@ -108,7 +108,7 @@ verifies('typescript:subscriptions:listChanged-auto-open-modern', async () => {
 verifies('typescript:subscriptions:listen:legacy-era-steer', async ({ transport }: TestArgs) => {
     const client = new Client({ name: 'c', version: '0' });
     await using _ = await wire(transport, makeServer, client);
-    const error = await client.listen({ toolsListChanged: true }).catch(e => e as SdkError);
+    const error = await client.listen({ toolsListChanged: true }).catch(error_ => error_ as SdkError);
     expect(error).toBeInstanceOf(SdkError);
     expect((error as SdkError).code).toBe(SdkErrorCode.MethodNotSupportedByProtocolVersion);
     expect((error as SdkError).message).toContain('resources/subscribe');