start signature_collector and implement it for the randao reveal

Cargo.toml

@@ -3,6 +3,7 @@
 members = [
     "anchor",
     "anchor/client",
+    "anchor/common/signature_collector",
     "anchor/common/ssv_types",
     "anchor/common/version",
     "anchor/http_api",
@@ -26,6 +27,7 @@ network = { path = "anchor/network" }
 version = { path = "anchor/common/version" }
 processor = { path = "anchor/processor" }
 anchor_validator_store = { path = "anchor/validator_store" }
+signature_collector = { path = "anchor/common/signature_collector" }
 ssv_types = { path = "anchor/common/ssv_types" }
 lighthouse_network = { git = "https://github.com/dknopik/lighthouse", branch = "modularize-validator-store" }
 task_executor = { git = "https://github.com/dknopik/lighthouse", branch = "modularize-validator-store", default-features = false, features = [ "tracing", ] }

anchor/client/Cargo.toml

@@ -26,6 +26,7 @@ processor = { workspace = true }
 sensitive_url = { workspace = true }
 serde = { workspace = true }
 slot_clock = { workspace = true }
+ssv_types = { workspace = true }
 strum = { workspace = true }
 task_executor = { workspace = true }
 tokio = { workspace = true }

anchor/client/src/lib.rs

@@ -16,6 +16,7 @@ use network::Network;
 use parking_lot::RwLock;
 use sensitive_url::SensitiveUrl;
 use slot_clock::{SlotClock, SystemTimeSlotClock};
+use ssv_types::OperatorId;
 use std::fs::File;
 use std::io::Read;
 use std::net::SocketAddr;
@@ -243,7 +244,7 @@ impl Client {
         );
 
         // Perform some potentially long-running initialization tasks.
-        let (genesis_time, _genesis_validators_root) = tokio::select! {
+        let (genesis_time, genesis_validators_root) = tokio::select! {
             tuple = init_from_beacon_node(&beacon_nodes, &proposer_nodes) => tuple?,
             () = executor.exit() => return Err("Shutting down".to_string())
         };
@@ -263,7 +264,12 @@ impl Client {
         let proposer_nodes = Arc::new(proposer_nodes);
         start_fallback_updater_service(executor.clone(), proposer_nodes.clone())?;
 
-        let validator_store = Arc::new(AnchorValidatorStore::new(processor_senders));
+        let validator_store = Arc::new(AnchorValidatorStore::new(
+            processor_senders,
+            spec.clone(),
+            genesis_validators_root,
+            OperatorId(123),
+        ));
 
         let duties_service = Arc::new(
             DutiesServiceBuilder::new()

anchor/common/signature_collector/Cargo.toml

@@ -0,0 +1,12 @@
+[package]
+name = "signature_collector"
+version = "0.1.0"
+edition = { workspace = true }
+authors = ["Sigma Prime <contact@sigmaprime.io>"]
+
+[dependencies]
+processor = { workspace = true }
+ssv_types = { workspace = true }
+tokio = { workspace = true, features = ["sync"] }
+tracing = { workspace = true }
+types = { workspace = true }