Skip to content

Commit fa3c164

Browse files
obliquefl0rek
andauthored
feat(node/daser)!: Implement backward sampling and sampling window (#269)
Signed-off-by: Yiannis Marangos <[email protected]> Co-authored-by: Mikołaj Florkiewicz <[email protected]>
1 parent fde19fe commit fa3c164

File tree

11 files changed

+691
-362
lines changed

11 files changed

+691
-362
lines changed

Cargo.lock

Lines changed: 1 addition & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

node-wasm/src/node.rs

Lines changed: 5 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ use libp2p::multiaddr::Protocol;
99
use lumina_node::blockstore::IndexedDbBlockstore;
1010
use lumina_node::network::{canonical_network_bootnodes, network_genesis, network_id};
1111
use lumina_node::node::{Node, NodeConfig};
12-
use lumina_node::store::{IndexedDbStore, Store};
12+
use lumina_node::store::{IndexedDbStore, SamplingStatus, Store};
1313
use serde::Serialize;
1414
use serde_wasm_bindgen::{from_value, to_value};
1515
use tracing::info;
@@ -205,17 +205,13 @@ impl WasmNode {
205205

206206
#[derive(Serialize)]
207207
struct Intermediate {
208-
accepted: bool,
209-
cids_sampled: Vec<String>,
208+
status: SamplingStatus,
209+
cids: Vec<String>,
210210
}
211211

212212
let metadata = metadata.map(|m| Intermediate {
213-
accepted: m.accepted,
214-
cids_sampled: m
215-
.cids_sampled
216-
.into_iter()
217-
.map(|cid| cid.to_string())
218-
.collect(),
213+
status: m.status,
214+
cids: m.cids.into_iter().map(|cid| cid.to_string()).collect(),
219215
});
220216

221217
Ok(to_value(&metadata)?)

node/Cargo.toml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@ categories = [
2020

2121
[dependencies]
2222
celestia-proto = { workspace = true }
23+
celestia-tendermint = { workspace = true }
2324
celestia-tendermint-proto = { workspace = true }
2425
celestia-types = { workspace = true }
2526
libp2p = { workspace = true, features = [

0 commit comments

Comments
 (0)