cloud-sdk 0.44.0

no_std-first provider-neutral cloud SDK foundations.
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

use super::super::{
    OffsetPageMetadata, OffsetPagination, PaginationBudget, PaginationError, PaginationLimits,
    SnapshotPolicy,
};

fn traversal(requests: u32, items: u64) -> OffsetPagination {
    let limits = PaginationLimits::new(requests, items, 64).unwrap_or_else(|_| unreachable!());
    OffsetPagination::new(
        0,
        20,
        PaginationBudget::new(limits, SnapshotPolicy::Forbidden),
    )
    .unwrap_or_else(|_| unreachable!())
}

#[test]
fn walks_offsets_and_binds_exact_progression() {
    let mut offset_traversal = traversal(3, 50);
    let first =
        OffsetPageMetadata::new(0, 20, Some(20), Some(23)).unwrap_or_else(|_| unreachable!());
    assert!(offset_traversal.observe(first, 20, None, None).is_ok());
    assert_eq!(offset_traversal.next_offset(), Ok(20));
    let last = OffsetPageMetadata::new(20, 20, None, Some(23)).unwrap_or_else(|_| unreachable!());
    assert!(
        offset_traversal
            .observe(last, 3, None, None)
            .is_ok_and(|value| { value.is_terminal() && value.progress().items() == 23 })
    );
}

#[test]
fn rejects_offset_skips_total_drift_and_budget_overrun_transactionally() {
    let mut offset_traversal = traversal(3, 50);
    let skipped = OffsetPageMetadata::new(0, 20, Some(21), None).unwrap_or_else(|_| unreachable!());
    assert_eq!(
        offset_traversal.observe(skipped, 20, None, None),
        Err(PaginationError::InvalidNextPage)
    );
    assert_eq!(offset_traversal.next_offset(), Ok(0));

    let first =
        OffsetPageMetadata::new(0, 20, Some(20), Some(40)).unwrap_or_else(|_| unreachable!());
    assert!(offset_traversal.observe(first, 20, None, None).is_ok());
    let changed =
        OffsetPageMetadata::new(20, 20, None, Some(21)).unwrap_or_else(|_| unreachable!());
    assert_eq!(
        offset_traversal.observe(changed, 1, None, None),
        Err(PaginationError::TraversalChanged)
    );
    assert_eq!(offset_traversal.next_offset(), Ok(20));

    let mut limited = traversal(2, 19);
    let response =
        OffsetPageMetadata::new(0, 20, None, Some(20)).unwrap_or_else(|_| unreachable!());
    assert_eq!(
        limited.observe(response, 20, None, None),
        Err(PaginationError::ItemBudgetExceeded)
    );
    assert_eq!(limited.progress().items(), 0);
}