From b7aed717d8118ba115c34dab47443c394f99c2a4 Mon Sep 17 00:00:00 2001
From: bryan31 <weenyc31@163.com>
Date: Sat, 5 Mar 2022 18:11:47 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A1=A5=E5=85=85=E6=B5=8B=E8=AF=95=E7=94=A8?=
 =?UTF-8?q?=E4=BE=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../liteflow/test/flowmeta/FlowMetaTest.java  | 34 +++++++++++++++++++
 .../liteflow/test/flowmeta/cmp1/ACmp.java     | 18 ++++++++++
 .../liteflow/test/flowmeta/cmp1/BCmp.java     | 19 +++++++++++
 .../liteflow/test/flowmeta/cmp1/CCmp.java     | 19 +++++++++++
 .../liteflow/test/flowmeta/cmp2/DCmp.java     | 19 +++++++++++
 .../src/test/resources/flowmeta/flow.xml      | 12 +++++++
 .../test/config/LiteflowConfigSpringTest.java |  2 +-
 7 files changed, 122 insertions(+), 1 deletion(-)
 create mode 100644 liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/flowmeta/FlowMetaTest.java
 create mode 100644 liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/flowmeta/cmp1/ACmp.java
 create mode 100644 liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/flowmeta/cmp1/BCmp.java
 create mode 100644 liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/flowmeta/cmp1/CCmp.java
 create mode 100644 liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/flowmeta/cmp2/DCmp.java
 create mode 100644 liteflow-testcase-nospring/src/test/resources/flowmeta/flow.xml

