feat: add dkg/exchanger (#350)

* feat: add deadline.rs

* feat: deadline tests

* fix: remove comments

* wip: add parasig db and some tests

* refactor: remove old app/deadline

* feat: add rust docs

* feat: add clone box and clone eq

* feat: finish tests

* feat: add parsigex [wip]

* fix: typo

* fix: parsigex

* refactor: parsigex

* fix: linter

* feat: add subscribe

* feat: add documentation for parsigex

* fix: review comments

* fix: review comments

* fix: review comments

* fix: cargo deny

* fix: linter

* feat: add exchanger

* fix: remove unused deps

* fix: remove comments

* fix: address review comments

* fix: review comments

---------

Co-authored-by: Bohdan Ohorodnii <273991985+varex83agent@users.noreply.github.com>

Author: varex83

Cargo.lock

@@ -73,7 +73,7 @@ pub type ThreshSub = Arc<
 ///         }
 ///     }
 /// });
-/// db.subscribe_internal(sub).await?;
+/// db.subscribe_internal(sub).await;
 /// ```
 pub fn internal_subscriber<F, Fut>(f: F) -> InternalSub
 where
@@ -105,7 +105,7 @@ where
 ///         }
 ///     }
 /// });
-/// db.subscribe_threshold(sub).await?;
+/// db.subscribe_threshold(sub).await;
 /// ```
 pub fn threshold_subscriber<F, Fut>(f: F) -> ThreshSub
 where
@@ -193,20 +193,18 @@ impl MemDB {
     ///
     /// The subscriber will be called when the node generates partial signed
     /// data that needs to be exchanged with peers.
-    pub async fn subscribe_internal(&self, sub: InternalSub) -> Result<()> {
+    pub async fn subscribe_internal(&self, sub: InternalSub) {
         let mut inner = self.inner.lock().await;
         inner.internal_subs.push(sub);
-        Ok(())
     }
 
     /// Registers a subscriber for threshold-reached partial signed data.
     ///
     /// The subscriber will be called when enough matching partial signatures
     /// have been collected to meet the threshold requirement.
-    pub async fn subscribe_threshold(&self, sub: ThreshSub) -> Result<()> {
+    pub async fn subscribe_threshold(&self, sub: ThreshSub) {
         let mut inner = self.inner.lock().await;
         inner.thresh_subs.push(sub);
-        Ok(())
     }
 
     /// Stores internally generated partial signed data and notifies

crates/core/src/parsigdb/memory.rs

@@ -125,8 +125,7 @@ async fn memdb_threshold() {
             }
         }
     }))
-    .await
-    .expect("subscription should succeed");
+    .await;
 
     let pubkey = random_core_pub_key();
     let attestation = testutil::random_deneb_versioned_attestation();

crates/core/src/parsigdb/memory_internal_test.rs

@@ -22,9 +22,12 @@ k256.workspace = true
 pluto-k1util.workspace = true
 pluto-p2p.workspace = true
 pluto-cluster.workspace = true
+pluto-core.workspace = true
 pluto-crypto.workspace = true
 pluto-eth1wrap.workspace = true
 pluto-eth2util.workspace = true
+pluto-parsigex.workspace = true
+async-trait.workspace = true
 pluto-tracing.workspace = true
 hex.workspace = true
 rand.workspace = true
@@ -42,7 +45,6 @@ test-case.workspace = true
 clap.workspace = true
 hex.workspace = true
 pluto-cluster = { workspace = true, features = ["test-cluster"] }
-pluto-core.workspace = true
 pluto-testutil.workspace = true
 pluto-tracing.workspace = true
 serde_json.workspace = true