formatting

Author: simzzz

adapter/src/ethereum/client.rs

@@ -10,7 +10,7 @@ use ethsign::{KeyFile, Signature};
 use primitives::{Address, BigNum, Chain, ChainId, ChainOf, Channel, Config, ValidatorId};
 
 use super::{
-    error::{Error, KeystoreError, VerifyError, OutpaceError},
+    error::{Error, KeystoreError, OutpaceError, VerifyError},
     ewt::{self, Payload},
     to_ethereum_signed, Electrum, LockedWallet, UnlockedWallet, WalletState, IDENTITY_ABI,
     OUTPACE_ABI,

adapter/src/ethereum/error.rs

@@ -22,7 +22,7 @@ impl From<Error> for AdapterError {
             err @ Error::ContractInitialization(..) => AdapterError::adapter(err),
             err @ Error::ContractQuerying(..) => AdapterError::adapter(err),
             err @ Error::VerifyAddress(..) => AdapterError::adapter(err),
-            err @ Error::OutpaceError( .. ) => AdapterError::adapter(err),
+            err @ Error::OutpaceError(..) => AdapterError::adapter(err),
             err @ Error::AuthenticationTokenNotIntendedForUs { .. } => {
                 AdapterError::authentication(err)
             }
@@ -152,7 +152,7 @@ pub enum EwtVerifyError {
     #[error("Error when decoding token signature")]
     InvalidSignature,
     #[error("Payload error: {0}")]
-    Payload(#[from] PayloadError)
+    Payload(#[from] PayloadError),
 }
 
 #[derive(Debug, Error)]

primitives/src/channel.rs

@@ -6,16 +6,11 @@ use serde::{Deserialize, Deserializer, Serialize, Serializer};
 
 use hex::{FromHex, FromHexError};
 
-use crate::{Address, Validator, ValidatorId, ToHex};
+use crate::{Address, ToHex, Validator, ValidatorId};
 
 #[derive(Deserialize, PartialEq, Eq, Copy, Clone, Hash)]
 #[serde(transparent)]
-pub struct ChannelId(
-    #[serde(
-        deserialize_with = "deserialize_channel_id",
-    )]
-    [u8; 32],
-);
+pub struct ChannelId(#[serde(deserialize_with = "deserialize_channel_id")] [u8; 32]);
 
 impl ChannelId {
     pub fn as_bytes(&self) -> &[u8; 32] {

sentry/src/db/analytics.rs

@@ -337,20 +337,25 @@ mod test {
 
             // 8.12.2021 23:00
             let click_ad_slot_2 = make_click_analytics(&ad_unit, ad_slot_ipfs_2, 8, 23);
-            let click_ad_slot_2 = update_analytics(&database.pool, click_ad_slot_2).await.expect("Should update");
-
+            let click_ad_slot_2 = update_analytics(&database.pool, click_ad_slot_2)
+                .await
+                .expect("Should update");
 
             // 9.12.2021 00:00
-            let mut impression_new_slot_type = make_impression_analytics(&ad_unit, ad_slot_ipfs_2, 9, 0);
+            let mut impression_new_slot_type =
+                make_impression_analytics(&ad_unit, ad_slot_ipfs_2, 9, 0);
             impression_new_slot_type.ad_slot_type = Some("legacy_500x500".to_string());
-            let impression_new_slot_type = update_analytics(&database.pool, impression_new_slot_type).await.expect("Should update");
+            let impression_new_slot_type =
+                update_analytics(&database.pool, impression_new_slot_type)
+                    .await
+                    .expect("Should update");
 
             vec![
                 ("click_germany", click_germany),
                 ("impression_ad_unit_2", impression_ad_unit_2),
                 ("impression_publisher_2", impression_publisher_2),
                 ("click_ad_slot_2", click_ad_slot_2),
-                ("impression_new_slot_type", impression_new_slot_type)
+                ("impression_new_slot_type", impression_new_slot_type),
             ]
             .into_iter()
             .collect()
@@ -891,11 +896,7 @@ mod test {
             .await
             .expect("Should fetch");
 
-            assert_eq!(
-                1,
-                count_clicks.len(),
-                "Only single analytics is expected"
-            );
+            assert_eq!(1, count_clicks.len(), "Only single analytics is expected");
             let fetched = count_clicks.get(0).expect("Should have index 0");
             assert_eq!(
                 23,