clean up

Author: st0o0

src/TurboHTTP.API.Tests/ModuleInit.cs

@@ -9,7 +9,7 @@ public static void Init()
     {
         VerifyDiffPlex.Initialize();
         VerifierSettings.ScrubLinesContaining("[assembly: ReleaseDateAttribute(");
-        Verifier.UseProjectRelativeDirectory("verify");
+        UseProjectRelativeDirectory("verify");
         VerifierSettings.UniqueForRuntime();
         VerifierSettings.InitializePlugins();
     }

src/TurboHTTP.API.Tests/verify/CoreAPISpec.ApproveCore.DotNet.verified.txt

@@ -60,7 +60,6 @@ namespace TurboHTTP
         public bool AllowServerPush { get; set; }
         public bool EnableAltSvcDiscovery { get; set; }
         public System.TimeSpan IdleTimeout { get; set; }
-        public long MaxBatchWeight { get; set; }
         public int MaxConnectionsPerServer { get; set; }
         public int MaxFieldSectionSize { get; set; }
         public int MaxReconnectAttempts { get; set; }
@@ -222,6 +221,8 @@ namespace TurboHTTP.Diagnostics
     }
     public static class TurboTraceExtensions
     {
+        public static OpenTelemetry.Metrics.MeterProviderBuilder AddTurboHttpMetrics(this OpenTelemetry.Metrics.MeterProviderBuilder builder) { }
+        public static OpenTelemetry.Trace.TracerProviderBuilder AddTurboHttpTracing(this OpenTelemetry.Trace.TracerProviderBuilder builder) { }
         public static Microsoft.Extensions.DependencyInjection.IServiceCollection AddTurboLoggerTracing(this Microsoft.Extensions.DependencyInjection.IServiceCollection services, TurboHTTP.Diagnostics.TurboTraceCategory categories = 1023, TurboHTTP.Diagnostics.TurboTraceLevel minimumLevel = 1) { }
         public static Microsoft.Extensions.DependencyInjection.IServiceCollection AddTurboTracing(this Microsoft.Extensions.DependencyInjection.IServiceCollection services, TurboHTTP.Diagnostics.ITurboTraceListener listener, TurboHTTP.Diagnostics.TurboTraceCategory categories = 1023, TurboHTTP.Diagnostics.TurboTraceLevel minimumLevel = 1) { }
     }
@@ -285,89 +286,4 @@ namespace TurboHTTP.Protocol.Cookies
         void AddCookiesToRequest(System.Uri requestUri, ref System.Net.Http.HttpRequestMessage request);
         void ProcessResponse(System.Uri requestUri, System.Net.Http.HttpResponseMessage response);
     }
