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): introduce LocalWatchServiceHelper and internal implementations

Browse Source 
Context:
This change introduces an internal scaffold to organize WatchEventHandler building logic.
This commit is contained in:
slhafzjw
2025-12-29 17:45:39 +08:00
parent 1bd23b20c4
commit bf99e01b51
1 changed files with 139 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -458,6 +458,145 @@ public class LocalRunnerClient extends RunnerClient {
}
private sealed static abstract class LocalWatchServiceHelper permits LocalWatchServiceHelper.Dynamic, LocalWatchServiceHelper.Desc, LocalWatchServiceHelper.Common {
protected final ConcurrentHashMap<String, MetaActionInfo> existedMetaActions;
private LocalWatchServiceHelper(ConcurrentHashMap<String, MetaActionInfo> existedMetaActions) {
this.existedMetaActions = existedMetaActions;
}
protected abstract @NotNull WatchInitLoader buildLoad();
protected abstract @NotNull WatchEventHandler buildModify();
protected abstract @NotNull WatchEventHandler buildCreate();
protected abstract @NotNull WatchEventHandler buildDelete();
protected abstract @NotNull WatchEventHandler buildOverflow();
private static final class Dynamic extends LocalWatchServiceHelper {
private final McpStatelessAsyncServer dynamicActionMcpServer;
private Dynamic(ConcurrentHashMap<String, MetaActionInfo> existedMetaActions, McpStatelessAsyncServer dynamicActionMcpServer) {
super(existedMetaActions);
this.dynamicActionMcpServer = dynamicActionMcpServer;
}
@Override
@NotNull
protected WatchInitLoader buildLoad() {
return null;
}
@Override
@NotNull
protected WatchEventHandler buildModify() {
return null;
}
@Override
@NotNull
protected WatchEventHandler buildCreate() {
return null;
}
@Override
@NotNull
protected WatchEventHandler buildDelete() {
return null;
}
@Override
@NotNull
protected WatchEventHandler buildOverflow() {
return null;
}
}
private static final class Desc extends LocalWatchServiceHelper {
private final McpStatelessAsyncServer mcpDescServer;
private Desc(ConcurrentHashMap<String, MetaActionInfo> existedMetaActions, McpStatelessAsyncServer mcpDescServer) {
super(existedMetaActions);
this.mcpDescServer = mcpDescServer;
}
@Override
@NotNull
protected WatchInitLoader buildLoad() {
return null;
}
@Override
@NotNull
protected WatchEventHandler buildModify() {
return null;
}
@Override
@NotNull
protected WatchEventHandler buildCreate() {
return null;
}
@Override
@NotNull
protected WatchEventHandler buildDelete() {
return null;
}
@Override
@NotNull
protected WatchEventHandler buildOverflow() {
return null;
}
}
private static final class Common extends LocalWatchServiceHelper {
private final Map<String, McpSyncClient> mcpClients;
private Common(ConcurrentHashMap<String, MetaActionInfo> existedMetaActions, Map<String, McpSyncClient> mcpClients) {
super(existedMetaActions);
this.mcpClients = mcpClients;
}
@Override
@NotNull
protected WatchInitLoader buildLoad() {
return null;
}
@Override
@NotNull
protected WatchEventHandler buildModify() {
return null;
}
@Override
@NotNull
protected WatchEventHandler buildCreate() {
return null;
}
@Override
@NotNull
protected WatchEventHandler buildDelete() {
return null;
}
@Override
@NotNull
protected WatchEventHandler buildOverflow() {
return null;
}
}
}
private sealed abstract static class McpClientTransportParams permits HttpMcpClientTransportParams, StdioMcpClientTransportParams {
private final int timeout;