Skip to content

Commit dbfedef

Browse files
committed
Emit ChannelEstablished upon channel getting usable
1 parent c5cadfb commit dbfedef

File tree

1 file changed

+16
-0
lines changed

1 file changed

+16
-0
lines changed

lightning/src/ln/channelmanager.rs

+16
Original file line numberDiff line numberDiff line change
@@ -4658,6 +4658,14 @@ impl<Signer: Sign, M: Deref, T: Deref, K: Deref, F: Deref, L: Deref> ChannelMana
46584658
msg,
46594659
});
46604660
}
4661+
4662+
let mut pending_events = self.pending_events.lock().unwrap();
4663+
pending_events.push(events::Event::ChannelEstablished {
4664+
channel_id: chan.get().channel_id(),
4665+
user_channel_id: chan.get().get_user_id(),
4666+
counterparty_node_id: chan.get().get_counterparty_node_id(),
4667+
channel_type: chan.get().get_channel_type().clone(),
4668+
});
46614669
}
46624670
Ok(())
46634671
},
@@ -5807,6 +5815,14 @@ where
58075815
msg,
58085816
});
58095817
}
5818+
5819+
let mut pending_events = self.pending_events.lock().unwrap();
5820+
pending_events.push(events::Event::ChannelEstablished {
5821+
channel_id: channel.channel_id(),
5822+
user_channel_id: channel.get_user_id(),
5823+
counterparty_node_id: channel.get_counterparty_node_id(),
5824+
channel_type: channel.get_channel_type().clone(),
5825+
});
58105826
} else {
58115827
log_trace!(self.logger, "Sending channel_ready WITHOUT channel_update for {}", log_bytes!(channel.channel_id()));
58125828
}

0 commit comments

Comments
 (0)