Add: Mutable composite JSON document

src/All.slnx

@@ -47,7 +47,6 @@
     <Project Path="HotChocolate/AspNetCore/src/Transport.Sockets.Client/HotChocolate.Transport.Sockets.Client.csproj" />
     <Project Path="HotChocolate/AspNetCore/src/Transport.Sockets/HotChocolate.Transport.Sockets.csproj" />
   </Folder>
-  <Folder Name="/HotChocolate/AspNetCore/src/AspNetCore/" />
   <Folder Name="/HotChocolate/AspNetCore/test/">
     <Project Path="HotChocolate/AspNetCore/test/AspNetCore.Authorization.Opa.Tests/HotChocolate.AspNetCore.Authorization.Opa.Tests.csproj" />
     <Project Path="HotChocolate/AspNetCore/test/AspNetCore.Authorization.Tests/HotChocolate.AspNetCore.Authorization.Tests.csproj" />
@@ -175,6 +174,9 @@
     <Project Path="HotChocolate/Diagnostics/test/Diagnostics.Tests/HotChocolate.Diagnostics.Tests.csproj" />
   </Folder>
   <Folder Name="/HotChocolate/Fusion-vnext/" />
+  <Folder Name="/HotChocolate/Fusion-vnext/benchmarks/">
+    <Project Path="HotChocolate/Fusion-vnext/benchmarks/Fusion.Execution.Benchmarks/Fusion.Execution.Benchmarks.csproj" />
+  </Folder>
   <Folder Name="/HotChocolate/Fusion-vnext/src/">
     <Project Path="HotChocolate/Fusion-vnext/src/Fusion.Aspire/HotChocolate.Fusion.Aspire.csproj" />
     <Project Path="HotChocolate/Fusion-vnext/src/Fusion.AspNetCore/HotChocolate.Fusion.AspNetCore.csproj" />
@@ -188,13 +190,22 @@
   <Folder Name="/HotChocolate/Fusion-vnext/test/">
     <Project Path="HotChocolate/Fusion-vnext/test/Fusion.AspNetCore.Tests/HotChocolate.Fusion.AspNetCore.Tests.csproj" />
     <Project Path="HotChocolate/Fusion-vnext/test/Fusion.Composition.Tests/HotChocolate.Fusion.Composition.Tests.csproj" />
-    <Project Path="HotChocolate/Fusion-vnext/test/Fusion.Execution.Tests/HotChocolate.Fusion.Execution.Tests.csproj" />
     <Project Path="HotChocolate/Fusion-vnext/test/Fusion.EventSources.Tests/HotChocolate.Fusion.EventSources.Tests.csproj" />
+    <Project Path="HotChocolate/Fusion-vnext/test/Fusion.Execution.Tests/HotChocolate.Fusion.Execution.Tests.csproj" />
     <Project Path="HotChocolate/Fusion-vnext/test/Fusion.Language.Tests/HotChocolate.Fusion.Language.Tests.csproj" />
     <Project Path="HotChocolate/Fusion-vnext/test/Fusion.Packaging.Tests/HotChocolate.Fusion.Packaging.Tests.csproj" />
     <Project Path="HotChocolate/Fusion-vnext/test/Fusion.Utilities.Tests/HotChocolate.Fusion.Utilities.Tests.csproj" />
     <Project Path="HotChocolate/Fusion-vnext/test/Fusion.Tests.Shared/HotChocolate.Fusion.Tests.Shared.csproj" />
   </Folder>
+  <Folder Name="/HotChocolate/Json/" />
+  <Folder Name="/HotChocolate/Json/src/" />
+  <Folder Name="/HotChocolate/Json/src/Json/">
+    <Project Path="HotChocolate/Json/src/Json/HotChocolate.Text.Json.csproj" />
+  </Folder>
+  <Folder Name="/HotChocolate/Json/test/" />
+  <Folder Name="/HotChocolate/Json/test/Json.Tests/">
+    <Project Path="HotChocolate/Json/test/Json.Tests/HotChocolate.Text.Json.Tests.csproj" />
+  </Folder>
   <Folder Name="/HotChocolate/Language/" />
   <Folder Name="/HotChocolate/Language/src/">
     <Project Path="HotChocolate/Language/src/Language.SyntaxTree/HotChocolate.Language.SyntaxTree.csproj" />
