Implement SSV Handshake Protocol

.github/wordlist.txt

@@ -47,4 +47,14 @@ Holesky
 Mainnet
 lifecycle
 Syncer
-
+JSON
+Protobuf
+Responder
+responder
+Prepends
+Secp
+NodeMetadata
+NodeInfo
+subnets
+holesky
+responder's

anchor/client/src/config.rs

@@ -16,7 +16,7 @@ pub const DEFAULT_EXECUTION_NODE_WS: &str = "ws://localhost:8545/";
 /// The default Data directory, relative to the users home directory
 pub const DEFAULT_ROOT_DIR: &str = ".anchor";
 /// Default network, used to partition the data storage
-pub const DEFAULT_HARDCODED_NETWORK: &str = "mainnet";
+pub const DEFAULT_HARDCODED_NETWORK: &str = "holesky";
 /// Base directory name for unnamed testnets passed through the --testnet-dir flag
 pub const CUSTOM_TESTNET_DIR: &str = "custom";
 

anchor/common/ssv_network_config/built_in_network_configs/holesky/ssv_domain_type.txt

@@ -0,0 +1 @@
+0x00000502

anchor/common/ssv_network_config/built_in_network_configs/mainnet/ssv_domain_type.txt

@@ -0,0 +1 @@
+0x00000001

anchor/common/ssv_network_config/src/lib.rs

@@ -1,3 +1,4 @@
+use alloy::hex;
 use alloy::primitives::Address;
 use enr::{CombinedKey, Enr};
 use eth2_network_config::Eth2NetworkConfig;
@@ -22,21 +23,46 @@ macro_rules! get_hardcoded {
             include_str_for_net!($network, "ssv_boot_enr.yaml"),
             include_str_for_net!($network, "ssv_contract_address.txt"),
             include_str_for_net!($network, "ssv_contract_block.txt"),
+            include_str_for_net!($network, "ssv_domain_type.txt"),
         )
     };
 }
 
+#[derive(Clone, Debug, Default)]
+pub struct DomainType(pub [u8; 4]);
+
+impl FromStr for DomainType {
+    type Err = String;
+
+    fn from_str(hex_str: &str) -> Result<Self, Self::Err> {
+        let bytes = hex::decode(hex_str).map_err(|_| "Invalid domain type hex")?;
+        if bytes.len() != 4 {
+            return Err("Domain type must be 4 bytes".into());
+        }
+        let mut domain_type = [0; 4];
+        domain_type.copy_from_slice(&bytes);
+        Ok(Self(domain_type))
+    }
+}
+
+impl From<DomainType> for String {
+    fn from(domain_type: DomainType) -> Self {
+        hex::encode(domain_type.0)
+    }
+}
+
 #[derive(Clone, Debug)]
 pub struct SsvNetworkConfig {
     pub eth2_network: Eth2NetworkConfig,
     pub ssv_boot_nodes: Option<Vec<Enr<CombinedKey>>>,
     pub ssv_contract: Address,
     pub ssv_contract_block: u64,
+    pub ssv_domain_type: DomainType,
 }
 
 impl SsvNetworkConfig {
     pub fn constant(name: &str) -> Result<Option<Self>, String> {
-        let (enr_yaml, address, block) = match name {
+        let (enr_yaml, address, block, domain_type) = match name {
             "mainnet" => get_hardcoded!(mainnet),
             "holesky" => get_hardcoded!(holesky),
             _ => return Ok(None),
@@ -55,6 +81,9 @@ impl SsvNetworkConfig {
             ssv_contract_block: block
                 .parse()
                 .map_err(|_| "Unable to parse built-in block!")?,
+            ssv_domain_type: domain_type
+                .parse()
+                .map_err(|_| "Unable to parse built-in domain type!")?,
         }))
     }
 
@@ -76,6 +105,7 @@ impl SsvNetworkConfig {
             ssv_boot_nodes,
             ssv_contract: read(&base_dir.join("ssv_contract_address.txt"))?,
             ssv_contract_block: read(&base_dir.join("ssv_contract_block.txt"))?,
+            ssv_domain_type: read(&base_dir.join("ssv_domain_type.txt"))?,
             eth2_network: Eth2NetworkConfig::load(base_dir)?,
         })
     }

anchor/network/Cargo.toml

@@ -5,6 +5,7 @@ edition = { workspace = true }
 authors = ["Sigma Prime <[email protected]>"]
 
 [dependencies]
+async-trait = "0.1.85"
 dirs = { workspace = true }
 discv5 = { workspace = true }
 ethereum_ssz = "0.8.1"
@@ -22,15 +23,19 @@ libp2p = { version = "0.54", default-features = false, features = [
   "gossipsub",
   "quic",
   "ping",
+  "request-response",
 ] }
 lighthouse_network = { workspace = true }
+quick-protobuf = "0.8.1"
 serde = { workspace = true }
+serde_json = "1.0.137"
+ssv_network_config = { workspace = true }
 ssz_types = "0.10"
 subnet_tracker = { workspace = true }
 task_executor = { workspace = true }
+thiserror = "1.0.69"
 tokio = { workspace = true }
 tracing = { workspace = true }
-types = { workspace = true }
 version = { workspace = true }
 
 [dev-dependencies]

anchor/network/src/behaviour.rs

@@ -1,4 +1,5 @@
 use crate::discovery::Discovery;
+use crate::handshake;
 use libp2p::swarm::NetworkBehaviour;
 use libp2p::{gossipsub, identify, ping};
 
@@ -12,4 +13,6 @@ pub struct AnchorBehaviour {
     pub gossipsub: gossipsub::Behaviour,
     /// Discv5 Discovery protocol.
     pub discovery: Discovery,
+
+    pub handshake: handshake::Behaviour,
 }

anchor/network/src/config.rs

@@ -2,7 +2,7 @@ use discv5::Enr;
 use libp2p::Multiaddr;
 use lighthouse_network::types::GossipKind;
 use lighthouse_network::{ListenAddr, ListenAddress};
-use serde::{Deserialize, Serialize};
+use ssv_network_config::DomainType;
 use std::net::{Ipv4Addr, Ipv6Addr};
 use std::num::NonZeroU16;
 use std::path::PathBuf;
@@ -16,7 +16,7 @@ pub const DEFAULT_DISC_PORT: u16 = 9100u16;
 pub const DEFAULT_QUIC_PORT: u16 = 9101u16;
 
 /// Configuration for setting up the p2p network.
-#[derive(Clone, Serialize, Deserialize)]
+#[derive(Clone)]
 pub struct Config {
     /// Data directory where node's keyfile is stored
     pub network_dir: PathBuf,
@@ -66,6 +66,8 @@ pub struct Config {
 
     /// Target number of connected peers.
     pub target_peers: usize,
+
+    pub domain_type: DomainType,
 }
 
 impl Default for Config {
@@ -100,6 +102,7 @@ impl Default for Config {
             disable_discovery: false,
             disable_quic_support: false,
             topics: vec![],
+            domain_type: DomainType::default(),
         }
     }
 }