parse-net 0.6.1

//! Counting-allocator tests: no parse, compare, or write into a `SliceSink`
//! allocates (NFR-1).
//!
//! The allocator counts allocations made by this thread only, so the test
//! harness running other tests in parallel cannot disturb the count.

use std::{
    alloc::{GlobalAlloc, Layout, System},
    cell::Cell,
};

use core::net::IpAddr;

use parse_net::{
    self as pn, ByteRange, EntityTag, ForwardedSource, HttpDate, Limits, SliceSink, auth, cache,
    class::Class, etag, forwarded, list, mail, media, negotiate, param, pct, range, scan, sfv,
    text, write,
};

struct Counting;

thread_local! {
    static ALLOCATIONS: Cell<usize> = const { Cell::new(0) };
}

// SAFETY: every call is forwarded unchanged to the system allocator, which
// upholds the `GlobalAlloc` contract; the only addition is a thread-local
// counter increment, which does not allocate.
unsafe impl GlobalAlloc for Counting {
    unsafe fn alloc(&self, layout: Layout) -> *mut u8 {
        let _ = ALLOCATIONS.try_with(|n| n.set(n.get() + 1));
        // SAFETY: the caller's layout is passed through as received.
        unsafe { System.alloc(layout) }
    }

    unsafe fn dealloc(&self, ptr: *mut u8, layout: Layout) {
        // SAFETY: `ptr` was allocated by `System` with this layout.
        unsafe { System.dealloc(ptr, layout) }
    }

    unsafe fn realloc(&self, ptr: *mut u8, layout: Layout, new_size: usize) -> *mut u8 {
        let _ = ALLOCATIONS.try_with(|n| n.set(n.get() + 1));
        // SAFETY: forwarded unchanged; `ptr` came from `System`.
        unsafe { System.realloc(ptr, layout, new_size) }
    }
}

#[global_allocator]
static GLOBAL: Counting = Counting;

fn allocations(f: impl FnOnce()) -> usize {
    let before = ALLOCATIONS.with(Cell::get);
    f();
    ALLOCATIONS.with(Cell::get) - before
}

/// Inputs covering every parser's accept and refuse paths.
const INPUTS: &[&[u8]] = &[
    b"",
    b"text/html; charset=utf-8",
    b"Multipart/Form-Data; boundary=\"----x y\"",
    b"a, \"b,c\" , , (d, (e)) f;g=\"h\\\"i\",",
    b"gzip;q=0.5, br",
    b"Sun, 06 Nov 1994 08:49:37 GMT",
    b"Sunday, 06-Nov-94 08:49:37 GMT",
    b"Sun Nov  6 08:49:37 1994",
    b"[2001:db8::1]:8443",
    b"example.com:80",
    b"127.1",
    b"caf%C3%A9%20%e2%82%ac",
    b"\"unterminated",
    b"bad\r\nvalue",
    b";a=1;A=2",
    b"(((((((((deep)))))))))",
];

#[test]
fn test_parsing_never_allocates() {
    let mut out = [0u8; 256];
    let n = allocations(|| {
        for &v in INPUTS {
            let _ = scan::check_field_value(v);
            let _ = scan::find_byte(b',', v);
            let _ = scan::find_either(b',', b'"', v);
            let _ = scan::first_not_in(v, Class::TCHAR);
            let _ = text::trim_ows(v);
            let _ = text::parse_token(v);
            let _ = text::parse_word(v).map(|(w, _)| w.eq_ignore_ascii_case(b"x"));
            if let Ok((q, _)) = text::parse_quoted(v) {
                let _ = q.unescape_into(&mut out);
                let _ = q.eq_bytes(b"x");
            }
            let _ = text::parse_comment(v, &Limits::DEFAULT);
            if let Ok(l) = pn::list(v) {
                for e in l.iter() {
                    let _ = e.len();
                }
            }
            let lines = [v, v];
            if let Ok(c) = list::combined(lines, &Limits::DEFAULT) {
                for e in c.iter() {
                    let _ = e.len();
                }
            }
            let _ = list::contains_token([v], b"upgrade");
            if let Ok((p, _)) = param::parse(v, &Limits::DEFAULT) {
                let _ = p.get("a");
                for x in p.iter() {
                    let _ = x.value.len();
                }
            }
            if let Ok(m) = pn::parse_media_type(v) {
                let _ = m.boundary();
                let _ = m.charset();
                let _ = m.is_json();
            }
            let _ = HttpDate::parse_at(v, 1_792_540_800).map(HttpDate::format);
            let _ = HttpDate::parse_imf_fixdate(v).map(HttpDate::civil);
            let _ = pn::parse_host_port(v);
            let _ = pct::decode_utf8_into(v, &mut out);
            let _ = pct::decode_lower_only_into(v, &mut out);
            let _ = pct::validate_with(v, Class::URI_TARGET);
            let _ = pn::num::parse_u64(v);
        }
    });
    assert_eq!(n, 0, "a parse allocated");
}

