feat: sigagg

crates/core/Cargo.toml

@@ -46,6 +46,7 @@ prost-types.workspace = true
 hex.workspace = true
 chrono.workspace = true
 test-case.workspace = true
+pluto-crypto.workspace = true
 pluto-eth2util.workspace = true
 pluto-cluster.workspace = true
 pluto-p2p.workspace = true

crates/core/src/lib.rs

@@ -29,6 +29,9 @@ pub mod parsigdb;
 /// DutyDB — in-memory store for unsigned duty data.
 pub mod dutydb;
 
+/// SigAgg — threshold BLS signature aggregation.
+pub mod sigagg;
+
 mod parsigex_codec;
 // SSZ codec operates on compile-time-constant byte sizes and offsets.
 // Arithmetic is bounded and casts from `usize` to `u32` are safe because all

crates/core/src/parsigdb/memory.rs

@@ -127,7 +127,7 @@ pub enum MemDBError {
         /// Public key of the validator
         pubkey: PubKey,
         /// Share index of the mismatched signature
-        share_idx: u64,
+        share_idx: u8,
     },
 
     /// Signed data error.

crates/core/src/parsigdb/memory_internal_test.rs

@@ -51,7 +51,7 @@ async fn test_get_threshold_matching(input: Vec<usize>, output: Vec<usize>) {
                     signature: testutil::random_eth2_signature_bytes(),
                 };
 
-                SignedSyncMessage::new_partial(message, u64::try_from(i.wrapping_add(1)).unwrap())
+                SignedSyncMessage::new_partial(message, u8::try_from(i.wrapping_add(1)).unwrap())
             }),
         ),
         (
@@ -65,7 +65,7 @@ async fn test_get_threshold_matching(input: Vec<usize>, output: Vec<usize>) {
 
                 BeaconCommitteeSelection::new_partial(
                     selection,
-                    u64::try_from(i.wrapping_add(1)).unwrap(),
+                    u8::try_from(i.wrapping_add(1)).unwrap(),
                 )
             }),
         ),
@@ -135,7 +135,7 @@ async fn memdb_threshold() {
         for i in 0..N {
             let partial = VersionedAttestation::new_partial(
                 attestation.clone(),
-                u64::try_from(i + 1).unwrap(),
+                u8::try_from(i + 1).unwrap(),
             )
             .expect("versioned attestation should be valid");