refactor(gateway): remove tools refresh notification endpoint and client notification service

Author: Lasim

services/gateway/src/core/server/proxy.ts

@@ -246,10 +246,6 @@ export class ProxyServer {
       await this.handleRestartServer(request, reply);
     });
 
-    // Tools refresh notification endpoint
-    this.fastify.post('/api/tools/refresh', async (request, reply) => {
-      await this.handleToolsRefresh(request, reply);
-    });
 
     // Logs streaming endpoint - real-time log streaming via SSE
     this.fastify.get('/logs/stream', async (request, reply) => {
@@ -1347,51 +1343,4 @@ export class ProxyServer {
     }
   }
 
-  /**
-   * Handle tools refresh notification - notify all connected clients about tool changes
-   */
-  private async handleToolsRefresh(request: FastifyRequest, reply: FastifyReply): Promise<void> {
-    try {
-      const body = request.body as any;
-      const reason = body?.reason || 'manual_refresh';
-
-      console.log(chalk.blue(`[API] Tools refresh notification: ${reason}`));
-
-      // Import ClientNotificationService here to avoid circular dependencies
-      const { ClientNotificationService } = await import('../../services/client-notification-service');
-      
-      // Create notification service with current handlers
-      const notificationService = new ClientNotificationService(
-        this.sessionManager,
-        this.streamableHandler,
-        this.sseHandler
-      );
-
-      // Notify all connected clients about tool changes
-      const result = await notificationService.notifyToolsChanged();
-
-      console.log(chalk.green(`[API] Notified ${result.totalNotified} clients about tool changes`));
-      if (result.errors.length > 0) {
-        console.log(chalk.yellow(`[API] ${result.errors.length} notification errors occurred`));
-      }
-
-      reply.code(200).send({
-        success: true,
-        message: 'Tool refresh notifications sent',
-        totalNotified: result.totalNotified,
-        sseNotified: result.sseNotified,
-        streamableHttpNotified: result.streamableHttpNotified,
-        errors: result.errors.length,
-        reason
-      });
-
-    } catch (error) {
-      console.error(chalk.red(`[API] Error handling tools refresh:`), error);
-      
-      reply.code(500).send({
-        error: 'Internal server error',
-        message: error instanceof Error ? error.message : String(error)
-      });
-    }
-  }
 }

services/gateway/src/services/client-notification-service.ts

@@ -4,7 +4,6 @@ import { CredentialStorage } from '../core/auth/storage';
 import { DeployStackAPI } from '../core/auth/api-client';
 import { MCPConfigService } from '../core/mcp';
 import { ConfigurationChangeService } from './configuration-change-service';
-import { ClientNotificationService } from './client-notification-service';
 import { AuthenticationError } from '../types/auth';
 import { detectDeviceInfo } from '../utils/device-detection';
 
@@ -100,9 +99,6 @@ export class RefreshService {
         // Step 2: Handle configuration changes
         if (changeInfo.hasChanges) {
           await this.changeService.handleConfigurationChanges(changeInfo, teamMCPConfig.servers);
-          
-          // Step 3: Notify connected clients about tool changes
-          await this.notifyConnectedClients();
         } else {
           console.log(chalk.green('✅ No configuration changes detected - your MCP servers are up to date'));
           console.log(chalk.gray('💡 All servers are already running with the latest configuration'));
@@ -141,52 +137,4 @@ export class RefreshService {
     }
   }
 
-  /**
-   * Notify connected clients about tool changes using HTTP requests to the running gateway
-   */
-  private async notifyConnectedClients(): Promise<void> {
-    try {
-      console.log(chalk.blue('Notifying connected MCP clients about tool changes...'));
-      
-      // Try to notify the running gateway about tool changes
-      // The gateway will handle notifying all connected clients
-      const gatewayUrl = 'http://localhost:9095';
-      
-      try {
-        const fetch = (await import('node-fetch')).default;
-        const response = await fetch(`${gatewayUrl}/api/tools/refresh`, {
-          method: 'POST',
-          headers: {
-            'Content-Type': 'application/json'
-          },
-          body: JSON.stringify({ reason: 'configuration_refresh' })
-        });
-        
-        if (response.ok) {
-          const result = await response.json() as {
-            totalNotified?: number;
-            sseNotified?: number;
-            streamableHttpNotified?: number;
-          };
-          console.log(chalk.green(`✅ Notified ${result.totalNotified || 0} connected clients`));
-          if (result.sseNotified && result.sseNotified > 0) {
-            console.log(chalk.gray(`   • SSE clients: ${result.sseNotified}`));
-          }
-          if (result.streamableHttpNotified && result.streamableHttpNotified > 0) {
-            console.log(chalk.gray(`   • Streamable HTTP clients: ${result.streamableHttpNotified}`));
-          }
-        } else {
-          throw new Error(`HTTP ${response.status}`);
-        }
-      } catch (error) {
-        // Gateway might not be running, which is fine
-        console.log(chalk.gray('💡 Gateway not running - clients will receive updated tools when they connect'));
-      }
-      
-    } catch (error) {
-      console.log(chalk.yellow(`⚠️  Failed to notify some clients: ${error instanceof Error ? error.message : String(error)}`));
-      console.log(chalk.gray('💡 Clients will still receive updated tools on their next request'));
-    }
-  }
-
 }