icydb-cli 0.296.7

Developer CLI tools for IcyDB
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

use icydb::__macro::RpcMethod;
use icydb::db::{ExpectedAcceptedHead, SchemaMigrationCommand, TargetDatabaseIdentity};
use icydb_schema::{ExpectedSchemaFingerprint, SchemaMigrationPlanDigest};

#[test]
fn migration_commands_decode_without_canister_type_metadata() {
    for revision in [1, u64::MAX] {
        for head in [
            ExpectedAcceptedHead::Empty,
            ExpectedAcceptedHead::Exact {
                revision,
                fingerprint: ExpectedSchemaFingerprint::from_bytes([3; 32]),
            },
        ] {
            let database = TargetDatabaseIdentity::from_bytes([1; 32]);
            let plan = SchemaMigrationPlanDigest::from_bytes([2; 32]);
            for command in [
                SchemaMigrationCommand::Adopt {
                    expected_database: database,
                    expected_head: head.clone(),
                },
                SchemaMigrationCommand::Abort {
                    expected_database: database,
                    expected_head: head.clone(),
                    expected_plan: plan,
                },
                SchemaMigrationCommand::Advance {
                    expected_database: database,
                    expected_head: head.clone(),
                    expected_plan: plan,
                },
            ] {
                // The argument carries its own types, without service metadata.
                let bytes = RpcMethod::SchemaMigrate
                    .encode_request(
                        &command,
                        icydb::wire::limits(icydb::wire::MAX_REQUEST_BYTES),
                    )
                    .unwrap();
                assert_eq!(
                    icydb::__macro::RpcMethod::SchemaMigrate
                        .decode_request::<SchemaMigrationCommand>(
                            &bytes,
                            icydb::wire::limits(icydb::wire::MAX_REQUEST_BYTES)
                        )
                        .unwrap(),
                    command
                );
            }
        }
    }
}