ckb-sync 1.3.2

The ckb sync/relayer protocols implementation
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

use crate::relayer::block_uncles_verifier::BlockUnclesVerifier;
use crate::{Status, StatusCode};
use ckb_types::{
    core::BlockBuilder,
    packed::{CompactBlock, CompactBlockBuilder},
    prelude::*,
};

fn build_compact_block_with_uncles() -> (CompactBlock, Vec<ckb_types::core::UncleBlockView>) {
    let uncles = vec![
        BlockBuilder::default().nonce(1u128).build().as_uncle(),
        BlockBuilder::default().nonce(2u128).build().as_uncle(),
    ];
    let uncle_hashes = uncles.iter().map(|uncle| uncle.hash()).collect::<Vec<_>>();
    let block = CompactBlockBuilder::default().uncles(uncle_hashes).build();
    (block, uncles)
}

#[test]
fn test_invalid_len() {
    let (block, uncles) = build_compact_block_with_uncles();

    assert_eq!(
        BlockUnclesVerifier::verify(&block, &[0, 1], &uncles[..1]),
        StatusCode::BlockUnclesLengthIsUnmatchedWithPendingCompactBlock.into(),
    );
}

#[test]
fn test_unmatched_hash() {
    let (block, _) = build_compact_block_with_uncles();
    let wrong_uncle = BlockBuilder::default().nonce(3u128).build().as_uncle();

    assert_eq!(
        BlockUnclesVerifier::verify(&block, &[0], &[wrong_uncle]),
        StatusCode::BlockUnclesAreUnmatchedWithPendingCompactBlock.into(),
    );
}

#[test]
fn test_ok() {
    let (block, uncles) = build_compact_block_with_uncles();

    assert_eq!(
        BlockUnclesVerifier::verify(&block, &[0, 1], &uncles),
        Status::ok(),
    );
}