Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commit2dd50e7

Browse files
authored
test(Dtmgrpc.IntegrationTests): add workflow testing support (#95)
- Update project references to include Dtmworkflow- Modify ITTestHelper to support workflow testing- Add new test class WorkflowGrpcTest with workflow test cases
1 parent477b12b commit2dd50e7

File tree

3 files changed

+108
-0
lines changed

3 files changed

+108
-0
lines changed

‎tests/Dtmgrpc.IntegrationTests/Dtmgrpc.IntegrationTests.csproj‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@
2424
<ItemGroup>
2525
<ProjectReferenceInclude="..\..\src\Dtmgrpc\Dtmgrpc.csproj" />
2626
<ProjectReferenceInclude="..\..\src\DtmSERedisBarrier\DtmSERedisBarrier.csproj" />
27+
<ProjectReferenceInclude="..\..\src\Dtmworkflow\Dtmworkflow.csproj" />
2728
</ItemGroup>
2829

2930
<ItemGroup>

‎tests/Dtmgrpc.IntegrationTests/ITTestHelper.cs‎

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33
usingSystem.Collections.Generic;
44
usingSystem.Linq;
55
usingSystem.Threading.Tasks;
6+
usingDtmworkflow;
67
usingXunit.Abstractions;
78
usingXunit.Sdk;
89

@@ -13,6 +14,7 @@ public class ITTestHelper
1314
publicstaticstringDTMHttpUrl="http://localhost:36789";
1415
publicstaticstringDTMgRPCUrl="http://localhost:36790";
1516
publicstaticstringBuisgRPCUrl="localhost:5005";
17+
publicstaticstringBuisgRPCUrlWithProtocol="http://localhost:5005";
1618
privatestaticSystem.Net.Http.HttpClient_client=newSystem.Net.Http.HttpClient();
1719

1820
publicstaticasyncTask<string>GetTranStatus(stringgid)
@@ -67,6 +69,13 @@ public static ServiceProvider AddDtmGrpc(int dtmTimout = 10000)
6769
services.AddLogging();
6870
services.AddDtmGrpc(x=>
6971
{
72+
x.DtmUrl=DTMHttpUrl;
73+
x.DtmGrpcUrl=DTMgRPCUrl;
74+
x.DtmTimeout=dtmTimout;
75+
});
76+
services.AddDtmWorkflow(x=>
77+
{
78+
x.DtmUrl=DTMHttpUrl;
7079
x.DtmGrpcUrl=DTMgRPCUrl;
7180
x.DtmTimeout=dtmTimout;
7281
});
Lines changed: 98 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,98 @@
1+
usingMicrosoft.Extensions.DependencyInjection;
2+
usingSystem;
3+
usingSystem.Text;
4+
usingSystem.Threading;
5+
usingSystem.Threading.Tasks;
6+
usingbusi;
7+
usingDtmworkflow;
8+
usingGrpc.Net.Client;
9+
usingMicrosoft.Extensions.Logging;
10+
usingNewtonsoft.Json;
11+
usingXunit;
12+
13+
namespaceDtmgrpc.IntegrationTests
14+
{
15+
publicclassWorkflowGrpcTest
16+
{
17+
[Fact]
18+
publicasyncTaskExecute_Http_Should_Succeed()
19+
{
20+
varprovider=ITTestHelper.AddDtmGrpc();
21+
varworkflowFactory=provider.GetRequiredService<IWorkflowFactory>();
22+
varloggerFactory=provider.GetRequiredService<ILoggerFactory>();
23+
WorkflowGlobalTransactionworkflowGlobalTransaction=newWorkflowGlobalTransaction(workflowFactory,loggerFactory);
24+
25+
stringwfName1=$"wf-simple-{Guid.NewGuid().ToString("D")[..8]}";
26+
workflowGlobalTransaction.Register(wfName1,async(workflow,data)=>awaitTask.FromResult("my result"u8.ToArray()));
27+
28+
stringgid=wfName1+Guid.NewGuid().ToString()[..8];
29+
varreq=ITTestHelper.GenBusiReq(false,false);
30+
awaitworkflowGlobalTransaction.Execute(wfName1,gid,Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(req)),isHttp:true);
31+
32+
stringstatus=awaitITTestHelper.GetTranStatus(gid);
33+
Assert.Equal("succeed",status);
34+
}
35+
36+
[Fact]
37+
publicasyncTaskExecute_gPRC_Should_Succeed()
38+
{
39+
varprovider=ITTestHelper.AddDtmGrpc();
40+
varworkflowFactory=provider.GetRequiredService<IWorkflowFactory>();
41+
varloggerFactory=provider.GetRequiredService<ILoggerFactory>();
42+
WorkflowGlobalTransactionworkflowGlobalTransaction=newWorkflowGlobalTransaction(workflowFactory,loggerFactory);
43+
44+
stringwfName1=$"wf-simple-{Guid.NewGuid().ToString("D")[..8]}";
45+
workflowGlobalTransaction.Register(wfName1,async(workflow,data)=>awaitTask.FromResult("my result"u8.ToArray()));
46+
47+
stringgid=wfName1+Guid.NewGuid().ToString()[..8];
48+
varreq=ITTestHelper.GenBusiReq(false,false);
49+
awaitworkflowGlobalTransaction.Execute(wfName1,gid,Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(req)),isHttp:false);
50+
51+
stringstatus=awaitITTestHelper.GetTranStatus(gid);
52+
Assert.Equal("succeed",status);
53+
}
54+
55+
[Fact]
56+
publicasyncTaskExecute_Success()
57+
{
58+
varprovider=ITTestHelper.AddDtmGrpc();
59+
varworkflowFactory=provider.GetRequiredService<IWorkflowFactory>();
60+
varloggerFactory=provider.GetRequiredService<ILoggerFactory>();
61+
WorkflowGlobalTransactionworkflowGlobalTransaction=newWorkflowGlobalTransaction(workflowFactory,loggerFactory);
62+
63+
Busi.BusiClientbusiClient=newBusi.BusiClient(GrpcChannel.ForAddress(ITTestHelper.BuisgRPCUrlWithProtocol));
64+
65+
stringwfName1=$"wf-simple-{Guid.NewGuid().ToString("D")[..8]}";
66+
workflowGlobalTransaction.Register(wfName1,async(workflow,data)=>
67+
{
68+
BusiReqrequest=JsonConvert.DeserializeObject<BusiReq>(Encoding.UTF8.GetString(data));
69+
workflow.NewBranch().OnRollback(async(barrier)=>
70+
{
71+
awaitbusiClient.TransInRevertAsync(request);
72+
});
73+
awaitbusiClient.TransInAsync(request);
74+
75+
workflow.NewBranch().OnRollback(async(barrier)=>
76+
{
77+
awaitbusiClient.TransOutRevertAsync(request);
78+
});
79+
awaitbusiClient.TransOutAsync(request);
80+
81+
returnawaitTask.FromResult("my result"u8.ToArray());
82+
});
83+
84+
stringgid=wfName1+Guid.NewGuid().ToString()[..8];
85+
varreq=ITTestHelper.GenBusiReq(false,false);
86+
byte[]result=awaitworkflowGlobalTransaction.Execute(wfName1,gid,Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(req)));
87+
Assert.Equal("my result",Encoding.UTF8.GetString(result));
88+
stringstatus=awaitITTestHelper.GetTranStatus(gid);
89+
Assert.Equal("succeed",status);
90+
91+
// again
92+
result=awaitworkflowGlobalTransaction.Execute(wfName1,gid,Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(req)));
93+
Assert.Equal("my result",Encoding.UTF8.GetString(result));
94+
status=awaitITTestHelper.GetTranStatus(gid);
95+
Assert.Equal("succeed",status);
96+
}
97+
}
98+
}

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp