@@ -8547,36 +8547,31 @@ This indicates a bug inside LDK. Please report this error at https://github.com/
8547
8547
}
8548
8548
8549
8549
#[rustfmt::skip]
8550
- fn internal_peer_storage_retrieval(&self, counterparty_node_id : PublicKey, msg: msgs::PeerStorageRetrieval) -> Result<(), MsgHandleErrInternal> {
8550
+ fn internal_peer_storage_retrieval(&self, peer_node_id : PublicKey, msg: msgs::PeerStorageRetrieval) -> Result<(), MsgHandleErrInternal> {
8551
8551
// TODO: Check if have any stale or missing ChannelMonitor.
8552
- let logger = WithContext::from(&self.logger, Some(counterparty_node_id ), None, None);
8553
- let err = MsgHandleErrInternal::from_chan_no_close(
8552
+ let logger = WithContext::from(&self.logger, Some(peer_node_id ), None, None);
8553
+ let err = || MsgHandleErrInternal::from_chan_no_close(
8554
8554
ChannelError::Ignore("Invalid PeerStorageRetrieval message received.".into()),
8555
8555
ChannelId([0; 32]),
8556
8556
);
8557
- let err_str = || {
8558
- format!("Invalid PeerStorage received from {}", counterparty_node_id)
8559
- };
8560
8557
8561
8558
let encrypted_ops = match EncryptedOurPeerStorage::new(msg.data) {
8562
8559
Ok(encrypted_ops) => encrypted_ops,
8563
- Err(_ ) => {
8564
- log_debug!(logger, "{}", err_str() );
8565
- return Err(err);
8560
+ Err(() ) => {
8561
+ log_debug!(logger, "Received a peer backup which wasn't long enough to be valid" );
8562
+ return Err(err() );
8566
8563
}
8567
8564
};
8568
8565
8569
- let decrypted_data = match encrypted_ops.decrypt(&self.node_signer.get_peer_storage_key()) {
8566
+ let decrypted = match encrypted_ops.decrypt(&self.node_signer.get_peer_storage_key()) {
8570
8567
Ok(decrypted_ops) => decrypted_ops.into_vec(),
8571
- Err(_ ) => {
8572
- log_debug!(logger, "{}", err_str() );
8573
- return Err(err);
8568
+ Err(() ) => {
8569
+ log_debug!(logger, "Received a peer backup which was corrupted" );
8570
+ return Err(err() );
8574
8571
}
8575
8572
};
8576
8573
8577
- if decrypted_data.is_empty() {
8578
- log_debug!(logger, "Received a peer storage from peer {} with 0 channels.", log_pubkey!(counterparty_node_id));
8579
- }
8574
+ log_trace!(logger, "Got valid {}-byte peer backup from {}", decrypted.len(), peer_node_id);
8580
8575
8581
8576
Ok(())
8582
8577
}
0 commit comments