Upgrade rust-bitcoin to 0.32.2.

Author: arik-so

fuzz/Cargo.toml

@@ -22,7 +22,7 @@ lightning = { path = "../lightning", features = ["regex", "hashbrown", "_test_ut
 lightning-invoice = { path = "../lightning-invoice" }
 lightning-rapid-gossip-sync = { path = "../lightning-rapid-gossip-sync" }
 bech32 = "0.9.1"
-bitcoin = { version = "0.31.2", features = ["secp-lowmemory"] }
+bitcoin = { version = "0.32.2", features = ["secp-lowmemory"] }
 
 afl = { version = "0.12", optional = true }
 honggfuzz = { version = "0.5", optional = true, default-features = false }

fuzz/src/chanmon_consistency.rs

@@ -81,8 +81,8 @@ use bitcoin::secp256k1::ecdsa::{RecoverableSignature, Signature};
 use bitcoin::secp256k1::schnorr;
 use bitcoin::secp256k1::{self, Message, PublicKey, Scalar, Secp256k1, SecretKey};
 
+use lightning::io::Cursor;
 use std::cmp::{self, Ordering};
-use std::io::Cursor;
 use std::mem;
 use std::sync::atomic;
 use std::sync::{Arc, Mutex};
@@ -154,7 +154,7 @@ impl BroadcasterInterface for TestBroadcaster {
 
 pub struct VecWriter(pub Vec<u8>);
 impl Writer for VecWriter {
-	fn write_all(&mut self, buf: &[u8]) -> Result<(), ::std::io::Error> {
+	fn write_all(&mut self, buf: &[u8]) -> Result<(), ::lightning::io::Error> {
 		self.0.extend_from_slice(buf);
 		Ok(())
 	}
@@ -394,7 +394,7 @@ impl SignerProvider for KeyProvider {
 	}
 
 	fn read_chan_signer(&self, buffer: &[u8]) -> Result<Self::EcdsaSigner, DecodeError> {
-		let mut reader = std::io::Cursor::new(buffer);
+		let mut reader = lightning::io::Cursor::new(buffer);
 
 		let inner: InMemorySigner = ReadableArgs::read(&mut reader, self)?;
 		let state = self.make_enforcement_state_cell(inner.commitment_seed);

fuzz/src/chanmon_deser.rs

@@ -10,11 +10,11 @@ use lightning::util::test_utils::OnlyReadsKeysInterface;
 
 use crate::utils::test_logger;
 
-use std::io::Cursor;
+use lightning::io::Cursor;
 
 struct VecWriter(Vec<u8>);
 impl Writer for VecWriter {
-	fn write_all(&mut self, buf: &[u8]) -> Result<(), ::std::io::Error> {
+	fn write_all(&mut self, buf: &[u8]) -> Result<(), ::lightning::io::Error> {
 		self.0.extend_from_slice(buf);
 		Ok(())
 	}

fuzz/src/full_stack.rs

@@ -121,8 +121,8 @@ impl InputData {
 		Some(&self.data[old_pos..old_pos + len])
 	}
 }
-impl std::io::Read for &InputData {
-	fn read(&mut self, buf: &mut [u8]) -> std::io::Result<usize> {
+impl lightning::io::Read for &InputData {
+	fn read(&mut self, buf: &mut [u8]) -> lightning::io::Result<usize> {
 		if let Some(sl) = self.get_slice(buf.len()) {
 			buf.copy_from_slice(sl);
 			Ok(buf.len())

fuzz/src/msg_targets/utils.rs

@@ -12,7 +12,7 @@
 use lightning::util::ser::Writer;
 pub struct VecWriter(pub Vec<u8>);
 impl Writer for VecWriter {
-	fn write_all(&mut self, buf: &[u8]) -> Result<(), ::std::io::Error> {
+	fn write_all(&mut self, buf: &[u8]) -> Result<(), ::lightning::io::Error> {
 		self.0.extend_from_slice(buf);
 		Ok(())
 	}
@@ -31,7 +31,7 @@ impl Writer for VecWriter {
 macro_rules! test_msg {
 	($MsgType: path, $data: ident) => {{
 		use lightning::util::ser::{Readable, Writeable};
-		let mut r = ::std::io::Cursor::new($data);
+		let mut r = ::lightning::io::Cursor::new($data);
 		if let Ok(msg) = <$MsgType as Readable>::read(&mut r) {
 			let p = r.position() as usize;
 			let mut w = VecWriter(Vec::new());
@@ -50,13 +50,14 @@ macro_rules! test_msg {
 macro_rules! test_msg_simple {
 	($MsgType: path, $data: ident) => {{
 		use lightning::util::ser::{Readable, Writeable};
-		let mut r = ::std::io::Cursor::new($data);
+		let mut r = ::lightning::io::Cursor::new($data);
 		if let Ok(msg) = <$MsgType as Readable>::read(&mut r) {
 			let mut w = VecWriter(Vec::new());
 			msg.write(&mut w).unwrap();
 			assert_eq!(msg.serialized_length(), w.0.len());
 
-			let msg = <$MsgType as Readable>::read(&mut ::std::io::Cursor::new(&w.0)).unwrap();
+			let msg =
+				<$MsgType as Readable>::read(&mut ::lightning::io::Cursor::new(&w.0)).unwrap();
 			let mut w_two = VecWriter(Vec::new());
 			msg.write(&mut w_two).unwrap();
 			assert_eq!(&w.0[..], &w_two.0[..]);
@@ -70,7 +71,7 @@ macro_rules! test_msg_simple {
 macro_rules! test_msg_exact {
 	($MsgType: path, $data: ident) => {{
 		use lightning::util::ser::{Readable, Writeable};
-		let mut r = ::std::io::Cursor::new($data);
+		let mut r = ::lightning::io::Cursor::new($data);
 		if let Ok(msg) = <$MsgType as Readable>::read(&mut r) {
 			let mut w = VecWriter(Vec::new());
 			msg.write(&mut w).unwrap();
@@ -86,7 +87,7 @@ macro_rules! test_msg_exact {
 macro_rules! test_msg_hole {
 	($MsgType: path, $data: ident, $hole: expr, $hole_len: expr) => {{
 		use lightning::util::ser::{Readable, Writeable};
-		let mut r = ::std::io::Cursor::new($data);
+		let mut r = ::lightning::io::Cursor::new($data);
 		if let Ok(msg) = <$MsgType as Readable>::read(&mut r) {
 			let mut w = VecWriter(Vec::new());
 			msg.write(&mut w).unwrap();

fuzz/src/onion_hop_data.rs

@@ -17,7 +17,7 @@ use lightning::util::test_utils;
 pub fn onion_hop_data_test<Out: test_logger::Output>(data: &[u8], _out: Out) {
 	use bitcoin::secp256k1::PublicKey;
 	use lightning::util::ser::ReadableArgs;
-	let mut r = ::std::io::Cursor::new(data);
+	let mut r = ::lightning::io::Cursor::new(data);
 	let node_signer = test_utils::TestNodeSigner::new(test_utils::privkey(42));
 	let _ = <lightning::ln::msgs::InboundOnionPayload as ReadableArgs<(
 		Option<PublicKey>,
@@ -30,7 +30,7 @@ pub extern "C" fn onion_hop_data_run(data: *const u8, datalen: usize) {
 	use bitcoin::secp256k1::PublicKey;
 	use lightning::util::ser::ReadableArgs;
 	let data = unsafe { std::slice::from_raw_parts(data, datalen) };
-	let mut r = ::std::io::Cursor::new(data);
+	let mut r = ::lightning::io::Cursor::new(data);
 	let node_signer = test_utils::TestNodeSigner::new(test_utils::privkey(42));
 	let _ = <lightning::ln::msgs::InboundOnionPayload as ReadableArgs<(
 		Option<PublicKey>,

fuzz/src/onion_message.rs

@@ -30,7 +30,7 @@ use lightning_invoice::RawBolt11Invoice;
 
 use crate::utils::test_logger;
 
-use std::io::{self, Cursor};
+use lightning::io::{self, Cursor};
 use std::sync::atomic::{AtomicU64, Ordering};
 
 #[inline]
@@ -168,7 +168,7 @@ impl CustomOnionMessageHandler for TestCustomMessageHandler {
 		&self, _message_type: u64, buffer: &mut R,
 	) -> Result<Option<Self::CustomMessage>, msgs::DecodeError> {
 		let mut buf = Vec::new();
-		buffer.read_to_end(&mut buf)?;
+		buffer.read_to_limit(&mut buf, u64::MAX)?;
 		return Ok(Some(TestCustomMessage {}));
 	}
 	fn release_pending_custom_messages(&self) -> Vec<PendingOnionMessage<Self::CustomMessage>> {
@@ -178,7 +178,7 @@ impl CustomOnionMessageHandler for TestCustomMessageHandler {
 
 pub struct VecWriter(pub Vec<u8>);
 impl Writer for VecWriter {
-	fn write_all(&mut self, buf: &[u8]) -> Result<(), ::std::io::Error> {
+	fn write_all(&mut self, buf: &[u8]) -> Result<(), ::lightning::io::Error> {
 		self.0.extend_from_slice(buf);
 		Ok(())
 	}

fuzz/src/router.rs

@@ -146,7 +146,7 @@ pub fn do_test<Out: test_logger::Output>(data: &[u8], out: Out) {
 
 	macro_rules! decode_msg {
 		($MsgType: path, $len: expr) => {{
-			let mut reader = ::std::io::Cursor::new(get_slice!($len));
+			let mut reader = ::lightning::io::Cursor::new(get_slice!($len));
 			match <$MsgType>::read(&mut reader) {
 				Ok(msg) => {
 					assert_eq!(reader.position(), $len as u64);

lightning-background-processor/Cargo.toml

@@ -16,12 +16,12 @@ rustdoc-args = ["--cfg", "docsrs"]
 [features]
 futures = [ ]
 std = ["bitcoin/std", "lightning/std", "lightning-rapid-gossip-sync/std"]
-no-std = ["bitcoin/no-std", "lightning/no-std", "lightning-rapid-gossip-sync/no-std"]
+no-std = ["lightning/no-std", "lightning-rapid-gossip-sync/no-std"]
 
 default = ["std"]
 
 [dependencies]
-bitcoin = { version = "0.31.2", default-features = false }
+bitcoin = { version = "0.32.2", default-features = false }
 lightning = { version = "0.0.123-beta", path = "../lightning", default-features = false }
 lightning-rapid-gossip-sync = { version = "0.0.123-beta", path = "../lightning-rapid-gossip-sync", default-features = false }
 

lightning-background-processor/src/lib.rs

@@ -1326,7 +1326,7 @@ mod tests {
 				&& key == CHANNEL_MANAGER_PERSISTENCE_KEY
 			{
 				if let Some((error, message)) = self.manager_error {
-					return Err(std::io::Error::new(error, message));
+					return Err(std::io::Error::new(error, message).into());
 				}
 			}
 
@@ -1344,7 +1344,7 @@ mod tests {
 				};
 
 				if let Some((error, message)) = self.graph_error {
-					return Err(std::io::Error::new(error, message));
+					return Err(std::io::Error::new(error, message).into());
 				}
 			}
 
@@ -1353,7 +1353,7 @@ mod tests {
 				&& key == SCORER_PERSISTENCE_KEY
 			{
 				if let Some((error, message)) = self.scorer_error {
-					return Err(std::io::Error::new(error, message));
+					return Err(std::io::Error::new(error, message).into());
 				}
 			}
 
@@ -2002,7 +2002,7 @@ mod tests {
 		match bp_future.await {
 			Ok(_) => panic!("Expected error persisting manager"),
 			Err(e) => {
-				assert_eq!(e.kind(), std::io::ErrorKind::Other);
+				assert_eq!(e.kind(), lightning::io::ErrorKind::Other);
 				assert_eq!(e.get_ref().unwrap().to_string(), "test");
 			},
 		}