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

feat(LocalRunnerClient): support registering DescMcpServer watch service

Browse Source
This commit is contained in:
slhafzjw
2026-01-02 21:41:47 +08:00
parent 4ea8926363
commit de462866b2
1 changed files with 13 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -115,11 +115,22 @@ public class LocalRunnerClient extends RunnerClient {
.capabilities(serverCapabilities) .capabilities(serverCapabilities)
.jsonMapper(McpJsonMapper.getDefault()) .jsonMapper(McpJsonMapper.getDefault())
.build(); .build();
registerDescMcpWatch();
// TODO 完善加载与监听逻辑
registerMcpClient("mcp-desc", pair.clientSide(), 10); registerMcpClient("mcp-desc", pair.clientSide(), 10);
} }
private void registerDescMcpWatch() {
WatchContext ctx = new WatchContext(Path.of(MCP_DESC_PATH), watchService);
LocalWatchEventProcessor.Desc desc = new LocalWatchEventProcessor.Desc(existedMetaActions, mcpDescServer, ctx);
new LocalWatchServiceBuild.BuildRegistry(ctx)
.initialLoad(desc.buildLoad())
.registerCreate(desc.buildCreate())
.registerDelete(desc.buildDelete())
.registerModify(desc.buildModify())
.registerOverflow(desc.buildOverflow())
.commit(executor);
}
private void registerDynamicActionMcp() { private void registerDynamicActionMcp() {
InProcessMcpTransport.Pair pair = InProcessMcpTransport.pair(); InProcessMcpTransport.Pair pair = InProcessMcpTransport.pair();
McpSchema.ServerCapabilities serverCapabilities = McpSchema.ServerCapabilities.builder() McpSchema.ServerCapabilities serverCapabilities = McpSchema.ServerCapabilities.builder()