test: add some UT for server/cluster module

Author: WangzJi

server/src/test/java/org/apache/seata/server/cluster/listener/ClusterChangeEventTest.java

@@ -17,6 +17,7 @@
 package org.apache.seata.server.cluster.listener;
 
 import org.junit.jupiter.api.Test;
+
 import java.time.Clock;
 
 import static org.junit.jupiter.api.Assertions.*;

server/src/test/java/org/apache/seata/server/cluster/raft/sync/msg/RaftBaseMsgTest.java

@@ -17,6 +17,7 @@
 package org.apache.seata.server.cluster.raft.sync.msg;
 
 import org.junit.jupiter.api.Test;
+
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
 import java.io.ObjectInputStream;

server/src/test/java/org/apache/seata/server/cluster/raft/sync/msg/RaftBranchSessionSyncMsgTest.java

@@ -18,6 +18,7 @@
 
 import org.apache.seata.server.cluster.raft.sync.msg.dto.BranchTransactionDTO;
 import org.junit.jupiter.api.Test;
+
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
 import java.io.ObjectInputStream;
@@ -40,8 +41,7 @@ public void testDefaultConstructor() {
     @Test
     public void testConstructorWithParameters() {
         BranchTransactionDTO dto = new BranchTransactionDTO("xid:123", 456L);
-        RaftBranchSessionSyncMsg msg = new RaftBranchSessionSyncMsg(
-                RaftSyncMsgType.ADD_BRANCH_SESSION, dto);
+        RaftBranchSessionSyncMsg msg = new RaftBranchSessionSyncMsg(RaftSyncMsgType.ADD_BRANCH_SESSION, dto);
 
         assertEquals(RaftSyncMsgType.ADD_BRANCH_SESSION, msg.getMsgType());
         assertEquals(dto, msg.getBranchSession());
@@ -66,8 +66,7 @@ public void testSetAndGetGroup() {
     @Test
     public void testToString() {
         BranchTransactionDTO dto = new BranchTransactionDTO("xid:123", 456L);
-        RaftBranchSessionSyncMsg msg = new RaftBranchSessionSyncMsg(
-                RaftSyncMsgType.UPDATE_BRANCH_SESSION_STATUS, dto);
+        RaftBranchSessionSyncMsg msg = new RaftBranchSessionSyncMsg(RaftSyncMsgType.UPDATE_BRANCH_SESSION_STATUS, dto);
 
         String str = msg.toString();
         assertNotNull(str);
@@ -78,8 +77,7 @@ public void testToString() {
     public void testSerialization() throws Exception {
         BranchTransactionDTO dto = new BranchTransactionDTO("xid:123", 456L);
         dto.setLockKey("table:1,2,3");
-        RaftBranchSessionSyncMsg original = new RaftBranchSessionSyncMsg(
-                RaftSyncMsgType.ADD_BRANCH_SESSION, dto);
+        RaftBranchSessionSyncMsg original = new RaftBranchSessionSyncMsg(RaftSyncMsgType.ADD_BRANCH_SESSION, dto);
         original.setGroup("test-group");
 
         // Serialize
@@ -97,7 +95,11 @@ public void testSerialization() throws Exception {
         // Verify
         assertEquals(original.getMsgType(), deserialized.getMsgType());
         assertEquals(original.getGroup(), deserialized.getGroup());
-        assertEquals(original.getBranchSession().getXid(), deserialized.getBranchSession().getXid());
-        assertEquals(original.getBranchSession().getBranchId(), deserialized.getBranchSession().getBranchId());
+        assertEquals(
+                original.getBranchSession().getXid(),
+                deserialized.getBranchSession().getXid());
+        assertEquals(
+                original.getBranchSession().getBranchId(),
+                deserialized.getBranchSession().getBranchId());
     }
 }

server/src/test/java/org/apache/seata/server/cluster/raft/sync/msg/RaftClusterMetadataMsgTest.java

@@ -18,6 +18,7 @@
 
 import org.apache.seata.server.cluster.raft.sync.msg.dto.RaftClusterMetadata;
 import org.junit.jupiter.api.Test;
+
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
 import java.io.ObjectInputStream;
@@ -81,6 +82,8 @@ public void testSerialization() throws Exception {
 
         // Verify
         assertEquals(original.getMsgType(), deserialized.getMsgType());
-        assertEquals(original.getRaftClusterMetadata().getTerm(), deserialized.getRaftClusterMetadata().getTerm());
+        assertEquals(
+                original.getRaftClusterMetadata().getTerm(),
+                deserialized.getRaftClusterMetadata().getTerm());
     }
 }

server/src/test/java/org/apache/seata/server/cluster/raft/sync/msg/RaftGlobalSessionSyncMsgTest.java

@@ -18,6 +18,7 @@
 
 import org.apache.seata.server.cluster.raft.sync.msg.dto.GlobalTransactionDTO;
 import org.junit.jupiter.api.Test;
+
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
 import java.io.ObjectInputStream;
@@ -38,8 +39,7 @@ public void testDefaultConstructor() {
     @Test
     public void testConstructorWithParameters() {
         GlobalTransactionDTO dto = new GlobalTransactionDTO("xid:123456");
-        RaftGlobalSessionSyncMsg msg = new RaftGlobalSessionSyncMsg(
-                RaftSyncMsgType.ADD_GLOBAL_SESSION, dto);
+        RaftGlobalSessionSyncMsg msg = new RaftGlobalSessionSyncMsg(RaftSyncMsgType.ADD_GLOBAL_SESSION, dto);
 
         assertEquals(RaftSyncMsgType.ADD_GLOBAL_SESSION, msg.getMsgType());
         assertEquals(dto, msg.getGlobalSession());
@@ -57,8 +57,7 @@ public void testSetAndGetGlobalSession() {
     @Test
     public void testToString() {
         GlobalTransactionDTO dto = new GlobalTransactionDTO("xid:123");
-        RaftGlobalSessionSyncMsg msg = new RaftGlobalSessionSyncMsg(
-                RaftSyncMsgType.REMOVE_GLOBAL_SESSION, dto);
+        RaftGlobalSessionSyncMsg msg = new RaftGlobalSessionSyncMsg(RaftSyncMsgType.REMOVE_GLOBAL_SESSION, dto);
 
         String str = msg.toString();
         assertNotNull(str);
@@ -68,8 +67,8 @@ public void testToString() {
     @Test
     public void testSerialization() throws Exception {
         GlobalTransactionDTO dto = new GlobalTransactionDTO("xid:123456");
-        RaftGlobalSessionSyncMsg original = new RaftGlobalSessionSyncMsg(
-                RaftSyncMsgType.UPDATE_GLOBAL_SESSION_STATUS, dto);
+        RaftGlobalSessionSyncMsg original =
+                new RaftGlobalSessionSyncMsg(RaftSyncMsgType.UPDATE_GLOBAL_SESSION_STATUS, dto);
 
         // Serialize
         ByteArrayOutputStream bos = new ByteArrayOutputStream();
@@ -85,6 +84,8 @@ public void testSerialization() throws Exception {
 
         // Verify
         assertEquals(original.getMsgType(), deserialized.getMsgType());
-        assertEquals(original.getGlobalSession().getXid(), deserialized.getGlobalSession().getXid());
+        assertEquals(
+                original.getGlobalSession().getXid(),
+                deserialized.getGlobalSession().getXid());
     }
 }

server/src/test/java/org/apache/seata/server/cluster/raft/sync/msg/dto/BranchTransactionDTOTest.java

@@ -17,6 +17,7 @@
 package org.apache.seata.server.cluster.raft.sync.msg.dto;
 
 import org.junit.jupiter.api.Test;
+
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
 import java.io.ObjectInputStream;

server/src/test/java/org/apache/seata/server/cluster/raft/sync/msg/dto/GlobalTransactionDTOTest.java

@@ -17,6 +17,7 @@
 package org.apache.seata.server.cluster.raft.sync.msg.dto;
 
 import org.junit.jupiter.api.Test;
+
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
 import java.io.ObjectInputStream;

server/src/test/java/org/apache/seata/server/cluster/raft/sync/msg/dto/RaftClusterMetadataTest.java

@@ -18,6 +18,7 @@
 
 import org.apache.seata.common.metadata.Node;
 import org.junit.jupiter.api.Test;
+
 import java.util.Arrays;
 
 import static org.junit.jupiter.api.Assertions.*;