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

feat(LocalRunnerClient): support creating MCP configurations in CommonMcp

Browse Source
This commit is contained in:
slhafzjw
2026-01-08 22:09:14 +08:00
parent a0bca668cb
commit 00993bd763
1 changed files with 33 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1031,28 +1031,7 @@ public class LocalRunnerClient extends RunnerClient {
if (!normalFile(file)) {
continue;
}
val json = readJson(file);
if (json == null) {
return;
}
val newFileRecord = new McpConfigFileRecord(file.lastModified(), file.length());
for (String id : json.keySet()) {
val mcp = readMcp(json, id);
if (mcp == null) {
continue;
}
val params = readParams(mcp);
if (params == null) {
continue;
}
registerMcpClient(id, params);
newFileRecord.paramsCacheMap().put(id, params);
}
mcpConfigFileCache.put(file, newFileRecord);
loadAndRegisterMcpClientsFromFile(file);
}
};
}
@@ -1226,7 +1205,38 @@ public class LocalRunnerClient extends RunnerClient {
@Override
@NotNull
protected LocalWatchServiceBuild.EventHandler buildCreate() {
return null;
return (thisDir, context) -> {
val file = context.toFile();
if (!normalFile(file)) {
return;
}
loadAndRegisterMcpClientsFromFile(file);
};
}
private void loadAndRegisterMcpClientsFromFile(File file) {
val mcpConfigJson = readJson(file);
if (mcpConfigJson == null) {
return;
}
val newFileRecord = new McpConfigFileRecord(file.lastModified(), file.length());
for (String id : mcpConfigJson.keySet()) {
val mcp = readMcp(mcpConfigJson, id);
if (mcp == null) {
continue;
}
val params = readParams(mcp);
if (params == null) {
continue;
}
registerMcpClient(id, params);
newFileRecord.paramsCacheMap().put(id, params);
}
mcpConfigFileCache.put(file, newFileRecord);
}
@Override