@@ -288,12 +299,12 @@
   </Folder>
   <Folder Name="/HotChocolate/Utilities/" />
   <Folder Name="/HotChocolate/Utilities/src/">
+    <Project Path="HotChocolate/Utilities/src/Utilities.Base36/HotChocolate.Utilities.Base36.csproj" />
     <Project Path="HotChocolate/Utilities/src/Utilities.Buffers/HotChocolate.Utilities.Buffers.csproj" />
     <Project Path="HotChocolate/Utilities/src/Utilities.DependencyInjection/HotChocolate.Utilities.DependencyInjection.csproj" />
     <Project Path="HotChocolate/Utilities/src/Utilities.Introspection/HotChocolate.Utilities.Introspection.csproj" />
     <Project Path="HotChocolate/Utilities/src/Utilities.Tasks/HotChocolate.Utilities.Tasks.csproj" />
     <Project Path="HotChocolate/Utilities/src/Utilities/HotChocolate.Utilities.csproj" />
-    <Project Path="HotChocolate/Utilities/src/Utilities.Base36/HotChocolate.Utilities.Base36.csproj" />
   </Folder>
   <Folder Name="/HotChocolate/Utilities/test/">
     <Project Path="HotChocolate/Utilities/test/Utilities.Introspection.Tests/HotChocolate.Utilities.Introspection.Tests.csproj" />
@@ -353,4 +364,4 @@
   <Folder Name="/StrawberryShake/Tooling/test/">
     <Project Path="StrawberryShake/Tooling/test/Configuration.Tests/StrawberryShake.Tools.Configuration.Tests.csproj" />
   </Folder>
-</Solution>
+</Solution>

src/HotChocolate/AspNetCore/src/AspNetCore.Pipeline/Extensions/HttpContextExtensions.cs

@@ -26,7 +26,6 @@ public static bool IncludeOperationPlan(this HttpContext context)
         return false;
     }
 
