refactor: 优化错误处理，使其兼容 OpenAI API

Co-authored-by: aider (gemini/gemini-2.5-pro) <aider@aider.chat>

Author: Dango233

packages/mcp-server/src/bridge/openai.ts

@@ -3,6 +3,7 @@ import { type Config } from '@google/gemini-cli-core';
 import { createOpenAIStreamTransformer } from './stream-transformer.js';
 import { GeminiApiClient } from '../gemini-client.js'; // <-- 引入新类
 import { type OpenAIChatCompletionRequest } from '../types.js'; // <-- 引入新类型
+import { mapErrorToOpenAIError } from '../utils/error-mapper.js';
 
 export function createOpenAIRouter(config: Config, debugMode = false): Router {
   const router = Router();
@@ -75,44 +76,18 @@ export function createOpenAIRouter(config: Config, debugMode = false): Router {
       // --- 修正结束 ---
 
       res.end();
-    } catch (error) {
-      console.error('[OpenAI Bridge] Error:', error);
-      const errorMessage =
-        error instanceof Error ? error.message : 'An unknown error occurred';
+    } catch (e: unknown) {
+      console.error('[OpenAI Bridge] Error:', e);
 
-      // [MODIFICATION] 检查错误类型并设置适当的状态码
-      let statusCode = 500; // 默认为内部服务器错误
-      if (error instanceof Error) {
-        // 检查 gaxios 或类似 HTTP 客户端可能附加的 status 属性
-        const status = (error as any).status;
-        if (status === 429) {
-          statusCode = 429;
-        } else if (typeof status === 'number' && status >= 400 && status < 500) {
-          statusCode = status;
-        }
-        // 也可以通过检查消息内容来增加健壮性
-        else if (
-          errorMessage.includes('429') ||
-          errorMessage.toLowerCase().includes('quota')
-        ) {
-          statusCode = 429;
-        }
-      }
+      // 调用新的错误映射函数
+      const { openAIError, statusCode } = mapErrorToOpenAIError(e);
 
+      // 使用映射后的状态码和错误对象进行响应
       if (!res.headersSent) {
-        // 使用动态的状态码
-        res.status(statusCode).json({
-          error: {
-            message: errorMessage,
-            type: 'gemini_api_error',
-            code: statusCode, // 在响应体中也反映出来
-          },
-        });
+        res.status(statusCode).json(openAIError);
       } else {
         // 如果流已经开始，我们无法改变状态码，但可以在流中发送错误
-        res.write(
-          `data: ${JSON.stringify({ error: errorMessage, code: statusCode })}\n\n`,
-        );
+        res.write(`data: ${JSON.stringify({ error: openAIError.error })}\n\n`);
         res.end();
       }
     }

packages/mcp-server/src/types.ts

@@ -61,3 +61,24 @@ export type StreamChunk =
   | { type: 'text'; data: string }
   | { type: 'reasoning'; data: ReasoningData }
   | { type: 'tool_code'; data: { name: string; args: Record<string, unknown> } };
+
+/**
+ * 定义了 OpenAI API 兼容的错误对象结构。
+ */
+export interface OpenAIError {
+  message: string;
+  type:
+    | 'invalid_request_error'
+    | 'api_error'
+    | 'authentication_error'
+    | 'server_error';
+  param: string | null;
+  code: string | null;
+}
+
+/**
+ * 定义了完整的 OpenAI API 错误响应结构。
+ */
+export interface OpenAIErrorResponse {
+  error: OpenAIError;
+}

packages/mcp-server/src/utils/error-mapper.ts

@@ -0,0 +1,61 @@
+import { type OpenAIError, type OpenAIErrorResponse } from '../types.js';
+
+/**
+ * 将从 Gemini API 或身份验证流程中捕获的错误映射为标准的 OpenAI 错误对象和对应的 HTTP 状态码。
+ * @param error 捕获到的未知错误。
+ * @returns 一个包含标准 OpenAI 错误对象和建议的 HTTP 状态码的对象。
+ */
+export function mapErrorToOpenAIError(error: unknown): {
+  openAIError: OpenAIErrorResponse;
+  statusCode: number;
+} {
+  let message = 'An unknown error occurred.';
+  let type: OpenAIError['type'] = 'server_error';
+  let code: string | null = 'internal_error';
+  let statusCode = 500;
+
+  if (error instanceof Error) {
+    message = error.message;
+
+    // 检查特定的错误类型或消息内容来确定更精确的错误码
+    if (message.includes('Authentication failed')) {
+      statusCode = 401;
+      type = 'authentication_error';
+      code = 'invalid_api_key';
+      message =
+        'Invalid authentication credentials. Please check your GCP_SERVICE_ACCOUNT.';
+    } else if (
+      message.includes('429') ||
+      message.toLowerCase().includes('quota')
+    ) {
+      statusCode = 429;
+      type = 'server_error';
+      code = 'rate_limit_exceeded';
+      message =
+        'You exceeded your current quota, please check your plan and billing details.';
+    } else if (
+      message.includes('400') ||
+      message.toLowerCase().includes('invalid')
+    ) {
+      statusCode = 400;
+      type = 'invalid_request_error';
+      code = 'invalid_request';
+    } else if (message.includes('500')) {
+      statusCode = 500;
+      type = 'server_error';
+      code = 'server_error';
+    }
+    // 可以根据需要添加更多针对 Gemini 特定错误的映射
+  }
+
+  const openAIError: OpenAIErrorResponse = {
+    error: {
+      message,
+      type,
+      param: null, // 在这个场景下，我们通常不知道是哪个具体参数出错，所以设为 null
+      code,
+    },
+  };
+
+  return { openAIError, statusCode };
+}