fix: multiple fixes for remote mcp error and timeout

Author: bywang56

server/aws-lsp-codewhisperer/src/language-server/agenticChat/tools/mcp/mcpEventHandler.ts

@@ -1238,7 +1238,7 @@ export class McpEventHandler {
             const serverConfig = McpManager.instance.getAllServerConfigs().get(serverName)
             if (serverConfig) {
                 // Emit server initialize event after permission change
-                const transportType = serverConfig.command ? 'stdio' : 'http'
+                const transportType = serverConfig.command?.trim() ? 'stdio' : 'http'
                 this.#telemetryController?.emitMCPServerInitializeEvent({
                     source: 'updatePermission',
                     command: transportType === 'stdio' ? serverConfig.command : undefined,
@@ -1319,7 +1319,7 @@ export class McpEventHandler {
                 enabled: enabled,
                 numTools: mcpManager.getAllToolsWithPermissions(serverName).length,
                 scope: config.__configPath__ === globalAgentPath ? 'global' : 'workspace',
-                transportType: 'stdio',
+                transportType: transportType,
                 languageServerVersion: this.#features.runtime.serverInfo.version,
             })
         }

server/aws-lsp-codewhisperer/src/language-server/agenticChat/tools/mcp/mcpManager.ts

@@ -292,7 +292,7 @@ export class McpManager {
             this.features.logging.debug(`MCP: initializing server [${serverName}]`)
 
             const client = new Client({
-                name: `mcp-client-${serverName}`,
+                name: `q-chat-plugin`, // Do not use variables in the client name to avoid polluting builder-mcp metrics
                 version: '1.0.0',
             })
 
@@ -662,7 +662,7 @@ export class McpManager {
                 disabled: cfg.disabled ?? false,
             }
             // Only add timeout to agent config if it's not 0
-            if (cfg.timeout !== 0) {
+            if (cfg.timeout !== undefined) {
                 serverConfig.timeout = cfg.timeout
             }
             if (cfg.args && cfg.args.length > 0) {
@@ -1281,11 +1281,21 @@ export class McpManager {
     private handleError(server: string | undefined, err: unknown) {
         const msg = err instanceof Error ? err.message : String(err)
 
-        this.features.logging.error(`MCP ERROR${server ? ` [${server}]` : ''}: ${msg}`)
+        const isBenignSseDisconnect =
+            /SSE error:\s*TypeError:\s*terminated:\s*Body Timeout Error/i.test(msg) ||
+            /TypeError:\s*terminated:\s*Body Timeout Error/i.test(msg) ||
+            /TypeError:\s*terminated:\s*other side closed/i.test(msg) ||
+            /ECONNRESET|ENETRESET|EPIPE/i.test(msg)
 
-        if (server) {
-            this.setState(server, McpServerStatus.FAILED, 0, msg)
-            this.emitToolsChanged(server)
+        if (isBenignSseDisconnect) {
+            this.features.logging.debug(`MCP SSE idle timeout${server ? ` [${server}]` : ''}: ${msg}`)
+        } else {
+            // default path for real errors
+            this.features.logging.error(`MCP ERROR${server ? ` [${server}]` : ''}: ${msg}`)
+            if (server) {
+                this.setState(server, McpServerStatus.FAILED, 0, msg)
+                this.emitToolsChanged(server)
+            }
         }
     }
 

server/aws-lsp-codewhisperer/src/language-server/agenticChat/tools/mcp/mcpOauthClient.ts

@@ -56,11 +56,16 @@ export class OAuthClient {
             const port = Number(new URL(savedReg.redirect_uri).port)
             server = http.createServer()
             try {
-                await new Promise<void>(res => server.listen(port, '127.0.0.1', res))
+                await this.listen(server, port)
                 redirectUri = savedReg.redirect_uri
                 this.logger.info(`OAuth: reusing redirect URI ${redirectUri}`)
             } catch (e: any) {
                 if (e.code === 'EADDRINUSE') {
+                    try {
+                        server.close()
+                    } catch {
+                        /* ignore */
+                    }
                     this.logger.warn(`Port ${port} in use; falling back to new random port`)
                     ;({ server, redirectUri } = await this.buildCallbackServer())
                     this.logger.info(`OAuth: new redirect URI ${redirectUri}`)
@@ -131,9 +136,8 @@ export class OAuthClient {
     // Spin up a one‑time HTTP listener on localhost:randomPort */
     private static async buildCallbackServer(): Promise<{ server: http.Server; redirectUri: string }> {
         const server = http.createServer()
-        const port = await new Promise<number>(res =>
-            server.listen(0, '127.0.0.1', () => res((server.address() as any).port))
-        )
+        await this.listen(server, 0)
+        const port = (server.address() as any).port as number
         return { server, redirectUri: `http://localhost:${port}` }
     }
 
@@ -393,4 +397,24 @@ export class OAuthClient {
         'sso',
         'cache'
     )
+
+    /**
+     * Await server.listen() but reject if it emits 'error' (eg EADDRINUSE),
+     * so callers can handle it immediately instead of hanging.
+     */
+    private static listen(server: http.Server, port: number, host: string = '127.0.0.1'): Promise<void> {
+        return new Promise((resolve, reject) => {
+            const onListening = () => {
+                server.off('error', onError)
+                resolve()
+            }
+            const onError = (err: NodeJS.ErrnoException) => {
+                server.off('listening', onListening)
+                reject(err)
+            }
+            server.once('listening', onListening)
+            server.once('error', onError)
+            server.listen(port, host)
+        })
+    }
 }

server/aws-lsp-codewhisperer/src/shared/localProjectContextController.ts

@@ -85,7 +85,7 @@ export class LocalProjectContextController {
         try {
             await waitUntil(async () => this.instance, {
                 interval: 1000,
-                timeout: 60,
+                timeout: 60_000,
                 truthy: true,
             })
 
@@ -359,7 +359,7 @@ export class LocalProjectContextController {
                     }
                     return false
                 },
-                { interval: 1000, timeout: 60, truthy: true }
+                { interval: 1000, timeout: 60_000, truthy: true }
             )
             return true
         } catch (error) {