c1d74a3eae Run the formatter (Tobin C. Harding)

Pull request description:

  We recently merged a PR that enables the formatter on the `examples/` directory, at the same time we merged `examples/ecdsa-psbt.rs` but it had formatting issues under the new formatter config.

  Run `cargo +nightly fmt` to format the `examples/` directory.

ACKs for top commit:
  sanket1729:
    utACK c1d74a3eae
  apoelstra:
    ACK c1d74a3eae

Tree-SHA512: 645bf01c7cbb21e2eec23e6fa9c2f5d26e03566059d906e1985af5a9c0186470ef8a0c295f7be0a5226e2f948e2a94aa336de4b3704a31fd8715764f1625737d
This commit is contained in:
Andrew Poelstra 2022-07-20 16:23:01 +00:00
commit e8b58fbcb1
No known key found for this signature in database
GPG Key ID: C588D63CE41B97C1
1 changed files with 82 additions and 95 deletions

View File

@ -28,18 +28,24 @@
//! `bt listunspent` //! `bt listunspent`
//! //!
use std::collections::BTreeMap;
use std::fmt; use std::fmt;
use std::str::FromStr; use std::str::FromStr;
use std::collections::BTreeMap;
use bitcoin::{Address, Amount, Network, OutPoint, PublicKey, PrivateKey, Sequence, Script, Transaction, Txid, TxOut, TxIn, Witness};
use bitcoin::consensus::encode; use bitcoin::consensus::encode;
use bitcoin::hashes::hex::{self, FromHex}; use bitcoin::hashes::hex::{self, FromHex};
use bitcoin::secp256k1::{Secp256k1, Signing, Verification}; use bitcoin::secp256k1::{Secp256k1, Signing, Verification};
use bitcoin::util::address; use bitcoin::util::address;
use bitcoin::util::amount::ParseAmountError; use bitcoin::util::amount::ParseAmountError;
use bitcoin::util::bip32::{self, ChildNumber, DerivationPath, ExtendedPrivKey, ExtendedPubKey, Fingerprint, IntoDerivationPath}; use bitcoin::util::bip32::{
self, ChildNumber, DerivationPath, ExtendedPrivKey, ExtendedPubKey, Fingerprint,
IntoDerivationPath,
};
use bitcoin::util::psbt::{self, Input, Psbt, PsbtSighashType}; use bitcoin::util::psbt::{self, Input, Psbt, PsbtSighashType};
use bitcoin::{
Address, Amount, Network, OutPoint, PrivateKey, PublicKey, Script, Sequence, Transaction, TxIn,
TxOut, Txid, Witness,
};
use self::psbt_sign::*; use self::psbt_sign::*;
@ -69,7 +75,8 @@ const NETWORK: Network = Network::Regtest;
fn main() -> Result<()> { fn main() -> Result<()> {
let secp = Secp256k1::new(); let secp = Secp256k1::new();
let (offline, fingerprint, account_0_xpub, input_xpub) = ColdStorage::new(&secp, EXTENDED_MASTER_PRIVATE_KEY)?; let (offline, fingerprint, account_0_xpub, input_xpub) =
ColdStorage::new(&secp, EXTENDED_MASTER_PRIVATE_KEY)?;
let online = WatchOnly::new(account_0_xpub, input_xpub, fingerprint); let online = WatchOnly::new(account_0_xpub, input_xpub, fingerprint);
@ -109,7 +116,7 @@ impl ColdStorage {
/// # Returns /// # Returns
/// ///
/// The newly created signer along with the data needed to configure a watch-only wallet. /// The newly created signer along with the data needed to configure a watch-only wallet.
fn new<C: Signing>(secp: &Secp256k1<C>, xpriv: &str)-> Result<ExportData> { fn new<C: Signing>(secp: &Secp256k1<C>, xpriv: &str) -> Result<ExportData> {
let master_xpriv = ExtendedPrivKey::from_str(xpriv)?; let master_xpriv = ExtendedPrivKey::from_str(xpriv)?;
let master_xpub = ExtendedPubKey::from_priv(secp, &master_xpriv); let master_xpub = ExtendedPubKey::from_priv(secp, &master_xpriv);
@ -123,19 +130,14 @@ impl ColdStorage {
let input_xpriv = master_xpriv.derive_priv(secp, &path)?; let input_xpriv = master_xpriv.derive_priv(secp, &path)?;
let input_xpub = ExtendedPubKey::from_priv(secp, &input_xpriv); let input_xpub = ExtendedPubKey::from_priv(secp, &input_xpriv);
let wallet = ColdStorage { let wallet = ColdStorage { master_xpriv, master_xpub };
master_xpriv,
master_xpub,
};
let fingerprint = wallet.master_fingerprint(); let fingerprint = wallet.master_fingerprint();
Ok((wallet, fingerprint, account_0_xpub, input_xpub)) Ok((wallet, fingerprint, account_0_xpub, input_xpub))
} }
/// Returns the fingerprint for the master extended public key. /// Returns the fingerprint for the master extended public key.
fn master_fingerprint(&self) -> Fingerprint { fn master_fingerprint(&self) -> Fingerprint { self.master_xpub.fingerprint() }
self.master_xpub.fingerprint()
}
/// Signs `psbt` with this signer. /// Signs `psbt` with this signer.
fn sign_psbt<C: Signing>(&self, secp: &Secp256k1<C>, mut psbt: Psbt) -> Result<Psbt> { fn sign_psbt<C: Signing>(&self, secp: &Secp256k1<C>, mut psbt: Psbt) -> Result<Psbt> {
@ -146,7 +148,11 @@ impl ColdStorage {
} }
/// Returns the private key required to sign `input` if we have it. /// Returns the private key required to sign `input` if we have it.
fn private_key_to_sign<C: Signing>(&self, secp: &Secp256k1<C>, input: &Input) -> Result<PrivateKey> { fn private_key_to_sign<C: Signing>(
&self,
secp: &Secp256k1<C>,
input: &Input,
) -> Result<PrivateKey> {
match input.bip32_derivation.iter().next() { match input.bip32_derivation.iter().next() {
Some((pk, (fingerprint, path))) => { Some((pk, (fingerprint, path))) => {
if *fingerprint != self.master_fingerprint() { if *fingerprint != self.master_fingerprint() {
@ -159,8 +165,7 @@ impl ColdStorage {
} }
Ok(sk) Ok(sk)
}
},
None => Err(Error::MissingBip32Derivation), None => Err(Error::MissingBip32Derivation),
} }
} }
@ -184,7 +189,11 @@ impl WatchOnly {
/// ///
/// The reason for importing the `input_xpub` is so one can use bitcoind to grab a valid input /// The reason for importing the `input_xpub` is so one can use bitcoind to grab a valid input
/// to verify the workflow presented in this file. /// to verify the workflow presented in this file.
fn new(account_0_xpub: ExtendedPubKey, input_xpub: ExtendedPubKey, master_fingerprint: Fingerprint) -> Self { fn new(
account_0_xpub: ExtendedPubKey,
input_xpub: ExtendedPubKey,
master_fingerprint: Fingerprint,
) -> Self {
WatchOnly { account_0_xpub, input_xpub, master_fingerprint } WatchOnly { account_0_xpub, input_xpub, master_fingerprint }
} }
@ -199,26 +208,21 @@ impl WatchOnly {
let tx = Transaction { let tx = Transaction {
version: 2, version: 2,
lock_time: 0, lock_time: 0,
input: vec![ input: vec![TxIn {
TxIn { previous_output: OutPoint {
previous_output: OutPoint { txid: Txid::from_hex(INPUT_UTXO_TXID)?,
txid: Txid::from_hex(INPUT_UTXO_TXID)?, vout: INPUT_UTXO_VOUT,
vout: INPUT_UTXO_VOUT,
},
script_sig: Script::new(),
sequence: Sequence::MAX, // Disable LockTime and RBF.
witness: Witness::default(),
}, },
], script_sig: Script::new(),
sequence: Sequence::MAX, // Disable LockTime and RBF.
witness: Witness::default(),
}],
output: vec![ output: vec![
TxOut { TxOut { value: to_amount.to_sat(), script_pubkey: to_address.script_pubkey() },
value: to_amount.to_sat(),
script_pubkey: to_address.script_pubkey(),
},
TxOut { TxOut {
value: change_amount.to_sat(), value: change_amount.to_sat(),
script_pubkey: change_address.script_pubkey(), script_pubkey: change_address.script_pubkey(),
} },
], ],
}; };
@ -281,7 +285,10 @@ impl WatchOnly {
/// "m/84h/0h/0h/1/0"). A real wallet would have access to the chain so could determine if an /// "m/84h/0h/0h/1/0"). A real wallet would have access to the chain so could determine if an
/// address has been used or not. We ignore this detail and just re-use the first change address /// address has been used or not. We ignore this detail and just re-use the first change address
/// without loss of generality. /// without loss of generality.
fn change_address<C: Verification>(&self, secp: &Secp256k1<C>) -> Result<(PublicKey, Address, DerivationPath)> { fn change_address<C: Verification>(
&self,
secp: &Secp256k1<C>,
) -> Result<(PublicKey, Address, DerivationPath)> {
let path = vec![ChildNumber::from_normal_idx(1)?, ChildNumber::from_normal_idx(0)?]; let path = vec![ChildNumber::from_normal_idx(1)?, ChildNumber::from_normal_idx(0)?];
let derived = self.account_0_xpub.derive_pub(secp, &path)?; let derived = self.account_0_xpub.derive_pub(secp, &path)?;
@ -299,13 +306,11 @@ fn input_derivation_path() -> Result<DerivationPath> {
} }
fn previous_output() -> TxOut { fn previous_output() -> TxOut {
let script_pubkey = Script::from_hex(INPUT_UTXO_SCRIPT_PUBKEY).expect("failed to parse input utxo scriptPubkey"); let script_pubkey = Script::from_hex(INPUT_UTXO_SCRIPT_PUBKEY)
.expect("failed to parse input utxo scriptPubkey");
let amount = Amount::from_str(INPUT_UTXO_VALUE).expect("failed to parse input utxo value"); let amount = Amount::from_str(INPUT_UTXO_VALUE).expect("failed to parse input utxo value");
TxOut { TxOut { value: amount.to_sat(), script_pubkey }
value: amount.to_sat(),
script_pubkey,
}
} }
#[derive(Clone, Debug, PartialEq, Eq)] #[derive(Clone, Debug, PartialEq, Eq)]
@ -335,51 +340,35 @@ enum Error {
} }
impl std::error::Error for Error { impl std::error::Error for Error {
fn source(&self) -> Option<&(dyn std::error::Error + 'static)> { fn source(&self) -> Option<&(dyn std::error::Error + 'static)> { None }
None
}
} }
impl fmt::Display for Error { impl fmt::Display for Error {
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { write!(f, "{:?}", self) }
write!(f, "{:?}", self)
}
} }
impl From<bip32::Error> for Error { impl From<bip32::Error> for Error {
fn from(e: bip32::Error) -> Error { fn from(e: bip32::Error) -> Error { Error::Bip32(e) }
Error::Bip32(e)
}
} }
impl From<psbt::Error> for Error { impl From<psbt::Error> for Error {
fn from(e: psbt::Error) -> Error { fn from(e: psbt::Error) -> Error { Error::Psbt(e) }
Error::Psbt(e)
}
} }
impl From<SighashError> for Error { impl From<SighashError> for Error {
fn from(e: SighashError) -> Error { fn from(e: SighashError) -> Error { Error::PsbtSighash(e) }
Error::PsbtSighash(e)
}
} }
impl From<hex::Error> for Error { impl From<hex::Error> for Error {
fn from(e: hex::Error) -> Error { fn from(e: hex::Error) -> Error { Error::Hex(e) }
Error::Hex(e)
}
} }
impl From<address::Error> for Error { impl From<address::Error> for Error {
fn from(e: address::Error) -> Error { fn from(e: address::Error) -> Error { Error::Address(e) }
Error::Address(e)
}
} }
impl From<ParseAmountError> for Error { impl From<ParseAmountError> for Error {
fn from(e: ParseAmountError) -> Error { fn from(e: ParseAmountError) -> Error { Error::ParseAmount(e) }
Error::ParseAmount(e)
}
} }
/// This module implements signing a PSBT. It is based on code in `rust-miniscript` with a bit of a /// This module implements signing a PSBT. It is based on code in `rust-miniscript` with a bit of a
@ -392,15 +381,22 @@ mod psbt_sign {
use std::fmt; use std::fmt;
use std::ops::Deref; use std::ops::Deref;
use bitcoin::{EcdsaSig, EcdsaSighashType, EcdsaSigError, PrivateKey, SchnorrSighashType, Script, Transaction, TxOut};
use bitcoin::psbt::{Input, Prevouts, Psbt, PsbtSighashType}; use bitcoin::psbt::{Input, Prevouts, Psbt, PsbtSighashType};
use bitcoin::util::sighash::{self, SighashCache}; use bitcoin::util::sighash::{self, SighashCache};
use bitcoin::util::taproot::TapLeafHash; use bitcoin::util::taproot::TapLeafHash;
use bitcoin::{
use secp256k1::{Message, Signing, Secp256k1}; EcdsaSig, EcdsaSigError, EcdsaSighashType, PrivateKey, SchnorrSighashType, Script,
Transaction, TxOut,
};
use secp256k1::{Message, Secp256k1, Signing};
/// Signs the input at `input_index` with private key `sk`. /// Signs the input at `input_index` with private key `sk`.
pub fn sign<C: Signing>(psbt: &mut Psbt, sk: &PrivateKey, input_index: usize, secp: &Secp256k1<C>) -> Result<(), SighashError> { pub fn sign<C: Signing>(
psbt: &mut Psbt,
sk: &PrivateKey,
input_index: usize,
secp: &Secp256k1<C>,
) -> Result<(), SighashError> {
check_index_is_within_bounds(psbt, input_index)?; check_index_is_within_bounds(psbt, input_index)?;
let mut cache = SighashCache::new(&psbt.unsigned_tx); let mut cache = SighashCache::new(&psbt.unsigned_tx);
@ -413,16 +409,13 @@ mod psbt_sign {
final_signature.push(sighash_ty.to_u32() as u8); final_signature.push(sighash_ty.to_u32() as u8);
let pk = sk.public_key(secp); let pk = sk.public_key(secp);
psbt.inputs[input_index] psbt.inputs[input_index].partial_sigs.insert(pk, EcdsaSig::from_slice(&final_signature)?);
.partial_sigs
.insert(pk, EcdsaSig::from_slice(&final_signature)?);
Ok(()) Ok(())
} }
/// Returns the sighash message to sign along with the sighash type. /// Returns the sighash message to sign along with the sighash type.
fn sighash<T: Deref<Target=Transaction>>( fn sighash<T: Deref<Target = Transaction>>(
psbt: &Psbt, psbt: &Psbt,
input_index: usize, input_index: usize,
cache: &mut SighashCache<T>, cache: &mut SighashCache<T>,
@ -450,12 +443,10 @@ mod psbt_sign {
let is_wsh = script.is_v0_p2wsh(); let is_wsh = script.is_v0_p2wsh();
let is_nested_wpkh = script.is_p2sh() let is_nested_wpkh = script.is_p2sh()
&& input.redeem_script.as_ref() && input.redeem_script.as_ref().map(|s| s.is_v0_p2wpkh()).unwrap_or(false);
.map(|s| s.is_v0_p2wpkh()).unwrap_or(false);
let is_nested_wsh = script.is_p2sh() let is_nested_wsh = script.is_p2sh()
&& input.redeem_script.as_ref() && input.redeem_script.as_ref().map(|x| x.is_v0_p2wsh()).unwrap_or(false);
.map(|x| x.is_v0_p2wsh()).unwrap_or(false);
let is_segwit = is_wpkh || is_wsh || is_nested_wpkh || is_nested_wsh; let is_segwit = is_wpkh || is_wsh || is_nested_wpkh || is_nested_wsh;
@ -468,9 +459,9 @@ mod psbt_sign {
.ok_or(SighashError::NotWpkh)? .ok_or(SighashError::NotWpkh)?
}; };
cache.segwit_signature_hash(input_index, &script_code, utxo.value, hash_ty)? cache.segwit_signature_hash(input_index, &script_code, utxo.value, hash_ty)?
} else { } else {
let script_code = input.witness_script.as_ref().ok_or(SighashError::MissingWitnessScript)?; let script_code =
input.witness_script.as_ref().ok_or(SighashError::MissingWitnessScript)?;
cache.segwit_signature_hash(input_index, script_code, utxo.value, hash_ty)? cache.segwit_signature_hash(input_index, script_code, utxo.value, hash_ty)?
} }
} else { } else {
@ -528,7 +519,7 @@ mod psbt_sign {
} }
/// Returns the sighash message and sighash type for this `input`. /// Returns the sighash message and sighash type for this `input`.
fn taproot_sighash<T: Deref<Target=Transaction>>( fn taproot_sighash<T: Deref<Target = Transaction>>(
input: &Input, input: &Input,
prevouts: Vec<&TxOut>, prevouts: Vec<&TxOut>,
input_index: usize, input_index: usize,
@ -546,16 +537,16 @@ mod psbt_sign {
.map_err(|_e| SighashError::InvalidSighashType)?; .map_err(|_e| SighashError::InvalidSighashType)?;
let sighash = match tapleaf_hash { let sighash = match tapleaf_hash {
Some(leaf_hash) => { Some(leaf_hash) => cache.taproot_script_spend_signature_hash(
cache.taproot_script_spend_signature_hash(input_index, &prevouts, leaf_hash, hash_ty)? input_index,
} &prevouts,
None => { leaf_hash,
cache.taproot_key_spend_signature_hash(input_index, &prevouts, hash_ty)? hash_ty,
} )?,
None => cache.taproot_key_spend_signature_hash(input_index, &prevouts, hash_ty)?,
}; };
let msg = Message::from_slice(&sighash).expect("sighashes are 32 bytes"); let msg = Message::from_slice(&sighash).expect("sighashes are 32 bytes");
Ok((msg, hash_ty.into())) Ok((msg, hash_ty.into()))
} }
/// Errors encountered while calculating the sighash message. /// Errors encountered while calculating the sighash message.
@ -598,15 +589,11 @@ mod psbt_sign {
} }
impl From<sighash::Error> for SighashError { impl From<sighash::Error> for SighashError {
fn from(e: sighash::Error) -> Self { fn from(e: sighash::Error) -> Self { SighashError::SighashComputation(e) }
SighashError::SighashComputation(e)
}
} }
impl From<EcdsaSigError> for SighashError { impl From<EcdsaSigError> for SighashError {
fn from(e: EcdsaSigError) -> Self { fn from(e: EcdsaSigError) -> Self { SighashError::EcdsaSig(e) }
SighashError::EcdsaSig(e)
}
} }
#[cfg(feature = "std")] #[cfg(feature = "std")]
@ -616,11 +603,11 @@ mod psbt_sign {
match self { match self {
IndexOutOfBounds(_, _) IndexOutOfBounds(_, _)
| MissingSpendUtxo | MissingSpendUtxo
| MissingWitnessScript | MissingWitnessScript
| MissingRedeemScript | MissingRedeemScript
| InvalidSighashType | InvalidSighashType
| NotWpkh => None, | NotWpkh => None,
SighashComputation(e) => Some(e), SighashComputation(e) => Some(e),
EcdsaSig(e) => Some(e), EcdsaSig(e) => Some(e),
} }