s2n-quic-dc 0.77.0

// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
// SPDX-License-Identifier: Apache-2.0

use super::*;
use crate::credentials::Id;
use bolero::{check, ValueGenerator};
use rand::{seq::SliceRandom, RngExt, SeedableRng};
use std::collections::{binary_heap::PeekMut, BinaryHeap, HashSet};

#[test]
fn check() {
    check!().with_type::<Vec<KeyId>>().for_each(|ops| {
        let mut oracle = std::collections::HashSet::new();
        let subject = State::new();
        let id = Id::from([0; 16]);
        for op in ops {
            let expected = oracle.insert(*op);
            let actual = subject
                .post_authentication(&Credentials { id, key_id: *op })
                .is_ok();
            // If we did expect this to be a new value, it may have already been marked as
            // "seen" by the set. However, we should never return a false OK (i.e., claim that
            // the value was not seen when it actually was).
            if !expected {
                assert!(!actual);
            }
        }
    });
}

#[test]
fn check_huge_gap() {
    let subject = State::new();
    let id = Id::from([0; 16]);
    for op in [0u64, u32::MAX as u64 + 10] {
        let actual = subject
            .post_authentication(&Credentials {
                id,
                key_id: KeyId::new(op).unwrap(),
            })
            .is_ok();
        assert!(actual);
    }
}

#[test]
fn check_ordered() {
    check!().with_type::<Vec<KeyId>>().for_each(|ops| {
        let mut ops = ops.clone();
        ops.sort();
        let mut oracle = std::collections::HashSet::new();
        let subject = State::new();
        let id = Id::from([0; 16]);
        for op in ops {
            let expected = oracle.insert(op);
            let actual = subject
                .post_authentication(&Credentials { id, key_id: op })
                .is_ok();
            assert_eq!(actual, expected);
        }
    });
}

#[test]
fn check_u16() {
    check!().with_type::<Vec<u16>>().for_each(|ops| {
        let mut oracle = std::collections::HashSet::new();
        let subject = State::new();
        for op in ops {
            let op = KeyId::new(*op as u64).unwrap();
            let expected = oracle.insert(op);
            let id = Id::from([0; 16]);
            let actual = subject
                .post_authentication(&Credentials { id, key_id: op })
                .is_ok();
            // If we did expect this to be a new value, it may have already been marked as
            // "seen" by the set. However, we should never return a false OK (i.e., claim that
            // the value was not seen when it actually was).
            if !expected {
                assert!(!actual);
            }
        }
    });
}

#[test]
fn check_ordered_u16() {
    check!().with_type::<Vec<u16>>().for_each(|ops| {
        let mut ops = ops.clone();
        ops.sort();
        let mut oracle = std::collections::HashSet::new();
        let subject = State::new();
        let id = Id::from([0; 16]);
        for op in ops {
            let op = KeyId::new(op as u64).unwrap();
            let expected = oracle.insert(op);
            let actual = subject
                .post_authentication(&Credentials { id, key_id: op })
                .is_ok();
            assert_eq!(actual, expected);
        }
    });
}

// This test is not particularly interesting, it's mostly just the same as the random tests above
// which insert ordered and unordered values. Mostly it tests that we continue to allow 129 IDs of
// arbitrary reordering.
#[test]
fn check_shuffled_chunks() {
    check!()
        .with_type::<(u64, u8)>()
        .for_each(|&(seed, chunk_size)| {
            check_shuffled_chunks_inner(seed, chunk_size);
        });
}

#[test]
fn check_shuffled_chunks_specific() {
    check_shuffled_chunks_inner(0xf323243, 10);
    check_shuffled_chunks_inner(0xf323243, 63);
    check_shuffled_chunks_inner(0xf323243, 129);
}

fn check_shuffled_chunks_inner(seed: u64, chunk_size: u8) {
    eprintln!("======== starting test run ({seed} {chunk_size}) ==========");
    if chunk_size == 0 || chunk_size >= 129 {
        // Needs at least 1 in the chunk.
        //
        // Chunk sizes that are larger than the local set are not guaranteed to pass, since they
        // may skip entirely over the 129-element window which then isn't inserted at all into our
        // backup/shared set.
        return;
    }
    let mut model = Model::default();
    let mut rng = rand::rngs::SmallRng::seed_from_u64(seed);
    let mut deltas = (-(chunk_size as i32 / 2)..(chunk_size as i32 / 2)).collect::<Vec<_>>();
    for initial in (128u32..100_000u32).step_by(chunk_size as usize) {
        deltas.shuffle(&mut rng);
        for delta in deltas.iter() {
            model.insert(initial.checked_add_signed(*delta).unwrap() as u64);
        }
    }
}

// This represents the commonly seen behavior in production where a small percentage of inserted
// keys are potentially significantly delayed. Currently our percentage is fixed, but the delay is
// not; it's minimum is set by our test here and the maximum is always at most WINDOW.
//
// This ensures that in the common case we see in production our receiver map, presuming no
// contention in the shared map, is reliably able to return accurate results.
#[test]
fn check_delayed() {
    check!()
        .with_type::<(u64, u16)>()
        .for_each(|&(seed, delay)| {
            if delay as usize >= WINDOW {
                return;
            }
            check_delayed_inner(seed, delay);
        });
}

