#[cfg(feature = "alloc")]
use alloc::{
string::{String, ToString},
vec::Vec,
};
use core::marker::PhantomData;
use bitcoin::{PrivateKey, bip32::Xpriv, key::CompressedPublicKey, secp256k1::Secp256k1};
use kobe_core::{Derive, DerivedAccount, Wallet};
use zeroize::Zeroizing;
use crate::address::create_address;
use crate::{AddressType, DerivationPath, Error, Network};
#[derive(Debug)]
pub struct Deriver<'a> {
master_key: Xpriv,
secp: Secp256k1<bitcoin::secp256k1::All>,
network: Network,
_wallet: PhantomData<&'a Wallet>,
}
#[derive(Debug, Clone)]
#[non_exhaustive]
pub struct DerivedAddress {
pub path: DerivationPath,
pub private_key_hex: Zeroizing<String>,
pub private_key_wif: Zeroizing<String>,
pub public_key_hex: String,
pub address: String,
pub address_type: AddressType,
}
impl<'a> Deriver<'a> {
#[inline]
pub fn new(wallet: &'a Wallet, network: Network) -> Result<Self, Error> {
let master_key = Xpriv::new_master(network.to_bitcoin_network(), wallet.seed())?;
Ok(Self {
master_key,
secp: Secp256k1::new(),
network,
_wallet: PhantomData,
})
}
#[inline]
pub fn derive(&self, index: u32) -> Result<DerivedAddress, Error> {
self.derive_with(AddressType::P2wpkh, index)
}
#[inline]
pub fn derive_with(
&self,
address_type: AddressType,
index: u32,
) -> Result<DerivedAddress, Error> {
let path = DerivationPath::bip_standard(address_type, self.network, 0, false, index)?;
self.derive_path(&path, address_type)
}
#[inline]
pub fn derive_many(&self, start: u32, count: u32) -> Result<Vec<DerivedAddress>, Error> {
self.derive_many_with(AddressType::P2wpkh, start, count)
}
pub fn derive_many_with(
&self,
address_type: AddressType,
start: u32,
count: u32,
) -> Result<Vec<DerivedAddress>, Error> {
let end = start.checked_add(count).ok_or_else(|| {
Error::InvalidDerivationPath("index overflow: start + count exceeds u32::MAX".into())
})?;
(start..end)
.map(|index| self.derive_with(address_type, index))
.collect()
}
pub fn derive_path(
&self,
path: &DerivationPath,
address_type: AddressType,
) -> Result<DerivedAddress, Error> {
let derived = self.master_key.derive_priv(&self.secp, path.inner())?;
let private_key = PrivateKey::new(derived.private_key, self.network.to_bitcoin_network());
let public_key = CompressedPublicKey::from_private_key(&self.secp, &private_key)
.map_err(|_| Error::InvalidPrivateKey)?;
let address = create_address(&public_key, self.network, address_type);
let private_key_bytes = Zeroizing::new(derived.private_key.secret_bytes());
Ok(DerivedAddress {
path: path.clone(),
private_key_hex: Zeroizing::new(hex::encode(private_key_bytes)),
private_key_wif: Zeroizing::new(private_key.to_wif()),
public_key_hex: public_key.to_string(),
address: address.to_string(),
address_type,
})
}
#[must_use]
pub const fn network(&self) -> Network {
self.network
}
fn derive_account_at_path(&self, path_str: &str) -> Result<DerivedAccount, Error> {
let path = DerivationPath::from_path_str(path_str)?;
let da = self.derive_path(&path, AddressType::P2wpkh)?;
Ok(DerivedAccount::new(
da.path.to_string(),
da.private_key_hex,
da.public_key_hex,
da.address,
))
}
}
impl Derive for Deriver<'_> {
type Error = Error;
fn derive(&self, index: u32) -> Result<DerivedAccount, Error> {
let da = self.derive_with(AddressType::P2wpkh, index)?;
Ok(DerivedAccount::new(
da.path.to_string(),
da.private_key_hex,
da.public_key_hex,
da.address,
))
}
fn derive_path(&self, path: &str) -> Result<DerivedAccount, Error> {
self.derive_account_at_path(path)
}
}
#[cfg(test)]
#[allow(clippy::unwrap_used)]
mod tests {
use super::*;
const TEST_MNEMONIC: &str = "abandon abandon abandon abandon abandon abandon abandon abandon abandon abandon abandon about";
fn test_wallet() -> Wallet {
Wallet::from_mnemonic(TEST_MNEMONIC, None).unwrap()
}
#[test]
fn kat_p2wpkh() {
let wallet = test_wallet();
let deriver = Deriver::new(&wallet, Network::Mainnet).unwrap();
let addr = deriver.derive_with(AddressType::P2wpkh, 0).unwrap();
assert_eq!(addr.address, "bc1qcr8te4kr609gcawutmrza0j4xv80jy8z306fyu");
assert_eq!(addr.path.to_string(), "m/84'/0'/0'/0/0");
}
#[test]
fn kat_p2pkh() {
let wallet = test_wallet();
let deriver = Deriver::new(&wallet, Network::Mainnet).unwrap();
let addr = deriver.derive_with(AddressType::P2pkh, 0).unwrap();
assert_eq!(addr.address, "1LqBGSKuX5yYUonjxT5qGfpUsXKYYWeabA");
assert_eq!(addr.path.to_string(), "m/44'/0'/0'/0/0");
}
#[test]
fn kat_p2sh_p2wpkh() {
let wallet = test_wallet();
let deriver = Deriver::new(&wallet, Network::Mainnet).unwrap();
let addr = deriver.derive_with(AddressType::P2shP2wpkh, 0).unwrap();
assert_eq!(addr.address, "37VucYSaXLCAsxYyAPfbSi9eh4iEcbShgf");
assert_eq!(addr.path.to_string(), "m/49'/0'/0'/0/0");
}
#[test]
fn p2tr_prefix() {
let wallet = test_wallet();
let deriver = Deriver::new(&wallet, Network::Mainnet).unwrap();
let addr = deriver.derive_with(AddressType::P2tr, 0).unwrap();
assert!(addr.address.starts_with("bc1p"));
assert_eq!(addr.path.to_string(), "m/86'/0'/0'/0/0");
}
#[test]
fn derive_default_is_p2wpkh() {
let wallet = test_wallet();
let deriver = Deriver::new(&wallet, Network::Mainnet).unwrap();
let def = deriver.derive(0).unwrap();
let explicit = deriver.derive_with(AddressType::P2wpkh, 0).unwrap();
assert_eq!(def.address, explicit.address);
}
#[test]
fn testnet_prefix() {
let wallet = test_wallet();
let deriver = Deriver::new(&wallet, Network::Testnet).unwrap();
let addr = deriver.derive(0).unwrap();
assert!(addr.address.starts_with("tb1q"));
assert_eq!(addr.path.to_string(), "m/84'/1'/0'/0/0");
}
#[test]
fn derive_many_unique() {
let wallet = test_wallet();
let deriver = Deriver::new(&wallet, Network::Mainnet).unwrap();
let addrs = deriver.derive_many(0, 5).unwrap();
assert_eq!(addrs.len(), 5);
let set: std::collections::HashSet<_> = addrs.iter().map(|a| &a.address).collect();
assert_eq!(set.len(), 5);
}
#[test]
fn passphrase_changes_addresses() {
let wallet1 = Wallet::from_mnemonic(TEST_MNEMONIC, None).unwrap();
let wallet2 = Wallet::from_mnemonic(TEST_MNEMONIC, Some("password")).unwrap();
let d1 = Deriver::new(&wallet1, Network::Mainnet).unwrap();
let d2 = Deriver::new(&wallet2, Network::Mainnet).unwrap();
assert_ne!(d1.derive(0).unwrap().address, d2.derive(0).unwrap().address);
}
}