|
| 1 | +import { |
| 2 | + defineCommand, |
| 3 | + McpClient, |
| 4 | + bailianMcpUrl, |
| 5 | + detectOutputFormat, |
| 6 | + type Config, |
| 7 | + type GlobalFlags, |
| 8 | +} from "bailian-cli-core"; |
| 9 | +import { failIfMissing } from "../../output/prompt.ts"; |
| 10 | +import { emitResult } from "../../output/output.ts"; |
| 11 | + |
| 12 | +function parseArgFlags(raw: string[]): Record<string, unknown> { |
| 13 | + const out: Record<string, unknown> = {}; |
| 14 | + for (const item of raw) { |
| 15 | + const idx = item.indexOf("="); |
| 16 | + if (idx <= 0) { |
| 17 | + process.stderr.write(`Error: --arg must be in K=V form, got: ${item}\n`); |
| 18 | + process.exit(1); |
| 19 | + } |
| 20 | + const key = item.slice(0, idx).trim(); |
| 21 | + const rawVal = item.slice(idx + 1); |
| 22 | + try { |
| 23 | + out[key] = JSON.parse(rawVal); |
| 24 | + } catch { |
| 25 | + out[key] = rawVal; |
| 26 | + } |
| 27 | + } |
| 28 | + return out; |
| 29 | +} |
| 30 | + |
| 31 | +export default defineCommand({ |
| 32 | + name: "mcp call", |
| 33 | + description: "Call a tool on an MCP server (tools/call)", |
| 34 | + usage: "bl mcp call <server-code>.<tool> [--arg k=v ...] [--json '{...}'] [--url <url>]", |
| 35 | + options: [ |
| 36 | + { |
| 37 | + flag: "<server-code>.<tool>", |
| 38 | + description: |
| 39 | + "Server code and tool name joined by a dot, e.g. market-cmapi00073529.SmartStockSelection", |
| 40 | + required: true, |
| 41 | + }, |
| 42 | + { |
| 43 | + flag: "--arg <kv>", |
| 44 | + description: "Tool argument (repeatable). Values parsed as JSON if possible, else string.", |
| 45 | + type: "array", |
| 46 | + }, |
| 47 | + { |
| 48 | + flag: "--json <obj>", |
| 49 | + description: "Full arguments object as JSON; merged with --arg (arg wins).", |
| 50 | + }, |
| 51 | + { |
| 52 | + flag: "--query <text>", |
| 53 | + description: "Shortcut for --arg query=<text> (mirrors many DashScope MCP tools).", |
| 54 | + }, |
| 55 | + { flag: "--url <url>", description: "Override the MCP endpoint URL (for non-Bailian servers)" }, |
| 56 | + ], |
| 57 | + examples: [ |
| 58 | + 'bl mcp call market-cmapi00073529.SmartStockSelection --query "筛选ROE>15%的消费股"', |
| 59 | + 'bl mcp call market-cmapi00073529.FinQuery --json \'{"q":"贵州茅台","limit":5}\'', |
| 60 | + "bl mcp call market-cmapi00073529.SmartFundSelection --arg riskLevel=R3 --arg minScale=10", |
| 61 | + ], |
| 62 | + async run(config: Config, flags: GlobalFlags) { |
| 63 | + const positional = |
| 64 | + ((flags as Record<string, unknown>)._positional as string[] | undefined) ?? []; |
| 65 | + const target = positional[0]; |
| 66 | + if (!target) failIfMissing("<server-code>.<tool>", "bl mcp call <server-code>.<tool>"); |
| 67 | + |
| 68 | + const dot = target!.indexOf("."); |
| 69 | + if (dot <= 0 || dot === target!.length - 1) { |
| 70 | + process.stderr.write(`Error: target must be <server-code>.<tool>, got "${target}".\n`); |
| 71 | + process.exit(1); |
| 72 | + } |
| 73 | + const serverCode = target!.slice(0, dot); |
| 74 | + const toolName = target!.slice(dot + 1); |
| 75 | + |
| 76 | + let toolArgs: Record<string, unknown> = {}; |
| 77 | + if (flags.json) { |
| 78 | + try { |
| 79 | + const parsed = JSON.parse(flags.json as string); |
| 80 | + if (!parsed || typeof parsed !== "object" || Array.isArray(parsed)) { |
| 81 | + process.stderr.write("Error: --json must decode to an object.\n"); |
| 82 | + process.exit(1); |
| 83 | + } |
| 84 | + toolArgs = parsed as Record<string, unknown>; |
| 85 | + } catch (err) { |
| 86 | + process.stderr.write(`Error: --json is not valid JSON — ${(err as Error).message}\n`); |
| 87 | + process.exit(1); |
| 88 | + } |
| 89 | + } |
| 90 | + Object.assign(toolArgs, parseArgFlags((flags.arg as string[] | undefined) ?? [])); |
| 91 | + if (flags.query !== undefined) toolArgs.query = flags.query; |
| 92 | + |
| 93 | + const url = (flags.url as string) || bailianMcpUrl(config.baseUrl, serverCode); |
| 94 | + const format = detectOutputFormat(config.output); |
| 95 | + |
| 96 | + if (config.dryRun) { |
| 97 | + emitResult( |
| 98 | + { |
| 99 | + server: serverCode, |
| 100 | + url, |
| 101 | + tool: toolName, |
| 102 | + arguments: toolArgs, |
| 103 | + }, |
| 104 | + format, |
| 105 | + ); |
| 106 | + return; |
| 107 | + } |
| 108 | + |
| 109 | + const client = new McpClient(config, url); |
| 110 | + await client.initialize(); |
| 111 | + const result = await client.callTool(toolName, toolArgs); |
| 112 | + |
| 113 | + if (result.isError) { |
| 114 | + const errText = result.content.map((c) => c.text || "").join("\n"); |
| 115 | + process.stderr.write(`Tool error: ${errText}\n`); |
| 116 | + process.exit(1); |
| 117 | + } |
| 118 | + |
| 119 | + emitResult(result, format); |
| 120 | + }, |
| 121 | +}); |
0 commit comments