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

refactor(gateway): remove unused abstract methods

Browse Source
This commit is contained in:
slhafzjw
2026-05-01 22:09:16 +08:00
parent 843549dadf
commit 018b524be3
5 changed files with 2 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
Partner-Core/src/main/java/work/slhaf/partner/runtime/PartnerAgentBootstrap.java
View File

@@ -12,7 +12,7 @@ public final class PartnerAgentBootstrap extends Agent.AgentBootstrap {
@Override @Override
protected void bootstrap() { protected void bootstrap() {
addGatewayRegistration(WebSocketGatewayRegistration.INSTANCE); addGatewayRegistration(new WebSocketGatewayRegistration());
addConfigurable(new VectorClientRegistry()); addConfigurable(new VectorClientRegistry());
} }
} }

7
Partner-Core/src/main/java/work/slhaf/partner/runtime/gateway/WebSocketGateway.java
View File

@@ -10,7 +10,6 @@ import org.java_websocket.handshake.ClientHandshake;
import org.java_websocket.server.WebSocketServer; import org.java_websocket.server.WebSocketServer;
import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.NotNull;
import work.slhaf.partner.framework.agent.interaction.AgentGateway; import work.slhaf.partner.framework.agent.interaction.AgentGateway;
import work.slhaf.partner.framework.agent.interaction.AgentGatewayRegistration;
import work.slhaf.partner.framework.agent.interaction.data.InputData; import work.slhaf.partner.framework.agent.interaction.data.InputData;
import work.slhaf.partner.framework.agent.interaction.data.InteractionEvent; import work.slhaf.partner.framework.agent.interaction.data.InteractionEvent;
import work.slhaf.partner.runtime.PartnerRunningFlowContext; import work.slhaf.partner.runtime.PartnerRunningFlowContext;
@@ -49,7 +48,6 @@ public class WebSocketGateway extends WebSocketServer implements AgentGateway<In
} }
this.start(); this.start();
startHeartbeatThread(); startHeartbeatThread();
log.info("WebSocketGateway started");
} }
@Override @Override
@@ -140,11 +138,6 @@ public class WebSocketGateway extends WebSocketServer implements AgentGateway<In
log.info("WebSocketServer 已启动..."); log.info("WebSocketServer 已启动...");
} }
@Override
public AgentGatewayRegistration registration() {
return WebSocketGatewayRegistration.INSTANCE;
}
@Override @Override
@NotNull @NotNull
public String getChannelName() { public String getChannelName() {

2
Partner-Core/src/main/java/work/slhaf/partner/runtime/gateway/WebSocketGatewayRegistration.kt
View File

@@ -3,7 +3,7 @@ package work.slhaf.partner.runtime.gateway
import work.slhaf.partner.framework.agent.interaction.AgentGateway import work.slhaf.partner.framework.agent.interaction.AgentGateway
import work.slhaf.partner.framework.agent.interaction.AgentGatewayRegistration import work.slhaf.partner.framework.agent.interaction.AgentGatewayRegistration
object WebSocketGatewayRegistration : AgentGatewayRegistration { class WebSocketGatewayRegistration : AgentGatewayRegistration {
override val channelName: String = "websocket_channel" override val channelName: String = "websocket_channel"

7
Partner-Framework/src/main/java/work/slhaf/partner/framework/agent/interaction/AgentGateway.java
View File

@@ -7,13 +7,6 @@ public interface AgentGateway<I extends InputData, C extends RunningFlowContext>
void launch(); void launch();
AgentGatewayRegistration registration();
@Override
default void register() {
registration().register();
}
default void receive(I inputData) { default void receive(I inputData) {
C parsedContext = parseRunningFlowContext(inputData); C parsedContext = parseRunningFlowContext(inputData);
AgentRuntime.INSTANCE.submit(parsedContext); AgentRuntime.INSTANCE.submit(parsedContext);

7
Partner-Framework/src/main/java/work/slhaf/partner/framework/agent/interaction/ResponseChannel.kt
View File

@@ -10,9 +10,6 @@ interface ResponseChannel {
fun response(event: InteractionEvent) fun response(event: InteractionEvent)
fun register() {
AgentRuntime.registerResponseChannel(channelName, this)
}
} }
object LogChannel : ResponseChannel { object LogChannel : ResponseChannel {
@@ -22,10 +19,6 @@ object LogChannel : ResponseChannel {
override val channelName: String override val channelName: String
get() = "log_channel" get() = "log_channel"
init {
register()
}
override fun response(event: InteractionEvent) { override fun response(event: InteractionEvent) {
log.info(JSONObject.toJSONString(event)) log.info(JSONObject.toJSONString(event))
} }