From 505fe38fa7f4539398c369a2a7ea5e830d675ad6 Mon Sep 17 00:00:00 2001 From: 0007 <0007@qq.com> Date: Wed, 27 Aug 2025 19:58:44 +0800 Subject: [PATCH] Add File --- .../core/chain/impl/SequentialChain.java | 41 +++++++++++++++++++ 1 file changed, 41 insertions(+) create mode 100644 agents-flex-core/src/main/java/com/agentsflex/core/chain/impl/SequentialChain.java diff --git a/agents-flex-core/src/main/java/com/agentsflex/core/chain/impl/SequentialChain.java b/agents-flex-core/src/main/java/com/agentsflex/core/chain/impl/SequentialChain.java new file mode 100644 index 0000000..96669ca --- /dev/null +++ b/agents-flex-core/src/main/java/com/agentsflex/core/chain/impl/SequentialChain.java @@ -0,0 +1,41 @@ +/* + * Copyright (c) 2023-2025, Agents-Flex (fuhai999@gmail.com). + *
+ * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + *
+ * http://www.apache.org/licenses/LICENSE-2.0 + *
+ * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package com.agentsflex.core.chain.impl; + +import com.agentsflex.core.chain.Chain; +import com.agentsflex.core.chain.ChainEdge; +import com.agentsflex.core.chain.ChainNode; + +public class SequentialChain extends Chain { + + @Override + public void addNode(ChainNode chainNode) { + super.addNode(chainNode); + + if (this.nodes.size() < 2) { + return; + } + + String sourceId = this.nodes.get(this.nodes.size() - 2).getId(); + String targetId = this.nodes.get(this.nodes.size() - 1).getId(); + + ChainEdge edge = new ChainEdge(); + edge.setSource(sourceId); + edge.setTarget(targetId); + + super.addEdge(edge); + } +}