Skip to content

Commit 34e97f7

Browse files
committed
fixup: Distribute PeerStorage from ChainMonitor
1 parent 7a6306b commit 34e97f7

File tree

1 file changed

+10
-4
lines changed

1 file changed

+10
-4
lines changed

lightning/src/chain/chainmonitor.rs

+10-4
Original file line numberDiff line numberDiff line change
@@ -710,10 +710,16 @@ where C::Target: chain::Filter,
710710
let random_bytes = self.entropy_source.get_secure_random_bytes();
711711
let peer_storage_key = self.our_peerstorage_encryption_key;
712712
let serialised_channels = Vec::new();
713-
let our_peer_storage = OurPeerStorage::create_from_data(peer_storage_key, serialised_channels, random_bytes);
714-
log_debug!(self.logger, "Sending Peer Storage from chainmonitor");
715-
self.pending_send_only_events.lock().unwrap().push(MessageSendEvent::SendPeerStorage { node_id: their_node_id,
716-
msg: msgs::PeerStorage { data: our_peer_storage.into_vec() } })
713+
let our_peer_storage = OurPeerStorage::create_from_data(
714+
peer_storage_key, serialised_channels, random_bytes
715+
);
716+
717+
log_debug!(self.logger, "Sending Peer Storage to {}", log_pubkey!(their_node_id));
718+
let send_peer_storage_event = MessageSendEvent::SendPeerStorage {
719+
node_id: their_node_id, msg: msgs::PeerStorage { data: our_peer_storage.into_vec() }
720+
};
721+
722+
self.pending_send_only_events.lock().unwrap().push(send_peer_storage_event)
717723
}
718724
}
719725

0 commit comments

Comments
 (0)