aeternusdb 1.0.0

An embeddable, persistent key-value store built on an LSM-tree architecture.
Documentation 
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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116

//! Tests for safety limits: MAX_BYTE_LEN, MAX_VEC_ELEMENTS,
//! and LengthOverflow error paths.

use crate::encoding::*;

// ------------------------------------------------------------------------------------------------
// Vec<u8> decode — length exceeds MAX_BYTE_LEN
// ------------------------------------------------------------------------------------------------

#[test]
fn vec_u8_decode_exceeds_max_byte_len() {
    // Craft a buffer that claims length = MAX_BYTE_LEN + 1
    let bogus_len = MAX_BYTE_LEN + 1;
    let buf = bogus_len.to_le_bytes();
    let err = decode_from_slice::<Vec<u8>>(&buf).unwrap_err();
    assert!(
        matches!(err, EncodingError::LengthOverflow(_)),
        "expected LengthOverflow, got: {err:?}"
    );
}

#[test]
fn vec_u8_decode_at_max_byte_len_needs_data() {
    // length = MAX_BYTE_LEN (valid limit) but no data follows → UnexpectedEof
    let buf = MAX_BYTE_LEN.to_le_bytes();
    let err = decode_from_slice::<Vec<u8>>(&buf).unwrap_err();
    assert!(
        matches!(err, EncodingError::UnexpectedEof { .. }),
        "expected UnexpectedEof, got: {err:?}"
    );
}

// ------------------------------------------------------------------------------------------------
// String decode — length exceeds MAX_BYTE_LEN (goes through Vec<u8>)
// ------------------------------------------------------------------------------------------------

#[test]
fn string_decode_exceeds_max_byte_len() {
    let bogus_len = MAX_BYTE_LEN + 1;
    let buf = bogus_len.to_le_bytes();
    let err = decode_from_slice::<String>(&buf).unwrap_err();
    assert!(matches!(err, EncodingError::LengthOverflow(_)));
}

// ------------------------------------------------------------------------------------------------
// PathBuf decode — length exceeds MAX_BYTE_LEN
// ------------------------------------------------------------------------------------------------

#[test]
fn pathbuf_decode_exceeds_max_byte_len() {
    let bogus_len = MAX_BYTE_LEN + 1;
    let buf = bogus_len.to_le_bytes();
    let err = decode_from_slice::<std::path::PathBuf>(&buf).unwrap_err();
    assert!(matches!(err, EncodingError::LengthOverflow(_)));
}

// ------------------------------------------------------------------------------------------------
// decode_vec — count exceeds MAX_VEC_ELEMENTS
// ------------------------------------------------------------------------------------------------

/// Simple type for testing.
#[derive(Debug, PartialEq)]
struct Dummy(u8);

impl Encode for Dummy {
    fn encode_to(&self, buf: &mut Vec<u8>) -> Result<(), EncodingError> {
        self.0.encode_to(buf)
    }
}

impl Decode for Dummy {
    fn decode_from(buf: &[u8]) -> Result<(Self, usize), EncodingError> {
        let (v, n) = u8::decode_from(buf)?;
        Ok((Dummy(v), n))
    }
}

#[test]
fn decode_vec_exceeds_max_elements() {
    let bogus_count = MAX_VEC_ELEMENTS + 1;
    let buf = bogus_count.to_le_bytes();
    let err = decode_vec::<Dummy>(&buf).unwrap_err();
    assert!(
        matches!(err, EncodingError::LengthOverflow(_)),
        "expected LengthOverflow, got: {err:?}"
    );
}

#[test]
fn decode_vec_at_max_elements_needs_data() {
    // count = MAX_VEC_ELEMENTS (valid) but no data follows → UnexpectedEof
    let buf = MAX_VEC_ELEMENTS.to_le_bytes();
    let err = decode_vec::<Dummy>(&buf).unwrap_err();
    assert!(
        matches!(err, EncodingError::UnexpectedEof { .. }),
        "expected UnexpectedEof, got: {err:?}"
    );
}

// ------------------------------------------------------------------------------------------------
// Crafted u32::MAX length — LengthOverflow
// ------------------------------------------------------------------------------------------------

#[test]
fn vec_u8_decode_u32_max_length() {
    let buf = u32::MAX.to_le_bytes();
    let err = decode_from_slice::<Vec<u8>>(&buf).unwrap_err();
    assert!(matches!(err, EncodingError::LengthOverflow(_)));
}

#[test]
fn decode_vec_u32_max_count() {
    let buf = u32::MAX.to_le_bytes();
    let err = decode_vec::<Dummy>(&buf).unwrap_err();
    assert!(matches!(err, EncodingError::LengthOverflow(_)));
}