add ConnectionParams object

Author: rose-a

src/GraphQL.Client.Abstractions.Websocket/GraphQLWebSocketRequest.cs

@@ -34,9 +34,9 @@ public string Type
         /// <summary>
         /// The payload of the websocket request
         /// </summary>
-        public GraphQLRequest Payload
+        public object Payload
         {
-            get => ContainsKey(PAYLOAD_KEY) ? (GraphQLRequest)this[PAYLOAD_KEY] : null;
+            get => ContainsKey(PAYLOAD_KEY) ? this[PAYLOAD_KEY] : null;
             set => this[PAYLOAD_KEY] = value;
         }
 

src/GraphQL.Client/GraphQLHttpClientOptions.cs

@@ -56,5 +56,11 @@ public class GraphQLHttpClientOptions
         /// Configure additional websocket options (i.e. headers). This will not be invoked on Windows 7 when targeting .NET Framework 4.x. 
         /// </summary>
         public Action<ClientWebSocketOptions> ConfigureWebsocketOptions { get; set; } = options => { };
+
+        /// <summary>
+        /// The `ConnectionParams` object sent with the GQL_CONNECTION_INIT message on establishing a websocket connection.
+        /// See https://github.com/apollographql/subscriptions-transport-ws/blob/master/PROTOCOL.md#gql_connection_init.
+        /// </summary>
+        public object? WebSocketConnectionParams { get; set; } = null;
     }
 }

src/GraphQL.Client/Websocket/GraphQLHttpWebSocket.cs

@@ -105,7 +105,7 @@ public IObservable<GraphQLResponse<TResponse>> CreateSubscriptionStream<TRespons
                             Type = GraphQLWebSocketMessageType.GQL_START,
                             Payload = request
                         };
-                        var closeRequest = new GraphQLWebSocketRequest
+                        var stopRequest = new GraphQLWebSocketRequest
                         {
                             Id = startRequest.Id,
                             Type = GraphQLWebSocketMessageType.GQL_STOP
@@ -114,7 +114,7 @@ public IObservable<GraphQLResponse<TResponse>> CreateSubscriptionStream<TRespons
                         {
                             Id = startRequest.Id,
                             Type = GraphQLWebSocketMessageType.GQL_CONNECTION_INIT,
-                            Payload = new GraphQLRequest()
+                            Payload = Options.WebSocketConnectionParams
                         };
 
                         var observable = Observable.Create<GraphQLResponse<TResponse>>(o =>
@@ -179,8 +179,8 @@ public IObservable<GraphQLResponse<TResponse>> CreateSubscriptionStream<TRespons
 
                                 try
                                 {
-                                    Debug.WriteLine($"sending close message on subscription {startRequest.Id}");
-                                    await QueueWebSocketRequest(closeRequest);
+                                    Debug.WriteLine($"sending stop message on subscription {startRequest.Id}");
+                                    await QueueWebSocketRequest(stopRequest);
                                 }
                                 // do not break on disposing
                                 catch (OperationCanceledException) { }