diff --git a/dsms-engine-application/src/test/java/com/dsms/common/taskmanager/model/AsyncStepTest.java b/dsms-engine-application/src/test/java/com/dsms/common/taskmanager/model/AsyncStepTest.java new file mode 100644 index 0000000000000000000000000000000000000000..0221ec6e50530a4ae5cddd8826ab6d2d8ce31cd7 --- /dev/null +++ b/dsms-engine-application/src/test/java/com/dsms/common/taskmanager/model/AsyncStepTest.java @@ -0,0 +1,48 @@ +package com.dsms.common.taskmanager.model; + +import static org.junit.jupiter.api.Assertions.assertNull; + +import com.alibaba.fastjson2.JSON; +import com.dsms.common.constant.StepTypeEnum; +import com.dsms.common.constant.TaskStatusEnum; +import com.dsms.dfsbroker.filesystem.model.dto.FileSystemDTO; +import org.junit.jupiter.api.Assertions; +import org.junit.jupiter.api.Test; + +class AsyncStepTest { + + @Test + void testAsyncStep() { + AsyncStep asyncStep = new AsyncStep(); + assertNull(asyncStep.getId()); + } + + @Test + void testAsyncStepOne() { + Step moveOsdStep = new AsyncStep( + 1, + StepTypeEnum.MOVE_OSD_TO_DEFAULT.getName(), + StepTypeEnum.MOVE_OSD_TO_DEFAULT.getType(), + StepTypeEnum.MOVE_OSD_TO_DEFAULT.getName(), + TaskStatusEnum.QUEUE.getStatus()); + + Assertions.assertEquals(1, moveOsdStep.getTaskId()); + Assertions.assertNull(moveOsdStep.getStepParam()); + } + + @Test + void testAsyncStepTwo() { + FileSystemDTO fileSystemDTO = new FileSystemDTO(); + + Step deleteFileSystemAuth = new AsyncStep( + 1, + StepTypeEnum.DELETE_FILE_SYSTEM_AUTH.getName(), + StepTypeEnum.DELETE_FILE_SYSTEM_AUTH.getType(), + StepTypeEnum.DELETE_FILE_SYSTEM_AUTH.getName() + ":" + fileSystemDTO.getFsName(), + TaskStatusEnum.QUEUE.getStatus(), + JSON.toJSONString(fileSystemDTO)); + + Assertions.assertEquals(JSON.toJSONString(new FileSystemDTO()), deleteFileSystemAuth.getStepParam()); + } + +} \ No newline at end of file