diff --git a/dsms-engine-application/src/test/java/com/dsms/dfsbroker/cluster/request/StatusRequestTest.java b/dsms-engine-application/src/test/java/com/dsms/dfsbroker/cluster/request/StatusRequestTest.java new file mode 100644 index 0000000000000000000000000000000000000000..678a13a304e600797713daa53f2267152bef5b20 --- /dev/null +++ b/dsms-engine-application/src/test/java/com/dsms/dfsbroker/cluster/request/StatusRequestTest.java @@ -0,0 +1,46 @@ +package com.dsms.dfsbroker.cluster.request; + +import com.alibaba.fastjson2.JSON; +import com.dsms.dfsbroker.common.RequestUrlEnum; +import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.Test; +import org.springframework.http.HttpMethod; + +import java.util.Map; + +import static org.junit.jupiter.api.Assertions.*; + +public class StatusRequestTest { + private StatusRequest statusRequest; + + @BeforeEach + void setUp() { + statusRequest = new StatusRequest(); + } + + @Test + void testUrlPrefixSetCorrectly() { + String expectedPrefix = RequestUrlEnum.REQUEST_URL.getUrlPrefix(); + assertNotNull(expectedPrefix); + assertEquals(expectedPrefix, statusRequest.getUrlPrefix()); + } + + @Test + void testHttpMethodSetToPost() { + assertEquals(HttpMethod.POST, statusRequest.getHttpMethod()); + } + + @Test + void testRequestBodyIsCorrectJson() { + String requestBody = statusRequest.getRequestBody(); + assertNotNull(requestBody); + assertTrue(requestBody.startsWith("{")); + assertTrue(requestBody.endsWith("}")); + + // 解析 JSON 验证内容 + Map map = JSON.parseObject(requestBody, Map.class); + assertNotNull(map); + assertEquals("status", map.get("prefix")); + assertEquals("json", map.get("format")); + } +}