slhaf/Partner
1
0
Fork 0
mirror of https://github.com/slhaf/Partner.git synced 2026-05-12 16:53:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(LocalRunnerClient): correct method loadFiles in LocalWatchEventProcessor

Browse Source
This commit is contained in:
slhafzjw
2026-01-11 16:30:44 +08:00
parent dd8d86d3c4
commit cdb6ae9d01
1 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
Partner-Main/src/main/java/work/slhaf/partner/core/action/runner/LocalRunnerClient.java
View File

@@ -556,8 +556,7 @@ public class LocalRunnerClient extends RunnerClient {
protected abstract @NotNull LocalWatchServiceBuild.EventHandler buildOverflow(); protected abstract @NotNull LocalWatchServiceBuild.EventHandler buildOverflow();
protected File[] loadFiles() { protected File[] loadFiles(Path root) {
val root = ctx.root;
if (!Files.isDirectory(root)) { if (!Files.isDirectory(root)) {
throw new ActionInitFailedException("未找到目录: " + root); throw new ActionInitFailedException("未找到目录: " + root);
} }
@@ -580,7 +579,7 @@ public class LocalRunnerClient extends RunnerClient {
@SuppressWarnings("BooleanMethodIsAlwaysInverted") @SuppressWarnings("BooleanMethodIsAlwaysInverted")
private boolean normalPath(Path path) { private boolean normalPath(Path path) {
val files = loadFiles(); val files = loadFiles(path);
if (files.length < 2) { if (files.length < 2) {
return false; return false;
} }
@@ -950,7 +949,7 @@ public class LocalRunnerClient extends RunnerClient {
return () -> { return () -> {
// DescMcp 的加载逻辑只负责读取已有的 *.desc.json 并注册为 resources // DescMcp 的加载逻辑只负责读取已有的 *.desc.json 并注册为 resources
// 正常来讲 root 直接对应 MCP_DESC_PATH，先检查 root 是否为目录，否则拒绝启动 // 正常来讲 root 直接对应 MCP_DESC_PATH，先检查 root 是否为目录，否则拒绝启动
val files = loadFiles(); val files = loadFiles(ctx.root);
for (File file : files) { for (File file : files) {
addResource(file); addResource(file);
} }
@@ -1138,7 +1137,7 @@ public class LocalRunnerClient extends RunnerClient {
// For CommonMcp, we need to list all files in MCP_SERVER_PATH, // For CommonMcp, we need to list all files in MCP_SERVER_PATH,
// and search for files with extend name .json, // and search for files with extend name .json,
// and then reading them as JSONObject to get McpClientTransportParams. // and then reading them as JSONObject to get McpClientTransportParams.
val files = loadFiles(); val files = loadFiles(ctx.root);
for (File file : files) { for (File file : files) {
if (!normalFile(file)) { if (!normalFile(file)) {
@@ -1230,7 +1229,7 @@ public class LocalRunnerClient extends RunnerClient {
val changedMap = new HashMap<String, McpClientTransportParams>(); val changedMap = new HashMap<String, McpClientTransportParams>();
val existingMcpIdSet = new HashSet<String>(); val existingMcpIdSet = new HashSet<String>();
val files = loadFiles(); val files = loadFiles(ctx.root);
for (File file : files) { for (File file : files) {
if (!normalFile(file)) { if (!normalFile(file)) {
continue; continue;