#[test]
fn test_writing_into_slice_sink_never_allocates() {
    let mut buf = [0u8; 1024];
    let n = allocations(|| {
        let mut out = SliceSink::new(&mut buf);
        let _ = write::write_token(b"gzip", &mut out);
        let _ = write::write_quoted(b"a \"b\"", &mut out);
        let _ = write::write_word(b"x y", &mut out);
        let _ = write::write_param(b"charset", b"utf-8", &mut out);
        let _ = write::write_field_value(b"text/html", &mut out);
        let _ = write::write_field_value(b"bad\r\n", &mut out);
        let _ = write::write_decimal_u64(u64::MAX, &mut out);
        let _ = write::write_hex_u64(u64::MAX, &mut out);
        let _ = media::write("text", "plain", &[("charset", "utf-8")], &mut out);
        if let Ok(m) = pn::parse_media_type(b"Text/HTML;Charset=UTF-8") {
            let _ = m.write_canonical(&mut out);
        }
        let _ = HttpDate::MAX.write_to(&mut out);
        if let Ok(hp) = pn::parse_host_port(b"[::1]:80") {
            let _ = hp.write_to(&mut out);
        }
        let _ = pct::encode(
            b"a b",
            &pct::EncodeSet::ATTR_CHAR_COMPLEMENT,
            pct::HexCase::Upper,
            &mut out,
        );
    });
    assert_eq!(n, 0, "a write allocated");
}

/// Web-layer (0.4) inputs: one or more per parser, valid and invalid.
const WEB_INPUTS: &[&[u8]] = &[
    b"text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8",
    b"en-US,en;q=0.9,*;q=0.1",
    b"gzip;q=1.0, identity; q=0.5, *;q=0",
    b"W/\"xyzzy\", \"r2d2xxxx\"",
    b"*",
    b"bytes=0-499,-500,1000-",
    b"bytes 0-499/1234",
    b"UTF-8''%e2%82%ac%20rates",
    b"attachment; filename=\"EURO rates\"; filename*=utf-8''%e2%82%ac%20rates",
    b"max-age=3600, no-cache=\"Set-Cookie\", private",
    b"https://example.com:8443",
    b"for=192.0.2.60;proto=http;by=203.0.113.43, for=\"[2001:db8::17]:4711\"",
    b"203.0.113.195, 70.41.3.18",
    b"Basic dXNlcjpwYXNzd29yZA==",
    b"Bearer realm=\"example\", error=\"invalid_token\", Basic realm=\"x\"",
    b"(\"foo\" \"bar\");lvl=5, abc;a=?0, %\"f%c3%bc\", :AQID:, @1659578233, 1.5",
    b"a=1, b, c=(x y);q",
    b"\"unterminated",
    b"bad\r\nvalue",
];

