From 232231c6bcc118ffe8b82dd954c10afb8835be6b Mon Sep 17 00:00:00 2001 From: mabofu Date: Wed, 26 Mar 2025 15:59:56 +0800 Subject: [PATCH] Fixed code coverage: fixed AsyncTask code coverage --- .../taskmanager/model/AsyncTaskTest.java | 55 +++++++++++++++++++ 1 file changed, 55 insertions(+) create mode 100644 dsms-engine-application/src/test/java/com/dsms/common/taskmanager/model/AsyncTaskTest.java diff --git a/dsms-engine-application/src/test/java/com/dsms/common/taskmanager/model/AsyncTaskTest.java b/dsms-engine-application/src/test/java/com/dsms/common/taskmanager/model/AsyncTaskTest.java new file mode 100644 index 00000000..b829597c --- /dev/null +++ b/dsms-engine-application/src/test/java/com/dsms/common/taskmanager/model/AsyncTaskTest.java @@ -0,0 +1,55 @@ +package com.dsms.common.taskmanager.model; + +import static org.junit.jupiter.api.Assertions.assertNull; + +import cn.hutool.json.JSONUtil; +import com.dsms.common.constant.TaskExclusiveEnum; +import com.dsms.common.constant.TaskStatusEnum; +import com.dsms.common.constant.TaskTypeEnum; +import com.dsms.dfsbroker.rbd.model.dto.RbdDeleteDTO; +import com.dsms.modules.node.model.dto.NodeDeviceManageDto; +import org.junit.jupiter.api.Assertions; +import org.junit.jupiter.api.Test; + +class AsyncTaskTest { + + @Test + void testAsyncTask() { + AsyncTask asyncTask = new AsyncTask(); + assertNull(asyncTask.getId()); + } + + @Test + void testAsyncTaskOne() { + + RbdDeleteDTO rbdDeleteDTO = new RbdDeleteDTO(); + String taskMessage = TaskTypeEnum.DELETE_RBD.getName() + ":" + rbdDeleteDTO.getRbdName() + ",存储池:" + rbdDeleteDTO.getPoolName(); + + Task task = new AsyncTask( + TaskTypeEnum.DELETE_RBD.getName(), + TaskTypeEnum.DELETE_RBD.getType(), + TaskStatusEnum.QUEUE.getStatus(), + taskMessage, + JSONUtil.toJsonStr(rbdDeleteDTO)); + + Assertions.assertEquals(TaskTypeEnum.DELETE_RBD.getName(), task.getTaskName()); + Assertions.assertEquals(0, task.getIsExclusive()); + } + + @Test + void testAsyncTaskTwo() { + String nodeName = "ceph1"; + String devicePath = "sda"; + + String taskMessage = "节点管理磁盘，节点:" + nodeName + ", 磁盘路径:" + devicePath; + Task task = new AsyncTask( + TaskTypeEnum.ADD_OSD.getName(), + TaskTypeEnum.ADD_OSD.getType(), + TaskStatusEnum.QUEUE.getStatus(), + taskMessage, + JSONUtil.toJsonStr(JSONUtil.toJsonStr(new NodeDeviceManageDto(nodeName, devicePath))), + TaskExclusiveEnum.EXCLUSIVE.getCode()); + + Assertions.assertEquals(TaskExclusiveEnum.EXCLUSIVE.getCode(), task.getIsExclusive()); + } +} \ No newline at end of file -- Gitee