Skip to content

Commit c505f07

Browse files
committed
Somewhat simplify message handling error mapping in peer_handler
1 parent 72a668b commit c505f07

File tree

1 file changed

+6
-12
lines changed

1 file changed

+6
-12
lines changed

lightning/src/ln/peer_handler.rs

Lines changed: 6 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -967,27 +967,21 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, L: Deref> PeerManager<D
967967
self.message_handler.chan_handler.handle_announcement_signatures(&peer.their_node_id.unwrap(), &msg);
968968
},
969969
wire::Message::ChannelAnnouncement(msg) => {
970-
if match self.message_handler.route_handler.handle_channel_announcement(&msg) {
971-
Ok(v) => v,
972-
Err(e) => { return Err(e.into()); },
973-
} {
970+
if self.message_handler.route_handler.handle_channel_announcement(&msg)
971+
.map_err(|e| -> MessageHandlingError { e.into() })? {
974972
should_forward = Some(wire::Message::ChannelAnnouncement(msg));
975973
}
976974
},
977975
wire::Message::NodeAnnouncement(msg) => {
978-
if match self.message_handler.route_handler.handle_node_announcement(&msg) {
979-
Ok(v) => v,
980-
Err(e) => { return Err(e.into()); },
981-
} {
976+
if self.message_handler.route_handler.handle_node_announcement(&msg)
977+
.map_err(|e| -> MessageHandlingError { e.into() })? {
982978
should_forward = Some(wire::Message::NodeAnnouncement(msg));
983979
}
984980
},
985981
wire::Message::ChannelUpdate(msg) => {
986982
self.message_handler.chan_handler.handle_channel_update(&peer.their_node_id.unwrap(), &msg);
987-
if match self.message_handler.route_handler.handle_channel_update(&msg) {
988-
Ok(v) => v,
989-
Err(e) => { return Err(e.into()); },
990-
} {
983+
if self.message_handler.route_handler.handle_channel_update(&msg)
984+
.map_err(|e| -> MessageHandlingError { e.into() })? {
991985
should_forward = Some(wire::Message::ChannelUpdate(msg));
992986
}
993987
},

0 commit comments

Comments
 (0)