diff --git a/Partner-Core/src/main/java/work/slhaf/partner/core/action/entity/Action.kt b/Partner-Core/src/main/java/work/slhaf/partner/core/action/entity/Action.kt index 6d7cb9b1..cee6002f 100644 --- a/Partner-Core/src/main/java/work/slhaf/partner/core/action/entity/Action.kt +++ b/Partner-Core/src/main/java/work/slhaf/partner/core/action/entity/Action.kt @@ -1,6 +1,6 @@ package work.slhaf.partner.core.action.entity -import work.slhaf.partner.module.modules.action.dispatcher.executor.entity.HistoryAction +import work.slhaf.partner.module.modules.action.executor.entity.HistoryAction import java.time.ZonedDateTime import java.util.* diff --git a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/ActionDispatcher.java b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/ActionDispatcher.java deleted file mode 100644 index a40d7261..00000000 --- a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/ActionDispatcher.java +++ /dev/null @@ -1,69 +0,0 @@ -package work.slhaf.partner.module.modules.action.dispatcher; - -import lombok.val; -import work.slhaf.partner.api.agent.factory.capability.annotation.InjectCapability; -import work.slhaf.partner.api.agent.factory.component.annotation.Init; -import work.slhaf.partner.api.agent.factory.component.annotation.InjectModule; -import work.slhaf.partner.core.action.ActionCapability; -import work.slhaf.partner.core.action.ActionCore; -import work.slhaf.partner.core.action.entity.ExecutableAction; -import work.slhaf.partner.core.action.entity.ImmediateExecutableAction; -import work.slhaf.partner.core.action.entity.SchedulableExecutableAction; -import work.slhaf.partner.module.common.module.PostRunningAbstractAgentModuleAbstract; -import work.slhaf.partner.module.modules.action.dispatcher.executor.ActionExecutor; -import work.slhaf.partner.module.modules.action.dispatcher.executor.entity.ActionExecutorInput; -import work.slhaf.partner.module.modules.action.dispatcher.scheduler.ActionScheduler; -import work.slhaf.partner.runtime.interaction.data.context.PartnerRunningFlowContext; - -import java.util.HashSet; -import java.util.Set; -import java.util.concurrent.ExecutorService; - -public class ActionDispatcher extends PostRunningAbstractAgentModuleAbstract { - @InjectCapability - private ActionCapability actionCapability; - @InjectModule - private ActionExecutor actionExecutor; - @InjectModule - private ActionScheduler actionScheduler; - private ExecutorService executor; - - @Init - public void init() { - executor = actionCapability.getExecutor(ActionCore.ExecutorType.VIRTUAL); - } - - @Override - public void doExecute(PartnerRunningFlowContext context) { - // 只需要处理prepared action,因为pending action在用户确认后也将变为prepared action - // 将PLANNING action放入时间轮中,IMMEDIATE action直接进入并发执行流 - // 对于将触发的PLANNING - // action,理想做法是将执行工具做成执行链的形式,模型的自对话流程、是否通知用户都做成与普通工具同等的通用可选能力,避免绑定固定流程 - executor.execute(() -> { - String userId = context.getSource(); - val preparedActions = actionCapability.listActions(ExecutableAction.Status.PREPARE, userId); - // 分类成PLANNING和IMMEDIATE两类 - Set scheduledActions = new HashSet<>(); - Set immediateActions = new HashSet<>(); - for (ExecutableAction preparedAction : preparedActions) { - if (preparedAction instanceof SchedulableExecutableAction actionInfo) { - scheduledActions.add(actionInfo); - } else if (preparedAction instanceof ImmediateExecutableAction actionInfo) { - immediateActions.add(actionInfo); - } - } - actionExecutor.execute(new ActionExecutorInput(immediateActions)); - actionScheduler.schedule(scheduledActions); - }); - } - - @Override - protected boolean relyOnMessage() { - return false; - } - - @Override - public int order() { - return 7; - } -} diff --git a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionCorrector.java b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/ActionCorrector.java similarity index 86% rename from Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionCorrector.java rename to Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/ActionCorrector.java index 6efb87b2..4d0b591c 100644 --- a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionCorrector.java +++ b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/ActionCorrector.java @@ -1,11 +1,11 @@ -package work.slhaf.partner.module.modules.action.dispatcher.executor; +package work.slhaf.partner.module.modules.action.executor; import com.alibaba.fastjson2.JSONObject; import lombok.val; import work.slhaf.partner.api.agent.factory.component.abstracts.AbstractAgentModule; import work.slhaf.partner.api.agent.factory.component.abstracts.ActivateModel; -import work.slhaf.partner.module.modules.action.dispatcher.executor.entity.CorrectorInput; -import work.slhaf.partner.module.modules.action.dispatcher.executor.entity.CorrectorResult; +import work.slhaf.partner.module.modules.action.executor.entity.CorrectorInput; +import work.slhaf.partner.module.modules.action.executor.entity.CorrectorResult; /** * 负责在单组行动执行后,根据行动意图与结果检查后续行动是否符合目的,必要时直接调整行动链,或发起自对话请求进行干预 diff --git a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutor.java b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/ActionExecutor.java similarity index 98% rename from Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutor.java rename to Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/ActionExecutor.java index 1bf80b4a..3e55d6c5 100644 --- a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutor.java +++ b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/ActionExecutor.java @@ -1,4 +1,4 @@ -package work.slhaf.partner.module.modules.action.dispatcher.executor; +package work.slhaf.partner.module.modules.action.executor; import lombok.val; import work.slhaf.partner.api.agent.factory.capability.annotation.InjectCapability; @@ -12,8 +12,8 @@ import work.slhaf.partner.core.action.entity.ExecutableAction.Status; import work.slhaf.partner.core.action.runner.RunnerClient; import work.slhaf.partner.core.cognation.CognationCapability; import work.slhaf.partner.core.memory.MemoryCapability; -import work.slhaf.partner.module.modules.action.dispatcher.executor.entity.*; -import work.slhaf.partner.module.modules.action.dispatcher.scheduler.ActionScheduler; +import work.slhaf.partner.module.modules.action.executor.entity.*; +import work.slhaf.partner.module.modules.action.scheduler.ActionScheduler; import java.util.ArrayList; import java.util.List; diff --git a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionRepairer.java b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/ActionRepairer.java similarity index 94% rename from Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionRepairer.java rename to Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/ActionRepairer.java index 581014ed..12625e7c 100644 --- a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionRepairer.java +++ b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/ActionRepairer.java @@ -1,4 +1,4 @@ -package work.slhaf.partner.module.modules.action.dispatcher.executor; +package work.slhaf.partner.module.modules.action.executor; import com.alibaba.fastjson2.JSONArray; import com.alibaba.fastjson2.JSONObject; @@ -16,11 +16,11 @@ import work.slhaf.partner.core.action.entity.MetaAction; import work.slhaf.partner.core.action.entity.MetaAction.Result; import work.slhaf.partner.core.action.runner.RunnerClient; import work.slhaf.partner.core.cognation.CognationCapability; -import work.slhaf.partner.module.modules.action.dispatcher.executor.entity.GeneratorInput; -import work.slhaf.partner.module.modules.action.dispatcher.executor.entity.GeneratorResult; -import work.slhaf.partner.module.modules.action.dispatcher.executor.entity.RepairerInput; -import work.slhaf.partner.module.modules.action.dispatcher.executor.entity.RepairerResult; -import work.slhaf.partner.module.modules.action.dispatcher.executor.entity.RepairerResult.RepairerStatus; +import work.slhaf.partner.module.modules.action.executor.entity.GeneratorInput; +import work.slhaf.partner.module.modules.action.executor.entity.GeneratorResult; +import work.slhaf.partner.module.modules.action.executor.entity.RepairerInput; +import work.slhaf.partner.module.modules.action.executor.entity.RepairerResult; +import work.slhaf.partner.module.modules.action.executor.entity.RepairerResult.RepairerStatus; import java.util.List; import java.util.concurrent.CountDownLatch; diff --git a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/DynamicActionGenerator.java b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/DynamicActionGenerator.java similarity index 93% rename from Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/DynamicActionGenerator.java rename to Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/DynamicActionGenerator.java index fe3befd8..d4931f11 100644 --- a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/DynamicActionGenerator.java +++ b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/DynamicActionGenerator.java @@ -1,4 +1,4 @@ -package work.slhaf.partner.module.modules.action.dispatcher.executor; +package work.slhaf.partner.module.modules.action.executor; import com.alibaba.fastjson2.JSONObject; import lombok.val; @@ -12,8 +12,8 @@ import work.slhaf.partner.core.action.ActionCapability; import work.slhaf.partner.core.action.entity.GeneratedData; import work.slhaf.partner.core.action.entity.MetaAction; import work.slhaf.partner.core.action.runner.RunnerClient; -import work.slhaf.partner.module.modules.action.dispatcher.executor.entity.GeneratorInput; -import work.slhaf.partner.module.modules.action.dispatcher.executor.entity.GeneratorResult; +import work.slhaf.partner.module.modules.action.executor.entity.GeneratorInput; +import work.slhaf.partner.module.modules.action.executor.entity.GeneratorResult; /** * 负责依据输入内容生成可执行的动态行动单元,并选择是否持久化至 SandboxRunner 容器内 diff --git a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ParamsExtractor.java b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/ParamsExtractor.java similarity index 87% rename from Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ParamsExtractor.java rename to Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/ParamsExtractor.java index c584933c..aa928626 100644 --- a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ParamsExtractor.java +++ b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/ParamsExtractor.java @@ -1,4 +1,4 @@ -package work.slhaf.partner.module.modules.action.dispatcher.executor; +package work.slhaf.partner.module.modules.action.executor; import com.alibaba.fastjson2.JSONArray; import com.alibaba.fastjson2.JSONObject; @@ -6,9 +6,9 @@ import work.slhaf.partner.api.agent.factory.component.abstracts.AbstractAgentMod import work.slhaf.partner.api.agent.factory.component.abstracts.ActivateModel; import work.slhaf.partner.api.chat.pojo.ChatResponse; import work.slhaf.partner.core.action.entity.MetaActionInfo; -import work.slhaf.partner.module.modules.action.dispatcher.executor.entity.ExtractorInput; -import work.slhaf.partner.module.modules.action.dispatcher.executor.entity.ExtractorResult; -import work.slhaf.partner.module.modules.action.dispatcher.executor.entity.HistoryAction; +import work.slhaf.partner.module.modules.action.executor.entity.ExtractorInput; +import work.slhaf.partner.module.modules.action.executor.entity.ExtractorResult; +import work.slhaf.partner.module.modules.action.executor.entity.HistoryAction; import java.util.HashMap; import java.util.List; diff --git a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/ActionExecutorInput.kt b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/ActionExecutorInput.kt similarity index 63% rename from Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/ActionExecutorInput.kt rename to Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/ActionExecutorInput.kt index 01fe25fa..273addd8 100644 --- a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/ActionExecutorInput.kt +++ b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/ActionExecutorInput.kt @@ -1,4 +1,4 @@ -package work.slhaf.partner.module.modules.action.dispatcher.executor.entity +package work.slhaf.partner.module.modules.action.executor.entity import work.slhaf.partner.core.action.entity.ExecutableAction diff --git a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/CorrectorInput.java b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/CorrectorInput.java similarity index 88% rename from Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/CorrectorInput.java rename to Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/CorrectorInput.java index 80e1fdb2..db3d22a5 100644 --- a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/CorrectorInput.java +++ b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/CorrectorInput.java @@ -1,4 +1,4 @@ -package work.slhaf.partner.module.modules.action.dispatcher.executor.entity; +package work.slhaf.partner.module.modules.action.executor.entity; import lombok.Builder; import lombok.Data; diff --git a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/CorrectorResult.java b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/CorrectorResult.java similarity index 74% rename from Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/CorrectorResult.java rename to Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/CorrectorResult.java index a2c267e2..b5d86e00 100644 --- a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/CorrectorResult.java +++ b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/CorrectorResult.java @@ -1,4 +1,4 @@ -package work.slhaf.partner.module.modules.action.dispatcher.executor.entity; +package work.slhaf.partner.module.modules.action.executor.entity; import lombok.Data; import work.slhaf.partner.module.modules.action.interventor.entity.MetaIntervention; diff --git a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/ExtractorInput.java b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/ExtractorInput.java similarity index 90% rename from Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/ExtractorInput.java rename to Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/ExtractorInput.java index 4a99b457..8189022c 100644 --- a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/ExtractorInput.java +++ b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/ExtractorInput.java @@ -1,4 +1,4 @@ -package work.slhaf.partner.module.modules.action.dispatcher.executor.entity; +package work.slhaf.partner.module.modules.action.executor.entity; import lombok.Data; import work.slhaf.partner.api.chat.pojo.Message; diff --git a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/ExtractorResult.java b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/ExtractorResult.java similarity index 65% rename from Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/ExtractorResult.java rename to Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/ExtractorResult.java index aefb5ba1..14e90d41 100644 --- a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/ExtractorResult.java +++ b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/ExtractorResult.java @@ -1,4 +1,4 @@ -package work.slhaf.partner.module.modules.action.dispatcher.executor.entity; +package work.slhaf.partner.module.modules.action.executor.entity; import lombok.Data; diff --git a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/GeneratorInput.java b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/GeneratorInput.java similarity index 75% rename from Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/GeneratorInput.java rename to Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/GeneratorInput.java index 67c9094a..860f288f 100644 --- a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/GeneratorInput.java +++ b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/GeneratorInput.java @@ -1,4 +1,4 @@ -package work.slhaf.partner.module.modules.action.dispatcher.executor.entity; +package work.slhaf.partner.module.modules.action.executor.entity; import lombok.Data; diff --git a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/GeneratorResult.java b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/GeneratorResult.java similarity index 66% rename from Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/GeneratorResult.java rename to Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/GeneratorResult.java index 0b8572fb..8996a4c8 100644 --- a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/GeneratorResult.java +++ b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/GeneratorResult.java @@ -1,4 +1,4 @@ -package work.slhaf.partner.module.modules.action.dispatcher.executor.entity; +package work.slhaf.partner.module.modules.action.executor.entity; import lombok.Data; import work.slhaf.partner.core.action.entity.MetaAction; diff --git a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/HistoryAction.java b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/HistoryAction.java similarity index 52% rename from Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/HistoryAction.java rename to Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/HistoryAction.java index cf36f1ed..dbc120b4 100644 --- a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/HistoryAction.java +++ b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/HistoryAction.java @@ -1,4 +1,4 @@ -package work.slhaf.partner.module.modules.action.dispatcher.executor.entity; +package work.slhaf.partner.module.modules.action.executor.entity; public record HistoryAction(String actionKey, String description, String result) { } diff --git a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/RepairerInput.java b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/RepairerInput.java similarity index 82% rename from Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/RepairerInput.java rename to Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/RepairerInput.java index dd470a13..8583949a 100644 --- a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/RepairerInput.java +++ b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/RepairerInput.java @@ -1,4 +1,4 @@ -package work.slhaf.partner.module.modules.action.dispatcher.executor.entity; +package work.slhaf.partner.module.modules.action.executor.entity; import lombok.Data; import work.slhaf.partner.api.chat.pojo.Message; diff --git a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/RepairerResult.java b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/RepairerResult.java similarity index 91% rename from Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/RepairerResult.java rename to Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/RepairerResult.java index c6e2c999..d3f757db 100644 --- a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/RepairerResult.java +++ b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/entity/RepairerResult.java @@ -1,4 +1,4 @@ -package work.slhaf.partner.module.modules.action.dispatcher.executor.entity; +package work.slhaf.partner.module.modules.action.executor.entity; import lombok.Data; diff --git a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/exception/ActionExecutingFailedException.java b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/exception/ActionExecutingFailedException.java similarity index 81% rename from Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/exception/ActionExecutingFailedException.java rename to Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/exception/ActionExecutingFailedException.java index f10273d1..62365a94 100644 --- a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/exception/ActionExecutingFailedException.java +++ b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/executor/exception/ActionExecutingFailedException.java @@ -1,4 +1,4 @@ -package work.slhaf.partner.module.modules.action.dispatcher.executor.exception; +package work.slhaf.partner.module.modules.action.executor.exception; import work.slhaf.partner.api.agent.runtime.exception.AgentRuntimeException; diff --git a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/planner/ActionPlanner.java b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/planner/ActionPlanner.java index 3f267a5e..96245e0d 100644 --- a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/planner/ActionPlanner.java +++ b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/planner/ActionPlanner.java @@ -16,9 +16,8 @@ import work.slhaf.partner.core.cognation.CognationCapability; import work.slhaf.partner.core.memory.MemoryCapability; import work.slhaf.partner.core.perceive.PerceiveCapability; import work.slhaf.partner.module.common.module.PreRunningAbstractAgentModuleAbstract; -import work.slhaf.partner.module.modules.action.dispatcher.executor.ActionExecutor; -import work.slhaf.partner.module.modules.action.dispatcher.executor.entity.ActionExecutorInput; -import work.slhaf.partner.module.modules.action.dispatcher.scheduler.ActionScheduler; +import work.slhaf.partner.module.modules.action.executor.ActionExecutor; +import work.slhaf.partner.module.modules.action.executor.entity.ActionExecutorInput; import work.slhaf.partner.module.modules.action.planner.confirmer.ActionConfirmer; import work.slhaf.partner.module.modules.action.planner.confirmer.entity.ConfirmerInput; import work.slhaf.partner.module.modules.action.planner.confirmer.entity.ConfirmerResult; @@ -28,6 +27,7 @@ import work.slhaf.partner.module.modules.action.planner.evaluator.entity.Evaluat import work.slhaf.partner.module.modules.action.planner.extractor.ActionExtractor; import work.slhaf.partner.module.modules.action.planner.extractor.entity.ExtractorInput; import work.slhaf.partner.module.modules.action.planner.extractor.entity.ExtractorResult; +import work.slhaf.partner.module.modules.action.scheduler.ActionScheduler; import work.slhaf.partner.runtime.interaction.data.context.PartnerRunningFlowContext; import java.util.*; diff --git a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/scheduler/ActionScheduler.kt b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/scheduler/ActionScheduler.kt similarity index 98% rename from Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/scheduler/ActionScheduler.kt rename to Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/scheduler/ActionScheduler.kt index 55678203..6be46681 100644 --- a/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/scheduler/ActionScheduler.kt +++ b/Partner-Core/src/main/java/work/slhaf/partner/module/modules/action/scheduler/ActionScheduler.kt @@ -1,4 +1,4 @@ -package work.slhaf.partner.module.modules.action.dispatcher.scheduler +package work.slhaf.partner.module.modules.action.scheduler import com.cronutils.model.CronType import com.cronutils.model.definition.CronDefinition @@ -20,8 +20,8 @@ import work.slhaf.partner.core.action.ActionCore import work.slhaf.partner.core.action.entity.Schedulable import work.slhaf.partner.core.action.entity.SchedulableExecutableAction import work.slhaf.partner.core.action.entity.StateAction -import work.slhaf.partner.module.modules.action.dispatcher.executor.ActionExecutor -import work.slhaf.partner.module.modules.action.dispatcher.executor.entity.ActionExecutorInput +import work.slhaf.partner.module.modules.action.executor.ActionExecutor +import work.slhaf.partner.module.modules.action.executor.entity.ActionExecutorInput import java.io.Closeable import java.time.Duration import java.time.ZonedDateTime diff --git a/Partner-Core/src/test/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutorTest.java b/Partner-Core/src/test/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutorTest.java index f660f376..89cd45b9 100644 --- a/Partner-Core/src/test/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutorTest.java +++ b/Partner-Core/src/test/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutorTest.java @@ -13,10 +13,14 @@ import work.slhaf.partner.core.action.entity.*; import work.slhaf.partner.core.action.runner.RunnerClient; import work.slhaf.partner.core.cognation.CognationCapability; import work.slhaf.partner.core.memory.MemoryCapability; -import work.slhaf.partner.module.modules.action.dispatcher.executor.entity.ActionExecutorInput; -import work.slhaf.partner.module.modules.action.dispatcher.executor.entity.CorrectorResult; -import work.slhaf.partner.module.modules.action.dispatcher.executor.entity.ExtractorResult; -import work.slhaf.partner.module.modules.action.dispatcher.executor.entity.RepairerResult; +import work.slhaf.partner.module.modules.action.executor.ActionCorrector; +import work.slhaf.partner.module.modules.action.executor.ActionExecutor; +import work.slhaf.partner.module.modules.action.executor.ActionRepairer; +import work.slhaf.partner.module.modules.action.executor.ParamsExtractor; +import work.slhaf.partner.module.modules.action.executor.entity.ActionExecutorInput; +import work.slhaf.partner.module.modules.action.executor.entity.CorrectorResult; +import work.slhaf.partner.module.modules.action.executor.entity.ExtractorResult; +import work.slhaf.partner.module.modules.action.executor.entity.RepairerResult; import java.util.*; import java.util.concurrent.*; diff --git a/Partner-Core/src/test/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionSchedulerTest.kt b/Partner-Core/src/test/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionSchedulerTest.kt index f631bd0f..368c6055 100644 --- a/Partner-Core/src/test/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionSchedulerTest.kt +++ b/Partner-Core/src/test/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionSchedulerTest.kt @@ -17,8 +17,9 @@ import work.slhaf.partner.core.action.ActionCapability import work.slhaf.partner.core.action.entity.ExecutableAction import work.slhaf.partner.core.action.entity.Schedulable import work.slhaf.partner.core.action.entity.SchedulableExecutableAction -import work.slhaf.partner.module.modules.action.dispatcher.executor.entity.ActionExecutorInput -import work.slhaf.partner.module.modules.action.dispatcher.scheduler.ActionScheduler +import work.slhaf.partner.module.modules.action.executor.ActionExecutor +import work.slhaf.partner.module.modules.action.executor.entity.ActionExecutorInput +import work.slhaf.partner.module.modules.action.scheduler.ActionScheduler import java.time.ZonedDateTime import java.time.temporal.ChronoUnit