#[test]
fn check_delayed_specific() {
    check_delayed_inner(0xf323243, 10);
    check_delayed_inner(0xf323243, 63);
    check_delayed_inner(0xf323243, 129);
    check_delayed_inner(0xf323243, (super::WINDOW - 1) as u16);
}

// delay represents the *minimum* delay a delayed entry sees. The maximum is up to WINDOW.
fn check_delayed_inner(seed: u64, delay: u16) {
    assert!((delay as usize) < super::WINDOW);
    let delay = delay as u64;
    eprintln!("======== starting test run ({seed} {delay}) ==========");
    let mut model = Model::default();
    let mut rng = rand::rngs::SmallRng::seed_from_u64(seed);
    // reverse the first element (insert_before) to ensure we pop smallest pending ID first.
    // max on the second element (id_to_insert) to ensure that we go in least-favorable order if
    // there are multiple elements to insert, inserting most recent first and only afterwards older
    // entries.
    let mut buffered: BinaryHeap<(std::cmp::Reverse<u64>, u64)> = BinaryHeap::new();
    for id in 0..(100_000u64 * 3) {
        while let Some(peeked) = buffered.peek_mut() {
            // min-heap means that if the first entry isn't the one we want, then there's no entry
            // that we want.
            if (peeked.0).0 == id {
                model.insert(peeked.1);
                PeekMut::pop(peeked);
            } else {
                break;
            }
        }
        // Every 128th ID gets put in immediately, the rest are delayed by a random amount.
        // This ensures that we always evict all the gaps as we move forward into the backing set.
        // In production, this roughly means that at least 1/128 = 0.7% of packets arrive in relative order
        // to each other. (That's an approximation, it's not obvious how to really derive a simple
        // explanation for what guarantees we're actually trying to provide here).
        if id % 128 != 0 {
            // ...until some random interval no more than WINDOW away.
            let insert_before = rng.random_range(id + 1 + delay..=id + WINDOW as u64);
            buffered.push((std::cmp::Reverse(insert_before), id));
        } else {
            model.insert(id);
        }
    }
}

#[derive(Default)]
struct Model {
    insert_order: Vec<u64>,
    oracle: HashSet<u64>,
    subject: State,
}

impl Model {
    fn insert(&mut self, op: u64) {
        let pid = Id::from([0; 16]);
        let id = KeyId::new(op).unwrap();
        let expected = self.oracle.insert(op);
        if expected {
            self.insert_order.push(op);
        }
        let actual = self.subject.post_authentication(&Credentials {
            id: pid,
            key_id: id,
        });
        if actual.is_ok() != expected {
            let mut oracle = self.oracle.iter().collect::<Vec<_>>();
            oracle.sort_unstable();
            panic!(
                "Inserting {:?} failed, in oracle: {}, in subject: {:?}, inserted: {:?}",
                op, expected, actual, self.insert_order
            );
        }
    }
}

#[test]
fn check_sequential() {
    let subject = State::new();
    let id = Id::from([0; 16]);
    for op in 0u64..(100 * u16::MAX as u64) {
        let actual = subject
            .post_authentication(&Credentials {
                id,
                key_id: KeyId::new(op).unwrap(),
            })
            .is_ok();
        assert!(actual);
    }

    // check all of those are considered gone.
    for op in 0u64..(100 * u16::MAX as u64) {
        subject
            .post_authentication(&Credentials {
                id,
                key_id: KeyId::new(op).unwrap(),
            })
            .unwrap_err();
    }
}

#[test]
fn unseen() {
    let subject = State::new();
    assert_eq!(*subject.minimum_unseen_key_id(), 0);
    let id = Id::from([0; 16]);
    subject
        .post_authentication(&Credentials {
            id,
            key_id: KeyId::new(0).unwrap(),
        })
        .unwrap();
    assert_eq!(*subject.minimum_unseen_key_id(), 1);

    let id = Id::from([0; 16]);
    subject
        .post_authentication(&Credentials {
            id,
            key_id: KeyId::new(3).unwrap(),
        })
        .unwrap();
    assert_eq!(*subject.minimum_unseen_key_id(), 4);

    let id = Id::from([0; 16]);
    subject
        .post_authentication(&Credentials {
            id,
            key_id: KeyId::new(2).unwrap(),
        })
        .unwrap();
    assert_eq!(*subject.minimum_unseen_key_id(), 4);
}

#[test]
#[cfg_attr(kani, kani::proof, kani::unwind(130), kani::solver(kissat))]
#[cfg_attr(miri, ignore)] // this test is too expensive for miri
fn insert_unequal() {
    // Make sure the two packet numbers are not the same
    let gen = bolero::produce::<(KeyId, KeyId)>().filter_gen(|(a, b)| a != b);

    check!()
        .with_generator(gen)
        .cloned()
        .for_each(|(pn, other_pn)| {
            let state = State::new();
            let id = Id::from([0; 16]);
            let pn = Credentials { id, key_id: pn };
            let other_pn = Credentials {
                id,
                key_id: other_pn,
            };
            assert!(state.post_authentication(&pn).is_ok());
            assert_eq!(Err(Error::AlreadyExists), state.post_authentication(&pn));
            assert_ne!(
                Err(Error::AlreadyExists),
                state.post_authentication(&other_pn)
            );
        });
}