feat: saga support retrylimit (#56)

Author: catcherwong

build/version.props

@@ -1,7 +1,7 @@
 <Project>
   <PropertyGroup>
 
-    <DtmCSharpVersion>1.2.0</DtmCSharpVersion>
+    <DtmCSharpVersion>1.3.0</DtmCSharpVersion>
 
   </PropertyGroup>
 </Project>

src/DtmCommon/Imp/TransBase.cs

@@ -26,6 +26,12 @@ public class TransBase
         [JsonPropertyName("branch_headers")]
         public Dictionary<string, string> BranchHeaders { get; set; }
 
+        [JsonPropertyName("retry_limit")]
+        public long RetryLimit { get; set; }
+
+        [JsonPropertyName("retry_count")]
+        public long RetryCount { get; set; }
+
         /// <summary>
         /// use in MSG/SAGA
         /// </summary>

src/Dtmcli/Saga/Saga.cs

@@ -96,5 +96,16 @@ public Saga SetBranchHeaders(Dictionary<string, string> headers)
             this._transBase.BranchHeaders = headers;
             return this;
         }
+
+        /// <summary>
+        /// Set global trans retry limit
+        /// </summary>
+        /// <param name="limit"></param>
+        /// <returns></returns>
+        public Saga SetRetryLimit(long limit)
+        {
+            this._transBase.RetryLimit = limit;
+            return this;
+        }
     }
 }

src/Dtmgrpc/DtmgRPCClient.cs

@@ -104,6 +104,7 @@ private dtmgpb.DtmRequest BuildDtmRequest(TransBase transBase)
                 WaitResult = transBase.WaitResult,
                 TimeoutToFail = transBase.TimeoutToFail,
                 RetryInterval = transBase.RetryInterval,
+                RetryLimit = transBase.RetryLimit,
             };
 
             if (transBase.BranchHeaders != null)

src/Dtmgrpc/Saga/SagaGrpc.cs

@@ -99,5 +99,16 @@ public SagaGrpc SetBranchHeaders(Dictionary<string, string> headers)
             this._transBase.BranchHeaders = headers;
             return this;
         }
+
+        /// <summary>
+        /// Set global trans retry limit
+        /// </summary>
+        /// <param name="limit"></param>
+        /// <returns></returns>
+        public SagaGrpc SetRetryLimit(long limit)
+        {
+            this._transBase.RetryLimit = limit;
+            return this;
+        }
     }
 }

src/Dtmgrpc/dtmgpb/dtmgimp.proto

@@ -21,6 +21,8 @@ message DtmTransOptions {
   int64 RetryInterval = 3;
   // repeated string PassthroughHeaders = 4;
   map<string, string> BranchHeaders = 5;
+  int64 RequestTimeout = 6;
+  int64 RetryLimit = 7;
 }
 
 // DtmRequest request sent to dtm server

tests/Dtmcli.Tests/SagaTests.cs

@@ -40,6 +40,7 @@ public async void Submit_Should_Succeed()
                 .EnableWaitResult()
                 .SetRetryInterval(10)
                 .SetTimeoutToFail(100)
+                .SetRetryLimit(2)
                 .SetBranchHeaders(new Dictionary<string, string> 
                 {
                     { "bh1", "123" },
@@ -123,6 +124,7 @@ protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage
                 Assert.Contains("bh2", transBase.BranchHeaders.Keys);
                 Assert.Equal(4, transBase.Payloads.Count);
                 Assert.Equal(4, transBase.Steps.Count);
+                Assert.Equal(2, transBase.RetryLimit);
 
                 var content = new StringContent("{\"dtm_result\":\"SUCCESS\"}");
 

tests/Dtmgrpc.Tests/SagaTests.cs

@@ -31,6 +31,7 @@ public async void Submit_Should_Succeed()
                 .EnableConcurrent()
                 .SetRetryInterval(10)
                 .SetTimeoutToFail(100)
+                .SetRetryLimit(2)
                 .SetBranchHeaders(new Dictionary<string, string>
                  {
                      { "bh1", "123" },
@@ -43,6 +44,7 @@ public async void Submit_Should_Succeed()
             Assert.NotNull(tb.CustomData);
             Assert.Equal(10, tb.RetryInterval);
             Assert.Equal(100, tb.TimeoutToFail);
+            Assert.Equal(2, tb.RetryLimit);
 
             Assert.True(true);
         }