33using System . Net . WebSockets ;
44using System . Threading ;
55using System . Threading . Tasks ;
6+ using FluentAssertions ;
67using GraphQL . Client . Abstractions ;
8+ using GraphQL . Client . Abstractions . Websocket ;
79using GraphQL . Client . Tests . Common . Chat ;
810using GraphQL . Client . Tests . Common . Helpers ;
911using GraphQL . Integration . Tests . Helpers ;
1012using IntegrationTestServer ;
1113using Microsoft . AspNetCore . Hosting ;
1214using Xunit ;
1315using Xunit . Abstractions ;
14- using FluentAssertions ;
15- using GraphQL . Client . Abstractions . Websocket ;
1616
17- namespace GraphQL . Integration . Tests {
18- public class WebsocketTest {
19- private readonly ITestOutputHelper output ;
20- private static IWebHost CreateServer ( int port ) => WebHostHelpers . CreateServer < StartupChat > ( port ) ;
17+ namespace GraphQL . Integration . Tests . WebsocketTests {
18+ public abstract class Base {
19+ protected readonly ITestOutputHelper output ;
20+ protected readonly IGraphQLWebsocketJsonSerializer serializer ;
21+ protected IWebHost CreateServer ( int port ) => WebHostHelpers . CreateServer < StartupChat > ( port ) ;
2122
22- public WebsocketTest ( ITestOutputHelper output ) {
23+ public Base ( ITestOutputHelper output , IGraphQLWebsocketJsonSerializer serializer ) {
24+ this . output = output ;
25+ this . serializer = serializer ;
26+ }
27+
28+ public Base ( ITestOutputHelper output ) {
2329 this . output = output ;
2430 }
2531
26- [ Theory ]
27- [ ClassData ( typeof ( AvailableJsonSerializers < IGraphQLWebsocketJsonSerializer > ) ) ]
28- public async void AssertTestingHarness ( IGraphQLWebsocketJsonSerializer serializer ) {
32+ [ Fact ]
33+ public async void AssertTestingHarness ( ) {
2934 var port = NetworkHelpers . GetFreeTcpPortNumber ( ) ;
3035 using ( CreateServer ( port ) ) {
3136 var client = WebHostHelpers . GetGraphQLClient ( port , serializer : serializer ) ;
@@ -38,9 +43,8 @@ public async void AssertTestingHarness(IGraphQLWebsocketJsonSerializer serialize
3843 }
3944
4045
41- [ Theory ]
42- [ ClassData ( typeof ( AvailableJsonSerializers < IGraphQLWebsocketJsonSerializer > ) ) ]
43- public async void CanSendRequestViaWebsocket ( IGraphQLWebsocketJsonSerializer serializer ) {
46+ [ Fact ]
47+ public async void CanSendRequestViaWebsocket ( ) {
4448 var port = NetworkHelpers . GetFreeTcpPortNumber ( ) ;
4549 using ( CreateServer ( port ) ) {
4650 var client = WebHostHelpers . GetGraphQLClient ( port , true , serializer ) ;
@@ -51,10 +55,8 @@ public async void CanSendRequestViaWebsocket(IGraphQLWebsocketJsonSerializer ser
5155 }
5256 }
5357
54-
55- [ Theory ]
56- [ ClassData ( typeof ( AvailableJsonSerializers < IGraphQLWebsocketJsonSerializer > ) ) ]
57- public async void CanHandleRequestErrorViaWebsocket ( IGraphQLWebsocketJsonSerializer serializer ) {
58+ [ Fact ]
59+ public async void CanHandleRequestErrorViaWebsocket ( ) {
5860 var port = NetworkHelpers . GetFreeTcpPortNumber ( ) ;
5961 using ( CreateServer ( port ) ) {
6062 var client = WebHostHelpers . GetGraphQLClient ( port , true , serializer ) ;
@@ -74,9 +76,8 @@ public async void CanHandleRequestErrorViaWebsocket(IGraphQLWebsocketJsonSeriali
7476 private readonly GraphQLRequest SubscriptionRequest = new GraphQLRequest ( SubscriptionQuery ) ;
7577
7678
77- [ Theory ]
78- [ ClassData ( typeof ( AvailableJsonSerializers < IGraphQLWebsocketJsonSerializer > ) ) ]
79- public async void CanCreateObservableSubscription ( IGraphQLWebsocketJsonSerializer serializer ) {
79+ [ Fact ]
80+ public async void CanCreateObservableSubscription ( ) {
8081 var port = NetworkHelpers . GetFreeTcpPortNumber ( ) ;
8182 using ( CreateServer ( port ) ) {
8283 var client = WebHostHelpers . GetGraphQLClient ( port , serializer : serializer ) ;
@@ -116,9 +117,8 @@ public class MessageAddedContent {
116117 }
117118
118119
119- [ Theory ]
120- [ ClassData ( typeof ( AvailableJsonSerializers < IGraphQLWebsocketJsonSerializer > ) ) ]
121- public async void CanReconnectWithSameObservable ( IGraphQLWebsocketJsonSerializer serializer ) {
120+ [ Fact ]
121+ public async void CanReconnectWithSameObservable ( ) {
122122 var port = NetworkHelpers . GetFreeTcpPortNumber ( ) ;
123123 using ( CreateServer ( port ) ) {
124124 var client = WebHostHelpers . GetGraphQLClient ( port , serializer : serializer ) ;
@@ -185,9 +185,8 @@ public class UserJoinedContent {
185185 private readonly GraphQLRequest SubscriptionRequest2 = new GraphQLRequest ( SubscriptionQuery2 ) ;
186186
187187
188- [ Theory ]
189- [ ClassData ( typeof ( AvailableJsonSerializers < IGraphQLWebsocketJsonSerializer > ) ) ]
190- public async void CanConnectTwoSubscriptionsSimultaneously ( IGraphQLWebsocketJsonSerializer serializer ) {
188+ [ Fact ]
189+ public async void CanConnectTwoSubscriptionsSimultaneously ( ) {
191190 var port = NetworkHelpers . GetFreeTcpPortNumber ( ) ;
192191 var callbackTester = new CallbackTester < Exception > ( ) ;
193192 var callbackTester2 = new CallbackTester < Exception > ( ) ;
@@ -234,9 +233,8 @@ public async void CanConnectTwoSubscriptionsSimultaneously(IGraphQLWebsocketJson
234233 }
235234
236235
237- [ Theory ]
238- [ ClassData ( typeof ( AvailableJsonSerializers < IGraphQLWebsocketJsonSerializer > ) ) ]
239- public async void CanHandleConnectionTimeout ( IGraphQLWebsocketJsonSerializer serializer ) {
236+ [ Fact ]
237+ public async void CanHandleConnectionTimeout ( ) {
240238 var port = NetworkHelpers . GetFreeTcpPortNumber ( ) ;
241239 var server = CreateServer ( port ) ;
242240 var callbackTester = new CallbackTester < Exception > ( ) ;
@@ -277,9 +275,8 @@ public async void CanHandleConnectionTimeout(IGraphQLWebsocketJsonSerializer ser
277275 }
278276
279277
280- [ Theory ]
281- [ ClassData ( typeof ( AvailableJsonSerializers < IGraphQLWebsocketJsonSerializer > ) ) ]
282- public async void CanHandleSubscriptionError ( IGraphQLWebsocketJsonSerializer serializer ) {
278+ [ Fact ]
279+ public async void CanHandleSubscriptionError ( ) {
283280 var port = NetworkHelpers . GetFreeTcpPortNumber ( ) ;
284281 using ( CreateServer ( port ) ) {
285282 var client = WebHostHelpers . GetGraphQLClient ( port , serializer : serializer ) ;
@@ -305,9 +302,8 @@ public async void CanHandleSubscriptionError(IGraphQLWebsocketJsonSerializer ser
305302 }
306303
307304
308- [ Theory ]
309- [ ClassData ( typeof ( AvailableJsonSerializers < IGraphQLWebsocketJsonSerializer > ) ) ]
310- public async void CanHandleQueryErrorInSubscription ( IGraphQLWebsocketJsonSerializer serializer ) {
305+ [ Fact ]
306+ public async void CanHandleQueryErrorInSubscription ( ) {
311307 var port = NetworkHelpers . GetFreeTcpPortNumber ( ) ;
312308 using ( CreateServer ( port ) ) {
313309
0 commit comments