Skip to content

Commit 40d80c2

Browse files
valentinewallacevalentinewallace
committed
Rustfmt wire.rs
Easier to review the previous commit this way.
1 parent 50731ea commit 40d80c2

File tree

1 file changed

+88
-36
lines changed

1 file changed

+88
-36
lines changed

‎lightning/src/ln/wire.rs

+88-36
Original file line numberDiff line numberDiff line change
@@ -262,49 +262,97 @@ 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)]
276282
msgs::SpliceInit::TYPE => Ok(Message::SpliceInit(Readable::read(buffer)?)),
277-
msgs::Stfu::TYPE => Ok(Message::Stfu(LengthReadable::read_from_fixed_length_buffer(buffer)?)),
283+
msgs::Stfu::TYPE => {
284+
Ok(Message::Stfu(LengthReadable::read_from_fixed_length_buffer(buffer)?))
285+
},
278286
#[cfg(splicing)]
279287
msgs::SpliceAck::TYPE => Ok(Message::SpliceAck(Readable::read(buffer)?)),
280288
#[cfg(splicing)]
281289
msgs::SpliceLocked::TYPE => Ok(Message::SpliceLocked(Readable::read(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)?))
290+
msgs::TxAddInput::TYPE => {
291+
Ok(Message::TxAddInput(LengthReadable::read_from_fixed_length_buffer(buffer)?))
292+
},
293+
msgs::TxAddOutput::TYPE => {
294+
Ok(Message::TxAddOutput(LengthReadable::read_from_fixed_length_buffer(buffer)?))
295+
},
296+
msgs::TxRemoveInput::TYPE => {
297+
Ok(Message::TxRemoveInput(LengthReadable::read_from_fixed_length_buffer(buffer)?))
298+
},
299+
msgs::TxRemoveOutput::TYPE => {
300+
Ok(Message::TxRemoveOutput(LengthReadable::read_from_fixed_length_buffer(buffer)?))
301+
},
302+
msgs::TxComplete::TYPE => {
303+
Ok(Message::TxComplete(LengthReadable::read_from_fixed_length_buffer(buffer)?))
304+
},
305+
msgs::TxSignatures::TYPE => {
306+
Ok(Message::TxSignatures(LengthReadable::read_from_fixed_length_buffer(buffer)?))
307+
},
308+
msgs::TxInitRbf::TYPE => {
309+
Ok(Message::TxInitRbf(LengthReadable::read_from_fixed_length_buffer(buffer)?))
310+
},
311+
msgs::TxAckRbf::TYPE => {
312+
Ok(Message::TxAckRbf(LengthReadable::read_from_fixed_length_buffer(buffer)?))
313+
},
314+
msgs::TxAbort::TYPE => {
315+
Ok(Message::TxAbort(LengthReadable::read_from_fixed_length_buffer(buffer)?))
316+
},
317+
msgs::ChannelReady::TYPE => {
318+
Ok(Message::ChannelReady(LengthReadable::read_from_fixed_length_buffer(buffer)?))
319+
},
320+
msgs::Shutdown::TYPE => {
321+
Ok(Message::Shutdown(LengthReadable::read_from_fixed_length_buffer(buffer)?))
322+
},
323+
msgs::ClosingSigned::TYPE => {
324+
Ok(Message::ClosingSigned(LengthReadable::read_from_fixed_length_buffer(buffer)?))
325+
},
326+
msgs::OnionMessage::TYPE => {
327+
Ok(Message::OnionMessage(LengthReadable::read_from_fixed_length_buffer(buffer)?))
328+
},
329+
msgs::UpdateAddHTLC::TYPE => {
330+
Ok(Message::UpdateAddHTLC(LengthReadable::read_from_fixed_length_buffer(buffer)?))
331+
},
332+
msgs::UpdateFulfillHTLC::TYPE => {
333+
Ok(Message::UpdateFulfillHTLC(LengthReadable::read_from_fixed_length_buffer(buffer)?))
334+
},
335+
msgs::UpdateFailHTLC::TYPE => {
336+
Ok(Message::UpdateFailHTLC(LengthReadable::read_from_fixed_length_buffer(buffer)?))
337+
},
338+
msgs::UpdateFailMalformedHTLC::TYPE => Ok(Message::UpdateFailMalformedHTLC(
339+
LengthReadable::read_from_fixed_length_buffer(buffer)?,
340+
)),
341+
msgs::CommitmentSigned::TYPE => {
342+
Ok(Message::CommitmentSigned(LengthReadable::read_from_fixed_length_buffer(buffer)?))
343+
},
344+
msgs::RevokeAndACK::TYPE => {
345+
Ok(Message::RevokeAndACK(LengthReadable::read_from_fixed_length_buffer(buffer)?))
346+
},
347+
msgs::UpdateFee::TYPE => {
348+
Ok(Message::UpdateFee(LengthReadable::read_from_fixed_length_buffer(buffer)?))
300349
},
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)?))
350+
msgs::ChannelReestablish::TYPE => {
351+
Ok(Message::ChannelReestablish(LengthReadable::read_from_fixed_length_buffer(buffer)?))
307352
},
353+
msgs::AnnouncementSignatures::TYPE => Ok(Message::AnnouncementSignatures(
354+
LengthReadable::read_from_fixed_length_buffer(buffer)?,
355+
)),
308356
msgs::ChannelAnnouncement::TYPE => {
309357
Ok(Message::ChannelAnnouncement(Readable::read(buffer)?))
310358
},
@@ -313,14 +361,18 @@ where
313361
msgs::QueryShortChannelIds::TYPE => {
314362
Ok(Message::QueryShortChannelIds(Readable::read(buffer)?))
315363
},
316-
msgs::ReplyShortChannelIdsEnd::TYPE => {
317-
Ok(Message::ReplyShortChannelIdsEnd(LengthReadable::read_from_fixed_length_buffer(buffer)?))
364+
msgs::ReplyShortChannelIdsEnd::TYPE => Ok(Message::ReplyShortChannelIdsEnd(
365+
LengthReadable::read_from_fixed_length_buffer(buffer)?,
366+
)),
367+
msgs::QueryChannelRange::TYPE => {
368+
Ok(Message::QueryChannelRange(LengthReadable::read_from_fixed_length_buffer(buffer)?))
318369
},
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)?))
370+
msgs::ReplyChannelRange::TYPE => {
371+
Ok(Message::ReplyChannelRange(LengthReadable::read_from_fixed_length_buffer(buffer)?))
323372
},
373+
msgs::GossipTimestampFilter::TYPE => Ok(Message::GossipTimestampFilter(
374+
LengthReadable::read_from_fixed_length_buffer(buffer)?,
375+
)),
324376
_ => {
325377
if let Some(custom) = custom_reader.read(message_type, buffer)? {
326378
Ok(Message::Custom(custom))

0 commit comments

Comments
 (0)