logos-co
/
nomos-node
mirror of
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

update waku (#146) 

* update waku

* Fix waku update

---------

Co-authored-by: danielsanchezq <sanchez.quiros.daniel@gmail.com>
This commit is contained in:
Giacomo Pasini 2023-05-15 16:21:49 +02:00 committed by GitHub
parent 4b880778ab
commit bbd313f70a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 14 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
nodes/mockpool-node/Cargo.toml
View File

@ -28,4 +28,4 @@ serde_json = "1.0"
serde_yaml = "0.9" serde_yaml = "0.9"
color-eyre = "0.6.0" color-eyre = "0.6.0"
serde = "1" serde = "1"
waku-bindings = "0.1.0-rc.2" waku-bindings = "0.1.0"

2
nodes/mockpool-node/src/bridges.rs
View File

@ -244,6 +244,8 @@ async fn send_transaction(
WAKU_CARNOT_TX_CONTENT_TOPIC.clone(), WAKU_CARNOT_TX_CONTENT_TOPIC.clone(),
1, 1,
chrono::Utc::now().timestamp() as usize, chrono::Utc::now().timestamp() as usize,
[],
false,
), ),
topic: Some(WAKU_CARNOT_PUB_SUB_TOPIC.clone()), topic: Some(WAKU_CARNOT_PUB_SUB_TOPIC.clone()),
})) }))

11
nomos-services/consensus/src/network/adapters/waku.rs
View File

@ -112,7 +112,14 @@ impl WakuAdapter {
} }
async fn broadcast(&self, bytes: Box<[u8]>, topic: WakuContentTopic) { 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 if let Err((_, _e)) = self
.network_relay .network_relay
.send(NetworkMsg::Process(WakuBackendMessage::Broadcast { .send(NetworkMsg::Process(WakuBackendMessage::Broadcast {
@ -220,6 +227,8 @@ impl NetworkAdapter for WakuAdapter {
content_topic, content_topic,
1, 1,
chrono::Utc::now().timestamp() as usize, chrono::Utc::now().timestamp() as usize,
[],
false,
); );
if let Err((_, _e)) = self if let Err((_, _e)) = self
.network_relay .network_relay

2
nomos-services/network/Cargo.toml
View File

@ -19,7 +19,7 @@ tokio-stream = "0.1"
thiserror = "1.0" thiserror = "1.0"
tracing = "0.1" tracing = "0.1"
rand = { version = "0.8", optional = true } 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-appender = "0.2"
tracing-subscriber = { version = "0.3", features = ["json"] } tracing-subscriber = { version = "0.3", features = ["json"] }
tracing-gelf = "0.7" tracing-gelf = "0.7"