slhaf/Partner
1
0
Fork 0
mirror of https://github.com/slhaf/Partner.git synced 2026-05-12 08:43:02 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor(framework): correct InteractionAdapter, support loading latest modules while running

Browse Source
This commit is contained in:
slhafzjw
2026-03-03 11:26:36 +08:00
parent cf25fce09e
commit 5ae8b713d7
1 changed files with 10 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
Partner-Framework/src/main/java/work/slhaf/partner/api/agent/runtime/interaction/AgentInteractionAdapter.kt
View File

@@ -13,17 +13,16 @@ import work.slhaf.partner.api.agent.runtime.interaction.flow.RunningFlowContext
abstract class AgentInteractionAdapter<I : AgentInputData, O : AgentOutputData, C : RunningFlowContext> {
private val runningModules =
mutableMapOf<Int, MutableList<ModuleContextData.Running<AbstractAgentModule.Running<RunningFlowContext>>>>()
fun call(runningFlowContext: C): C = runBlocking {
if (runningModules.isEmpty()) {
AgentContext.modules
.filter { ModuleContextData.Running::class.java.isAssignableFrom(it.value.javaClass) }
.map { it.value as ModuleContextData.Running<AbstractAgentModule.Running<RunningFlowContext>> }
.sortedBy { it.order }
.forEach { runningModules.computeIfAbsent(it.order) { mutableListOf() }.add(it) }
}
val runningModules =
mutableMapOf<Int, MutableList<ModuleContextData.Running<AbstractAgentModule.Running<RunningFlowContext>>>>()
AgentContext.modules
.filter { ModuleContextData.Running::class.java.isAssignableFrom(it.value.javaClass) }
.map { it.value as ModuleContextData.Running<AbstractAgentModule.Running<RunningFlowContext>> }
.filter { it.enabled }
.sortedBy { it.order }
.forEach { runningModules.computeIfAbsent(it.order) { mutableListOf() }.add(it) }
try {
for (modules in runningModules.values) {
@@ -34,7 +33,7 @@ abstract class AgentInteractionAdapter<I : AgentInputData, O : AgentOutputData,
runningFlowContext.ok = 0
runningFlowContext.errMsg.add(e.localizedMessage)
}
return@runBlocking runningFlowContext
}