Add Http3

Author: st0o0

.maggus/features/feature_002.md .maggus/features/feature_002_completed.md.maggus/features/feature_002.md renamed to .maggus/features/feature_002_completed.md

@@ -30,17 +30,17 @@ HTTP/3's `Http3Options` is an empty placeholder class, while HTTP/2 has 5 config
 **Parallel:** yes — can run alongside nothing (foundation task)
 
 **Acceptance Criteria:**
-- [ ] `Http3Options` has these properties with XML doc comments:
+- [x] `Http3Options` has these properties with XML doc comments:
   - `MaxConnectionsPerServer` (int, default 4) — fewer than H2's 6 since QUIC multiplexes better
   - `QpackMaxTableCapacity` (int, default 4096) — QPACK dynamic table size
   - `QpackBlockedStreams` (int, default 100) — max streams blocked on encoder instructions
   - `MaxFieldSectionSize` (int, default 65536) — HTTP/3 equivalent of header size limits
   - `IdleTimeout` (TimeSpan, default 30s) — QUIC idle timeout
   - `MaxReconnectAttempts` (int, default 3) — reconnect limit for QUIC connection drops
-- [ ] Property style matches `Http2Options` (public getters/setters, summary comments referencing relevant RFCs)
-- [ ] `TurboClientOptions.Http3` property already exists and returns `Http3Options` — verify it works with new properties
-- [ ] Unit test validates defaults match documented values
-- [ ] Typecheck passes: `dotnet build --configuration Release ./src/TurboHTTP.sln`
+- [x] Property style matches `Http2Options` (public getters/setters, summary comments referencing relevant RFCs)
+- [x] `TurboClientOptions.Http3` property already exists and returns `Http3Options` — verify it works with new properties
+- [x] Unit test validates defaults match documented values
+- [x] Typecheck passes: `dotnet build --configuration Release ./src/TurboHTTP.sln`
 
 **Files to modify:**
 - `src/TurboHTTP/Http3Options.cs`
@@ -59,13 +59,13 @@ HTTP/3's `Http3Options` is an empty placeholder class, while HTTP/2 has 5 config
 **Parallel:** yes — can run alongside TASK-002-003
 
 **Acceptance Criteria:**
-- [ ] `ProtocolCoreBuilder.Build()` extracts `clientOptions.Http3.QpackMaxTableCapacity` and `clientOptions.Http3.IdleTimeout`
-- [ ] `Http30Engine` constructor signature updated: `Http30Engine(int maxTableCapacity, TimeSpan idleTimeout)`
-- [ ] `Http30Engine` passes `idleTimeout` to `Http30ConnectionStage` constructor
-- [ ] `ProtocolCoreBuilder` line `new Http30Engine()` changed to `new Http30Engine(clientOptions.Http3.QpackMaxTableCapacity, clientOptions.Http3.IdleTimeout)`
-- [ ] Default parameterless `Http30Engine()` constructor preserved for backward compatibility (delegates to new constructor with defaults)
-- [ ] All existing tests still pass unchanged
-- [ ] Typecheck passes
+- [x] `ProtocolCoreBuilder.Build()` extracts `clientOptions.Http3.QpackMaxTableCapacity` and `clientOptions.Http3.IdleTimeout`
+- [x] `Http30Engine` constructor signature updated: `Http30Engine(int maxTableCapacity, TimeSpan idleTimeout)`
+- [x] `Http30Engine` passes `idleTimeout` to `Http30ConnectionStage` constructor
+- [x] `ProtocolCoreBuilder` line `new Http30Engine()` changed to `new Http30Engine(clientOptions.Http3.QpackMaxTableCapacity, clientOptions.Http3.IdleTimeout)`
+- [x] Default parameterless `Http30Engine()` constructor preserved for backward compatibility (delegates to new constructor with defaults)
+- [x] All existing tests still pass unchanged
+- [x] Typecheck passes
 
 **Files to modify:**
 - `src/TurboHTTP/Streams/ProtocolCoreBuilder.cs` (line 63)
