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

fix(LocalRunnerClient): support creating and registering new action in

Browse Source 
method buildCreate in DynamicActionMcp
This commit is contained in:
slhafzjw
2026-01-01 00:32:34 +08:00
parent f35a467ebc
commit 74f2c6c950
1 changed files with 56 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -309,7 +309,6 @@ public class LocalRunnerClient extends RunnerClient {
private final Map<WatchEvent.Kind<?>, EventHandler> handlers = new HashMap<>(); private final Map<WatchEvent.Kind<?>, EventHandler> handlers = new HashMap<>();
private InitLoader initLoader; private InitLoader initLoader;
private final WatchContext ctx; private final WatchContext ctx;
List<WatchEvent.Kind<?>> kinds = new ArrayList<>();
private boolean watchAll = false; private boolean watchAll = false;
private BuildRegistry(WatchContext ctx) { private BuildRegistry(WatchContext ctx) {
@@ -318,28 +317,28 @@ public class LocalRunnerClient extends RunnerClient {
@Override @Override
public LocalWatchServiceBuild registerCreate(EventHandler handler) { public LocalWatchServiceBuild registerCreate(EventHandler handler) {
kinds.add(StandardWatchEventKinds.ENTRY_CREATE); ctx.kinds.add(StandardWatchEventKinds.ENTRY_CREATE);
handlers.put(StandardWatchEventKinds.ENTRY_CREATE, handler); handlers.put(StandardWatchEventKinds.ENTRY_CREATE, handler);
return this; return this;
} }
@Override @Override
public LocalWatchServiceBuild registerModify(EventHandler handler) { public LocalWatchServiceBuild registerModify(EventHandler handler) {
kinds.add(StandardWatchEventKinds.ENTRY_MODIFY); ctx.kinds.add(StandardWatchEventKinds.ENTRY_MODIFY);
handlers.put(StandardWatchEventKinds.ENTRY_MODIFY, handler); handlers.put(StandardWatchEventKinds.ENTRY_MODIFY, handler);
return this; return this;
} }
@Override @Override
public LocalWatchServiceBuild registerDelete(EventHandler handler) { public LocalWatchServiceBuild registerDelete(EventHandler handler) {
kinds.add(StandardWatchEventKinds.ENTRY_DELETE); ctx.kinds.add(StandardWatchEventKinds.ENTRY_DELETE);
handlers.put(StandardWatchEventKinds.ENTRY_DELETE, handler); handlers.put(StandardWatchEventKinds.ENTRY_DELETE, handler);
return this; return this;
} }
@Override @Override
public LocalWatchServiceBuild registerOverflow(EventHandler handler) { public LocalWatchServiceBuild registerOverflow(EventHandler handler) {
kinds.add(StandardWatchEventKinds.OVERFLOW); ctx.kinds.add(StandardWatchEventKinds.OVERFLOW);
handlers.put(StandardWatchEventKinds.OVERFLOW, handler); handlers.put(StandardWatchEventKinds.OVERFLOW, handler);
return this; return this;
} }
@@ -365,31 +364,31 @@ public class LocalRunnerClient extends RunnerClient {
} }
private void registerPath() { private void registerPath() {
Path path = ctx.path; Path root = ctx.root;
WatchService watchService = ctx.watchService; WatchService watchService = ctx.watchService;
Map<WatchKey, Path> watchKeys = ctx.watchKeys; Map<WatchKey, Path> watchKeys = ctx.watchKeys;
try { try {
WatchEvent.Kind<?>[] kindsArray = kinds.toArray(WatchEvent.Kind[]::new); WatchEvent.Kind<?>[] kindsArray = ctx.kinds.toArray(WatchEvent.Kind[]::new);
WatchKey root = path.register(watchService, kindsArray); WatchKey rootKey = root.register(watchService, kindsArray);
watchKeys.put(root, path); watchKeys.put(rootKey, root);
if (!watchAll) { if (!watchAll) {
return; return;
} }
Stream<Path> walk = Files.walk(path).filter(Files::isDirectory); Stream<Path> walk = Files.walk(root).filter(Files::isDirectory);
for (Path dir : walk.toList()) { for (Path dir : walk.toList()) {
WatchKey key = dir.register(watchService, kindsArray); WatchKey key = dir.register(watchService, kindsArray);
watchKeys.put(key, dir); watchKeys.put(key, dir);
} }
walk.close(); walk.close();
} catch (IOException e) { } catch (IOException e) {
log.error("监听目录注册失败: "); log.error("监听目录注册失败: ", e);
} }
} }
private Runnable buildWatchTask() { private Runnable buildWatchTask() {
return () -> { return () -> {
String pathStr = ctx.path.toString(); String rootStr = ctx.root.toString();
log.info("行动程序目录监听器已启动，监听目录: {}", pathStr); log.info("行动程序目录监听器已启动，监听目录: {}", rootStr);
while (true) { while (true) {
WatchKey key; WatchKey key;
try { try {
@@ -398,13 +397,13 @@ public class LocalRunnerClient extends RunnerClient {
for (WatchEvent<?> e : events) { for (WatchEvent<?> e : events) {
WatchEvent.Kind<?> kind = e.kind(); WatchEvent.Kind<?> kind = e.kind();
Object context = e.context(); Object context = e.context();
log.info("行动程序目录变更事件: {} - {} - {}", pathStr, kind.name(), context); log.info("行动程序目录变更事件: {} - {} - {}", rootStr, kind.name(), context);
Path thisDir = (Path) key.watchable(); Path thisDir = (Path) key.watchable();
EventHandler handler = handlers.get(kind); EventHandler handler = handlers.get(kind);
if (handler == null) { if (handler == null) {
continue; continue;
} }
handler.handle(thisDir, context instanceof Path ? (Path) context : null); handler.handle(thisDir, context instanceof Path ? thisDir.resolve((Path) context) : null);
} }
} catch (InterruptedException e) { } catch (InterruptedException e) {
log.info("监听线程被中断，准备退出..."); log.info("监听线程被中断，准备退出...");
@@ -421,9 +420,10 @@ public class LocalRunnerClient extends RunnerClient {
} }
} }
private record WatchContext(Path path, WatchService watchService, Map<WatchKey, Path> watchKeys) { private record WatchContext(Path root, WatchService watchService, Map<WatchKey, Path> watchKeys,
private WatchContext(Path path, WatchService watchService) { List<WatchEvent.Kind<?>> kinds) {
this(path, watchService, new HashMap<>()); private WatchContext(Path root, WatchService watchService) {
this(root, watchService, new HashMap<>(), new ArrayList<>());
} }
} }
@@ -534,14 +534,14 @@ public class LocalRunnerClient extends RunnerClient {
} }
private void load() { private void load() {
Path path = ctx.path; Path root = ctx.root;
File file = path.toFile(); File file = root.toFile();
if (file.isFile()) { if (file.isFile()) {
throw new ActionInitFailedException("未找到目录: " + path); throw new ActionInitFailedException("未找到目录: " + root);
} }
File[] files = file.listFiles(); File[] files = file.listFiles();
if (files == null) { if (files == null) {
throw new ActionInitFailedException("未正常读取目录: " + path); throw new ActionInitFailedException("未正常读取目录: " + root);
} }
for (File dir : files) { for (File dir : files) {
if (!normalPath(dir.toPath())) { if (!normalPath(dir.toPath())) {
@@ -589,6 +589,11 @@ public class LocalRunnerClient extends RunnerClient {
return; return;
} }
// 对应本地程序或者描述文件的修改行为 // 对应本地程序或者描述文件的修改行为
modify(thisDir, context);
};
}
private void modify(Path thisDir, Path context) {
String fileName = context.getFileName().toString(); String fileName = context.getFileName().toString();
if (fileName.equals("desc.json")) { if (fileName.equals("desc.json")) {
handleMetaModify(thisDir, context); handleMetaModify(thisDir, context);
@@ -596,7 +601,6 @@ public class LocalRunnerClient extends RunnerClient {
if (fileName.startsWith("run.")) { if (fileName.startsWith("run.")) {
handleProgramModify(thisDir, context); handleProgramModify(thisDir, context);
} }
};
} }
private void handleProgramModify(Path thisDir, Path context) { private void handleProgramModify(Path thisDir, Path context) {
@@ -619,7 +623,7 @@ public class LocalRunnerClient extends RunnerClient {
private void handleMetaModify(Path thisDir, Path context) { private void handleMetaModify(Path thisDir, Path context) {
// 检查是否除了描述文件外还存在别的可执行文件 // 检查是否除了描述文件外还存在别的可执行文件
File meta = Path.of(thisDir.toString(), context.toString()).toFile(); File meta = context.toFile();
String name = thisDir.getFileName().toString(); String name = thisDir.getFileName().toString();
try { try {
MetaActionInfo info = JSONUtil.readJSONObject(meta, StandardCharsets.UTF_8).toBean(MetaActionInfo.class); MetaActionInfo info = JSONUtil.readJSONObject(meta, StandardCharsets.UTF_8).toBean(MetaActionInfo.class);
@@ -639,7 +643,28 @@ public class LocalRunnerClient extends RunnerClient {
@Override @Override
@NotNull @NotNull
protected LocalWatchServiceBuild.EventHandler buildCreate() { protected LocalWatchServiceBuild.EventHandler buildCreate() {
return buildModify(); return (thisDir, context) -> {
if (thisDir.equals(ctx.root) && Files.isDirectory(context)) {
try {
context.register(ctx.watchService, ctx.kinds.toArray(WatchEvent.Kind[]::new));
} catch (IOException e) {
log.error("监听目录注册失败: {}", context);
}
}
if (normalPath(thisDir)) {
modify(thisDir, context);
}
if (Files.isDirectory(context) && normalPath(context)) {
File[] files = context.toFile().listFiles();
if (files == null) {
log.warn("目录无法访问: {}", context);
return;
}
for (File f : files) {
modify(context, f.toPath());
}
}
};
} }
@Override @Override