Feat/mcp command

packages/cli/src/commands/catalog.ts

@@ -27,6 +27,9 @@ import memoryDelete from "./memory/delete.ts";
 import memoryProfileCreate from "./memory/profile-create.ts";
 import memoryProfileGet from "./memory/profile-get.ts";
 import knowledgeRetrieve from "./knowledge/retrieve.ts";
+import mcpCall from "./mcp/call.ts";
+import mcpList from "./mcp/list.ts";
+import mcpTools from "./mcp/tools.ts";
 import searchWeb from "./search/web.ts";
 import speechSynthesize from "./speech/synthesize.ts";
 import speechRecognize from "./speech/recognize.ts";
@@ -61,6 +64,9 @@ export const commands: Record<string, Command> = {
  "memory profile create": memoryProfileCreate,
  "memory profile get": memoryProfileGet,
  "knowledge retrieve": knowledgeRetrieve,
+ "mcp list": mcpList,
+ "mcp tools": mcpTools,
+ "mcp call": mcpCall,
  "search web": searchWeb,
  "speech synthesize": speechSynthesize,
  "speech recognize": speechRecognize,

packages/cli/src/commands/mcp/call.ts

@@ -0,0 +1,123 @@
+import {
+ defineCommand,
+ McpClient,
+ bailianMcpUrl,
+ detectOutputFormat,
+ type Config,
+ type GlobalFlags,
+} from "bailian-cli-core";
+import { failIfMissing } from "../../output/prompt.ts";
+import { emitResult } from "../../output/output.ts";
+import { ensureApiKey } from "../../utils/ensure-key.ts";
+
+function parseArgFlags(raw: string[]): Record<string, unknown> {
+ const out: Record<string, unknown> = {};
+ for (const item of raw) {
+ const idx = item.indexOf("=");
+ if (idx <= 0) {
+ process.stderr.write(`Error: --arg must be in K=V form, got: ${item}\n`);
+ process.exit(1);
+ }
+ const key = item.slice(0, idx).trim();
+ const rawVal = item.slice(idx + 1);
+ try {
+ out[key] = JSON.parse(rawVal);
+ } catch {
+ out[key] = rawVal;
+ }
+ }
+ return out;
+}
+
+export default defineCommand({
+ name: "mcp call",
+ description: "Call a tool on an MCP server (tools/call)",
+ usage: "bl mcp call <server-code>.<tool> [--arg k=v ...] [--json '{...}'] [--url <url>]",
+ options: [
+ {
+ flag: "<server-code>.<tool>",
+ description:
+ "Server code and tool name joined by a dot, e.g. market-cmapi00073529.SmartStockSelection",
+ required: true,
+ },
+ {
+ flag: "--arg <kv>",
+ description: "Tool argument (repeatable). Values parsed as JSON if possible, else string.",
+ type: "array",
+ },
+ {
+ flag: "--json <obj>",
+ description: "Full arguments object as JSON; merged with --arg (arg wins).",
+ },
+ {
+ flag: "--query <text>",
+ description: "Shortcut for --arg query=<text> (mirrors many DashScope MCP tools).",
+ },
+ { flag: "--url <url>", description: "Override the MCP endpoint URL (for non-Bailian servers)" },
+ ],
+ examples: [
+ 'bl mcp call market-cmapi00073529.SmartStockSelection --query "筛选ROE>15%的消费股"',
+ 'bl mcp call market-cmapi00073529.FinQuery --json \'{"q":"贵州茅台","limit":5}\'',
+ "bl mcp call market-cmapi00073529.SmartFundSelection --arg riskLevel=R3 --arg minScale=10",
+ ],
+ async run(config: Config, flags: GlobalFlags) {
+ const positional =
+ ((flags as Record<string, unknown>)._positional as string[] | undefined) ?? [];
+ const target = positional[0];
+ if (!target) failIfMissing("<server-code>.<tool>", "bl mcp call <server-code>.<tool>");
+
+ const dot = target!.indexOf(".");
+ if (dot <= 0 || dot === target!.length - 1) {
+ process.stderr.write(`Error: target must be <server-code>.<tool>, got "${target}".\n`);
+ process.exit(1);
+ }
+ const serverCode = target!.slice(0, dot);
+ const toolName = target!.slice(dot + 1);
+
+ let toolArgs: Record<string, unknown> = {};
+ if (flags.json) {
+ try {
+ const parsed = JSON.parse(flags.json as string);
+ if (!parsed || typeof parsed !== "object" || Array.isArray(parsed)) {
+ process.stderr.write("Error: --json must decode to an object.\n");
+ process.exit(1);
+ }
+ toolArgs = parsed as Record<string, unknown>;
+ } catch (err) {
+ process.stderr.write(`Error: --json is not valid JSON — ${(err as Error).message}\n`);
+ process.exit(1);
+ }
+ }
+ Object.assign(toolArgs, parseArgFlags((flags.arg as string[] | undefined) ?? []));
+ if (flags.query !== undefined) toolArgs.query = flags.query;
+
+ const url = (flags.url as string) || bailianMcpUrl(config.baseUrl, serverCode);
+ const format = detectOutputFormat(config.output);
+
+ if (config.dryRun) {
+ emitResult(
+ {
+ server: serverCode,
+ url,
+ tool: toolName,
+ arguments: toolArgs,
+ },
+ format,
+ );
+ return;
+ }
+
+ await ensureApiKey(config);
+ const client = new McpClient(config, url);
+ await client.initialize();
+ const result = await client.callTool(toolName, toolArgs);
+
+ if (result.isError) {
+ const errText = result.content.map((c) => c.text || "").join("\n");
+ process.stderr.write(`Tool error: ${errText}\n`);
+ process.exit(1);
+ }
+
+ emitResult(result, format);
+ },
+});

packages/cli/src/commands/mcp/list.ts

@@ -0,0 +1,103 @@
+import {
+ defineCommand,
+ callConsoleGateway,
+ resolveConsoleGatewayCredential,
+ detectOutputFormat,
+ BailianError,
+ ExitCode,
+ type Config,
+ type GlobalFlags,
+} from "bailian-cli-core";
+import { emitResult } from "../../output/output.ts";
+
+const MCP_LIST_API = "zeldaEasy.broadscope-bailian.mcp-server.PageList";
+
+interface ServerSummary {
+ code: string;
+ name: string;
+ description?: string;
+ type: string;
+ source?: string;
+ bizType?: string;
+ installType?: string;
+ streamable: boolean;
+}
+
+export default defineCommand({
+ name: "mcp list",
+ description: "List MCP servers activated under your Bailian account",
+ usage: "bl mcp list [flags]",
+ options: [
+ { flag: "--name <text>", description: "Filter by server name (substring match)" },
+ {
+ flag: "--type <type>",
+ description: "Server type: OFFICIAL | PRIVATE (default: OFFICIAL)",
+ },
+ { flag: "--page <n>", description: "Page number (default: 1)", type: "number" },
+ { flag: "--page-size <n>", description: "Results per page (default: 30)", type: "number" },
+ { flag: "--region <region>", description: "API region (default: cn-beijing)" },
+ ],
+ examples: ["bl mcp list", "bl mcp list --name 金融", "bl mcp list --output json"],
+ async run(config: Config, flags: GlobalFlags) {
+ const serverName = (flags.name as string) || "";
+ const type = (flags.type as string) || "OFFICIAL";
+ const pageNo = (flags.page as number) || 1;
+ const pageSize = (flags.pageSize as number) || 30;
+ const region = (flags.region as string) || "cn-beijing";
+ const format = detectOutputFormat(config.output);
+
+ const data = {
+ reqDTO: {
+ type,
+ displayTools: false,
+ activated: 1,
+ pageNo,
+ pageSize,
+ serverName,
+ },
+ };
+
+ if (config.dryRun) {
+ emitResult({ api: MCP_LIST_API, data, region }, format);
+ return;
+ }
+
+ const credential = await resolveConsoleGatewayCredential(config);
+
+ const result = (await callConsoleGateway(config, credential.token, {
+ api: MCP_LIST_API,
+ data,
+ region,
+ })) as Record<string, unknown>;
+
+ const dataField = (result?.data as Record<string, unknown> | undefined) ?? {};
+ if (dataField.success === false) {
+ const code = (dataField.errorCode as string | undefined) ?? "UnknownError";
+ const msg = (dataField.errorMsg as string | undefined) ?? code;
+ const hint =
+ code === "BailianGateway.Login.NotLogined"
+ ? "Run `bl auth login --console` to refresh your console session."
+ : undefined;
+ throw new BailianError(`Console gateway: ${msg}`, ExitCode.AUTH, hint);
+ }
+ const dataV2 = (dataField.DataV2 as Record<string, unknown> | undefined) ?? {};
+ const inner =
+ (dataV2.data as { data?: { mcpServerDetailList?: unknown[]; total?: number } } | undefined)
+ ?.data ?? {};
+ const list = (inner.mcpServerDetailList ?? []) as Array<Record<string, unknown>>;
+ const total = (inner.total as number) ?? 0;
+
+ const servers: ServerSummary[] = list.map((item) => ({
+ code: (item.serverCode as string | undefined) ?? "",
+ name: (item.serverName as string | undefined) ?? "",
+ description: item.description as string | undefined,
+ type: (item.type as string | undefined) ?? "",
+ source: item.source as string | undefined,
+ bizType: item.bizType as string | undefined,
+ installType: item.installType as string | undefined,
+ streamable: item.streamable === true,
+ }));
+
+ emitResult({ total, servers }, format);
+ },
+});

packages/cli/src/commands/mcp/tools.ts

@@ -0,0 +1,50 @@
+import {
+ defineCommand,
+ McpClient,
+ bailianMcpUrl,
+ detectOutputFormat,
+ type Config,
+ type GlobalFlags,
+} from "bailian-cli-core";
+import { failIfMissing } from "../../output/prompt.ts";
+import { emitResult } from "../../output/output.ts";
+import { ensureApiKey } from "../../utils/ensure-key.ts";
+
+export default defineCommand({
+ name: "mcp tools",
+ description: "List tools exposed by an MCP server (tools/list)",
+ usage: "bl mcp tools <server-code> [--url <url>]",
+ options: [
+ {
+ flag: "<server-code>",
+ description: "Server code from `bl mcp list` (e.g. market-cmapi00073529)",
+ required: true,
+ },
+ { flag: "--url <url>", description: "Override the MCP endpoint URL (for non-Bailian servers)" },
+ ],
+ examples: [
+ "bl mcp tools market-cmapi00073529",
+ "bl mcp tools market-cmapi00073529 --output json",
+ "bl mcp tools my-server --url https://example.com/mcp",
+ ],
+ async run(config: Config, flags: GlobalFlags) {
+ const positional =
+ ((flags as Record<string, unknown>)._positional as string[] | undefined) ?? [];
+ const code = positional[0];
+ if (!code) failIfMissing("server-code", "bl mcp tools <server-code>");
+
+ const url = (flags.url as string) || bailianMcpUrl(config.baseUrl, code!);
+ const format = detectOutputFormat(config.output);
+
+ if (config.dryRun) {
+ emitResult({ server: code, url, action: "tools/list" }, format);
+ return;
+ }
+
+ await ensureApiKey(config);
+ const client = new McpClient(config, url);
+ await client.initialize();
+ const tools = await client.listTools();
+ emitResult({ server: code, url, tools }, format);
+ },
+});

packages/cli/src/commands/search/web.ts

@@ -1,7 +1,7 @@
 import {
  defineCommand,
- mcpWebSearchEndpoint,
  detectOutputFormat,
+ mcpWebSearchEndpoint,
  type Config,
  type GlobalFlags,
  isInteractive,

packages/cli/src/main.ts

@@ -60,6 +60,9 @@ const NO_AUTH_SETUP = [
  ["app", "list"],
  ["console", "call"],
  ["usage", "free"],
+ ["mcp", "list"],
+ ["mcp", "tools"],
+ ["mcp", "call"],
 ];
 
 async function main() {

packages/cli/src/commands/catalog.ts

@@ -27,6 +27,9 @@ import memoryDelete from "./memory/delete.ts";
 import memoryProfileCreate from "./memory/profile-create.ts";
 import memoryProfileGet from "./memory/profile-get.ts";
 import knowledgeRetrieve from "./knowledge/retrieve.ts";
+import mcpCall from "./mcp/call.ts";
+import mcpList from "./mcp/list.ts";
+import mcpTools from "./mcp/tools.ts";
 import searchWeb from "./search/web.ts";
 import speechSynthesize from "./speech/synthesize.ts";
 import speechRecognize from "./speech/recognize.ts";
@@ -61,6 +64,9 @@ export const commands: Record<string, Command> = {
  "memory profile create": memoryProfileCreate,
  "memory profile get": memoryProfileGet,
  "knowledge retrieve": knowledgeRetrieve,
+ "mcp list": mcpList,
+ "mcp tools": mcpTools,
+ "mcp call": mcpCall,
  "search web": searchWeb,
  "speech synthesize": speechSynthesize,
  "speech recognize": speechRecognize,

packages/cli/src/commands/mcp/call.ts

@@ -0,0 +1,123 @@
+import {
+ defineCommand,
+ McpClient,
+ bailianMcpUrl,
+ detectOutputFormat,
+ type Config,
+ type GlobalFlags,
+} from "bailian-cli-core";
+import { failIfMissing } from "../../output/prompt.ts";
+import { emitResult } from "../../output/output.ts";
+import { ensureApiKey } from "../../utils/ensure-key.ts";
+
+function parseArgFlags(raw: string[]): Record<string, unknown> {
+ const out: Record<string, unknown> = {};
+ for (const item of raw) {
+ const idx = item.indexOf("=");
+ if (idx <= 0) {
+ process.stderr.write(`Error: --arg must be in K=V form, got: ${item}\n`);
+ process.exit(1);
+ }
+ const key = item.slice(0, idx).trim();
+ const rawVal = item.slice(idx + 1);
+ try {
+ out[key] = JSON.parse(rawVal);
+ } catch {
+ out[key] = rawVal;
+ }
+ }
+ return out;
+}
+
+export default defineCommand({
+ name: "mcp call",
+ description: "Call a tool on an MCP server (tools/call)",
+ usage: "bl mcp call <server-code>.<tool> [--arg k=v ...] [--json '{...}'] [--url <url>]",
+ options: [
+ {
+ flag: "<server-code>.<tool>",
+ description:
+ "Server code and tool name joined by a dot, e.g. market-cmapi00073529.SmartStockSelection",
+ required: true,
+ },
+ {
+ flag: "--arg <kv>",
+ description: "Tool argument (repeatable). Values parsed as JSON if possible, else string.",
+ type: "array",
+ },
+ {
+ flag: "--json <obj>",
+ description: "Full arguments object as JSON; merged with --arg (arg wins).",
+ },
+ {
+ flag: "--query <text>",
+ description: "Shortcut for --arg query=<text> (mirrors many DashScope MCP tools).",
+ },
+ { flag: "--url <url>", description: "Override the MCP endpoint URL (for non-Bailian servers)" },
+ ],
+ examples: [
+ 'bl mcp call market-cmapi00073529.SmartStockSelection --query "筛选ROE>15%的消费股"',
+ 'bl mcp call market-cmapi00073529.FinQuery --json \'{"q":"贵州茅台","limit":5}\'',
+ "bl mcp call market-cmapi00073529.SmartFundSelection --arg riskLevel=R3 --arg minScale=10",
+ ],
+ async run(config: Config, flags: GlobalFlags) {
+ const positional =
+ ((flags as Record<string, unknown>)._positional as string[] | undefined) ?? [];
+ const target = positional[0];
+ if (!target) failIfMissing("<server-code>.<tool>", "bl mcp call <server-code>.<tool>");
+
+ const dot = target!.indexOf(".");
+ if (dot <= 0 || dot === target!.length - 1) {
+ process.stderr.write(`Error: target must be <server-code>.<tool>, got "${target}".\n`);
+ process.exit(1);
+ }
+ const serverCode = target!.slice(0, dot);
+ const toolName = target!.slice(dot + 1);
+
+ let toolArgs: Record<string, unknown> = {};
+ if (flags.json) {
+ try {
+ const parsed = JSON.parse(flags.json as string);
+ if (!parsed || typeof parsed !== "object" || Array.isArray(parsed)) {
+ process.stderr.write("Error: --json must decode to an object.\n");
+ process.exit(1);
+ }
+ toolArgs = parsed as Record<string, unknown>;
+ } catch (err) {
+ process.stderr.write(`Error: --json is not valid JSON — ${(err as Error).message}\n`);
+ process.exit(1);
+ }
+ }
+ Object.assign(toolArgs, parseArgFlags((flags.arg as string[] | undefined) ?? []));
+ if (flags.query !== undefined) toolArgs.query = flags.query;
+
+ const url = (flags.url as string) || bailianMcpUrl(config.baseUrl, serverCode);
+ const format = detectOutputFormat(config.output);
+
+ if (config.dryRun) {
+ emitResult(
+ {
+ server: serverCode,
+ url,
+ tool: toolName,
+ arguments: toolArgs,
+ },
+ format,
+ );
+ return;
+ }
+
+ await ensureApiKey(config);
+ const client = new McpClient(config, url);
+ await client.initialize();
+ const result = await client.callTool(toolName, toolArgs);
+
+ if (result.isError) {
+ const errText = result.content.map((c) => c.text || "").join("\n");
+ process.stderr.write(`Tool error: ${errText}\n`);
+ process.exit(1);
+ }
+
+ emitResult(result, format);
+ },
+});

packages/cli/src/commands/mcp/list.ts

@@ -0,0 +1,103 @@
+import {
+ defineCommand,
+ callConsoleGateway,
+ resolveConsoleGatewayCredential,
+ detectOutputFormat,
+ BailianError,
+ ExitCode,
+ type Config,
+ type GlobalFlags,
+} from "bailian-cli-core";
+import { emitResult } from "../../output/output.ts";
+
+const MCP_LIST_API = "zeldaEasy.broadscope-bailian.mcp-server.PageList";
+
+interface ServerSummary {
+ code: string;
+ name: string;
+ description?: string;
+ type: string;
+ source?: string;
+ bizType?: string;
+ installType?: string;
+ streamable: boolean;
+}
+
+export default defineCommand({
+ name: "mcp list",
+ description: "List MCP servers activated under your Bailian account",
+ usage: "bl mcp list [flags]",
+ options: [
+ { flag: "--name <text>", description: "Filter by server name (substring match)" },
+ {
+ flag: "--type <type>",
+ description: "Server type: OFFICIAL | PRIVATE (default: OFFICIAL)",
+ },
+ { flag: "--page <n>", description: "Page number (default: 1)", type: "number" },
+ { flag: "--page-size <n>", description: "Results per page (default: 30)", type: "number" },
+ { flag: "--region <region>", description: "API region (default: cn-beijing)" },
+ ],
+ examples: ["bl mcp list", "bl mcp list --name 金融", "bl mcp list --output json"],
+ async run(config: Config, flags: GlobalFlags) {
+ const serverName = (flags.name as string) || "";
+ const type = (flags.type as string) || "OFFICIAL";
+ const pageNo = (flags.page as number) || 1;
+ const pageSize = (flags.pageSize as number) || 30;
+ const region = (flags.region as string) || "cn-beijing";
+ const format = detectOutputFormat(config.output);
+
+ const data = {
+ reqDTO: {
+ type,
+ displayTools: false,
+ activated: 1,
+ pageNo,
+ pageSize,
+ serverName,
+ },
+ };
+
+ if (config.dryRun) {
+ emitResult({ api: MCP_LIST_API, data, region }, format);
+ return;
+ }
+
+ const credential = await resolveConsoleGatewayCredential(config);
+
+ const result = (await callConsoleGateway(config, credential.token, {
+ api: MCP_LIST_API,
+ data,
+ region,
+ })) as Record<string, unknown>;
+
+ const dataField = (result?.data as Record<string, unknown> | undefined) ?? {};
+ if (dataField.success === false) {
+ const code = (dataField.errorCode as string | undefined) ?? "UnknownError";
+ const msg = (dataField.errorMsg as string | undefined) ?? code;
+ const hint =
+ code === "BailianGateway.Login.NotLogined"
+ ? "Run `bl auth login --console` to refresh your console session."
+ : undefined;
+ throw new BailianError(`Console gateway: ${msg}`, ExitCode.AUTH, hint);
+ }
+ const dataV2 = (dataField.DataV2 as Record<string, unknown> | undefined) ?? {};
+ const inner =
+ (dataV2.data as { data?: { mcpServerDetailList?: unknown[]; total?: number } } | undefined)
+ ?.data ?? {};
+ const list = (inner.mcpServerDetailList ?? []) as Array<Record<string, unknown>>;
+ const total = (inner.total as number) ?? 0;
+
+ const servers: ServerSummary[] = list.map((item) => ({
+ code: (item.serverCode as string | undefined) ?? "",
+ name: (item.serverName as string | undefined) ?? "",
+ description: item.description as string | undefined,
+ type: (item.type as string | undefined) ?? "",
+ source: item.source as string | undefined,
+ bizType: item.bizType as string | undefined,
+ installType: item.installType as string | undefined,
+ streamable: item.streamable === true,
+ }));
+
+ emitResult({ total, servers }, format);
+ },
+});

packages/cli/src/commands/mcp/tools.ts

@@ -0,0 +1,50 @@
+import {
+ defineCommand,
+ McpClient,
+ bailianMcpUrl,
+ detectOutputFormat,
+ type Config,
+ type GlobalFlags,
+} from "bailian-cli-core";
+import { failIfMissing } from "../../output/prompt.ts";
+import { emitResult } from "../../output/output.ts";
+import { ensureApiKey } from "../../utils/ensure-key.ts";
+
+export default defineCommand({
+ name: "mcp tools",
+ description: "List tools exposed by an MCP server (tools/list)",
+ usage: "bl mcp tools <server-code> [--url <url>]",
+ options: [
+ {
+ flag: "<server-code>",
+ description: "Server code from `bl mcp list` (e.g. market-cmapi00073529)",
+ required: true,
+ },
+ { flag: "--url <url>", description: "Override the MCP endpoint URL (for non-Bailian servers)" },
+ ],
+ examples: [
+ "bl mcp tools market-cmapi00073529",
+ "bl mcp tools market-cmapi00073529 --output json",
+ "bl mcp tools my-server --url https://example.com/mcp",
+ ],
+ async run(config: Config, flags: GlobalFlags) {
+ const positional =
+ ((flags as Record<string, unknown>)._positional as string[] | undefined) ?? [];
+ const code = positional[0];
+ if (!code) failIfMissing("server-code", "bl mcp tools <server-code>");
+
+ const url = (flags.url as string) || bailianMcpUrl(config.baseUrl, code!);
+ const format = detectOutputFormat(config.output);
+
+ if (config.dryRun) {
+ emitResult({ server: code, url, action: "tools/list" }, format);
+ return;
+ }
+
+ await ensureApiKey(config);
+ const client = new McpClient(config, url);
+ await client.initialize();
+ const tools = await client.listTools();
+ emitResult({ server: code, url, tools }, format);
+ },
+});

packages/cli/src/commands/search/web.ts

@@ -1,7 +1,7 @@
 import {
  defineCommand,
- mcpWebSearchEndpoint,
  detectOutputFormat,
+ mcpWebSearchEndpoint,
  type Config,
  type GlobalFlags,
  isInteractive,

packages/cli/src/main.ts

@@ -60,6 +60,9 @@ const NO_AUTH_SETUP = [
  ["app", "list"],
  ["console", "call"],
  ["usage", "free"],
+ ["mcp", "list"],
+ ["mcp", "tools"],
+ ["mcp", "call"],
 ];
 
 async function main() {

packages/cli/src/commands/catalog.ts

@@ -27,6 +27,9 @@ import memoryDelete from "./memory/delete.ts";
 import memoryProfileCreate from "./memory/profile-create.ts";
 import memoryProfileGet from "./memory/profile-get.ts";
 import knowledgeRetrieve from "./knowledge/retrieve.ts";
+import mcpCall from "./mcp/call.ts";
+import mcpList from "./mcp/list.ts";
+import mcpTools from "./mcp/tools.ts";
 import searchWeb from "./search/web.ts";
 import speechSynthesize from "./speech/synthesize.ts";
 import speechRecognize from "./speech/recognize.ts";
@@ -61,6 +64,9 @@ export const commands: Record<string, Command> = {
  "memory profile create": memoryProfileCreate,
  "memory profile get": memoryProfileGet,
  "knowledge retrieve": knowledgeRetrieve,
+ "mcp list": mcpList,
+ "mcp tools": mcpTools,
+ "mcp call": mcpCall,
  "search web": searchWeb,
  "speech synthesize": speechSynthesize,
  "speech recognize": speechRecognize,

packages/cli/src/commands/mcp/call.ts

@@ -0,0 +1,123 @@
+import {
+ defineCommand,
+ McpClient,
+ bailianMcpUrl,
+ detectOutputFormat,
+ type Config,
+ type GlobalFlags,
+} from "bailian-cli-core";
+import { failIfMissing } from "../../output/prompt.ts";
+import { emitResult } from "../../output/output.ts";
+import { ensureApiKey } from "../../utils/ensure-key.ts";
+
+function parseArgFlags(raw: string[]): Record<string, unknown> {
+ const out: Record<string, unknown> = {};
+ for (const item of raw) {
+ const idx = item.indexOf("=");
+ if (idx <= 0) {
+ process.stderr.write(`Error: --arg must be in K=V form, got: ${item}\n`);
+ process.exit(1);
+ }
+ const key = item.slice(0, idx).trim();
+ const rawVal = item.slice(idx + 1);
+ try {
+ out[key] = JSON.parse(rawVal);
+ } catch {
+ out[key] = rawVal;
+ }
+ }
+ return out;
+}
+
+export default defineCommand({
+ name: "mcp call",
+ description: "Call a tool on an MCP server (tools/call)",
+ usage: "bl mcp call <server-code>.<tool> [--arg k=v ...] [--json '{...}'] [--url <url>]",
+ options: [
+ {
+ flag: "<server-code>.<tool>",
+ description:
+ "Server code and tool name joined by a dot, e.g. market-cmapi00073529.SmartStockSelection",
+ required: true,
+ },
+ {
+ flag: "--arg <kv>",
+ description: "Tool argument (repeatable). Values parsed as JSON if possible, else string.",
+ type: "array",
+ },
+ {
+ flag: "--json <obj>",
+ description: "Full arguments object as JSON; merged with --arg (arg wins).",
+ },
+ {
+ flag: "--query <text>",
+ description: "Shortcut for --arg query=<text> (mirrors many DashScope MCP tools).",
+ },
+ { flag: "--url <url>", description: "Override the MCP endpoint URL (for non-Bailian servers)" },
+ ],
+ examples: [
+ 'bl mcp call market-cmapi00073529.SmartStockSelection --query "筛选ROE>15%的消费股"',
+ 'bl mcp call market-cmapi00073529.FinQuery --json \'{"q":"贵州茅台","limit":5}\'',
+ "bl mcp call market-cmapi00073529.SmartFundSelection --arg riskLevel=R3 --arg minScale=10",
+ ],
+ async run(config: Config, flags: GlobalFlags) {
+ const positional =
+ ((flags as Record<string, unknown>)._positional as string[] | undefined) ?? [];
+ const target = positional[0];
+ if (!target) failIfMissing("<server-code>.<tool>", "bl mcp call <server-code>.<tool>");
+
+ const dot = target!.indexOf(".");
+ if (dot <= 0 || dot === target!.length - 1) {
+ process.stderr.write(`Error: target must be <server-code>.<tool>, got "${target}".\n`);
+ process.exit(1);
+ }
+ const serverCode = target!.slice(0, dot);
+ const toolName = target!.slice(dot + 1);
+
+ let toolArgs: Record<string, unknown> = {};
+ if (flags.json) {
+ try {
+ const parsed = JSON.parse(flags.json as string);
+ if (!parsed || typeof parsed !== "object" || Array.isArray(parsed)) {
+ process.stderr.write("Error: --json must decode to an object.\n");
+ process.exit(1);
+ }
+ toolArgs = parsed as Record<string, unknown>;
+ } catch (err) {
+ process.stderr.write(`Error: --json is not valid JSON — ${(err as Error).message}\n`);
+ process.exit(1);
+ }
+ }
+ Object.assign(toolArgs, parseArgFlags((flags.arg as string[] | undefined) ?? []));
+ if (flags.query !== undefined) toolArgs.query = flags.query;
+
+ const url = (flags.url as string) || bailianMcpUrl(config.baseUrl, serverCode);
+ const format = detectOutputFormat(config.output);
+
+ if (config.dryRun) {
+ emitResult(
+ {
+ server: serverCode,
+ url,
+ tool: toolName,
+ arguments: toolArgs,
+ },
+ format,
+ );
+ return;
+ }
+
+ await ensureApiKey(config);
+ const client = new McpClient(config, url);
+ await client.initialize();
+ const result = await client.callTool(toolName, toolArgs);
+
+ if (result.isError) {
+ const errText = result.content.map((c) => c.text || "").join("\n");
+ process.stderr.write(`Tool error: ${errText}\n`);
+ process.exit(1);
+ }
+
+ emitResult(result, format);
+ },
+});

packages/cli/src/commands/mcp/list.ts

@@ -0,0 +1,103 @@
+import {
+ defineCommand,
+ callConsoleGateway,
+ resolveConsoleGatewayCredential,
+ detectOutputFormat,
+ BailianError,
+ ExitCode,
+ type Config,
+ type GlobalFlags,
+} from "bailian-cli-core";
+import { emitResult } from "../../output/output.ts";
+
+const MCP_LIST_API = "zeldaEasy.broadscope-bailian.mcp-server.PageList";
+
+interface ServerSummary {
+ code: string;
+ name: string;
+ description?: string;
+ type: string;
+ source?: string;
+ bizType?: string;
+ installType?: string;
+ streamable: boolean;
+}
+
+export default defineCommand({
+ name: "mcp list",
+ description: "List MCP servers activated under your Bailian account",
+ usage: "bl mcp list [flags]",
+ options: [
+ { flag: "--name <text>", description: "Filter by server name (substring match)" },
+ {
+ flag: "--type <type>",
+ description: "Server type: OFFICIAL | PRIVATE (default: OFFICIAL)",
+ },
+ { flag: "--page <n>", description: "Page number (default: 1)", type: "number" },
+ { flag: "--page-size <n>", description: "Results per page (default: 30)", type: "number" },
+ { flag: "--region <region>", description: "API region (default: cn-beijing)" },
+ ],
+ examples: ["bl mcp list", "bl mcp list --name 金融", "bl mcp list --output json"],
+ async run(config: Config, flags: GlobalFlags) {
+ const serverName = (flags.name as string) || "";
+ const type = (flags.type as string) || "OFFICIAL";
+ const pageNo = (flags.page as number) || 1;
+ const pageSize = (flags.pageSize as number) || 30;
+ const region = (flags.region as string) || "cn-beijing";
+ const format = detectOutputFormat(config.output);
+
+ const data = {
+ reqDTO: {
+ type,
+ displayTools: false,
+ activated: 1,
+ pageNo,
+ pageSize,
+ serverName,
+ },
+ };
+
+ if (config.dryRun) {
+ emitResult({ api: MCP_LIST_API, data, region }, format);
+ return;
+ }
+
+ const credential = await resolveConsoleGatewayCredential(config);
+
+ const result = (await callConsoleGateway(config, credential.token, {
+ api: MCP_LIST_API,
+ data,
+ region,
+ })) as Record<string, unknown>;
+
+ const dataField = (result?.data as Record<string, unknown> | undefined) ?? {};
+ if (dataField.success === false) {
+ const code = (dataField.errorCode as string | undefined) ?? "UnknownError";
+ const msg = (dataField.errorMsg as string | undefined) ?? code;
+ const hint =
+ code === "BailianGateway.Login.NotLogined"
+ ? "Run `bl auth login --console` to refresh your console session."
+ : undefined;
+ throw new BailianError(`Console gateway: ${msg}`, ExitCode.AUTH, hint);
+ }
+ const dataV2 = (dataField.DataV2 as Record<string, unknown> | undefined) ?? {};
+ const inner =
+ (dataV2.data as { data?: { mcpServerDetailList?: unknown[]; total?: number } } | undefined)
+ ?.data ?? {};
+ const list = (inner.mcpServerDetailList ?? []) as Array<Record<string, unknown>>;
+ const total = (inner.total as number) ?? 0;
+
+ const servers: ServerSummary[] = list.map((item) => ({
+ code: (item.serverCode as string | undefined) ?? "",
+ name: (item.serverName as string | undefined) ?? "",
+ description: item.description as string | undefined,
+ type: (item.type as string | undefined) ?? "",
+ source: item.source as string | undefined,
+ bizType: item.bizType as string | undefined,
+ installType: item.installType as string | undefined,
+ streamable: item.streamable === true,
+ }));
+
+ emitResult({ total, servers }, format);
+ },
+});

packages/cli/src/commands/mcp/tools.ts

@@ -0,0 +1,50 @@
+import {
+ defineCommand,
+ McpClient,
+ bailianMcpUrl,
+ detectOutputFormat,
+ type Config,
+ type GlobalFlags,
+} from "bailian-cli-core";
+import { failIfMissing } from "../../output/prompt.ts";
+import { emitResult } from "../../output/output.ts";
+import { ensureApiKey } from "../../utils/ensure-key.ts";
+
+export default defineCommand({
+ name: "mcp tools",
+ description: "List tools exposed by an MCP server (tools/list)",
+ usage: "bl mcp tools <server-code> [--url <url>]",
+ options: [
+ {
+ flag: "<server-code>",
+ description: "Server code from `bl mcp list` (e.g. market-cmapi00073529)",
+ required: true,
+ },
+ { flag: "--url <url>", description: "Override the MCP endpoint URL (for non-Bailian servers)" },
+ ],
+ examples: [
+ "bl mcp tools market-cmapi00073529",
+ "bl mcp tools market-cmapi00073529 --output json",
+ "bl mcp tools my-server --url https://example.com/mcp",
+ ],
+ async run(config: Config, flags: GlobalFlags) {
+ const positional =
+ ((flags as Record<string, unknown>)._positional as string[] | undefined) ?? [];
+ const code = positional[0];
+ if (!code) failIfMissing("server-code", "bl mcp tools <server-code>");
+
+ const url = (flags.url as string) || bailianMcpUrl(config.baseUrl, code!);
+ const format = detectOutputFormat(config.output);
+
+ if (config.dryRun) {
+ emitResult({ server: code, url, action: "tools/list" }, format);
+ return;
+ }
+
+ await ensureApiKey(config);
+ const client = new McpClient(config, url);
+ await client.initialize();
+ const tools = await client.listTools();
+ emitResult({ server: code, url, tools }, format);
+ },
+});

packages/cli/src/commands/search/web.ts

@@ -1,7 +1,7 @@
 import {
  defineCommand,
- mcpWebSearchEndpoint,
  detectOutputFormat,
+ mcpWebSearchEndpoint,
  type Config,
  type GlobalFlags,
  isInteractive,

packages/cli/src/main.ts

@@ -60,6 +60,9 @@ const NO_AUTH_SETUP = [
  ["app", "list"],
  ["console", "call"],
  ["usage", "free"],
+ ["mcp", "list"],
+ ["mcp", "tools"],
+ ["mcp", "call"],
 ];
 
 async function main() {

packages/cli/src/commands/catalog.ts

@@ -27,6 +27,9 @@ import memoryDelete from "./memory/delete.ts";
 import memoryProfileCreate from "./memory/profile-create.ts";
 import memoryProfileGet from "./memory/profile-get.ts";
 import knowledgeRetrieve from "./knowledge/retrieve.ts";
+import mcpCall from "./mcp/call.ts";
+import mcpList from "./mcp/list.ts";
+import mcpTools from "./mcp/tools.ts";
 import searchWeb from "./search/web.ts";
 import speechSynthesize from "./speech/synthesize.ts";
 import speechRecognize from "./speech/recognize.ts";
@@ -61,6 +64,9 @@ export const commands: Record<string, Command> = {
  "memory profile create": memoryProfileCreate,
  "memory profile get": memoryProfileGet,
  "knowledge retrieve": knowledgeRetrieve,
+ "mcp list": mcpList,
+ "mcp tools": mcpTools,
+ "mcp call": mcpCall,
  "search web": searchWeb,
  "speech synthesize": speechSynthesize,
  "speech recognize": speechRecognize,

packages/cli/src/commands/mcp/call.ts

@@ -0,0 +1,123 @@
+import {
+ defineCommand,
+ McpClient,
+ bailianMcpUrl,
+ detectOutputFormat,
+ type Config,
+ type GlobalFlags,
+} from "bailian-cli-core";
+import { failIfMissing } from "../../output/prompt.ts";
+import { emitResult } from "../../output/output.ts";
+import { ensureApiKey } from "../../utils/ensure-key.ts";
+
+function parseArgFlags(raw: string[]): Record<string, unknown> {
+ const out: Record<string, unknown> = {};
+ for (const item of raw) {
+ const idx = item.indexOf("=");
+ if (idx <= 0) {
+ process.stderr.write(`Error: --arg must be in K=V form, got: ${item}\n`);
+ process.exit(1);
+ }
+ const key = item.slice(0, idx).trim();
+ const rawVal = item.slice(idx + 1);
+ try {
+ out[key] = JSON.parse(rawVal);
+ } catch {
+ out[key] = rawVal;
+ }
+ }
+ return out;
+}
+
+export default defineCommand({
+ name: "mcp call",
+ description: "Call a tool on an MCP server (tools/call)",
+ usage: "bl mcp call <server-code>.<tool> [--arg k=v ...] [--json '{...}'] [--url <url>]",
+ options: [
+ {
+ flag: "<server-code>.<tool>",
+ description:
+ "Server code and tool name joined by a dot, e.g. market-cmapi00073529.SmartStockSelection",
+ required: true,
+ },
+ {
+ flag: "--arg <kv>",
+ description: "Tool argument (repeatable). Values parsed as JSON if possible, else string.",
+ type: "array",
+ },
+ {
+ flag: "--json <obj>",
+ description: "Full arguments object as JSON; merged with --arg (arg wins).",
+ },
+ {
+ flag: "--query <text>",
+ description: "Shortcut for --arg query=<text> (mirrors many DashScope MCP tools).",
+ },
+ { flag: "--url <url>", description: "Override the MCP endpoint URL (for non-Bailian servers)" },
+ ],
+ examples: [
+ 'bl mcp call market-cmapi00073529.SmartStockSelection --query "筛选ROE>15%的消费股"',
+ 'bl mcp call market-cmapi00073529.FinQuery --json \'{"q":"贵州茅台","limit":5}\'',
+ "bl mcp call market-cmapi00073529.SmartFundSelection --arg riskLevel=R3 --arg minScale=10",
+ ],
+ async run(config: Config, flags: GlobalFlags) {
+ const positional =
+ ((flags as Record<string, unknown>)._positional as string[] | undefined) ?? [];
+ const target = positional[0];
+ if (!target) failIfMissing("<server-code>.<tool>", "bl mcp call <server-code>.<tool>");
+
+ const dot = target!.indexOf(".");
+ if (dot <= 0 || dot === target!.length - 1) {
+ process.stderr.write(`Error: target must be <server-code>.<tool>, got "${target}".\n`);
+ process.exit(1);
+ }
+ const serverCode = target!.slice(0, dot);
+ const toolName = target!.slice(dot + 1);
+
+ let toolArgs: Record<string, unknown> = {};
+ if (flags.json) {
+ try {
+ const parsed = JSON.parse(flags.json as string);
+ if (!parsed || typeof parsed !== "object" || Array.isArray(parsed)) {
+ process.stderr.write("Error: --json must decode to an object.\n");
+ process.exit(1);
+ }
+ toolArgs = parsed as Record<string, unknown>;
+ } catch (err) {
+ process.stderr.write(`Error: --json is not valid JSON — ${(err as Error).message}\n`);
+ process.exit(1);
+ }
+ }
+ Object.assign(toolArgs, parseArgFlags((flags.arg as string[] | undefined) ?? []));
+ if (flags.query !== undefined) toolArgs.query = flags.query;
+
+ const url = (flags.url as string) || bailianMcpUrl(config.baseUrl, serverCode);
+ const format = detectOutputFormat(config.output);
+
+ if (config.dryRun) {
+ emitResult(
+ {
+ server: serverCode,
+ url,
+ tool: toolName,
+ arguments: toolArgs,
+ },
+ format,
+ );
+ return;
+ }
+
+ await ensureApiKey(config);
+ const client = new McpClient(config, url);
+ await client.initialize();
+ const result = await client.callTool(toolName, toolArgs);
+
+ if (result.isError) {
+ const errText = result.content.map((c) => c.text || "").join("\n");
+ process.stderr.write(`Tool error: ${errText}\n`);
+ process.exit(1);
+ }
+
+ emitResult(result, format);
+ },
+});

packages/cli/src/commands/mcp/list.ts

@@ -0,0 +1,103 @@
+import {
+ defineCommand,
+ callConsoleGateway,
+ resolveConsoleGatewayCredential,
+ detectOutputFormat,
+ BailianError,
+ ExitCode,
+ type Config,
+ type GlobalFlags,
+} from "bailian-cli-core";
+import { emitResult } from "../../output/output.ts";
+
+const MCP_LIST_API = "zeldaEasy.broadscope-bailian.mcp-server.PageList";
+
+interface ServerSummary {
+ code: string;
+ name: string;
+ description?: string;
+ type: string;
+ source?: string;
+ bizType?: string;
+ installType?: string;
+ streamable: boolean;
+}
+
+export default defineCommand({
+ name: "mcp list",
+ description: "List MCP servers activated under your Bailian account",
+ usage: "bl mcp list [flags]",
+ options: [
+ { flag: "--name <text>", description: "Filter by server name (substring match)" },
+ {
+ flag: "--type <type>",
+ description: "Server type: OFFICIAL | PRIVATE (default: OFFICIAL)",
+ },
+ { flag: "--page <n>", description: "Page number (default: 1)", type: "number" },
+ { flag: "--page-size <n>", description: "Results per page (default: 30)", type: "number" },
+ { flag: "--region <region>", description: "API region (default: cn-beijing)" },
+ ],
+ examples: ["bl mcp list", "bl mcp list --name 金融", "bl mcp list --output json"],
+ async run(config: Config, flags: GlobalFlags) {
+ const serverName = (flags.name as string) || "";
+ const type = (flags.type as string) || "OFFICIAL";
+ const pageNo = (flags.page as number) || 1;
+ const pageSize = (flags.pageSize as number) || 30;
+ const region = (flags.region as string) || "cn-beijing";
+ const format = detectOutputFormat(config.output);
+
+ const data = {
+ reqDTO: {
+ type,
+ displayTools: false,
+ activated: 1,
+ pageNo,
+ pageSize,
+ serverName,
+ },
+ };
+
+ if (config.dryRun) {
+ emitResult({ api: MCP_LIST_API, data, region }, format);
+ return;
+ }
+
+ const credential = await resolveConsoleGatewayCredential(config);
+
+ const result = (await callConsoleGateway(config, credential.token, {
+ api: MCP_LIST_API,
+ data,
+ region,
+ })) as Record<string, unknown>;
+
+ const dataField = (result?.data as Record<string, unknown> | undefined) ?? {};
+ if (dataField.success === false) {
+ const code = (dataField.errorCode as string | undefined) ?? "UnknownError";
+ const msg = (dataField.errorMsg as string | undefined) ?? code;
+ const hint =
+ code === "BailianGateway.Login.NotLogined"
+ ? "Run `bl auth login --console` to refresh your console session."
+ : undefined;
+ throw new BailianError(`Console gateway: ${msg}`, ExitCode.AUTH, hint);
+ }
+ const dataV2 = (dataField.DataV2 as Record<string, unknown> | undefined) ?? {};
+ const inner =
+ (dataV2.data as { data?: { mcpServerDetailList?: unknown[]; total?: number } } | undefined)
+ ?.data ?? {};
+ const list = (inner.mcpServerDetailList ?? []) as Array<Record<string, unknown>>;
+ const total = (inner.total as number) ?? 0;
+
+ const servers: ServerSummary[] = list.map((item) => ({
+ code: (item.serverCode as string | undefined) ?? "",
+ name: (item.serverName as string | undefined) ?? "",
+ description: item.description as string | undefined,
+ type: (item.type as string | undefined) ?? "",
+ source: item.source as string | undefined,
+ bizType: item.bizType as string | undefined,
+ installType: item.installType as string | undefined,
+ streamable: item.streamable === true,
+ }));
+
+ emitResult({ total, servers }, format);
+ },
+});

packages/cli/src/commands/mcp/tools.ts

@@ -0,0 +1,50 @@
+import {
+ defineCommand,
+ McpClient,
+ bailianMcpUrl,
+ detectOutputFormat,
+ type Config,
+ type GlobalFlags,
+} from "bailian-cli-core";
+import { failIfMissing } from "../../output/prompt.ts";
+import { emitResult } from "../../output/output.ts";
+import { ensureApiKey } from "../../utils/ensure-key.ts";
+
+export default defineCommand({
+ name: "mcp tools",
+ description: "List tools exposed by an MCP server (tools/list)",
+ usage: "bl mcp tools <server-code> [--url <url>]",
+ options: [
+ {
+ flag: "<server-code>",
+ description: "Server code from `bl mcp list` (e.g. market-cmapi00073529)",
+ required: true,
+ },
+ { flag: "--url <url>", description: "Override the MCP endpoint URL (for non-Bailian servers)" },
+ ],
+ examples: [
+ "bl mcp tools market-cmapi00073529",
+ "bl mcp tools market-cmapi00073529 --output json",
+ "bl mcp tools my-server --url https://example.com/mcp",
+ ],
+ async run(config: Config, flags: GlobalFlags) {
+ const positional =
+ ((flags as Record<string, unknown>)._positional as string[] | undefined) ?? [];
+ const code = positional[0];
+ if (!code) failIfMissing("server-code", "bl mcp tools <server-code>");
+
+ const url = (flags.url as string) || bailianMcpUrl(config.baseUrl, code!);
+ const format = detectOutputFormat(config.output);
+
+ if (config.dryRun) {
+ emitResult({ server: code, url, action: "tools/list" }, format);
+ return;
+ }
+
+ await ensureApiKey(config);
+ const client = new McpClient(config, url);
+ await client.initialize();
+ const tools = await client.listTools();
+ emitResult({ server: code, url, tools }, format);
+ },
+});

packages/cli/src/commands/search/web.ts

@@ -1,7 +1,7 @@
 import {
  defineCommand,
- mcpWebSearchEndpoint,
  detectOutputFormat,
+ mcpWebSearchEndpoint,
  type Config,
  type GlobalFlags,
  isInteractive,

packages/cli/src/main.ts

@@ -60,6 +60,9 @@ const NO_AUTH_SETUP = [
  ["app", "list"],
  ["console", "call"],
  ["usage", "free"],
+ ["mcp", "list"],
+ ["mcp", "tools"],
+ ["mcp", "call"],
 ];
 
 async function main() {

packages/cli/src/commands/catalog.ts

@@ -27,6 +27,9 @@ import memoryDelete from "./memory/delete.ts";
 import memoryProfileCreate from "./memory/profile-create.ts";
 import memoryProfileGet from "./memory/profile-get.ts";
 import knowledgeRetrieve from "./knowledge/retrieve.ts";
+import mcpCall from "./mcp/call.ts";
+import mcpList from "./mcp/list.ts";
+import mcpTools from "./mcp/tools.ts";
 import searchWeb from "./search/web.ts";
 import speechSynthesize from "./speech/synthesize.ts";
 import speechRecognize from "./speech/recognize.ts";
@@ -61,6 +64,9 @@ export const commands: Record<string, Command> = {
  "memory profile create": memoryProfileCreate,
  "memory profile get": memoryProfileGet,
  "knowledge retrieve": knowledgeRetrieve,
+ "mcp list": mcpList,
+ "mcp tools": mcpTools,
+ "mcp call": mcpCall,
  "search web": searchWeb,
  "speech synthesize": speechSynthesize,
  "speech recognize": speechRecognize,

packages/cli/src/commands/mcp/call.ts

@@ -0,0 +1,123 @@
+import {
+ defineCommand,
+ McpClient,
+ bailianMcpUrl,
+ detectOutputFormat,
+ type Config,
+ type GlobalFlags,
+} from "bailian-cli-core";
+import { failIfMissing } from "../../output/prompt.ts";
+import { emitResult } from "../../output/output.ts";
+import { ensureApiKey } from "../../utils/ensure-key.ts";
+
+function parseArgFlags(raw: string[]): Record<string, unknown> {
+ const out: Record<string, unknown> = {};
+ for (const item of raw) {
+ const idx = item.indexOf("=");
+ if (idx <= 0) {
+ process.stderr.write(`Error: --arg must be in K=V form, got: ${item}\n`);
+ process.exit(1);
+ }
+ const key = item.slice(0, idx).trim();
+ const rawVal = item.slice(idx + 1);
+ try {
+ out[key] = JSON.parse(rawVal);
+ } catch {
+ out[key] = rawVal;
+ }
+ }
+ return out;
+}
+
+export default defineCommand({
+ name: "mcp call",
+ description: "Call a tool on an MCP server (tools/call)",
+ usage: "bl mcp call <server-code>.<tool> [--arg k=v ...] [--json '{...}'] [--url <url>]",
+ options: [
+ {
+ flag: "<server-code>.<tool>",
+ description:
+ "Server code and tool name joined by a dot, e.g. market-cmapi00073529.SmartStockSelection",
+ required: true,
+ },
+ {
+ flag: "--arg <kv>",
+ description: "Tool argument (repeatable). Values parsed as JSON if possible, else string.",
+ type: "array",
+ },
+ {
+ flag: "--json <obj>",
+ description: "Full arguments object as JSON; merged with --arg (arg wins).",
+ },
+ {
+ flag: "--query <text>",
+ description: "Shortcut for --arg query=<text> (mirrors many DashScope MCP tools).",
+ },
+ { flag: "--url <url>", description: "Override the MCP endpoint URL (for non-Bailian servers)" },
+ ],
+ examples: [
+ 'bl mcp call market-cmapi00073529.SmartStockSelection --query "筛选ROE>15%的消费股"',
+ 'bl mcp call market-cmapi00073529.FinQuery --json \'{"q":"贵州茅台","limit":5}\'',
+ "bl mcp call market-cmapi00073529.SmartFundSelection --arg riskLevel=R3 --arg minScale=10",
+ ],
+ async run(config: Config, flags: GlobalFlags) {
+ const positional =
+ ((flags as Record<string, unknown>)._positional as string[] | undefined) ?? [];
+ const target = positional[0];
+ if (!target) failIfMissing("<server-code>.<tool>", "bl mcp call <server-code>.<tool>");
+
+ const dot = target!.indexOf(".");
+ if (dot <= 0 || dot === target!.length - 1) {
+ process.stderr.write(`Error: target must be <server-code>.<tool>, got "${target}".\n`);
+ process.exit(1);
+ }
+ const serverCode = target!.slice(0, dot);
+ const toolName = target!.slice(dot + 1);
+
+ let toolArgs: Record<string, unknown> = {};
+ if (flags.json) {
+ try {
+ const parsed = JSON.parse(flags.json as string);
+ if (!parsed || typeof parsed !== "object" || Array.isArray(parsed)) {
+ process.stderr.write("Error: --json must decode to an object.\n");
+ process.exit(1);
+ }
+ toolArgs = parsed as Record<string, unknown>;
+ } catch (err) {
+ process.stderr.write(`Error: --json is not valid JSON — ${(err as Error).message}\n`);
+ process.exit(1);
+ }
+ }
+ Object.assign(toolArgs, parseArgFlags((flags.arg as string[] | undefined) ?? []));
+ if (flags.query !== undefined) toolArgs.query = flags.query;
+
+ const url = (flags.url as string) || bailianMcpUrl(config.baseUrl, serverCode);
+ const format = detectOutputFormat(config.output);
+
+ if (config.dryRun) {
+ emitResult(
+ {
+ server: serverCode,
+ url,
+ tool: toolName,
+ arguments: toolArgs,
+ },
+ format,
+ );
+ return;
+ }
+
+ await ensureApiKey(config);
+ const client = new McpClient(config, url);
+ await client.initialize();
+ const result = await client.callTool(toolName, toolArgs);
+
+ if (result.isError) {
+ const errText = result.content.map((c) => c.text || "").join("\n");
+ process.stderr.write(`Tool error: ${errText}\n`);
+ process.exit(1);
+ }
+
+ emitResult(result, format);
+ },
+});

packages/cli/src/commands/mcp/list.ts

@@ -0,0 +1,103 @@
+import {
+ defineCommand,
+ callConsoleGateway,
+ resolveConsoleGatewayCredential,
+ detectOutputFormat,
+ BailianError,
+ ExitCode,
+ type Config,
+ type GlobalFlags,
+} from "bailian-cli-core";
+import { emitResult } from "../../output/output.ts";
+
+const MCP_LIST_API = "zeldaEasy.broadscope-bailian.mcp-server.PageList";
+
+interface ServerSummary {
+ code: string;
+ name: string;
+ description?: string;
+ type: string;
+ source?: string;
+ bizType?: string;
+ installType?: string;
+ streamable: boolean;
+}
+
+export default defineCommand({
+ name: "mcp list",
+ description: "List MCP servers activated under your Bailian account",
+ usage: "bl mcp list [flags]",
+ options: [
+ { flag: "--name <text>", description: "Filter by server name (substring match)" },
+ {
+ flag: "--type <type>",
+ description: "Server type: OFFICIAL | PRIVATE (default: OFFICIAL)",
+ },
+ { flag: "--page <n>", description: "Page number (default: 1)", type: "number" },
+ { flag: "--page-size <n>", description: "Results per page (default: 30)", type: "number" },
+ { flag: "--region <region>", description: "API region (default: cn-beijing)" },
+ ],
+ examples: ["bl mcp list", "bl mcp list --name 金融", "bl mcp list --output json"],
+ async run(config: Config, flags: GlobalFlags) {
+ const serverName = (flags.name as string) || "";
+ const type = (flags.type as string) || "OFFICIAL";
+ const pageNo = (flags.page as number) || 1;
+ const pageSize = (flags.pageSize as number) || 30;
+ const region = (flags.region as string) || "cn-beijing";
+ const format = detectOutputFormat(config.output);
+
+ const data = {
+ reqDTO: {
+ type,
+ displayTools: false,
+ activated: 1,
+ pageNo,
+ pageSize,
+ serverName,
+ },
+ };
+
+ if (config.dryRun) {
+ emitResult({ api: MCP_LIST_API, data, region }, format);
+ return;
+ }
+
+ const credential = await resolveConsoleGatewayCredential(config);
+
+ const result = (await callConsoleGateway(config, credential.token, {
+ api: MCP_LIST_API,
+ data,
+ region,
+ })) as Record<string, unknown>;
+
+ const dataField = (result?.data as Record<string, unknown> | undefined) ?? {};
+ if (dataField.success === false) {
+ const code = (dataField.errorCode as string | undefined) ?? "UnknownError";
+ const msg = (dataField.errorMsg as string | undefined) ?? code;
+ const hint =
+ code === "BailianGateway.Login.NotLogined"
+ ? "Run `bl auth login --console` to refresh your console session."
+ : undefined;
+ throw new BailianError(`Console gateway: ${msg}`, ExitCode.AUTH, hint);
+ }
+ const dataV2 = (dataField.DataV2 as Record<string, unknown> | undefined) ?? {};
+ const inner =
+ (dataV2.data as { data?: { mcpServerDetailList?: unknown[]; total?: number } } | undefined)
+ ?.data ?? {};
+ const list = (inner.mcpServerDetailList ?? []) as Array<Record<string, unknown>>;
+ const total = (inner.total as number) ?? 0;
+
+ const servers: ServerSummary[] = list.map((item) => ({
+ code: (item.serverCode as string | undefined) ?? "",
+ name: (item.serverName as string | undefined) ?? "",
+ description: item.description as string | undefined,
+ type: (item.type as string | undefined) ?? "",
+ source: item.source as string | undefined,
+ bizType: item.bizType as string | undefined,
+ installType: item.installType as string | undefined,
+ streamable: item.streamable === true,
+ }));
+
+ emitResult({ total, servers }, format);
+ },
+});

packages/cli/src/commands/mcp/tools.ts

@@ -0,0 +1,50 @@
+import {
+ defineCommand,
+ McpClient,
+ bailianMcpUrl,
+ detectOutputFormat,
+ type Config,
+ type GlobalFlags,
+} from "bailian-cli-core";
+import { failIfMissing } from "../../output/prompt.ts";
+import { emitResult } from "../../output/output.ts";
+import { ensureApiKey } from "../../utils/ensure-key.ts";
+
+export default defineCommand({
+ name: "mcp tools",
+ description: "List tools exposed by an MCP server (tools/list)",
+ usage: "bl mcp tools <server-code> [--url <url>]",
+ options: [
+ {
+ flag: "<server-code>",
+ description: "Server code from `bl mcp list` (e.g. market-cmapi00073529)",
+ required: true,
+ },
+ { flag: "--url <url>", description: "Override the MCP endpoint URL (for non-Bailian servers)" },
+ ],
+ examples: [
+ "bl mcp tools market-cmapi00073529",
+ "bl mcp tools market-cmapi00073529 --output json",
+ "bl mcp tools my-server --url https://example.com/mcp",
+ ],
+ async run(config: Config, flags: GlobalFlags) {
+ const positional =
+ ((flags as Record<string, unknown>)._positional as string[] | undefined) ?? [];
+ const code = positional[0];
+ if (!code) failIfMissing("server-code", "bl mcp tools <server-code>");
+
+ const url = (flags.url as string) || bailianMcpUrl(config.baseUrl, code!);
+ const format = detectOutputFormat(config.output);
+
+ if (config.dryRun) {
+ emitResult({ server: code, url, action: "tools/list" }, format);
+ return;
+ }
+
+ await ensureApiKey(config);
+ const client = new McpClient(config, url);
+ await client.initialize();
+ const tools = await client.listTools();
+ emitResult({ server: code, url, tools }, format);
+ },
+});

packages/cli/src/commands/search/web.ts

@@ -1,7 +1,7 @@
 import {
  defineCommand,
- mcpWebSearchEndpoint,
  detectOutputFormat,
+ mcpWebSearchEndpoint,
  type Config,
  type GlobalFlags,
  isInteractive,

packages/cli/src/main.ts

@@ -60,6 +60,9 @@ const NO_AUTH_SETUP = [
  ["app", "list"],
  ["console", "call"],
  ["usage", "free"],
+ ["mcp", "list"],
+ ["mcp", "tools"],
+ ["mcp", "call"],
 ];
 
 async function main() {

packages/cli/src/commands/catalog.ts

@@ -27,6 +27,9 @@ import memoryDelete from "./memory/delete.ts";
 import memoryProfileCreate from "./memory/profile-create.ts";
 import memoryProfileGet from "./memory/profile-get.ts";
 import knowledgeRetrieve from "./knowledge/retrieve.ts";
+import mcpCall from "./mcp/call.ts";
+import mcpList from "./mcp/list.ts";
+import mcpTools from "./mcp/tools.ts";
 import searchWeb from "./search/web.ts";
 import speechSynthesize from "./speech/synthesize.ts";
 import speechRecognize from "./speech/recognize.ts";
@@ -61,6 +64,9 @@ export const commands: Record<string, Command> = {
  "memory profile create": memoryProfileCreate,
  "memory profile get": memoryProfileGet,
  "knowledge retrieve": knowledgeRetrieve,
+ "mcp list": mcpList,
+ "mcp tools": mcpTools,
+ "mcp call": mcpCall,
  "search web": searchWeb,
  "speech synthesize": speechSynthesize,
  "speech recognize": speechRecognize,

packages/cli/src/commands/mcp/call.ts

@@ -0,0 +1,123 @@
+import {
+ defineCommand,
+ McpClient,
+ bailianMcpUrl,
+ detectOutputFormat,
+ type Config,
+ type GlobalFlags,
+} from "bailian-cli-core";
+import { failIfMissing } from "../../output/prompt.ts";
+import { emitResult } from "../../output/output.ts";
+import { ensureApiKey } from "../../utils/ensure-key.ts";
+
+function parseArgFlags(raw: string[]): Record<string, unknown> {
+ const out: Record<string, unknown> = {};
+ for (const item of raw) {
+ const idx = item.indexOf("=");
+ if (idx <= 0) {
+ process.stderr.write(`Error: --arg must be in K=V form, got: ${item}\n`);
+ process.exit(1);
+ }
+ const key = item.slice(0, idx).trim();
+ const rawVal = item.slice(idx + 1);
+ try {
+ out[key] = JSON.parse(rawVal);
+ } catch {
+ out[key] = rawVal;
+ }
+ }
+ return out;
+}
+
+export default defineCommand({
+ name: "mcp call",
+ description: "Call a tool on an MCP server (tools/call)",
+ usage: "bl mcp call <server-code>.<tool> [--arg k=v ...] [--json '{...}'] [--url <url>]",
+ options: [
+ {
+ flag: "<server-code>.<tool>",
+ description:
+ "Server code and tool name joined by a dot, e.g. market-cmapi00073529.SmartStockSelection",
+ required: true,
+ },
+ {
+ flag: "--arg <kv>",
+ description: "Tool argument (repeatable). Values parsed as JSON if possible, else string.",
+ type: "array",
+ },
+ {
+ flag: "--json <obj>",
+ description: "Full arguments object as JSON; merged with --arg (arg wins).",
+ },
+ {
+ flag: "--query <text>",
+ description: "Shortcut for --arg query=<text> (mirrors many DashScope MCP tools).",
+ },
+ { flag: "--url <url>", description: "Override the MCP endpoint URL (for non-Bailian servers)" },
+ ],
+ examples: [
+ 'bl mcp call market-cmapi00073529.SmartStockSelection --query "筛选ROE>15%的消费股"',
+ 'bl mcp call market-cmapi00073529.FinQuery --json \'{"q":"贵州茅台","limit":5}\'',
+ "bl mcp call market-cmapi00073529.SmartFundSelection --arg riskLevel=R3 --arg minScale=10",
+ ],
+ async run(config: Config, flags: GlobalFlags) {
+ const positional =
+ ((flags as Record<string, unknown>)._positional as string[] | undefined) ?? [];
+ const target = positional[0];
+ if (!target) failIfMissing("<server-code>.<tool>", "bl mcp call <server-code>.<tool>");
+
+ const dot = target!.indexOf(".");
+ if (dot <= 0 || dot === target!.length - 1) {
+ process.stderr.write(`Error: target must be <server-code>.<tool>, got "${target}".\n`);
+ process.exit(1);
+ }
+ const serverCode = target!.slice(0, dot);
+ const toolName = target!.slice(dot + 1);
+
+ let toolArgs: Record<string, unknown> = {};
+ if (flags.json) {
+ try {
+ const parsed = JSON.parse(flags.json as string);
+ if (!parsed || typeof parsed !== "object" || Array.isArray(parsed)) {
+ process.stderr.write("Error: --json must decode to an object.\n");
+ process.exit(1);
+ }
+ toolArgs = parsed as Record<string, unknown>;
+ } catch (err) {
+ process.stderr.write(`Error: --json is not valid JSON — ${(err as Error).message}\n`);
+ process.exit(1);
+ }
+ }
+ Object.assign(toolArgs, parseArgFlags((flags.arg as string[] | undefined) ?? []));
+ if (flags.query !== undefined) toolArgs.query = flags.query;
+
+ const url = (flags.url as string) || bailianMcpUrl(config.baseUrl, serverCode);
+ const format = detectOutputFormat(config.output);
+
+ if (config.dryRun) {
+ emitResult(
+ {
+ server: serverCode,
+ url,
+ tool: toolName,
+ arguments: toolArgs,
+ },
+ format,
+ );
+ return;
+ }
+
+ await ensureApiKey(config);
+ const client = new McpClient(config, url);
+ await client.initialize();
+ const result = await client.callTool(toolName, toolArgs);
+
+ if (result.isError) {
+ const errText = result.content.map((c) => c.text || "").join("\n");
+ process.stderr.write(`Tool error: ${errText}\n`);
+ process.exit(1);
+ }
+
+ emitResult(result, format);
+ },
+});

packages/cli/src/commands/mcp/list.ts

@@ -0,0 +1,103 @@
+import {
+ defineCommand,
+ callConsoleGateway,
+ resolveConsoleGatewayCredential,
+ detectOutputFormat,
+ BailianError,
+ ExitCode,
+ type Config,
+ type GlobalFlags,
+} from "bailian-cli-core";
+import { emitResult } from "../../output/output.ts";
+
+const MCP_LIST_API = "zeldaEasy.broadscope-bailian.mcp-server.PageList";
+
+interface ServerSummary {
+ code: string;
+ name: string;
+ description?: string;
+ type: string;
+ source?: string;
+ bizType?: string;
+ installType?: string;
+ streamable: boolean;
+}
+
+export default defineCommand({
+ name: "mcp list",
+ description: "List MCP servers activated under your Bailian account",
+ usage: "bl mcp list [flags]",
+ options: [
+ { flag: "--name <text>", description: "Filter by server name (substring match)" },
+ {
+ flag: "--type <type>",
+ description: "Server type: OFFICIAL | PRIVATE (default: OFFICIAL)",
+ },
+ { flag: "--page <n>", description: "Page number (default: 1)", type: "number" },
+ { flag: "--page-size <n>", description: "Results per page (default: 30)", type: "number" },
+ { flag: "--region <region>", description: "API region (default: cn-beijing)" },
+ ],
+ examples: ["bl mcp list", "bl mcp list --name 金融", "bl mcp list --output json"],
+ async run(config: Config, flags: GlobalFlags) {
+ const serverName = (flags.name as string) || "";
+ const type = (flags.type as string) || "OFFICIAL";
+ const pageNo = (flags.page as number) || 1;
+ const pageSize = (flags.pageSize as number) || 30;
+ const region = (flags.region as string) || "cn-beijing";
+ const format = detectOutputFormat(config.output);
+
+ const data = {
+ reqDTO: {
+ type,
+ displayTools: false,
+ activated: 1,
+ pageNo,
+ pageSize,
+ serverName,
+ },
+ };
+
+ if (config.dryRun) {
+ emitResult({ api: MCP_LIST_API, data, region }, format);
+ return;
+ }
+
+ const credential = await resolveConsoleGatewayCredential(config);
+
+ const result = (await callConsoleGateway(config, credential.token, {
+ api: MCP_LIST_API,
+ data,
+ region,
+ })) as Record<string, unknown>;
+
+ const dataField = (result?.data as Record<string, unknown> | undefined) ?? {};
+ if (dataField.success === false) {
+ const code = (dataField.errorCode as string | undefined) ?? "UnknownError";
+ const msg = (dataField.errorMsg as string | undefined) ?? code;
+ const hint =
+ code === "BailianGateway.Login.NotLogined"
+ ? "Run `bl auth login --console` to refresh your console session."
+ : undefined;
+ throw new BailianError(`Console gateway: ${msg}`, ExitCode.AUTH, hint);
+ }
+ const dataV2 = (dataField.DataV2 as Record<string, unknown> | undefined) ?? {};
+ const inner =
+ (dataV2.data as { data?: { mcpServerDetailList?: unknown[]; total?: number } } | undefined)
+ ?.data ?? {};
+ const list = (inner.mcpServerDetailList ?? []) as Array<Record<string, unknown>>;
+ const total = (inner.total as number) ?? 0;
+
+ const servers: ServerSummary[] = list.map((item) => ({
+ code: (item.serverCode as string | undefined) ?? "",
+ name: (item.serverName as string | undefined) ?? "",
+ description: item.description as string | undefined,
+ type: (item.type as string | undefined) ?? "",
+ source: item.source as string | undefined,
+ bizType: item.bizType as string | undefined,
+ installType: item.installType as string | undefined,
+ streamable: item.streamable === true,
+ }));
+
+ emitResult({ total, servers }, format);
+ },
+});

packages/cli/src/commands/mcp/tools.ts

@@ -0,0 +1,50 @@
+import {
+ defineCommand,
+ McpClient,
+ bailianMcpUrl,
+ detectOutputFormat,
+ type Config,
+ type GlobalFlags,
+} from "bailian-cli-core";
+import { failIfMissing } from "../../output/prompt.ts";
+import { emitResult } from "../../output/output.ts";
+import { ensureApiKey } from "../../utils/ensure-key.ts";
+
+export default defineCommand({
+ name: "mcp tools",
+ description: "List tools exposed by an MCP server (tools/list)",
+ usage: "bl mcp tools <server-code> [--url <url>]",
+ options: [
+ {
+ flag: "<server-code>",
+ description: "Server code from `bl mcp list` (e.g. market-cmapi00073529)",
+ required: true,
+ },
+ { flag: "--url <url>", description: "Override the MCP endpoint URL (for non-Bailian servers)" },
+ ],
+ examples: [
+ "bl mcp tools market-cmapi00073529",
+ "bl mcp tools market-cmapi00073529 --output json",
+ "bl mcp tools my-server --url https://example.com/mcp",
+ ],
+ async run(config: Config, flags: GlobalFlags) {
+ const positional =
+ ((flags as Record<string, unknown>)._positional as string[] | undefined) ?? [];
+ const code = positional[0];
+ if (!code) failIfMissing("server-code", "bl mcp tools <server-code>");
+
+ const url = (flags.url as string) || bailianMcpUrl(config.baseUrl, code!);
+ const format = detectOutputFormat(config.output);
+
+ if (config.dryRun) {
+ emitResult({ server: code, url, action: "tools/list" }, format);
+ return;
+ }
+
+ await ensureApiKey(config);
+ const client = new McpClient(config, url);
+ await client.initialize();
+ const tools = await client.listTools();
+ emitResult({ server: code, url, tools }, format);
+ },
+});

packages/cli/src/commands/search/web.ts

@@ -1,7 +1,7 @@
 import {
  defineCommand,
- mcpWebSearchEndpoint,
  detectOutputFormat,
+ mcpWebSearchEndpoint,
  type Config,
  type GlobalFlags,
  isInteractive,

packages/cli/src/main.ts

@@ -60,6 +60,9 @@ const NO_AUTH_SETUP = [
  ["app", "list"],
  ["console", "call"],
  ["usage", "free"],
+ ["mcp", "list"],
+ ["mcp", "tools"],
+ ["mcp", "call"],
 ];
 
 async function main() {

packages/cli/src/commands/catalog.ts

@@ -27,6 +27,9 @@ import memoryDelete from "./memory/delete.ts";
 import memoryProfileCreate from "./memory/profile-create.ts";
 import memoryProfileGet from "./memory/profile-get.ts";
 import knowledgeRetrieve from "./knowledge/retrieve.ts";
+import mcpCall from "./mcp/call.ts";
+import mcpList from "./mcp/list.ts";
+import mcpTools from "./mcp/tools.ts";
 import searchWeb from "./search/web.ts";
 import speechSynthesize from "./speech/synthesize.ts";
 import speechRecognize from "./speech/recognize.ts";
@@ -61,6 +64,9 @@ export const commands: Record<string, Command> = {
  "memory profile create": memoryProfileCreate,
  "memory profile get": memoryProfileGet,
  "knowledge retrieve": knowledgeRetrieve,
+ "mcp list": mcpList,
+ "mcp tools": mcpTools,
+ "mcp call": mcpCall,
  "search web": searchWeb,
  "speech synthesize": speechSynthesize,
  "speech recognize": speechRecognize,

packages/cli/src/commands/mcp/call.ts

@@ -0,0 +1,123 @@
+import {
+ defineCommand,
+ McpClient,
+ bailianMcpUrl,
+ detectOutputFormat,
+ type Config,
+ type GlobalFlags,
+} from "bailian-cli-core";
+import { failIfMissing } from "../../output/prompt.ts";
+import { emitResult } from "../../output/output.ts";
+import { ensureApiKey } from "../../utils/ensure-key.ts";
+
+function parseArgFlags(raw: string[]): Record<string, unknown> {
+ const out: Record<string, unknown> = {};
+ for (const item of raw) {
+ const idx = item.indexOf("=");
+ if (idx <= 0) {
+ process.stderr.write(`Error: --arg must be in K=V form, got: ${item}\n`);
+ process.exit(1);
+ }
+ const key = item.slice(0, idx).trim();
+ const rawVal = item.slice(idx + 1);
+ try {
+ out[key] = JSON.parse(rawVal);
+ } catch {
+ out[key] = rawVal;
+ }
+ }
+ return out;
+}
+
+export default defineCommand({
+ name: "mcp call",
+ description: "Call a tool on an MCP server (tools/call)",
+ usage: "bl mcp call <server-code>.<tool> [--arg k=v ...] [--json '{...}'] [--url <url>]",
+ options: [
+ {
+ flag: "<server-code>.<tool>",
+ description:
+ "Server code and tool name joined by a dot, e.g. market-cmapi00073529.SmartStockSelection",
+ required: true,
+ },
+ {
+ flag: "--arg <kv>",
+ description: "Tool argument (repeatable). Values parsed as JSON if possible, else string.",
+ type: "array",
+ },
+ {
+ flag: "--json <obj>",
+ description: "Full arguments object as JSON; merged with --arg (arg wins).",
+ },
+ {
+ flag: "--query <text>",
+ description: "Shortcut for --arg query=<text> (mirrors many DashScope MCP tools).",
+ },
+ { flag: "--url <url>", description: "Override the MCP endpoint URL (for non-Bailian servers)" },
+ ],
+ examples: [
+ 'bl mcp call market-cmapi00073529.SmartStockSelection --query "筛选ROE>15%的消费股"',
+ 'bl mcp call market-cmapi00073529.FinQuery --json \'{"q":"贵州茅台","limit":5}\'',
+ "bl mcp call market-cmapi00073529.SmartFundSelection --arg riskLevel=R3 --arg minScale=10",
+ ],
+ async run(config: Config, flags: GlobalFlags) {
+ const positional =
+ ((flags as Record<string, unknown>)._positional as string[] | undefined) ?? [];
+ const target = positional[0];
+ if (!target) failIfMissing("<server-code>.<tool>", "bl mcp call <server-code>.<tool>");
+
+ const dot = target!.indexOf(".");
+ if (dot <= 0 || dot === target!.length - 1) {
+ process.stderr.write(`Error: target must be <server-code>.<tool>, got "${target}".\n`);
+ process.exit(1);
+ }
+ const serverCode = target!.slice(0, dot);
+ const toolName = target!.slice(dot + 1);
+
+ let toolArgs: Record<string, unknown> = {};
+ if (flags.json) {
+ try {
+ const parsed = JSON.parse(flags.json as string);
+ if (!parsed || typeof parsed !== "object" || Array.isArray(parsed)) {
+ process.stderr.write("Error: --json must decode to an object.\n");
+ process.exit(1);
+ }
+ toolArgs = parsed as Record<string, unknown>;
+ } catch (err) {
+ process.stderr.write(`Error: --json is not valid JSON — ${(err as Error).message}\n`);
+ process.exit(1);
+ }
+ }
+ Object.assign(toolArgs, parseArgFlags((flags.arg as string[] | undefined) ?? []));
+ if (flags.query !== undefined) toolArgs.query = flags.query;
+
+ const url = (flags.url as string) || bailianMcpUrl(config.baseUrl, serverCode);
+ const format = detectOutputFormat(config.output);
+
+ if (config.dryRun) {
+ emitResult(
+ {
+ server: serverCode,
+ url,
+ tool: toolName,
+ arguments: toolArgs,
+ },
+ format,
+ );
+ return;
+ }
+
+ await ensureApiKey(config);
+ const client = new McpClient(config, url);
+ await client.initialize();
+ const result = await client.callTool(toolName, toolArgs);
+
+ if (result.isError) {
+ const errText = result.content.map((c) => c.text || "").join("\n");
+ process.stderr.write(`Tool error: ${errText}\n`);
+ process.exit(1);
+ }
+
+ emitResult(result, format);
+ },
+});

packages/cli/src/commands/mcp/list.ts

@@ -0,0 +1,103 @@
+import {
+ defineCommand,
+ callConsoleGateway,
+ resolveConsoleGatewayCredential,
+ detectOutputFormat,
+ BailianError,
+ ExitCode,
+ type Config,
+ type GlobalFlags,
+} from "bailian-cli-core";
+import { emitResult } from "../../output/output.ts";
+
+const MCP_LIST_API = "zeldaEasy.broadscope-bailian.mcp-server.PageList";
+
+interface ServerSummary {
+ code: string;
+ name: string;
+ description?: string;
+ type: string;
+ source?: string;
+ bizType?: string;
+ installType?: string;
+ streamable: boolean;
+}
+
+export default defineCommand({
+ name: "mcp list",
+ description: "List MCP servers activated under your Bailian account",
+ usage: "bl mcp list [flags]",
+ options: [
+ { flag: "--name <text>", description: "Filter by server name (substring match)" },
+ {
+ flag: "--type <type>",
+ description: "Server type: OFFICIAL | PRIVATE (default: OFFICIAL)",
+ },
+ { flag: "--page <n>", description: "Page number (default: 1)", type: "number" },
+ { flag: "--page-size <n>", description: "Results per page (default: 30)", type: "number" },
+ { flag: "--region <region>", description: "API region (default: cn-beijing)" },
+ ],
+ examples: ["bl mcp list", "bl mcp list --name 金融", "bl mcp list --output json"],
+ async run(config: Config, flags: GlobalFlags) {
+ const serverName = (flags.name as string) || "";
+ const type = (flags.type as string) || "OFFICIAL";
+ const pageNo = (flags.page as number) || 1;
+ const pageSize = (flags.pageSize as number) || 30;
+ const region = (flags.region as string) || "cn-beijing";
+ const format = detectOutputFormat(config.output);
+
+ const data = {
+ reqDTO: {
+ type,
+ displayTools: false,
+ activated: 1,
+ pageNo,
+ pageSize,
+ serverName,
+ },
+ };
+
+ if (config.dryRun) {
+ emitResult({ api: MCP_LIST_API, data, region }, format);
+ return;
+ }
+
+ const credential = await resolveConsoleGatewayCredential(config);
+
+ const result = (await callConsoleGateway(config, credential.token, {
+ api: MCP_LIST_API,
+ data,
+ region,
+ })) as Record<string, unknown>;
+
+ const dataField = (result?.data as Record<string, unknown> | undefined) ?? {};
+ if (dataField.success === false) {
+ const code = (dataField.errorCode as string | undefined) ?? "UnknownError";
+ const msg = (dataField.errorMsg as string | undefined) ?? code;
+ const hint =
+ code === "BailianGateway.Login.NotLogined"
+ ? "Run `bl auth login --console` to refresh your console session."
+ : undefined;
+ throw new BailianError(`Console gateway: ${msg}`, ExitCode.AUTH, hint);
+ }
+ const dataV2 = (dataField.DataV2 as Record<string, unknown> | undefined) ?? {};
+ const inner =
+ (dataV2.data as { data?: { mcpServerDetailList?: unknown[]; total?: number } } | undefined)
+ ?.data ?? {};
+ const list = (inner.mcpServerDetailList ?? []) as Array<Record<string, unknown>>;
+ const total = (inner.total as number) ?? 0;
+
+ const servers: ServerSummary[] = list.map((item) => ({
+ code: (item.serverCode as string | undefined) ?? "",
+ name: (item.serverName as string | undefined) ?? "",
+ description: item.description as string | undefined,
+ type: (item.type as string | undefined) ?? "",
+ source: item.source as string | undefined,
+ bizType: item.bizType as string | undefined,
+ installType: item.installType as string | undefined,
+ streamable: item.streamable === true,
+ }));
+
+ emitResult({ total, servers }, format);
+ },
+});

packages/cli/src/commands/mcp/tools.ts

@@ -0,0 +1,50 @@
+import {
+ defineCommand,
+ McpClient,
+ bailianMcpUrl,
+ detectOutputFormat,
+ type Config,
+ type GlobalFlags,
+} from "bailian-cli-core";
+import { failIfMissing } from "../../output/prompt.ts";
+import { emitResult } from "../../output/output.ts";
+import { ensureApiKey } from "../../utils/ensure-key.ts";
+
+export default defineCommand({
+ name: "mcp tools",
+ description: "List tools exposed by an MCP server (tools/list)",
+ usage: "bl mcp tools <server-code> [--url <url>]",
+ options: [
+ {
+ flag: "<server-code>",
+ description: "Server code from `bl mcp list` (e.g. market-cmapi00073529)",
+ required: true,
+ },
+ { flag: "--url <url>", description: "Override the MCP endpoint URL (for non-Bailian servers)" },
+ ],
+ examples: [
+ "bl mcp tools market-cmapi00073529",
+ "bl mcp tools market-cmapi00073529 --output json",
+ "bl mcp tools my-server --url https://example.com/mcp",
+ ],
+ async run(config: Config, flags: GlobalFlags) {
+ const positional =
+ ((flags as Record<string, unknown>)._positional as string[] | undefined) ?? [];
+ const code = positional[0];
+ if (!code) failIfMissing("server-code", "bl mcp tools <server-code>");
+
+ const url = (flags.url as string) || bailianMcpUrl(config.baseUrl, code!);
+ const format = detectOutputFormat(config.output);
+
+ if (config.dryRun) {
+ emitResult({ server: code, url, action: "tools/list" }, format);
+ return;
+ }
+
+ await ensureApiKey(config);
+ const client = new McpClient(config, url);
+ await client.initialize();
+ const tools = await client.listTools();
+ emitResult({ server: code, url, tools }, format);
+ },
+});

packages/cli/src/commands/search/web.ts

@@ -1,7 +1,7 @@
 import {
  defineCommand,
- mcpWebSearchEndpoint,
  detectOutputFormat,
+ mcpWebSearchEndpoint,
  type Config,
  type GlobalFlags,
  isInteractive,

packages/cli/src/main.ts

@@ -60,6 +60,9 @@ const NO_AUTH_SETUP = [
  ["app", "list"],
  ["console", "call"],
  ["usage", "free"],
+ ["mcp", "list"],
+ ["mcp", "tools"],
+ ["mcp", "call"],
 ];
 
 async function main() {

packages/cli/src/commands/catalog.ts

@@ -27,6 +27,9 @@ import memoryDelete from "./memory/delete.ts";
 import memoryProfileCreate from "./memory/profile-create.ts";
 import memoryProfileGet from "./memory/profile-get.ts";
 import knowledgeRetrieve from "./knowledge/retrieve.ts";
+import mcpCall from "./mcp/call.ts";
+import mcpList from "./mcp/list.ts";
+import mcpTools from "./mcp/tools.ts";
 import searchWeb from "./search/web.ts";
 import speechSynthesize from "./speech/synthesize.ts";
 import speechRecognize from "./speech/recognize.ts";
@@ -61,6 +64,9 @@ export const commands: Record<string, Command> = {
  "memory profile create": memoryProfileCreate,
  "memory profile get": memoryProfileGet,
  "knowledge retrieve": knowledgeRetrieve,
+ "mcp list": mcpList,
+ "mcp tools": mcpTools,
+ "mcp call": mcpCall,
  "search web": searchWeb,
  "speech synthesize": speechSynthesize,
  "speech recognize": speechRecognize,

packages/cli/src/commands/mcp/call.ts

@@ -0,0 +1,123 @@
+import {
+ defineCommand,
+ McpClient,
+ bailianMcpUrl,
+ detectOutputFormat,
+ type Config,
+ type GlobalFlags,
+} from "bailian-cli-core";
+import { failIfMissing } from "../../output/prompt.ts";
+import { emitResult } from "../../output/output.ts";
+import { ensureApiKey } from "../../utils/ensure-key.ts";
+
+function parseArgFlags(raw: string[]): Record<string, unknown> {
+ const out: Record<string, unknown> = {};
+ for (const item of raw) {
+ const idx = item.indexOf("=");
+ if (idx <= 0) {
+ process.stderr.write(`Error: --arg must be in K=V form, got: ${item}\n`);
+ process.exit(1);
+ }
+ const key = item.slice(0, idx).trim();
+ const rawVal = item.slice(idx + 1);
+ try {
+ out[key] = JSON.parse(rawVal);
+ } catch {
+ out[key] = rawVal;
+ }
+ }
+ return out;
+}
+
+export default defineCommand({
+ name: "mcp call",
+ description: "Call a tool on an MCP server (tools/call)",
+ usage: "bl mcp call <server-code>.<tool> [--arg k=v ...] [--json '{...}'] [--url <url>]",
+ options: [
+ {
+ flag: "<server-code>.<tool>",
+ description:
+ "Server code and tool name joined by a dot, e.g. market-cmapi00073529.SmartStockSelection",
+ required: true,
+ },
+ {
+ flag: "--arg <kv>",
+ description: "Tool argument (repeatable). Values parsed as JSON if possible, else string.",
+ type: "array",
+ },
+ {
+ flag: "--json <obj>",
+ description: "Full arguments object as JSON; merged with --arg (arg wins).",
+ },
+ {
+ flag: "--query <text>",
+ description: "Shortcut for --arg query=<text> (mirrors many DashScope MCP tools).",
+ },
+ { flag: "--url <url>", description: "Override the MCP endpoint URL (for non-Bailian servers)" },
+ ],
+ examples: [
+ 'bl mcp call market-cmapi00073529.SmartStockSelection --query "筛选ROE>15%的消费股"',
+ 'bl mcp call market-cmapi00073529.FinQuery --json \'{"q":"贵州茅台","limit":5}\'',
+ "bl mcp call market-cmapi00073529.SmartFundSelection --arg riskLevel=R3 --arg minScale=10",
+ ],
+ async run(config: Config, flags: GlobalFlags) {
+ const positional =
+ ((flags as Record<string, unknown>)._positional as string[] | undefined) ?? [];
+ const target = positional[0];
+ if (!target) failIfMissing("<server-code>.<tool>", "bl mcp call <server-code>.<tool>");
+
+ const dot = target!.indexOf(".");
+ if (dot <= 0 || dot === target!.length - 1) {
+ process.stderr.write(`Error: target must be <server-code>.<tool>, got "${target}".\n`);
+ process.exit(1);
+ }
+ const serverCode = target!.slice(0, dot);
+ const toolName = target!.slice(dot + 1);
+
+ let toolArgs: Record<string, unknown> = {};
+ if (flags.json) {
+ try {
+ const parsed = JSON.parse(flags.json as string);
+ if (!parsed || typeof parsed !== "object" || Array.isArray(parsed)) {
+ process.stderr.write("Error: --json must decode to an object.\n");
+ process.exit(1);
+ }
+ toolArgs = parsed as Record<string, unknown>;
+ } catch (err) {
+ process.stderr.write(`Error: --json is not valid JSON — ${(err as Error).message}\n`);
+ process.exit(1);
+ }
+ }
+ Object.assign(toolArgs, parseArgFlags((flags.arg as string[] | undefined) ?? []));
+ if (flags.query !== undefined) toolArgs.query = flags.query;
+
+ const url = (flags.url as string) || bailianMcpUrl(config.baseUrl, serverCode);
+ const format = detectOutputFormat(config.output);
+
+ if (config.dryRun) {
+ emitResult(
+ {
+ server: serverCode,
+ url,
+ tool: toolName,
+ arguments: toolArgs,
+ },
+ format,
+ );
+ return;
+ }
+
+ await ensureApiKey(config);
+ const client = new McpClient(config, url);
+ await client.initialize();
+ const result = await client.callTool(toolName, toolArgs);
+
+ if (result.isError) {
+ const errText = result.content.map((c) => c.text || "").join("\n");
+ process.stderr.write(`Tool error: ${errText}\n`);
+ process.exit(1);
+ }
+
+ emitResult(result, format);
+ },
+});

packages/cli/src/commands/mcp/list.ts

@@ -0,0 +1,103 @@
+import {
+ defineCommand,
+ callConsoleGateway,
+ resolveConsoleGatewayCredential,
+ detectOutputFormat,
+ BailianError,
+ ExitCode,
+ type Config,
+ type GlobalFlags,
+} from "bailian-cli-core";
+import { emitResult } from "../../output/output.ts";
+
+const MCP_LIST_API = "zeldaEasy.broadscope-bailian.mcp-server.PageList";
+
+interface ServerSummary {
+ code: string;
+ name: string;
+ description?: string;
+ type: string;
+ source?: string;
+ bizType?: string;
+ installType?: string;
+ streamable: boolean;
+}
+
+export default defineCommand({
+ name: "mcp list",
+ description: "List MCP servers activated under your Bailian account",
+ usage: "bl mcp list [flags]",
+ options: [
+ { flag: "--name <text>", description: "Filter by server name (substring match)" },
+ {
+ flag: "--type <type>",
+ description: "Server type: OFFICIAL | PRIVATE (default: OFFICIAL)",
+ },
+ { flag: "--page <n>", description: "Page number (default: 1)", type: "number" },
+ { flag: "--page-size <n>", description: "Results per page (default: 30)", type: "number" },
+ { flag: "--region <region>", description: "API region (default: cn-beijing)" },
+ ],
+ examples: ["bl mcp list", "bl mcp list --name 金融", "bl mcp list --output json"],
+ async run(config: Config, flags: GlobalFlags) {
+ const serverName = (flags.name as string) || "";
+ const type = (flags.type as string) || "OFFICIAL";
+ const pageNo = (flags.page as number) || 1;
+ const pageSize = (flags.pageSize as number) || 30;
+ const region = (flags.region as string) || "cn-beijing";
+ const format = detectOutputFormat(config.output);
+
+ const data = {
+ reqDTO: {
+ type,
+ displayTools: false,
+ activated: 1,
+ pageNo,
+ pageSize,
+ serverName,
+ },
+ };
+
+ if (config.dryRun) {
+ emitResult({ api: MCP_LIST_API, data, region }, format);
+ return;
+ }
+
+ const credential = await resolveConsoleGatewayCredential(config);
+
+ const result = (await callConsoleGateway(config, credential.token, {
+ api: MCP_LIST_API,
+ data,
+ region,
+ })) as Record<string, unknown>;
+
+ const dataField = (result?.data as Record<string, unknown> | undefined) ?? {};
+ if (dataField.success === false) {
+ const code = (dataField.errorCode as string | undefined) ?? "UnknownError";
+ const msg = (dataField.errorMsg as string | undefined) ?? code;
+ const hint =
+ code === "BailianGateway.Login.NotLogined"
+ ? "Run `bl auth login --console` to refresh your console session."
+ : undefined;
+ throw new BailianError(`Console gateway: ${msg}`, ExitCode.AUTH, hint);
+ }
+ const dataV2 = (dataField.DataV2 as Record<string, unknown> | undefined) ?? {};
+ const inner =
+ (dataV2.data as { data?: { mcpServerDetailList?: unknown[]; total?: number } } | undefined)
+ ?.data ?? {};
+ const list = (inner.mcpServerDetailList ?? []) as Array<Record<string, unknown>>;
+ const total = (inner.total as number) ?? 0;
+
+ const servers: ServerSummary[] = list.map((item) => ({
+ code: (item.serverCode as string | undefined) ?? "",
+ name: (item.serverName as string | undefined) ?? "",
+ description: item.description as string | undefined,
+ type: (item.type as string | undefined) ?? "",
+ source: item.source as string | undefined,
+ bizType: item.bizType as string | undefined,
+ installType: item.installType as string | undefined,
+ streamable: item.streamable === true,
+ }));
+
+ emitResult({ total, servers }, format);
+ },
+});

packages/cli/src/commands/mcp/tools.ts

@@ -0,0 +1,50 @@
+import {
+ defineCommand,
+ McpClient,
+ bailianMcpUrl,
+ detectOutputFormat,
+ type Config,
+ type GlobalFlags,
+} from "bailian-cli-core";
+import { failIfMissing } from "../../output/prompt.ts";
+import { emitResult } from "../../output/output.ts";
+import { ensureApiKey } from "../../utils/ensure-key.ts";
+
+export default defineCommand({
+ name: "mcp tools",
+ description: "List tools exposed by an MCP server (tools/list)",
+ usage: "bl mcp tools <server-code> [--url <url>]",
+ options: [
+ {
+ flag: "<server-code>",
+ description: "Server code from `bl mcp list` (e.g. market-cmapi00073529)",
+ required: true,
+ },
+ { flag: "--url <url>", description: "Override the MCP endpoint URL (for non-Bailian servers)" },
+ ],
+ examples: [
+ "bl mcp tools market-cmapi00073529",
+ "bl mcp tools market-cmapi00073529 --output json",
+ "bl mcp tools my-server --url https://example.com/mcp",
+ ],
+ async run(config: Config, flags: GlobalFlags) {
+ const positional =
+ ((flags as Record<string, unknown>)._positional as string[] | undefined) ?? [];
+ const code = positional[0];
+ if (!code) failIfMissing("server-code", "bl mcp tools <server-code>");
+
+ const url = (flags.url as string) || bailianMcpUrl(config.baseUrl, code!);
+ const format = detectOutputFormat(config.output);
+
+ if (config.dryRun) {
+ emitResult({ server: code, url, action: "tools/list" }, format);
+ return;
+ }
+
+ await ensureApiKey(config);
+ const client = new McpClient(config, url);
+ await client.initialize();
+ const tools = await client.listTools();
+ emitResult({ server: code, url, tools }, format);
+ },
+});

packages/cli/src/commands/search/web.ts

@@ -1,7 +1,7 @@
 import {
  defineCommand,
- mcpWebSearchEndpoint,
  detectOutputFormat,
+ mcpWebSearchEndpoint,
  type Config,
  type GlobalFlags,
  isInteractive,

packages/cli/src/main.ts

@@ -60,6 +60,9 @@ const NO_AUTH_SETUP = [
  ["app", "list"],
  ["console", "call"],
  ["usage", "free"],
+ ["mcp", "list"],
+ ["mcp", "tools"],
+ ["mcp", "call"],
 ];
 
 async function main() {