@@ -85,13 +85,13 @@ HTTP/3's `Http3Options` is an empty placeholder class, while HTTP/2 has 5 config
 **Parallel:** yes — can run alongside TASK-002-002
 
 **Acceptance Criteria:**
-- [ ] `ProtocolCoreBuilder.Build()` extracts `maxConnsH3` from `clientOptions.Http3.MaxConnectionsPerServer`
-- [ ] `MaxSubstreamsPerKey()` has separate branch: `endpoint.Version.Major == 3 ? maxConnsH3`
-- [ ] `MaxConcurrencyPerSlot()` has separate branch: `endpoint.Version.Major == 3 ? int.MaxValue` (QUIC handles stream limits at transport level)
-- [ ] Existing `Major >= 2` changed to `Major == 2` for HTTP/2-only path
-- [ ] Unit test: H2 endpoint uses H2 limits, H3 endpoint uses H3 limits
-- [ ] All existing tests still pass
-- [ ] Typecheck passes
+- [x] `ProtocolCoreBuilder.Build()` extracts `maxConnsH3` from `clientOptions.Http3.MaxConnectionsPerServer`
+- [x] `MaxSubstreamsPerKey()` has separate branch: `endpoint.Version.Major == 3 ? maxConnsH3`
+- [x] `MaxConcurrencyPerSlot()` has separate branch: `endpoint.Version.Major == 3 ? int.MaxValue` (QUIC handles stream limits at transport level)
+- [x] Existing `Major >= 2` changed to `Major == 2` for HTTP/2-only path
+- [x] Unit test: H2 endpoint uses H2 limits, H3 endpoint uses H3 limits
+- [x] All existing tests still pass
+- [x] Typecheck passes
 
 **Files to modify:**
 - `src/TurboHTTP/Streams/ProtocolCoreBuilder.cs` (lines 28-50)
@@ -108,9 +108,9 @@ HTTP/3's `Http3Options` is an empty placeholder class, while HTTP/2 has 5 config
 **Model:** haiku
 
 **Acceptance Criteria:**
-- [ ] ARCHITECTURE.md "Implementation Status" table: HTTP/3 score updated (was 75/100)
-- [ ] "Open gaps" list: remove "QUIC transport" if now wired, update QPACK status
-- [ ] `TurboClientOptions` description mentions `Http3Options` alongside `Http2Options`
+- [x] ARCHITECTURE.md "Implementation Status" table: HTTP/3 score updated (was 75/100)
+- [x] "Open gaps" list: remove "QUIC transport" if now wired, update QPACK status
+- [x] `TurboClientOptions` description mentions `Http3Options` alongside `Http2Options`
 
 **Files to modify:**
 - `ARCHITECTURE.md` (lines 318-331)

.maggus/features/feature_003.md .maggus/features/feature_003_completed.md.maggus/features/feature_003.md renamed to .maggus/features/feature_003_completed.md

@@ -36,7 +36,7 @@ HTTP/2's connection handling follows a clean architecture: `StateMachine` (all p
 **Parallel:** yes — can run alongside TASK-003-002
 
 **Acceptance Criteria:**
-- [ ] `Http3ConnectionConfig` record created in `src/TurboHTTP/Protocol/Http3/`:
+- [x] `Http3ConnectionConfig` record created in `src/TurboHTTP/Protocol/Http3/`:
   ```csharp
   public sealed record Http3ConnectionConfig(
       int MaxFieldSectionSize = 65536,
@@ -46,7 +46,7 @@ HTTP/2's connection handling follows a clean architecture: `StateMachine` (all p
       int MaxReconnectAttempts = 3,
       bool AllowServerPush = false);
   ```
-- [ ] `IHttp3StageOperations` interface created in `src/TurboHTTP/Protocol/Http3/`:
+- [x] `IHttp3StageOperations` interface created in `src/TurboHTTP/Protocol/Http3/`:
   ```csharp
   public interface IHttp3StageOperations
   {
@@ -56,8 +56,8 @@ HTTP/2's connection handling follows a clean architecture: `StateMachine` (all p
       void OnReconnectFailed();
   }
   ```
