@@ -17,7 +17,7 @@ namespace GraphQL.AspNet.Tests.Engine
17
17
using GraphQL . AspNet . Schemas ;
18
18
using GraphQL . AspNet . SubscriptionServer ;
19
19
using GraphQL . AspNet . Tests . Framework . CommonHelpers ;
20
- using Moq ;
20
+ using NSubstitute ;
21
21
using NUnit . Framework ;
22
22
23
23
[ TestFixture ]
@@ -26,8 +26,8 @@ public class DefaultEventRouterTests
26
26
[ Test ]
27
27
public void NullEventResultsInException ( )
28
28
{
29
- var dispatcher = new Mock < ISubscriptionEventDispatchQueue > ( ) ;
30
- var router = new DefaultSubscriptionEventRouter ( dispatcher . Object ) ;
29
+ var dispatcher = Substitute . For < ISubscriptionEventDispatchQueue > ( ) ;
30
+ var router = new DefaultSubscriptionEventRouter ( dispatcher ) ;
31
31
32
32
Assert . Throws < ArgumentNullException > ( ( ) =>
33
33
{
@@ -40,8 +40,8 @@ public void NullEventResultsInException()
40
40
[ Test ]
41
41
public void RemovingANullReceiverDoesNothing ( )
42
42
{
43
- var dispatcher = new Mock < ISubscriptionEventDispatchQueue > ( ) ;
44
- var router = new DefaultSubscriptionEventRouter ( dispatcher . Object ) ;
43
+ var dispatcher = Substitute . For < ISubscriptionEventDispatchQueue > ( ) ;
44
+ var router = new DefaultSubscriptionEventRouter ( dispatcher ) ;
45
45
46
46
router . RemoveClient ( null ) ;
47
47
@@ -51,11 +51,11 @@ public void RemovingANullReceiverDoesNothing()
51
51
[ Test ]
52
52
public void SubscribedReceiver_ReceivesRaisedEvent ( )
53
53
{
54
- var receiver = new Mock < ISubscriptionClientProxy > ( ) ;
55
- receiver . Setup ( x => x . Id ) . Returns ( SubscriptionClientId . NewClientId ( ) ) ;
56
- var dispatcher = new Mock < ISubscriptionEventDispatchQueue > ( ) ;
54
+ var receiver = Substitute . For < ISubscriptionClientProxy > ( ) ;
55
+ receiver . Id . Returns ( SubscriptionClientId . NewClientId ( ) ) ;
56
+ var dispatcher = Substitute . For < ISubscriptionEventDispatchQueue > ( ) ;
57
57
58
- var router = new DefaultSubscriptionEventRouter ( dispatchQueue : dispatcher . Object ) ;
58
+ var router = new DefaultSubscriptionEventRouter ( dispatchQueue : dispatcher ) ;
59
59
60
60
var evt = new SubscriptionEvent ( )
61
61
{
@@ -65,23 +65,23 @@ public void SubscribedReceiver_ReceivesRaisedEvent()
65
65
Data = new TwoPropertyObject ( ) ,
66
66
} ;
67
67
68
- router . AddClient ( receiver . Object , evt . ToSubscriptionEventName ( ) ) ;
68
+ router . AddClient ( receiver , evt . ToSubscriptionEventName ( ) ) ;
69
69
router . RaisePublishedEvent ( evt ) ;
70
70
71
- dispatcher . Verify ( x => x . EnqueueEvent ( receiver . Object . Id , evt , false ) , Times . Once , "Event1 never received" ) ;
71
+ dispatcher . Received ( 1 ) . EnqueueEvent ( receiver . Id , evt , false ) ;
72
72
73
73
router . Dispose ( ) ;
74
74
}
75
75
76
76
[ Test ]
77
77
public void SubscribedReceiveer_TwoEvents_BothEventsAreDispatchedToTheReceiver ( )
78
78
{
79
- var receiver = new Mock < ISubscriptionClientProxy > ( ) ;
80
- receiver . Setup ( x => x . Id ) . Returns ( SubscriptionClientId . NewClientId ( ) ) ;
79
+ var receiver = Substitute . For < ISubscriptionClientProxy > ( ) ;
80
+ receiver . Id . Returns ( SubscriptionClientId . NewClientId ( ) ) ;
81
81
82
- var dispatcher = new Mock < ISubscriptionEventDispatchQueue > ( ) ;
82
+ var dispatcher = Substitute . For < ISubscriptionEventDispatchQueue > ( ) ;
83
83
84
- var router = new DefaultSubscriptionEventRouter ( dispatchQueue : dispatcher . Object ) ;
84
+ var router = new DefaultSubscriptionEventRouter ( dispatchQueue : dispatcher ) ;
85
85
86
86
var evt = new SubscriptionEvent ( )
87
87
{
@@ -100,26 +100,26 @@ public void SubscribedReceiveer_TwoEvents_BothEventsAreDispatchedToTheReceiver()
100
100
} ;
101
101
102
102
// add two events but remove the one being raised
103
- router . AddClient ( receiver . Object , evt . ToSubscriptionEventName ( ) ) ;
104
- router . AddClient ( receiver . Object , evt2 . ToSubscriptionEventName ( ) ) ;
103
+ router . AddClient ( receiver , evt . ToSubscriptionEventName ( ) ) ;
104
+ router . AddClient ( receiver , evt2 . ToSubscriptionEventName ( ) ) ;
105
105
router . RaisePublishedEvent ( evt ) ;
106
106
router . RaisePublishedEvent ( evt2 ) ;
107
107
108
- dispatcher . Verify ( x => x . EnqueueEvent ( receiver . Object . Id , evt , false ) , Times . Once , "Event1 never received" ) ;
109
- dispatcher . Verify ( x => x . EnqueueEvent ( receiver . Object . Id , evt2 , false ) , Times . Once , "Event2 never received" ) ;
108
+ dispatcher . Received ( 1 ) . EnqueueEvent ( receiver . Id , evt , false ) ;
109
+ dispatcher . Received ( 1 ) . EnqueueEvent ( receiver . Id , evt2 , false ) ;
110
110
111
111
router . Dispose ( ) ;
112
112
}
113
113
114
114
[ Test ]
115
115
public void UnsubscribedReceiver_DoesNotReceivesRaisedEvent ( )
116
116
{
117
- var receiver = new Mock < ISubscriptionClientProxy > ( ) ;
118
- receiver . Setup ( x => x . Id ) . Returns ( SubscriptionClientId . NewClientId ( ) ) ;
117
+ var receiver = Substitute . For < ISubscriptionClientProxy > ( ) ;
118
+ receiver . Id . Returns ( SubscriptionClientId . NewClientId ( ) ) ;
119
119
120
- var dispatcher = new Mock < ISubscriptionEventDispatchQueue > ( ) ;
120
+ var dispatcher = Substitute . For < ISubscriptionEventDispatchQueue > ( ) ;
121
121
122
- var router = new DefaultSubscriptionEventRouter ( dispatchQueue : dispatcher . Object ) ;
122
+ var router = new DefaultSubscriptionEventRouter ( dispatchQueue : dispatcher ) ;
123
123
124
124
var evt = new SubscriptionEvent ( )
125
125
{
@@ -139,27 +139,27 @@ public void UnsubscribedReceiver_DoesNotReceivesRaisedEvent()
139
139
140
140
// add two events but remove the one being raised
141
141
// to ensure its not processed
142
- router . AddClient ( receiver . Object , evt . ToSubscriptionEventName ( ) ) ;
143
- router . AddClient ( receiver . Object , evt2 . ToSubscriptionEventName ( ) ) ;
144
- router . RemoveClient ( receiver . Object , evt . ToSubscriptionEventName ( ) ) ;
142
+ router . AddClient ( receiver , evt . ToSubscriptionEventName ( ) ) ;
143
+ router . AddClient ( receiver , evt2 . ToSubscriptionEventName ( ) ) ;
144
+ router . RemoveClient ( receiver , evt . ToSubscriptionEventName ( ) ) ;
145
145
router . RaisePublishedEvent ( evt ) ;
146
146
router . RaisePublishedEvent ( evt2 ) ;
147
147
148
- dispatcher . Verify ( x => x . EnqueueEvent ( receiver . Object . Id , evt , false ) , Times . Never , "Event1 was received" ) ;
149
- dispatcher . Verify ( x => x . EnqueueEvent ( receiver . Object . Id , evt2 , false ) , Times . Once , "Event2 never received" ) ;
148
+ dispatcher . Received ( 0 ) . EnqueueEvent ( receiver . Id , evt , false ) ;
149
+ dispatcher . Received ( 1 ) . EnqueueEvent ( receiver . Id , evt2 , false ) ;
150
150
151
151
router . Dispose ( ) ;
152
152
}
153
153
154
154
[ Test ]
155
155
public void UnsubscribedAllReceiver_DoesNotReceivesRaisedEvent ( )
156
156
{
157
- var receiver = new Mock < ISubscriptionClientProxy > ( ) ;
158
- receiver . Setup ( x => x . Id ) . Returns ( SubscriptionClientId . NewClientId ( ) ) ;
157
+ var receiver = Substitute . For < ISubscriptionClientProxy > ( ) ;
158
+ receiver . Id . Returns ( SubscriptionClientId . NewClientId ( ) ) ;
159
159
160
- var dispatcher = new Mock < ISubscriptionEventDispatchQueue > ( ) ;
160
+ var dispatcher = Substitute . For < ISubscriptionEventDispatchQueue > ( ) ;
161
161
162
- var router = new DefaultSubscriptionEventRouter ( dispatchQueue : dispatcher . Object ) ;
162
+ var router = new DefaultSubscriptionEventRouter ( dispatchQueue : dispatcher ) ;
163
163
164
164
var evt = new SubscriptionEvent ( )
165
165
{
@@ -178,14 +178,14 @@ public void UnsubscribedAllReceiver_DoesNotReceivesRaisedEvent()
178
178
} ;
179
179
180
180
// add two events and ensure both are removed when not directly named
181
- router . AddClient ( receiver . Object , evt . ToSubscriptionEventName ( ) ) ;
182
- router . AddClient ( receiver . Object , evt2 . ToSubscriptionEventName ( ) ) ;
183
- router . RemoveClient ( receiver . Object ) ;
181
+ router . AddClient ( receiver , evt . ToSubscriptionEventName ( ) ) ;
182
+ router . AddClient ( receiver , evt2 . ToSubscriptionEventName ( ) ) ;
183
+ router . RemoveClient ( receiver ) ;
184
184
router . RaisePublishedEvent ( evt ) ;
185
185
router . RaisePublishedEvent ( evt2 ) ;
186
186
187
- dispatcher . Verify ( x => x . EnqueueEvent ( receiver . Object . Id , evt , false ) , Times . Never , "Event1 was received" ) ;
188
- dispatcher . Verify ( x => x . EnqueueEvent ( receiver . Object . Id , evt2 , false ) , Times . Never , "Event2 was received" ) ;
187
+ dispatcher . Received ( 0 ) . EnqueueEvent ( receiver . Id , evt , false ) ;
188
+ dispatcher . Received ( 0 ) . EnqueueEvent ( receiver . Id , evt2 , false ) ;
189
189
190
190
router . Dispose ( ) ;
191
191
}
0 commit comments