Skip to content

Commit b2d3bab

Browse files
TheBlueMattTheBlueMatt
committed
Make Readable::read a templated on the stream, not Readable itself
This makes Readable symmetric with Writeable and makes sense - something which is Readable should be Readable for any stream which implements std::io::Read, not only for a stream type it decides on. This solves some lifetime-compatibility issues in trying to read() from a LengthLimitingReader in arbitrary Readable impls.
1 parent 0496ede commit b2d3bab

File tree

13 files changed

+174
-180
lines changed

13 files changed

+174
-180
lines changed

‎lightning/src/chain/keysinterface.rs‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -115,8 +115,8 @@ impl Writeable for SpendableOutputDescriptor {
115115
}
116116
}
117117

118-
impl<R: ::std::io::Read> Readable<R> for SpendableOutputDescriptor {
119-
fn read(reader: &mut R) -> Result<Self, DecodeError> {
118+
impl Readable for SpendableOutputDescriptor {
119+
fn read<R: ::std::io::Read>(reader: &mut R) -> Result<Self, DecodeError> {
120120
match Readable::read(reader)? {
121121
0u8 => Ok(SpendableOutputDescriptor::StaticOutput {
122122
outpoint: Readable::read(reader)?,
@@ -381,8 +381,8 @@ impl Writeable for InMemoryChannelKeys {
381381
}
382382
}
383383

384-
impl<R: ::std::io::Read> Readable<R> for InMemoryChannelKeys {
385-
fn read(reader: &mut R) -> Result<Self, DecodeError> {
384+
impl Readable for InMemoryChannelKeys {
385+
fn read<R: ::std::io::Read>(reader: &mut R) -> Result<Self, DecodeError> {
386386
let funding_key = Readable::read(reader)?;
387387
let revocation_base_key = Readable::read(reader)?;
388388
let payment_base_key = Readable::read(reader)?;

‎lightning/src/ln/chan_utils.rs‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -156,8 +156,8 @@ impl Writeable for CounterpartyCommitmentSecrets {
156156
Ok(())
157157
}
158158
}
159-
impl<R: ::std::io::Read> Readable<R> for CounterpartyCommitmentSecrets {
160-
fn read(reader: &mut R) -> Result<Self, DecodeError> {
159+
impl Readable for CounterpartyCommitmentSecrets {
160+
fn read<R: ::std::io::Read>(reader: &mut R) -> Result<Self, DecodeError> {
161161
let mut old_secrets = [([0; 32], 1 << 48); 49];
162162
for &mut (ref mut secret, ref mut idx) in old_secrets.iter_mut() {
163163
*secret = Readable::read(reader)?;
@@ -607,8 +607,8 @@ impl Writeable for LocalCommitmentTransaction {
607607
Ok(())
608608
}
609609
}
610-
impl<R: ::std::io::Read> Readable<R> for LocalCommitmentTransaction {
611-
fn read(reader: &mut R) -> Result<Self, DecodeError> {
610+
impl Readable for LocalCommitmentTransaction {
611+
fn read<R: ::std::io::Read>(reader: &mut R) -> Result<Self, DecodeError> {
612612
let tx = match Transaction::consensus_decode(reader.by_ref()) {
613613
Ok(tx) => tx,
614614
Err(e) => match e {

‎lightning/src/ln/channel.rs‎

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -3811,9 +3811,9 @@ impl Writeable for InboundHTLCRemovalReason {
38113811
}
38123812
}
38133813

3814-
impl<R: ::std::io::Read> Readable<R> for InboundHTLCRemovalReason {
3815-
fn read(reader: &mut R) -> Result<Self, DecodeError> {
3816-
Ok(match <u8 as Readable<R>>::read(reader)? {
3814+
impl Readable for InboundHTLCRemovalReason {
3815+
fn read<R: ::std::io::Read>(reader: &mut R) -> Result<Self, DecodeError> {
3816+
Ok(match <u8 as Readable>::read(reader)? {
38173817
0 => InboundHTLCRemovalReason::FailRelay(Readable::read(reader)?),
38183818
1 => InboundHTLCRemovalReason::FailMalformed((Readable::read(reader)?, Readable::read(reader)?)),
38193819
2 => InboundHTLCRemovalReason::Fulfill(Readable::read(reader)?),
@@ -4022,8 +4022,8 @@ impl<ChanSigner: ChannelKeys + Writeable> Writeable for Channel<ChanSigner> {
40224022
}
40234023
}
40244024

4025-
impl<R : ::std::io::Read, ChanSigner: ChannelKeys + Readable<R>> ReadableArgs<R, Arc<Logger>> for Channel<ChanSigner> {
4026-
fn read(reader: &mut R, logger: Arc<Logger>) -> Result<Self, DecodeError> {
4025+
impl<ChanSigner: ChannelKeys + Readable> ReadableArgs<Arc<Logger>> for Channel<ChanSigner> {
4026+
fn read<R : ::std::io::Read>(reader: &mut R, logger: Arc<Logger>) -> Result<Self, DecodeError> {
40274027
let _ver: u8 = Readable::read(reader)?;
40284028
let min_ver: u8 = Readable::read(reader)?;
40294029
if min_ver > SERIALIZATION_VERSION {
@@ -4056,7 +4056,7 @@ impl<R : ::std::io::Read, ChanSigner: ChannelKeys + Readable<R>> ReadableArgs<R,
40564056
amount_msat: Readable::read(reader)?,
40574057
cltv_expiry: Readable::read(reader)?,
40584058
payment_hash: Readable::read(reader)?,
4059-
state: match <u8 as Readable<R>>::read(reader)? {
4059+
state: match <u8 as Readable>::read(reader)? {
40604060
1 => InboundHTLCState::AwaitingRemoteRevokeToAnnounce(Readable::read(reader)?),
40614061
2 => InboundHTLCState::AwaitingAnnouncedRemoteRevoke(Readable::read(reader)?),
40624062
3 => InboundHTLCState::Committed,
@@ -4075,7 +4075,7 @@ impl<R : ::std::io::Read, ChanSigner: ChannelKeys + Readable<R>> ReadableArgs<R,
40754075
cltv_expiry: Readable::read(reader)?,
40764076
payment_hash: Readable::read(reader)?,
40774077
source: Readable::read(reader)?,
4078-
state: match <u8 as Readable<R>>::read(reader)? {
4078+
state: match <u8 as Readable>::read(reader)? {
40794079
0 => OutboundHTLCState::LocalAnnounced(Box::new(Readable::read(reader)?)),
40804080
1 => OutboundHTLCState::Committed,
40814081
2 => OutboundHTLCState::RemoteRemoved(Readable::read(reader)?),
@@ -4089,7 +4089,7 @@ impl<R : ::std::io::Read, ChanSigner: ChannelKeys + Readable<R>> ReadableArgs<R,
40894089
let holding_cell_htlc_update_count: u64 = Readable::read(reader)?;
40904090
let mut holding_cell_htlc_updates = Vec::with_capacity(cmp::min(holding_cell_htlc_update_count as usize, OUR_MAX_HTLCS as usize*2));
40914091
for _ in 0..holding_cell_htlc_update_count {
4092-
holding_cell_htlc_updates.push(match <u8 as Readable<R>>::read(reader)? {
4092+
holding_cell_htlc_updates.push(match <u8 as Readable>::read(reader)? {
40934093
0 => HTLCUpdateAwaitingACK::AddHTLC {
40944094
amount_msat: Readable::read(reader)?,
40954095
cltv_expiry: Readable::read(reader)?,
@@ -4109,7 +4109,7 @@ impl<R : ::std::io::Read, ChanSigner: ChannelKeys + Readable<R>> ReadableArgs<R,
41094109
});
41104110
}
41114111

4112-
let resend_order = match <u8 as Readable<R>>::read(reader)? {
4112+
let resend_order = match <u8 as Readable>::read(reader)? {
41134113
0 => RAACommitmentOrder::CommitmentFirst,
41144114
1 => RAACommitmentOrder::RevokeAndACKFirst,
41154115
_ => return Err(DecodeError::InvalidValue),
@@ -4139,7 +4139,7 @@ impl<R : ::std::io::Read, ChanSigner: ChannelKeys + Readable<R>> ReadableArgs<R,
41394139
let channel_update_count = Readable::read(reader)?;
41404140
let feerate_per_kw = Readable::read(reader)?;
41414141

4142-
let last_sent_closing_fee = match <u8 as Readable<R>>::read(reader)? {
4142+
let last_sent_closing_fee = match <u8 as Readable>::read(reader)? {
41434143
0 => None,
41444144
1 => Some((Readable::read(reader)?, Readable::read(reader)?, Readable::read(reader)?)),
41454145
_ => return Err(DecodeError::InvalidValue),

‎lightning/src/ln/channelmanager.rs‎

Lines changed: 23 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -3061,8 +3061,8 @@ impl Writeable for PendingHTLCInfo {
30613061
}
30623062
}
30633063

3064-
impl<R: ::std::io::Read> Readable<R> for PendingHTLCInfo {
3065-
fn read(reader: &mut R) -> Result<PendingHTLCInfo, DecodeError> {
3064+
impl Readable for PendingHTLCInfo {
3065+
fn read<R: ::std::io::Read>(reader: &mut R) -> Result<PendingHTLCInfo, DecodeError> {
30663066
Ok(PendingHTLCInfo {
30673067
onion_packet: Readable::read(reader)?,
30683068
incoming_shared_secret: Readable::read(reader)?,
@@ -3090,9 +3090,9 @@ impl Writeable for HTLCFailureMsg {
30903090
}
30913091
}
30923092

3093-
impl<R: ::std::io::Read> Readable<R> for HTLCFailureMsg {
3094-
fn read(reader: &mut R) -> Result<HTLCFailureMsg, DecodeError> {
3095-
match <u8 as Readable<R>>::read(reader)? {
3093+
impl Readable for HTLCFailureMsg {
3094+
fn read<R: ::std::io::Read>(reader: &mut R) -> Result<HTLCFailureMsg, DecodeError> {
3095+
match <u8 as Readable>::read(reader)? {
30963096
0 => Ok(HTLCFailureMsg::Relay(Readable::read(reader)?)),
30973097
1 => Ok(HTLCFailureMsg::Malformed(Readable::read(reader)?)),
30983098
_ => Err(DecodeError::InvalidValue),
@@ -3116,9 +3116,9 @@ impl Writeable for PendingHTLCStatus {
31163116
}
31173117
}
31183118

3119-
impl<R: ::std::io::Read> Readable<R> for PendingHTLCStatus {
3120-
fn read(reader: &mut R) -> Result<PendingHTLCStatus, DecodeError> {
3121-
match <u8 as Readable<R>>::read(reader)? {
3119+
impl Readable for PendingHTLCStatus {
3120+
fn read<R: ::std::io::Read>(reader: &mut R) -> Result<PendingHTLCStatus, DecodeError> {
3121+
match <u8 as Readable>::read(reader)? {
31223122
0 => Ok(PendingHTLCStatus::Forward(Readable::read(reader)?)),
31233123
1 => Ok(PendingHTLCStatus::Fail(Readable::read(reader)?)),
31243124
_ => Err(DecodeError::InvalidValue),
@@ -3150,9 +3150,9 @@ impl Writeable for HTLCSource {
31503150
}
31513151
}
31523152

3153-
impl<R: ::std::io::Read> Readable<R> for HTLCSource {
3154-
fn read(reader: &mut R) -> Result<HTLCSource, DecodeError> {
3155-
match <u8 as Readable<R>>::read(reader)? {
3153+
impl Readable for HTLCSource {
3154+
fn read<R: ::std::io::Read>(reader: &mut R) -> Result<HTLCSource, DecodeError> {
3155+
match <u8 as Readable>::read(reader)? {
31563156
0 => Ok(HTLCSource::PreviousHopData(Readable::read(reader)?)),
31573157
1 => Ok(HTLCSource::OutboundRoute {
31583158
route: Readable::read(reader)?,
@@ -3181,9 +3181,9 @@ impl Writeable for HTLCFailReason {
31813181
}
31823182
}
31833183

3184-
impl<R: ::std::io::Read> Readable<R> for HTLCFailReason {
3185-
fn read(reader: &mut R) -> Result<HTLCFailReason, DecodeError> {
3186-
match <u8 as Readable<R>>::read(reader)? {
3184+
impl Readable for HTLCFailReason {
3185+
fn read<R: ::std::io::Read>(reader: &mut R) -> Result<HTLCFailReason, DecodeError> {
3186+
match <u8 as Readable>::read(reader)? {
31873187
0 => Ok(HTLCFailReason::LightningError { err: Readable::read(reader)? }),
31883188
1 => Ok(HTLCFailReason::Reason {
31893189
failure_code: Readable::read(reader)?,
@@ -3213,9 +3213,9 @@ impl Writeable for HTLCForwardInfo {
32133213
}
32143214
}
32153215

3216-
impl<R: ::std::io::Read> Readable<R> for HTLCForwardInfo {
3217-
fn read(reader: &mut R) -> Result<HTLCForwardInfo, DecodeError> {
3218-
match <u8 as Readable<R>>::read(reader)? {
3216+
impl Readable for HTLCForwardInfo {
3217+
fn read<R: ::std::io::Read>(reader: &mut R) -> Result<HTLCForwardInfo, DecodeError> {
3218+
match <u8 as Readable>::read(reader)? {
32193219
0 => Ok(HTLCForwardInfo::AddHTLC {
32203220
prev_short_channel_id: Readable::read(reader)?,
32213221
prev_htlc_id: Readable::read(reader)?,
@@ -3354,27 +3354,27 @@ pub struct ChannelManagerReadArgs<'a, ChanSigner: 'a + ChannelKeys, M: Deref, T:
33543354

33553355
// Implement ReadableArgs for an Arc'd ChannelManager to make it a bit easier to work with the
33563356
// SipmleArcChannelManager type:
3357-
impl<'a, R : ::std::io::Read, ChanSigner: ChannelKeys + Readable<R>, M: Deref, T: Deref, K: Deref, F: Deref>
3358-
ReadableArgs<R, ChannelManagerReadArgs<'a, ChanSigner, M, T, K, F>> for (Sha256dHash, Arc<ChannelManager<ChanSigner, M, T, K, F>>)
3357+
impl<'a, ChanSigner: ChannelKeys + Readable, M: Deref, T: Deref, K: Deref, F: Deref>
3358+
ReadableArgs<ChannelManagerReadArgs<'a, ChanSigner, M, T, K, F>> for (Sha256dHash, Arc<ChannelManager<ChanSigner, M, T, K, F>>)
33593359
where M::Target: ManyChannelMonitor<ChanSigner>,
33603360
T::Target: BroadcasterInterface,
33613361
K::Target: KeysInterface<ChanKeySigner = ChanSigner>,
33623362
F::Target: FeeEstimator,
33633363
{
3364-
fn read(reader: &mut R, args: ChannelManagerReadArgs<'a, ChanSigner, M, T, K, F>) -> Result<Self, DecodeError> {
3364+
fn read<R: ::std::io::Read>(reader: &mut R, args: ChannelManagerReadArgs<'a, ChanSigner, M, T, K, F>) -> Result<Self, DecodeError> {
33653365
let (blockhash, chan_manager) = <(Sha256dHash, ChannelManager<ChanSigner, M, T, K, F>)>::read(reader, args)?;
33663366
Ok((blockhash, Arc::new(chan_manager)))
33673367
}
33683368
}
33693369

3370-
impl<'a, R : ::std::io::Read, ChanSigner: ChannelKeys + Readable<R>, M: Deref, T: Deref, K: Deref, F: Deref>
3371-
ReadableArgs<R, ChannelManagerReadArgs<'a, ChanSigner, M, T, K, F>> for (Sha256dHash, ChannelManager<ChanSigner, M, T, K, F>)
3370+
impl<'a, ChanSigner: ChannelKeys + Readable, M: Deref, T: Deref, K: Deref, F: Deref>
3371+
ReadableArgs<ChannelManagerReadArgs<'a, ChanSigner, M, T, K, F>> for (Sha256dHash, ChannelManager<ChanSigner, M, T, K, F>)
33723372
where M::Target: ManyChannelMonitor<ChanSigner>,
33733373
T::Target: BroadcasterInterface,
33743374
K::Target: KeysInterface<ChanKeySigner = ChanSigner>,
33753375
F::Target: FeeEstimator,
33763376
{
3377-
fn read(reader: &mut R, args: ChannelManagerReadArgs<'a, ChanSigner, M, T, K, F>) -> Result<Self, DecodeError> {
3377+
fn read<R: ::std::io::Read>(reader: &mut R, args: ChannelManagerReadArgs<'a, ChanSigner, M, T, K, F>) -> Result<Self, DecodeError> {
33783378
let _ver: u8 = Readable::read(reader)?;
33793379
let min_ver: u8 = Readable::read(reader)?;
33803380
if min_ver > SERIALIZATION_VERSION {

0 commit comments

Comments
 (0)