github-mirror/n8n
1
0
Fork 0
mirror of https://github.com/n8n-io/n8n.git synced 2026-05-31 08:46:58 +02:00
Code Issues Actions 9 Packages Projects Releases Wiki Activity Graph

refactor(instance-ai): use native mcp client manager

Browse Source
This commit is contained in:
Oleg Ivaniv 2026-05-05 10:26:01 +02:00
parent 3a9eccddbd
commit 77212b10e5
No known key found for this signature in database
1 changed files with 17 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
packages/@n8n/instance-ai/src/mcp/mcp-client-manager.ts
View File

@ -1,37 +1,38 @@
import { MCPClient } from '@mastra/mcp';
import {
McpClient,
type BuiltTool,
type McpServerConfig as NativeMcpServerConfig,
} from '@n8n/agents';
import type { McpServerConfig } from '../types';
export class McpClientManager {
private mcpClient: MCPClient | undefined;
private mcpClient: McpClient | undefined;
async connect(servers: McpServerConfig[]): Promise<Record<string, unknown>> {
if (servers.length === 0) return {};
async connect(servers: McpServerConfig[]): Promise<BuiltTool[]> {
if (servers.length === 0) return [];
const serverMap: Record<
string,
{ url: URL } | { command: string; args?: string[]; env?: Record<string, string> }
> = {};
const configs: NativeMcpServerConfig[] = [];
for (const server of servers) {
const config: NativeMcpServerConfig = { name: server.name };
if (server.url) {
serverMap[server.name] = { url: new URL(server.url) };
config.url = server.url;
} else if (server.command) {
serverMap[server.name] = {
command: server.command,
args: server.args,
env: server.env,
};
config.command = server.command;
if (server.args !== undefined) config.args = server.args;
if (server.env !== undefined) config.env = server.env;
}
configs.push(config);
}
this.mcpClient = new MCPClient({ servers: serverMap });
this.mcpClient = new McpClient(configs);
return await this.mcpClient.listTools();
}
async disconnect(): Promise<void> {
if (this.mcpClient) {
await this.mcpClient.disconnect();
await this.mcpClient.close();
this.mcpClient = undefined;
}
}