X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=src%2Fln%2Fpeer_handler.rs;h=2472518d613a4199678a6dbe0c811d9fe42e38ea;hb=c47525cb8496c4a82b68e0933a3a5fe0c38e5494;hp=812bade6881bf3ffe705bc5006772498836bb37c;hpb=e98e1e2fdca15edab9a5e0ef9b49c841904af445;p=rust-lightning diff --git a/src/ln/peer_handler.rs b/src/ln/peer_handler.rs index 812bade6..2472518d 100644 --- a/src/ln/peer_handler.rs +++ b/src/ln/peer_handler.rs @@ -614,6 +614,14 @@ impl PeerManager { //TODO: Handle upstream in some confused form so that upstream just knows //to call us somehow? }, + Event::SendOpenChannel { ref node_id, ref msg } => { + let (mut descriptor, peer) = get_peer_for_forwarding!(node_id, { + //TODO: Drop the pending channel? (or just let it timeout, but that sucks) + }); + peer.pending_outbound_buffer.push_back(peer.channel_encryptor.encrypt_message(&encode_msg!(msg, 32))); + Self::do_attempt_write_data(&mut descriptor, peer); + continue; + }, Event::SendFundingCreated { ref node_id, ref msg } => { let (mut descriptor, peer) = get_peer_for_forwarding!(node_id, { //TODO: generate a DiscardFunding event indicating to the wallet that