Quellcode durchsuchen

暂时移除mcp策略

Grizzly vor 5 Monaten
Ursprung
Commit
639a0afbca

+ 0 - 43
src/main/java/edu/nju/software/aipaasagent/client/mcp/config/McpServerConfig.java

@@ -1,43 +0,0 @@
-package edu.nju.software.aipaasagent.client.mcp.config;
-
-import lombok.Data;
-import org.springframework.boot.context.properties.ConfigurationProperties;
-import org.springframework.context.annotation.Configuration;
-
-/**
- * MCP Hub 服务器配置
- * 
- * 配置项:
- * mcp.hub.base-url=https://ai-paas-mcp-endpoint.njuu.top/mcp  # 同学 MCP Hub 的地址
- * mcp.hub.authorization=sqGYuMvKgdxmzmTM5lNBgLdVpl6XNnPX  # 鉴权 token
- */
-@Data
-@Configuration
-@ConfigurationProperties(prefix = "mcp.hub")
-public class McpServerConfig {
-    
-    /**
-     * MCP Hub 基础 URL
-     */
-    private String baseUrl = "https://ai-paas-mcp-endpoint.njuu.top";
-    
-    /**
-     * 鉴权 token
-     */
-    private String authorization = "sqGYuMvKgdxmzmTM5lNBgLdVpl6XNnPX";
-    
-    /**
-     * 连接超时(秒)
-     */
-    private int connectTimeout = 10;
-    
-    /**
-     * 请求超时(秒)
-     */
-    private int requestTimeout = 60;
-    
-    /**
-     * 是否自动重连
-     */
-    private boolean autoReconnect = true;
-}

+ 0 - 41
src/main/java/edu/nju/software/aipaasagent/client/mcp/strategy/McpStrategy.java

@@ -1,41 +0,0 @@
-package edu.nju.software.aipaasagent.client.mcp.strategy;
-
-import edu.nju.software.aipaasagent.agent.config.AgentConfiguration;
-import edu.nju.software.aipaasagent.client.mcp.McpClientService;
-import org.springframework.ai.tool.ToolCallback;
-
-import java.util.List;
-
-/**
- * MCP 策略接口
- * 定义不同 MCP 模式的行为
- */
-public interface McpStrategy {
-
-    /**
-     * 初始化策略
-     * @param mcpClientService MCP 客户端服务
-     * @param config Agent 配置
-     */
-    void initialize(McpClientService mcpClientService, AgentConfiguration config);
-
-    /**
-     * 创建 MCP 工具列表
-     * @param mcpClientService MCP 客户端服务
-     * @param config Agent 配置
-     * @return MCP 工具回调列表
-     */
-    List<ToolCallback> createMcpTools(McpClientService mcpClientService, AgentConfiguration config);
-
-    /**
-     * 是否应该包含本地工具
-     * @return true 包含本地工具,false 不包含
-     */
-    boolean includeLocalTools();
-
-    /**
-     * 获取策略模式名称
-     * @return 模式名称
-     */
-    String getMode();
-}

+ 0 - 40
src/main/java/edu/nju/software/aipaasagent/client/mcp/strategy/McpStrategyFactory.java

@@ -1,40 +0,0 @@
-package edu.nju.software.aipaasagent.client.mcp.strategy;
-
-import java.util.HashMap;
-import java.util.Map;
-
-/**
- * MCP 策略工厂
- * 根据模式名称创建对应的策略实例
- */
-public class McpStrategyFactory {
-
-    private static final Map<String, McpStrategy> strategyMap = new HashMap<>();
-
-    static {
-        // 初始化策略映射
-        strategyMap.put("auto", new AutoMcpStrategy());
-        strategyMap.put("force", new ForceMcpStrategy());
-        strategyMap.put("disabled", new DisabledMcpStrategy());
-        strategyMap.put("intelligence", new IntelligenceMcpStrategy());
-    }
-
-    /**
-     * 根据模式名称获取策略实例
-     * @param mode 模式名称
-     * @return MCP 策略实例
-     */
-    public static McpStrategy getStrategy(String mode) {
-        if (mode == null || mode.isEmpty()) {
-            mode = "auto"; // 默认使用 auto 模式
-        }
-        
-        McpStrategy strategy = strategyMap.get(mode.toLowerCase());
-        if (strategy == null) {
-            // 如果模式不存在,使用 auto 模式作为默认值
-            strategy = strategyMap.get("auto");
-        }
-        
-        return strategy;
-    }
-}

+ 0 - 24
src/test/java/edu/nju/software/aipaasagent/client/mcp/McpTest.java

@@ -1,24 +0,0 @@
-package edu.nju.software.aipaasagent.client.mcp;
-
-import org.junit.jupiter.api.Test;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.test.context.SpringBootTest;
-
-@SpringBootTest
-public class McpTest {
-
-    @Autowired
-    private McpClientService mcpClientService;
-
-    @Test
-    public void testConnect() {
-        System.out.println("Testing MCP connection...");
-        try {
-            String sessionId = mcpClientService.connect("default");
-            System.out.println("Session ID: " + sessionId);
-        } catch (Exception e) {
-            System.out.println("Error: " + e.getMessage());
-            e.printStackTrace();
-        }
-    }
-}