Skip to content

Commit d32a7b3

Browse files
committed
f Account for ChannelMonitors being tracked by ChannelId
1 parent 09d7b2e commit d32a7b3

File tree

3 files changed

+5
-5
lines changed

3 files changed

+5
-5
lines changed

src/builder.rs

+2-2
Original file line numberDiff line numberDiff line change
@@ -1078,8 +1078,8 @@ fn build_with_store_internal(
10781078

10791079
// Give ChannelMonitors to ChainMonitor
10801080
for (_blockhash, channel_monitor) in channel_monitors.into_iter() {
1081-
let funding_outpoint = channel_monitor.get_funding_txo().0;
1082-
chain_monitor.watch_channel(funding_outpoint, channel_monitor).map_err(|e| {
1081+
let channel_id = channel_monitor.channel_id();
1082+
chain_monitor.watch_channel(channel_id, channel_monitor).map_err(|e| {
10831083
log_error!(logger, "Failed to watch channel monitor: {:?}", e);
10841084
BuildError::InvalidChannelMonitor
10851085
})?;

src/chain/mod.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -306,7 +306,7 @@ impl ChainSource {
306306
if let Some(worst_channel_monitor_block_hash) = chain_monitor
307307
.list_monitors()
308308
.iter()
309-
.flat_map(|(txo, _)| chain_monitor.get_monitor(*txo))
309+
.flat_map(|channel_id| chain_monitor.get_monitor(*channel_id))
310310
.map(|m| m.current_best_block())
311311
.min_by_key(|b| b.height)
312312
.map(|b| b.block_hash)

src/lib.rs

+2-2
Original file line numberDiff line numberDiff line change
@@ -1376,8 +1376,8 @@ impl Node {
13761376

13771377
let mut total_lightning_balance_sats = 0;
13781378
let mut lightning_balances = Vec::new();
1379-
for (funding_txo, channel_id) in self.chain_monitor.list_monitors() {
1380-
match self.chain_monitor.get_monitor(funding_txo) {
1379+
for channel_id in self.chain_monitor.list_monitors() {
1380+
match self.chain_monitor.get_monitor(channel_id) {
13811381
Ok(monitor) => {
13821382
// unwrap safety: `get_counterparty_node_id` will always be `Some` after 0.0.110 and
13831383
// LDK Node 0.1 depended on 0.0.115 already.

0 commit comments

Comments
 (0)