6
6
using OHunt . Web . Crawlers ;
7
7
using OHunt . Web . Dataflow ;
8
8
using OHunt . Web . Models ;
9
- using Xbehave ;
10
9
using Xunit ;
11
10
12
11
namespace OHunt . Tests . Dataflow
@@ -26,51 +25,44 @@ public CrawlerPropagatorTests()
26
25
_propagator = new CrawlerPropagator ( _submissionOutput , _errorOutput ) ;
27
26
}
28
27
29
- [ Scenario ]
30
- public void It_ShouldWork ( )
28
+ [ Fact ]
29
+ public async Task It_ShouldWork ( )
31
30
{
32
- "Given a propagator" . x ( ( ) => { } ) ;
33
-
34
- "When receiving data"
35
- . x ( ( ) => _propagator . SendAsync ( new CrawlerMessage
36
- {
37
- Submission = new Submission
38
- {
39
- Status = RunResult . Accepted ,
40
- Time = new DateTime ( 2020 , 4 , 1 , 0 , 0 , 0 ) ,
41
- ProblemLabel = "1001" ,
42
- SubmissionId = 42 ,
43
- UserName = "user1" ,
44
- OnlineJudgeId = OnlineJudge . ZOJ ,
45
- } ,
46
- CrawlerError = new CrawlerError
47
- {
48
- Crawler = "zoj" ,
49
- Data = null ,
50
- Message = "An error" ,
51
- Time = new DateTime ( 2020 , 4 , 1 , 1 , 0 , 0 ) ,
52
- } ,
53
- } )
54
- ) ;
55
-
56
- "Then they are cached"
57
- . x ( async ( ) =>
31
+ // Given a propagator
32
+
33
+ // When receiving data
34
+ await _propagator . SendAsync ( new CrawlerMessage
35
+ {
36
+ Submission = new Submission
37
+ {
38
+ Status = RunResult . Accepted ,
39
+ Time = new DateTime ( 2020 , 4 , 1 , 0 , 0 , 0 ) ,
40
+ ProblemLabel = "1001" ,
41
+ SubmissionId = 42 ,
42
+ UserName = "user1" ,
43
+ OnlineJudgeId = OnlineJudge . ZOJ ,
44
+ } ,
45
+ CrawlerError = new CrawlerError
58
46
{
59
- await Utils . WaitSecond ( ) ;
60
- _submissionOutput . Count . Should ( ) . Be ( 0 ) ;
61
- _errorOutput . Count . Should ( ) . Be ( 0 ) ;
62
- } ) ;
47
+ Crawler = "zoj" ,
48
+ Data = null ,
49
+ Message = "An error" ,
50
+ Time = new DateTime ( 2020 , 4 , 1 , 1 , 0 , 0 ) ,
51
+ } ,
52
+ } ) ;
63
53
64
- "When a checkpoint is sent"
65
- . x ( ( ) => _propagator . SendAsync ( new CrawlerMessage { Checkpoint = true } ) ) ;
54
+ // Then they are cached
55
+ await Utils . WaitSecond ( ) ;
56
+ _submissionOutput . Count . Should ( ) . Be ( 0 ) ;
57
+ _errorOutput . Count . Should ( ) . Be ( 0 ) ;
66
58
67
- "Then data are dispatched"
68
- . x ( async ( ) =>
69
- {
70
- await Utils . WaitSecond ( ) ;
71
- _submissionOutput . Count . Should ( ) . Be ( 1 ) ;
72
- _errorOutput . Count . Should ( ) . Be ( 1 ) ;
73
- } ) ;
59
+ // When a checkpoint is sent
60
+ await _propagator . SendAsync ( new CrawlerMessage { Checkpoint = true } ) ;
61
+
62
+ // Then data are dispatched
63
+ await Utils . WaitSecond ( ) ;
64
+ _submissionOutput . Count . Should ( ) . Be ( 1 ) ;
65
+ _errorOutput . Count . Should ( ) . Be ( 1 ) ;
74
66
}
75
67
76
68
[ Fact ]
@@ -107,7 +99,7 @@ await _propagator.SendAsync(new CrawlerMessage
107
99
await _propagator . SendAsync ( new CrawlerMessage
108
100
{
109
101
Submission = new Submission
110
- {
102
+ {
111
103
SubmissionId = 4 ,
112
104
} ,
113
105
Checkpoint = true ,
0 commit comments