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 CommonMcp

Browse Source
This commit is contained in:
slhafzjw
2026-01-08 22:28:12 +08:00
parent 4f36c0dd2d
commit 8ca475beeb
1 changed files with 13 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -105,9 +105,22 @@ public class LocalRunnerClient extends RunnerClient {
} }
registerDescMcp(); registerDescMcp();
registerDynamicActionMcp(); registerDynamicActionMcp();
registerCommonMcp();
setupShutdownHook(); setupShutdownHook();
} }
private void registerCommonMcp() {
val ctx = new WatchContext(Path.of(MCP_SERVER_PATH), watchService);
val common = new LocalWatchEventProcessor.Common(existedMetaActions, mcpClients, ctx);
new LocalWatchServiceBuild.BuildRegistry(ctx)
.initialLoad(common.buildLoad())
.registerCreate(common.buildCreate())
.registerDelete(common.buildDelete())
.registerModify(common.buildModify())
.registerOverflow(common.buildOverflow())
.commit(executor);
}
private void registerDescMcp() { private void registerDescMcp() {
InProcessMcpTransport.Pair pair = InProcessMcpTransport.pair(); InProcessMcpTransport.Pair pair = InProcessMcpTransport.pair();
McpSchema.ServerCapabilities serverCapabilities = McpSchema.ServerCapabilities.builder() McpSchema.ServerCapabilities serverCapabilities = McpSchema.ServerCapabilities.builder()