Skip to content

Commit 0d374cf

Browse files
committed
Somewhat simplify message handling error mapping in peer_handler
1 parent ca153fe commit 0d374cf

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
@@ -966,27 +966,21 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, L: Deref> PeerManager<D
966966
self.message_handler.chan_handler.handle_announcement_signatures(&peer.their_node_id.unwrap(), &msg);
967967
},
968968
wire::Message::ChannelAnnouncement(msg) => {
969-
if match self.message_handler.route_handler.handle_channel_announcement(&msg) {
970-
Ok(v) => v,
971-
Err(e) => { return Err(e.into()); },
972-
} {
969+
if self.message_handler.route_handler.handle_channel_announcement(&msg)
970+
.map_err(|e| -> MessageHandlingError { e.into() })? {
973971
should_forward = Some(wire::Message::ChannelAnnouncement(msg));
974972
}
975973
},
976974
wire::Message::NodeAnnouncement(msg) => {
977-
if match self.message_handler.route_handler.handle_node_announcement(&msg) {
978-
Ok(v) => v,
979-
Err(e) => { return Err(e.into()); },
980-
} {
975+
if self.message_handler.route_handler.handle_node_announcement(&msg)
976+
.map_err(|e| -> MessageHandlingError { e.into() })? {
981977
should_forward = Some(wire::Message::NodeAnnouncement(msg));
982978
}
983979
},
984980
wire::Message::ChannelUpdate(msg) => {
985981
self.message_handler.chan_handler.handle_channel_update(&peer.their_node_id.unwrap(), &msg);
986-
if match self.message_handler.route_handler.handle_channel_update(&msg) {
987-
Ok(v) => v,
988-
Err(e) => { return Err(e.into()); },
989-
} {
982+
if self.message_handler.route_handler.handle_channel_update(&msg)
983+
.map_err(|e| -> MessageHandlingError { e.into() })? {
990984
should_forward = Some(wire::Message::ChannelUpdate(msg));
991985
}
992986
},

0 commit comments

Comments
 (0)