Skip to content

Commit ce25c63

Browse files
valentinewallacevalentinewallace
committed
Rustfmt wire.rs
Easier to review the previous commit this way.
1 parent e520d20 commit ce25c63

File tree

1 file changed

+98
-40
lines changed

1 file changed

+98
-40
lines changed

‎lightning/src/ln/wire.rs

+98-40
Original file line numberDiff line numberDiff line change
@@ -262,49 +262,103 @@ where
262262
msgs::WarningMessage::TYPE => Ok(Message::Warning(Readable::read(buffer)?)),
263263
msgs::Ping::TYPE => Ok(Message::Ping(Readable::read(buffer)?)),
264264
msgs::Pong::TYPE => Ok(Message::Pong(Readable::read(buffer)?)),
265-
msgs::PeerStorage::TYPE => Ok(Message::PeerStorage(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
266-
msgs::PeerStorageRetrieval::TYPE => {
267-
Ok(Message::PeerStorageRetrieval(LengthReadable::read_from_fixed_length_buffer(buffer)?))
265+
msgs::PeerStorage::TYPE => {
266+
Ok(Message::PeerStorage(LengthReadable::read_from_fixed_length_buffer(buffer)?))
268267
},
268+
msgs::PeerStorageRetrieval::TYPE => Ok(Message::PeerStorageRetrieval(
269+
LengthReadable::read_from_fixed_length_buffer(buffer)?,
270+
)),
269271
msgs::OpenChannel::TYPE => Ok(Message::OpenChannel(Readable::read(buffer)?)),
270272
msgs::OpenChannelV2::TYPE => Ok(Message::OpenChannelV2(Readable::read(buffer)?)),
271273
msgs::AcceptChannel::TYPE => Ok(Message::AcceptChannel(Readable::read(buffer)?)),
272274
msgs::AcceptChannelV2::TYPE => Ok(Message::AcceptChannelV2(Readable::read(buffer)?)),
273-
msgs::FundingCreated::TYPE => Ok(Message::FundingCreated(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
274-
msgs::FundingSigned::TYPE => Ok(Message::FundingSigned(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
275+
msgs::FundingCreated::TYPE => {
276+
Ok(Message::FundingCreated(LengthReadable::read_from_fixed_length_buffer(buffer)?))
277+
},
278+
msgs::FundingSigned::TYPE => {
279+
Ok(Message::FundingSigned(LengthReadable::read_from_fixed_length_buffer(buffer)?))
280+
},
275281
#[cfg(splicing)]
276-
msgs::SpliceInit::TYPE => Ok(Message::SpliceInit(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
277-
msgs::Stfu::TYPE => Ok(Message::Stfu(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
282+
msgs::SpliceInit::TYPE => {
283+
Ok(Message::SpliceInit(LengthReadable::read_from_fixed_length_buffer(buffer)?))
284+
},
285+
msgs::Stfu::TYPE => {
286+
Ok(Message::Stfu(LengthReadable::read_from_fixed_length_buffer(buffer)?))
287+
},
278288
#[cfg(splicing)]
279-
msgs::SpliceAck::TYPE => Ok(Message::SpliceAck(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
289+
msgs::SpliceAck::TYPE => {
290+
Ok(Message::SpliceAck(LengthReadable::read_from_fixed_length_buffer(buffer)?))
291+
},
280292
#[cfg(splicing)]
281-
msgs::SpliceLocked::TYPE => Ok(Message::SpliceLocked(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
282-
msgs::TxAddInput::TYPE => Ok(Message::TxAddInput(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
283-
msgs::TxAddOutput::TYPE => Ok(Message::TxAddOutput(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
284-
msgs::TxRemoveInput::TYPE => Ok(Message::TxRemoveInput(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
285-
msgs::TxRemoveOutput::TYPE => Ok(Message::TxRemoveOutput(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
286-
msgs::TxComplete::TYPE => Ok(Message::TxComplete(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
287-
msgs::TxSignatures::TYPE => Ok(Message::TxSignatures(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
288-
msgs::TxInitRbf::TYPE => Ok(Message::TxInitRbf(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
289-
msgs::TxAckRbf::TYPE => Ok(Message::TxAckRbf(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
290-
msgs::TxAbort::TYPE => Ok(Message::TxAbort(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
291-
msgs::ChannelReady::TYPE => Ok(Message::ChannelReady(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
292-
msgs::Shutdown::TYPE => Ok(Message::Shutdown(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
293-
msgs::ClosingSigned::TYPE => Ok(Message::ClosingSigned(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
294-
msgs::OnionMessage::TYPE => Ok(Message::OnionMessage(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
295-
msgs::UpdateAddHTLC::TYPE => Ok(Message::UpdateAddHTLC(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
296-
msgs::UpdateFulfillHTLC::TYPE => Ok(Message::UpdateFulfillHTLC(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
297-
msgs::UpdateFailHTLC::TYPE => Ok(Message::UpdateFailHTLC(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
298-
msgs::UpdateFailMalformedHTLC::TYPE => {
299-
Ok(Message::UpdateFailMalformedHTLC(LengthReadable::read_from_fixed_length_buffer(buffer)?))
300-
},
301-
msgs::CommitmentSigned::TYPE => Ok(Message::CommitmentSigned(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
302-
msgs::RevokeAndACK::TYPE => Ok(Message::RevokeAndACK(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
303-
msgs::UpdateFee::TYPE => Ok(Message::UpdateFee(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
304-
msgs::ChannelReestablish::TYPE => Ok(Message::ChannelReestablish(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
305-
msgs::AnnouncementSignatures::TYPE => {
306-
Ok(Message::AnnouncementSignatures(LengthReadable::read_from_fixed_length_buffer(buffer)?))
293+
msgs::SpliceLocked::TYPE => {
294+
Ok(Message::SpliceLocked(LengthReadable::read_from_fixed_length_buffer(buffer)?))
295+
},
296+
msgs::TxAddInput::TYPE => {
297+
Ok(Message::TxAddInput(LengthReadable::read_from_fixed_length_buffer(buffer)?))
298+
},
299+
msgs::TxAddOutput::TYPE => {
300+
Ok(Message::TxAddOutput(LengthReadable::read_from_fixed_length_buffer(buffer)?))
301+
},
302+
msgs::TxRemoveInput::TYPE => {
303+
Ok(Message::TxRemoveInput(LengthReadable::read_from_fixed_length_buffer(buffer)?))
304+
},
305+
msgs::TxRemoveOutput::TYPE => {
306+
Ok(Message::TxRemoveOutput(LengthReadable::read_from_fixed_length_buffer(buffer)?))
307+
},
308+
msgs::TxComplete::TYPE => {
309+
Ok(Message::TxComplete(LengthReadable::read_from_fixed_length_buffer(buffer)?))
310+
},
311+
msgs::TxSignatures::TYPE => {
312+
Ok(Message::TxSignatures(LengthReadable::read_from_fixed_length_buffer(buffer)?))
313+
},
314+
msgs::TxInitRbf::TYPE => {
315+
Ok(Message::TxInitRbf(LengthReadable::read_from_fixed_length_buffer(buffer)?))
316+
},
317+
msgs::TxAckRbf::TYPE => {
318+
Ok(Message::TxAckRbf(LengthReadable::read_from_fixed_length_buffer(buffer)?))
319+
},
320+
msgs::TxAbort::TYPE => {
321+
Ok(Message::TxAbort(LengthReadable::read_from_fixed_length_buffer(buffer)?))
322+
},
323+
msgs::ChannelReady::TYPE => {
324+
Ok(Message::ChannelReady(LengthReadable::read_from_fixed_length_buffer(buffer)?))
325+
},
326+
msgs::Shutdown::TYPE => {
327+
Ok(Message::Shutdown(LengthReadable::read_from_fixed_length_buffer(buffer)?))
328+
},
329+
msgs::ClosingSigned::TYPE => {
330+
Ok(Message::ClosingSigned(LengthReadable::read_from_fixed_length_buffer(buffer)?))
331+
},
332+
msgs::OnionMessage::TYPE => {
333+
Ok(Message::OnionMessage(LengthReadable::read_from_fixed_length_buffer(buffer)?))
334+
},
335+
msgs::UpdateAddHTLC::TYPE => {
336+
Ok(Message::UpdateAddHTLC(LengthReadable::read_from_fixed_length_buffer(buffer)?))
337+
},
338+
msgs::UpdateFulfillHTLC::TYPE => {
339+
Ok(Message::UpdateFulfillHTLC(LengthReadable::read_from_fixed_length_buffer(buffer)?))
340+
},
341+
msgs::UpdateFailHTLC::TYPE => {
342+
Ok(Message::UpdateFailHTLC(LengthReadable::read_from_fixed_length_buffer(buffer)?))
343+
},
344+
msgs::UpdateFailMalformedHTLC::TYPE => Ok(Message::UpdateFailMalformedHTLC(
345+
LengthReadable::read_from_fixed_length_buffer(buffer)?,
346+
)),
347+
msgs::CommitmentSigned::TYPE => {
348+
Ok(Message::CommitmentSigned(LengthReadable::read_from_fixed_length_buffer(buffer)?))
349+
},
350+
msgs::RevokeAndACK::TYPE => {
351+
Ok(Message::RevokeAndACK(LengthReadable::read_from_fixed_length_buffer(buffer)?))
352+
},
353+
msgs::UpdateFee::TYPE => {
354+
Ok(Message::UpdateFee(LengthReadable::read_from_fixed_length_buffer(buffer)?))
355+
},
356+
msgs::ChannelReestablish::TYPE => {
357+
Ok(Message::ChannelReestablish(LengthReadable::read_from_fixed_length_buffer(buffer)?))
307358
},
359+
msgs::AnnouncementSignatures::TYPE => Ok(Message::AnnouncementSignatures(
360+
LengthReadable::read_from_fixed_length_buffer(buffer)?,
361+
)),
308362
msgs::ChannelAnnouncement::TYPE => {
309363
Ok(Message::ChannelAnnouncement(Readable::read(buffer)?))
310364
},
@@ -313,14 +367,18 @@ where
313367
msgs::QueryShortChannelIds::TYPE => {
314368
Ok(Message::QueryShortChannelIds(Readable::read(buffer)?))
315369
},
316-
msgs::ReplyShortChannelIdsEnd::TYPE => {
317-
Ok(Message::ReplyShortChannelIdsEnd(LengthReadable::read_from_fixed_length_buffer(buffer)?))
370+
msgs::ReplyShortChannelIdsEnd::TYPE => Ok(Message::ReplyShortChannelIdsEnd(
371+
LengthReadable::read_from_fixed_length_buffer(buffer)?,
372+
)),
373+
msgs::QueryChannelRange::TYPE => {
374+
Ok(Message::QueryChannelRange(LengthReadable::read_from_fixed_length_buffer(buffer)?))
318375
},
319-
msgs::QueryChannelRange::TYPE => Ok(Message::QueryChannelRange(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
320-
msgs::ReplyChannelRange::TYPE => Ok(Message::ReplyChannelRange(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
321-
msgs::GossipTimestampFilter::TYPE => {
322-
Ok(Message::GossipTimestampFilter(LengthReadable::read_from_fixed_length_buffer(buffer)?))
376+
msgs::ReplyChannelRange::TYPE => {
377+
Ok(Message::ReplyChannelRange(LengthReadable::read_from_fixed_length_buffer(buffer)?))
323378
},
379+
msgs::GossipTimestampFilter::TYPE => Ok(Message::GossipTimestampFilter(
380+
LengthReadable::read_from_fixed_length_buffer(buffer)?,
381+
)),
324382
_ => {
325383
if let Some(custom) = custom_reader.read(message_type, buffer)? {
326384
Ok(Message::Custom(custom))

0 commit comments

Comments
 (0)