optimize: added interface to get current transaction role (#3533)

changes/1.5.0.md

@@ -25,7 +25,7 @@ Seata 是一款开源的分布式事务解决方案，提供高性能和简单
   - [[#3427](https://github.com/seata/seata/pull/3427)] 添加分布式锁接口
   - [[#3443](https://github.com/seata/seata/pull/3443)] 将`seata-server`的日志发送到`logstash`或`kafka`中，再存入`ElasticSearch`
   - [[#3486](https://github.com/seata/seata/pull/3486)] Metrics增加事务分组属性
-  
+
 
   ### bugfix：
 
@@ -63,6 +63,7 @@ Seata 是一款开源的分布式事务解决方案，提供高性能和简单
   - [[#3415](https://github.com/seata/seata/pull/3415)] 优化 maven clean 插件可清除 distribution 目录
   - [[#3316](https://github.com/seata/seata/pull/3316)] 优化读取配置值时，属性bean可能未初始化  
   - [[#3420](https://github.com/seata/seata/pull/3420)] 优化枚举类并添加单元测试
+  - [[#3533](https://github.com/seata/seata/pull/3533)] 添加获取当前对应事务角色接口
   - [[#3436](https://github.com/seata/seata/pull/3436)] 优化SQLType类中的错别字
   - [[#3439](https://github.com/seata/seata/pull/3439)] 调整springApplicationContextProvider的顺序以使得他可以在xml的bean之前被调用
   - [[#3156](https://github.com/seata/seata/pull/3156)] 优化SpringProxyUtils.findTargetClass的逻辑

changes/en-us/1.5.0.md

@@ -65,6 +65,7 @@
   - [[#3415](https://github.com/seata/seata/pull/3415)] optimize maven clean plugin to clear the distribution directory 	
   - [[#3316](https://github.com/seata/seata/pull/3316)] optimize the property bean may not be initialized while reading config value	
   - [[#3420](https://github.com/seata/seata/pull/3420)] optimize enumerated classes and add unit tests	
+  - [[#3533](https://github.com/seata/seata/pull/3533)] added interface to get current transaction role
   - [[#3436](https://github.com/seata/seata/pull/3436)] optimize typo in SQLType class 	
   - [[#3439](https://github.com/seata/seata/pull/3439)] adjust the order of springApplicationContextProvider
   - [[#3156](https://github.com/seata/seata/pull/3156)] optimize the logic of SpringProxyUtils.findTargetClass
@@ -77,11 +78,11 @@
                                                         
 
   
-  
+
   ### test	
 
   - [[#3381](https://github.com/seata/seata/pull/3381)] test case for tmClient	
-  
+
 
   Thanks to these contributors for their code commits. Please report an unintended omission.  	
 
@@ -107,7 +108,7 @@
   - [github-ganyu](https://github.com/github-ganyu)
   - [xuande](https://github.com/xuande)
   - [tanggen](https://github.com/tanggen)
-  
+
 
   Also, we receive many valuable issues, questions and advices from our community. Thanks for you all.	
 

test/src/test/java/io/seata/saga/engine/mock/MockGlobalTransaction.java

@@ -20,6 +20,7 @@ import io.seata.core.exception.TransactionException;
 import io.seata.core.model.GlobalStatus;
 import io.seata.saga.engine.sequence.SpringJvmUUIDSeqGenerator;
 import io.seata.tm.api.GlobalTransaction;
+import io.seata.tm.api.GlobalTransactionRole;
 import io.seata.tm.api.transaction.SuspendedResourcesHolder;
 
 /**
@@ -102,4 +103,10 @@ public class MockGlobalTransaction implements GlobalTransaction {
     public GlobalStatus getLocalStatus() {
         return status;
     }
+
+    @Override
+    public GlobalTransactionRole getGlobalTransactionRole() {
+        return null;
+    }
+
 }

tm/src/main/java/io/seata/tm/api/DefaultGlobalTransaction.java

@@ -243,6 +243,11 @@ public class DefaultGlobalTransaction implements GlobalTransaction {
         return status;
     }
 
+    @Override
+    public GlobalTransactionRole getGlobalTransactionRole() {
+        return role;
+    }
+
     private void assertXIDNotNull() {
         if (xid == null) {
             throw new IllegalStateException();

tm/src/main/java/io/seata/tm/api/GlobalTransaction.java

@@ -123,4 +123,13 @@ public interface GlobalTransaction {
      * @see GlobalStatus
      */
     GlobalStatus getLocalStatus();
+
+    /**
+     * get global transaction role.
+     *
+     * @return global transaction Role.
+     * @see GlobalTransactionRole
+     */
+    GlobalTransactionRole getGlobalTransactionRole();
+
 }