diff --git a/processor/src/key_gen.rs b/processor/src/key_gen.rs index 9c2ba8abd..e36524b48 100644 --- a/processor/src/key_gen.rs +++ b/processor/src/key_gen.rs @@ -56,8 +56,7 @@ fn confirm_keys( ) -> (ThresholdKeys, ThresholdKeys) { let val: &[u8] = key_pair.1.as_ref(); let (keys_vec, keys) = - read_keys::(txn, &GeneratedKeysDb::key((set, (&key_pair.0 .0, val)).encode())) - .unwrap(); + read_keys::(txn, &GeneratedKeysDb::key((set, (&key_pair.0 .0, val)).encode())).unwrap(); assert_eq!(key_pair.0 .0, keys.0.group_key().to_bytes()); assert_eq!( { @@ -87,11 +86,12 @@ impl GeneratedKeysDb { ) { let mut keys = substrate_keys.serialize(); keys.extend(network_keys.serialize().iter()); - let key = (id.set, (&substrate_keys.group_key().to_bytes(), network_keys.group_key().to_bytes().as_ref())).encode(); - txn.put( - Self::key(key), - keys, - ); + let key = ( + id.set, + (&substrate_keys.group_key().to_bytes(), network_keys.group_key().to_bytes().as_ref()), + ) + .encode(); + txn.put(Self::key(key), keys); } } diff --git a/processor/src/main.rs b/processor/src/main.rs index 210efad4d..7725ec6c9 100644 --- a/processor/src/main.rs +++ b/processor/src/main.rs @@ -306,7 +306,9 @@ async fn handle_coordinator_msg( } => { assert_eq!(network_id, N::NETWORK, "coordinator sent us data for another network"); - if let Some((block, set, key_pair)) = PendingActivationsDb::pending_activation::>(txn) { + if let Some((block, set, key_pair)) = + PendingActivationsDb::pending_activation::>(txn) + { // Only run if this is a Batch belonging to a distinct block if context.network_latest_finalized_block.as_ref() != block.as_ref() { let mut queue_block = >::Id::default(); @@ -379,7 +381,7 @@ async fn handle_coordinator_msg( async fn boot( raw_db: &mut D, network: &N, -) -> (D,TributaryMutable, SubstrateMutable) { +) -> (D, TributaryMutable, SubstrateMutable) { let mut entropy_transcript = { let entropy = Zeroizing::new(env::var("ENTROPY").expect("entropy wasn't specified")); if entropy.len() != 64 {