fix(mcp): prevent server reconnection when toggling disabled state

Fixed bug where MCP servers would reconnect instead of staying disabled when toggled off. The issue was that toggleServerDisabled() used stale in-memory config instead of reading the fresh config from disk after writing the disabled flag.

Changes:
Added readServerConfigFromFile() helper to read and validate server config from disk
Updated disable path to read fresh config before calling connectToServer()
Updated enable path to read fresh config before calling connectToServer()
This ensures the disabled: true flag is properly read, causing connectToServer() to create a disabled placeholder connection instead of actually connecting the server.

+ refactor(mcp): use safeWriteJson for atomic config writes

Replace JSON.stringify + fs.writeFile with safeWriteJson in McpHub.ts
to prevent data corruption through atomic writes with file locking.

Author: heyseth

src/services/mcp/McpHub.ts

@@ -32,6 +32,7 @@ import {
 import { fileExistsAtPath } from "../../utils/fs"
 import { arePathsEqual, getWorkspacePath } from "../../utils/path"
 import { injectVariables } from "../../utils/config"
+import { safeWriteJson } from "../../utils/safeWriteJson"
 
 // Discriminated union for connection states
 export type ConnectedMcpConnection = {
@@ -1375,13 +1376,16 @@ export class McpHub {
 						this.removeFileWatchersForServer(serverName)
 						await this.deleteConnection(serverName, serverSource)
 						// Re-add as a disabled connection
-						await this.connectToServer(serverName, JSON.parse(connection.server.config), serverSource)
+						// Re-read config from file to get updated disabled state
+					const updatedConfig = await this.readServerConfigFromFile(serverName, serverSource)
+					await this.connectToServer(serverName, updatedConfig, serverSource)
 					} else if (!disabled && connection.server.status === "disconnected") {
 						// If enabling a disabled server, connect it
-						const config = JSON.parse(connection.server.config)
+						// Re-read config from file to get updated disabled state
+						const updatedConfig = await this.readServerConfigFromFile(serverName, serverSource)
 						await this.deleteConnection(serverName, serverSource)
 						// When re-enabling, file watchers will be set up in connectToServer
-						await this.connectToServer(serverName, config, serverSource)
+						await this.connectToServer(serverName, updatedConfig, serverSource)
 					} else if (connection.server.status === "connected") {
 						// Only refresh capabilities if connected
 						connection.server.tools = await this.fetchToolsList(serverName, serverSource)
@@ -1403,6 +1407,57 @@ export class McpHub {
 		}
 	}
 
+	/**
+	 * Helper method to read a server's configuration from the appropriate settings file
+	 * @param serverName The name of the server to read
+	 * @param source Whether to read from the global or project config
+	 * @returns The validated server configuration
+	 */
+	private async readServerConfigFromFile(
+		serverName: string,
+		source: "global" | "project" = "global",
+	): Promise<z.infer<typeof ServerConfigSchema>> {
+		// Determine which config file to read
+		let configPath: string
+		if (source === "project") {
+			const projectMcpPath = await this.getProjectMcpPath()
+			if (!projectMcpPath) {
+				throw new Error("Project MCP configuration file not found")
+			}
+			configPath = projectMcpPath
+		} else {
+			configPath = await this.getMcpSettingsFilePath()
+		}
+
+		// Ensure the settings file exists and is accessible
+		try {
+			await fs.access(configPath)
+		} catch (error) {
+			console.error("Settings file not accessible:", error)
+			throw new Error("Settings file not accessible")
+		}
+
+		// Read and parse the config file
+		const content = await fs.readFile(configPath, "utf-8")
+		const config = JSON.parse(content)
+
+		// Validate the config structure
+		if (!config || typeof config !== "object") {
+			throw new Error("Invalid config structure")
+		}
+
+		if (!config.mcpServers || typeof config.mcpServers !== "object") {
+			throw new Error("No mcpServers section in config")
+		}
+
+		if (!config.mcpServers[serverName]) {
+			throw new Error(`Server ${serverName} not found in config`)
+		}
+
+		// Validate and return the server config
+		return this.validateServerConfig(config.mcpServers[serverName], serverName)
+	}
+
 	/**
 	 * Helper method to update a server's configuration in the appropriate settings file
 	 * @param serverName The name of the server to update
@@ -1471,13 +1526,12 @@ export class McpHub {
 
 		// Set flag to prevent file watcher from triggering server restart
 		this.isProgrammaticUpdate = true
-		try {
-			await fs.writeFile(configPath, JSON.stringify(updatedConfig, null, 2))
-			// Delay longer than debounce timer (500ms) to ensure watcher event is processed while flag is set
-			await delay(600)
-		} finally {
+		await safeWriteJson(configPath, updatedConfig)
+
+		// Reset flag after watcher debounce period (non-blocking)
+		delay(600).then(() => {
 			this.isProgrammaticUpdate = false
-		}
+		})
 	}
 
 	public async updateServerTimeout(
@@ -1555,7 +1609,7 @@ export class McpHub {
 					mcpServers: config.mcpServers,
 				}
 
-				await fs.writeFile(configPath, JSON.stringify(updatedConfig, null, 2))
+				await safeWriteJson(configPath, updatedConfig)
 
 				// Update server connections with the correct source
 				await this.updateServerConnections(config.mcpServers, serverSource)
@@ -1702,13 +1756,12 @@ export class McpHub {
 
 		// Set flag to prevent file watcher from triggering server restart
 		this.isProgrammaticUpdate = true
-		try {
-			await fs.writeFile(normalizedPath, JSON.stringify(config, null, 2))
-			// Delay longer than debounce timer (500ms) to ensure watcher event is processed while flag is set
-			await delay(600)
-		} finally {
+		await safeWriteJson(normalizedPath, config)
+
+		// Reset flag after watcher debounce period (non-blocking)
+		delay(600).then(() => {
 			this.isProgrammaticUpdate = false
-		}
+		})
 
 		if (connection) {
 			connection.server.tools = await this.fetchToolsList(serverName, source)