Add support for input extensions; light refactoring (#746)

Shane32 · web-flow · commit 231b8a576f0a · 2022-03-02T11:08:26.000-05:00
diff --git a/src/Core/BasicGraphQLExecuter.cs b/src/Core/BasicGraphQLExecuter.cs
@@ -3,6 +3,7 @@
 using System.Threading;
 using System.Threading.Tasks;
 using GraphQL.Instrumentation;
+using GraphQL.Transport;
 using GraphQL.Types;
 using Microsoft.Extensions.Options;
 
@@ -27,11 +28,11 @@ public BasicGraphQLExecuter(
             _options = options.Value;
         }
 
-        public virtual async Task<ExecutionResult> ExecuteAsync(string operationName, string query, Inputs variables, IDictionary<string, object> context, IServiceProvider requestServices, CancellationToken cancellationToken = default)
+        public virtual async Task<ExecutionResult> ExecuteAsync(GraphQLRequest request, IDictionary<string, object> context, IServiceProvider requestServices, CancellationToken cancellationToken = default)
         {
             var start = DateTime.UtcNow;
 
-            var options = GetOptions(operationName, query, variables, context, requestServices, cancellationToken);
+            var options = GetOptions(request, context, requestServices, cancellationToken);
             var result = await _documentExecuter.ExecuteAsync(options);
 
             if (options.EnableMetrics)
@@ -42,14 +43,15 @@ public virtual async Task<ExecutionResult> ExecuteAsync(string operationName, st
             return result;
         }
 
-        protected virtual ExecutionOptions GetOptions(string operationName, string query, Inputs variables, IDictionary<string, object> context, IServiceProvider requestServices, CancellationToken cancellationToken)
+        protected virtual ExecutionOptions GetOptions(GraphQLRequest request, IDictionary<string, object> context, IServiceProvider requestServices, CancellationToken cancellationToken)
         {
             var opts = new ExecutionOptions
             {
                 Schema = Schema,
-                OperationName = operationName,
-                Query = query,
-                Variables = variables,
+                OperationName = request.OperationName,
+                Query = request.Query,
+                Variables = request.Variables,
+                Extensions = request.Extensions,
                 UserContext = context,
                 CancellationToken = cancellationToken,
                 ComplexityConfiguration = _options.ComplexityConfiguration,
diff --git a/src/Core/DefaultGraphQLExecuter.cs b/src/Core/DefaultGraphQLExecuter.cs
@@ -5,6 +5,7 @@
 using System.Threading.Tasks;
 using GraphQL.Execution;
 using GraphQL.Instrumentation;
+using GraphQL.Transport;
 using GraphQL.Types;
 using GraphQL.Validation;
 using Microsoft.Extensions.Options;
@@ -37,11 +38,11 @@ public DefaultGraphQLExecuter(
             _validationRules = validationRules;
         }
 
-        public virtual async Task<ExecutionResult> ExecuteAsync(string operationName, string query, Inputs variables, IDictionary<string, object> context, IServiceProvider requestServices, CancellationToken cancellationToken = default)
+        public virtual async Task<ExecutionResult> ExecuteAsync(GraphQLRequest request, IDictionary<string, object> context, IServiceProvider requestServices, CancellationToken cancellationToken = default)
         {
             var start = DateTime.UtcNow;
 
-            var options = GetOptions(operationName, query, variables, context, requestServices, cancellationToken);
+            var options = GetOptions(request, context, requestServices, cancellationToken);
             var result = await _documentExecuter.ExecuteAsync(options);
 
             if (options.EnableMetrics)
@@ -52,14 +53,15 @@ public virtual async Task<ExecutionResult> ExecuteAsync(string operationName, st
             return result;
         }
 
-        protected virtual ExecutionOptions GetOptions(string operationName, string query, Inputs variables, IDictionary<string, object> context, IServiceProvider requestServices, CancellationToken cancellationToken)
+        protected virtual ExecutionOptions GetOptions(GraphQLRequest request, IDictionary<string, object> context, IServiceProvider requestServices, CancellationToken cancellationToken)
         {
             var opts = new ExecutionOptions
             {
                 Schema = Schema,
-                OperationName = operationName,
-                Query = query,
-                Variables = variables,
+                OperationName = request.OperationName,
+                Query = request.Query,
+                Variables = request.Variables,
+                Extensions = request.Extensions,
                 UserContext = context,
                 CancellationToken = cancellationToken,
                 ComplexityConfiguration = _options.ComplexityConfiguration,
diff --git a/src/Core/IGraphQLExecuter.cs b/src/Core/IGraphQLExecuter.cs
@@ -2,6 +2,7 @@
 using System.Collections.Generic;
 using System.Threading;
 using System.Threading.Tasks;
+using GraphQL.Transport;
 using GraphQL.Types;
 
 namespace GraphQL.Server
@@ -14,14 +15,7 @@ public interface IGraphQLExecuter
         /// <summary>
         /// Execute operation
         /// </summary>
-        /// <param name="operationName"></param>
-        /// <param name="query"></param>
-        /// <param name="variables"></param>
-        /// <param name="context"></param>
-        /// <param name="requestServices"></param>
-        /// <param name="cancellationToken"></param>
-        /// <returns></returns>
-        Task<ExecutionResult> ExecuteAsync(string operationName, string query, Inputs variables, IDictionary<string, object> context, IServiceProvider requestServices, CancellationToken cancellationToken = default);
+        Task<ExecutionResult> ExecuteAsync(GraphQLRequest request, IDictionary<string, object> context, IServiceProvider requestServices, CancellationToken cancellationToken = default);
     }
 
     public interface IGraphQLExecuter<TSchema> : IGraphQLExecuter
diff --git a/src/Transports.AspNetCore/GraphQLHttpMiddleware.cs b/src/Transports.AspNetCore/GraphQLHttpMiddleware.cs
@@ -227,11 +227,9 @@ protected virtual Task HandleInvalidContentTypeErrorAsync(HttpContext context)
         protected virtual Task HandleInvalidHttpMethodErrorAsync(HttpContext context)
             => WriteErrorResponseAsync(context, $"Invalid HTTP method. Only GET and POST are supported. {DOCS_URL}", HttpStatusCode.MethodNotAllowed);
 
-        private static Task<ExecutionResult> ExecuteRequestAsync(GraphQLRequest gqlRequest, IDictionary<string, object> userContext, IGraphQLExecuter<TSchema> executer, IServiceProvider requestServices, CancellationToken token)
+        protected virtual Task<ExecutionResult> ExecuteRequestAsync(GraphQLRequest gqlRequest, IDictionary<string, object> userContext, IGraphQLExecuter<TSchema> executer, IServiceProvider requestServices, CancellationToken token)
             => executer.ExecuteAsync(
-                gqlRequest.OperationName,
-                gqlRequest.Query,
-                gqlRequest.Variables,
+                gqlRequest,
                 userContext,
                 requestServices,
                 token);
diff --git a/src/Transports.Subscriptions.Abstractions/SubscriptionManager.cs b/src/Transports.Subscriptions.Abstractions/SubscriptionManager.cs
@@ -94,9 +94,7 @@ private async Task<Subscription> ExecuteAsync(
             using (var scope = _serviceScopeFactory.CreateScope())
             {
                 result = await _executer.ExecuteAsync(
-                    payload.OperationName,
-                    payload.Query,
-                    payload.Variables,
+                    payload,
                     context,
                     scope.ServiceProvider
                 ).ConfigureAwait(false);
diff --git a/tests/ApiApprovalTests/GraphQL.Server.Core.approved.txt b/tests/ApiApprovalTests/GraphQL.Server.Core.approved.txt
@@ -5,8 +5,8 @@ namespace GraphQL.Server
     {
         public BasicGraphQLExecuter(TSchema schema, GraphQL.IDocumentExecuter documentExecuter, Microsoft.Extensions.Options.IOptions<GraphQL.Server.GraphQLOptions> options) { }
         public TSchema Schema { get; }
-        public virtual System.Threading.Tasks.Task<GraphQL.ExecutionResult> ExecuteAsync(string operationName, string query, GraphQL.Inputs variables, System.Collections.Generic.IDictionary<string, object> context, System.IServiceProvider requestServices, System.Threading.CancellationToken cancellationToken = default) { }
-        protected virtual GraphQL.ExecutionOptions GetOptions(string operationName, string query, GraphQL.Inputs variables, System.Collections.Generic.IDictionary<string, object> context, System.IServiceProvider requestServices, System.Threading.CancellationToken cancellationToken) { }
+        public virtual System.Threading.Tasks.Task<GraphQL.ExecutionResult> ExecuteAsync(GraphQL.Transport.GraphQLRequest request, System.Collections.Generic.IDictionary<string, object> context, System.IServiceProvider requestServices, System.Threading.CancellationToken cancellationToken = default) { }
+        protected virtual GraphQL.ExecutionOptions GetOptions(GraphQL.Transport.GraphQLRequest request, System.Collections.Generic.IDictionary<string, object> context, System.IServiceProvider requestServices, System.Threading.CancellationToken cancellationToken) { }
     }
     public class DefaultErrorInfoProvider : GraphQL.Execution.ErrorInfoProvider
     {
@@ -18,8 +18,8 @@ namespace GraphQL.Server
     {
         public DefaultGraphQLExecuter(TSchema schema, GraphQL.IDocumentExecuter documentExecuter, Microsoft.Extensions.Options.IOptions<GraphQL.Server.GraphQLOptions> options, System.Collections.Generic.IEnumerable<GraphQL.Execution.IDocumentExecutionListener> listeners, System.Collections.Generic.IEnumerable<GraphQL.Validation.IValidationRule> validationRules) { }
         public TSchema Schema { get; }
-        public virtual System.Threading.Tasks.Task<GraphQL.ExecutionResult> ExecuteAsync(string operationName, string query, GraphQL.Inputs variables, System.Collections.Generic.IDictionary<string, object> context, System.IServiceProvider requestServices, System.Threading.CancellationToken cancellationToken = default) { }
-        protected virtual GraphQL.ExecutionOptions GetOptions(string operationName, string query, GraphQL.Inputs variables, System.Collections.Generic.IDictionary<string, object> context, System.IServiceProvider requestServices, System.Threading.CancellationToken cancellationToken) { }
+        public virtual System.Threading.Tasks.Task<GraphQL.ExecutionResult> ExecuteAsync(GraphQL.Transport.GraphQLRequest request, System.Collections.Generic.IDictionary<string, object> context, System.IServiceProvider requestServices, System.Threading.CancellationToken cancellationToken = default) { }
+        protected virtual GraphQL.ExecutionOptions GetOptions(GraphQL.Transport.GraphQLRequest request, System.Collections.Generic.IDictionary<string, object> context, System.IServiceProvider requestServices, System.Threading.CancellationToken cancellationToken) { }
     }
     public static class GraphQLBuilderCoreExtensions
     {
@@ -36,7 +36,7 @@ namespace GraphQL.Server
     }
     public interface IGraphQLExecuter
     {
-        System.Threading.Tasks.Task<GraphQL.ExecutionResult> ExecuteAsync(string operationName, string query, GraphQL.Inputs variables, System.Collections.Generic.IDictionary<string, object> context, System.IServiceProvider requestServices, System.Threading.CancellationToken cancellationToken = default);
+        System.Threading.Tasks.Task<GraphQL.ExecutionResult> ExecuteAsync(GraphQL.Transport.GraphQLRequest request, System.Collections.Generic.IDictionary<string, object> context, System.IServiceProvider requestServices, System.Threading.CancellationToken cancellationToken = default);
     }
     public interface IGraphQLExecuter<TSchema> : GraphQL.Server.IGraphQLExecuter
         where TSchema : GraphQL.Types.ISchema
diff --git a/tests/ApiApprovalTests/GraphQL.Server.Transports.AspNetCore.approved.txt b/tests/ApiApprovalTests/GraphQL.Server.Transports.AspNetCore.approved.txt
@@ -25,6 +25,7 @@ namespace GraphQL.Server.Transports.AspNetCore
         where TSchema : GraphQL.Types.ISchema
     {
         public GraphQLHttpMiddleware(GraphQL.IGraphQLTextSerializer serializer) { }
+        protected virtual System.Threading.Tasks.Task<GraphQL.ExecutionResult> ExecuteRequestAsync(GraphQL.Transport.GraphQLRequest gqlRequest, System.Collections.Generic.IDictionary<string, object> userContext, GraphQL.Server.IGraphQLExecuter<TSchema> executer, System.IServiceProvider requestServices, System.Threading.CancellationToken token) { }
         protected virtual System.Threading.CancellationToken GetCancellationToken(Microsoft.AspNetCore.Http.HttpContext context) { }
         protected virtual System.Threading.Tasks.Task HandleContentTypeCouldNotBeParsedErrorAsync(Microsoft.AspNetCore.Http.HttpContext context) { }
         protected virtual System.Threading.Tasks.ValueTask<bool> HandleDeserializationErrorAsync(Microsoft.AspNetCore.Http.HttpContext context, System.Exception ex) { }
diff --git a/tests/Transports.Subscriptions.Abstractions.Tests/ProtocolHandlerFacts.cs b/tests/Transports.Subscriptions.Abstractions.Tests/ProtocolHandlerFacts.cs
@@ -27,7 +27,7 @@ public ProtocolHandlerFacts()
             _transportReader = _transport.Reader as TestableReader;
             _transportWriter = _transport.Writer as TestableWriter;
             _documentExecuter = Substitute.For<IGraphQLExecuter>();
-            _documentExecuter.ExecuteAsync(null, null, null, null, null).ReturnsForAnyArgs(
+            _documentExecuter.ExecuteAsync(null, null, null).ReturnsForAnyArgs(
                 new SubscriptionExecutionResult
                 {
                     Streams = new Dictionary<string, IObservable<ExecutionResult>>
@@ -67,7 +67,7 @@ public async Task Receive_init()
         public async Task Receive_start_mutation()
         {
             /* Given */
-            _documentExecuter.ExecuteAsync(null, null, null, null, null).ReturnsForAnyArgs(
+            _documentExecuter.ExecuteAsync(null, null, null).ReturnsForAnyArgs(
                 new ExecutionResult());
             var expected = new OperationMessage
             {
@@ -104,7 +104,7 @@ public async Task Receive_start_mutation()
         public async Task Receive_start_query()
         {
             /* Given */
-            _documentExecuter.ExecuteAsync(null, null, null, null, null).ReturnsForAnyArgs(
+            _documentExecuter.ExecuteAsync(null, null, null).ReturnsForAnyArgs(
                 new ExecutionResult());
             var expected = new OperationMessage
             {
diff --git a/tests/Transports.Subscriptions.Abstractions.Tests/SubscriptionManagerFacts.cs b/tests/Transports.Subscriptions.Abstractions.Tests/SubscriptionManagerFacts.cs
@@ -15,7 +15,7 @@ public SubscriptionManagerFacts()
         {
             _writer = Substitute.For<IWriterPipeline>();
             _executer = Substitute.For<IGraphQLExecuter>();
-            _executer.ExecuteAsync(null, null, null, null, null).ReturnsForAnyArgs(
+            _executer.ExecuteAsync(null, null, null).ReturnsForAnyArgs(
                 new SubscriptionExecutionResult
                 {
                     Streams = new Dictionary<string, IObservable<ExecutionResult>>
@@ -40,7 +40,7 @@ public async Task Failed_Subscribe_does_not_add()
             var payload = new GraphQLRequest();
             var context = new MessageHandlingContext(_server, null);
 
-            _executer.ExecuteAsync(null, null, null, null, null).ReturnsForAnyArgs(
+            _executer.ExecuteAsync(null, null, null).ReturnsForAnyArgs(
                 new SubscriptionExecutionResult
                 {
                     Errors = new ExecutionErrors
@@ -64,7 +64,7 @@ public async Task Failed_Subscribe_with_null_stream()
             var payload = new GraphQLRequest();
             var context = new MessageHandlingContext(_server, null);
 
-            _executer.ExecuteAsync(null, null, null, null, null).ReturnsForAnyArgs(
+            _executer.ExecuteAsync(null, null, null).ReturnsForAnyArgs(
                 new SubscriptionExecutionResult
                 {
                     Streams = new Dictionary<string, IObservable<ExecutionResult>>
@@ -91,7 +91,7 @@ public async Task Failed_Subscribe_writes_error()
             var payload = new GraphQLRequest();
             var context = new MessageHandlingContext(_server, null);
 
-            _executer.ExecuteAsync(null, null, null, null, null).ReturnsForAnyArgs(
+            _executer.ExecuteAsync(null, null, null).ReturnsForAnyArgs(
                 new SubscriptionExecutionResult
                 {
                     Errors = new ExecutionErrors
@@ -138,9 +138,7 @@ public async Task Subscribe_executes()
 
             /* Then */
             await _executer.Received().ExecuteAsync(
-                Arg.Is(payload.OperationName),
-                Arg.Is(payload.Query),
-                Arg.Any<Inputs>(),
+                Arg.Is(payload),
                 context,
                 null);
         }
diff --git a/tests/Transports.Subscriptions.Abstractions.Tests/SubscriptionServerFacts.cs b/tests/Transports.Subscriptions.Abstractions.Tests/SubscriptionServerFacts.cs
@@ -18,7 +18,7 @@ public SubscriptionServerFacts()
             _transportReader = _transport.Reader as TestableReader;
             _transportWriter = _transport.Writer as TestableWriter;
             _documentExecuter = Substitute.For<IGraphQLExecuter>();
-            _documentExecuter.ExecuteAsync(null, null, null, null, null).ReturnsForAnyArgs(
+            _documentExecuter.ExecuteAsync(null, null, null).ReturnsForAnyArgs(
                 new SubscriptionExecutionResult
                 {
                     Streams = new Dictionary<string, IObservable<ExecutionResult>>

Original file line number	Diff line number	Diff line change
`@@ -5,8 +5,8 @@ namespace GraphQL.Server`
`5`	`5`	`{`
`6`	`6`	`public BasicGraphQLExecuter(TSchema schema, GraphQL.IDocumentExecuter documentExecuter, Microsoft.Extensions.Options.IOptions<GraphQL.Server.GraphQLOptions> options) { }`
`7`	`7`	`public TSchema Schema { get; }`
`8`		`- public virtual System.Threading.Tasks.Task<GraphQL.ExecutionResult> ExecuteAsync(string operationName, string query, GraphQL.Inputs variables, System.Collections.Generic.IDictionary<string, object> context, System.IServiceProvider requestServices, System.Threading.CancellationToken cancellationToken = default) { }`
`9`		`- protected virtual GraphQL.ExecutionOptions GetOptions(string operationName, string query, GraphQL.Inputs variables, System.Collections.Generic.IDictionary<string, object> context, System.IServiceProvider requestServices, System.Threading.CancellationToken cancellationToken) { }`
	`8`	`+ public virtual System.Threading.Tasks.Task<GraphQL.ExecutionResult> ExecuteAsync(GraphQL.Transport.GraphQLRequest request, System.Collections.Generic.IDictionary<string, object> context, System.IServiceProvider requestServices, System.Threading.CancellationToken cancellationToken = default) { }`
	`9`	`+ protected virtual GraphQL.ExecutionOptions GetOptions(GraphQL.Transport.GraphQLRequest request, System.Collections.Generic.IDictionary<string, object> context, System.IServiceProvider requestServices, System.Threading.CancellationToken cancellationToken) { }`
`10`	`10`	`}`
`11`	`11`	`public class DefaultErrorInfoProvider : GraphQL.Execution.ErrorInfoProvider`
`12`	`12`	`{`
`@@ -18,8 +18,8 @@ namespace GraphQL.Server`
`18`	`18`	`{`
`19`	`19`	`public DefaultGraphQLExecuter(TSchema schema, GraphQL.IDocumentExecuter documentExecuter, Microsoft.Extensions.Options.IOptions<GraphQL.Server.GraphQLOptions> options, System.Collections.Generic.IEnumerable<GraphQL.Execution.IDocumentExecutionListener> listeners, System.Collections.Generic.IEnumerable<GraphQL.Validation.IValidationRule> validationRules) { }`
`20`	`20`	`public TSchema Schema { get; }`
`21`		`- public virtual System.Threading.Tasks.Task<GraphQL.ExecutionResult> ExecuteAsync(string operationName, string query, GraphQL.Inputs variables, System.Collections.Generic.IDictionary<string, object> context, System.IServiceProvider requestServices, System.Threading.CancellationToken cancellationToken = default) { }`
`22`		`- protected virtual GraphQL.ExecutionOptions GetOptions(string operationName, string query, GraphQL.Inputs variables, System.Collections.Generic.IDictionary<string, object> context, System.IServiceProvider requestServices, System.Threading.CancellationToken cancellationToken) { }`
	`21`	`+ public virtual System.Threading.Tasks.Task<GraphQL.ExecutionResult> ExecuteAsync(GraphQL.Transport.GraphQLRequest request, System.Collections.Generic.IDictionary<string, object> context, System.IServiceProvider requestServices, System.Threading.CancellationToken cancellationToken = default) { }`
	`22`	`+ protected virtual GraphQL.ExecutionOptions GetOptions(GraphQL.Transport.GraphQLRequest request, System.Collections.Generic.IDictionary<string, object> context, System.IServiceProvider requestServices, System.Threading.CancellationToken cancellationToken) { }`
`23`	`23`	`}`
`24`	`24`	`public static class GraphQLBuilderCoreExtensions`
`25`	`25`	`{`
`@@ -36,7 +36,7 @@ namespace GraphQL.Server`
`36`	`36`	`}`
`37`	`37`	`public interface IGraphQLExecuter`
`38`	`38`	`{`
`39`		`- System.Threading.Tasks.Task<GraphQL.ExecutionResult> ExecuteAsync(string operationName, string query, GraphQL.Inputs variables, System.Collections.Generic.IDictionary<string, object> context, System.IServiceProvider requestServices, System.Threading.CancellationToken cancellationToken = default);`
	`39`	`+ System.Threading.Tasks.Task<GraphQL.ExecutionResult> ExecuteAsync(GraphQL.Transport.GraphQLRequest request, System.Collections.Generic.IDictionary<string, object> context, System.IServiceProvider requestServices, System.Threading.CancellationToken cancellationToken = default);`
`40`	`40`	`}`
`41`	`41`	`public interface IGraphQLExecuter<TSchema> : GraphQL.Server.IGraphQLExecuter`
`42`	`42`	`where TSchema : GraphQL.Types.ISchema`
Original file line number	Diff line number	Diff line change
`@@ -25,6 +25,7 @@ namespace GraphQL.Server.Transports.AspNetCore`
`25`	`25`	`where TSchema : GraphQL.Types.ISchema`
`26`	`26`	`{`
`27`	`27`	`public GraphQLHttpMiddleware(GraphQL.IGraphQLTextSerializer serializer) { }`
	`28`	`+ protected virtual System.Threading.Tasks.Task<GraphQL.ExecutionResult> ExecuteRequestAsync(GraphQL.Transport.GraphQLRequest gqlRequest, System.Collections.Generic.IDictionary<string, object> userContext, GraphQL.Server.IGraphQLExecuter<TSchema> executer, System.IServiceProvider requestServices, System.Threading.CancellationToken token) { }`
`28`	`29`	`protected virtual System.Threading.CancellationToken GetCancellationToken(Microsoft.AspNetCore.Http.HttpContext context) { }`
`29`	`30`	`protected virtual System.Threading.Tasks.Task HandleContentTypeCouldNotBeParsedErrorAsync(Microsoft.AspNetCore.Http.HttpContext context) { }`
`30`	`31`	`protected virtual System.Threading.Tasks.ValueTask<bool> HandleDeserializationErrorAsync(Microsoft.AspNetCore.Http.HttpContext context, System.Exception ex) { }`
Original file line number	Diff line number	Diff line change
`@@ -27,7 +27,7 @@ public ProtocolHandlerFacts()`
`27`	`27`	`_transportReader = _transport.Reader as TestableReader;`
`28`	`28`	`_transportWriter = _transport.Writer as TestableWriter;`
`29`	`29`	`_documentExecuter = Substitute.For<IGraphQLExecuter>();`
`30`		`- _documentExecuter.ExecuteAsync(null, null, null, null, null).ReturnsForAnyArgs(`
	`30`	`+ _documentExecuter.ExecuteAsync(null, null, null).ReturnsForAnyArgs(`
`31`	`31`	`new SubscriptionExecutionResult`
`32`	`32`	`{`
`33`	`33`	`Streams = new Dictionary<string, IObservable<ExecutionResult>>`
`@@ -67,7 +67,7 @@ public async Task Receive_init()`
`67`	`67`	`public async Task Receive_start_mutation()`
`68`	`68`	`{`
`69`	`69`	`/* Given */`
`70`		`- _documentExecuter.ExecuteAsync(null, null, null, null, null).ReturnsForAnyArgs(`
	`70`	`+ _documentExecuter.ExecuteAsync(null, null, null).ReturnsForAnyArgs(`
`71`	`71`	`new ExecutionResult());`
`72`	`72`	`var expected = new OperationMessage`
`73`	`73`	`{`
`@@ -104,7 +104,7 @@ public async Task Receive_start_mutation()`
`104`	`104`	`public async Task Receive_start_query()`
`105`	`105`	`{`
`106`	`106`	`/* Given */`
`107`		`- _documentExecuter.ExecuteAsync(null, null, null, null, null).ReturnsForAnyArgs(`
	`107`	`+ _documentExecuter.ExecuteAsync(null, null, null).ReturnsForAnyArgs(`
`108`	`108`	`new ExecutionResult());`
`109`	`109`	`var expected = new OperationMessage`
`110`	`110`	`{`
Original file line number	Diff line number	Diff line change
`@@ -18,7 +18,7 @@ public SubscriptionServerFacts()`
`18`	`18`	`_transportReader = _transport.Reader as TestableReader;`
`19`	`19`	`_transportWriter = _transport.Writer as TestableWriter;`
`20`	`20`	`_documentExecuter = Substitute.For<IGraphQLExecuter>();`
`21`		`- _documentExecuter.ExecuteAsync(null, null, null, null, null).ReturnsForAnyArgs(`
	`21`	`+ _documentExecuter.ExecuteAsync(null, null, null).ReturnsForAnyArgs(`
`22`	`22`	`new SubscriptionExecutionResult`
`23`	`23`	`{`
`24`	`24`	`Streams = new Dictionary<string, IObservable<ExecutionResult>>`