linera-chain 0.15.17

Persistent data and the corresponding logics used by the Linera protocol for chains of blocks, certificates, and cross-chain messaging.
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

// Copyright (c) Zefchain Labs, Inc.
// SPDX-License-Identifier: Apache-2.0

use super::*;

#[tokio::test]
async fn test_outbox() {
    let mut view = OutboxStateView::new().await;
    assert!(view.schedule_message(BlockHeight::ZERO).unwrap());
    assert!(view.schedule_message(BlockHeight::from(2)).unwrap());
    assert!(view.schedule_message(BlockHeight::from(4)).unwrap());
    assert!(!view.schedule_message(BlockHeight::ZERO).unwrap());

    assert_eq!(view.queue.count(), 3);
    assert_eq!(
        view.mark_messages_as_received(BlockHeight::from(3))
            .await
            .unwrap(),
        vec![BlockHeight::ZERO, BlockHeight::from(2)]
    );
    assert_eq!(
        view.mark_messages_as_received(BlockHeight::from(3))
            .await
            .unwrap(),
        vec![]
    );
    assert_eq!(view.queue.count(), 1);
    assert_eq!(
        view.mark_messages_as_received(BlockHeight::from(4))
            .await
            .unwrap(),
        vec![BlockHeight::from(4)]
    );
    assert_eq!(view.queue.count(), 0);
}

#[tokio::test]
async fn test_outbox_revert() {
    let mut view = OutboxStateView::new().await;
    // Schedule heights 0, 2, 4.
    assert!(view.schedule_message(BlockHeight::ZERO).unwrap());
    assert!(view.schedule_message(BlockHeight::from(2)).unwrap());
    assert!(view.schedule_message(BlockHeight::from(4)).unwrap());
    // Confirm up to height 2 (removes 0 and 2 from queue).
    view.mark_messages_as_received(BlockHeight::from(2))
        .await
        .unwrap();
    assert_eq!(view.queue.count(), 1); // only height 4 remains

    // Revert: re-add heights 0 and 2.
    let new = view
        .revert(&[BlockHeight::ZERO, BlockHeight::from(2)])
        .await
        .unwrap();
    assert_eq!(new, vec![BlockHeight::ZERO, BlockHeight::from(2)]);
    // Queue now has all three heights in order.
    let elements = view.queue.elements().await.unwrap();
    assert_eq!(
        elements,
        vec![
            BlockHeight::ZERO,
            BlockHeight::from(2),
            BlockHeight::from(4)
        ]
    );

    // Reverting with already-present heights is a no-op.
    let new = view
        .revert(&[BlockHeight::from(2), BlockHeight::from(4)])
        .await
        .unwrap();
    assert!(new.is_empty());
    assert_eq!(view.queue.count(), 3);
}