Selaa lähdekoodia

clean up by running cargo clippy

ghassmo 4 vuotta sitten
vanhempi
sitoutus
0c66ce6cf2
7 muutettua tiedostoa jossa 16 lisäystä ja 24 poistoa
  1. 5 8
      src/bin/darkfid.rs
  2. 1 2
      src/bin/drk.rs
  3. 1 1
      src/client.rs
  4. 4 5
      src/service/btc.rs
  5. 2 2
      src/service/eth.rs
  6. 1 4
      src/util/address.rs
  7. 2 2
      src/util/token_list.rs

+ 5 - 8
src/bin/darkfid.rs

@@ -176,15 +176,14 @@ impl Darkfid {
             let mut symbols: HashMap<String, (String, String)> = HashMap::new();
             let mut symbols: HashMap<String, (String, String)> = HashMap::new();
 
 
             for balance in balances.list.iter() {
             for balance in balances.list.iter() {
+                let amount = encode_base10(BigUint::from(balance.value), 8);
                 if let Some((network, symbol)) =
                 if let Some((network, symbol)) =
                     self.drk_tokenlist.symbol_from_id(&balance.token_id)?
                     self.drk_tokenlist.symbol_from_id(&balance.token_id)?
                 {
                 {
-                    let amount = encode_base10(BigUint::from(balance.value), 8);
                     symbols.insert(symbol, (amount, network.to_string()));
                     symbols.insert(symbol, (amount, network.to_string()));
                 } else {
                 } else {
                     // TODO: SQL needs to have the mint address for show, not the internal hash.
                     // TODO: SQL needs to have the mint address for show, not the internal hash.
                     // TODO: SQL needs to have the network name
                     // TODO: SQL needs to have the network name
-                    let amount = encode_base10(BigUint::from(balance.value), 8);
                     symbols.insert(
                     symbols.insert(
                         balance.token_id.to_string(),
                         balance.token_id.to_string(),
                         (amount, String::from("UNKNOWN")),
                         (amount, String::from("UNKNOWN")),
@@ -239,7 +238,7 @@ impl Darkfid {
                     if let Some(tkn) = self.sol_tokenlist.search_id(symbol)? {
                     if let Some(tkn) = self.sol_tokenlist.search_id(symbol)? {
                         Ok(json!(tkn))
                         Ok(json!(tkn))
                     } else {
                     } else {
-                        return Err(Error::NotSupportedToken);
+                        Err(Error::NotSupportedToken)
                     }
                     }
                 }
                 }
                 #[cfg(feature = "btc")]
                 #[cfg(feature = "btc")]
@@ -254,12 +253,10 @@ impl Darkfid {
                     let token_id: String = if symbol.to_lowercase() == "eth" {
                     let token_id: String = if symbol.to_lowercase() == "eth" {
                         use drk::service::eth::ETH_NATIVE_TOKEN_ID;
                         use drk::service::eth::ETH_NATIVE_TOKEN_ID;
                         ETH_NATIVE_TOKEN_ID.to_string()
                         ETH_NATIVE_TOKEN_ID.to_string()
+                    } else if let Some(tkn) = self.eth_tokenlist.search_id(symbol)? {
+                        tkn
                     } else {
                     } else {
-                        if let Some(tkn) = self.eth_tokenlist.search_id(symbol)? {
-                            tkn
-                        } else {
-                            return Err(Error::NotSupportedToken);
-                        }
+                        return Err(Error::NotSupportedToken);
                     };
                     };
 
 
                     Ok(json!(token_id))
                     Ok(json!(token_id))

+ 1 - 2
src/bin/drk.rs

@@ -33,8 +33,7 @@ impl Drk {
             && features.as_object().unwrap()["networks"]
             && features.as_object().unwrap()["networks"]
                 .as_array()
                 .as_array()
                 .unwrap()
                 .unwrap()
-                .len()
-                == 0
+                .is_empty()
         {
         {
             return Err(Error::NotSupportedNetwork);
             return Err(Error::NotSupportedNetwork);
         }
         }

+ 1 - 1
src/client.rs

@@ -70,7 +70,7 @@ impl Client {
             bs58::encode(&serialize(&main_keypair.public)).into_string()
             bs58::encode(&serialize(&main_keypair.public)).into_string()
         );
         );
 
 
-        let slabstore = RocksColumn::<columns::Slabs>::new(rocks.clone());
+        let slabstore = RocksColumn::<columns::Slabs>::new(rocks);
 
 
         // create gateway client
         // create gateway client
         debug!(target: "CLIENT", "Creating GatewayClient");
         debug!(target: "CLIENT", "Creating GatewayClient");

+ 4 - 5
src/service/btc.rs

@@ -229,7 +229,7 @@ impl Client {
         let config = bdk::electrum_client::ConfigBuilder::default()
         let config = bdk::electrum_client::ConfigBuilder::default()
             .retry(5)
             .retry(5)
             .build();
             .build();
-        let client = ElectrumClient::from_config(electrum_url, config)?;
+        let _client = ElectrumClient::from_config(electrum_url, config)?;
 
 
         let electrum = ElectrumClient::new(electrum_url)
         let electrum = ElectrumClient::new(electrum_url)
             .map_err(|err| crate::Error::from(super::BtcFailed::from(err)))?;
             .map_err(|err| crate::Error::from(super::BtcFailed::from(err)))?;
@@ -263,8 +263,7 @@ impl Client {
     }
     }
     fn update_latest_block(&mut self) -> BtcResult<()> {
     fn update_latest_block(&mut self) -> BtcResult<()> {
         let latest_block = self.electrum.block_headers_subscribe()?;
         let latest_block = self.electrum.block_headers_subscribe()?;
-        let latest_block_height = BlockHeight::try_from(latest_block)
-            .map_err(|err| crate::Error::from(super::BtcFailed::from(err)))?;
+        let latest_block_height = BlockHeight::try_from(latest_block)?;
 
 
         if latest_block_height > self.latest_block_height {
         if latest_block_height > self.latest_block_height {
             debug!( target: "BTC BRIDGE", "{} {}",
             debug!( target: "BTC BRIDGE", "{} {}",
@@ -304,7 +303,7 @@ impl Client {
         }
         }
         self.update_state()?;
         self.update_state()?;
 
 
-        let history = self.script_history.entry(script.clone()).or_default();
+        let history = self.script_history.entry(script).or_default();
 
 
         match history.as_slice() {
         match history.as_slice() {
             [] => Ok(ScriptStatus::Unseen),
             [] => Ok(ScriptStatus::Unseen),
@@ -598,7 +597,7 @@ impl NetworkClient for BtcClient {
         let main_script_pubkey = &self.main_account.script_pubkey;
         let main_script_pubkey = &self.main_account.script_pubkey;
 
 
         let main_utxo = electrum
         let main_utxo = electrum
-            .script_list_unspent(&main_script_pubkey)
+            .script_list_unspent(main_script_pubkey)
             .map_err(|e| Error::from(BtcFailed::from(e)))?;
             .map_err(|e| Error::from(BtcFailed::from(e)))?;
 
 
         let transaction = Transaction {
         let transaction = Transaction {

+ 2 - 2
src/service/eth.rs

@@ -297,7 +297,7 @@ impl EthClient {
         Ok(())
         Ok(())
     }
     }
 
 
-    async fn unsubscribe(&self, pubkey: &String) {
+    async fn unsubscribe(&self, pubkey: &str) {
         let mut subscriptions = self.subscriptions.lock().await;
         let mut subscriptions = self.subscriptions.lock().await;
         let index = subscriptions.iter().position(|p| p == pubkey);
         let index = subscriptions.iter().position(|p| p == pubkey);
         if let Some(ind) = index {
         if let Some(ind) = index {
@@ -376,7 +376,7 @@ impl EthClient {
         let block = block.as_str().unwrap();
         let block = block.as_str().unwrap();
 
 
         // Native ETH balance
         // Native ETH balance
-        let hexbalance = self.get_eth_balance(&acc, block).await?;
+        let hexbalance = self.get_eth_balance(acc, block).await?;
         let hexbalance = hexbalance.as_str().unwrap().trim_start_matches("0x");
         let hexbalance = hexbalance.as_str().unwrap().trim_start_matches("0x");
         let balance = BigUint::parse_bytes(hexbalance.as_bytes(), 16).unwrap();
         let balance = BigUint::parse_bytes(hexbalance.as_bytes(), 16).unwrap();
 
 

+ 1 - 4
src/util/address.rs

@@ -23,10 +23,7 @@ impl std::fmt::Display for Address {
         hasher.update(self.hash);
         hasher.update(self.hash);
         let mut hash = hasher.finalize().to_vec();
         let mut hash = hasher.finalize().to_vec();
 
 
-        let mut payload = vec![];
-
-        // add version
-        payload.push(0x00 as u8);
+        let mut payload: Vec<u8> = vec![0x00_u8];
 
 
         // add public key hash
         // add public key hash
         payload.append(&mut hash);
         payload.append(&mut hash);

+ 2 - 2
src/util/token_list.rs

@@ -68,14 +68,14 @@ impl DrkTokenList {
         let sol_tokens: HashMap<String, jubjub::Fr> = sol_symbols
         let sol_tokens: HashMap<String, jubjub::Fr> = sol_symbols
             .iter()
             .iter()
             .filter_map(|symbol| {
             .filter_map(|symbol| {
-                Self::generate_hash_pair(&sol_list, &NetworkName::Solana, symbol).ok()
+                Self::generate_hash_pair(sol_list, &NetworkName::Solana, symbol).ok()
             })
             })
             .collect();
             .collect();
 
 
         let eth_tokens: HashMap<String, jubjub::Fr> = eth_symbols
         let eth_tokens: HashMap<String, jubjub::Fr> = eth_symbols
             .iter()
             .iter()
             .filter_map(|symbol| {
             .filter_map(|symbol| {
-                Self::generate_hash_pair(&eth_list, &NetworkName::Ethereum, symbol).ok()
+                Self::generate_hash_pair(eth_list, &NetworkName::Ethereum, symbol).ok()
             })
             })
             .collect();
             .collect();