forked from sarbian/ModuleManager
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathQueueLogRunnerTest.cs
More file actions
152 lines (135 loc) · 5.6 KB
/
Copy pathQueueLogRunnerTest.cs
File metadata and controls
152 lines (135 loc) · 5.6 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
using System;
using Xunit;
using NSubstitute;
using ModuleManager.Collections;
using ModuleManager.Logging;
namespace ModuleManagerTests.Logging
{
public class QueueLogRunnerTest
{
[Fact]
public void TestConstructor__LogQueueNull()
{
ArgumentNullException ex = Assert.Throws<ArgumentNullException>(delegate
{
new QueueLogRunner(null);
});
Assert.Equal("logQueue", ex.ParamName);
}
[Fact]
public void TestConstructor__TimeToWaitForLogsMsNegative()
{
ArgumentException ex = Assert.Throws<ArgumentException>(delegate
{
new QueueLogRunner(Substitute.For<IMessageQueue<ILogMessage>>(), -1);
});
Assert.Contains("must be non-negative", ex.Message);
Assert.Equal("timeToWaitForLogsMs", ex.ParamName);
}
[Fact]
public void TestRun()
{
ILogMessage message1 = Substitute.For<ILogMessage>();
ILogMessage message2 = Substitute.For<ILogMessage>();
ILogMessage message3 = Substitute.For<ILogMessage>();
ILogMessage message4 = Substitute.For<ILogMessage>();
ILogMessage message5 = Substitute.For<ILogMessage>();
ILogMessage message6 = Substitute.For<ILogMessage>();
IMessageQueue<ILogMessage> messageQueue = Substitute.For<IMessageQueue<ILogMessage>>();
QueueLogRunner logRunner = new QueueLogRunner(messageQueue, 0);
int counter = 0;
messageQueue.TakeAll().Returns(delegate
{
IMessageQueue<ILogMessage> messageQueue2 = Substitute.For<IMessageQueue<ILogMessage>>();
if (counter == 0)
{
messageQueue2.GetEnumerator().Returns(new ArrayEnumerator<ILogMessage>(message1, message2));
}
else if (counter == 1)
{
logRunner.RequestStop(); // Called from Running state
messageQueue2.GetEnumerator().Returns(new ArrayEnumerator<ILogMessage>(message3, message4));
}
else
{
logRunner.RequestStop(); // Called from StopRequested state
messageQueue2.GetEnumerator().Returns(new ArrayEnumerator<ILogMessage>(message5, message6));
}
counter++;
return messageQueue2;
});
IBasicLogger logger = Substitute.For<IBasicLogger>();
logRunner.Run(logger);
logRunner.RequestStop(); // Called from Stopped state
Received.InOrder(delegate
{
logger.Log(message1);
logger.Log(message2);
logger.Log(message3);
logger.Log(message4);
logger.Log(message5);
logger.Log(message6);
});
}
[Fact]
public void TestRun__AlreadyStarted()
{
IMessageQueue<ILogMessage> messageQueue = Substitute.For<IMessageQueue<ILogMessage>>();
QueueLogRunner logRunner = new QueueLogRunner(messageQueue, 0);
int counter = 0;
messageQueue.TakeAll().Returns(delegate
{
IMessageQueue<ILogMessage> messageQueue2 = Substitute.For<IMessageQueue<ILogMessage>>();
if (counter == 0)
{
InvalidOperationException ex = Assert.Throws<InvalidOperationException>(delegate
{
logRunner.Run(Substitute.For<IBasicLogger>());
});
Assert.Equal("Cannot run from Running state", ex.Message);
logRunner.RequestStop();
messageQueue2.GetEnumerator().Returns(new ArrayEnumerator<ILogMessage>());
}
else
{
InvalidOperationException ex = Assert.Throws<InvalidOperationException>(delegate
{
logRunner.Run(Substitute.For<IBasicLogger>());
});
Assert.Equal("Cannot run from StopRequested state", ex.Message);
logRunner.RequestStop();
messageQueue2.GetEnumerator().Returns(new ArrayEnumerator<ILogMessage>());
}
counter++;
return messageQueue2;
});
IBasicLogger logger = Substitute.For<IBasicLogger>();
logRunner.Run(logger);
InvalidOperationException ex2 = Assert.Throws<InvalidOperationException>(delegate
{
logRunner.Run(Substitute.For<IBasicLogger>());
});
Assert.Equal("Cannot run from Stopped state", ex2.Message);
}
[Fact]
public void TestRun__LoggerNull()
{
QueueLogRunner logRunner = new QueueLogRunner(Substitute.For<IMessageQueue<ILogMessage>>());
ArgumentNullException ex = Assert.Throws<ArgumentNullException>(delegate
{
logRunner.Run(null);
});
Assert.Equal("logger", ex.ParamName);
}
[Fact]
public void TestRequestStop__NotStarted()
{
QueueLogRunner logRunner = new QueueLogRunner(Substitute.For<IMessageQueue<ILogMessage>>());
InvalidOperationException ex = Assert.Throws<InvalidOperationException>(delegate
{
logRunner.RequestStop();
});
Assert.Equal("Cannot request stop from Initialized state", ex.Message);
}
}
}