lumina-node 1.0.0-rc.3

Celestia data availability node implementation in Rust
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

//! Blockstore types aliases with lumina specific constants.

use blockstore::{Blockstore, Result};
use celestia_types::sample::SAMPLE_ID_CODEC;
use cid::CidGeneric;

use crate::p2p::MAX_MH_SIZE;

/// An [`InMemoryBlockstore`] with maximum multihash size used by lumina.
///
/// [`InMemoryBlockstore`]: blockstore::InMemoryBlockstore
pub type InMemoryBlockstore = blockstore::InMemoryBlockstore<MAX_MH_SIZE>;

#[cfg(not(target_arch = "wasm32"))]
/// A [`RedbBlockstore`].
///
/// [`RedbBlockstore`]: blockstore::RedbBlockstore
pub type RedbBlockstore = blockstore::RedbBlockstore;

#[cfg(target_arch = "wasm32")]
/// An [`IndexedDbBlockstore`].
///
/// [`IndexedDbBlockstore`]: blockstore::IndexedDbBlockstore
pub type IndexedDbBlockstore = blockstore::IndexedDbBlockstore;

/// A blockstore which only stores samples and discards other CIDs.
pub(crate) struct SampleBlockstore<B> {
    blockstore: B,
}

impl<B> SampleBlockstore<B> {
    /// Wrap another blockstore with sample blockstore.
    pub(crate) fn new(blockstore: B) -> Self {
        Self { blockstore }
    }
}

impl<B> Blockstore for SampleBlockstore<B>
where
    B: Blockstore,
{
    async fn get<const S: usize>(&self, cid: &CidGeneric<S>) -> Result<Option<Vec<u8>>> {
        self.blockstore.get(cid).await
    }

    async fn put_keyed<const S: usize>(&self, cid: &CidGeneric<S>, data: &[u8]) -> Result<()> {
        if cid.codec() == SAMPLE_ID_CODEC {
            self.blockstore.put_keyed(cid, data).await
        } else {
            Ok(())
        }
    }

    async fn remove<const S: usize>(&self, cid: &CidGeneric<S>) -> Result<()> {
        self.blockstore.remove(cid).await
    }

    async fn has<const S: usize>(&self, cid: &CidGeneric<S>) -> Result<bool> {
        self.blockstore.has(cid).await
    }

    async fn close(self) -> Result<()> {
        self.blockstore.close().await
    }
}

#[cfg(test)]
mod tests {
    use blockstore::Blockstore;
    use celestia_types::{
        nmt::Namespace, row::RowId, row_namespace_data::RowNamespaceDataId, sample::SampleId,
    };
    use lumina_utils::test_utils::async_test;

    use super::{InMemoryBlockstore, SampleBlockstore};

    #[async_test]
    async fn should_only_store_samples() {
        macro_rules! cid {
            ($bytes:expr) => {
                ::cid::CidGeneric::try_from($bytes).unwrap()
            };
            ($id:ty, $($args:expr),+ $(,)?) => {
                $crate::p2p::shwap::convert_cid(
                    &<$id>::new($($args),+).unwrap().into()
                )
                .unwrap()
            };
        }

        let blockstore = SampleBlockstore::new(InMemoryBlockstore::new());

        let sample_cids = [
            cid!(SampleId, 1, 2, 3),
            cid!(SampleId, 1111, 232, 33),
            cid!(SampleId, 123, 1, 888888888),
        ];

        let non_sample_cids = [
            cid!(RowId, 1, 1737),
            cid!(RowId, 8812, 193139),
            cid!(RowNamespaceDataId, Namespace::new_v0(b"a").unwrap(), 15, 12),
            cid!(RowNamespaceDataId, Namespace::new_v0(b"z").unwrap(), 1, 1),
            cid!([1; 64].as_ref()),
            cid!([[1].as_ref(), &[18; 63]].concat()),
        ];

        for cid in sample_cids.iter().chain(non_sample_cids.iter()) {
            blockstore.put_keyed(cid, &[10; 150]).await.unwrap();
        }

        for cid in &sample_cids {
            assert!(blockstore.has(cid).await.unwrap());
        }
        for cid in &non_sample_cids {
            assert!(!blockstore.has(cid).await.unwrap());
        }
    }
}