From 76d2a49da9d3dc9a7c249c8ba240d2f1811d4fb5 Mon Sep 17 00:00:00 2001 From: even <827656971@qq.com> Date: Sat, 7 Jun 2025 17:10:58 +0800 Subject: [PATCH] =?UTF-8?q?RunContextManager=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 --- .../casic/server/RunContextManagerTest.java | 44 +++++++++++++++++++ 1 file changed, 44 insertions(+) create mode 100644 ops-server/src/test/java/cd/casic/server/RunContextManagerTest.java diff --git a/ops-server/src/test/java/cd/casic/server/RunContextManagerTest.java b/ops-server/src/test/java/cd/casic/server/RunContextManagerTest.java new file mode 100644 index 00000000..9ce641b3 --- /dev/null +++ b/ops-server/src/test/java/cd/casic/server/RunContextManagerTest.java @@ -0,0 +1,44 @@ +package cd.casic.server; + +import cd.casic.ci.process.engine.manager.RunContextManager; +import cd.casic.ci.process.engine.runContext.PipelineRunContext; +import cd.casic.ci.process.engine.runContext.SecondStageRunContext; +import cd.casic.ci.process.engine.runContext.TaskRunContext; +import cd.casic.ci.process.process.dataObject.pipeline.PipPipeline; +import cd.casic.ci.process.process.dataObject.stage.PipStage; +import cd.casic.ci.process.process.dataObject.task.PipTask; +import cd.casic.ci.process.process.service.pipeline.PipelineService; +import cd.casic.ci.process.process.service.stage.StageService; +import cd.casic.ci.process.process.service.task.TaskService; +import jakarta.annotation.Resource; +import org.junit.jupiter.api.Test; +import org.springframework.boot.test.context.SpringBootTest; +import org.springframework.test.context.ActiveProfiles; + +import java.util.HashMap; + +@SpringBootTest(classes = {OpsServerApplication.class}) +@ActiveProfiles("local") +public class RunContextManagerTest { + @Resource + RunContextManager contextManager; + @Resource + PipelineService pipelineService; + @Resource + StageService stageService; + @Resource + TaskService taskService; + @Test + public void test01(){ + // 所使用的 pipeline 、stage、task 必须有父子集关系 + PipPipeline pipeline = pipelineService.getById("719208124933869568"); + PipelineRunContext pipelineRunContext = new PipelineRunContext(pipeline, 11); + PipStage childStage = stageService.getById("719208126888415232"); + SecondStageRunContext secondStageRunContext = new SecondStageRunContext(childStage,11,pipelineRunContext,new HashMap<>()); + PipTask task = taskService.getById("719208127425286144"); + TaskRunContext taskRunContext = new TaskRunContext(task, secondStageRunContext, new HashMap<>()); + contextManager.contextRegister(pipelineRunContext); + contextManager.contextRegister(secondStageRunContext); + contextManager.contextRegister(taskRunContext); + } +}