feat: add MCP connected clients list and menu status item

Author: datlechin

CHANGELOG.md

@@ -10,6 +10,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 ### Added
 
 - MCP server: built-in Model Context Protocol server lets AI tools (Claude Desktop, Claude Code, Cursor) browse schemas, run queries, and export data through TablePro's connections
+- MCP server: connected clients list in Settings and status menu item showing server state
 - Import connections from TablePlus, Sequel Ace, and DBeaver with one-click migration
 - Embedded database CLI terminal (View > Open Terminal or Ctrl+Cmd+`) auto-launches mysql, psql, redis-cli, etc. for the active connection
 - Structure tab: modify existing tables (add, modify, drop columns, indexes, foreign keys, primary keys)

TablePro/Core/MCP/MCPServer.swift

@@ -8,6 +8,14 @@ import Network
 import os
 
 actor MCPServer {
+    struct SessionSnapshot: Sendable, Identifiable {
+        let id: String
+        let clientName: String
+        let clientVersion: String?
+        let connectedSince: Date
+        let lastActivityAt: Date
+    }
+
     private static let logger = Logger(subsystem: "com.TablePro", category: "MCPServer")
 
     private static let maxSessions = 10
@@ -109,6 +117,26 @@ actor MCPServer {
         sessions.count
     }
 
+    func sessionSnapshots() async -> [SessionSnapshot] {
+        let now = ContinuousClock.now
+        var snapshots: [SessionSnapshot] = []
+        for (_, session) in sessions {
+            let info = await session.clientInfo
+            let created = await session.createdAt
+            let lastActive = await session.lastActivityAt
+            let connectedElapsed = now - created
+            let activeElapsed = now - lastActive
+            snapshots.append(SessionSnapshot(
+                id: session.id,
+                clientName: info?.name ?? String(localized: "Unknown"),
+                clientVersion: info?.version,
+                connectedSince: Date.now - TimeInterval(connectedElapsed.components.seconds),
+                lastActivityAt: Date.now - TimeInterval(activeElapsed.components.seconds)
+            ))
+        }
+        return snapshots
+    }
+
     // MARK: - Listener State
 
     private func handleListenerState(_ state: NWListener.State, listener: NWListener) {

TablePro/Core/MCP/MCPServerManager.swift

@@ -21,7 +21,9 @@ final class MCPServerManager {
     static let shared = MCPServerManager()
 
     private(set) var state: MCPServerState = .stopped
+    private(set) var connectedClients: [MCPServer.SessionSnapshot] = []
     private var server: MCPServer?
+    private var clientRefreshTask: Task<Void, Never>?
 
     var isRunning: Bool {
         if case .running = state { return true } else { return false }
@@ -67,6 +69,7 @@ final class MCPServerManager {
 
         do {
             try await newServer.start(port: port)
+            startClientRefresh()
         } catch {
             Self.logger.error("Failed to start MCP server: \(error.localizedDescription)")
             state = .failed(error.localizedDescription)
@@ -75,6 +78,7 @@ final class MCPServerManager {
     }
 
     func stop() async {
+        stopClientRefresh()
         guard let server else { return }
         await server.stop()
         self.server = nil
@@ -85,4 +89,34 @@ final class MCPServerManager {
         await stop()
         await start(port: port)
     }
+
+    func disconnectClient(_ sessionId: String) async {
+        await server?.removeSession(sessionId)
+        await refreshClients()
+    }
+
+    // MARK: - Client Refresh
+
+    private func startClientRefresh() {
+        clientRefreshTask = Task { [weak self] in
+            while !Task.isCancelled {
+                await self?.refreshClients()
+                try? await Task.sleep(for: .seconds(5))
+            }
+        }
+    }
+
+    private func stopClientRefresh() {
+        clientRefreshTask?.cancel()
+        clientRefreshTask = nil
+        connectedClients = []
+    }
+
+    private func refreshClients() async {
+        guard let server else {
+            connectedClients = []
+            return
+        }
+        connectedClients = await server.sessionSnapshots()
+    }
 }

TablePro/TableProApp.swift

@@ -141,12 +141,14 @@ struct AppMenuCommands: Commands {
     }
 
     var body: some Commands {
-        // Custom About window + Check for Updates
+        // Custom About window + Check for Updates + MCP status
         CommandGroup(replacing: .appInfo) {
             Button(String(localized: "About TablePro")) {
                 AboutWindowController.shared.showAboutPanel()
             }
             CheckForUpdatesView(updaterBridge: updaterBridge)
+            Divider()
+            MCPServerMenuItem()
         }
 
         // MARK: - Keyboard Shortcut Architecture
@@ -667,6 +669,35 @@ struct CheckForUpdatesView: View {
     }
 }
 
+// MARK: - MCP Server Menu Item
+
+private struct MCPServerMenuItem: View {
+    @State private var manager = MCPServerManager.shared
+
+    var body: some View {
+        Button(menuTitle) {
+            NotificationCenter.default.post(name: .openSettingsWindow, object: nil)
+        }
+    }
+
+    private var menuTitle: String {
+        switch manager.state {
+        case .running:
+            let count = manager.connectedClients.count
+            if count == 0 {
+                return String(localized: "MCP Server: Running")
+            }
+            return String(format: String(localized: "MCP Server: Running (%d clients)"), count)
+        case .failed:
+            return String(localized: "MCP Server: Failed")
+        case .stopped:
+            return String(localized: "MCP Server: Stopped")
+        case .starting:
+            return String(localized: "MCP Server: Starting...")
+        }
+    }
+}
+
 // MARK: - Open Window Handler
 
 /// Helper view that listens for window open notifications

TablePro/Views/Settings/MCPSettingsView.swift

@@ -7,6 +7,7 @@ import SwiftUI
 
 struct MCPSettingsView: View {
     @Bindable var settingsManager: AppSettingsManager
+    @State private var manager = MCPServerManager.shared
 
     var body: some View {
         Form {
@@ -25,6 +26,7 @@ struct MCPSettingsView: View {
             if settingsManager.mcp.enabled {
                 configurationSection
                 clientConfigurationSection
+                connectedClientsSection
 
                 Section {
                     Text("AI access policies are configured per-connection in each connection's settings.")
@@ -108,6 +110,41 @@ struct MCPSettingsView: View {
         }
     }
 
+    // MARK: - Connected Clients
+
+    private var connectedClientsSection: some View {
+        Section("Connected Clients") {
+            if manager.connectedClients.isEmpty {
+                Text("No clients connected")
+                    .foregroundStyle(.secondary)
+            } else {
+                ForEach(manager.connectedClients) { client in
+                    HStack {
+                        VStack(alignment: .leading, spacing: 2) {
+                            HStack(spacing: 4) {
+                                Text(client.clientName)
+                                if let version = client.clientVersion {
+                                    Text(version)
+                                        .foregroundStyle(.secondary)
+                                }
+                            }
+                            Text(client.connectedSince, style: .relative)
+                                .font(.caption)
+                                .foregroundStyle(.secondary)
+                        }
+                        Spacer()
+                        Button("Disconnect") {
+                            Task {
+                                await manager.disconnectClient(client.id)
+                            }
+                        }
+                        .controlSize(.small)
+                    }
+                }
+            }
+        }
+    }
+
     private var configSnippet: String {
         """
         {