sark-http 0.29.3

HTTP wire types, semantics, codecs, and ownership invariants for Sark
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

use sark_http::preface::{CLIENT_PREFACE, Prefix, Read};

#[test]
fn carries_only_the_admitted_prefix() {
    for split in 0..CLIENT_PREFACE.len() {
        let (count, Read::Pending(prefix)) = Prefix::default()
            .read(&CLIENT_PREFACE[..split])
            .expect("prefix")
        else {
            panic!("incomplete prefix");
        };
        assert_eq!(count, split);
        assert_eq!(prefix.as_ref(), &CLIENT_PREFACE[..split]);
        let mut suffix = CLIENT_PREFACE[split..].to_vec();
        suffix.push(0);
        let (count, Read::Complete(_)) = prefix.read(&suffix).expect("complete") else {
            panic!("complete preface");
        };
        assert_eq!(
            count,
            suffix.len() - 1,
            "next protocol input stays unconsumed"
        );
    }
}

#[test]
fn mismatch_retains_prior_input_and_exact_failure() {
    let (_, Read::Pending(prefix)) = Prefix::default().read(b"P").expect("prefix") else {
        panic!("partial preface");
    };
    let (prefix, offset, expected, actual) = prefix.read(b"RX").expect_err("mismatch").into_parts();
    assert_eq!(
        prefix.as_ref(),
        b"P",
        "the current input remains with its caller"
    );
    assert_eq!((offset, expected, actual), (2, b'I', b'X'));
}