-    // TODO : Implement this
     public static string? TryGetCostSwitch(this HttpContext context)
     {
         var headers = context.Request.Headers;

src/HotChocolate/AspNetCore/src/AspNetCore.Pipeline/Formatters/DefaultHttpResponseFormatter.cs

@@ -224,7 +224,7 @@ private async ValueTask FormatInternalAsync(
 
                 OnWriteResponseHeaders(operationResult, format, response.Headers);
 
-                await format.Formatter.FormatAsync(result, response.Body, cancellationToken);
+                await format.Formatter.FormatAsync(result, response.BodyWriter, cancellationToken);
                 break;
             }
 
@@ -238,7 +238,7 @@ private async ValueTask FormatInternalAsync(
                 OnWriteResponseHeaders(resultBatch, format, response.Headers);
                 await response.Body.FlushAsync(cancellationToken);
 
-                await format.Formatter.FormatAsync(result, response.Body, cancellationToken);
+                await format.Formatter.FormatAsync(result, response.BodyWriter, cancellationToken);
                 break;
             }
 
@@ -252,7 +252,7 @@ private async ValueTask FormatInternalAsync(
                 OnWriteResponseHeaders(responseStream, format, response.Headers);
                 await response.Body.FlushAsync(cancellationToken);
 
-                await format.Formatter.FormatAsync(result, response.Body, cancellationToken);
+                await format.Formatter.FormatAsync(result, response.BodyWriter, cancellationToken);
                 break;
             }
 

src/HotChocolate/AspNetCore/src/AspNetCore.Pipeline/HttpMultipartMiddleware.cs

@@ -80,8 +80,7 @@ protected override async ValueTask<IReadOnlyList<GraphQLRequest>> ParseRequestsF
 
         // Parse the string values of interest from the IFormCollection
         var multipartRequest = ParseMultipartRequest(form);
-        var requests = session.RequestParser.ParseRequest(
-            multipartRequest.Operations);
+        var requests = session.RequestParser.ParseRequest(multipartRequest.Operations);
 
         foreach (var graphQLRequest in requests)
         {

src/HotChocolate/AspNetCore/src/AspNetCore.Pipeline/HttpPostMiddlewareBase.cs

@@ -221,9 +221,9 @@ protected async Task HandleRequestAsync(HttpContext context, ExecutorSession ses
             // to the HTTP response stream.
             Debug.Assert(result is not null, "No GraphQL result was created.");
 
-            if (result is IOperationResult queryResult)
+            if (result is IOperationResult operationResult)
             {
-                formatScope = session.DiagnosticEvents.FormatHttpResponse(context, queryResult);
+                formatScope = session.DiagnosticEvents.FormatHttpResponse(context, operationResult);
             }
 
             await session.WriteResultAsync(context, result, acceptMediaTypes, statusCode);

src/HotChocolate/AspNetCore/src/Transport.Abstractions/HotChocolate.Transport.Abstractions.csproj

@@ -15,6 +15,7 @@
     <InternalsVisibleTo Include="HotChocolate.Transport.Http" />
     <InternalsVisibleTo Include="HotChocolate.Transport.Sockets" />
     <InternalsVisibleTo Include="HotChocolate.Transport.Sockets.Client" />
+    <InternalsVisibleTo Include="HotChocolate.Fusion.Execution" />
   </ItemGroup>
 
   <ItemGroup>

src/HotChocolate/AspNetCore/src/Transport.Formatters/EventStreamResultFormatter.cs

@@ -24,39 +24,31 @@ public sealed class EventStreamResultFormatter(JsonResultFormatterOptions option
     /// <summary>
     /// Formats an <see cref="IExecutionResult"/> into an SSE stream.
     /// </summary>
-    /// <param name="result"></param>
-    /// <param name="outputStream"></param>
-    /// <param name="cancellationToken"></param>
-    /// <returns></returns>
-    /// <exception cref="ArgumentNullException"></exception>
-    /// <exception cref="NotSupportedException"></exception>
     public ValueTask FormatAsync(
         IExecutionResult result,
-        Stream outputStream,
+        PipeWriter writer,
         CancellationToken cancellationToken = default)
     {
         ArgumentNullException.ThrowIfNull(result);
-        ArgumentNullException.ThrowIfNull(outputStream);
+        ArgumentNullException.ThrowIfNull(writer);
 
         return result switch
         {
             IOperationResult operationResult
-                => FormatOperationResultAsync(operationResult, outputStream, cancellationToken),
+                => FormatOperationResultAsync(operationResult, writer, cancellationToken),
             OperationResultBatch resultBatch
-                => FormatResultBatchAsync(resultBatch, outputStream, cancellationToken),
+                => FormatResultBatchAsync(resultBatch, writer, cancellationToken),
             IResponseStream responseStream
-                => FormatResponseStreamAsync(responseStream, outputStream, cancellationToken),
+                => FormatResponseStreamAsync(responseStream, writer, cancellationToken),
             _ => throw new NotSupportedException()
         };
     }
 
     private async ValueTask FormatOperationResultAsync(
         IOperationResult operationResult,
-        Stream outputStream,
+        PipeWriter writer,
         CancellationToken ct)
     {
-        Exception? exception = null;
-        var writer = outputStream.CreatePipeWriter();
         var scope = Log.FormatOperationResultStart();
 
         try
@@ -67,24 +59,21 @@ private async ValueTask FormatOperationResultAsync(
         catch (Exception ex)
         {
             scope?.AddError(ex);
-            exception = ex;
             throw;
         }
         finally
         {
             scope?.Dispose();
-            await writer.CompleteAsync(exception).ConfigureAwait(false);
         }
     }
 
     private async ValueTask FormatResultBatchAsync(
         OperationResultBatch resultBatch,
-        Stream outputStream,
+        PipeWriter writer,
         CancellationToken ct)
     {
         Exception? exception = null;
         using var semaphore = new SemaphoreSlim(1, 1);
-        var writer = outputStream.CreatePipeWriter();
         List<Task>? streams = null;
         KeepAliveJob? keepAlive = null;
 
@@ -157,8 +146,6 @@ private async ValueTask FormatResultBatchAsync(
             {
                 await TryWriteCompleteAsync(writer, ct).ConfigureAwait(false);
             }
-
-            await writer.CompleteAsync(exception).ConfigureAwait(false);
         }
 
         // we rethrow any stream exception that happened.
@@ -170,12 +157,11 @@ private async ValueTask FormatResultBatchAsync(
 
     private async ValueTask FormatResponseStreamAsync(
         IResponseStream responseStream,
-        Stream outputStream,
+        PipeWriter writer,
         CancellationToken ct)
     {
         Exception? exception = null;
         using var semaphore = new SemaphoreSlim(1, 1);
-        var writer = outputStream.CreatePipeWriter();
 
         try
         {
@@ -205,8 +191,6 @@ private async ValueTask FormatResponseStreamAsync(
             {
                 await TryWriteCompleteAsync(writer, ct).ConfigureAwait(false);
             }
-
-            await writer.CompleteAsync(exception).ConfigureAwait(false);
         }
     }
 

src/HotChocolate/AspNetCore/src/Transport.Formatters/JsonLinesResultFormatter.cs

@@ -10,22 +10,25 @@ public sealed class JsonLinesResultFormatter(JsonResultFormatterOptions options)
 {
     private readonly JsonResultFormatter _payloadFormatter = new(options with { Indented = false });
 
+    /// <summary>
+    /// Formats an <see cref="IExecutionResult"/> into an JSONL stream.
+    /// </summary>
     public ValueTask FormatAsync(
         IExecutionResult result,
-        Stream outputStream,
+        PipeWriter writer,
         CancellationToken cancellationToken = default)
     {
         ArgumentNullException.ThrowIfNull(result);
-        ArgumentNullException.ThrowIfNull(outputStream);
+        ArgumentNullException.ThrowIfNull(writer);
 
         return result switch
         {
             IOperationResult operationResult
-                => FormatOperationResultAsync(operationResult, outputStream, cancellationToken),
+                => FormatOperationResultAsync(operationResult, writer, cancellationToken),
             OperationResultBatch resultBatch
-                => FormatResultBatchAsync(resultBatch, outputStream, cancellationToken),
+                => FormatResultBatchAsync(resultBatch, writer, cancellationToken),
             IResponseStream responseStream
-                => FormatResponseStreamAsync(responseStream, outputStream, cancellationToken),
+                => FormatResponseStreamAsync(responseStream, writer, cancellationToken),
             _ => throw new NotSupportedException()
         };
     }
@@ -35,11 +38,9 @@ IResponseStream responseStream
     /// </summary>
     private async ValueTask FormatOperationResultAsync(
         IOperationResult operationResult,
-        Stream outputStream,
+        PipeWriter writer,
         CancellationToken ct)
     {
-        Exception? exception = null;
-        var writer = outputStream.CreatePipeWriter();
         var scope = Log.FormatOperationResultStart();
 
         try
@@ -50,13 +51,11 @@ private async ValueTask FormatOperationResultAsync(
         catch (Exception ex)
         {
             scope?.AddError(ex);
-            exception = ex;
             throw;
         }
         finally
         {
             scope?.Dispose();
-            await writer.CompleteAsync(exception).ConfigureAwait(false);
         }
     }
 
@@ -65,12 +64,11 @@ private async ValueTask FormatOperationResultAsync(
     /// </summary>
     private async ValueTask FormatResultBatchAsync(
         OperationResultBatch resultBatch,
-        Stream outputStream,
+        PipeWriter writer,
         CancellationToken ct)
     {
         Exception? exception = null;
         using var semaphore = new SemaphoreSlim(1, 1);
-        var writer = outputStream.CreatePipeWriter();
         List<Task>? streams = null;
         KeepAliveJob? keepAlive = null;
 
@@ -138,7 +136,6 @@ private async ValueTask FormatResultBatchAsync(
             var streamError = await TryCompleteStreamsAsync(streams).ConfigureAwait(false);
             exception ??= streamError;
             keepAlive?.Dispose();
-            await writer.CompleteAsync(exception).ConfigureAwait(false);
         }
 
         // we rethrow any stream exception that happened.
@@ -150,12 +147,10 @@ private async ValueTask FormatResultBatchAsync(
 
     private async ValueTask FormatResponseStreamAsync(
         IResponseStream responseStream,
-        Stream outputStream,
+        PipeWriter writer,
         CancellationToken ct)
     {
-        Exception? exception = null;
         using var semaphore = new SemaphoreSlim(1, 1);
-        var writer = outputStream.CreatePipeWriter();
 
         try
         {
@@ -167,20 +162,10 @@ private async ValueTask FormatResponseStreamAsync(
 
             await writer.FlushAsync(ct).ConfigureAwait(false);
         }
-        catch (OperationCanceledException ex)
+        catch (OperationCanceledException)
         {
             // if the operation was canceled, we do not need to log this
             // and will stop gracefully.
-            exception = ex;
-        }
-        catch (Exception ex)
-        {
-            exception = ex;
-            throw;
-        }
-        finally
-        {
-            await writer.CompleteAsync(exception).ConfigureAwait(false);
         }
     }