-}
-namespace TurboHTTP.Protocol.Http2.Hpack
-{
-    public static class HpackStaticTable
-    {
-        public const int StaticCount = 61;
-        [System.Runtime.CompilerServices.TupleElementNames(new string[] {
-                "Name",
-                "Value"})]
-        public static readonly System.ValueTuple<string, string>[] Entries;
-    }
-}
-namespace TurboHTTP.Protocol.Http3
-{
-    public sealed class Http3ConnectionReuseDecision : System.IEquatable<TurboHTTP.Protocol.Http3.Http3ConnectionReuseDecision>
-    {
-        public Http3ConnectionReuseDecision() { }
-        public bool CanReuse { get; }
-        public string Reason { get; }
-        public static TurboHTTP.Protocol.Http3.Http3ConnectionReuseDecision NewConnection(string reason) { }
-        public static TurboHTTP.Protocol.Http3.Http3ConnectionReuseDecision Reuse(string reason) { }
-    }
-    public enum Http3DecodeStatus
-    {
-        Success = 0,
-        NeedMoreData = 1,
-    }
-}
-namespace TurboHTTP.Protocol.Http3.Qpack
-{
-    public sealed class DecoderInstruction
-    {
-        public DecoderInstruction() { }
-        public int IntValue { get; init; }
-        public TurboHTTP.Protocol.Http3.Qpack.DecoderInstructionType Type { get; init; }
-    }
-    public enum DecoderInstructionType
-    {
-        SectionAcknowledgment = 0,
-        StreamCancellation = 1,
-        InsertCountIncrement = 2,
-    }
-    public sealed class EncoderInstruction
-    {
-        public EncoderInstruction() { }
-        public int IntValue { get; init; }
-        public bool IsStatic { get; init; }
-        public byte[] Name { get; init; }
-        public int NameIndex { get; init; }
-        public string NameString { get; }
-        public TurboHTTP.Protocol.Http3.Qpack.EncoderInstructionType Type { get; init; }
-        public byte[] Value { get; init; }
-        public string ValueString { get; }
-    }
-    public enum EncoderInstructionType
-    {
-        SetDynamicTableCapacity = 0,
-        InsertWithNameReference = 1,
-        InsertWithLiteralName = 2,
-        Duplicate = 3,
-    }
-    public sealed class QpackDecodeResult
-    {
-        [System.Runtime.CompilerServices.TupleElementNames(new string[] {
-                "Name",
-                "Value"})]
-        public System.Collections.Generic.IReadOnlyList<System.ValueTuple<string, string>>? Headers { get; }
-        public bool IsBlocked { get; }
-        public int RequiredInsertCount { get; }
-        public static TurboHTTP.Protocol.Http3.Qpack.QpackDecodeResult Blocked(int requiredInsertCount) { }
-        public static TurboHTTP.Protocol.Http3.Qpack.QpackDecodeResult Success([System.Runtime.CompilerServices.TupleElementNames(new string[] {
-                "Name",
-                "Value"})] System.Collections.Generic.IReadOnlyList<System.ValueTuple<string, string>> headers) { }
-    }
-    public enum QpackDecodeStatus
-    {
-        Success = 0,
-        NeedMoreData = 1,
-    }
-    public readonly struct QpackEntry : System.IEquatable<TurboHTTP.Protocol.Http3.Qpack.QpackEntry>
-    {
-        public QpackEntry(string Name, string Value) { }
-        public string Name { get; init; }
-        public string Value { get; init; }
-    }
 }

src/TurboHTTP.AcceptanceTests/Diagnostics/LoggingBridgeSpec.cs

@@ -65,11 +65,6 @@ public async ValueTask DisposeAsync()
         }
     }
 
-    /// <summary>
-    /// Builds a fully DI-wired client, mirroring a user's Program.cs / Startup setup.
-    /// Registers <see cref="ILoggerFactory"/> and <see cref="ActorSystem"/> as singletons
-    /// so that <see cref="ITurboHttpClientFactory"/> picks them up via normal DI resolution.
-    /// </summary>
     private ITurboHttpClient BuildClientViaUserDI(int serverPort, bool withTurboTrace = false)
     {
         _capture = new CapturingLoggerProvider();
@@ -128,11 +123,6 @@ private ITurboHttpClient BuildClientViaUserDI(int serverPort, bool withTurboTrac
         return _client;
     }
 
-    /// <summary>
-    /// Starts a minimal in-process HTTP/1.1 server on a random loopback port.
-    /// Accepts connections and responds with HTTP/1.1 200 OK for each request.
-    /// No external server or Kestrel dependency required.
-    /// </summary>
     private int StartFakeTcpServer()
     {
         var listener = new TcpListener(IPAddress.Loopback, 0);
@@ -261,9 +251,6 @@ public async Task TurboTrace_connection_events_should_route_to_MEL_via_AddTurboL
             e.Message.Contains("Connection opened:", StringComparison.OrdinalIgnoreCase));
     }
 
