Formatting

packages/ciphernode/aggregator/src/publickey_aggregator.rs

@@ -166,7 +166,7 @@ impl Handler<KeyshareCreated> for PublicKeyAggregator {
                     if let PublicKeyAggregatorState::Computing { keyshares } = &act.state {
                         ctx.notify(ComputeAggregate {
                             keyshares: keyshares.clone(),
-                            e3_id
+                            e3_id,
                         })
                     }
 
@@ -207,12 +207,11 @@ impl Handler<NotifyNetwork> for PublicKeyAggregator {
                     let event = EnclaveEvent::from(PublicKeyAggregated {
                         pubkey: msg.pubkey.clone(),
                         e3_id: msg.e3_id.clone(),
-                        nodes: OrderedSet::from(nodes)
+                        nodes: OrderedSet::from(nodes),
                     });
                     act.bus.do_send(event);
                     Ok(())
                 }),
         )
     }
 }
-

packages/ciphernode/core/src/events.rs

@@ -309,7 +309,7 @@ pub struct DecryptionshareCreated {
 pub struct PublicKeyAggregated {
     pub pubkey: Vec<u8>,
     pub e3_id: E3id,
-    pub nodes: OrderedSet<String>
+    pub nodes: OrderedSet<String>,
 }
 
 #[derive(Message, Clone, Debug, PartialEq, Eq, Hash, Serialize, Deserialize)]

packages/ciphernode/evm/src/ciphernode_registry_sol.rs

@@ -113,7 +113,6 @@ impl CiphernodeRegistrySolReader {
         contract_address: Address,
         rpc_url: &str,
     ) -> Result<Self> {
-
         let provider = create_readonly_provider(rpc_url).await?;
 
         Ok(Self {
@@ -155,7 +154,11 @@ impl Actor for CiphernodeRegistrySolReader {
 
 pub struct CiphernodeRegistrySol;
 impl CiphernodeRegistrySol {
-    pub async fn attach(bus: Addr<EventBus>, rpc_url: &str, contract_address: Address) -> Result<()> {
+    pub async fn attach(
+        bus: Addr<EventBus>,
+        rpc_url: &str,
+        contract_address: Address,
+    ) -> Result<()> {
         CiphernodeRegistrySolReader::attach(bus.clone(), rpc_url, contract_address).await?;
         Ok(())
     }

packages/ciphernode/evm/src/enclave_sol_reader.rs

@@ -1,4 +1,3 @@
-
 use crate::helpers::{self, create_readonly_provider, ReadonlyProvider};
 use actix::prelude::*;
 use actix::{Addr, Recipient};

packages/ciphernode/evm/src/helpers.rs

@@ -13,7 +13,7 @@ use alloy::{
     transports::BoxTransport,
 };
 use anyhow::{Context, Result};
-use enclave_core::{EnclaveErrorType, EnclaveEvent, BusError};
+use enclave_core::{BusError, EnclaveErrorType, EnclaveEvent};
 use futures_util::stream::StreamExt;
 
 pub async fn stream_from_evm(

packages/ciphernode/evm/src/lib.rs

@@ -1,12 +1,12 @@
-mod enclave_sol;
 mod ciphernode_registry_sol;
-mod registry_filter_sol;
-pub mod helpers;
+mod enclave_sol;
 mod enclave_sol_reader;
 mod enclave_sol_writer;
+pub mod helpers;
+mod registry_filter_sol;
 
+pub use ciphernode_registry_sol::*;
 pub use enclave_sol::*;
 pub use enclave_sol_reader::*;
 pub use enclave_sol_writer::*;
-pub use ciphernode_registry_sol::*;
 pub use registry_filter_sol::*;

packages/ciphernode/evm/src/registry_filter_sol.rs

@@ -115,7 +115,11 @@ pub async fn publish_committee(
 
 pub struct RegistryFilterSol;
 impl RegistryFilterSol {
-    pub async fn attach(bus: Addr<EventBus>, rpc_url: &str, contract_address: Address) -> Result<()> {
+    pub async fn attach(
+        bus: Addr<EventBus>,
+        rpc_url: &str,
+        contract_address: Address,
+    ) -> Result<()> {
         RegistryFilterSolWriter::attach(bus.clone(), rpc_url, contract_address).await?;
         Ok(())
     }

packages/ciphernode/tests/tests/test_aggregation_and_decryption.rs

@@ -1,6 +1,8 @@
 use data::Data;
 use enclave_core::{
-    CiphernodeAdded, CiphernodeSelected, CiphertextOutputPublished, DecryptionshareCreated, E3Requested, E3id, EnclaveEvent, EventBus, GetHistory, KeyshareCreated, OrderedSet, PlaintextAggregated, PublicKeyAggregated, ResetHistory, Seed
+    CiphernodeAdded, CiphernodeSelected, CiphertextOutputPublished, DecryptionshareCreated,
+    E3Requested, E3id, EnclaveEvent, EventBus, GetHistory, KeyshareCreated, OrderedSet,
+    PlaintextAggregated, PublicKeyAggregated, ResetHistory, Seed,
 };
 use fhe::{setup_crp_params, ParamsWithCrp, SharedRng};
 use logger::SimpleLogger;