ic-memory 0.48.2

Durable stable-memory allocation governance 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
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
117
118
119
120
121
122
123
124

use ic_memory::{
    MemoryAllocationPool, MemoryAllocationPoolError, MemoryAuthority, MemoryDeclarationError,
    MemoryRequest,
};

#[test]
fn committed_bindings_serialize_checked_key_and_slot() {
    let mut runtime = ic_memory::MemoryRuntime::new(ic_memory::VectorMemory::default()).unwrap();
    let snapshot = ic_memory::SealedDeclarationSnapshot::new(vec![
        MemoryRequest::new("app", "app.rows.v1").unwrap(),
    ])
    .unwrap();
    let pool =
        MemoryAllocationPool::new(vec![MemoryAuthority::new("app", "app.").unwrap()], vec![])
            .unwrap();
    runtime
        .bootstrap(&snapshot, &pool, &ic_memory::GenericAllocationPolicy)
        .unwrap();
    let declaration = &runtime.committed_allocations().unwrap()[0];
    assert_eq!(
        serde_json::to_value(declaration).unwrap(),
        serde_json::json!({
            "stable_key": "app.rows.v1", "slot": 10,
        })
    );
    let mut bytes = Vec::new();
    ciborium::into_writer(declaration, &mut bytes).unwrap();
    assert_eq!(bytes, b"\xa2\x6astable_key\x6bapp.rows.v1\x64slot\x0a");
}

#[test]
fn diagnostic_metadata_accepts_printable_ascii_through_the_byte_limit() {
    for value in [
        " ".to_string(),
        (b' '..=b'~').map(char::from).collect(),
        "x".repeat(256),
    ] {
        MemoryRequest::new(value.as_str(), "app.rows.v1").unwrap();
        let grant = MemoryAuthority::new(value.as_str(), "app.").unwrap();
        let json = serde_json::json!({"authority":value,"key_prefix":"app."});
        assert_eq!(serde_json::to_value(&grant).unwrap(), json);
        let mut bytes = Vec::new();
        ciborium::into_writer(&grant, &mut bytes).unwrap();
        let wire: serde_json::Value = ciborium::from_reader(bytes.as_slice()).unwrap();
        assert_eq!(wire, json);
        #[cfg(feature = "test-support")]
        {
            assert_eq!(
                serde_json::from_value::<MemoryAuthority>(json).unwrap(),
                grant
            );
            assert_eq!(
                ciborium::from_reader::<MemoryAuthority, _>(bytes.as_slice()).unwrap(),
                grant
            );
        }
    }
}

#[test]
fn diagnostic_metadata_preserves_field_errors_and_rejection_order() {
    let cases = [
        (String::new(), "must not be empty"),
        (
            // Length rejection precedes control-character rejection.
            format!("{}\0", "x".repeat(256)),
            "must be at most 256 bytes",
        ),
        (
            // ASCII rejection precedes control-character rejection.
            "é\0".to_string(),
            "must be ASCII",
        ),
        (
            "printable\u{7f}".to_string(),
            "must not contain ASCII control characters",
        ),
    ];
    for (value, reason) in cases {
        assert_eq!(
            MemoryRequest::new(value.as_str(), "app.rows.v1").unwrap_err(),
            MemoryDeclarationError::InvalidAuthority { reason }
        );
        assert_eq!(
            MemoryAuthority::new(value.as_str(), "app.").unwrap_err(),
            MemoryAllocationPoolError::InvalidAuthority { reason }
        );
    }
}

#[test]
#[cfg(feature = "test-support")]
fn authority_decode_rejects_invalid_metadata_before_pool_assembly() {
    for grant in [
        serde_json::json!({"authority":"","key_prefix":"app."}),
        serde_json::json!({"authority":"app","key_prefix":"ic_memory."}),
        serde_json::json!({"authority":"app","key_prefix":"App."}),
        serde_json::json!({"authority":"app","key_prefix":"app"}),
        serde_json::json!({"authority":"app","key_prefix":"app.","extra":true}),
    ] {
        assert!(serde_json::from_value::<MemoryAuthority>(grant.clone()).is_err());
        let mut bytes = Vec::new();
        ciborium::into_writer(&grant, &mut bytes).unwrap();
        assert!(ciborium::from_reader::<MemoryAuthority, _>(bytes.as_slice()).is_err());
        assert!(
            serde_json::from_value::<MemoryAllocationPool>(
                serde_json::json!({"authorities":[grant],"excluded_ids":[]})
            )
            .is_err()
        );
    }
}
#[test]
#[cfg(feature = "test-support")]
fn authority_decode_preserves_current_shape_and_required_fields() {
    let grant = MemoryAuthority::new("app", "app.").unwrap();
    let json = serde_json::json!({"authority":"app","key_prefix":"app."});
    assert_eq!(serde_json::to_value(&grant).unwrap(), json);
    for field in ["authority", "key_prefix"] {
        let mut incomplete = json.clone();
        incomplete.as_object_mut().unwrap().remove(field);
        assert!(serde_json::from_value::<MemoryAuthority>(incomplete).is_err());
    }
}