icydb-core 0.98.1

IcyDB — A schema-first typed query engine and persistence runtime for Internet Computer canisters
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

//! Module: db::executor::terminal::tests
//! Covers terminal paging, shaping, and output invariants in executor
//! materialization paths.
//! Does not own: cross-module orchestration outside this module.
//! Boundary: exposes this module API while keeping implementation details internal.

use crate::value::Value;

use crate::db::executor::terminal::{
    bytes_window_accept_row, bytes_window_limit_exhausted, saturating_add_payload_len,
    serialized_value_len,
};

#[test]
fn payload_len_sum_saturates_on_overflow() {
    let total = saturating_add_payload_len(u64::MAX - 2, 10);
    assert_eq!(total, u64::MAX);
}

#[test]
fn payload_len_sum_accumulates_without_overflow() {
    let total = saturating_add_payload_len(11, 5);
    assert_eq!(total, 16);
}

#[test]
fn bytes_window_accept_row_respects_offset_and_limit() {
    let mut offset_remaining = 2usize;
    let mut limit_remaining = Some(2usize);

    assert!(!bytes_window_accept_row(
        &mut offset_remaining,
        &mut limit_remaining
    ));
    assert!(!bytes_window_accept_row(
        &mut offset_remaining,
        &mut limit_remaining
    ));
    assert!(bytes_window_accept_row(
        &mut offset_remaining,
        &mut limit_remaining
    ));
    assert!(bytes_window_accept_row(
        &mut offset_remaining,
        &mut limit_remaining
    ));
    assert!(!bytes_window_accept_row(
        &mut offset_remaining,
        &mut limit_remaining
    ));
    assert!(bytes_window_limit_exhausted(limit_remaining));
}

#[test]
fn serialized_value_len_encodes_scalar_payload() {
    let len = serialized_value_len(&Value::Uint(10)).expect("value encode should succeed");
    assert!(len > 0, "encoded scalar payload should be non-empty");
}