feat(core): implement validatorapi attestation + aggregation handlers

crates/core/src/scheduler.rs

@@ -1161,7 +1161,10 @@ mod tests {
             pubkey: pubkey.to_string(),
             validator_index: v_idx.to_string(),
             slot: slot.to_string(),
-            ..Default::default()
+            committee_index: "0".to_owned(),
+            committee_length: "0".to_owned(),
+            committees_at_slot: "0".to_owned(),
+            validator_committee_index: "0".to_owned(),
         };
         let def: types::AttesterDutyDefinition = datum.try_into().expect("valid attester datum");
         types::DutyDefinition::Attester(def)

crates/core/src/signeddata.rs

@@ -1176,7 +1176,7 @@ impl SignedSyncContributionAndProof {
 }
 
 /// Attester duty metadata associated with an attestation.
-#[derive(Debug, Clone, PartialEq, Eq)]
+#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
 pub struct AttesterDuty {
     /// Slot for the duty.
     pub slot: phase0::Slot,

crates/core/src/types.rs

@@ -435,6 +435,15 @@ pub struct AttesterDutyDefinition {
     pub v_idx: u64,
     /// The slot at which the validator must attest.
     pub slot: SlotNumber,
+    /// Index of the beacon committee the validator attests in.
+    pub committee_index: u64,
+    /// Number of validators in the committee.
+    pub committee_length: u64,
+    /// Total number of committees at the slot.
+    pub committees_at_slot: u64,
+    /// Position of the validator within its committee. Used to match a
+    /// submitted attestation's single aggregation bit back to this validator.
+    pub validator_committee_index: u64,
 }
 
 impl TryInto<AttesterDutyDefinition>
@@ -452,11 +461,30 @@ impl TryInto<AttesterDutyDefinition>
             SlotNumber::from(self.slot.parse::<u64>().map_err(|_| {
                 pluto_eth2api::EthBeaconNodeApiClientError::ParseError("slot".into())
             })?);
+        let committee_index = self.committee_index.parse::<u64>().map_err(|_| {
+            pluto_eth2api::EthBeaconNodeApiClientError::ParseError("committee_index".into())
+        })?;
+        let committee_length = self.committee_length.parse::<u64>().map_err(|_| {
+            pluto_eth2api::EthBeaconNodeApiClientError::ParseError("committee_length".into())
+        })?;
+        let committees_at_slot = self.committees_at_slot.parse::<u64>().map_err(|_| {
+            pluto_eth2api::EthBeaconNodeApiClientError::ParseError("committees_at_slot".into())
+        })?;
+        let validator_committee_index =
+            self.validator_committee_index.parse::<u64>().map_err(|_| {
+                pluto_eth2api::EthBeaconNodeApiClientError::ParseError(
+                    "validator_committee_index".into(),
+                )
+            })?;
 
         Ok(AttesterDutyDefinition {
             pubkey,
             v_idx,
             slot,
+            committee_index,
+            committee_length,
+            committees_at_slot,
+            validator_committee_index,
         })
     }
 }