From 1465d7687b075ec345d734c643841b9685626544 Mon Sep 17 00:00:00 2001 From: slhafzjw Date: Tue, 17 Mar 2026 10:35:35 +0800 Subject: [PATCH] refactor(runner): add policy listener registering function and support registering McpConfigWatcher after starting --- .../slhaf/partner/core/action/runner/LocalRunnerClient.java | 1 + .../partner/core/action/runner/policy/ExecutionPolicy.kt | 4 ++++ 2 files changed, 5 insertions(+) diff --git a/Partner-Core/src/main/java/work/slhaf/partner/core/action/runner/LocalRunnerClient.java b/Partner-Core/src/main/java/work/slhaf/partner/core/action/runner/LocalRunnerClient.java index 666e08ee..f26094f4 100644 --- a/Partner-Core/src/main/java/work/slhaf/partner/core/action/runner/LocalRunnerClient.java +++ b/Partner-Core/src/main/java/work/slhaf/partner/core/action/runner/LocalRunnerClient.java @@ -95,6 +95,7 @@ public class LocalRunnerClient extends RunnerClient implements AutoCloseable { executor ); configWatcher.start(); + configWatcher.registerPolicyListener(); } catch (Exception e) { closeQuietly(configWatcher); closeQuietly(dynamicManager); diff --git a/Partner-Core/src/main/java/work/slhaf/partner/core/action/runner/policy/ExecutionPolicy.kt b/Partner-Core/src/main/java/work/slhaf/partner/core/action/runner/policy/ExecutionPolicy.kt index 1425c332..5738841b 100644 --- a/Partner-Core/src/main/java/work/slhaf/partner/core/action/runner/policy/ExecutionPolicy.kt +++ b/Partner-Core/src/main/java/work/slhaf/partner/core/action/runner/policy/ExecutionPolicy.kt @@ -112,4 +112,8 @@ abstract class PolicyProvider( interface RunnerExecutionPolicyListener { fun onPolicyChanged(policy: ExecutionPolicy) + + fun registerPolicyListener() { + ExecutionPolicyRegistry.addListener(this) + } }