summaryrefslogtreecommitdiff
path: root/packages/server/src/tools/mcp-tool.ts
diff options
context:
space:
mode:
Diffstat (limited to 'packages/server/src/tools/mcp-tool.ts')
-rw-r--r--packages/server/src/tools/mcp-tool.ts49
1 files changed, 49 insertions, 0 deletions
diff --git a/packages/server/src/tools/mcp-tool.ts b/packages/server/src/tools/mcp-tool.ts
new file mode 100644
index 00000000..05ad750c
--- /dev/null
+++ b/packages/server/src/tools/mcp-tool.ts
@@ -0,0 +1,49 @@
+/**
+ * @license
+ * Copyright 2025 Google LLC
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+import { Client } from '@modelcontextprotocol/sdk/client/index.js';
+import { BaseTool, ToolResult } from './tools.js';
+
+type ToolParams = Record<string, unknown>;
+
+export const MCP_TOOL_DEFAULT_TIMEOUT_MSEC = 10 * 60 * 1000; // default to 10 minutes
+
+export class DiscoveredMCPTool extends BaseTool<ToolParams, ToolResult> {
+ constructor(
+ private readonly mcpClient: Client,
+ readonly name: string,
+ readonly description: string,
+ readonly parameterSchema: Record<string, unknown>,
+ readonly serverToolName: string,
+ readonly timeout?: number,
+ ) {
+ description += `
+
+This MCP tool was discovered from a local MCP server using JSON RPC 2.0 over stdio transport protocol.
+When called, this tool will invoke the \`tools/call\` method for tool name \`${name}\`.
+MCP servers can be configured in project or user settings.
+Returns the MCP server response as a json string.
+`;
+ super(name, name, description, parameterSchema);
+ }
+
+ async execute(params: ToolParams): Promise<ToolResult> {
+ const result = await this.mcpClient.callTool(
+ {
+ name: this.serverToolName,
+ arguments: params,
+ },
+ undefined, // skip resultSchema to specify options (RequestOptions)
+ {
+ timeout: this.timeout ?? MCP_TOOL_DEFAULT_TIMEOUT_MSEC,
+ },
+ );
+ return {
+ llmContent: JSON.stringify(result, null, 2),
+ returnDisplay: JSON.stringify(result, null, 2),
+ };
+ }
+}