feature: updated ResolveIncidentCommand so that it would run with ret…

Client.UnitTests/TestDataProvider.cs

@@ -41,7 +41,6 @@ public static IEnumerable<TestCaseData> Provider()
                     new TopologyResponse(),
                     (RequestCreator<ITopology>)
                     (zeebeClient => zeebeClient.TopologyRequest()));
-
                 yield return new TestCaseData(
                     new UpdateJobRetriesRequest
                     {
@@ -61,6 +60,13 @@ public static IEnumerable<TestCaseData> Provider()
                     }, new GatewayProtocol.ThrowErrorResponse(),
                     (RequestCreator<IThrowErrorResponse>)
                     (zeebeClient => zeebeClient.NewThrowErrorCommand(12113).ErrorCode("Code 13").ErrorMessage("This is a business error!")));
-            }
+                yield return new TestCaseData(
+                    new ResolveIncidentRequest
+                    {
+                        IncidentKey = 1201321
+                    }, new GatewayProtocol.ResolveIncidentResponse(),
+                    (RequestCreator<IResolveIncidentResponse>)
+                    (zeebeClient => zeebeClient.NewResolveIncidentCommand(1201321)));
+        }
     }
-}
+}

Client/Api/Commands/IResolveIncidentCommandStep1.cs

@@ -2,7 +2,7 @@
 
 namespace Zeebe.Client.Api.Commands
 {
-    public interface IResolveIncidentCommandStep1 : IFinalCommandStep<IResolveIncidentResponse>
+    public interface IResolveIncidentCommandStep1 : IFinalCommandWithRetryStep<IResolveIncidentResponse>
     {
         // the place for new optional parameters
     }

Client/Impl/Commands/ResolveIncidentCommand.cs

@@ -3,6 +3,7 @@
 using System.Threading.Tasks;
 using GatewayProtocol;
 using Zeebe.Client.Api.Commands;
+using Zeebe.Client.Api.Misc;
 using Zeebe.Client.Api.Responses;
 using ResolveIncidentResponse = Zeebe.Client.Impl.Responses.ResolveIncidentResponse;
 
@@ -12,14 +13,16 @@ public class ResolveIncidentCommand : IResolveIncidentCommandStep1
     {
         private readonly ResolveIncidentRequest request;
         private readonly Gateway.GatewayClient client;
+        private readonly IAsyncRetryStrategy asyncRetryStrategy;
 
-        public ResolveIncidentCommand(Gateway.GatewayClient client, long incidentKey)
+        public ResolveIncidentCommand(Gateway.GatewayClient client, IAsyncRetryStrategy asyncRetryStrategy, long incidentKey)
         {
             request = new ResolveIncidentRequest
             {
                 IncidentKey = incidentKey
             };
             this.client = client;
+            this.asyncRetryStrategy = asyncRetryStrategy;
         }
 
         public async Task<IResolveIncidentResponse> Send(TimeSpan? timeout = null, CancellationToken token = default)
@@ -33,5 +36,10 @@ public async Task<IResolveIncidentResponse> Send(CancellationToken cancellationT
         {
             return await Send(token: cancellationToken);
         }
+        public async Task<IResolveIncidentResponse> SendWithRetry(TimeSpan? timespan = null, CancellationToken token = default)
+        {
+            return await asyncRetryStrategy.DoWithRetry(() => Send(timespan, token));
+        }
+
     }
 }

Client/ZeebeClient.cs

@@ -156,7 +156,7 @@ public ISetVariablesCommandStep1 NewSetVariablesCommand(long elementInstanceKey)
 
         public IResolveIncidentCommandStep1 NewResolveIncidentCommand(long incidentKey)
         {
-            return new ResolveIncidentCommand(gatewayClient, incidentKey);
+            return new ResolveIncidentCommand(gatewayClient, asyncRetryStrategy, incidentKey);
         }
 
         public IPublishMessageCommandStep1 NewPublishMessageCommand()