#[test]
fn test_web_layer_parsing_never_allocates() {
    let l = Limits::DEFAULT;
    let mut out = [0u8; 256];
    let mut ranges = [ByteRange { start: 0, end: 0 }; 8];
    let mut slots = [(
        "",
        sfv::Member::Item(sfv::Item::new(sfv::BareItem::Boolean(false))),
    ); 16];
    let peer = IpAddr::from([10, 0, 0, 1]);
    let trust = |_: IpAddr| true;
    let tag = EntityTag::strong(b"xyzzy").expect("tag");
    let n = allocations(|| {
        for &v in WEB_INPUTS {
            if let Ok(r) = media::parse_range(v, &l) {
                let _ = r.specificity();
            }
            let _ = pn::best_media(Some(v), &["text/html", "application/json"]);
            let _ = pn::best_language(Some(v), &["en", "de"]);
            let _ = pn::best_encoding(Some(v), &["br", "gzip"]);
            let _ = pn::best_charset(Some(v), &["utf-8"]);
            if let Ok(a) = negotiate::parse_accept(v, &l) {
                let _ = a.iter().count();
            }
            if let Ok(etag::Condition::Tags(t)) = etag::parse_condition(v, &l) {
                let _ = t.iter().count();
            }
            let _ = etag::if_none_match(v, &tag);
            let _ = range::byte_ranges(v, 10_000, &mut ranges);
            let _ = range::parse_content_range(v);
            if let Ok(e) = pn::ExtValue::parse(v) {
                let _ = e.decode_into(&mut out);
            }
            if let Ok(d) = pn::parse_content_disposition(v) {
                if let Some(f) = d.filename() {
                    let _ = f.decode_into(&mut out);
                }
            }
            let _ = pn::response_cache_control(v);
            let _ = pn::request_cache_control(v);
            let _ = pn::parse_origin(v);
            let lines = [v];
            if let Ok(f) = forwarded::parse(&lines, &l) {
                let _ = f.iter().count();
            }
            if let Ok(x) = forwarded::parse_x_forwarded_for(&lines, &l) {
                let _ = x.iter().count();
            }
            let _ = pn::client_address(peer, ForwardedSource::Forwarded(&lines), &trust, 8);
            let _ = pn::client_address(peer, ForwardedSource::XForwardedFor(&lines), &trust, 8);
            let _ = auth::parse_credentials(v, &l);
            let _ = pn::basic(v);
            if let Ok(c) = auth::parse_challenges(v, &l) {
                for ch in c.iter() {
                    let _ = ch.param("realm");
                }
            }
            if let Ok(i) = sfv::parse_item(v) {
                let _ = i.params.get("a");
            }
            if let Ok(s) = sfv::parse_list(v) {
                for m in s.iter() {
                    if let sfv::Member::InnerList(il) = m {
                        let _ = il.iter().count();
                    }
                }
            }
            if let Ok(d) = sfv::parse_dictionary(v) {
                let _ = d.get("a");
                let _ = d.index_into(&mut slots);
            }
            let _ = sfv::parse_list_lines(&lines);
        }
    });
    assert_eq!(n, 0, "a web-layer parse allocated");
}

#[test]
fn test_web_layer_writing_never_allocates() {
    let mut buf = [0u8; 1024];
    let mut buf2 = [0u8; 256];
    let n = allocations(|| {
        let mut out = SliceSink::new(&mut buf);
        let _ = EntityTag::weak(b"v1").map(|t| t.write_to(&mut out));
        let _ = range::write_content_range(ByteRange { start: 0, end: 9 }, Some(10), &mut out);
        let _ = range::write_unsatisfied(10, &mut out);
        let _ = pn::write_ext_value("\u{20ac} rates", &mut out);
        let _ = pn::write_attachment("\u{20ac} rates.txt", &mut out);
        let _ = auth::write_challenge("Basic", &[("realm", "a \"b\"")], &mut out);
        let _ = auth::write_challenge_token68("Negotiate", b"abc==", &mut out);
        let mut c = SliceSink::new(&mut buf2);
        let mut w = cache::Writer::new(&mut c);
        let _ = w.flag("no-store");
        let _ = w.seconds("max-age", 60);
        let _ = w.fields("no-cache", &["Set-Cookie"]);
    });
    assert_eq!(n, 0, "a web-layer write allocated");
}

