feat(network): initial gossip implementation

alchemyplatform · Oct 12, 2023 · 9d38cc8 · 9d38cc8
1 parent 6c48301
commit 9d38cc8
Show file tree

Hide file tree

Showing 16 changed files with 1,012 additions and 244 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/crates/network/Cargo.toml b/crates/network/Cargo.toml
@@ -12,23 +12,27 @@ rundler-types = { path = "../types" }
 ethereum_ssz = "0.5.3"
 ethereum_ssz_derive = "0.5.3"
 ethers.workspace = true
-snap = "1.1.0"
-ssz_types = "0.5.4"
 discv5 = { version = "0.3.1", features = ["libp2p"] }
 futures.workspace = true
 hex = "0.4.3"
 libp2p-mplex = "0.40.0"
+sha2 = "0.10.8"
+snap = "1.1.0"
+ssz_types = "0.5.4"
 tokio.workspace = true
 tokio-io-timeout = "1.2.0"
 tokio-util = { workspace = true, features = ["codec", "compat"] }
 thiserror.workspace = true
 tracing.workspace = true
 unsigned-varint = { version = "0.7.2", features = ["codec"] }
 
+# required version by gossipsub
+getrandom = "0.2.10"
+
 [dependencies.libp2p]
 version = "0.52.3"
 default-features = false
-features = ["tokio", "noise", "macros", "tcp", "identify", "yamux", "secp256k1"]
+features = ["tokio", "noise", "macros", "tcp", "identify", "yamux", "secp256k1", "gossipsub"]
 
 [dev-dependencies]
 rand.workspace = true

diff --git a/crates/network/src/behaviour.rs b/crates/network/src/behaviour.rs
@@ -16,12 +16,15 @@ use libp2p::{
     swarm::{keep_alive, NetworkBehaviour},
 };
 
-use crate::{discovery, rpc};
+use crate::{discovery, gossip, rpc};
+
+pub(crate) type GossipSub = libp2p::gossipsub::Behaviour<gossip::SnappyTransform>;
 
 #[derive(NetworkBehaviour)]
 pub(crate) struct Behaviour {
     // TODO(danc): temp, remove when not needed
     pub(crate) keep_alive: keep_alive::Behaviour,
+    pub(crate) gossipsub: GossipSub,
     // Request/response protocol
     pub(crate) rpc: rpc::Behaviour,
     // Discv5 based discovery protocol