Message sending for Signature Collector

anchor/client/src/lib.rs

@@ -318,7 +318,7 @@ impl Client {
                     .full
                     .to_string(),
                 beacon_url: "".to_string(), // this one is not actually needed :)
-                network: config.ssv_network,
+                network: config.ssv_network.clone(),
                 historic_finished_notify: Some(historic_finished_tx),
             },
         )
@@ -369,6 +369,8 @@ impl Client {
         // Create the signature collector
         let signature_collector = SignatureCollectorManager::new(
             processor_senders.clone(),
+            operator_id,
+            config.ssv_network.ssv_domain_type.clone(),
             network_message_sender.clone(),
             slot_clock.clone(),
         )
@@ -391,7 +393,6 @@ impl Client {
             slot_clock.clone(),
             spec.clone(),
             genesis_validators_root,
-            operator_id,
             key,
             executor.clone(),
         );

anchor/network/src/network.rs

@@ -127,13 +127,7 @@ impl Network {
             log_address.push(Protocol::P2p(peer_id));
             info!(address = %log_address, "Listening established");
         }
-        /*
-        TODO
-        - Dial peers
-        - Subscribe gossip topics
-         */
 
-        // TODO: Return channels for input/output
         Ok(network)
     }
 

anchor/signature_collector/Cargo.toml

@@ -7,6 +7,7 @@ authors = ["Sigma Prime <[email protected]>"]
 [dependencies]
 bls_lagrange = { workspace = true }
 dashmap = { workspace = true }
+ethereum_ssz = { workspace = true }
 message_sender = { workspace = true }
 processor = { workspace = true }
 slot_clock = { workspace = true }