chore: format

src/Fluss.HotChocolate.IntegrationTest/HotChocolateTest.cs

@@ -44,9 +44,9 @@ public async Task Setup()
         Host.UseWebSockets();
         Host.MapGraphQL();
         Host.MapGraphQLWebSocket();
-        
+
         await Host.StartAsync();
-        
+
         var server = Host.Services.GetRequiredService<IServer>();
         var addressFeature = server.Features.Get<IServerAddressesFeature>();
         Address = addressFeature!.Addresses.First();
@@ -57,14 +57,14 @@ public async Task SubscriberReceivesLiveUpdates()
     {
         var tokenSource = new CancellationTokenSource();
         tokenSource.CancelAfter(30000);
-        
+
         var channel = await SubscribeToTodos(default);
-        
+
         // Receive initial response
         await channel.Reader.WaitToReadAsync(tokenSource.Token);
         var ids = await channel.Reader.ReadAsync(tokenSource.Token);
         Assert.That(ids, Is.Empty);
-        
+
         for (var i = 0; i < 10; i++)
         {
             var newId = await CreateTodo($"Todo {i}");
@@ -87,7 +87,7 @@ private async Task<Guid> CreateTodo(string todo)
             query = "mutation CreateTodo($todo: String!) { createTodo(todo: $todo) { id } }",
             variables = new { todo },
         };
-        
+
         var response = await httpClient.PostAsJsonAsync("/graphql", body);
         response.EnsureSuccessStatusCode();
 
@@ -113,7 +113,7 @@ private async Task<Channel<List<Guid>>> SubscribeToTodos(CancellationToken ct)
                 var message = Encoding.UTF8.GetString(buffer.AsSpan(0, result.Count));
 
                 if (message.Contains("connection_ack")) continue;
-                
+
                 var document = JsonDocument.Parse(message);
                 var ids = document.RootElement.GetProperty("payload").GetProperty("data").GetProperty("todos").EnumerateArray()
                     .Select(t => t.GetProperty("id").GetGuid())
@@ -127,13 +127,13 @@ private async Task<Channel<List<Guid>>> SubscribeToTodos(CancellationToken ct)
 
         const string init = """{"type":"connection_init"}""";
         await socket.SendAsync(Encoding.UTF8.GetBytes(init).AsMemory(), WebSocketMessageType.Text, true, ct);
-        
+
         const string subscription = """{"id":"0","type":"subscribe","payload":{"query":"\n  query Todos {\n todos { id } }\n","operationName":"Todos","variables":{}}}""";
         await socket.SendAsync(Encoding.UTF8.GetBytes(subscription).AsMemory(), WebSocketMessageType.Text, true, ct);
-        
+
         return channel;
     }
-    
+
     [TearDown]
     public async Task TearDown()
     {
@@ -265,7 +265,7 @@ public class TodoMutations
     public async Task<TodoRead> CreateTodo([Service] IServiceProvider serviceProvider, string todo)
     {
         var unitOfWorkFactory = serviceProvider.GetSystemUserUnitOfWorkFactory();
-        
+
         return await unitOfWorkFactory.Commit(async unitOfWork =>
         {
             var created = await TodoWrite.Create(unitOfWork, todo);

src/Fluss.HotChocolate/AddExtensionMiddleware.cs

@@ -61,7 +61,7 @@ private IReadOnlyCollection<EventListener> GetCurrentListeners(IReadOnlyDictiona
             logger.LogWarning("Trying to add live results but {ContextData} is null!", nameof(contextData));
             throw new InvalidOperationException("Cannot fetch ReadModels from null context.");
         }
-        
+
         if (!contextData.TryGetValue(nameof(IUnitOfWork), out var value) || value is not IUnitOfWork unitOfWork)
         {
             logger.LogWarning("Trying to add live results but {ContextData} does not contain UnitOfWork!", nameof(contextData));
@@ -70,15 +70,15 @@ private IReadOnlyCollection<EventListener> GetCurrentListeners(IReadOnlyDictiona
 
         return unitOfWork.ReadModels.ToList().AsReadOnly();
     }
-    
+
     private async IAsyncEnumerable<IQueryResult> LiveResults(IReadOnlyDictionary<string, object?>? contextData, QueryResult firstResult, IQueryRequest originalRequest)
     {
         if (contextData == null)
         {
             logger.LogWarning("Trying to add live results but {ContextData} is null!", nameof(contextData));
             yield break;
         }
-        
+
         var listeners = GetCurrentListeners(contextData);
         yield return firstResult;
 

src/Fluss.HotChocolate/UnitOfWorkParameterExpressionBuilder.cs

@@ -17,7 +17,7 @@ private static IUnitOfWork CreateIUnitOfWork(IResolverContext context)
                    .WithPrefilledVersion(
                        context.GetGlobalStateOrDefault<long?>(PrefillUnitOfWorkVersion)
                    );
-               
+
                // CleanAfter.Requests allows us to read the used ReadModels after the resolver and before returning
                //  the first result. The default CleanAfter.Resolver immediately returns the unitOfWork after the
                //  resolver, losing us valuable information.
@@ -28,7 +28,7 @@ private static IUnitOfWork CreateIUnitOfWork(IResolverContext context)
 
         return unitOfWork;
     }
-    
+
     public const string PrefillUnitOfWorkVersion = nameof(AddExtensionMiddleware) + ".prefillUnitOfWorkVersion";
 
     public ArgumentKind Kind => ArgumentKind.Custom;

src/Fluss/UnitOfWork/UnitOfWorkFactory.cs

@@ -24,7 +24,7 @@ await RetryPolicy
             .ExecuteAsync(async () =>
             {
                 var unitOfWork = serviceProvider.GetRequiredService<UnitOfWork>();
-                
+
                 try
                 {
                     await action(unitOfWork);

src/Fluss/UnitOfWork/UnitOfWorkRecordingProxy.cs

@@ -94,6 +94,6 @@ public async ValueTask<bool> IsStillUpToDate(IUnitOfWork unitOfWork, long? at =
             return readModel.LastAcceptedEvent <= Version;
         }
     }
-    
+
     public ValueTask Return() => ValueTask.CompletedTask;
 }