From bbd313f70a1ab15aefac2e388ec8f15f6032bd6e Mon Sep 17 00:00:00 2001 From: Giacomo Pasini Date: Mon, 15 May 2023 16:21:49 +0200 Subject: [PATCH] update waku (#146) * update waku * Fix waku update --------- Co-authored-by: danielsanchezq --- nodes/mockpool-node/Cargo.toml | 2 +- nodes/mockpool-node/src/bridges.rs | 2 ++ nomos-services/consensus/src/network/adapters/waku.rs | 11 ++++++++++- nomos-services/network/Cargo.toml | 2 +- 4 files changed, 14 insertions(+), 3 deletions(-) diff --git a/nodes/mockpool-node/Cargo.toml b/nodes/mockpool-node/Cargo.toml index fdaed7e2..e50779ba 100644 --- a/nodes/mockpool-node/Cargo.toml +++ b/nodes/mockpool-node/Cargo.toml @@ -28,4 +28,4 @@ serde_json = "1.0" serde_yaml = "0.9" color-eyre = "0.6.0" serde = "1" -waku-bindings = "0.1.0-rc.2" +waku-bindings = "0.1.0" diff --git a/nodes/mockpool-node/src/bridges.rs b/nodes/mockpool-node/src/bridges.rs index 1d1529e0..066013e7 100644 --- a/nodes/mockpool-node/src/bridges.rs +++ b/nodes/mockpool-node/src/bridges.rs @@ -244,6 +244,8 @@ async fn send_transaction( WAKU_CARNOT_TX_CONTENT_TOPIC.clone(), 1, chrono::Utc::now().timestamp() as usize, + [], + false, ), topic: Some(WAKU_CARNOT_PUB_SUB_TOPIC.clone()), })) diff --git a/nomos-services/consensus/src/network/adapters/waku.rs b/nomos-services/consensus/src/network/adapters/waku.rs index d3758859..694027d8 100644 --- a/nomos-services/consensus/src/network/adapters/waku.rs +++ b/nomos-services/consensus/src/network/adapters/waku.rs @@ -112,7 +112,14 @@ impl WakuAdapter { } async fn broadcast(&self, bytes: Box<[u8]>, topic: WakuContentTopic) { - let message = WakuMessage::new(bytes, topic, 1, chrono::Utc::now().timestamp() as usize); + let message = WakuMessage::new( + bytes, + topic, + 1, + chrono::Utc::now().timestamp() as usize, + [], + false, + ); if let Err((_, _e)) = self .network_relay .send(NetworkMsg::Process(WakuBackendMessage::Broadcast { @@ -220,6 +227,8 @@ impl NetworkAdapter for WakuAdapter { content_topic, 1, chrono::Utc::now().timestamp() as usize, + [], + false, ); if let Err((_, _e)) = self .network_relay diff --git a/nomos-services/network/Cargo.toml b/nomos-services/network/Cargo.toml index f75a329d..57e26e65 100644 --- a/nomos-services/network/Cargo.toml +++ b/nomos-services/network/Cargo.toml @@ -19,7 +19,7 @@ tokio-stream = "0.1" thiserror = "1.0" tracing = "0.1" rand = { version = "0.8", optional = true } -waku-bindings = { version = "0.1.0-rc.2", optional = true } +waku-bindings = { version = "0.1.0", optional = true } tracing-appender = "0.2" tracing-subscriber = { version = "0.3", features = ["json"] } tracing-gelf = "0.7"