Bugfix workflow execute dtmfailureexception (#100)

* Change the test method to verify exception handling

Change the test method name to a more accurate description, and update the test logic to expect a 'DtmFailureException' instead of returning 'null'. This enhances the verification of exception handling.

* Inside the 'Process' method, a check for the 'err' variable is added to make sure an error is thrown if 'err' is not null. Modify the exception assertion of the 'Rollback_Should_Be_Executed' single test to use 'Assert.ThrowsAsync' to verify whether a 'DtmFailureException' was thrown.

Author: yxou

src/Dtmworkflow/Workflow.Imp.cs

@@ -81,6 +81,9 @@ internal async Task<byte[]> Process(WfFunc2 handler, byte[] data)
                 await this.Submit(res, err, default);
             }
 
+            if (err != null)
+                throw err;
+
             return res;
         }
 

tests/Dtmworkflow.Tests/WorkflowHttpTests.cs

@@ -141,7 +141,7 @@ public async void Execute_Should_ThrowException_When_WfFunc2_ThrowException()
         }
 
         [Fact]
-        public async void Execute_Should_Return_Null_When_WfFunc2_ThrowDtmFailureException()
+        public async void Execute_Should_ThrowDtmFailureException_When_WfFunc2_ThrowDtmFailureException()
         {
             var factory = new Mock<IWorkflowFactory>();
             var httpClient = new Mock<IDtmClient>();
@@ -161,7 +161,7 @@ public async void Execute_Should_Return_Null_When_WfFunc2_ThrowDtmFailureExcepti
 
             var wfgt = new WorkflowGlobalTransaction(factory.Object, NullLoggerFactory.Instance);
 
-            var wfName = nameof(Execute_Should_Return_Null_When_WfFunc2_ThrowDtmFailureException);
+            var wfName = nameof(Execute_Should_ThrowDtmFailureException_When_WfFunc2_ThrowDtmFailureException);
             var gid = Guid.NewGuid().ToString("N");
 
             var handler = new Mock<WfFunc2>();
@@ -170,8 +170,7 @@ public async void Execute_Should_Return_Null_When_WfFunc2_ThrowDtmFailureExcepti
             wfgt.Register(wfName, handler.Object);
             var req = JsonSerializer.Serialize(new { userId = "1", amount = 30 });
 
-            var res = await wfgt.Execute(wfName, gid, Encoding.UTF8.GetBytes(req), true);
-            Assert.Null(res);
+            await Assert.ThrowsAsync<DtmFailureException>(async () => await wfgt.Execute(wfName, gid, Encoding.UTF8.GetBytes(req), true));
         }
 
         [Fact]
@@ -209,7 +208,7 @@ public async void Rollback_Should_Be_Executed()
             wfgt.Register(wfName, handler);
             var req = JsonSerializer.Serialize(new { userId = "1", amount = 30 });
 
-            var res = await wfgt.Execute(wfName, gid, Encoding.UTF8.GetBytes(req), true);
+            var res = await Assert.ThrowsAsync<DtmFailureException>(async () => await wfgt.Execute(wfName, gid, Encoding.UTF8.GetBytes(req), true));
 
             func.Verify(x => x.Invoke(It.IsAny<BranchBarrier>()), Times.Once);
         }