fix(core): 修复 SSE 流 GET 失败时的错误消息重建

- 移除 image/edit.ts 中对 resolveAutoImageInput 的 localize 参数
- 简化 aigc-mcp.ts 中 resolveAutoImageInput 和 resolveAutoAudioInput 的参数，取消 localize
- 调整 MCP 错误提示文案，使 "auto" 模型失败时提示更清晰
- core/client/mcp-sdk.ts 中增加对经典 SSE 流 GET 失败的捕获与状态体重建
- mapSdkError 函数支持通过捕获的 SSE GET 失败信息重建错误消息
- SdkMcpAdapter 内部保存并使用 SSE GET 失败信息映射错误
- 在 fetch 拦截中，当 SSE GET 非 2xx 返回时读取响应体并传递供错误重建使用
- 添加多个测试覆盖包括 SseError 结合 SSE GET 失败的错误映射及适配器流程测试

Author: wangmingxiang

packages/commands/src/commands/image/edit.ts

@@ -385,7 +385,7 @@ async function handleAutoMcpMode(
     throw new BailianError("Provide one --image to edit.", ExitCode.USAGE);
   }
 
-  const imageUrl = resolveAutoImageInput(source, localize);
+  const imageUrl = resolveAutoImageInput(source);
   const concurrent = getConcurrency(flags);
   const args = buildImageEditArgs({
     imageUrl,

packages/commands/src/commands/shared/aigc-mcp.ts

@@ -268,47 +268,30 @@ export function assertMcpTtsVoice(voice: string, localize: Localize): void {
 
 // ---- Local file input (auto mode inlines files as base64 data URIs) ----
 
-/**
- * Conservative cap on the inline base64 data-URI size sent through MCP. The
- * AIGC MCP servers accept a public http(s) URL or a base64 data URI but reject
- * `oss://` and private upload URLs, so `auto` mode inlines local files; an
- * oversized payload would bloat the JSON-RPC body and fail obscurely, so it is
- * rejected up front with an actionable message.
- */
-const MAX_MCP_DATA_URI_BYTES = 10 * 1024 * 1024;
-
 /** True for inputs already carrying a URL / inline scheme (not a local path). */
 function isUrlScheme(source: string): boolean {
   return /^(https?|oss|data):/i.test(source);
 }
 
-function guardDataUriSize(dataUri: string, kind: "image" | "audio", localize: Localize): string {
-  if (dataUri.length <= MAX_MCP_DATA_URI_BYTES) return dataUri;
-  const message = localize({
-    "en-US": `The local ${kind} file is too large to inline through MCP in auto mode (limit ~10 MB after base64 encoding). Host it at a public http(s) URL, or switch to a specific --model.`,
-    "zh-CN": `本地${kind === "image" ? "图片" : "音频"}文件过大，无法在 auto 模式下通过 MCP 内联发送（base64 编码后上限约 10 MB）。请将其托管为公网 http(s) URL，或切换为具体的 --model。`,
-  });
-  const hint = localize({
-    "en-US":
-      "Pass a public http(s) URL instead of a local path, or use --model <id> to switch to the REST path.",
-    "zh-CN": "请传入公网 http(s) URL 而非本地路径，或使用 --model <id> 切换回 REST。",
-  });
-  throw new BailianError(message, ExitCode.USAGE, hint);
-}
-
 /**
  * Resolve an `auto`-mode image input: local paths are inlined as base64 data
  * URIs; http(s) URLs and data URIs pass through verbatim.
+ *
+ * Files are inlined rather than uploaded because the AIGC MCP servers reject
+ * `oss://` and cannot fetch private upload URLs. The inline payload is
+ * deliberately not capped on this side: how large a data URI is acceptable is
+ * the server's own contract, so an oversized one surfaces as a server error
+ * passed through verbatim (AGENTS.md §3) instead of a client-side guess.
  */
-export function resolveAutoImageInput(source: string, localize: Localize): string {
+export function resolveAutoImageInput(source: string): string {
   if (isUrlScheme(source)) return source;
-  return guardDataUriSize(imageFileToDataUri(source), "image", localize);
+  return imageFileToDataUri(source);
 }
 
 /** Resolve an `auto`-mode audio input the same way (ASR `file_urls`). */
-export function resolveAutoAudioInput(source: string, localize: Localize): string {
+export function resolveAutoAudioInput(source: string): string {
   if (isUrlScheme(source)) return source;
-  return guardDataUriSize(audioFileToDataUri(source), "audio", localize);
+  return audioFileToDataUri(source);
 }
 
 // ---- Shared-session MCP call wrapper ----
@@ -333,9 +316,9 @@ function withAutoModelHint(error: unknown, localize: Localize): never {
   ) {
     const hint = localize({
       "en-US":
-        'MCP generation failed. To use the REST path instead, run with a specific --model <id> (or set a concrete default model instead of "auto").',
+        "The current model (auto) failed to generate. Retry with a specific --model <id> (or set a concrete default model).",
       "zh-CN":
-        'MCP 生成失败。如需改走 REST，请使用具体的 --model <id>（或将默认模型设为具体值而非 "auto"）。',
+        "当前模型（auto）生成失败，请使用具体的 --model <id>（或将默认模型设为具体值）进行重试。",
     });
     throw new BailianError(error.message, error.exitCode, hint, {
       cause: error,

packages/commands/src/commands/speech/recognize.ts

@@ -361,7 +361,7 @@ async function handleAutoMcpMode(
 
   // Public http(s)/oss URLs pass through; local files become inline base64 data
   // URIs (the MCP server rejects oss:// and cannot fetch private uploads).
-  const fileUrls = rawUrls.map((source) => resolveAutoAudioInput(source, localize));
+  const fileUrls = rawUrls.map((source) => resolveAutoAudioInput(source));
   const args = buildSpeechToTextArgs(fileUrls);
 
   if (settings.dryRun) {

packages/commands/src/commands/video/generate.ts

@@ -227,7 +227,7 @@ export default defineCommand({
       const duration = flags.duration || undefined;
       const resolution = flags.resolution || undefined;
       const firstFrameUrl =
-        imageInput !== undefined ? resolveAutoImageInput(imageInput, ctx.localize) : undefined;
+        imageInput !== undefined ? resolveAutoImageInput(imageInput) : undefined;
       const submitTool =
         imageInput !== undefined
           ? AIGC_MCP_TOOL.imageToVideoSubmit

packages/core/src/client/mcp-sdk.ts

@@ -13,6 +13,9 @@
  * - `MCP request failed: <status> <statusText> - <body>` message contract for
  *   HTTP transport failures, which `isStreamableHttpUnsupported`,
  *   `isUrlOverrideSseFallbackCandidate` and the MCP-not-activated hint rely on.
+ *   Classic SSE stream GET failures carry the same contract: `eventsource`
+ *   drops non-200 GET bodies, so the interceptor captures status/body and
+ *   `mapSdkError` rebuilds the message from the SDK's `SseError`.
  * - `MCP error (<code>): <message>` for JSON-RPC business errors (passthrough).
  * - Raw `TypeError` (e.g. ENOTFOUND) propagation so runtime can surface errno.
  */
@@ -22,7 +25,7 @@ import {
   StreamableHTTPClientTransport,
   StreamableHTTPError,
 } from "@modelcontextprotocol/sdk/client/streamableHttp.js";
-import { SSEClientTransport } from "@modelcontextprotocol/sdk/client/sse.js";
+import { SSEClientTransport, SseError } from "@modelcontextprotocol/sdk/client/sse.js";
 import { ErrorCode, McpError } from "@modelcontextprotocol/sdk/types.js";
 import type { FetchLike, Transport } from "@modelcontextprotocol/sdk/shared/transport.js";
 
@@ -90,10 +93,16 @@ export interface SdkMcpAdapterOptions {
  *   (message passed through verbatim per AGENTS.md §3).
  * - `StreamableHTTPError` (HTTP status in `.code`) → GENERAL with the
  *   `MCP request failed: <status>` shape so the fallback detectors still match.
+ * - `SseError` (classic SSE): when the fetch interceptor captured the failing
+ *   stream GET (`sseGetFailure` with a matching status), rebuild the
+ *   `MCP request failed: <status> <statusText> - <body>` contract — the SDK's
+ *   own message only carries `Non-200 status code (<status>)` and would lose
+ *   the server body the MCP-not-activated hint matches on. Without a captured
+ *   failure (e.g. a mid-stream drop) the error passes through unchanged.
  * - Anything else (e.g. a `TypeError` from `fetch`) is returned unchanged so the
  *   runtime keeps its errno-specific handling.
  */
-export function mapSdkError(error: unknown): unknown {
+export function mapSdkError(error: unknown, sseGetFailure?: SseGetFailure): unknown {
   if (error instanceof BailianError) return error;
 
   if (error instanceof McpError) {
@@ -115,6 +124,15 @@ export function mapSdkError(error: unknown): unknown {
     });
   }
 
+  if (error instanceof SseError && sseGetFailure && sseGetFailure.status === error.code) {
+    let message = `MCP request failed: ${sseGetFailure.status} ${sseGetFailure.statusText}`;
+    if (sseGetFailure.body) message += ` - ${sseGetFailure.body.slice(0, 500)}`;
+    return new BailianError(message, ExitCode.GENERAL, undefined, {
+      api: { httpStatus: sseGetFailure.status },
+      cause: error,
+    });
+  }
+
   return error;
 }
 
@@ -131,17 +149,35 @@ function rawMcpMessage(error: McpError): string {
   return error.message.startsWith(prefix) ? error.message.slice(prefix.length) : error.message;
 }
 
+/**
+ * Server-side failure of a classic SSE stream GET, captured by the fetch
+ * interceptor before `eventsource` discards the body (it only reports
+ * `Non-200 status code (<status>)` and never reads the payload).
+ * `mapSdkError` rebuilds the HTTP-failure contract from it.
+ */
+export interface SseGetFailure {
+  status: number;
+  statusText: string;
+  body: string;
+}
+
 /**
  * Build the transport-level fetch. It reproduces the old client's error contract
  * for message POSTs and mirrors its `--verbose` wire logging. GET responses are
  * passed through untouched so the SDK's own SSE-stream handling (including the
- * tolerated 405 on a standalone Streamable GET) stays intact. Redirect responses
- * are likewise passed through: the SDK wraps this fetch with its same-origin
- * redirect policy (`fetchWithinOrigin`) and must see the 3xx to follow or
- * reject it itself — intercepting it here would break same-origin redirects
- * the old client's default `redirect: "follow"` used to honor.
+ * tolerated 405 on a standalone Streamable GET) stays intact — except that a
+ * failing classic SSE stream GET has its status/body captured first, since
+ * `eventsource` would drop them. Redirect responses are likewise passed through:
+ * the SDK wraps this fetch with its same-origin redirect policy
+ * (`fetchWithinOrigin`) and must see the 3xx to follow or reject it itself —
+ * intercepting it here would break same-origin redirects the old client's
+ * default `redirect: "follow"` used to honor.
  */
-function createMcpFetch(deps: HttpDeps): FetchLike {
+function createMcpFetch(
+  deps: HttpDeps,
+  kind: SdkMcpTransportKind,
+  onSseGetFailure?: (failure: SseGetFailure) => void,
+): FetchLike {
   return async (url, init) => {
     const method = init?.method ?? "GET";
     const target = typeof url === "string" ? url : url.href;
@@ -175,6 +211,28 @@ function createMcpFetch(deps: HttpDeps): FetchLike {
       throw new BailianError(message, ExitCode.GENERAL);
     }
 
+    if (
+      kind === "sse" &&
+      onSseGetFailure &&
+      !response.ok &&
+      method === "GET" &&
+      !isRedirectStatus(response.status)
+    ) {
+      // Classic SSE: this GET *is* the connection stream. `eventsource` fails
+      // non-200 responses with `Non-200 status code (<status>)` without ever
+      // reading the body, and the SDK rewraps that as `SseError` — losing the
+      // server payload (e.g. MCP_IS_INVALID) the not-activated hint matches on.
+      // Drain it here and hand it to the adapter; returning the drained
+      // response is safe because neither transport reads a non-2xx GET body.
+      let body = "";
+      try {
+        body = await response.text();
+      } catch {
+        /* body already consumed or unreadable */
+      }
+      onSseGetFailure({ status: response.status, statusText: response.statusText, body });
+    }
+
     return response;
   };
 }
@@ -198,6 +256,8 @@ export class SdkMcpAdapter implements McpConnectedClient {
   private client: Client | undefined;
   private transport: Transport | undefined;
   private connecting: Promise<void> | undefined;
+  /** Last failed classic SSE stream GET, for `SseError` contract reconstruction. */
+  private sseGetFailure: SseGetFailure | undefined;
 
   constructor(options: SdkMcpAdapterOptions) {
     this.deps = options.deps;
@@ -216,7 +276,7 @@ export class SdkMcpAdapter implements McpConnectedClient {
       this.connecting = this.connect().catch((error) => {
         // Allow a later initialize() to retry on the same instance.
         this.connecting = undefined;
-        throw mapSdkError(error);
+        throw this.mapTransportError(error);
       });
     }
     return this.connecting;
@@ -234,7 +294,7 @@ export class SdkMcpAdapter implements McpConnectedClient {
           : {}),
       }));
     } catch (error) {
-      throw mapSdkError(error);
+      throw this.mapTransportError(error);
     }
   }
 
@@ -257,7 +317,7 @@ export class SdkMcpAdapter implements McpConnectedClient {
       // lives in the business adapter (`aigc-mcp.ts`), not here.
       return result;
     } catch (error) {
-      throw mapSdkError(error);
+      throw this.mapTransportError(error);
     }
   }
 
@@ -270,21 +330,29 @@ export class SdkMcpAdapter implements McpConnectedClient {
     this.client = undefined;
     this.transport = undefined;
     this.connecting = undefined;
+    this.sseGetFailure = undefined;
     if (transport) {
       void transport.close().catch(() => undefined);
     }
   }
 
   // ---- Internal ----
 
+  /** `mapSdkError` with this adapter's captured classic SSE GET failure. */
+  private mapTransportError(error: unknown): unknown {
+    return mapSdkError(error, this.sseGetFailure);
+  }
+
   private async connect(): Promise<void> {
     const headers: Record<string, string> = {
       "User-Agent": `${this.deps.identity.clientName}/${this.deps.identity.version}`,
       ...trackingHeaders(this.deps.identity, this.serviceSource),
       Authorization: `Bearer ${this.authToken}`,
     };
 
-    const mcpFetch = createMcpFetch(this.deps);
+    const mcpFetch = createMcpFetch(this.deps, this.kind, (failure) => {
+      this.sseGetFailure = failure;
+    });
     const endpoint = new URL(this.url);
     const transport =
       this.kind === "sse"