feat(mcp): 集成并展示MCP服务器状态和资源列表

- 新增McpStatusList组件，实现MCP服务器状态、工具、提示和资源的可视化展示
- 修改App组件，支持切换视图显示MCP状态列表
- MCP客户端增加对prompts和resources的分页列表及读取功能
- MCP管理器扩展，支持发现和管理prompts及resources，及工具列表变化的事件通知
- 优化MCP客户端，支持JSON-RPC通知的处理，完善请求超时控制
- 在session中添加MCP工具列表变化监听，实时更新工具定义数据
- 提供键盘操作支持，实现MCP状态列表的上下翻页和快速导航
- 美化MCP状态列表界面，显示服务器状态及能力的详细信息

Author: hqwlkj

src/mcp/mcp-client.ts

@@ -17,13 +17,20 @@ type JsonRpcResponse = {
   error?: { code: number; message: string; data?: unknown };
 };
 
+type JsonRpcNotification = {
+  jsonrpc: "2.0";
+  method: string;
+  params?: Record<string, unknown>;
+};
+
 export type McpToolDefinition = {
   name: string;
   description?: string;
   inputSchema: {
     type: "object";
     properties: Record<string, unknown>;
     required?: string[];
+    additionalProperties?: boolean;
   };
 };
 
@@ -37,6 +44,58 @@ type CallToolResult = {
   isError?: boolean;
 };
 
+export type McpPromptArgument = {
+  name: string;
+  description?: string;
+  required?: boolean;
+};
+
+export type McpPromptDefinition = {
+  name: string;
+  description?: string;
+  arguments?: McpPromptArgument[];
+};
+
+type ListPromptsResult = {
+  prompts: McpPromptDefinition[];
+  nextCursor?: string;
+};
+
+export type McpPromptMessage = {
+  role: "user" | "assistant";
+  content: { type: string; text?: string };
+};
+
+type GetPromptResult = {
+  description?: string;
+  messages: McpPromptMessage[];
+};
+
+export type McpResourceDefinition = {
+  uri: string;
+  name: string;
+  description?: string;
+  mimeType?: string;
+};
+
+type ListResourcesResult = {
+  resources: McpResourceDefinition[];
+  nextCursor?: string;
+};
+
+export type McpResourceContent = {
+  uri: string;
+  mimeType?: string;
+  text?: string;
+  blob?: string;
+};
+
+type ReadResourceResult = {
+  contents: McpResourceContent[];
+};
+
+export type McpNotificationHandler = (method: string, params?: Record<string, unknown>) => void;
+
 export class McpClient {
   private process: ChildProcess | null = null;
   private reader: Interface | null = null;
@@ -46,13 +105,17 @@ export class McpClient {
     { resolve: (value: unknown) => void; reject: (error: Error) => void; timer: NodeJS.Timeout }
   >();
   private stderrBuffer = "";
+  private notificationHandler: McpNotificationHandler | null = null;
 
   constructor(
     private readonly serverName: string,
     private readonly command: string,
     private readonly args: string[] = [],
-    private readonly env?: Record<string, string>
-  ) {}
+    private readonly env?: Record<string, string>,
+    onNotification?: McpNotificationHandler
+  ) {
+    this.notificationHandler = onNotification ?? null;
+  }
 
   async connect(timeoutMs: number): Promise<void> {
     return new Promise((resolve, reject) => {
@@ -109,7 +172,7 @@ export class McpClient {
       this.sendRequest(
         "initialize",
         {
-          protocolVersion: "2024-11-05",
+          protocolVersion: "2025-03-26",
           capabilities: {},
           clientInfo: { name: "deepcode-cli", version: "0.1.0" },
         },
@@ -141,8 +204,50 @@ export class McpClient {
     throw this.withStderr(`MCP server "${this.serverName}" returned too many tools/list pages`);
   }
 
-  async callTool(name: string, args: Record<string, unknown>): Promise<CallToolResult> {
-    return (await this.sendRequest("tools/call", { name, arguments: args })) as CallToolResult;
+  async callTool(name: string, args: Record<string, unknown>, timeoutMs = 60_000): Promise<CallToolResult> {
+    return (await this.sendRequest("tools/call", { name, arguments: args }, timeoutMs)) as CallToolResult;
+  }
+
+  async listPrompts(timeoutMs: number): Promise<McpPromptDefinition[]> {
+    const prompts: McpPromptDefinition[] = [];
+    let cursor: string | undefined;
+
+    for (let page = 0; page < 100; page++) {
+      const params = cursor ? { cursor } : {};
+      const result = (await this.sendRequest("prompts/list", params, timeoutMs)) as ListPromptsResult;
+      prompts.push(...(result.prompts ?? []));
+      cursor = typeof result.nextCursor === "string" && result.nextCursor ? result.nextCursor : undefined;
+      if (!cursor) {
+        return prompts;
+      }
+    }
+
+    throw this.withStderr(`MCP server "${this.serverName}" returned too many prompts/list pages`);
+  }
+
+  async getPrompt(name: string, args: Record<string, unknown>, timeoutMs = 30_000): Promise<GetPromptResult> {
+    return (await this.sendRequest("prompts/get", { name, arguments: args }, timeoutMs)) as GetPromptResult;
+  }
+
+  async listResources(timeoutMs: number): Promise<McpResourceDefinition[]> {
+    const resources: McpResourceDefinition[] = [];
+    let cursor: string | undefined;
+
+    for (let page = 0; page < 100; page++) {
+      const params = cursor ? { cursor } : {};
+      const result = (await this.sendRequest("resources/list", params, timeoutMs)) as ListResourcesResult;
+      resources.push(...(result.resources ?? []));
+      cursor = typeof result.nextCursor === "string" && result.nextCursor ? result.nextCursor : undefined;
+      if (!cursor) {
+        return resources;
+      }
+    }
+
+    throw this.withStderr(`MCP server "${this.serverName}" returned too many resources/list pages`);
+  }
+
+  async readResource(uri: string, timeoutMs = 30_000): Promise<ReadResourceResult> {
+    return (await this.sendRequest("resources/read", { uri }, timeoutMs)) as ReadResourceResult;
   }
 
   disconnect(): void {
@@ -195,7 +300,23 @@ export class McpClient {
 
   private handleLine(line: string): void {
     try {
-      const message = JSON.parse(line) as JsonRpcResponse;
+      const parsed: unknown = JSON.parse(line);
+
+      // Handle notifications (no id field — server-initiated)
+      if (parsed && typeof parsed === "object" && !("id" in parsed)) {
+        const notification = parsed as JsonRpcNotification;
+        if (this.notificationHandler && typeof notification.method === "string") {
+          try {
+            this.notificationHandler(notification.method, notification.params);
+          } catch {
+            // Swallow handler errors to avoid crashing the reader loop
+          }
+        }
+        return;
+      }
+
+      // Handle responses to our requests
+      const message = parsed as JsonRpcResponse;
       if (message.id !== undefined && this.pendingRequests.has(message.id)) {
         const pending = this.pendingRequests.get(message.id)!;
         this.pendingRequests.delete(message.id);