test: Increase [integration-tx-api] module test case coverage

changes/en-us/2.x.md

@@ -153,6 +153,8 @@ Add changes here for all PR submitted to the 2.x branch.
 - [[#6456](https://github.com/apache/incubator-seata/pull/6456)] adjust the test cases related to dynamic configuration
 - [[#6466](https://github.com/apache/incubator-seata/pull/6466)] support redis integration testing
 - [[#6484](https://github.com/apache/incubator-seata/pull/6484)] fix FileConfigurationTest and MockServerTest fail
+- [[#6545](https://github.com/apache/incubator-seata/pull/6545)] fix TestConfigCustomSPI compatibility test fail
+- [[#6533](https://github.com/apache/incubator-seata/pull/6533)] increase integration-tx-api module unit test coverage
 
 ### refactor:
 - [[#6280](https://github.com/apache/incubator-seata/pull/6280)] refactor Saga designer using diagram-js

changes/zh-cn/2.x.md

@@ -150,6 +150,8 @@
 - [[#6456](https://github.com/apache/incubator-seata/pull/6456)] 调整动态配置监听测试用例
 - [[#6466](https://github.com/apache/incubator-seata/pull/6466)] 支持redis的集成测试
 - [[#6484](https://github.com/apache/incubator-seata/pull/6484)] 修复FileConfigurationTest和MockServerTest失败
+- [[#6545](https://github.com/apache/incubator-seata/pull/6545)] 修复 TestConfigCustomSPI 兼容性测试失败
+- [[#6533](https://github.com/apache/incubator-seata/pull/6533)] 增加 Integration-TX-API 模块单元测试覆盖范围
 
 ### refactor:
 - [[#6280](https://github.com/apache/incubator-seata/pull/6280)] 使用diagram-js重构Saga设计器

integration-tx-api/src/main/java/org/apache/seata/integration/tx/api/remoting/TwoPhaseResult.java

@@ -87,7 +87,7 @@ public String toString() {
         sb.append("[");
         sb.append("isSuccess:").append(isSuccess);
         if (StringUtils.isNotBlank(message)) {
-            sb.append(", msg").append(message);
+            sb.append(", msg:").append(message);
         }
         sb.append("]");
         return sb.toString();

integration-tx-api/src/test/java/org/apache/seata/integration/tx/api/interceptor/TwoPhaseBusinessActionParamTest.java

@@ -0,0 +1,75 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.seata.integration.tx.api.interceptor;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import org.apache.seata.common.Constants;
+import org.apache.seata.core.model.BranchType;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
+public class TwoPhaseBusinessActionParamTest {
+
+    private TwoPhaseBusinessActionParam actionParam;
+
+    @BeforeEach
+    public void setUp() {
+        actionParam = new TwoPhaseBusinessActionParam();
+    }
+
+    @Test
+    public void testGetActionName() {
+        actionParam.setActionName("business_action");
+        assertEquals("business_action", actionParam.getActionName());
+    }
+
+    @Test
+    public void testIsReportDelayed() {
+        actionParam.setDelayReport(true);
+        assertTrue(actionParam.getDelayReport());
+    }
+
+    @Test
+    public void testIsCommonFenceUsed() {
+        actionParam.setUseCommonFence(true);
+        assertTrue(actionParam.getUseCommonFence());
+    }
+
+    @Test
+    public void testFillBusinessActionContext() {
+        Map<String, Object> businessActionContextMap = new HashMap<>(2);
+        businessActionContextMap.put(Constants.COMMIT_METHOD, "commit");
+        businessActionContextMap.put(Constants.USE_COMMON_FENCE, false);
+
+        actionParam.setBusinessActionContext(businessActionContextMap);
+
+        assertEquals("commit", actionParam.getBusinessActionContext().get(Constants.COMMIT_METHOD));
+        assertFalse((Boolean) actionParam.getBusinessActionContext().get(Constants.USE_COMMON_FENCE));
+    }
+
+    @Test
+    public void testGetBranchType() {
+        actionParam.setBranchType(BranchType.TCC);
+        assertEquals(BranchType.TCC, actionParam.getBranchType());
+    }
+}

integration-tx-api/src/test/java/org/apache/seata/integration/tx/api/interceptor/parser/IfNeedEnhanceBeanTest.java

@@ -0,0 +1,46 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.seata.integration.tx.api.interceptor.parser;
+
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
+public class IfNeedEnhanceBeanTest {
+
+    private IfNeedEnhanceBean enhanceBean;
+
+
+    @BeforeEach
+    public void setUp() {
+        enhanceBean = new IfNeedEnhanceBean();
+    }
+
+    @Test
+    public void testIsEnhanceNeeded() {
+        enhanceBean.setIfNeed(true);
+        assertTrue(enhanceBean.isIfNeed());
+    }
+
+    @Test
+    public void testGetNeedEnhanceEnum() {
+        enhanceBean.setNeedEnhanceEnum(NeedEnhanceEnum.SERVICE_BEAN);
+        assertEquals(NeedEnhanceEnum.SERVICE_BEAN, enhanceBean.getNeedEnhanceEnum());
+    }
+}

integration-tx-api/src/test/java/org/apache/seata/integration/tx/api/json/JsonParserImpl.java

@@ -0,0 +1,41 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.seata.integration.tx.api.json;
+
+import java.io.IOException;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+public class JsonParserImpl implements JsonParser {
+
+    private final ObjectMapper mapper = new ObjectMapper();
+
+    @Override
+    public String toJSONString(Object object) throws IOException {
+        return mapper.writeValueAsString(object);
+    }
+
+    @Override
+    public <T> T parseObject(String text, Class<T> clazz) throws IOException {
+        return mapper.readValue(text, clazz);
+    }
+
+    @Override
+    public String getName() {
+        return "customParser";
+    }
+}

integration-tx-api/src/test/java/org/apache/seata/integration/tx/api/json/JsonParserWrapTest.java

@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.seata.integration.tx.api.json;
+
+import org.apache.seata.common.exception.JsonParseException;
+import org.apache.seata.core.model.BranchType;
+import org.apache.seata.integration.tx.api.interceptor.TwoPhaseBusinessActionParam;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertThrows;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.when;
+
+public class JsonParserWrapTest {
+
+    private JsonParserWrap parserWrap;
+    private final String jsonString = "{\"actionName\":\"business_action\",\"useCommonFence\":null,\"businessActionContext\":null," +
+            "\"branchType\":\"TCC\",\"delayReport\":null}";
+
+
+    @BeforeEach
+    public void setUp() {
+        parserWrap = new JsonParserWrap(new JsonParserImpl());
+    }
+
+    @Test
+    public void testToJSONString() {
+        TwoPhaseBusinessActionParam actionParam = new TwoPhaseBusinessActionParam();
+        actionParam.setActionName("business_action");
+        actionParam.setBranchType(BranchType.TCC);
+
+        String resultString = parserWrap.toJSONString(actionParam);
+
+        assertEquals(jsonString, resultString);
+    }
+
+    @Test
+    public void testToJSONStringThrowsException() {
+        Object mockItem = mock(Object.class);
+        when(mockItem.toString()).thenReturn(mockItem.getClass().getName());
+        assertThrows(JsonParseException.class, () -> parserWrap.toJSONString(mockItem));
+    }
+
+    @Test
+    public void testParseObject() {
+        TwoPhaseBusinessActionParam actionParam = parserWrap.parseObject(jsonString, TwoPhaseBusinessActionParam.class);
+
+        assertEquals("business_action", actionParam.getActionName());
+        assertEquals(BranchType.TCC, actionParam.getBranchType());
+    }
+
+    @Test
+    public void testParseObjectThrowsException() {
+        assertThrows(JsonParseException.class, () -> parserWrap.parseObject(jsonString, Integer.class));
+    }
+
+    @Test
+    public void testGetName() {
+        assertEquals("customParser", parserWrap.getName());
+    }
+}

integration-tx-api/src/test/java/org/apache/seata/integration/tx/api/remoting/TwoPhaseResultTest.java

@@ -0,0 +1,56 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.seata.integration.tx.api.remoting;
+
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
+public class TwoPhaseResultTest {
+
+    private TwoPhaseResult result;
+
+    @BeforeEach
+    public void setUp() {
+        result = new TwoPhaseResult(false, "");
+    }
+
+    @Test
+    public void testGetMessage() {
+        result.setMessage("message");
+        assertEquals("message", result.getMessage());
+    }
+
+    @Test
+    public void testIsSuccess() {
+        result.setSuccess(true);
+        assertTrue(result.isSuccess());
+    }
+
+    @Test
+    public void testToStringEmptyMessage() {
+        assertEquals("[isSuccess:false]", result.toString());
+    }
+
+    @Test
+    public void testToStringNotEmptyMessage() {
+        result.setMessage("test");
+        assertEquals("[isSuccess:false, msg:test]", result.toString());
+    }
+}