feat: add proof of correct aggregration

crates/aggregator/Cargo.toml

@@ -16,6 +16,7 @@ e3-data = { workspace = true }
 e3-events = { workspace = true }
 e3-evm = { workspace = true }
 e3-fhe = { workspace = true }
+e3-fhe-params = { workspace = true }
 e3-multithread = { workspace = true }
 e3-trbfv = { workspace = true }
 e3-bfv-client = { workspace = true }

crates/aggregator/src/ext.rs

@@ -20,16 +20,21 @@ use e3_events::{prelude::*, E3id};
 use e3_events::{BusHandle, EType, EnclaveEvent, EnclaveEventData};
 use e3_fhe::ext::FHE_KEY;
 use e3_fhe::Fhe;
+use e3_fhe_params::BfvPreset;
 use e3_request::{E3Context, E3ContextSnapshot, E3Extension, META_KEY};
 use e3_sortition::Sortition;
 
 pub struct PublicKeyAggregatorExtension {
     bus: BusHandle,
+    params_preset: BfvPreset,
 }
 
 impl PublicKeyAggregatorExtension {
-    pub fn create(bus: &BusHandle) -> Box<Self> {
-        Box::new(Self { bus: bus.clone() })
+    pub fn create(bus: &BusHandle, params_preset: BfvPreset) -> Box<Self> {
+        Box::new(Self {
+            bus: bus.clone(),
+            params_preset,
+        })
     }
 }
 
@@ -62,10 +67,17 @@ impl E3Extension for PublicKeyAggregatorExtension {
         let repo = ctx.repositories().publickey(&e3_id);
         let sync_state = repo.send(Some(PublicKeyAggregatorState::init(
             meta.threshold_n,
+            meta.threshold_m,
             meta.seed,
         )));
 
-        let value = create_publickey_aggregator(fhe.clone(), self.bus.clone(), e3_id, sync_state);
+        let value = create_publickey_aggregator(
+            fhe.clone(),
+            self.bus.clone(),
+            e3_id,
+            sync_state,
+            self.params_preset.clone(),
+        );
 
         ctx.set_event_recipient("publickey", Some(value));
     }
@@ -98,6 +110,7 @@ impl E3Extension for PublicKeyAggregatorExtension {
             self.bus.clone(),
             ctx.e3_id.clone(),
             sync_state,
+            self.params_preset.clone(),
         );
 
         // send to context
@@ -112,11 +125,20 @@ fn create_publickey_aggregator(
     bus: BusHandle,
     e3_id: E3id,
     sync_state: Persistable<PublicKeyAggregatorState>,
+    params_preset: BfvPreset,
 ) -> Recipient<EnclaveEvent> {
     KeyshareCreatedFilterBuffer::new(
-        PublicKeyAggregator::new(PublicKeyAggregatorParams { fhe, bus, e3_id }, sync_state)
-            .start()
-            .into(),
+        PublicKeyAggregator::new(
+            PublicKeyAggregatorParams {
+                fhe,
+                bus,
+                e3_id,
+                params_preset,
+            },
+            sync_state,
+        )
+        .start()
+        .into(),
     )
     .start()
     .into()