Skip to content

Commit e530c86

Browse files
committed
f Clippy lints
1 parent 5802b5a commit e530c86

File tree

4 files changed

+30
-39
lines changed

4 files changed

+30
-39
lines changed

src/error.rs

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -71,9 +71,7 @@ impl From<bdk::Error> for Error {
7171
}
7272

7373
impl From<lightning_transaction_sync::TxSyncError> for Error {
74-
fn from(e: lightning_transaction_sync::TxSyncError) -> Self {
75-
match e {
76-
_ => Self::TxSyncFailed,
77-
}
74+
fn from(_e: lightning_transaction_sync::TxSyncError) -> Self {
75+
Self::TxSyncFailed
7876
}
7977
}

src/io_utils.rs

Lines changed: 7 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -12,8 +12,8 @@ use std::sync::Arc;
1212

1313
pub(crate) fn read_or_generate_seed_file(config: Arc<Config>) -> [u8; 32] {
1414
let keys_seed_path = format!("{}/keys_seed", config.storage_dir_path);
15-
let keys_seed = if Path::new(&keys_seed_path).exists() {
16-
let seed = fs::read(keys_seed_path.clone()).expect("Failed to read keys seed file");
15+
if Path::new(&keys_seed_path).exists() {
16+
let seed = fs::read(keys_seed_path).expect("Failed to read keys seed file");
1717
assert_eq!(seed.len(), 32);
1818
let mut key = [0; 32];
1919
key.copy_from_slice(&seed);
@@ -22,21 +22,18 @@ pub(crate) fn read_or_generate_seed_file(config: Arc<Config>) -> [u8; 32] {
2222
let mut key = [0; 32];
2323
thread_rng().fill_bytes(&mut key);
2424

25-
let mut f =
26-
fs::File::create(keys_seed_path.clone()).expect("Failed to create keys seed file");
25+
let mut f = fs::File::create(keys_seed_path).expect("Failed to create keys seed file");
2726
f.write_all(&key).expect("Failed to write node keys seed to disk");
2827
f.sync_all().expect("Failed to sync node keys seed to disk");
2928
key
30-
};
31-
32-
keys_seed
29+
}
3330
}
3431

3532
pub(crate) fn read_network_graph(
3633
config: Arc<Config>, logger: Arc<FilesystemLogger>,
3734
) -> Result<NetworkGraph, Error> {
3835
let ldk_data_dir = format!("{}/ldk", &config.storage_dir_path.clone());
39-
let network_graph_path = format!("{}/network_graph", ldk_data_dir.clone());
36+
let network_graph_path = format!("{}/network_graph", ldk_data_dir);
4037

4138
if let Ok(file) = fs::File::open(network_graph_path) {
4239
if let Ok(graph) = NetworkGraph::read(&mut BufReader::new(file), Arc::clone(&logger)) {
@@ -52,8 +49,8 @@ pub(crate) fn read_network_graph(
5249
pub(crate) fn read_scorer(
5350
config: Arc<Config>, network_graph: Arc<NetworkGraph>, logger: Arc<FilesystemLogger>,
5451
) -> Scorer {
55-
let ldk_data_dir = format!("{}/ldk", &config.storage_dir_path.clone());
56-
let scorer_path = format!("{}/scorer", ldk_data_dir.clone());
52+
let ldk_data_dir = format!("{}/ldk", &config.storage_dir_path);
53+
let scorer_path = format!("{}/scorer", ldk_data_dir);
5754

5855
let params = ProbabilisticScoringParameters::default();
5956
if let Ok(file) = fs::File::open(scorer_path) {

src/lib.rs

Lines changed: 18 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -215,19 +215,18 @@ impl Builder {
215215
.expect("Failed to read wallet master key");
216216

217217
let wallet_name = bdk::wallet::wallet_name_from_descriptor(
218-
Bip84(xprv.clone(), bdk::KeychainKind::External),
219-
Some(Bip84(xprv.clone(), bdk::KeychainKind::Internal)),
218+
Bip84(xprv, bdk::KeychainKind::External),
219+
Some(Bip84(xprv, bdk::KeychainKind::Internal)),
220220
config.network,
221221
&Secp256k1::new(),
222222
)
223223
.expect("Failed to derive on-chain wallet name");
224224
let database = sled::open(bdk_data_dir).expect("Failed to open BDK database");
225-
let database =
226-
database.open_tree(wallet_name.clone()).expect("Failed to open BDK database");
225+
let database = database.open_tree(wallet_name).expect("Failed to open BDK database");
227226

228227
let bdk_wallet = bdk::Wallet::new(
229-
Bip84(xprv.clone(), bdk::KeychainKind::External),
230-
Some(Bip84(xprv.clone(), bdk::KeychainKind::Internal)),
228+
Bip84(xprv, bdk::KeychainKind::External),
229+
Some(Bip84(xprv, bdk::KeychainKind::Internal)),
231230
config.network,
232231
database,
233232
)
@@ -294,7 +293,7 @@ impl Builder {
294293
let mut user_config = UserConfig::default();
295294
user_config.channel_handshake_limits.force_announced_channel_preference = false;
296295
let channel_manager = {
297-
if let Ok(mut f) = fs::File::open(format!("{}/manager", ldk_data_dir.clone())) {
296+
if let Ok(mut f) = fs::File::open(format!("{}/manager", ldk_data_dir)) {
298297
let mut channel_monitor_mut_references = Vec::new();
299298
for (_, channel_monitor) in channel_monitors.iter_mut() {
300299
channel_monitor_mut_references.push(channel_monitor);
@@ -325,7 +324,7 @@ impl Builder {
325324
network: config.network,
326325
best_block: BestBlock::new(dummy_block_hash, 0),
327326
};
328-
let fresh_channel_manager = channelmanager::ChannelManager::new(
327+
channelmanager::ChannelManager::new(
329328
Arc::clone(&wallet),
330329
Arc::clone(&chain_monitor),
331330
Arc::clone(&wallet),
@@ -336,8 +335,7 @@ impl Builder {
336335
Arc::clone(&keys_manager),
337336
user_config,
338337
chain_params,
339-
);
340-
fresh_channel_manager
338+
)
341339
}
342340
};
343341

@@ -389,7 +387,7 @@ impl Builder {
389387

390388
// Step 14: Restore event handler from disk or create a new one.
391389
let event_queue = if let Ok(mut f) =
392-
fs::File::open(format!("{}/{}", ldk_data_dir.clone(), event::EVENTS_PERSISTENCE_KEY))
390+
fs::File::open(format!("{}/{}", ldk_data_dir, event::EVENTS_PERSISTENCE_KEY))
393391
{
394392
Arc::new(
395393
EventQueue::read(&mut f, Arc::clone(&persister))
@@ -399,11 +397,9 @@ impl Builder {
399397
Arc::new(EventQueue::new(Arc::clone(&persister)))
400398
};
401399

402-
let peer_store = if let Ok(mut f) = fs::File::open(format!(
403-
"{}/{}",
404-
ldk_data_dir.clone(),
405-
peer_store::PEER_INFO_PERSISTENCE_KEY
406-
)) {
400+
let peer_store = if let Ok(mut f) =
401+
fs::File::open(format!("{}/{}", ldk_data_dir, peer_store::PEER_INFO_PERSISTENCE_KEY))
402+
{
407403
Arc::new(
408404
PeerInfoStorage::read(&mut f, Arc::clone(&persister))
409405
.expect("Failed to read peer information from disk."),
@@ -652,7 +648,7 @@ impl Node {
652648
if peer_info.pubkey == node_id {
653649
let _ = do_connect_peer(
654650
peer_info.pubkey,
655-
peer_info.address.clone(),
651+
peer_info.address,
656652
Arc::clone(&connect_pm),
657653
Arc::clone(&connect_logger),
658654
)
@@ -868,8 +864,8 @@ impl Node {
868864
}
869865
};
870866

871-
let payment_hash = PaymentHash(invoice.payment_hash().clone().into_inner());
872-
let payment_secret = Some(invoice.payment_secret().clone());
867+
let payment_hash = PaymentHash((*invoice.payment_hash()).into_inner());
868+
let payment_secret = Some(*invoice.payment_secret());
873869

874870
let mut outbound_payments_lock = self.outbound_payments.lock().unwrap();
875871
outbound_payments_lock.insert(
@@ -965,20 +961,20 @@ impl Node {
965961
}
966962
};
967963

968-
let payment_hash = PaymentHash(invoice.payment_hash().clone().into_inner());
964+
let payment_hash = PaymentHash((*invoice.payment_hash()).into_inner());
969965
inbound_payments_lock.insert(
970966
payment_hash,
971967
PaymentInfo {
972968
preimage: None,
973-
secret: Some(invoice.payment_secret().clone()),
969+
secret: Some(*invoice.payment_secret()),
974970
status: PaymentStatus::Pending,
975971
amount_msat,
976972
},
977973
);
978974
Ok(invoice)
979975
}
980976

981-
/// Query for information about the status of a specific payment.
977+
/// Query for information about the status of a specific payment.
982978
pub fn payment_info(&self, payment_hash: &[u8; 32]) -> Option<PaymentInfo> {
983979
let payment_hash = PaymentHash(*payment_hash);
984980

src/peer_store.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ impl<K: KVStorePersister> PeerInfoStorage<K> {
4242
.persist(PEER_INFO_PERSISTENCE_KEY, &*locked_peers)
4343
.map_err(|_| Error::PersistenceFailed)?;
4444

45-
return Ok(());
45+
Ok(())
4646
}
4747

4848
pub(crate) fn remove_peer(&self, peer_pubkey: &PublicKey) -> Result<(), Error> {
@@ -54,7 +54,7 @@ impl<K: KVStorePersister> PeerInfoStorage<K> {
5454
.persist(PEER_INFO_PERSISTENCE_KEY, &*locked_peers)
5555
.map_err(|_| Error::PersistenceFailed)?;
5656

57-
return Ok(());
57+
Ok(())
5858
}
5959

6060
pub(crate) fn peers(&self) -> Vec<PeerInfo> {
@@ -150,7 +150,7 @@ impl TryFrom<String> for PeerInfo {
150150
type Error = Error;
151151

152152
fn try_from(peer_pubkey_and_ip_addr: String) -> Result<Self, Self::Error> {
153-
let mut pubkey_and_addr = peer_pubkey_and_ip_addr.split("@");
153+
let mut pubkey_and_addr = peer_pubkey_and_ip_addr.split('@');
154154
let pubkey = pubkey_and_addr.next();
155155
let peer_addr_str = pubkey_and_addr.next();
156156
if pubkey.is_none() || peer_addr_str.is_none() {

0 commit comments

Comments
 (0)