/// 0.5 inputs: links, mail values, dates, parameters, addresses.
const MAIL_INPUTS: &[&[u8]] = &[
    b"<https://x.test/p?page=2,3>; rel=\"next last\"; title*=UTF-8''%E2%82%AC, </a>; rel=prev",
    b"Wed, 21 Oct 2026 17:38:00 +0200",
    b"21 Oct 26 17:38 (c) EDT",
    b"a long\r\n subject",
    b"=?UTF-8?Q?Caf=C3=A9?= =?ISO-8859-1?Q?_cr=E8me?=",
    b"; filename*0*=UTF-8''caf%C3%A9; filename*1=\".txt\"; charset=utf-8",
    b"\"john doe\"@example.com",
    b"John Q. Public <jqp@example.com>",
    b"<1234.5678@mail.example.com>",
    b"\"unterminated",
];

#[test]
fn test_mail_and_link_parsing_never_allocates() {
    let l = Limits::DEFAULT;
    let mut out = [0u8; 512];
    let n = allocations(|| {
        for &v in MAIL_INPUTS {
            if let Ok(links) = pn::parse_link(v, &l) {
                for x in links.iter() {
                    let _ = x.has_rel("next");
                    if let Some(t) = x.title() {
                        let _ = t.decode_into(&mut out);
                    }
                }
            }
            let _ = pn::MailDate::parse(v, false).map(pn::MailDate::format);
            let _ = pn::MailDate::parse(v, true);
            let _ = mail::check_header_value(v);
            if let Ok(u) = mail::unfold(v) {
                let _ = u.iter().count();
            }
            let _ = mail::decode_words(v, &l, &mut out);
            if let Ok((p, _)) = mail::parse_mime_params(v, &l) {
                let _ = p.decode_into("filename", &mut out);
                let _ = p.get("charset");
            }
            let _ = mail::parse_addr_spec(v).map(|a| a.is_ascii());
            let _ = mail::parse_mailbox(v, &l);
            let _ = mail::parse_msg_id(v);
            if let Ok(list) = sfv::parse_list(v) {
                let _ = list.iter().count();
            }
        }
    });
    assert_eq!(n, 0, "a 0.5 parse allocated");
}

#[test]
fn test_mail_and_link_writing_never_allocates() {
    let mut buf = [0u8; 4096];
    let n = allocations(|| {
        let mut out = SliceSink::new(&mut buf);
        let _ = pn::link::write_link(b"/a?b", &[("rel", "next"), ("title", "x y")], &mut out);
        let _ = pn::MailDate::new(0, 120).map(|d| d.write_to(&mut out));
        let _ = mail::fold(
            "Subject",
            b"a value that is long enough to fold at least once when it passes the limit",
            &mut out,
        );
        let _ = mail::encode_words("Caf\u{e9} au lait", 20, &mut out);
        let _ = mail::write_mime_param("filename", "caf\u{e9}.txt", &mut out);
        let _ = mail::write_msg_id("a.b", "example.com", &mut out);
        let e = forwarded::Element {
            for_: Some(forwarded::Node::Addr(IpAddr::from([192, 0, 2, 1]), None)),
            by: None,
            host: None,
            proto: Some(forwarded::Proto::Https),
        };
        let _ = forwarded::write_element(&e, &mut out);
        let mut w = sfv::Writer::list(&mut out);
        let _ = w
            .integer(1)
            .and_then(|w| w.param_key("a"))
            .and_then(|w| w.string("x"));
        let _ = w
            .open_inner_list()
            .and_then(|w| w.token("t"))
            .and_then(|w| w.close_inner_list());
        let _ = w.finish();
    });
    assert_eq!(n, 0, "a 0.5 write allocated");
}

#[test]
fn test_counter_sees_allocations() {
    // Proves the counter works, so a zero above means something.
    let n = allocations(|| drop(std::hint::black_box(vec![1u8; 16])));
    assert!(n >= 1);
}