{config.realtimeConfig.enable && (
@@ -987,6 +1023,7 @@ function _Chat() {
const { setAutoScroll, scrollDomToBottom } = useScrollToBottom(
scrollRef,
(isScrolledToBottom || isAttachWithTop) && !isTyping,
+ session.messages,
);
const [hitBottom, setHitBottom] = useState(true);
const isMobileScreen = useMobileScreen();
@@ -1246,6 +1283,7 @@ function _Chat() {
const accessStore = useAccessStore();
const [speechStatus, setSpeechStatus] = useState(false);
const [speechLoading, setSpeechLoading] = useState(false);
+
async function openaiSpeech(text: string) {
if (speechStatus) {
ttsPlayer.stop();
@@ -1345,6 +1383,7 @@ function _Chat() {
const [msgRenderIndex, _setMsgRenderIndex] = useState(
Math.max(0, renderMessages.length - CHAT_PAGE_SIZE),
);
+
function setMsgRenderIndex(newIndex: number) {
newIndex = Math.min(renderMessages.length - CHAT_PAGE_SIZE, newIndex);
newIndex = Math.max(0, newIndex);
@@ -1380,6 +1419,7 @@ function _Chat() {
setHitBottom(isHitBottom);
setAutoScroll(isHitBottom);
};
+
function scrollToBottom() {
setMsgRenderIndex(renderMessages.length - CHAT_PAGE_SIZE);
scrollDomToBottom();
@@ -1737,252 +1777,264 @@ function _Chat() {
setAutoScroll(false);
}}
>
- {messages.map((message, i) => {
- const isUser = message.role === "user";
- const isContext = i < context.length;
- const showActions =
- i > 0 &&
- !(message.preview || message.content.length === 0) &&
- !isContext;
- const showTyping = message.preview || message.streaming;
-
- const shouldShowClearContextDivider =
- i === clearContextIndex - 1;
-
- return (
-
-
-
-
-
-
-
+
+
(await import("./sd")).Sd, {
loading: () => >({});
+ const [editingServerId, setEditingServerId] = useState();
+ const [tools, setTools] = useState(null);
+ const [viewingServerId, setViewingServerId] = useState();
+ const [isLoading, setIsLoading] = useState(false);
+ const [config, setConfig] = useState();
+ const [clientStatuses, setClientStatuses] = useState<
+ Record
+ >({});
+ const [loadingPresets, setLoadingPresets] = useState(true);
+ const [presetServers, setPresetServers] = useState([]);
+ const [loadingStates, setLoadingStates] = useState>(
+ {},
+ );
+
+ // 检查 MCP 是否启用
+ useEffect(() => {
+ const checkMcpStatus = async () => {
+ const enabled = await isMcpEnabled();
+ setMcpEnabled(enabled);
+ if (!enabled) {
+ navigate(Path.Home);
+ }
+ };
+ checkMcpStatus();
+ }, [navigate]);
+
+ // 添加状态轮询
+ useEffect(() => {
+ if (!mcpEnabled || !config) return;
+
+ const updateStatuses = async () => {
+ const statuses = await getClientsStatus();
+ setClientStatuses(statuses);
+ };
+
+ // 立即执行一次
+ updateStatuses();
+ // 每 1000ms 轮询一次
+ const timer = setInterval(updateStatuses, 1000);
+
+ return () => clearInterval(timer);
+ }, [mcpEnabled, config]);
+
+ // 加载预设服务器
+ useEffect(() => {
+ const loadPresetServers = async () => {
+ if (!mcpEnabled) return;
+ try {
+ setLoadingPresets(true);
+ const response = await fetch("https://nextchat.club/mcp/list");
+ if (!response.ok) {
+ throw new Error("Failed to load preset servers");
+ }
+ const data = await response.json();
+ setPresetServers(data?.data ?? []);
+ } catch (error) {
+ console.error("Failed to load preset servers:", error);
+ showToast("Failed to load preset servers");
+ } finally {
+ setLoadingPresets(false);
+ }
+ };
+ loadPresetServers();
+ }, [mcpEnabled]);
+
+ // 加载初始状态
+ useEffect(() => {
+ const loadInitialState = async () => {
+ if (!mcpEnabled) return;
+ try {
+ setIsLoading(true);
+ const config = await getMcpConfigFromFile();
+ setConfig(config);
+
+ // 获取所有客户端的状态
+ const statuses = await getClientsStatus();
+ setClientStatuses(statuses);
+ } catch (error) {
+ console.error("Failed to load initial state:", error);
+ showToast("Failed to load initial state");
+ } finally {
+ setIsLoading(false);
+ }
+ };
+ loadInitialState();
+ }, [mcpEnabled]);
+
+ // 加载当前编辑服务器的配置
+ useEffect(() => {
+ if (!editingServerId || !config) return;
+ const currentConfig = config.mcpServers[editingServerId];
+ if (currentConfig) {
+ // 从当前配置中提取用户配置
+ const preset = presetServers.find((s) => s.id === editingServerId);
+ if (preset?.configSchema) {
+ const userConfig: Record = {};
+ Object.entries(preset.argsMapping || {}).forEach(([key, mapping]) => {
+ if (mapping.type === "spread") {
+ // For spread types, extract the array from args.
+ const startPos = mapping.position ?? 0;
+ userConfig[key] = currentConfig.args.slice(startPos);
+ } else if (mapping.type === "single") {
+ // For single types, get a single value
+ userConfig[key] = currentConfig.args[mapping.position ?? 0];
+ } else if (
+ mapping.type === "env" &&
+ mapping.key &&
+ currentConfig.env
+ ) {
+ // For env types, get values from environment variables
+ userConfig[key] = currentConfig.env[mapping.key];
+ }
+ });
+ setUserConfig(userConfig);
+ }
+ } else {
+ setUserConfig({});
+ }
+ }, [editingServerId, config, presetServers]);
+
+ if (!mcpEnabled) {
+ return null;
+ }
+
+ // 检查服务器是否已添加
+ const isServerAdded = (id: string) => {
+ return id in (config?.mcpServers ?? {});
+ };
+
+ // 保存服务器配置
+ const saveServerConfig = async () => {
+ const preset = presetServers.find((s) => s.id === editingServerId);
+ if (!preset || !preset.configSchema || !editingServerId) return;
+
+ const savingServerId = editingServerId;
+ setEditingServerId(undefined);
+
+ try {
+ updateLoadingState(savingServerId, "Updating configuration...");
+ // 构建服务器配置
+ const args = [...preset.baseArgs];
+ const env: Record = {};
+
+ Object.entries(preset.argsMapping || {}).forEach(([key, mapping]) => {
+ const value = userConfig[key];
+ if (mapping.type === "spread" && Array.isArray(value)) {
+ const pos = mapping.position ?? 0;
+ args.splice(pos, 0, ...value);
+ } else if (
+ mapping.type === "single" &&
+ mapping.position !== undefined
+ ) {
+ args[mapping.position] = value;
+ } else if (
+ mapping.type === "env" &&
+ mapping.key &&
+ typeof value === "string"
+ ) {
+ env[mapping.key] = value;
+ }
+ });
+
+ const serverConfig: ServerConfig = {
+ command: preset.command,
+ args,
+ ...(Object.keys(env).length > 0 ? { env } : {}),
+ };
+
+ const newConfig = await addMcpServer(savingServerId, serverConfig);
+ setConfig(newConfig);
+ showToast("Server configuration updated successfully");
+ } catch (error) {
+ showToast(
+ error instanceof Error ? error.message : "Failed to save configuration",
+ );
+ } finally {
+ updateLoadingState(savingServerId, null);
+ }
+ };
+
+ // 获取服务器支持的 Tools
+ const loadTools = async (id: string) => {
+ try {
+ const result = await getClientTools(id);
+ if (result) {
+ setTools(result);
+ } else {
+ throw new Error("Failed to load tools");
+ }
+ } catch (error) {
+ showToast("Failed to load tools");
+ console.error(error);
+ setTools(null);
+ }
+ };
+
+ // 更新加载状态的辅助函数
+ const updateLoadingState = (id: string, message: string | null) => {
+ setLoadingStates((prev) => {
+ if (message === null) {
+ const { [id]: _, ...rest } = prev;
+ return rest;
+ }
+ return { ...prev, [id]: message };
+ });
+ };
+
+ // 修改添加服务器函数
+ const addServer = async (preset: PresetServer) => {
+ if (!preset.configurable) {
+ try {
+ const serverId = preset.id;
+ updateLoadingState(serverId, "Creating MCP client...");
+
+ const serverConfig: ServerConfig = {
+ command: preset.command,
+ args: [...preset.baseArgs],
+ };
+ const newConfig = await addMcpServer(preset.id, serverConfig);
+ setConfig(newConfig);
+
+ // 更新状态
+ const statuses = await getClientsStatus();
+ setClientStatuses(statuses);
+ } finally {
+ updateLoadingState(preset.id, null);
+ }
+ } else {
+ // 如果需要配置，打开配置对话框
+ setEditingServerId(preset.id);
+ setUserConfig({});
+ }
+ };
+
+ // 修改暂停服务器函数
+ const pauseServer = async (id: string) => {
+ try {
+ updateLoadingState(id, "Stopping server...");
+ const newConfig = await pauseMcpServer(id);
+ setConfig(newConfig);
+ showToast("Server stopped successfully");
+ } catch (error) {
+ showToast("Failed to stop server");
+ console.error(error);
+ } finally {
+ updateLoadingState(id, null);
+ }
+ };
+
+ // Restart server
+ const restartServer = async (id: string) => {
+ try {
+ updateLoadingState(id, "Starting server...");
+ await resumeMcpServer(id);
+ } catch (error) {
+ showToast(
+ error instanceof Error
+ ? error.message
+ : "Failed to start server, please check logs",
+ );
+ console.error(error);
+ } finally {
+ updateLoadingState(id, null);
+ }
+ };
+
+ // Restart all clients
+ const handleRestartAll = async () => {
+ try {
+ updateLoadingState("all", "Restarting all servers...");
+ const newConfig = await restartAllClients();
+ setConfig(newConfig);
+ showToast("Restarting all clients");
+ } catch (error) {
+ showToast("Failed to restart clients");
+ console.error(error);
+ } finally {
+ updateLoadingState("all", null);
+ }
+ };
+
+ // Render configuration form
+ const renderConfigForm = () => {
+ const preset = presetServers.find((s) => s.id === editingServerId);
+ if (!preset?.configSchema) return null;
+
+ return Object.entries(preset.configSchema.properties).map(
+ ([key, prop]: [string, ConfigProperty]) => {
+ if (prop.type === "array") {
+ const currentValue = userConfig[key as keyof typeof userConfig] || [];
+ const itemLabel = (prop as any).itemLabel || key;
+ const addButtonText =
+ (prop as any).addButtonText || `Add ${itemLabel}`;
+
+ return (
+
+
+ );
+ } else if (prop.type === "string") {
+ const currentValue = userConfig[key as keyof typeof userConfig] || "";
+ return (
+
+ {
+ setUserConfig({ ...userConfig, [key]: e.target.value });
+ }}
+ />
+
+ );
+ }
+ return null;
+ },
+ );
+ };
+
+ const checkServerStatus = (clientId: string) => {
+ return clientStatuses[clientId] || { status: "undefined", errorMsg: null };
+ };
+
+ const getServerStatusDisplay = (clientId: string) => {
+ const status = checkServerStatus(clientId);
+
+ const statusMap = {
+ undefined: null, // 未配置/未找到不显示
+ // 添加初始化状态
+ initializing: (
+
+ Initializing
+
+ ),
+ paused: (
+
+ Stopped
+
+ ),
+ active: Running,
+ error: (
+
+ Error
+ : {status.errorMsg}
+
+ ),
+ };
+
+ return statusMap[status.status];
+ };
+
+ // Get the type of operation status
+ const getOperationStatusType = (message: string) => {
+ if (message.toLowerCase().includes("stopping")) return "stopping";
+ if (message.toLowerCase().includes("starting")) return "starting";
+ if (message.toLowerCase().includes("error")) return "error";
+ return "default";
+ };
+
+ // 渲染服务器列表
+ const renderServerList = () => {
+ if (loadingPresets) {
+ return (
+ = {
+ error: 0, // Highest priority for error status
+ active: 1, // Second for active
+ initializing: 2, // Initializing
+ starting: 3, // Starting
+ stopping: 4, // Stopping
+ paused: 5, // Paused
+ undefined: 6, // Lowest priority for undefined
+ };
+
+ // Get actual status (including loading status)
+ const getEffectiveStatus = (status: string, loading?: string) => {
+ if (loading) {
+ const operationType = getOperationStatusType(loading);
+ return operationType === "default" ? status : operationType;
+ }
+
+ if (status === "initializing" && !loading) {
+ return "active";
+ }
+
+ return status;
+ };
+
+ const aEffectiveStatus = getEffectiveStatus(aStatus, aLoading);
+ const bEffectiveStatus = getEffectiveStatus(bStatus, bLoading);
+
+ // 首先按状态排序
+ if (aEffectiveStatus !== bEffectiveStatus) {
+ return (
+ (statusPriority[aEffectiveStatus] ?? 6) -
+ (statusPriority[bEffectiveStatus] ?? 6)
+ );
+ }
+
+ // Sort by name when statuses are the same
+ return a.name.localeCompare(b.name);
+ })
+ .map((server) => (
+
+
+ );
+}
diff --git a/app/components/sidebar.tsx b/app/components/sidebar.tsx
index fa4caee0d9d..56bc5bb4327 100644
--- a/app/components/sidebar.tsx
+++ b/app/components/sidebar.tsx
@@ -1,4 +1,4 @@
-import React, { useEffect, useRef, useMemo, useState, Fragment } from "react";
+import React, { Fragment, useEffect, useMemo, useRef, useState } from "react";
import styles from "./home.module.scss";
@@ -9,6 +9,7 @@ import ChatGptIcon from "../icons/chatgpt.svg";
import AddIcon from "../icons/add.svg";
import DeleteIcon from "../icons/delete.svg";
import MaskIcon from "../icons/mask.svg";
+import McpIcon from "../icons/mcp.svg";
import DragIcon from "../icons/drag.svg";
import DiscoveryIcon from "../icons/discovery.svg";
@@ -28,8 +29,9 @@ import {
import { Link, useNavigate } from "react-router-dom";
import { isIOS, useMobileScreen } from "../utils";
import dynamic from "next/dynamic";
-import { showConfirm, Selector } from "./ui-lib";
+import { Selector, showConfirm } from "./ui-lib";
import clsx from "clsx";
+import { isMcpEnabled } from "../mcp/actions";
const DISCOVERY = [
{ name: Locale.Plugin.Name, path: Path.Plugins },
@@ -133,6 +135,7 @@ export function useDragSideBar() {
shouldNarrow,
};
}
+
export function SideBarContainer(props: {
children: React.ReactNode;
onDragStart: (e: MouseEvent) => void;
@@ -228,6 +231,17 @@ export function SideBar(props: { className?: string }) {
const navigate = useNavigate();
const config = useAppConfig();
const chatStore = useChatStore();
+ const [mcpEnabled, setMcpEnabled] = useState(false);
+
+ useEffect(() => {
+ // 检查 MCP 是否启用
+ const checkMcpStatus = async () => {
+ const enabled = await isMcpEnabled();
+ setMcpEnabled(enabled);
+ console.log("[SideBar] MCP enabled:", enabled);
+ };
+ checkMcpStatus();
+ }, []);
return (
();
+
+// 获取客户端状态
+export async function getClientsStatus(): Promise<
+ Record
+> {
+ const config = await getMcpConfigFromFile();
+ const result: Record = {};
+
+ for (const clientId of Object.keys(config.mcpServers)) {
+ const status = clientsMap.get(clientId);
+ const serverConfig = config.mcpServers[clientId];
+
+ if (!serverConfig) {
+ result[clientId] = { status: "undefined", errorMsg: null };
+ continue;
+ }
+
+ if (serverConfig.status === "paused") {
+ result[clientId] = { status: "paused", errorMsg: null };
+ continue;
+ }
+
+ if (!status) {
+ result[clientId] = { status: "undefined", errorMsg: null };
+ continue;
+ }
+
+ if (
+ status.client === null &&
+ status.tools === null &&
+ status.errorMsg === null
+ ) {
+ result[clientId] = { status: "initializing", errorMsg: null };
+ continue;
+ }
+
+ if (status.errorMsg) {
+ result[clientId] = { status: "error", errorMsg: status.errorMsg };
+ continue;
+ }
+
+ if (status.client) {
+ result[clientId] = { status: "active", errorMsg: null };
+ continue;
+ }
+
+ result[clientId] = { status: "error", errorMsg: "Client not found" };
+ }
+
+ return result;
+}
+
+// 获取客户端工具
+export async function getClientTools(clientId: string) {
+ return clientsMap.get(clientId)?.tools ?? null;
+}
+
+// 获取可用客户端数量
+export async function getAvailableClientsCount() {
+ let count = 0;
+ clientsMap.forEach((map) => !map.errorMsg && count++);
+ return count;
+}
+
+// 获取所有客户端工具
+export async function getAllTools() {
+ const result = [];
+ for (const [clientId, status] of clientsMap.entries()) {
+ result.push({
+ clientId,
+ tools: status.tools,
+ });
+ }
+ return result;
+}
+
+// 初始化单个客户端
+async function initializeSingleClient(
+ clientId: string,
+ serverConfig: ServerConfig,
+) {
+ // 如果服务器状态是暂停，则不初始化
+ if (serverConfig.status === "paused") {
+ logger.info(`Skipping initialization for paused client [${clientId}]`);
+ return;
+ }
+
+ logger.info(`Initializing client [${clientId}]...`);
+
+ // 先设置初始化状态
+ clientsMap.set(clientId, {
+ client: null,
+ tools: null,
+ errorMsg: null, // null 表示正在初始化
+ });
+
+ // 异步初始化
+ createClient(clientId, serverConfig)
+ .then(async (client) => {
+ const tools = await listTools(client);
+ logger.info(
+ `Supported tools for [${clientId}]: ${JSON.stringify(tools, null, 2)}`,
+ );
+ clientsMap.set(clientId, { client, tools, errorMsg: null });
+ logger.success(`Client [${clientId}] initialized successfully`);
+ })
+ .catch((error) => {
+ clientsMap.set(clientId, {
+ client: null,
+ tools: null,
+ errorMsg: error instanceof Error ? error.message : String(error),
+ });
+ logger.error(`Failed to initialize client [${clientId}]: ${error}`);
+ });
+}
+
+// 初始化系统
+export async function initializeMcpSystem() {
+ logger.info("MCP Actions starting...");
+ try {
+ // 检查是否已有活跃的客户端
+ if (clientsMap.size > 0) {
+ logger.info("MCP system already initialized, skipping...");
+ return;
+ }
+
+ const config = await getMcpConfigFromFile();
+ // 初始化所有客户端
+ for (const [clientId, serverConfig] of Object.entries(config.mcpServers)) {
+ await initializeSingleClient(clientId, serverConfig);
+ }
+ return config;
+ } catch (error) {
+ logger.error(`Failed to initialize MCP system: ${error}`);
+ throw error;
+ }
+}
+
+// 添加服务器
+export async function addMcpServer(clientId: string, config: ServerConfig) {
+ try {
+ const currentConfig = await getMcpConfigFromFile();
+ const isNewServer = !(clientId in currentConfig.mcpServers);
+
+ // 如果是新服务器，设置默认状态为 active
+ if (isNewServer && !config.status) {
+ config.status = "active";
+ }
+
+ const newConfig = {
+ ...currentConfig,
+ mcpServers: {
+ ...currentConfig.mcpServers,
+ [clientId]: config,
+ },
+ };
+ await updateMcpConfig(newConfig);
+
+ // 只有新服务器或状态为 active 的服务器才初始化
+ if (isNewServer || config.status === "active") {
+ await initializeSingleClient(clientId, config);
+ }
+
+ return newConfig;
+ } catch (error) {
+ logger.error(`Failed to add server [${clientId}]: ${error}`);
+ throw error;
+ }
+}
+
+// 暂停服务器
+export async function pauseMcpServer(clientId: string) {
+ try {
+ const currentConfig = await getMcpConfigFromFile();
+ const serverConfig = currentConfig.mcpServers[clientId];
+ if (!serverConfig) {
+ throw new Error(`Server ${clientId} not found`);
+ }
+
+ // 先更新配置
+ const newConfig: McpConfigData = {
+ ...currentConfig,
+ mcpServers: {
+ ...currentConfig.mcpServers,
+ [clientId]: {
+ ...serverConfig,
+ status: "paused",
+ },
+ },
+ };
+ await updateMcpConfig(newConfig);
+
+ // 然后关闭客户端
+ const client = clientsMap.get(clientId);
+ if (client?.client) {
+ await removeClient(client.client);
+ }
+ clientsMap.delete(clientId);
+
+ return newConfig;
+ } catch (error) {
+ logger.error(`Failed to pause server [${clientId}]: ${error}`);
+ throw error;
+ }
+}
+
+// 恢复服务器
+export async function resumeMcpServer(clientId: string): Promise {
+ try {
+ const currentConfig = await getMcpConfigFromFile();
+ const serverConfig = currentConfig.mcpServers[clientId];
+ if (!serverConfig) {
+ throw new Error(`Server ${clientId} not found`);
+ }
+
+ // 先尝试初始化客户端
+ logger.info(`Trying to initialize client [${clientId}]...`);
+ try {
+ const client = await createClient(clientId, serverConfig);
+ const tools = await listTools(client);
+ clientsMap.set(clientId, { client, tools, errorMsg: null });
+ logger.success(`Client [${clientId}] initialized successfully`);
+
+ // 初始化成功后更新配置
+ const newConfig: McpConfigData = {
+ ...currentConfig,
+ mcpServers: {
+ ...currentConfig.mcpServers,
+ [clientId]: {
+ ...serverConfig,
+ status: "active" as const,
+ },
+ },
+ };
+ await updateMcpConfig(newConfig);
+ } catch (error) {
+ const currentConfig = await getMcpConfigFromFile();
+ const serverConfig = currentConfig.mcpServers[clientId];
+
+ // 如果配置中存在该服务器，则更新其状态为 error
+ if (serverConfig) {
+ serverConfig.status = "error";
+ await updateMcpConfig(currentConfig);
+ }
+
+ // 初始化失败
+ clientsMap.set(clientId, {
+ client: null,
+ tools: null,
+ errorMsg: error instanceof Error ? error.message : String(error),
+ });
+ logger.error(`Failed to initialize client [${clientId}]: ${error}`);
+ throw error;
+ }
+ } catch (error) {
+ logger.error(`Failed to resume server [${clientId}]: ${error}`);
+ throw error;
+ }
+}
+
+// 移除服务器
+export async function removeMcpServer(clientId: string) {
+ try {
+ const currentConfig = await getMcpConfigFromFile();
+ const { [clientId]: _, ...rest } = currentConfig.mcpServers;
+ const newConfig = {
+ ...currentConfig,
+ mcpServers: rest,
+ };
+ await updateMcpConfig(newConfig);
+
+ // 关闭并移除客户端
+ const client = clientsMap.get(clientId);
+ if (client?.client) {
+ await removeClient(client.client);
+ }
+ clientsMap.delete(clientId);
+
+ return newConfig;
+ } catch (error) {
+ logger.error(`Failed to remove server [${clientId}]: ${error}`);
+ throw error;
+ }
+}
+
+// 重启所有客户端
+export async function restartAllClients() {
+ logger.info("Restarting all clients...");
+ try {
+ // 关闭所有客户端
+ for (const client of clientsMap.values()) {
+ if (client.client) {
+ await removeClient(client.client);
+ }
+ }
+
+ // 清空状态
+ clientsMap.clear();
+
+ // 重新初始化
+ const config = await getMcpConfigFromFile();
+ for (const [clientId, serverConfig] of Object.entries(config.mcpServers)) {
+ await initializeSingleClient(clientId, serverConfig);
+ }
+ return config;
+ } catch (error) {
+ logger.error(`Failed to restart clients: ${error}`);
+ throw error;
+ }
+}
+
+// 执行 MCP 请求
+export async function executeMcpAction(
+ clientId: string,
+ request: McpRequestMessage,
+) {
+ try {
+ const client = clientsMap.get(clientId);
+ if (!client?.client) {
+ throw new Error(`Client ${clientId} not found`);
+ }
+ logger.info(`Executing request for [${clientId}]`);
+ return await executeRequest(client.client, request);
+ } catch (error) {
+ logger.error(`Failed to execute request for [${clientId}]: ${error}`);
+ throw error;
+ }
+}
+
+// 获取 MCP 配置文件
+export async function getMcpConfigFromFile(): Promise {
+ try {
+ const configStr = await fs.readFile(CONFIG_PATH, "utf-8");
+ return JSON.parse(configStr);
+ } catch (error) {
+ logger.error(`Failed to load MCP config, using default config: ${error}`);
+ return DEFAULT_MCP_CONFIG;
+ }
+}
+
+// 更新 MCP 配置文件
+async function updateMcpConfig(config: McpConfigData): Promise {
+ try {
+ await fs.writeFile(CONFIG_PATH, JSON.stringify(config, null, 2));
+ } catch (error) {
+ throw error;
+ }
+}
+
+// 检查 MCP 是否启用
+export async function isMcpEnabled() {
+ try {
+ const serverConfig = getServerSideConfig();
+ return serverConfig.enableMcp;
+ } catch (error) {
+ logger.error(`Failed to check MCP status: ${error}`);
+ return false;
+ }
+}
diff --git a/app/mcp/client.ts b/app/mcp/client.ts
new file mode 100644
index 00000000000..5c2f071e301
--- /dev/null
+++ b/app/mcp/client.ts
@@ -0,0 +1,55 @@
+import { Client } from "@modelcontextprotocol/sdk/client/index.js";
+import { StdioClientTransport } from "@modelcontextprotocol/sdk/client/stdio.js";
+import { MCPClientLogger } from "./logger";
+import { ListToolsResponse, McpRequestMessage, ServerConfig } from "./types";
+import { z } from "zod";
+
+const logger = new MCPClientLogger();
+
+export async function createClient(
+ id: string,
+ config: ServerConfig,
+): Promise {
+ logger.info(`Creating client for ${id}...`);
+
+ const transport = new StdioClientTransport({
+ command: config.command,
+ args: config.args,
+ env: {
+ ...Object.fromEntries(
+ Object.entries(process.env)
+ .filter(([_, v]) => v !== undefined)
+ .map(([k, v]) => [k, v as string]),
+ ),
+ ...(config.env || {}),
+ },
+ });
+
+ const client = new Client(
+ {
+ name: `nextchat-mcp-client-${id}`,
+ version: "1.0.0",
+ },
+ {
+ capabilities: {},
+ },
+ );
+ await client.connect(transport);
+ return client;
+}
+
+export async function removeClient(client: Client) {
+ logger.info(`Removing client...`);
+ await client.close();
+}
+
+export async function listTools(client: Client): Promise {
+ return client.listTools();
+}
+
+export async function executeRequest(
+ client: Client,
+ request: McpRequestMessage,
+) {
+ return client.request(request, z.any());
+}
diff --git a/app/mcp/logger.ts b/app/mcp/logger.ts
new file mode 100644
index 00000000000..25129c592c3
--- /dev/null
+++ b/app/mcp/logger.ts
@@ -0,0 +1,65 @@
+// ANSI color codes for terminal output
+const colors = {
+ reset: "\x1b[0m",
+ bright: "\x1b[1m",
+ dim: "\x1b[2m",
+ green: "\x1b[32m",
+ yellow: "\x1b[33m",
+ red: "\x1b[31m",
+ blue: "\x1b[34m",
+};
+
+export class MCPClientLogger {
+ private readonly prefix: string;
+ private readonly debugMode: boolean;
+
+ constructor(
+ prefix: string = "NextChat MCP Client",
+ debugMode: boolean = false,
+ ) {
+ this.prefix = prefix;
+ this.debugMode = debugMode;
+ }
+
+ info(message: any) {
+ this.print(colors.blue, message);
+ }
+
+ success(message: any) {
+ this.print(colors.green, message);
+ }
+
+ error(message: any) {
+ this.print(colors.red, message);
+ }
+
+ warn(message: any) {
+ this.print(colors.yellow, message);
+ }
+
+ debug(message: any) {
+ if (this.debugMode) {
+ this.print(colors.dim, message);
+ }
+ }
+
+ /**
+ * Format message to string, if message is object, convert to JSON string
+ */
+ private formatMessage(message: any): string {
+ return typeof message === "object"
+ ? JSON.stringify(message, null, 2)
+ : message;
+ }
+
+ /**
+ * Print formatted message to console
+ */
+ private print(color: string, message: any) {
+ const formattedMessage = this.formatMessage(message);
+ const logMessage = `${color}${colors.bright}[${this.prefix}]${colors.reset} ${formattedMessage}`;
+
+ // 只使用 console.log，这样日志会显示在 Tauri 的终端中
+ console.log(logMessage);
+ }
+}
diff --git a/app/mcp/types.ts b/app/mcp/types.ts
new file mode 100644
index 00000000000..45d1d979a98
--- /dev/null
+++ b/app/mcp/types.ts
@@ -0,0 +1,180 @@
+// ref: https://spec.modelcontextprotocol.io/specification/basic/messages/
+
+import { z } from "zod";
+import { Client } from "@modelcontextprotocol/sdk/client/index.js";
+
+export interface McpRequestMessage {
+ jsonrpc?: "2.0";
+ id?: string | number;
+ method: "tools/call" | string;
+ params?: {
+ [key: string]: unknown;
+ };
+}
+
+export const McpRequestMessageSchema: z.ZodType = z.object({
+ jsonrpc: z.literal("2.0").optional(),
+ id: z.union([z.string(), z.number()]).optional(),
+ method: z.string(),
+ params: z.record(z.unknown()).optional(),
+});
+
+export interface McpResponseMessage {
+ jsonrpc?: "2.0";
+ id?: string | number;
+ result?: {
+ [key: string]: unknown;
+ };
+ error?: {
+ code: number;
+ message: string;
+ data?: unknown;
+ };
+}
+
+export const McpResponseMessageSchema: z.ZodType = z.object(
+ {
+ jsonrpc: z.literal("2.0").optional(),
+ id: z.union([z.string(), z.number()]).optional(),
+ result: z.record(z.unknown()).optional(),
+ error: z
+ .object({
+ code: z.number(),
+ message: z.string(),
+ data: z.unknown().optional(),
+ })
+ .optional(),
+ },
+);
+
+export interface McpNotifications {
+ jsonrpc?: "2.0";
+ method: string;
+ params?: {
+ [key: string]: unknown;
+ };
+}
+
+export const McpNotificationsSchema: z.ZodType = z.object({
+ jsonrpc: z.literal("2.0").optional(),
+ method: z.string(),
+ params: z.record(z.unknown()).optional(),
+});
+
+////////////
+// Next Chat
+////////////
+export interface ListToolsResponse {
+ tools: {
+ name?: string;
+ description?: string;
+ inputSchema?: object;
+ [key: string]: any;
+ };
+}
+
+export type McpClientData =
+ | McpActiveClient
+ | McpErrorClient
+ | McpInitializingClient;
+
+interface McpInitializingClient {
+ client: null;
+ tools: null;
+ errorMsg: null;
+}
+
+interface McpActiveClient {
+ client: Client;
+ tools: ListToolsResponse;
+ errorMsg: null;
+}
+
+interface McpErrorClient {
+ client: null;
+ tools: null;
+ errorMsg: string;
+}
+
+// 服务器状态类型
+export type ServerStatus =
+ | "undefined"
+ | "active"
+ | "paused"
+ | "error"
+ | "initializing";
+
+export interface ServerStatusResponse {
+ status: ServerStatus;
+ errorMsg: string | null;
+}
+
+// MCP 服务器配置相关类型
+export interface ServerConfig {
+ command: string;
+ args: string[];
+ env?: Record;
+ status?: "active" | "paused" | "error";
+}
+
+export interface McpConfigData {
+ // MCP Server 的配置
+ mcpServers: Record;
+}
+
+export const DEFAULT_MCP_CONFIG: McpConfigData = {
+ mcpServers: {},
+};
+
+export interface ArgsMapping {
+ // 参数映射的类型
+ type: "spread" | "single" | "env";
+
+ // 参数映射的位置
+ position?: number;
+
+ // 参数映射的 key
+ key?: string;
+}
+
+export interface PresetServer {
+ // MCP Server 的唯一标识，作为最终配置文件 Json 的 key
+ id: string;
+
+ // MCP Server 的显示名称
+ name: string;
+
+ // MCP Server 的描述
+ description: string;
+
+ // MCP Server 的仓库地址
+ repo: string;
+
+ // MCP Server 的标签
+ tags: string[];
+
+ // MCP Server 的命令
+ command: string;
+
+ // MCP Server 的参数
+ baseArgs: string[];
+
+ // MCP Server 是否需要配置
+ configurable: boolean;
+
+ // MCP Server 的配置 schema
+ configSchema?: {
+ properties: Record<
+ string,
+ {
+ type: string;
+ description?: string;
+ required?: boolean;
+ minItems?: number;
+ }
+ >;
+ };
+
+ // MCP Server 的参数映射
+ argsMapping?: Record;
+}
diff --git a/app/mcp/utils.ts b/app/mcp/utils.ts
new file mode 100644
index 00000000000..b74509881ef
--- /dev/null
+++ b/app/mcp/utils.ts
@@ -0,0 +1,11 @@
+export function isMcpJson(content: string) {
+ return content.match(/```json:mcp:([^{\s]+)([\s\S]*?)```/);
+}
+
+export function extractMcpJson(content: string) {
+ const match = content.match(/```json:mcp:([^{\s]+)([\s\S]*?)```/);
+ if (match && match.length === 3) {
+ return { clientId: match[1], mcp: JSON.parse(match[2]) };
+ }
+ return null;
+}
diff --git a/app/page.tsx b/app/page.tsx
index b3f169a9b74..c748d42c71a 100644
--- a/app/page.tsx
+++ b/app/page.tsx
@@ -1,7 +1,5 @@
import { Analytics } from "@vercel/analytics/react";
-
import { Home } from "./components/home";
-
import { getServerSideConfig } from "./config/server";
const serverConfig = getServerSideConfig();
diff --git a/app/store/chat.ts b/app/store/chat.ts
index 7a476fa7f6e..5c95ac02c7d 100644
--- a/app/store/chat.ts
+++ b/app/store/chat.ts
@@ -1,4 +1,9 @@
-import { getMessageTextContent, trimTopic } from "../utils";
+import {
+ getMessageTextContent,
+ isDalle3,
+ safeLocalStorage,
+ trimTopic,
+} from "../utils";
import { indexedDBStorage } from "@/app/utils/indexedDB-storage";
import { nanoid } from "nanoid";
@@ -14,14 +19,15 @@ import {
DEFAULT_INPUT_TEMPLATE,
DEFAULT_MODELS,
DEFAULT_SYSTEM_TEMPLATE,
+ GEMINI_SUMMARIZE_MODEL,
KnowledgeCutOffDate,
+ MCP_SYSTEM_TEMPLATE,
+ MCP_TOOLS_TEMPLATE,
+ ServiceProvider,
StoreKey,
SUMMARIZE_MODEL,
- GEMINI_SUMMARIZE_MODEL,
- ServiceProvider,
} from "../constant";
import Locale, { getLang } from "../locales";
-import { isDalle3, safeLocalStorage } from "../utils";
import { prettyObject } from "../utils/format";
import { createPersistStore } from "../utils/store";
import { estimateTokenLength } from "../utils/token";
@@ -29,6 +35,8 @@ import { ModelConfig, ModelType, useAppConfig } from "./config";
import { useAccessStore } from "./access";
import { collectModelsWithDefaultModel } from "../utils/model";
import { createEmptyMask, Mask } from "./mask";
+import { executeMcpAction, getAllTools } from "../mcp/actions";
+import { extractMcpJson, isMcpJson } from "../mcp/utils";
const localStorage = safeLocalStorage();
@@ -53,6 +61,7 @@ export type ChatMessage = RequestMessage & {
model?: ModelType;
tools?: ChatMessageTool[];
audio_url?: string;
+ isMcpResponse?: boolean;
};
export function createMessage(override: Partial): ChatMessage {
@@ -189,6 +198,27 @@ function fillTemplateWith(input: string, modelConfig: ModelConfig) {
return output;
}
+async function getMcpSystemPrompt(): Promise {
+ const tools = await getAllTools();
+
+ let toolsStr = "";
+
+ tools.forEach((i) => {
+ // error client has no tools
+ if (!i.tools) return;
+
+ toolsStr += MCP_TOOLS_TEMPLATE.replace(
+ "{{ clientId }}",
+ i.clientId,
+ ).replace(
+ "{{ tools }}",
+ i.tools.tools.map((p: object) => JSON.stringify(p, null, 2)).join("\n"),
+ );
+ });
+
+ return MCP_SYSTEM_TEMPLATE.replace("{{ MCP_TOOLS }}", toolsStr);
+}
+
const DEFAULT_CHAT_STATE = {
sessions: [createEmptySession()],
currentSessionIndex: 0,
@@ -362,24 +392,30 @@ export const useChatStore = createPersistStore(
session.messages = session.messages.concat();
session.lastUpdate = Date.now();
});
+
get().updateStat(message, targetSession);
+
+ get().checkMcpJson(message);
+
get().summarizeSession(false, targetSession);
},
- async onUserInput(content: string, attachImages?: string[]) {
+ async onUserInput(
+ content: string,
+ attachImages?: string[],
+ isMcpResponse?: boolean,
+ ) {
const session = get().currentSession();
const modelConfig = session.mask.modelConfig;
- const userContent = fillTemplateWith(content, modelConfig);
- console.log("[User Input] after template: ", userContent);
-
- let mContent: string | MultimodalContent[] = userContent;
+ // MCP Response no need to fill template
+ let mContent: string | MultimodalContent[] = isMcpResponse
+ ? content
+ : fillTemplateWith(content, modelConfig);
- if (attachImages && attachImages.length > 0) {
+ if (!isMcpResponse && attachImages && attachImages.length > 0) {
mContent = [
- ...(userContent
- ? [{ type: "text" as const, text: userContent }]
- : []),
+ ...(content ? [{ type: "text" as const, text: content }] : []),
...attachImages.map((url) => ({
type: "image_url" as const,
image_url: { url },
@@ -390,6 +426,7 @@ export const useChatStore = createPersistStore(
let userMessage: ChatMessage = createMessage({
role: "user",
content: mContent,
+ isMcpResponse,
});
const botMessage: ChatMessage = createMessage({
@@ -399,7 +436,7 @@ export const useChatStore = createPersistStore(
});
// get recent messages
- const recentMessages = get().getMessagesWithMemory();
+ const recentMessages = await get().getMessagesWithMemory();
const sendMessages = recentMessages.concat(userMessage);
const messageIndex = session.messages.length + 1;
@@ -429,7 +466,7 @@ export const useChatStore = createPersistStore(
session.messages = session.messages.concat();
});
},
- onFinish(message) {
+ async onFinish(message) {
botMessage.streaming = false;
if (message) {
botMessage.content = message;
@@ -498,7 +535,7 @@ export const useChatStore = createPersistStore(
}
},
- getMessagesWithMemory() {
+ async getMessagesWithMemory() {
const session = get().currentSession();
const modelConfig = session.mask.modelConfig;
const clearContextIndex = session.clearContextIndex ?? 0;
@@ -514,18 +551,26 @@ export const useChatStore = createPersistStore(
(session.mask.modelConfig.model.startsWith("gpt-") ||
session.mask.modelConfig.model.startsWith("chatgpt-"));
+ const mcpSystemPrompt = await getMcpSystemPrompt();
+
var systemPrompts: ChatMessage[] = [];
systemPrompts = shouldInjectSystemPrompts
? [
createMessage({
role: "system",
- content: fillTemplateWith("", {
- ...modelConfig,
- template: DEFAULT_SYSTEM_TEMPLATE,
- }),
+ content:
+ fillTemplateWith("", {
+ ...modelConfig,
+ template: DEFAULT_SYSTEM_TEMPLATE,
+ }) + mcpSystemPrompt,
}),
]
- : [];
+ : [
+ createMessage({
+ role: "system",
+ content: mcpSystemPrompt,
+ }),
+ ];
if (shouldInjectSystemPrompts) {
console.log(
"[Global System Prompt] ",
@@ -768,6 +813,36 @@ export const useChatStore = createPersistStore(
lastInput,
});
},
+
+ /** check if the message contains MCP JSON and execute the MCP action */
+ checkMcpJson(message: ChatMessage) {
+ const content = getMessageTextContent(message);
+ if (isMcpJson(content)) {
+ try {
+ const mcpRequest = extractMcpJson(content);
+ if (mcpRequest) {
+ console.debug("[MCP Request]", mcpRequest);
+
+ executeMcpAction(mcpRequest.clientId, mcpRequest.mcp)
+ .then((result) => {
+ console.log("[MCP Response]", result);
+ const mcpResponse =
+ typeof result === "object"
+ ? JSON.stringify(result)
+ : String(result);
+ get().onUserInput(
+ `\`\`\`json:mcp-response:${mcpRequest.clientId}\n${mcpResponse}\n\`\`\``,
+ [],
+ true,
+ );
+ })
+ .catch((error) => showToast("MCP execution failed", error));
+ }
+ } catch (error) {
+ console.error("[Check MCP JSON]", error);
+ }
+ }
+ },
};
return methods;
diff --git a/next.config.mjs b/next.config.mjs
index 2bb6bc4f4b2..0e1105d5647 100644
--- a/next.config.mjs
+++ b/next.config.mjs
@@ -71,8 +71,10 @@ if (mode !== "export") {
// },
{
// https://{resource_name}.openai.azure.com/openai/deployments/{deploy_name}/chat/completions
- source: "/api/proxy/azure/:resource_name/deployments/:deploy_name/:path*",
- destination: "https://:resource_name.openai.azure.com/openai/deployments/:deploy_name/:path*",
+ source:
+ "/api/proxy/azure/:resource_name/deployments/:deploy_name/:path*",
+ destination:
+ "https://:resource_name.openai.azure.com/openai/deployments/:deploy_name/:path*",
},
{
source: "/api/proxy/google/:path*",
@@ -99,7 +101,7 @@ if (mode !== "export") {
destination: "https://dashscope.aliyuncs.com/api/:path*",
},
];
-
+
return {
beforeFiles: ret,
};
diff --git a/package.json b/package.json
index e081567a4b1..0efe27b391a 100644
--- a/package.json
+++ b/package.json
@@ -13,6 +13,7 @@
"export:dev": "concurrently -r \"yarn mask:watch\" \"cross-env BUILD_MODE=export BUILD_APP=1 next dev\"",
"app:dev": "concurrently -r \"yarn mask:watch\" \"yarn tauri dev\"",
"app:build": "yarn mask && yarn tauri build",
+ "app:clear": "yarn tauri dev",
"prompts": "node ./scripts/fetch-prompts.mjs",
"prepare": "husky install",
"proxy-dev": "sh ./scripts/init-proxy.sh && proxychains -f ./scripts/proxychains.conf yarn dev",
@@ -22,6 +23,7 @@
"dependencies": {
"@fortaine/fetch-event-source": "^3.0.6",
"@hello-pangea/dnd": "^16.5.0",
+ "@modelcontextprotocol/sdk": "^1.0.4",
"@next/third-parties": "^14.1.0",
"@svgr/webpack": "^6.5.1",
"@vercel/analytics": "^0.1.11",
@@ -49,14 +51,15 @@
"remark-breaks": "^3.0.2",
"remark-gfm": "^3.0.1",
"remark-math": "^5.1.1",
+ "rt-client": "https://github.com/Azure-Samples/aoai-realtime-audio-sdk/releases/download/js/v0.5.0/rt-client-0.5.0.tgz",
"sass": "^1.59.2",
"spark-md5": "^3.0.2",
"use-debounce": "^9.0.4",
- "zustand": "^4.3.8",
- "rt-client": "https://github.com/Azure-Samples/aoai-realtime-audio-sdk/releases/download/js/v0.5.0/rt-client-0.5.0.tgz"
+ "zod": "^3.24.1",
+ "zustand": "^4.3.8"
},
"devDependencies": {
- "@tauri-apps/api": "^1.6.0",
+ "@tauri-apps/api": "^2.1.1",
"@tauri-apps/cli": "1.5.11",
"@testing-library/dom": "^10.4.0",
"@testing-library/jest-dom": "^6.6.3",
diff --git a/tsconfig.json b/tsconfig.json
index c73eef3e876..6d24b42f1de 100644
--- a/tsconfig.json
+++ b/tsconfig.json
@@ -1,6 +1,6 @@
{
"compilerOptions": {
- "target": "ES2015",
+ "target": "ES2022",
"lib": ["dom", "dom.iterable", "esnext"],
"allowJs": true,
"skipLibCheck": true,
@@ -23,6 +23,6 @@
"@/*": ["./*"]
}
},
- "include": ["next-env.d.ts", "**/*.ts", "**/*.tsx", ".next/types/**/*.ts", "app/calcTextareaHeight.ts"],
+ "include": ["next-env.d.ts", "**/*.ts", "**/*.tsx", ".next/types/**/*.ts"],
"exclude": ["node_modules"]
}
diff --git a/yarn.lock b/yarn.lock
index dffc35e9cb7..a99ff08041d 100644
--- a/yarn.lock
+++ b/yarn.lock
@@ -1797,6 +1797,15 @@
"@jridgewell/resolve-uri" "3.1.0"
"@jridgewell/sourcemap-codec" "1.4.14"
+"@modelcontextprotocol/sdk@^1.0.4":
+ version "1.0.4"
+ resolved "https://registry.yarnpkg.com/@modelcontextprotocol/sdk/-/sdk-1.0.4.tgz#34ad1edd3db7dd7154e782312dfb29d2d0c11d21"
+ integrity sha512-C+jw1lF6HSGzs7EZpzHbXfzz9rj9him4BaoumlTciW/IDDgIpweF/qiCWKlP02QKg5PPcgY6xY2WCt5y2tpYow==
+ dependencies:
+ content-type "^1.0.5"
+ raw-body "^3.0.0"
+ zod "^3.23.8"
+
"@next/env@14.1.1":
version "14.1.1"
resolved "https://registry.yarnpkg.com/@next/env/-/env-14.1.1.tgz#80150a8440eb0022a73ba353c6088d419b908bac"
@@ -2029,10 +2038,10 @@
dependencies:
tslib "^2.4.0"
-"@tauri-apps/api@^1.6.0":
- version "1.6.0"
- resolved "https://registry.npmjs.org/@tauri-apps/api/-/api-1.6.0.tgz#745b7e4e26782c3b2ad9510d558fa5bb2cf29186"
- integrity sha512-rqI++FWClU5I2UBp4HXFvl+sBWkdigBkxnpJDQUWttNyG7IZP4FwQGhTNL5EOw0vI8i6eSAJ5frLqO7n7jbJdg==
+"@tauri-apps/api@^2.1.1":
+ version "2.1.1"
+ resolved "https://registry.yarnpkg.com/@tauri-apps/api/-/api-2.1.1.tgz#77d4ddb683d31072de4e6a47c8613d9db011652b"
+ integrity sha512-fzUfFFKo4lknXGJq8qrCidkUcKcH2UHhfaaCNt4GzgzGaW2iS26uFOg4tS3H4P8D6ZEeUxtiD5z0nwFF0UN30A==
"@tauri-apps/cli-darwin-arm64@1.5.11":
version "1.5.11"
@@ -3039,6 +3048,11 @@ busboy@1.6.0:
dependencies:
streamsearch "^1.1.0"
+bytes@3.1.2:
+ version "3.1.2"
+ resolved "https://registry.yarnpkg.com/bytes/-/bytes-3.1.2.tgz#8b0beeb98605adf1b128fa4386403c009e0221a5"
+ integrity sha512-/Nf7TyzTx6S3yRJObOAV7956r8cr2+Oj8AC5dt8wSP3BQAoeX58NoHyCU8P8zGkNXStjTSi6fzO6F0pBdcYbEg==
+
call-bind@^1.0.0, call-bind@^1.0.2:
version "1.0.2"
resolved "https://registry.yarnpkg.com/call-bind/-/call-bind-1.0.2.tgz#b1d4e89e688119c3c9a903ad30abb2f6a919be3c"
@@ -3062,15 +3076,10 @@ camelcase@^6.2.0:
resolved "https://registry.yarnpkg.com/camelcase/-/camelcase-6.3.0.tgz#5685b95eb209ac9c0c177467778c9c84df58ba9a"
integrity sha512-Gmy6FhYlCY7uOElZUSbxo2UCDH8owEk996gkbrpsgGtrJLM3J7jGxl9Ic7Qwwj4ivOE5AWZWRMecDdF7hqGjFA==
-caniuse-lite@^1.0.30001449, caniuse-lite@^1.0.30001503, caniuse-lite@^1.0.30001579:
- version "1.0.30001617"
- resolved "https://registry.yarnpkg.com/caniuse-lite/-/caniuse-lite-1.0.30001617.tgz#809bc25f3f5027ceb33142a7d6c40759d7a901eb"
- integrity sha512-mLyjzNI9I+Pix8zwcrpxEbGlfqOkF9kM3ptzmKNw5tizSyYwMe+nGLTqMK9cO+0E+Bh6TsBxNAaHWEM8xwSsmA==
-
-caniuse-lite@^1.0.30001646:
- version "1.0.30001649"
- resolved "https://registry.npmmirror.com/caniuse-lite/-/caniuse-lite-1.0.30001649.tgz#3ec700309ca0da2b0d3d5fb03c411b191761c992"
- integrity sha512-fJegqZZ0ZX8HOWr6rcafGr72+xcgJKI9oWfDW5DrD7ExUtgZC7a7R7ZYmZqplh7XDocFdGeIFn7roAxhOeYrPQ==
+caniuse-lite@^1.0.30001449, caniuse-lite@^1.0.30001503, caniuse-lite@^1.0.30001579, caniuse-lite@^1.0.30001646:
+ version "1.0.30001692"
+ resolved "https://registry.npmjs.org/caniuse-lite/-/caniuse-lite-1.0.30001692.tgz"
+ integrity sha512-A95VKan0kdtrsnMubMKxEKUKImOPSuCpYgxSQBo036P5YYgVIcOYJEgt/txJWqObiRQeISNCfef9nvlQ0vbV7A==
ccount@^2.0.0:
version "2.0.1"
@@ -3285,6 +3294,11 @@ concurrently@^8.2.2:
tree-kill "^1.2.2"
yargs "^17.7.2"
+content-type@^1.0.5:
+ version "1.0.5"
+ resolved "https://registry.yarnpkg.com/content-type/-/content-type-1.0.5.tgz#8b773162656d1d1086784c8f23a54ce6d73d7918"
+ integrity sha512-nTjqfcBFEipKdXCv4YDQWCfmcLZKm81ldF0pAopTvyrFGVbcR6P/VAAd5G7N+0tTr8QqiU0tFadD6FK4NtJwOA==
+
convert-source-map@^1.7.0:
version "1.9.0"
resolved "https://registry.yarnpkg.com/convert-source-map/-/convert-source-map-1.9.0.tgz#7faae62353fb4213366d0ca98358d22e8368b05f"
@@ -3849,6 +3863,11 @@ delayed-stream@~1.0.0:
resolved "https://registry.npmjs.org/delayed-stream/-/delayed-stream-1.0.0.tgz#df3ae199acadfb7d440aaae0b29e2272b24ec619"
integrity sha512-ZySD7Nf91aLB0RxL4KGrKHBXl7Eds1DAmEdcoVawXnLD7SDhpNgtuII2aAkg7a7QS41jxPSZ17p4VdGnMHk3MQ==
+depd@2.0.0:
+ version "2.0.0"
+ resolved "https://registry.yarnpkg.com/depd/-/depd-2.0.0.tgz#b696163cc757560d09cf22cc8fad1571b79e76df"
+ integrity sha512-g7nH6P6dyDioJogAAGprGpCtVImJhpPk/roCzdb3fIh61/s/nPsfR6onyMwkCAR/OlC3yBC0lESvUoQEAssIrw==
+
dequal@^2.0.0, dequal@^2.0.3:
version "2.0.3"
resolved "https://registry.yarnpkg.com/dequal/-/dequal-2.0.3.tgz#2644214f1997d39ed0ee0ece72335490a7ac67be"
@@ -5007,6 +5026,17 @@ html-to-image@^1.11.11:
resolved "https://registry.npmmirror.com/html-to-image/-/html-to-image-1.11.11.tgz#c0f8a34dc9e4b97b93ff7ea286eb8562642ebbea"
integrity sha512-9gux8QhvjRO/erSnDPv28noDZcPZmYE7e1vFsBLKLlRlKDSqNJYebj6Qz1TGd5lsRV+X+xYyjCKjuZdABinWjA==
+http-errors@2.0.0:
+ version "2.0.0"
+ resolved "https://registry.yarnpkg.com/http-errors/-/http-errors-2.0.0.tgz#b7774a1486ef73cf7667ac9ae0858c012c57b9d3"
+ integrity sha512-FtwrG/euBzaEjYeRqOgly7G0qviiXoJWnvEH2Z1plBdXgbyjv34pHTSb9zoeHMyDy33+DWy5Wt9Wo+TURtOYSQ==
+ dependencies:
+ depd "2.0.0"
+ inherits "2.0.4"
+ setprototypeof "1.2.0"
+ statuses "2.0.1"
+ toidentifier "1.0.1"
+
http-proxy-agent@^5.0.0:
version "5.0.0"
resolved "https://registry.npmmirror.com/http-proxy-agent/-/http-proxy-agent-5.0.0.tgz#5129800203520d434f142bc78ff3c170800f2b43"
@@ -5095,7 +5125,7 @@ inflight@^1.0.4:
once "^1.3.0"
wrappy "1"
-inherits@2:
+inherits@2, inherits@2.0.4:
version "2.0.4"
resolved "https://registry.yarnpkg.com/inherits/-/inherits-2.0.4.tgz#0fa2c64f932917c3433a0ded55363aae37416b7c"
integrity sha512-k/vGaX4/Yla3WzyMCvTQOXYeIHvqOKtnqBduzTHpzpQZzAskKMhZ2K+EnBiSM9zGSoIFeMpXKxa4dYeZIQqewQ==
@@ -7138,6 +7168,16 @@ randombytes@^2.1.0:
dependencies:
safe-buffer "^5.1.0"
+raw-body@^3.0.0:
+ version "3.0.0"
+ resolved "https://registry.yarnpkg.com/raw-body/-/raw-body-3.0.0.tgz#25b3476f07a51600619dae3fe82ddc28a36e5e0f"
+ integrity sha512-RmkhL8CAyCRPXCE28MMH0z2PNWQBNk2Q09ZdxM9IOOXwxwZbN+qbWaatPkdkWIKL2ZVDImrN/pK5HTRz2PcS4g==
+ dependencies:
+ bytes "3.1.2"
+ http-errors "2.0.0"
+ iconv-lite "0.6.3"
+ unpipe "1.0.0"
+
react-dom@^18.2.0:
version "18.2.0"
resolved "https://registry.yarnpkg.com/react-dom/-/react-dom-18.2.0.tgz#22aaf38708db2674ed9ada224ca4aa708d821e3d"
@@ -7569,6 +7609,11 @@ serialize-javascript@^6.0.1:
dependencies:
randombytes "^2.1.0"
+setprototypeof@1.2.0:
+ version "1.2.0"
+ resolved "https://registry.yarnpkg.com/setprototypeof/-/setprototypeof-1.2.0.tgz#66c9a24a73f9fc28cbe66b09fed3d33dcaf1b424"
+ integrity sha512-E5LDX7Wrp85Kil5bhZv46j8jOeboKq5JMmYM3gVGdGH8xFpPWXUMsNrlODCrkoxMEeNi/XZIwuRvY4XNwYMJpw==
+
shebang-command@^2.0.0:
version "2.0.0"
resolved "https://registry.yarnpkg.com/shebang-command/-/shebang-command-2.0.0.tgz#ccd0af4f8835fbdc265b82461aaf0c36663f34ea"
@@ -7699,6 +7744,11 @@ stack-utils@^2.0.3:
dependencies:
escape-string-regexp "^2.0.0"
+statuses@2.0.1:
+ version "2.0.1"
+ resolved "https://registry.yarnpkg.com/statuses/-/statuses-2.0.1.tgz#55cb000ccf1d48728bd23c685a063998cf1a1b63"
+ integrity sha512-RwNA9Z/7PrK06rYLIzFMlaF+l73iwpzsqRIFgbMLbTcLD6cOao82TaWefPXQvB2fOC4AjuYSEndS7N/mTCbkdQ==
+
stop-iteration-iterator@^1.0.0:
version "1.0.0"
resolved "https://registry.yarnpkg.com/stop-iteration-iterator/-/stop-iteration-iterator-1.0.0.tgz#6a60be0b4ee757d1ed5254858ec66b10c49285e4"
@@ -7977,6 +8027,11 @@ to-regex-range@^5.0.1:
dependencies:
is-number "^7.0.0"
+toidentifier@1.0.1:
+ version "1.0.1"
+ resolved "https://registry.yarnpkg.com/toidentifier/-/toidentifier-1.0.1.tgz#3be34321a88a820ed1bd80dfaa33e479fbb8dd35"
+ integrity sha512-o5sSPKEkg/DIQNmH43V0/uerLrpzVedkUh8tGNvaeXpfpuwjKenlSox/2O/BTlZUtEe+JG7s5YhEz608PlAHRA==
+
tough-cookie@^4.1.2:
version "4.1.4"
resolved "https://registry.npmmirror.com/tough-cookie/-/tough-cookie-4.1.4.tgz#945f1461b45b5a8c76821c33ea49c3ac192c1b36"
@@ -8219,6 +8274,11 @@ universalify@^0.2.0:
resolved "https://registry.npmmirror.com/universalify/-/universalify-0.2.0.tgz#6451760566fa857534745ab1dde952d1b1761be0"
integrity sha512-CJ1QgKmNg3CwvAv/kOFmtnEN05f0D/cn9QntgNOQlQF9dgvVTHj3t+8JPdjqawCHk7V/KA+fbUqzZ9XWhcqPUg==
+unpipe@1.0.0:
+ version "1.0.0"
+ resolved "https://registry.yarnpkg.com/unpipe/-/unpipe-1.0.0.tgz#b2bf4ee8514aae6165b4817829d21b2ef49904ec"
+ integrity sha512-pjy2bYhSsufwWlKwPc+l3cN7+wuJlK6uz0YdJEOlQDbl6jo/YlPi4mb8agUkVC8BF7V8NuzeyPNqRksA3hztKQ==
+
update-browserslist-db@^1.0.10:
version "1.0.10"
resolved "https://registry.yarnpkg.com/update-browserslist-db/-/update-browserslist-db-1.0.10.tgz#0f54b876545726f17d00cd9a2561e6dade943ff3"
@@ -8572,6 +8632,11 @@ yocto-queue@^0.1.0:
resolved "https://registry.yarnpkg.com/yocto-queue/-/yocto-queue-0.1.0.tgz#0294eb3dee05028d31ee1a5fa2c556a6aaf10a1b"
integrity sha512-rVksvsnNCdJ/ohGc6xgPwyN8eheCxsiLM8mxuE/t/mOVqJewPuO1miLpTHQiRgTKCLexL4MeAFVagts7HmNZ2Q==
+zod@^3.23.8, zod@^3.24.1:
+ version "3.24.1"
+ resolved "https://registry.yarnpkg.com/zod/-/zod-3.24.1.tgz#27445c912738c8ad1e9de1bea0359fa44d9d35ee"
+ integrity sha512-muH7gBL9sI1nciMZV67X5fTKKBLtwpZ5VBp1vsOQzj1MhrBZ4wlVCm3gedKZWLp0Oyel8sIGfeiz54Su+OVT+A==
+
zustand@^4.3.8:
version "4.3.8"
resolved "https://registry.yarnpkg.com/zustand/-/zustand-4.3.8.tgz#37113df8e9e1421b0be1b2dca02b49b76210e7c4"
+
+
- {!isUser && (
-
+
+ />
+ )}
+
+ )}
- {isUser ? (
-
+
+ {isUser ? (
+
+ {message.model}
+
)}
-
- {message.model}
-
- )}
-
- {showActions && (
-
-
- {message?.tools?.length == 0 && showTyping && (
-
- {message.streaming ? (
-
+ {message?.tools?.length == 0 && showTyping && (
+
+
+ )}
+
+ {message.streaming ? (
+ {Locale.Chat.Typing}
)}
-
- {Locale.Chat.Typing}
-
- )}
- {/*@ts-ignore*/}
- {message?.tools?.length > 0 && (
-
- {message?.tools?.map((tool) => (
+ {/*@ts-ignore*/}
+ {message?.tools?.length > 0 && (
+
- {shouldShowClearContextDivider &&
+ {message?.tools?.map((tool) => (
+
+ )}
+
+ {tool.isError === false ? (
+
+ ))}
+
+ onRightClick(e, message)} // hard to use
+ onDoubleClickCapture={() => {
+ if (!isMobileScreen) return;
+ setUserInput(getMessageTextContent(message));
+ }}
+ fontSize={fontSize}
+ fontFamily={fontFamily}
+ parentRef={scrollRef}
+ defaultShow={i >= messages.length - 6}
+ />
+ {getMessageImages(message).length == 1 && (
+ [0]})
+ )}
+ {getMessageImages(message).length > 1 && (
- )}
-
- {tool.isError === false ? (
- 
+ );
+ },
)}
- {tool?.function?.name}
- ))}
+ )}
- onRightClick(e, message)} // hard to use
- onDoubleClickCapture={() => {
- if (!isMobileScreen) return;
- setUserInput(getMessageTextContent(message));
- }}
- fontSize={fontSize}
- fontFamily={fontFamily}
- parentRef={scrollRef}
- defaultShow={i >= messages.length - 6}
- />
- {getMessageImages(message).length == 1 && (
-
- )}
- {getMessageImages(message).length > 1 && (
-
-
- {getMessageImages(message).map((image, index) => {
- return (
-
- );
- })}
+ {message?.audio_url && (
+
- {message?.audio_url && (
-
+
)}
-
-
-
- )}
-
- {isContext
- ? Locale.Chat.IsContext
- : message.date.toLocaleString()}
+
+ {isContext
+ ? Locale.Chat.IsContext
+ : message.date.toLocaleString()}
+
+ {(currentValue as string[]).map(
+ (value: string, index: number) => (
+
+
+ {
+ const newValue = [...currentValue] as string[];
+ newValue[index] = e.target.value;
+ setUserConfig({ ...userConfig, [key]: newValue });
+ }}
+ />
+
+ ),
+ )}
+
+
+ );
+ }
+
+ if (!Array.isArray(presetServers) || presetServers.length === 0) {
+ return (
+
+ Loading preset server list...
+
+
+
+ );
+ }
+
+ return presetServers
+ .filter((server) => {
+ if (searchText.length === 0) return true;
+ const searchLower = searchText.toLowerCase();
+ return (
+ server.name.toLowerCase().includes(searchLower) ||
+ server.description.toLowerCase().includes(searchLower) ||
+ server.tags.some((tag) => tag.toLowerCase().includes(searchLower))
+ );
+ })
+ .sort((a, b) => {
+ const aStatus = checkServerStatus(a.id).status;
+ const bStatus = checkServerStatus(b.id).status;
+ const aLoading = loadingStates[a.id];
+ const bLoading = loadingStates[b.id];
+
+ // 定义状态优先级
+ const statusPriority: RecordNo servers available
+
+
+ ));
+ };
+
+ return (
+
+
+
+
+
+ {server.name}
+ {loadingStates[server.id] && (
+
+ {loadingStates[server.id]}
+
+ )}
+ {!loadingStates[server.id] && getServerStatusDisplay(server.id)}
+ {server.repo && (
+
+
+
+ {server.tags.map((tag, index) => (
+
+ {tag}
+
+ ))}
+
+
+ {server.description}
+
+
+ {isServerAdded(server.id) ? (
+ <>
+ {server.configurable && (
+
+
+
+
+
+
+
+
+
+
+ MCP Market
+ {loadingStates["all"] && (
+
+ {loadingStates["all"]}
+
+ )}
+
+
+ {Object.keys(config?.mcpServers ?? {}).length} servers configured
+
+
+
+
+
+
+
+
+
+
+ {/*编辑服务器配置*/}
+ {editingServerId && (
+
+ setSearchText(e.currentTarget.value)}
+ />
+
+
+ {renderServerList()}
+
+ !isLoading && setEditingServerId(undefined)}
+ actions={[
+ setEditingServerId(undefined)}
+ bordered
+ disabled={isLoading}
+ />,
+
+
+ )}
+
+ {viewingServerId && (
+ - {renderConfigForm()}
+ setViewingServerId(undefined)}
+ actions={[
+ setViewingServerId(undefined)}
+ bordered
+ />,
+ ]}
+ >
+
+
+ )}
+
+ {isLoading ? (
+
+ Loading...
+ ) : tools?.tools ? (
+ tools.tools.map(
+ (tool: ListToolsResponse["tools"], index: number) => (
+
+
+ ),
+ )
+ ) : (
+ {tool.name}
+
+ {tool.description}
+
+ No tools available
+ )}
+