diff --git a/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/flowmeta/FlowMetaTest.java b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/flowmeta/FlowMetaTest.java
new file mode 100644
index 000000000..f5474815f
--- /dev/null
+++ b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/flowmeta/FlowMetaTest.java
@@ -0,0 +1,34 @@
+package com.yomahub.liteflow.test.flowmeta;
+
+import com.yomahub.liteflow.core.FlowExecutor;
+import com.yomahub.liteflow.entity.data.DefaultSlot;
+import com.yomahub.liteflow.entity.data.LiteflowResponse;
+import com.yomahub.liteflow.flow.FlowBus;
+import com.yomahub.liteflow.property.LiteflowConfig;
+import com.yomahub.liteflow.test.BaseTest;
+import com.yomahub.liteflow.test.flowmeta.cmp2.DCmp;
+import org.junit.Assert;
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+public class FlowMetaTest extends BaseTest {
+
+    private static FlowExecutor flowExecutor;
+
+    @BeforeClass
+    public static void init(){
+        LiteflowConfig config = new LiteflowConfig();
+        config.setRuleSource("flowmeta/flow.xml");
+        config.setParseOnStart(false);
+        flowExecutor = FlowExecutor.loadInstance(config);
+    }
+
+    //测试动态添加元信息节点
+    @Test
+    public void testFlowMeta() {
+        FlowBus.addCommonNode("d", "d组件", DCmp.class);
+        LiteflowResponse<DefaultSlot> response= flowExecutor.execute2Resp("chain1", "it's a request");
+        Assert.assertTrue(response.isSuccess());
+        Assert.assertEquals("a==>b==>c==>d[d组件]", response.getSlot().getExecuteStepStr());
+    }
+}
diff --git a/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/flowmeta/cmp1/ACmp.java b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/flowmeta/cmp1/ACmp.java
new file mode 100644
index 000000000..a7d1fbe5f
--- /dev/null
+++ b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/flowmeta/cmp1/ACmp.java
@@ -0,0 +1,18 @@
+/**
+ * <p>Title: liteflow</p>
+ * <p>Description: 轻量级的组件式流程框架</p>
+ * @author Bryan.Zhang
+ * @email weenyc31@163.com
+ * @Date 2020/4/1
+ */
+package com.yomahub.liteflow.test.flowmeta.cmp1;
+
+import com.yomahub.liteflow.core.NodeComponent;
+
+public class ACmp extends NodeComponent {
+
+	@Override
+	public void process() {
+		System.out.println("ACmp executed!");
+	}
+}
diff --git a/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/flowmeta/cmp1/BCmp.java b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/flowmeta/cmp1/BCmp.java
new file mode 100644
index 000000000..801fe1b80
--- /dev/null
+++ b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/flowmeta/cmp1/BCmp.java
@@ -0,0 +1,19 @@
+/**
+ * <p>Title: liteflow</p>
+ * <p>Description: 轻量级的组件式流程框架</p>
+ * @author Bryan.Zhang
+ * @email weenyc31@163.com
+ * @Date 2020/4/1
+ */
+package com.yomahub.liteflow.test.flowmeta.cmp1;
+
+import com.yomahub.liteflow.core.NodeComponent;
+
+public class BCmp extends NodeComponent {
+
+	@Override
+	public void process() {
+		System.out.println("BCmp executed!");
+	}
+
+}
diff --git a/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/flowmeta/cmp1/CCmp.java b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/flowmeta/cmp1/CCmp.java
new file mode 100644
index 000000000..8b7627e45
--- /dev/null
+++ b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/flowmeta/cmp1/CCmp.java
@@ -0,0 +1,19 @@
+/**
+ * <p>Title: liteflow</p>
+ * <p>Description: 轻量级的组件式流程框架</p>
+ * @author Bryan.Zhang
+ * @email weenyc31@163.com
+ * @Date 2020/4/1
+ */
+package com.yomahub.liteflow.test.flowmeta.cmp1;
+
+import com.yomahub.liteflow.core.NodeComponent;
+
+public class CCmp extends NodeComponent {
+
+	@Override
+	public void process() {
+		System.out.println("CCmp executed!");
+	}
+
+}
diff --git a/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/flowmeta/cmp2/DCmp.java b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/flowmeta/cmp2/DCmp.java
new file mode 100644
index 000000000..9ed261058
--- /dev/null
+++ b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/flowmeta/cmp2/DCmp.java
@@ -0,0 +1,19 @@
+/**
+ * <p>Title: liteflow</p>
+ * <p>Description: 轻量级的组件式流程框架</p>
+ * @author Bryan.Zhang
+ * @email weenyc31@163.com
+ * @Date 2020/4/1
+ */
+package com.yomahub.liteflow.test.flowmeta.cmp2;
+
+import com.yomahub.liteflow.core.NodeComponent;
+
+public class DCmp extends NodeComponent {
+
+	@Override
+	public void process() {
+		System.out.println("Dcomp executed!");
+	}
+
+}
diff --git a/liteflow-testcase-nospring/src/test/resources/flowmeta/flow.xml b/liteflow-testcase-nospring/src/test/resources/flowmeta/flow.xml
new file mode 100644
index 000000000..d8821ff8b
--- /dev/null
+++ b/liteflow-testcase-nospring/src/test/resources/flowmeta/flow.xml
@@ -0,0 +1,12 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<flow>
+    <nodes>
+        <node id="a" class="com.yomahub.liteflow.test.flowmeta.cmp1.ACmp"/>
+        <node id="b" class="com.yomahub.liteflow.test.flowmeta.cmp1.BCmp"/>
+        <node id="c" class="com.yomahub.liteflow.test.flowmeta.cmp1.CCmp"/>
+    </nodes>
+
+    <chain name="chain1">
+        <then value="a,b,c,d"/>
+    </chain>
+</flow>
\ No newline at end of file
diff --git a/liteflow-testcase-springnative/src/test/java/com/yomahub/liteflow/test/config/LiteflowConfigSpringTest.java b/liteflow-testcase-springnative/src/test/java/com/yomahub/liteflow/test/config/LiteflowConfigSpringTest.java
index fc1cb76c5..a9146b60d 100644
--- a/liteflow-testcase-springnative/src/test/java/com/yomahub/liteflow/test/config/LiteflowConfigSpringTest.java
+++ b/liteflow-testcase-springnative/src/test/java/com/yomahub/liteflow/test/config/LiteflowConfigSpringTest.java
@@ -41,6 +41,6 @@ public class LiteflowConfigSpringTest extends BaseTest {
         Assert.assertEquals(300000L, config.getPeriod().longValue());
         Assert.assertFalse(config.getEnableLog());
         Assert.assertEquals(Runtime.getRuntime().availableProcessors() * 2, config.getWhenMaxWorkers().longValue());
-        Assert.assertEquals(100, config.getWhenQueueLimit().longValue());
+        Assert.assertEquals(512, config.getWhenQueueLimit().longValue());
     }
 }