X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=src%2Fln%2Fpeer_handler.rs;h=76cc35f64c550b9b401faab6272a9d163383e821;hb=ed30a199e35070c85fdf8199ec4ea65bcbec9a47;hp=13d3f1a681028aed9ab3dc05467f32a032fdac41;hpb=6e1318b0e28522244493c280f556e6749694b81e;p=rust-lightning

diff --git a/src/ln/peer_handler.rs b/src/ln/peer_handler.rs
index 13d3f1a6..76cc35f6 100644
--- a/src/ln/peer_handler.rs
+++ b/src/ln/peer_handler.rs
@@ -647,6 +647,9 @@ impl<Descriptor: SocketDescriptor> PeerManager<Descriptor> {
 														for resp in resps.update_fail_htlcs {
 															encode_and_send_msg!(resp, 131);
 														}
+														if let Some(resp) = resps.update_fee {
+															encode_and_send_msg!(resp, 134);
+														}
 														encode_and_send_msg!(resps.commitment_signed, 132);
 													},
 													None => {},
@@ -676,6 +679,9 @@ impl<Descriptor: SocketDescriptor> PeerManager<Descriptor> {
 														for resp in resps.update_fail_htlcs {
 															encode_and_send_msg!(resp, 131);
 														}
+														if let Some(resp) = resps.update_fee {
+															encode_and_send_msg!(resp, 134);
+														}
 														encode_and_send_msg!(resps.commitment_signed, 132);
 													},
 													None => {},
@@ -820,7 +826,7 @@ impl<Descriptor: SocketDescriptor> PeerManager<Descriptor> {
 						Self::do_attempt_write_data(&mut descriptor, peer);
 						continue;
 					},
-					Event::UpdateHTLCs { ref node_id, updates: msgs::CommitmentUpdate { ref update_add_htlcs, ref update_fulfill_htlcs, ref update_fail_htlcs, ref update_fail_malformed_htlcs, ref commitment_signed } } => {
+					Event::UpdateHTLCs { ref node_id, updates: msgs::CommitmentUpdate { ref update_add_htlcs, ref update_fulfill_htlcs, ref update_fail_htlcs, ref update_fail_malformed_htlcs, ref update_fee, ref commitment_signed } } => {
 						log_trace!(self, "Handling UpdateHTLCs event in peer_handler for node {} with {} adds, {} fulfills, {} fails for channel {}",
 								log_pubkey!(node_id),
 								update_add_htlcs.len(),
@@ -842,6 +848,9 @@ impl<Descriptor: SocketDescriptor> PeerManager<Descriptor> {
 						for msg in update_fail_malformed_htlcs {
 							peer.pending_outbound_buffer.push_back(peer.channel_encryptor.encrypt_message(&encode_msg!(msg, 135)));
 						}
+						if let &Some(ref msg) = update_fee {
+							peer.pending_outbound_buffer.push_back(peer.channel_encryptor.encrypt_message(&encode_msg!(msg, 134)));
+						}
 						peer.pending_outbound_buffer.push_back(peer.channel_encryptor.encrypt_message(&encode_msg!(commitment_signed, 132)));
 						Self::do_attempt_write_data(&mut descriptor, peer);
 						continue;