icydb 0.280.2

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
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

//! Current endpoint envelopes and native projections.

use crate::wire::{Endpoint, ID_BASE};

#[test]
fn endpoint_identity_and_direction_are_checked_before_payloads() {
    let request = Endpoint::Metrics.encode_request(()).unwrap();
    assert_eq!(&request[..2], b"IW");
    assert_eq!(&request[2..10], &Endpoint::Metrics.id().to_le_bytes());
    assert_eq!(request[10], 0);
    assert_eq!(Endpoint::Metrics.decode_request::<()>(&request), Ok(()));
    assert_eq!(
        Endpoint::Snapshot.decode_request::<()>(&request),
        Err(ic_wire::Error::Identity)
    );
    assert_eq!(
        Endpoint::Metrics.decode_response::<()>(&request),
        Err(ic_wire::Error::Identity)
    );

    let response = Endpoint::Metrics.encode_response(()).unwrap();
    assert_eq!(response[10], 1);
    assert_eq!(Endpoint::Metrics.decode_response::<()>(&response), Ok(()));
}

#[test]
fn borrowed_arguments_share_the_generated_native_request_projection() {
    let sql = "SELECT id FROM Item".to_owned();
    let request = Endpoint::Query.encode_request((&sql,)).unwrap();
    assert_eq!(
        Endpoint::Query.decode_request::<String>(&request).unwrap(),
        sql
    );
    assert!(
        Endpoint::Query
            .decode_request::<String>(&request[..request.len() - 1])
            .is_err()
    );
    let mut trailing = request;
    trailing.push(0);
    assert!(Endpoint::Query.decode_request::<String>(&trailing).is_err());
}

#[test]
fn lifecycle_arguments_bind_their_phase_and_native_types() {
    let arguments = ("fixture".to_owned(), 42_u64);
    let bytes = crate::wire::encode_init_arguments(&arguments).unwrap();
    let decoded = ic_wire::native::decode_request::<(String, u64)>(
        ID_BASE + 13,
        &bytes,
        icydb_schema::wire::limits(crate::wire::MAX_REQUEST_BYTES),
    )
    .unwrap();
    assert_eq!(decoded, arguments);
    assert!(
        ic_wire::native::decode_request::<(String, u64)>(
            ID_BASE + 14,
            &bytes,
            icydb_schema::wire::limits(crate::wire::MAX_REQUEST_BYTES)
        )
        .is_err()
    );
    let upgrade = crate::wire::encode_post_upgrade_arguments(&arguments).unwrap();
    let decoded = ic_wire::native::decode_request::<(String, u64)>(
        ID_BASE + 14,
        &upgrade,
        icydb_schema::wire::limits(crate::wire::MAX_REQUEST_BYTES),
    )
    .unwrap();
    assert_eq!(decoded, arguments);
}

#[test]
fn typed_public_errors_round_trip_through_the_actual_endpoint_envelope() {
    let error = crate::Error::from_runtime_boundary(
        crate::diagnostic::RuntimeBoundaryCode::DatabaseStartupRecoveryPending,
        crate::ErrorOrigin::Runtime,
    );
    let response: Result<(), crate::Error> = Err(error);
    let bytes = Endpoint::MetricsReset.encode_response(&response).unwrap();
    assert_eq!(
        Endpoint::MetricsReset
            .decode_response::<Result<(), crate::Error>>(&bytes)
            .unwrap(),
        response
    );
}