-    /// <summary>
-    /// A simple <see cref="ILoggerProvider"/> that captures all log entries for assertion.
-    /// </summary>
     private sealed class CapturingLoggerProvider : ILoggerProvider
     {
         public ConcurrentBag<LogEntry> Entries { get; } = [];

src/TurboHTTP.AcceptanceTests/H10/RequestCompressionSpec.cs

@@ -5,7 +5,6 @@
 using Akka.Streams.Dsl;
 using TurboHTTP.Internal;
 using TurboHTTP.Protocol.Semantics;
-using TurboHTTP.Streams;
 using TurboHTTP.Streams.Stages.Features;
 using TurboHTTP.Tests.Shared;
 

src/TurboHTTP.AcceptanceTests/H10/ResilienceSpec.cs

@@ -3,7 +3,6 @@
 using Akka;
 using Akka.Streams.Dsl;
 using TurboHTTP.Internal;
-using TurboHTTP.Streams;
 using TurboHTTP.Streams.Stages.Features;
 using TurboHTTP.Tests.Shared;
 

src/TurboHTTP.AcceptanceTests/H10/SmokeSpec.cs

@@ -3,7 +3,6 @@
 using Akka;
 using Akka.Streams.Dsl;
 using TurboHTTP.Internal;
-using TurboHTTP.Streams;
 using TurboHTTP.Tests.Shared;
 
 namespace TurboHTTP.AcceptanceTests.H10;

src/TurboHTTP.AcceptanceTests/H2/ConnectionSpec.cs

@@ -205,7 +205,7 @@ public async Task Post_with_body_followed_by_get_should_work_on_same_connection(
         var postBody = await postResponse.Content.ReadAsByteArrayAsync(TestContext.Current.CancellationToken);
         Assert.Equal(postPayload, postBody);
 
-        var getPath = "/h2/echo-path?q=1";
+        const string getPath = "/h2/echo-path?q=1";
         var getRequest = new HttpRequestMessage(HttpMethod.Get, $"http://localhost{getPath}")
         {
             Version = HttpVersion.Version20

src/TurboHTTP.AcceptanceTests/ModuleInit.cs

@@ -0,0 +1,13 @@
+using System.Runtime.CompilerServices;
+using TurboHTTP.Internal;
+
+namespace TurboHTTP.AcceptanceTests;
+
+public static class ModuleInit
+{
+    [ModuleInitializer]
+    public static void Init()
+    {
+        NetworkBuffer.ConfigurePoolSize(0);
+    }
+}

src/TurboHTTP.AcceptanceTests/Proxy/ProxyConnectSpec.cs

@@ -41,7 +41,7 @@ private static ConnectItem ToConnectItem(StreamAcquireItem acquire)
 
         var connectResponseConsumed = false;
         var tunnelFlow = Flow.Create<IOutputItem>()
-            .Select(item => item is StreamAcquireItem acquire ? (IOutputItem)ToConnectItem(acquire) : item)
+            .Select(item => item is StreamAcquireItem acquire ? ToConnectItem(acquire) : item)
             .Via(Flow.FromGraph<IOutputItem, IInputItem, NotUsed>(fake))
             .Where(item =>
             {

src/TurboHTTP.StreamTests/Caching/CacheBidiAsyncBodySpec.cs

@@ -8,15 +8,6 @@
 
 namespace TurboHTTP.StreamTests.Caching;
 
-/// <summary>
-/// RFC 9111 §3 — CacheBidiStage async body read path tests.
-/// Verifies that GetAsyncCallback keeps the stage scope alive during slow body reads,
-/// preventing GroupByHostKeyStage from completing the substream prematurely.
-/// </summary>
-/// <remarks>
-/// Stage under test: <see cref="CacheBidiStage"/>.
-/// RFC 9111 §3: Storing responses in a cache — async body read for cache storage.
-/// </remarks>
 public sealed class CacheBidiAsyncBodySpec : StreamTestBase
 {
     /// <summary>
@@ -77,7 +68,6 @@ private Task<IImmutableList<HttpResponseMessage>> RunResponseAsync(
         return RunnableGraph.FromGraph(graph).Run(Materializer);
     }
 
-
     [Trait("RFC", "RFC9111-3")]
     [Fact(Timeout = 10_000)]
     public async Task CacheBidiStage_should_push_response_immediately_while_body_read_is_pending()
@@ -150,4 +140,4 @@ public async Task CacheBidiStage_should_store_in_cache_after_async_body_complete
         Assert.NotNull(entry);
         Assert.Equal("pending body", System.Text.Encoding.UTF8.GetString(entry.Body.Span));
     }
-}
+}