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/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/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/Http2/Http20ConnectionStageSpec.cs

@@ -1,4 +1,3 @@
-using System.Net;
 using System.Text;
 using Akka.Streams;
 using Akka.Streams.Dsl;

src/TurboHTTP.StreamTests/Http3/Http30ConnectionStageSpec.cs

@@ -1,4 +1,3 @@
-using System.Net;
 using System.Text;
 using Akka.Streams;
 using Akka.Streams.Dsl;

src/TurboHTTP.StreamTests/Semantics/ContentEncodingBidiStageSpec.cs

@@ -153,7 +153,7 @@ public async Task ContentEncodingBidiStage_should_compress_gzip_when_body_exceed
         var policy = new CompressionPolicy { Encoding = "gzip", MinBodySizeBytes = 1000 };
         var stage = new ContentEncodingBidiStage(compressionPolicy: policy);
         var largeBody = new byte[2000];
-        for (int i = 0; i < largeBody.Length; i++)
+        for (var i = 0; i < largeBody.Length; i++)
         {
             largeBody[i] = (byte)(i % 256);
         }

src/TurboHTTP.StreamTests/Semantics/TracingBidiStageSpec.cs

@@ -1,5 +1,4 @@
 using System.Collections.Immutable;
-using System.Diagnostics;
 using System.Net;
 using Akka.Streams;
 using Akka.Streams.Dsl;