Merge of #5401

sigp · Mar 26, 2024 · 0692b2e · 0692b2e
2 parents 5cfd324 + 561d0ff
commit 0692b2e
Show file tree

Hide file tree

Showing 45 changed files with 662 additions and 375 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -9,6 +9,7 @@ members = [
     "beacon_node/client",
     "beacon_node/eth1",
     "beacon_node/lighthouse_network",
+    "beacon_node/lighthouse_network/gossipsub",
     "beacon_node/execution_layer",
     "beacon_node/http_api",
     "beacon_node/http_metrics",
@@ -200,6 +201,7 @@ execution_layer = { path = "beacon_node/execution_layer" }
 filesystem = { path = "common/filesystem" }
 fork_choice = { path = "consensus/fork_choice" }
 genesis = { path = "beacon_node/genesis" }
+gossipsub = { path = "beacon_node/lighthouse_network/gossipsub/" }
 http_api = { path = "beacon_node/http_api" }
 int_to_bytes = { path = "consensus/int_to_bytes" }
 kzg = { path = "crypto/kzg" }

diff --git a/beacon_node/lighthouse_network/Cargo.toml b/beacon_node/lighthouse_network/Cargo.toml
@@ -5,8 +5,8 @@ authors = ["Sigma Prime <contact@sigmaprime.io>"]
 edition = { workspace = true }
 
 [dependencies]
-async-channel = { workspace = true }
 discv5 = { workspace = true }
+gossipsub = { workspace = true }
 unsigned-varint = { version = "0.6", features = ["codec"] }
 ssz_types = { workspace = true }
 types = { workspace = true }
@@ -50,16 +50,12 @@ either = { workspace = true }
 
 # Local dependencies
 futures-ticker = "0.0.3"
-futures-timer = "3.0.2"
 getrandom = "0.2.11"
 hex_fmt = "0.3.0"
 instant = "0.1.12"
-quick-protobuf = "0.8"
 void = "1.0.2"
-asynchronous-codec = "0.7.0"
 base64 = "0.21.5"
 libp2p-mplex = "0.41"
-quick-protobuf-codec = "0.3"
 
 [dependencies.libp2p]
 version = "0.53"
@@ -72,7 +68,7 @@ slog-async = { workspace = true }
 tempfile = { workspace = true }
 quickcheck = { workspace = true }
 quickcheck_macros = { workspace = true }
-async-std = { version = "1.6.3", features = ["unstable"] }
+async-channel = { workspace = true }
 
 [features]
 libp2p-websocket = []