opensource/mateclaw
2
0
Fork 0
mirror of https://gitee.com/mateos/mateclaw.git synced 2026-09-15 03:55:09 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix(mcp): clear stale MCP connection errors

Browse Source 
Update MCP server status with an explicit wrapper so successful reconnects can persist lastError=null while keeping updateTime refreshed.
This commit is contained in:
DayByDay 2026-05-04 14:16:43 +08:00 committed by GitHub
parent f5d845ff31
commit 1aa7787ced
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
mateclaw-server/src/main/java/vip/mate/tool/mcp/service/McpServerService.java
View File

@ -2,6 +2,7 @@ package vip.mate.tool.mcp.service;
import cn.hutool.json.JSONUtil; import cn.hutool.json.JSONUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
@ -313,15 +314,16 @@ public class McpServerService {
private void updateStatus(Long id, String status, String error, int toolCount) { private void updateStatus(Long id, String status, String error, int toolCount) {
try { try {
McpServerEntity update = new McpServerEntity(); LambdaUpdateWrapper<McpServerEntity> wrapper = new LambdaUpdateWrapper<>();
update.setId(id); wrapper.eq(McpServerEntity::getId, id);
update.setLastStatus(status); wrapper.set(McpServerEntity::getLastStatus, status);
update.setLastError(error); wrapper.set(McpServerEntity::getLastError, error);
update.setToolCount(toolCount); wrapper.set(McpServerEntity::getToolCount, toolCount);
if ("connected".equals(status)) { if ("connected".equals(status)) {
update.setLastConnectedTime(LocalDateTime.now()); wrapper.set(McpServerEntity::getLastConnectedTime, LocalDateTime.now());
} }
mcpServerMapper.updateById(update); wrapper.set(McpServerEntity::getUpdateTime, LocalDateTime.now());
mcpServerMapper.update(null, wrapper);
} catch (Exception e) { } catch (Exception e) {
log.warn("Failed to update MCP server status: {}", e.getMessage()); log.warn("Failed to update MCP server status: {}", e.getMessage());
} }