-- [ ] Follows `IHttp2StageOperations` naming and callback semantics exactly
-- [ ] Typecheck passes
+- [x] Follows `IHttp2StageOperations` naming and callback semantics exactly
+- [x] Typecheck passes
 
 **Files to create:**
 - `src/TurboHTTP/Protocol/Http3/Http3ConnectionConfig.cs`
@@ -77,16 +77,16 @@ HTTP/2's connection handling follows a clean architecture: `StateMachine` (all p
 **Parallel:** yes — can run alongside TASK-003-001
 
 **Acceptance Criteria:**
-- [ ] `Http3StreamTracker` class created in `src/TurboHTTP/Protocol/Http3/`
-- [ ] Tracks client-initiated bidirectional stream IDs (0, 4, 8, 12, ... — incremented by 4 per RFC 9114 §6.1)
-- [ ] `AllocateStreamId()` returns next ID and advances counter by 4
-- [ ] `CanOpenStream()` checks against concurrency limit
-- [ ] `OnStreamOpened(long streamId)` / `OnStreamClosed(long streamId)` manage active set
-- [ ] `Reset()` clears state for reconnection
-- [ ] `ActiveStreamCount`, `MaxConcurrentStreams`, `NextStreamId` properties
-- [ ] Uses `long` for stream IDs (QUIC uses 62-bit variable-length integers, unlike HTTP/2's 31-bit)
-- [ ] Unit tests in `src/TurboHTTP.Tests/Http3/Connection/Http3StreamTrackerSpec.cs`
-- [ ] Typecheck passes
+- [x] `Http3StreamTracker` class created in `src/TurboHTTP/Protocol/Http3/`
+- [x] Tracks client-initiated bidirectional stream IDs (0, 4, 8, 12, ... — incremented by 4 per RFC 9114 §6.1)
+- [x] `AllocateStreamId()` returns next ID and advances counter by 4
+- [x] `CanOpenStream()` checks against concurrency limit
+- [x] `OnStreamOpened(long streamId)` / `OnStreamClosed(long streamId)` manage active set
+- [x] `Reset()` clears state for reconnection
+- [x] `ActiveStreamCount`, `MaxConcurrentStreams`, `NextStreamId` properties
+- [x] Uses `long` for stream IDs (QUIC uses 62-bit variable-length integers, unlike HTTP/2's 31-bit)
+- [x] Unit tests in `src/TurboHTTP.Tests/Http3/Connection/Http3StreamTrackerSpec.cs`
+- [x] Typecheck passes
 
 **Files to create:**
 - `src/TurboHTTP/Protocol/Http3/Http3StreamTracker.cs`
@@ -107,28 +107,28 @@ HTTP/2's connection handling follows a clean architecture: `StateMachine` (all p
 **Model:** opus
 
 **Acceptance Criteria:**
-- [ ] `Http3StateMachine` class created in `src/TurboHTTP/Protocol/Http3/StateMachine.cs`
-- [ ] Constructor takes `Http3ConnectionConfig` + `IHttp3StageOperations`
-- [ ] Owns `Http3StreamTracker`, `ConnectionState` (moved from Http30ConnectionStage inner class)
-- [ ] `ConnectionState` class moved from `Http30ConnectionStage` to `StateMachine` (or extracted to own file)
-- [ ] Key methods:
+- [x] `Http3StateMachine` class created in `src/TurboHTTP/Protocol/Http3/StateMachine.cs`
+- [x] Constructor takes `Http3ConnectionConfig` + `IHttp3StageOperations`
+- [x] Owns `Http3StreamTracker`, `ConnectionState` (moved from Http30ConnectionStage inner class)
+- [x] `ConnectionState` class moved from `Http30ConnectionStage` to `StateMachine` (or extracted to own file)
+- [x] Key methods:
   - `ProcessFrame(Http3Frame frame)` — handles SETTINGS, GOAWAY, PUSH_PROMISE, CANCEL_PUSH, MAX_PUSH_ID, forwards DATA/HEADERS via callback
   - `SendRequest(Http3Frame frame)` — validates GOAWAY not received, tracks stream open, enqueues outbound
   - `bool CanAcceptRequest` — no GOAWAY + not reconnecting + concurrency budget
   - `bool IsReconnecting` / `int ReconnectBufferCount`
   - `OnConnectionLost()` — enters reconnect state, buffers in-flight requests
   - `OnConnectionRestored()` — replays buffered requests via callback
   - `OnReconnectFailed()` — signals callback after max attempts exhausted
-- [ ] All existing `Http30ConnectionStage.Logic` protocol logic migrated to StateMachine
-- [ ] Unit tests in `src/TurboHTTP.Tests/Http3/Connection/Http3StateMachineSpec.cs` covering:
+- [x] All existing `Http30ConnectionStage.Logic` protocol logic migrated to StateMachine
+- [x] Unit tests in `src/TurboHTTP.Tests/Http3/Connection/Http3StateMachineSpec.cs` covering:
   - SETTINGS processing
   - GOAWAY handling (single, decreasing stream IDs, invalid IDs)
   - Push promise rejection (AllowServerPush = false)
   - Push promise acceptance (AllowServerPush = true)
   - Stream lifecycle (open/close tracking)
   - Idle timeout expiry
   - Reconnection enter/replay/fail
-- [ ] Typecheck passes
+- [x] Typecheck passes
 
 **Files to create:**
 - `src/TurboHTTP/Protocol/Http3/StateMachine.cs`
@@ -150,20 +150,20 @@ HTTP/2's connection handling follows a clean architecture: `StateMachine` (all p
 **Model:** opus
 
 **Acceptance Criteria:**
-- [ ] `Http30ConnectionStage` constructor takes `Http3ConnectionConfig` (not just `TimeSpan idleTimeout`)
-- [ ] `Logic` class implements `IHttp3StageOperations`
-- [ ] `Logic` creates `Http3StateMachine` in constructor
-- [ ] All frame handling delegated: `HandleServerFrame` → `_sm.ProcessFrame(frame)`, outbound → `_sm.SendRequest(frame)`
-- [ ] `ConnectionState` inner class removed (now lives in StateMachine)
-- [ ] `IHttp3StageOperations` callbacks translate to Akka operations:
+- [x] `Http30ConnectionStage` constructor takes `Http3ConnectionConfig` (not just `TimeSpan idleTimeout`)
+- [x] `Logic` class implements `IHttp3StageOperations`
+- [x] `Logic` creates `Http3StateMachine` in constructor
+- [x] All frame handling delegated: `HandleServerFrame` → `_sm.ProcessFrame(frame)`, outbound → `_sm.SendRequest(frame)`
+- [x] `ConnectionState` inner class removed (now lives in StateMachine)
+- [x] `IHttp3StageOperations` callbacks translate to Akka operations:
   - `OnResponse` → `Push(_outApp, frame)`
   - `OnOutbound` → `EnqueueOutbound(frame)`
   - `OnWarning` → `Log.Warning(...)`
   - `OnReconnectFailed` → `FailStage(...)`
-- [ ] `Http30Engine` updated to pass `Http3ConnectionConfig` to stage
-- [ ] All existing stream tests in `src/TurboHTTP.StreamTests/Http3/` pass unchanged
-- [ ] All existing stream tests in `src/TurboHTTP.StreamTests/Http3/Connection/` pass unchanged
-- [ ] Typecheck passes
+- [x] `Http30Engine` updated to pass `Http3ConnectionConfig` to stage
+- [x] All existing stream tests in `src/TurboHTTP.StreamTests/Http3/` pass unchanged
+- [x] All existing stream tests in `src/TurboHTTP.StreamTests/Http3/Connection/` pass unchanged
+- [x] Typecheck passes
 
 **Files to modify:**
 - `src/TurboHTTP/Streams/Stages/Decoding/Http30ConnectionStage.cs` (major refactor)
@@ -183,19 +183,19 @@ HTTP/2's connection handling follows a clean architecture: `StateMachine` (all p
 **Parallel:** no
 
 **Acceptance Criteria:**
-- [ ] `Http3StateMachine.OnConnectionLost()` enters reconnect state:
+- [x] `Http3StateMachine.OnConnectionLost()` enters reconnect state:
   - Sets `_reconnecting = true`
   - Buffers pending outbound frames in `_reconnectBuffer`
   - Increments `_reconnectAttempts`
-- [ ] `Http3StateMachine.OnConnectionRestored()` replays buffer:
+- [x] `Http3StateMachine.OnConnectionRestored()` replays buffer:
   - Resets stream tracker (`_tracker.Reset()`)
   - Replays buffered frames via `_ops.OnOutbound()`
   - Clears `_reconnecting` and `_reconnectBuffer`
-- [ ] After `MaxReconnectAttempts` exhausted → `_ops.OnReconnectFailed()`
-- [ ] `Http30ConnectionStage.Logic` handles upstream finish during reconnect (fails stage)
-- [ ] Unit tests in StateMachine spec: reconnect enter, replay, max attempts
-- [ ] Stream test: `Http30ConnectionStageReconnectSpec.cs` — simulates transport failure and recovery
-- [ ] Typecheck passes
+- [x] After `MaxReconnectAttempts` exhausted → `_ops.OnReconnectFailed()`
+- [x] `Http30ConnectionStage.Logic` handles upstream finish during reconnect (fails stage)
+- [x] Unit tests in StateMachine spec: reconnect enter, replay, max attempts
+- [x] Stream test: `Http30ConnectionStageReconnectSpec.cs` — simulates transport failure and recovery
+- [x] Typecheck passes
 
 **Files to modify:**
 - `src/TurboHTTP/Protocol/Http3/StateMachine.cs` (add reconnect fields + methods)
@@ -219,13 +219,13 @@ HTTP/2's connection handling follows a clean architecture: `StateMachine` (all p
 **Parallel:** yes — can run alongside TASK-003-007, TASK-003-008, TASK-003-009
 
 **Acceptance Criteria:**
-- [ ] `Http3ConnectionConfig.AllowServerPush` (already added in TASK-003-001) flows through to StateMachine
-- [ ] When `AllowServerPush = false`: PUSH_PROMISE triggers CANCEL_PUSH frame via `_ops.OnOutbound()`
-- [ ] When `AllowServerPush = true`: PUSH_PROMISE is forwarded to app layer
-- [ ] `MAX_PUSH_ID` frame sent with appropriate value based on config
-- [ ] Unit test: push rejected when disabled, accepted when enabled
-- [ ] Existing `Http30PushRejectionSpec` stream test still passes
-- [ ] Typecheck passes
+- [x] `Http3ConnectionConfig.AllowServerPush` (already added in TASK-003-001) flows through to StateMachine
+- [x] When `AllowServerPush = false`: PUSH_PROMISE triggers CANCEL_PUSH frame via `_ops.OnOutbound()`
+- [x] When `AllowServerPush = true`: PUSH_PROMISE is forwarded to app layer
+- [x] `MAX_PUSH_ID` frame sent with appropriate value based on config
+- [x] Unit test: push rejected when disabled, accepted when enabled
+- [x] Existing `Http30PushRejectionSpec` stream test still passes
+- [x] Typecheck passes
 
 **Files to modify:**
 - `src/TurboHTTP/Protocol/Http3/StateMachine.cs` (ProcessFrame PUSH_PROMISE branch)
@@ -241,15 +241,15 @@ HTTP/2's connection handling follows a clean architecture: `StateMachine` (all p
 **Parallel:** yes — can run alongside TASK-003-006, TASK-003-008, TASK-003-009
 
 **Acceptance Criteria:**
-- [ ] `Http3Options.AllowEarlyData` property added (bool, default false)
-- [ ] `Http3ConnectionConfig` includes `AllowEarlyData`
-- [ ] `Http30Request2FrameStage` checks if request method is idempotent (GET, HEAD, OPTIONS, TRACE, DELETE)
-- [ ] Idempotent requests tagged with `EarlyData = true` when `AllowEarlyData` is enabled
-- [ ] `QuicTransportStateMachine` / `QuicClientProvider` uses `QuicStream.CanWrite` for early data
-- [ ] On 0-RTT rejection: request re-sent after full handshake
-- [ ] Unit test: idempotent request marked for early data
-- [ ] Unit test: non-idempotent request blocked from early data
-- [ ] Typecheck passes
+- [x] `Http3Options.AllowEarlyData` property added (bool, default false)
+- [x] `Http3ConnectionConfig` includes `AllowEarlyData`
+- [x] `Http30Request2FrameStage` checks if request method is idempotent (GET, HEAD, OPTIONS, TRACE, DELETE)
+- [x] Idempotent requests tagged with `EarlyData = true` when `AllowEarlyData` is enabled
+- [x] `QuicTransportStateMachine` / `QuicClientProvider` uses `QuicStream.CanWrite` for early data
+- [x] On 0-RTT rejection: request re-sent after full handshake
+- [x] Unit test: idempotent request marked for early data
+- [x] Unit test: non-idempotent request blocked from early data
+- [x] Typecheck passes
 
 **Files to modify:**
 - `src/TurboHTTP/Http3Options.cs`
@@ -268,13 +268,13 @@ HTTP/2's connection handling follows a clean architecture: `StateMachine` (all p
 **Parallel:** yes — can run alongside TASK-003-006, TASK-003-007, TASK-003-009
 
 **Acceptance Criteria:**
-- [ ] `Http3Options.AllowConnectionMigration` property added (bool, default true)
-- [ ] `QuicTransportStateMachine` detects address changes on the QUIC connection
-- [ ] When migration detected and allowed: connection continues transparently
-- [ ] When migration detected and disallowed: connection closed, new connection established (leverages reconnect from TASK-003-005)
-- [ ] Unit test: migration allowed continues seamlessly
-- [ ] Unit test: migration disallowed triggers reconnect
-- [ ] Typecheck passes
+- [x] `Http3Options.AllowConnectionMigration` property added (bool, default true)
+- [x] `QuicTransportStateMachine` detects address changes on the QUIC connection
+- [x] When migration detected and allowed: connection continues transparently
+- [x] When migration detected and disallowed: connection closed, new connection established (leverages reconnect from TASK-003-005)
+- [x] Unit test: migration allowed continues seamlessly
+- [x] Unit test: migration disallowed triggers reconnect
+- [x] Typecheck passes
 
 **Files to modify:**
 - `src/TurboHTTP/Http3Options.cs`
@@ -293,14 +293,14 @@ HTTP/2's connection handling follows a clean architecture: `StateMachine` (all p
 **Model:** opus
 
 **Acceptance Criteria:**
-- [ ] `AltSvcCache` class created: per-host cache of Alt-Svc directives with TTL
-- [ ] Alt-Svc header parsed from HTTP/1.1 and HTTP/2 responses (RFC 7838)
-- [ ] `AltSvcEntry` record: protocol, host, port, maxAge, persist flag
-- [ ] Integration point in `ProtocolCoreBuilder` or `RequestEnricher`: check cache before version selection
-- [ ] If HTTP/3 advertised and QUIC available: upgrade endpoint version to 3.0
-- [ ] `Http3Options.EnableAltSvcDiscovery` property (bool, default false — opt-in)
-- [ ] Unit tests: Alt-Svc header parsing, cache TTL expiry, upgrade decision
-- [ ] Typecheck passes
+- [x] `AltSvcCache` class created: per-host cache of Alt-Svc directives with TTL
+- [x] Alt-Svc header parsed from HTTP/1.1 and HTTP/2 responses (RFC 7838)
+- [x] `AltSvcEntry` record: protocol, host, port, maxAge, persist flag
+- [x] Integration point in `ProtocolCoreBuilder` or `RequestEnricher`: check cache before version selection
+- [x] If HTTP/3 advertised and QUIC available: upgrade endpoint version to 3.0
+- [x] `Http3Options.EnableAltSvcDiscovery` property (bool, default false — opt-in)
+- [x] Unit tests: Alt-Svc header parsing, cache TTL expiry, upgrade decision
+- [x] Typecheck passes
 
 **Files to create:**
 - `src/TurboHTTP/Protocol/AltSvc/AltSvcCache.cs`