PipeReader Integration

using System.Buffers;
using System.IO.Pipelines;
using Glyph11;
using Glyph11.Protocol;
using Glyph11.Parser.Hardened;
using Glyph11.Validation;

public class RequestHandler
{
    private readonly BinaryRequest _request = new();
    private static readonly ParserLimits Limits = ParserLimits.Default;

    public async Task ProcessRequests(PipeReader reader)
    {
        while (true)
        {
            ReadResult result = await reader.ReadAsync();
            ReadOnlySequence<byte> buffer = result.Buffer;

            while (TryParseRequest(ref buffer))
            {
                HandleRequest();
                ResetForNextRequest();
            }

            reader.AdvanceTo(buffer.Start, buffer.End);

            if (result.IsCompleted) break;
        }
    }

    private bool TryParseRequest(ref ReadOnlySequence<byte> buffer)
    {
        try
        {
            if (!HardenedParser.TryExtractFullHeader(
                    ref buffer, _request, in Limits, out int bytesRead))
                return false; // incomplete, wait for more data

            // Post-parse security checks
            if (RequestSemantics.HasTransferEncodingWithContentLength(_request))
                throw new HttpParseException("Request smuggling attempt.");

            if (RequestSemantics.HasDotSegments(_request))
                throw new HttpParseException("Path traversal attempt.");

            buffer = buffer.Slice(bytesRead);
            return true;
        }
        catch (HttpParseException)
        {
            // Protocol violation — close connection
            throw;
        }
    }

    private void HandleRequest()
    {
        // Access parsed data:
        // _request.Method.Span  → e.g. "GET"
        // _request.Path.Span    → e.g. "/api/users"
        // _request.Version.Span → e.g. "HTTP/1.1"
        // _request.Headers      → KeyValueList of headers
        // _request.QueryParameters → KeyValueList of query params
    }

    private void ResetForNextRequest()
    {
        _request.Headers.Clear();
        _request.QueryParameters.Clear();
    }
}