diff --git a/Partner-Main/src/main/java/work/slhaf/partner/core/action/runner/LocalRunnerClient.java b/Partner-Main/src/main/java/work/slhaf/partner/core/action/runner/LocalRunnerClient.java index fef9578a..761f43ed 100644 --- a/Partner-Main/src/main/java/work/slhaf/partner/core/action/runner/LocalRunnerClient.java +++ b/Partner-Main/src/main/java/work/slhaf/partner/core/action/runner/LocalRunnerClient.java @@ -105,9 +105,22 @@ public class LocalRunnerClient extends RunnerClient { } registerDescMcp(); registerDynamicActionMcp(); + registerCommonMcp(); 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() { InProcessMcpTransport.Pair pair = InProcessMcpTransport.pair(); McpSchema.ServerCapabilities serverCapabilities = McpSchema.ServerCapabilities.builder()