From d462f029607798c22a4f7dcd9029ac0594328ac9 Mon Sep 17 00:00:00 2001
From: slhafzjw <slhafzjw@slhaf.work>
Date: Tue, 3 Mar 2026 11:48:08 +0800
Subject: [PATCH] refactor(framework): mv interaction in-out flow into
 AgentInteractionAdapter

---
 .../api/agent/runtime/interaction/AgentGateway.java       | 4 +---
 .../agent/runtime/interaction/AgentInteractionAdapter.kt  | 8 +++++++-
 2 files changed, 8 insertions(+), 4 deletions(-)

diff --git a/Partner-Framework/src/main/java/work/slhaf/partner/api/agent/runtime/interaction/AgentGateway.java b/Partner-Framework/src/main/java/work/slhaf/partner/api/agent/runtime/interaction/AgentGateway.java
index cfdbf660..5c38c219 100644
--- a/Partner-Framework/src/main/java/work/slhaf/partner/api/agent/runtime/interaction/AgentGateway.java
+++ b/Partner-Framework/src/main/java/work/slhaf/partner/api/agent/runtime/interaction/AgentGateway.java
@@ -9,9 +9,7 @@ public interface AgentGateway<I extends AgentInputData, O extends AgentOutputDat
     void launch();
 
     default void receive(I inputData) {
-        C finalInputData = adapter().parseInputData(inputData);
-        C outputContext = adapter().call(finalInputData);
-        O outputData = adapter().parseOutputData(outputContext);
+        O outputData = adapter().submit(inputData);
         send(outputData);
     }
 
diff --git a/Partner-Framework/src/main/java/work/slhaf/partner/api/agent/runtime/interaction/AgentInteractionAdapter.kt b/Partner-Framework/src/main/java/work/slhaf/partner/api/agent/runtime/interaction/AgentInteractionAdapter.kt
index 928b7dfe..7da9a486 100644
--- a/Partner-Framework/src/main/java/work/slhaf/partner/api/agent/runtime/interaction/AgentInteractionAdapter.kt
+++ b/Partner-Framework/src/main/java/work/slhaf/partner/api/agent/runtime/interaction/AgentInteractionAdapter.kt
@@ -13,7 +13,13 @@ import work.slhaf.partner.api.agent.runtime.interaction.flow.RunningFlowContext
 
 abstract class AgentInteractionAdapter<I : AgentInputData, O : AgentOutputData, C : RunningFlowContext> {
 
-    fun call(runningFlowContext: C): C = runBlocking {
+    fun submit(inputData: I): O {
+        val finalInputData: C = parseInputData(inputData)
+        val outputContext: C = call(finalInputData)
+        return parseOutputData(outputContext)
+    }
+
+    private fun call(runningFlowContext: C): C = runBlocking {
         val runningModules =
             mutableMapOf<Int, MutableList<ModuleContextData.Running<AbstractAgentModule.Running<RunningFlowContext>>>>()