update mcp server (#5076)

* update mcp server

* fix: action

* fix: dockerfile

* fix: dockerfile

* fix: dockerfile

* fix: dockerfile

* fix: dockerfile

* fix: dockerfile

projects/mcp_server/src/api/fastgpt.ts

@@ -1,5 +1,5 @@
 import type { Tool } from '@modelcontextprotocol/sdk/types.js';
-import { GET, POST } from './request.js';
+import { GET, POST } from './request';
 
 export const getTools = (key: string) => GET<Tool[]>('/support/mcp/server/toolList', { key });
 

projects/mcp_server/src/api/request.ts

@@ -1,29 +1,16 @@
-import type { Method, InternalAxiosRequestConfig, AxiosResponse } from 'axios';
-import axios from 'axios';
+import { addLog } from '../utils/log';
+
+type ConfigType = {
+  headers?: Record<string, string>;
+  timeout?: number;
+};
 
-type ConfigType = {};
 type ResponseDataType = {
   code: number;
   message: string;
   data: any;
 };
 
-/**
- * 请求开始
- */
-function startInterceptors(config: InternalAxiosRequestConfig): InternalAxiosRequestConfig {
-  if (config.headers) {
-  }
-
-  return config;
-}
-
-/**
- * 请求成功,检查请求头
- */
-function responseSuccess(response: AxiosResponse<ResponseDataType>) {
-  return response;
-}
 /**
  * 响应数据检查
  */
@@ -38,10 +25,10 @@ function checkRes(data: ResponseDataType) {
 }
 
 /**
- * 响应错误
+ * 响应错误处理
  */
 function responseError(err: any) {
-  console.log('error->', '请求错误', err);
+  addLog.error(`Fetch request error`, err);
   const data = err?.response?.data || err;
 
   if (!err) {
@@ -51,62 +38,175 @@ function responseError(err: any) {
     return Promise.reject({ message: err });
   }
   if (typeof data === 'string') {
-    return Promise.reject(data);
-  }
-}
-
-/* 创建请求实例 */
-const instance = axios.create({
-  baseURL: `${process.env.FASTGPT_ENDPOINT}/api`,
-  timeout: 600000, // 超时时间
-  headers: {
-    'content-type': 'application/json'
-  }
-});
-
-/* 请求拦截 */
-instance.interceptors.request.use(startInterceptors, (err) => Promise.reject(err));
-/* 响应拦截 */
-instance.interceptors.response.use(responseSuccess, (err) => Promise.reject(err));
-
-function request(url: string, data: any, config: ConfigType, method: Method): any {
-  /* 去空 */
-  for (const key in data) {
-    if (data[key] === undefined) {
-      delete data[key];
-    }
+    return Promise.reject({ message: data });
   }
 
-  return instance
-    .request({
-      url,
-      method,
-      data: ['POST', 'PUT'].includes(method) ? data : undefined,
-      params: !['POST', 'PUT'].includes(method) ? data : undefined
-    })
-    .then((res) => checkRes(res.data))
-    .catch((err) => responseError(err));
+  // Handle fetch-specific errors
+  if (err.name === 'AbortError') {
+    return Promise.reject({ message: '请求超时' });
+  }
+  if (err.name === 'TypeError' && err.message.includes('fetch')) {
+    return Promise.reject({ message: '网络连接失败' });
+  }
+
+  return Promise.reject(data || err);
 }
 
 /**
- * api请求方式
- * @param {String} url
- * @param {Any} params
- * @param {Object} config
- * @returns
+ * 构建查询参数
+ */
+function buildQueryString(params: Record<string, any>): string {
+  const searchParams = new URLSearchParams();
+
+  Object.keys(params).forEach((key) => {
+    const value = params[key];
+    if (value !== undefined && value !== null) {
+      if (Array.isArray(value)) {
+        value.forEach((item) => searchParams.append(key, String(item)));
+      } else {
+        searchParams.append(key, String(value));
+      }
+    }
+  });
+
+  return searchParams.toString();
+}
+
+/**
+ * 发送请求
+ */
+async function request(url: string, data: any, config: ConfigType, method: string): Promise<any> {
+  // Remove undefined values
+  const cleanData = { ...data };
+  for (const key in cleanData) {
+    if (cleanData[key] === undefined) {
+      delete cleanData[key];
+    }
+  }
+
+  const baseURL = `${process.env.FASTGPT_ENDPOINT}/api`;
+  let fullUrl = `${baseURL}${url}`;
+
+  // Default timeout from config or 600 seconds
+  const timeout = config.timeout || 600000;
+
+  const options: RequestInit = {
+    method,
+    headers: {
+      'content-type': 'application/json',
+      ...config.headers
+    },
+    signal: AbortSignal.timeout(timeout)
+  };
+
+  // Handle request body and query parameters
+  if (['POST', 'PUT', 'PATCH'].includes(method)) {
+    if (Object.keys(cleanData).length > 0) {
+      options.body = JSON.stringify(cleanData);
+    }
+  } else if (Object.keys(cleanData).length > 0) {
+    const queryString = buildQueryString(cleanData);
+    if (queryString) {
+      fullUrl += `?${queryString}`;
+    }
+  }
+
+  try {
+    const response = await fetch(fullUrl, options);
+
+    // Handle non-2xx responses
+    if (!response.ok) {
+      let errorData;
+      try {
+        errorData = await response.json();
+      } catch {
+        errorData = {
+          code: response.status,
+          message: response.statusText || `HTTP ${response.status}`,
+          data: null
+        };
+      }
+      throw errorData;
+    }
+
+    // Parse response
+    let result;
+    const contentType = response.headers.get('content-type');
+
+    if (contentType && contentType.includes('application/json')) {
+      result = await response.json();
+    } else {
+      // Handle non-JSON responses
+      const text = await response.text();
+      try {
+        result = JSON.parse(text);
+      } catch {
+        // If it's not JSON, wrap it in the expected format
+        result = {
+          code: response.status,
+          message: 'success',
+          data: text
+        };
+      }
+    }
+
+    return checkRes(result);
+  } catch (err) {
+    return responseError(err);
+  }
+}
+
+/**
+ * GET 请求
+ * @param {String} url - 请求路径
+ * @param {Object} params - 查询参数
+ * @param {Object} config - 请求配置
+ * @returns {Promise<T>}
  */
 export function GET<T = undefined>(url: string, params = {}, config: ConfigType = {}): Promise<T> {
   return request(url, params, config, 'GET');
 }
 
+/**
+ * POST 请求
+ * @param {String} url - 请求路径
+ * @param {Object} data - 请求体数据
+ * @param {Object} config - 请求配置
+ * @returns {Promise<T>}
+ */
 export function POST<T = undefined>(url: string, data = {}, config: ConfigType = {}): Promise<T> {
   return request(url, data, config, 'POST');
 }
 
+/**
+ * PUT 请求
+ * @param {String} url - 请求路径
+ * @param {Object} data - 请求体数据
+ * @param {Object} config - 请求配置
+ * @returns {Promise<T>}
+ */
 export function PUT<T = undefined>(url: string, data = {}, config: ConfigType = {}): Promise<T> {
   return request(url, data, config, 'PUT');
 }
 
+/**
+ * DELETE 请求
+ * @param {String} url - 请求路径
+ * @param {Object} data - 请求体数据
+ * @param {Object} config - 请求配置
+ * @returns {Promise<T>}
+ */
 export function DELETE<T = undefined>(url: string, data = {}, config: ConfigType = {}): Promise<T> {
   return request(url, data, config, 'DELETE');
 }
+
+/**
+ * PATCH 请求
+ * @param {String} url - 请求路径
+ * @param {Object} data - 请求体数据
+ * @param {Object} config - 请求配置
+ * @returns {Promise<T>}
+ */
+export function PATCH<T = undefined>(url: string, data = {}, config: ConfigType = {}): Promise<T> {
+  return request(url, data, config, 'PATCH');
+}

projects/mcp_server/src/index.ts

@@ -1,14 +1,14 @@
 #!/usr/bin/env node
-import './init.js';
+import './init';
 import { Server } from '@modelcontextprotocol/sdk/server/index.js';
 import type { CallToolResult } from '@modelcontextprotocol/sdk/types.js';
 import { CallToolRequestSchema, ListToolsRequestSchema } from '@modelcontextprotocol/sdk/types.js';
 import { SSEServerTransport } from '@modelcontextprotocol/sdk/server/sse.js';
 import express from 'express';
 
-import { callTool, getTools } from './api/fastgpt.js';
-import { addLog } from './utils/log.js';
-import { getErrText } from './utils/error.js';
+import { callTool, getTools } from './api/fastgpt';
+import { addLog } from './utils/log';
+import { getErrText } from '@fastgpt/global/common/error/utils';
 
 const app = express();
 

projects/mcp_server/src/utils/error.ts

@@ -1,10 +0,0 @@
-import { replaceSensitiveText } from './string.js';
-
-export const getErrText = (err: any, def = ''): any => {
-  const msg: string =
-    typeof err === 'string'
-      ? err
-      : err?.response?.data?.message || err?.response?.message || err?.message || def;
-  // msg && console.log('error =>', msg);
-  return replaceSensitiveText(msg);
-};

projects/mcp_server/src/utils/string.ts

@@ -1,8 +0,0 @@
-export const replaceSensitiveText = (text: string) => {
-  // 1. http link
-  text = text.replace(/(?<=https?:\/\/)[^\s]+/g, 'xxx');
-  // 2. nx-xxx 全部替换成xxx
-  text = text.replace(/ns-[\w-]+/g, 'xxx');
-
-  return text;
-};