#![deny(rustdoc::broken_intra_doc_links)]
#![deny(rustdoc::private_intra_doc_links)]
#![deny(missing_docs)]
#![deny(non_upper_case_globals)]
#![deny(non_camel_case_types)]
#![deny(non_snake_case)]
#![deny(unused_mut)]
#![cfg_attr(docsrs, feature(doc_auto_cfg))]
#![cfg_attr(all(not(feature = "std"), not(test)), no_std)]
extern crate alloc;
extern crate bech32;
#[cfg(any(test, feature = "std"))]
extern crate core;
extern crate lightning_types;
#[cfg(feature = "serde")]
extern crate serde;
#[cfg(feature = "std")]
use std::time::SystemTime;
use bech32::primitives::decode::CheckedHrpstringError;
use bech32::Fe32;
use bitcoin::hashes::{sha256, Hash};
use bitcoin::{Address, Network, PubkeyHash, ScriptHash, WitnessProgram, WitnessVersion};
use lightning_types::features::Bolt11InvoiceFeatures;
use bitcoin::secp256k1::ecdsa::RecoverableSignature;
use bitcoin::secp256k1::PublicKey;
use bitcoin::secp256k1::{Message, Secp256k1};
use alloc::boxed::Box;
use alloc::string;
use core::cmp::Ordering;
use core::fmt::{self, Display, Formatter};
use core::iter::FilterMap;
use core::num::ParseIntError;
use core::ops::Deref;
use core::slice::Iter;
use core::str::FromStr;
use core::time::Duration;
#[cfg(feature = "serde")]
use serde::{de::Error, Deserialize, Deserializer, Serialize, Serializer};
#[doc(no_inline)]
pub use lightning_types::payment::PaymentSecret;
#[doc(no_inline)]
pub use lightning_types::routing::{RouteHint, RouteHintHop, RoutingFees};
use lightning_types::string::UntrustedString;
mod de;
mod ser;
mod tb;
#[cfg(test)]
mod test_ser_de;
#[allow(unused_imports)]
mod prelude {
pub use alloc::{string::String, vec, vec::Vec};
pub use alloc::string::ToString;
}
use crate::prelude::*;
#[cfg(fuzzing)]
pub use crate::de::FromBase32;
#[cfg(not(fuzzing))]
use crate::de::FromBase32;
#[cfg(fuzzing)]
pub use crate::ser::Base32Iterable;
#[cfg(not(fuzzing))]
use crate::ser::Base32Iterable;
#[allow(missing_docs)]
#[derive(PartialEq, Eq, Debug, Clone)]
pub enum Bolt11ParseError {
Bech32Error(CheckedHrpstringError),
ParseAmountError(ParseIntError),
MalformedSignature(bitcoin::secp256k1::Error),
BadPrefix,
UnknownCurrency,
UnknownSiPrefix,
MalformedHRP,
TooShortDataPart,
UnexpectedEndOfTaggedFields,
DescriptionDecodeError(string::FromUtf8Error),
PaddingError,
IntegerOverflowError,
InvalidSegWitProgramLength,
InvalidPubKeyHashLength,
InvalidScriptHashLength,
InvalidRecoveryId,
InvalidSliceLength(usize, usize, &'static str),
Skip,
}
#[derive(PartialEq, Eq, Debug, Clone)]
pub enum ParseOrSemanticError {
ParseError(Bolt11ParseError),
SemanticError(crate::Bolt11SemanticError),
}
const TIMESTAMP_BITS: usize = 35;
pub const MAX_TIMESTAMP: u64 = (1 << TIMESTAMP_BITS) - 1;
pub const DEFAULT_EXPIRY_TIME: u64 = 3600;
pub const DEFAULT_MIN_FINAL_CLTV_EXPIRY_DELTA: u64 = 18;
#[derive(Eq, PartialEq, Debug, Clone)]
pub struct InvoiceBuilder<
D: tb::Bool,
H: tb::Bool,
T: tb::Bool,
C: tb::Bool,
S: tb::Bool,
M: tb::Bool,
> {
currency: Currency,
amount: Option<u64>,
si_prefix: Option<SiPrefix>,
timestamp: Option<PositiveTimestamp>,
tagged_fields: Vec<TaggedField>,
error: Option<CreationError>,
phantom_d: core::marker::PhantomData<D>,
phantom_h: core::marker::PhantomData<H>,
phantom_t: core::marker::PhantomData<T>,
phantom_c: core::marker::PhantomData<C>,
phantom_s: core::marker::PhantomData<S>,
phantom_m: core::marker::PhantomData<M>,
}
#[derive(Eq, PartialEq, Debug, Clone, Hash, Ord, PartialOrd)]
pub struct Bolt11Invoice {
signed_invoice: SignedRawBolt11Invoice,
}
#[derive(Eq, PartialEq, Debug, Clone, Ord, PartialOrd)]
pub enum Bolt11InvoiceDescription {
Direct(Description),
Hash(Sha256),
}
impl Display for Bolt11InvoiceDescription {
fn fmt(&self, f: &mut Formatter<'_>) -> fmt::Result {
match self {
Bolt11InvoiceDescription::Direct(desc) => write!(f, "{}", desc.0),
Bolt11InvoiceDescription::Hash(hash) => write!(f, "{}", hash.0),
}
}
}
#[derive(Eq, PartialEq, Debug, Clone, Copy, Ord, PartialOrd)]
pub enum Bolt11InvoiceDescriptionRef<'f> {
Direct(&'f Description),
Hash(&'f Sha256),
}
impl<'f> Display for Bolt11InvoiceDescriptionRef<'f> {
fn fmt(&self, f: &mut Formatter<'_>) -> fmt::Result {
match self {
Bolt11InvoiceDescriptionRef::Direct(desc) => write!(f, "{}", desc.0),
Bolt11InvoiceDescriptionRef::Hash(hash) => write!(f, "{}", hash.0),
}
}
}
#[derive(Eq, PartialEq, Debug, Clone, Hash, Ord, PartialOrd)]
pub struct SignedRawBolt11Invoice {
raw_invoice: RawBolt11Invoice,
hash: [u8; 32],
signature: Bolt11InvoiceSignature,
}
#[derive(Eq, PartialEq, Debug, Clone, Hash, Ord, PartialOrd)]
pub struct RawBolt11Invoice {
pub hrp: RawHrp,
pub data: RawDataPart,
}
#[derive(Eq, PartialEq, Debug, Clone, Hash, Ord, PartialOrd)]
pub struct RawHrp {
pub currency: Currency,
pub raw_amount: Option<u64>,
pub si_prefix: Option<SiPrefix>,
}
impl RawHrp {
pub fn to_hrp(&self) -> bech32::Hrp {
let hrp_str = self.to_string();
let s = core::str::from_utf8(&hrp_str.as_bytes()).expect("HRP bytes should be ASCII");
debug_assert!(bech32::Hrp::parse(s).is_ok(), "We should always build BIP 173-valid HRPs");
bech32::Hrp::parse_unchecked(s)
}
}
#[derive(Eq, PartialEq, Debug, Clone, Hash, Ord, PartialOrd)]
pub struct RawDataPart {
pub timestamp: PositiveTimestamp,
pub tagged_fields: Vec<RawTaggedField>,
}
#[derive(Eq, PartialEq, Debug, Clone, Hash, Ord, PartialOrd)]
pub struct PositiveTimestamp(Duration);
#[derive(Eq, PartialEq, Debug, Clone, Copy, Hash, Ord, PartialOrd)]
pub enum SiPrefix {
Milli,
Micro,
Nano,
Pico,
}
impl SiPrefix {
pub fn multiplier(&self) -> u64 {
match *self {
SiPrefix::Milli => 1_000_000_000,
SiPrefix::Micro => 1_000_000,
SiPrefix::Nano => 1_000,
SiPrefix::Pico => 1,
}
}
pub fn values_desc() -> &'static [SiPrefix] {
use crate::SiPrefix::*;
static VALUES: [SiPrefix; 4] = [Milli, Micro, Nano, Pico];
&VALUES
}
}
#[derive(Clone, Debug, Hash, Eq, PartialEq, Ord, PartialOrd)]
pub enum Currency {
Bitcoin,
BitcoinTestnet,
Regtest,
Simnet,
Signet,
}
impl From<Network> for Currency {
fn from(network: Network) -> Self {
match network {
Network::Bitcoin => Currency::Bitcoin,
Network::Testnet => Currency::BitcoinTestnet,
Network::Regtest => Currency::Regtest,
Network::Signet => Currency::Signet,
_ => {
debug_assert!(false, "Need to handle new rust-bitcoin network type");
Currency::Regtest
},
}
}
}
impl From<Currency> for Network {
fn from(currency: Currency) -> Self {
match currency {
Currency::Bitcoin => Network::Bitcoin,
Currency::BitcoinTestnet => Network::Testnet,
Currency::Regtest => Network::Regtest,
Currency::Simnet => Network::Regtest,
Currency::Signet => Network::Signet,
}
}
}
#[derive(Clone, Debug, Hash, Eq, PartialEq)]
pub enum RawTaggedField {
KnownSemantics(TaggedField),
UnknownSemantics(Vec<Fe32>),
}
impl PartialOrd for RawTaggedField {
fn partial_cmp(&self, other: &Self) -> Option<core::cmp::Ordering> {
Some(self.cmp(other))
}
}
impl Ord for RawTaggedField {
fn cmp(&self, other: &Self) -> core::cmp::Ordering {
match (self, other) {
(RawTaggedField::KnownSemantics(ref a), RawTaggedField::KnownSemantics(ref b)) => {
a.cmp(b)
},
(RawTaggedField::UnknownSemantics(ref a), RawTaggedField::UnknownSemantics(ref b)) => {
a.iter().map(|a| a.to_u8()).cmp(b.iter().map(|b| b.to_u8()))
},
(RawTaggedField::KnownSemantics(..), RawTaggedField::UnknownSemantics(..)) => {
core::cmp::Ordering::Less
},
(RawTaggedField::UnknownSemantics(..), RawTaggedField::KnownSemantics(..)) => {
core::cmp::Ordering::Greater
},
}
}
}
#[allow(missing_docs)]
#[derive(Clone, Debug, Hash, Eq, PartialEq, Ord, PartialOrd)]
pub enum TaggedField {
PaymentHash(Sha256),
Description(Description),
PayeePubKey(PayeePubKey),
DescriptionHash(Sha256),
ExpiryTime(ExpiryTime),
MinFinalCltvExpiryDelta(MinFinalCltvExpiryDelta),
Fallback(Fallback),
PrivateRoute(PrivateRoute),
PaymentSecret(PaymentSecret),
PaymentMetadata(Vec<u8>),
Features(Bolt11InvoiceFeatures),
}
#[derive(Clone, Debug, Hash, Eq, PartialEq, Ord, PartialOrd)]
pub struct Sha256(
pub sha256::Hash,
);
impl Sha256 {
#[cfg(c_bindings)]
pub fn from_bytes(bytes: &[u8; 32]) -> Self {
Self(sha256::Hash::from_slice(bytes).expect("from_slice only fails if len is not 32"))
}
}
#[derive(Clone, Debug, Hash, Eq, PartialEq, Ord, PartialOrd, Default)]
pub struct Description(UntrustedString);
#[derive(Clone, Debug, Hash, Eq, PartialEq, Ord, PartialOrd)]
pub struct PayeePubKey(pub PublicKey);
#[derive(Clone, Debug, Hash, Eq, PartialEq, Ord, PartialOrd)]
pub struct ExpiryTime(Duration);
#[derive(Clone, Debug, Hash, Eq, PartialEq, Ord, PartialOrd)]
pub struct MinFinalCltvExpiryDelta(pub u64);
#[allow(missing_docs)]
#[derive(Clone, Debug, Hash, Eq, PartialEq, Ord, PartialOrd)]
pub enum Fallback {
SegWitProgram { version: WitnessVersion, program: Vec<u8> },
PubKeyHash(PubkeyHash),
ScriptHash(ScriptHash),
}
#[derive(Clone, Debug, Hash, Eq, PartialEq)]
pub struct Bolt11InvoiceSignature(pub RecoverableSignature);
impl PartialOrd for Bolt11InvoiceSignature {
fn partial_cmp(&self, other: &Self) -> Option<Ordering> {
Some(self.cmp(other))
}
}
impl Ord for Bolt11InvoiceSignature {
fn cmp(&self, other: &Self) -> Ordering {
self.0.serialize_compact().1.cmp(&other.0.serialize_compact().1)
}
}
#[derive(Clone, Debug, Hash, Eq, PartialEq, Ord, PartialOrd)]
pub struct PrivateRoute(RouteHint);
#[allow(missing_docs)]
pub mod constants {
pub const TAG_PAYMENT_HASH: u8 = 1;
pub const TAG_DESCRIPTION: u8 = 13;
pub const TAG_PAYEE_PUB_KEY: u8 = 19;
pub const TAG_DESCRIPTION_HASH: u8 = 23;
pub const TAG_EXPIRY_TIME: u8 = 6;
pub const TAG_MIN_FINAL_CLTV_EXPIRY_DELTA: u8 = 24;
pub const TAG_FALLBACK: u8 = 9;
pub const TAG_PRIVATE_ROUTE: u8 = 3;
pub const TAG_PAYMENT_SECRET: u8 = 16;
pub const TAG_PAYMENT_METADATA: u8 = 27;
pub const TAG_FEATURES: u8 = 5;
}
impl InvoiceBuilder<tb::False, tb::False, tb::False, tb::False, tb::False, tb::False> {
pub fn new(currency: Currency) -> Self {
InvoiceBuilder {
currency,
amount: None,
si_prefix: None,
timestamp: None,
tagged_fields: Vec::with_capacity(8),
error: None,
phantom_d: core::marker::PhantomData,
phantom_h: core::marker::PhantomData,
phantom_t: core::marker::PhantomData,
phantom_c: core::marker::PhantomData,
phantom_s: core::marker::PhantomData,
phantom_m: core::marker::PhantomData,
}
}
}
impl<D: tb::Bool, H: tb::Bool, T: tb::Bool, C: tb::Bool, S: tb::Bool, M: tb::Bool>
InvoiceBuilder<D, H, T, C, S, M>
{
fn set_flags<
DN: tb::Bool,
HN: tb::Bool,
TN: tb::Bool,
CN: tb::Bool,
SN: tb::Bool,
MN: tb::Bool,
>(
self,
) -> InvoiceBuilder<DN, HN, TN, CN, SN, MN> {
InvoiceBuilder::<DN, HN, TN, CN, SN, MN> {
currency: self.currency,
amount: self.amount,
si_prefix: self.si_prefix,
timestamp: self.timestamp,
tagged_fields: self.tagged_fields,
error: self.error,
phantom_d: core::marker::PhantomData,
phantom_h: core::marker::PhantomData,
phantom_t: core::marker::PhantomData,
phantom_c: core::marker::PhantomData,
phantom_s: core::marker::PhantomData,
phantom_m: core::marker::PhantomData,
}
}
pub fn amount_milli_satoshis(mut self, amount_msat: u64) -> Self {
let amount = match amount_msat.checked_mul(10) {
Some(amt) => amt,
None => {
self.error = Some(CreationError::InvalidAmount);
return self;
},
};
let biggest_possible_si_prefix = SiPrefix::values_desc()
.iter()
.find(|prefix| amount % prefix.multiplier() == 0)
.expect("Pico should always match");
self.amount = Some(amount / biggest_possible_si_prefix.multiplier());
self.si_prefix = Some(*biggest_possible_si_prefix);
self
}
pub fn payee_pub_key(mut self, pub_key: PublicKey) -> Self {
self.tagged_fields.push(TaggedField::PayeePubKey(PayeePubKey(pub_key)));
self
}
pub fn expiry_time(mut self, expiry_time: Duration) -> Self {
self.tagged_fields.push(TaggedField::ExpiryTime(ExpiryTime::from_duration(expiry_time)));
self
}
pub fn fallback(mut self, fallback: Fallback) -> Self {
self.tagged_fields.push(TaggedField::Fallback(fallback));
self
}
pub fn private_route(mut self, hint: RouteHint) -> Self {
match PrivateRoute::new(hint) {
Ok(r) => self.tagged_fields.push(TaggedField::PrivateRoute(r)),
Err(e) => self.error = Some(e),
}
self
}
}
impl<D: tb::Bool, H: tb::Bool, C: tb::Bool, S: tb::Bool, M: tb::Bool>
InvoiceBuilder<D, H, tb::True, C, S, M>
{
pub fn build_raw(self) -> Result<RawBolt11Invoice, CreationError> {
if let Some(e) = self.error {
return Err(e);
}
let hrp =
RawHrp { currency: self.currency, raw_amount: self.amount, si_prefix: self.si_prefix };
let timestamp = self.timestamp.expect("ensured to be Some(t) by type T");
let tagged_fields = self
.tagged_fields
.into_iter()
.map(|tf| RawTaggedField::KnownSemantics(tf))
.collect::<Vec<_>>();
let data = RawDataPart { timestamp, tagged_fields };
Ok(RawBolt11Invoice { hrp, data })
}
}
impl<H: tb::Bool, T: tb::Bool, C: tb::Bool, S: tb::Bool, M: tb::Bool>
InvoiceBuilder<tb::False, H, T, C, S, M>
{
pub fn description(mut self, description: String) -> InvoiceBuilder<tb::True, H, T, C, S, M> {
match Description::new(description) {
Ok(d) => self.tagged_fields.push(TaggedField::Description(d)),
Err(e) => self.error = Some(e),
}
self.set_flags()
}
pub fn description_hash(
mut self, description_hash: sha256::Hash,
) -> InvoiceBuilder<tb::True, H, T, C, S, M> {
self.tagged_fields.push(TaggedField::DescriptionHash(Sha256(description_hash)));
self.set_flags()
}
pub fn invoice_description(
self, description: Bolt11InvoiceDescription,
) -> InvoiceBuilder<tb::True, H, T, C, S, M> {
match description {
Bolt11InvoiceDescription::Direct(desc) => self.description(desc.0 .0),
Bolt11InvoiceDescription::Hash(hash) => self.description_hash(hash.0),
}
}
}
impl<D: tb::Bool, T: tb::Bool, C: tb::Bool, S: tb::Bool, M: tb::Bool>
InvoiceBuilder<D, tb::False, T, C, S, M>
{
pub fn payment_hash(mut self, hash: sha256::Hash) -> InvoiceBuilder<D, tb::True, T, C, S, M> {
self.tagged_fields.push(TaggedField::PaymentHash(Sha256(hash)));
self.set_flags()
}
}
impl<D: tb::Bool, H: tb::Bool, C: tb::Bool, S: tb::Bool, M: tb::Bool>
InvoiceBuilder<D, H, tb::False, C, S, M>
{
#[cfg(feature = "std")]
pub fn timestamp(mut self, time: SystemTime) -> InvoiceBuilder<D, H, tb::True, C, S, M> {
match PositiveTimestamp::from_system_time(time) {
Ok(t) => self.timestamp = Some(t),
Err(e) => self.error = Some(e),
}
self.set_flags()
}
pub fn duration_since_epoch(
mut self, time: Duration,
) -> InvoiceBuilder<D, H, tb::True, C, S, M> {
match PositiveTimestamp::from_duration_since_epoch(time) {
Ok(t) => self.timestamp = Some(t),
Err(e) => self.error = Some(e),
}
self.set_flags()
}
#[cfg(feature = "std")]
pub fn current_timestamp(mut self) -> InvoiceBuilder<D, H, tb::True, C, S, M> {
let now = PositiveTimestamp::from_system_time(SystemTime::now());
self.timestamp = Some(now.expect("for the foreseeable future this shouldn't happen"));
self.set_flags()
}
}
impl<D: tb::Bool, H: tb::Bool, T: tb::Bool, S: tb::Bool, M: tb::Bool>
InvoiceBuilder<D, H, T, tb::False, S, M>
{
pub fn min_final_cltv_expiry_delta(
mut self, min_final_cltv_expiry_delta: u64,
) -> InvoiceBuilder<D, H, T, tb::True, S, M> {
self.tagged_fields.push(TaggedField::MinFinalCltvExpiryDelta(MinFinalCltvExpiryDelta(
min_final_cltv_expiry_delta,
)));
self.set_flags()
}
}
impl<D: tb::Bool, H: tb::Bool, T: tb::Bool, C: tb::Bool, M: tb::Bool>
InvoiceBuilder<D, H, T, C, tb::False, M>
{
pub fn payment_secret(
mut self, payment_secret: PaymentSecret,
) -> InvoiceBuilder<D, H, T, C, tb::True, M> {
let mut found_features = false;
for field in self.tagged_fields.iter_mut() {
if let TaggedField::Features(f) = field {
found_features = true;
f.set_variable_length_onion_required();
f.set_payment_secret_required();
}
}
self.tagged_fields.push(TaggedField::PaymentSecret(payment_secret));
if !found_features {
let mut features = Bolt11InvoiceFeatures::empty();
features.set_variable_length_onion_required();
features.set_payment_secret_required();
self.tagged_fields.push(TaggedField::Features(features));
}
self.set_flags()
}
}
impl<D: tb::Bool, H: tb::Bool, T: tb::Bool, C: tb::Bool, S: tb::Bool>
InvoiceBuilder<D, H, T, C, S, tb::False>
{
pub fn payment_metadata(
mut self, payment_metadata: Vec<u8>,
) -> InvoiceBuilder<D, H, T, C, S, tb::True> {
self.tagged_fields.push(TaggedField::PaymentMetadata(payment_metadata));
let mut found_features = false;
for field in self.tagged_fields.iter_mut() {
if let TaggedField::Features(f) = field {
found_features = true;
f.set_payment_metadata_optional();
}
}
if !found_features {
let mut features = Bolt11InvoiceFeatures::empty();
features.set_payment_metadata_optional();
self.tagged_fields.push(TaggedField::Features(features));
}
self.set_flags()
}
}
impl<D: tb::Bool, H: tb::Bool, T: tb::Bool, C: tb::Bool, S: tb::Bool>
InvoiceBuilder<D, H, T, C, S, tb::True>
{
pub fn require_payment_metadata(mut self) -> InvoiceBuilder<D, H, T, C, S, tb::True> {
for field in self.tagged_fields.iter_mut() {
if let TaggedField::Features(f) = field {
f.set_payment_metadata_required();
}
}
self
}
}
impl<D: tb::Bool, H: tb::Bool, T: tb::Bool, C: tb::Bool, M: tb::Bool>
InvoiceBuilder<D, H, T, C, tb::True, M>
{
pub fn basic_mpp(mut self) -> Self {
for field in self.tagged_fields.iter_mut() {
if let TaggedField::Features(f) = field {
f.set_basic_mpp_optional();
}
}
self
}
}
impl<M: tb::Bool> InvoiceBuilder<tb::True, tb::True, tb::True, tb::True, tb::True, M> {
pub fn build_signed<F>(self, sign_function: F) -> Result<Bolt11Invoice, CreationError>
where
F: FnOnce(&Message) -> RecoverableSignature,
{
let invoice = self.try_build_signed::<_, ()>(|hash| Ok(sign_function(hash)));
match invoice {
Ok(i) => Ok(i),
Err(SignOrCreationError::CreationError(e)) => Err(e),
Err(SignOrCreationError::SignError(())) => unreachable!(),
}
}
pub fn try_build_signed<F, E>(
self, sign_function: F,
) -> Result<Bolt11Invoice, SignOrCreationError<E>>
where
F: FnOnce(&Message) -> Result<RecoverableSignature, E>,
{
let raw = match self.build_raw() {
Ok(r) => r,
Err(e) => return Err(SignOrCreationError::CreationError(e)),
};
let signed = match raw.sign(sign_function) {
Ok(s) => s,
Err(e) => return Err(SignOrCreationError::SignError(e)),
};
let invoice = Bolt11Invoice { signed_invoice: signed };
invoice.check_field_counts().expect("should be ensured by type signature of builder");
invoice.check_feature_bits().expect("should be ensured by type signature of builder");
invoice.check_amount().expect("should be ensured by type signature of builder");
Ok(invoice)
}
}
impl SignedRawBolt11Invoice {
pub fn into_parts(self) -> (RawBolt11Invoice, [u8; 32], Bolt11InvoiceSignature) {
(self.raw_invoice, self.hash, self.signature)
}
pub fn raw_invoice(&self) -> &RawBolt11Invoice {
&self.raw_invoice
}
pub fn signable_hash(&self) -> &[u8; 32] {
&self.hash
}
pub fn signature(&self) -> &Bolt11InvoiceSignature {
&self.signature
}
pub fn recover_payee_pub_key(&self) -> Result<PayeePubKey, bitcoin::secp256k1::Error> {
let hash = Message::from_digest(self.hash);
Ok(PayeePubKey(Secp256k1::new().recover_ecdsa(&hash, &self.signature)?))
}
pub fn check_signature(&self) -> bool {
let included_pub_key = self.raw_invoice.payee_pub_key();
let mut recovered_pub_key = Option::None;
if recovered_pub_key.is_none() {
let recovered = match self.recover_payee_pub_key() {
Ok(pk) => pk,
Err(_) => return false,
};
recovered_pub_key = Some(recovered);
}
let pub_key =
included_pub_key.or(recovered_pub_key.as_ref()).expect("One is always present");
let hash = Message::from_digest(self.hash);
let secp_context = Secp256k1::new();
let verification_result =
secp_context.verify_ecdsa(&hash, &self.signature.to_standard(), pub_key);
match verification_result {
Ok(()) => true,
Err(_) => false,
}
}
}
macro_rules! find_extract {
($iter:expr, $enm:pat, $enm_var:ident) => {
find_all_extract!($iter, $enm, $enm_var).next()
};
}
macro_rules! find_all_extract {
($iter:expr, $enm:pat, $enm_var:ident) => {
$iter.filter_map(|tf| match *tf {
$enm => Some($enm_var),
_ => None,
})
};
}
#[allow(missing_docs)]
impl RawBolt11Invoice {
fn hash_from_parts<'s>(
hrp_bytes: &[u8], data_without_signature: Box<dyn Iterator<Item = Fe32> + 's>,
) -> [u8; 32] {
use crate::bech32::Fe32IterExt;
use bitcoin::hashes::HashEngine;
let mut data_part = data_without_signature.collect::<Vec<Fe32>>();
let overhang = (data_part.len() * 5) % 8;
if overhang > 0 {
data_part.push(Fe32::try_from(0).unwrap());
if overhang < 3 {
data_part.push(Fe32::try_from(0).unwrap());
}
}
let mut engine = sha256::Hash::engine();
engine.input(hrp_bytes);
data_part.into_iter().fes_to_bytes().for_each(|v| engine.input(&[v]));
let raw_hash = sha256::Hash::from_engine(engine);
let mut hash: [u8; 32] = Default::default();
hash.copy_from_slice(raw_hash.as_ref());
hash
}
pub fn signable_hash(&self) -> [u8; 32] {
Self::hash_from_parts(self.hrp.to_string().as_bytes(), self.data.fe_iter())
}
pub fn sign<F, E>(self, sign_method: F) -> Result<SignedRawBolt11Invoice, E>
where
F: FnOnce(&Message) -> Result<RecoverableSignature, E>,
{
let raw_hash = self.signable_hash();
let hash = Message::from_digest(raw_hash);
let signature = sign_method(&hash)?;
Ok(SignedRawBolt11Invoice {
raw_invoice: self,
hash: raw_hash,
signature: Bolt11InvoiceSignature(signature),
})
}
pub fn known_tagged_fields(
&self,
) -> FilterMap<Iter<RawTaggedField>, fn(&RawTaggedField) -> Option<&TaggedField>> {
fn match_raw(raw: &RawTaggedField) -> Option<&TaggedField> {
match *raw {
RawTaggedField::KnownSemantics(ref tf) => Some(tf),
_ => None,
}
}
self.data.tagged_fields.iter().filter_map(match_raw)
}
pub fn payment_hash(&self) -> Option<&Sha256> {
find_extract!(self.known_tagged_fields(), TaggedField::PaymentHash(ref x), x)
}
pub fn description(&self) -> Option<&Description> {
find_extract!(self.known_tagged_fields(), TaggedField::Description(ref x), x)
}
pub fn payee_pub_key(&self) -> Option<&PayeePubKey> {
find_extract!(self.known_tagged_fields(), TaggedField::PayeePubKey(ref x), x)
}
pub fn description_hash(&self) -> Option<&Sha256> {
find_extract!(self.known_tagged_fields(), TaggedField::DescriptionHash(ref x), x)
}
pub fn expiry_time(&self) -> Option<&ExpiryTime> {
find_extract!(self.known_tagged_fields(), TaggedField::ExpiryTime(ref x), x)
}
pub fn min_final_cltv_expiry_delta(&self) -> Option<&MinFinalCltvExpiryDelta> {
find_extract!(self.known_tagged_fields(), TaggedField::MinFinalCltvExpiryDelta(ref x), x)
}
pub fn payment_secret(&self) -> Option<&PaymentSecret> {
find_extract!(self.known_tagged_fields(), TaggedField::PaymentSecret(ref x), x)
}
pub fn payment_metadata(&self) -> Option<&Vec<u8>> {
find_extract!(self.known_tagged_fields(), TaggedField::PaymentMetadata(ref x), x)
}
pub fn features(&self) -> Option<&Bolt11InvoiceFeatures> {
find_extract!(self.known_tagged_fields(), TaggedField::Features(ref x), x)
}
pub fn fallbacks(&self) -> Vec<&Fallback> {
find_all_extract!(self.known_tagged_fields(), TaggedField::Fallback(ref x), x).collect()
}
pub fn private_routes(&self) -> Vec<&PrivateRoute> {
find_all_extract!(self.known_tagged_fields(), TaggedField::PrivateRoute(ref x), x).collect()
}
pub fn amount_pico_btc(&self) -> Option<u64> {
self.hrp.raw_amount.and_then(|v| {
v.checked_mul(
self.hrp.si_prefix.as_ref().map_or(1_000_000_000_000, |si| si.multiplier()),
)
})
}
pub fn currency(&self) -> Currency {
self.hrp.currency.clone()
}
pub fn to_raw(&self) -> (String, Vec<Fe32>) {
(self.hrp.to_string(), self.data.fe_iter().collect())
}
pub fn from_raw(hrp: &str, data: &[Fe32]) -> Result<Self, Bolt11ParseError> {
let raw_hrp: RawHrp = RawHrp::from_str(hrp)?;
let data_part = RawDataPart::from_base32(data)?;
Ok(Self { hrp: raw_hrp, data: data_part })
}
}
impl PositiveTimestamp {
pub fn from_unix_timestamp(unix_seconds: u64) -> Result<Self, CreationError> {
if unix_seconds <= MAX_TIMESTAMP {
Ok(Self(Duration::from_secs(unix_seconds)))
} else {
Err(CreationError::TimestampOutOfBounds)
}
}
#[cfg(feature = "std")]
pub fn from_system_time(time: SystemTime) -> Result<Self, CreationError> {
time.duration_since(SystemTime::UNIX_EPOCH)
.map(Self::from_duration_since_epoch)
.unwrap_or(Err(CreationError::TimestampOutOfBounds))
}
pub fn from_duration_since_epoch(duration: Duration) -> Result<Self, CreationError> {
Self::from_unix_timestamp(duration.as_secs())
}
pub fn as_unix_timestamp(&self) -> u64 {
self.0.as_secs()
}
pub fn as_duration_since_epoch(&self) -> Duration {
self.0
}
#[cfg(feature = "std")]
pub fn as_time(&self) -> SystemTime {
SystemTime::UNIX_EPOCH + self.0
}
}
impl From<PositiveTimestamp> for Duration {
fn from(val: PositiveTimestamp) -> Self {
val.0
}
}
#[cfg(feature = "std")]
impl From<PositiveTimestamp> for SystemTime {
fn from(val: PositiveTimestamp) -> Self {
SystemTime::UNIX_EPOCH + val.0
}
}
impl Bolt11Invoice {
pub fn signable_hash(&self) -> [u8; 32] {
self.signed_invoice.hash
}
pub fn into_signed_raw(self) -> SignedRawBolt11Invoice {
self.signed_invoice
}
fn check_field_counts(&self) -> Result<(), Bolt11SemanticError> {
let payment_hash_cnt = self
.tagged_fields()
.filter(|&tf| match *tf {
TaggedField::PaymentHash(_) => true,
_ => false,
})
.count();
if payment_hash_cnt < 1 {
return Err(Bolt11SemanticError::NoPaymentHash);
} else if payment_hash_cnt > 1 {
return Err(Bolt11SemanticError::MultiplePaymentHashes);
}
let description_cnt = self
.tagged_fields()
.filter(|&tf| match *tf {
TaggedField::Description(_) | TaggedField::DescriptionHash(_) => true,
_ => false,
})
.count();
if description_cnt < 1 {
return Err(Bolt11SemanticError::NoDescription);
} else if description_cnt > 1 {
return Err(Bolt11SemanticError::MultipleDescriptions);
}
self.check_payment_secret()?;
Ok(())
}
fn check_payment_secret(&self) -> Result<(), Bolt11SemanticError> {
let payment_secret_count = self
.tagged_fields()
.filter(|&tf| match *tf {
TaggedField::PaymentSecret(_) => true,
_ => false,
})
.count();
if payment_secret_count < 1 {
return Err(Bolt11SemanticError::NoPaymentSecret);
} else if payment_secret_count > 1 {
return Err(Bolt11SemanticError::MultiplePaymentSecrets);
}
Ok(())
}
fn check_amount(&self) -> Result<(), Bolt11SemanticError> {
if let Some(amount_pico_btc) = self.amount_pico_btc() {
if amount_pico_btc % 10 != 0 {
return Err(Bolt11SemanticError::ImpreciseAmount);
}
}
Ok(())
}
fn check_feature_bits(&self) -> Result<(), Bolt11SemanticError> {
self.check_payment_secret()?;
let features = self.tagged_fields().find(|&tf| match *tf {
TaggedField::Features(_) => true,
_ => false,
});
match features {
None => Err(Bolt11SemanticError::InvalidFeatures),
Some(TaggedField::Features(features)) => {
if features.requires_unknown_bits() {
Err(Bolt11SemanticError::InvalidFeatures)
} else if !features.supports_payment_secret() {
Err(Bolt11SemanticError::InvalidFeatures)
} else {
Ok(())
}
},
Some(_) => unreachable!(),
}
}
pub fn check_signature(&self) -> Result<(), Bolt11SemanticError> {
match self.signed_invoice.recover_payee_pub_key() {
Err(bitcoin::secp256k1::Error::InvalidRecoveryId) => {
return Err(Bolt11SemanticError::InvalidRecoveryId)
},
Err(bitcoin::secp256k1::Error::InvalidSignature) => {
return Err(Bolt11SemanticError::InvalidSignature)
},
Err(e) => panic!("no other error may occur, got {:?}", e),
Ok(_) => {},
}
if !self.signed_invoice.check_signature() {
return Err(Bolt11SemanticError::InvalidSignature);
}
Ok(())
}
pub fn from_signed(
signed_invoice: SignedRawBolt11Invoice,
) -> Result<Self, Bolt11SemanticError> {
let invoice = Bolt11Invoice { signed_invoice };
invoice.check_field_counts()?;
invoice.check_feature_bits()?;
invoice.check_signature()?;
invoice.check_amount()?;
Ok(invoice)
}
#[cfg(feature = "std")]
pub fn timestamp(&self) -> SystemTime {
self.signed_invoice.raw_invoice().data.timestamp.as_time()
}
pub fn duration_since_epoch(&self) -> Duration {
self.signed_invoice.raw_invoice().data.timestamp.0
}
pub fn tagged_fields(
&self,
) -> FilterMap<Iter<RawTaggedField>, fn(&RawTaggedField) -> Option<&TaggedField>> {
self.signed_invoice.raw_invoice().known_tagged_fields()
}
pub fn payment_hash(&self) -> &sha256::Hash {
&self.signed_invoice.payment_hash().expect("checked by constructor").0
}
pub fn description(&self) -> Bolt11InvoiceDescriptionRef {
if let Some(direct) = self.signed_invoice.description() {
return Bolt11InvoiceDescriptionRef::Direct(direct);
} else if let Some(hash) = self.signed_invoice.description_hash() {
return Bolt11InvoiceDescriptionRef::Hash(hash);
}
unreachable!("ensured by constructor");
}
pub fn payee_pub_key(&self) -> Option<&PublicKey> {
self.signed_invoice.payee_pub_key().map(|x| &x.0)
}
pub fn payment_secret(&self) -> &PaymentSecret {
self.signed_invoice.payment_secret().expect("was checked by constructor")
}
pub fn payment_metadata(&self) -> Option<&Vec<u8>> {
self.signed_invoice.payment_metadata()
}
pub fn features(&self) -> Option<&Bolt11InvoiceFeatures> {
self.signed_invoice.features()
}
pub fn recover_payee_pub_key(&self) -> PublicKey {
self.signed_invoice.recover_payee_pub_key().expect("was checked by constructor").0
}
pub fn get_payee_pub_key(&self) -> PublicKey {
match self.payee_pub_key() {
Some(pk) => *pk,
None => self.recover_payee_pub_key(),
}
}
pub fn expires_at(&self) -> Option<Duration> {
self.duration_since_epoch().checked_add(self.expiry_time())
}
pub fn expiry_time(&self) -> Duration {
self.signed_invoice
.expiry_time()
.map(|x| x.0)
.unwrap_or(Duration::from_secs(DEFAULT_EXPIRY_TIME))
}
#[cfg(feature = "std")]
pub fn is_expired(&self) -> bool {
Self::is_expired_from_epoch(&self.timestamp(), self.expiry_time())
}
#[cfg(feature = "std")]
pub(crate) fn is_expired_from_epoch(epoch: &SystemTime, expiry_time: Duration) -> bool {
match epoch.elapsed() {
Ok(elapsed) => elapsed > expiry_time,
Err(_) => false,
}
}
#[cfg(feature = "std")]
pub fn duration_until_expiry(&self) -> Duration {
SystemTime::now()
.duration_since(SystemTime::UNIX_EPOCH)
.map(|now| self.expiration_remaining_from_epoch(now))
.unwrap_or(Duration::from_nanos(0))
}
pub fn expiration_remaining_from_epoch(&self, time: Duration) -> Duration {
self.expires_at().map(|x| x.checked_sub(time)).flatten().unwrap_or(Duration::from_nanos(0))
}
pub fn would_expire(&self, at_time: Duration) -> bool {
self.duration_since_epoch()
.checked_add(self.expiry_time())
.unwrap_or_else(|| Duration::new(u64::max_value(), 1_000_000_000 - 1))
< at_time
}
pub fn min_final_cltv_expiry_delta(&self) -> u64 {
self.signed_invoice
.min_final_cltv_expiry_delta()
.map(|x| x.0)
.unwrap_or(DEFAULT_MIN_FINAL_CLTV_EXPIRY_DELTA)
}
pub fn fallbacks(&self) -> Vec<&Fallback> {
self.signed_invoice.fallbacks()
}
pub fn fallback_addresses(&self) -> Vec<Address> {
let filter_fn = |fallback: &&Fallback| {
let address = match fallback {
Fallback::SegWitProgram { version, program } => {
match WitnessProgram::new(*version, &program) {
Ok(witness_program) => {
Address::from_witness_program(witness_program, self.network())
},
Err(_) => return None,
}
},
Fallback::PubKeyHash(pkh) => Address::p2pkh(*pkh, self.network()),
Fallback::ScriptHash(sh) => Address::p2sh_from_hash(*sh, self.network()),
};
Some(address)
};
self.fallbacks().iter().filter_map(filter_fn).collect()
}
pub fn private_routes(&self) -> Vec<&PrivateRoute> {
self.signed_invoice.private_routes()
}
pub fn route_hints(&self) -> Vec<RouteHint> {
find_all_extract!(
self.signed_invoice.known_tagged_fields(),
TaggedField::PrivateRoute(ref x),
x
)
.map(|route| (**route).clone())
.collect()
}
pub fn currency(&self) -> Currency {
self.signed_invoice.currency()
}
pub fn network(&self) -> Network {
self.signed_invoice.currency().into()
}
pub fn amount_milli_satoshis(&self) -> Option<u64> {
self.signed_invoice.amount_pico_btc().map(|v| v / 10)
}
fn amount_pico_btc(&self) -> Option<u64> {
self.signed_invoice.amount_pico_btc()
}
}
impl From<TaggedField> for RawTaggedField {
fn from(tf: TaggedField) -> Self {
RawTaggedField::KnownSemantics(tf)
}
}
impl TaggedField {
pub fn tag(&self) -> Fe32 {
let tag = match *self {
TaggedField::PaymentHash(_) => constants::TAG_PAYMENT_HASH,
TaggedField::Description(_) => constants::TAG_DESCRIPTION,
TaggedField::PayeePubKey(_) => constants::TAG_PAYEE_PUB_KEY,
TaggedField::DescriptionHash(_) => constants::TAG_DESCRIPTION_HASH,
TaggedField::ExpiryTime(_) => constants::TAG_EXPIRY_TIME,
TaggedField::MinFinalCltvExpiryDelta(_) => constants::TAG_MIN_FINAL_CLTV_EXPIRY_DELTA,
TaggedField::Fallback(_) => constants::TAG_FALLBACK,
TaggedField::PrivateRoute(_) => constants::TAG_PRIVATE_ROUTE,
TaggedField::PaymentSecret(_) => constants::TAG_PAYMENT_SECRET,
TaggedField::PaymentMetadata(_) => constants::TAG_PAYMENT_METADATA,
TaggedField::Features(_) => constants::TAG_FEATURES,
};
Fe32::try_from(tag).expect("all tags defined are <32")
}
}
impl Description {
pub fn new(description: String) -> Result<Description, CreationError> {
if description.len() > 639 {
Err(CreationError::DescriptionTooLong)
} else {
Ok(Description(UntrustedString(description)))
}
}
pub fn empty() -> Self {
Description(UntrustedString(String::new()))
}
pub fn into_inner(self) -> UntrustedString {
self.0
}
pub fn as_inner(&self) -> &UntrustedString {
&self.0
}
}
impl Display for Description {
fn fmt(&self, f: &mut Formatter<'_>) -> fmt::Result {
write!(f, "{}", self.0)
}
}
impl From<PublicKey> for PayeePubKey {
fn from(pk: PublicKey) -> Self {
PayeePubKey(pk)
}
}
impl Deref for PayeePubKey {
type Target = PublicKey;
fn deref(&self) -> &PublicKey {
&self.0
}
}
impl ExpiryTime {
pub fn from_seconds(seconds: u64) -> ExpiryTime {
ExpiryTime(Duration::from_secs(seconds))
}
pub fn from_duration(duration: Duration) -> ExpiryTime {
Self::from_seconds(duration.as_secs())
}
pub fn as_seconds(&self) -> u64 {
self.0.as_secs()
}
pub fn as_duration(&self) -> &Duration {
&self.0
}
}
impl PrivateRoute {
pub fn new(hops: RouteHint) -> Result<PrivateRoute, CreationError> {
if hops.0.len() <= 12 {
Ok(PrivateRoute(hops))
} else {
Err(CreationError::RouteTooLong)
}
}
pub fn into_inner(self) -> RouteHint {
self.0
}
}
impl From<PrivateRoute> for RouteHint {
fn from(val: PrivateRoute) -> Self {
val.into_inner()
}
}
impl Deref for PrivateRoute {
type Target = RouteHint;
fn deref(&self) -> &RouteHint {
&self.0
}
}
impl Deref for Bolt11InvoiceSignature {
type Target = RecoverableSignature;
fn deref(&self) -> &RecoverableSignature {
&self.0
}
}
impl Deref for SignedRawBolt11Invoice {
type Target = RawBolt11Invoice;
fn deref(&self) -> &RawBolt11Invoice {
&self.raw_invoice
}
}
#[derive(Eq, PartialEq, Debug, Clone)]
pub enum CreationError {
DescriptionTooLong,
RouteTooLong,
TimestampOutOfBounds,
InvalidAmount,
MissingRouteHints,
MinFinalCltvExpiryDeltaTooShort,
}
impl Display for CreationError {
fn fmt(&self, f: &mut Formatter<'_>) -> fmt::Result {
match self {
CreationError::DescriptionTooLong => f.write_str("The supplied description string was longer than 639 bytes"),
CreationError::RouteTooLong => f.write_str("The specified route has too many hops and can't be encoded"),
CreationError::TimestampOutOfBounds => f.write_str("The Unix timestamp of the supplied date is less than zero or greater than 35-bits"),
CreationError::InvalidAmount => f.write_str("The supplied millisatoshi amount was greater than the total bitcoin supply"),
CreationError::MissingRouteHints => f.write_str("The invoice required route hints and they weren't provided"),
CreationError::MinFinalCltvExpiryDeltaTooShort => f.write_str(
"The supplied final CLTV expiry delta was less than LDK's `MIN_FINAL_CLTV_EXPIRY_DELTA`"),
}
}
}
#[cfg(feature = "std")]
impl std::error::Error for CreationError {}
#[derive(Eq, PartialEq, Debug, Clone)]
pub enum Bolt11SemanticError {
NoPaymentHash,
MultiplePaymentHashes,
NoDescription,
MultipleDescriptions,
NoPaymentSecret,
MultiplePaymentSecrets,
InvalidFeatures,
InvalidRecoveryId,
InvalidSignature,
ImpreciseAmount,
}
impl Display for Bolt11SemanticError {
fn fmt(&self, f: &mut Formatter<'_>) -> fmt::Result {
match self {
Bolt11SemanticError::NoPaymentHash => f.write_str("The invoice is missing the mandatory payment hash"),
Bolt11SemanticError::MultiplePaymentHashes => f.write_str("The invoice has multiple payment hashes which isn't allowed"),
Bolt11SemanticError::NoDescription => f.write_str("No description or description hash are part of the invoice"),
Bolt11SemanticError::MultipleDescriptions => f.write_str("The invoice contains multiple descriptions and/or description hashes which isn't allowed"),
Bolt11SemanticError::NoPaymentSecret => f.write_str("The invoice is missing the mandatory payment secret"),
Bolt11SemanticError::MultiplePaymentSecrets => f.write_str("The invoice contains multiple payment secrets"),
Bolt11SemanticError::InvalidFeatures => f.write_str("The invoice's features are invalid"),
Bolt11SemanticError::InvalidRecoveryId => f.write_str("The recovery id doesn't fit the signature/pub key"),
Bolt11SemanticError::InvalidSignature => f.write_str("The invoice's signature is invalid"),
Bolt11SemanticError::ImpreciseAmount => f.write_str("The invoice's amount was not a whole number of millisatoshis"),
}
}
}
#[cfg(feature = "std")]
impl std::error::Error for Bolt11SemanticError {}
#[derive(Eq, PartialEq, Debug, Clone)]
pub enum SignOrCreationError<S = ()> {
SignError(S),
CreationError(CreationError),
}
impl<S> Display for SignOrCreationError<S> {
fn fmt(&self, f: &mut Formatter<'_>) -> fmt::Result {
match self {
SignOrCreationError::SignError(_) => f.write_str("An error occurred during signing"),
SignOrCreationError::CreationError(err) => err.fmt(f),
}
}
}
#[cfg(feature = "serde")]
impl Serialize for Bolt11Invoice {
fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
where
S: Serializer,
{
serializer.serialize_str(self.to_string().as_str())
}
}
#[cfg(feature = "serde")]
impl<'de> Deserialize<'de> for Bolt11Invoice {
fn deserialize<D>(deserializer: D) -> Result<Bolt11Invoice, D::Error>
where
D: Deserializer<'de>,
{
let bolt11 = String::deserialize(deserializer)?
.parse::<Bolt11Invoice>()
.map_err(|e| D::Error::custom(format_args!("{:?}", e)))?;
Ok(bolt11)
}
}
#[cfg(test)]
mod test {
use bitcoin::hashes::sha256;
use bitcoin::ScriptBuf;
use std::str::FromStr;
#[test]
fn test_system_time_bounds_assumptions() {
assert_eq!(
crate::PositiveTimestamp::from_unix_timestamp(crate::MAX_TIMESTAMP + 1),
Err(crate::CreationError::TimestampOutOfBounds)
);
}
#[test]
fn test_calc_invoice_hash() {
use crate::TaggedField::*;
use crate::{Currency, PositiveTimestamp, RawBolt11Invoice, RawDataPart, RawHrp};
let invoice = RawBolt11Invoice {
hrp: RawHrp { currency: Currency::Bitcoin, raw_amount: None, si_prefix: None },
data: RawDataPart {
timestamp: PositiveTimestamp::from_unix_timestamp(1496314658).unwrap(),
tagged_fields: vec![
PaymentHash(crate::Sha256(
sha256::Hash::from_str(
"0001020304050607080900010203040506070809000102030405060708090102",
)
.unwrap(),
))
.into(),
Description(
crate::Description::new(
"Please consider supporting this project".to_owned(),
)
.unwrap(),
)
.into(),
],
},
};
let expected_hash = [
0xc3, 0xd4, 0xe8, 0x3f, 0x64, 0x6f, 0xa7, 0x9a, 0x39, 0x3d, 0x75, 0x27, 0x7b, 0x1d,
0x85, 0x8d, 0xb1, 0xd1, 0xf7, 0xab, 0x71, 0x37, 0xdc, 0xb7, 0x83, 0x5d, 0xb2, 0xec,
0xd5, 0x18, 0xe1, 0xc9,
];
assert_eq!(invoice.signable_hash(), expected_hash)
}
#[test]
fn test_check_signature() {
use crate::TaggedField::*;
use crate::{
Bolt11InvoiceSignature, Currency, PositiveTimestamp, RawBolt11Invoice, RawDataPart,
RawHrp, Sha256, SignedRawBolt11Invoice,
};
use bitcoin::secp256k1::ecdsa::{RecoverableSignature, RecoveryId};
use bitcoin::secp256k1::Secp256k1;
use bitcoin::secp256k1::{PublicKey, SecretKey};
let invoice =
SignedRawBolt11Invoice {
raw_invoice: RawBolt11Invoice {
hrp: RawHrp { currency: Currency::Bitcoin, raw_amount: None, si_prefix: None },
data: RawDataPart {
timestamp: PositiveTimestamp::from_unix_timestamp(1496314658).unwrap(),
tagged_fields: vec ! [
PaymentHash(Sha256(sha256::Hash::from_str(
"0001020304050607080900010203040506070809000102030405060708090102"
).unwrap())).into(),
Description(
crate::Description::new(
"Please consider supporting this project".to_owned()
).unwrap()
).into(),
],
},
},
hash: [
0xc3, 0xd4, 0xe8, 0x3f, 0x64, 0x6f, 0xa7, 0x9a, 0x39, 0x3d, 0x75, 0x27, 0x7b,
0x1d, 0x85, 0x8d, 0xb1, 0xd1, 0xf7, 0xab, 0x71, 0x37, 0xdc, 0xb7, 0x83, 0x5d,
0xb2, 0xec, 0xd5, 0x18, 0xe1, 0xc9,
],
signature: Bolt11InvoiceSignature(
RecoverableSignature::from_compact(
&[
0x38u8, 0xec, 0x68, 0x91, 0x34, 0x5e, 0x20, 0x41, 0x45, 0xbe, 0x8a,
0x3a, 0x99, 0xde, 0x38, 0xe9, 0x8a, 0x39, 0xd6, 0xa5, 0x69, 0x43, 0x4e,
0x18, 0x45, 0xc8, 0xaf, 0x72, 0x05, 0xaf, 0xcf, 0xcc, 0x7f, 0x42, 0x5f,
0xcd, 0x14, 0x63, 0xe9, 0x3c, 0x32, 0x88, 0x1e, 0xad, 0x0d, 0x6e, 0x35,
0x6d, 0x46, 0x7e, 0xc8, 0xc0, 0x25, 0x53, 0xf9, 0xaa, 0xb1, 0x5e, 0x57,
0x38, 0xb1, 0x1f, 0x12, 0x7f,
],
RecoveryId::from_i32(0).unwrap(),
)
.unwrap(),
),
};
assert!(invoice.check_signature());
let private_key = SecretKey::from_slice(
&[
0xe1, 0x26, 0xf6, 0x8f, 0x7e, 0xaf, 0xcc, 0x8b, 0x74, 0xf5, 0x4d, 0x26, 0x9f, 0xe2,
0x06, 0xbe, 0x71, 0x50, 0x00, 0xf9, 0x4d, 0xac, 0x06, 0x7d, 0x1c, 0x04, 0xa8, 0xca,
0x3b, 0x2d, 0xb7, 0x34,
][..],
)
.unwrap();
let public_key = PublicKey::from_secret_key(&Secp256k1::new(), &private_key);
assert_eq!(invoice.recover_payee_pub_key(), Ok(crate::PayeePubKey(public_key)));
let (raw_invoice, _, _) = invoice.into_parts();
let new_signed = raw_invoice
.sign::<_, ()>(|hash| Ok(Secp256k1::new().sign_ecdsa_recoverable(hash, &private_key)))
.unwrap();
assert!(new_signed.check_signature());
}
#[test]
fn test_check_feature_bits() {
use crate::TaggedField::*;
use crate::{
Bolt11Invoice, Bolt11SemanticError, Currency, PositiveTimestamp, RawBolt11Invoice,
RawDataPart, RawHrp, Sha256,
};
use bitcoin::secp256k1::Secp256k1;
use bitcoin::secp256k1::SecretKey;
use lightning_types::features::Bolt11InvoiceFeatures;
let private_key = SecretKey::from_slice(&[42; 32]).unwrap();
let payment_secret = lightning_types::payment::PaymentSecret([21; 32]);
let invoice_template = RawBolt11Invoice {
hrp: RawHrp { currency: Currency::Bitcoin, raw_amount: None, si_prefix: None },
data: RawDataPart {
timestamp: PositiveTimestamp::from_unix_timestamp(1496314658).unwrap(),
tagged_fields: vec![
PaymentHash(Sha256(
sha256::Hash::from_str(
"0001020304050607080900010203040506070809000102030405060708090102",
)
.unwrap(),
))
.into(),
Description(
crate::Description::new(
"Please consider supporting this project".to_owned(),
)
.unwrap(),
)
.into(),
],
},
};
let invoice = {
let mut invoice = invoice_template.clone();
invoice.data.tagged_fields.push(PaymentSecret(payment_secret).into());
invoice.sign::<_, ()>(|hash| {
Ok(Secp256k1::new().sign_ecdsa_recoverable(hash, &private_key))
})
}
.unwrap();
assert_eq!(Bolt11Invoice::from_signed(invoice), Err(Bolt11SemanticError::InvalidFeatures));
let invoice = {
let mut invoice = invoice_template.clone();
invoice.data.tagged_fields.push(PaymentSecret(payment_secret).into());
invoice.data.tagged_fields.push(Features(Bolt11InvoiceFeatures::empty()).into());
invoice.sign::<_, ()>(|hash| {
Ok(Secp256k1::new().sign_ecdsa_recoverable(hash, &private_key))
})
}
.unwrap();
assert_eq!(Bolt11Invoice::from_signed(invoice), Err(Bolt11SemanticError::InvalidFeatures));
let mut payment_secret_features = Bolt11InvoiceFeatures::empty();
payment_secret_features.set_payment_secret_required();
let invoice = {
let mut invoice = invoice_template.clone();
invoice.data.tagged_fields.push(PaymentSecret(payment_secret).into());
invoice.data.tagged_fields.push(Features(payment_secret_features.clone()).into());
invoice.sign::<_, ()>(|hash| {
Ok(Secp256k1::new().sign_ecdsa_recoverable(hash, &private_key))
})
}
.unwrap();
assert!(Bolt11Invoice::from_signed(invoice).is_ok());
let invoice = {
let invoice = invoice_template.clone();
invoice.sign::<_, ()>(|hash| {
Ok(Secp256k1::new().sign_ecdsa_recoverable(hash, &private_key))
})
}
.unwrap();
assert_eq!(Bolt11Invoice::from_signed(invoice), Err(Bolt11SemanticError::NoPaymentSecret));
let invoice = {
let mut invoice = invoice_template.clone();
invoice.data.tagged_fields.push(Features(Bolt11InvoiceFeatures::empty()).into());
invoice.sign::<_, ()>(|hash| {
Ok(Secp256k1::new().sign_ecdsa_recoverable(hash, &private_key))
})
}
.unwrap();
assert_eq!(Bolt11Invoice::from_signed(invoice), Err(Bolt11SemanticError::NoPaymentSecret));
let invoice = {
let mut invoice = invoice_template.clone();
invoice.data.tagged_fields.push(Features(payment_secret_features).into());
invoice.sign::<_, ()>(|hash| {
Ok(Secp256k1::new().sign_ecdsa_recoverable(hash, &private_key))
})
}
.unwrap();
assert_eq!(Bolt11Invoice::from_signed(invoice), Err(Bolt11SemanticError::NoPaymentSecret));
let invoice = {
let mut invoice = invoice_template;
invoice.data.tagged_fields.push(PaymentSecret(payment_secret).into());
invoice.data.tagged_fields.push(PaymentSecret(payment_secret).into());
invoice.sign::<_, ()>(|hash| {
Ok(Secp256k1::new().sign_ecdsa_recoverable(hash, &private_key))
})
}
.unwrap();
assert_eq!(
Bolt11Invoice::from_signed(invoice),
Err(Bolt11SemanticError::MultiplePaymentSecrets)
);
}
#[test]
fn test_builder_amount() {
use crate::*;
let builder = InvoiceBuilder::new(Currency::Bitcoin)
.description("Test".into())
.payment_hash(sha256::Hash::from_slice(&[0; 32][..]).unwrap())
.duration_since_epoch(Duration::from_secs(1234567));
let invoice = builder.clone().amount_milli_satoshis(1500).build_raw().unwrap();
assert_eq!(invoice.hrp.si_prefix, Some(SiPrefix::Nano));
assert_eq!(invoice.hrp.raw_amount, Some(15));
let invoice = builder.amount_milli_satoshis(150).build_raw().unwrap();
assert_eq!(invoice.hrp.si_prefix, Some(SiPrefix::Pico));
assert_eq!(invoice.hrp.raw_amount, Some(1500));
}
#[test]
fn test_builder_fail() {
use crate::*;
use bitcoin::secp256k1::PublicKey;
use lightning_types::routing::RouteHintHop;
use std::iter::FromIterator;
let builder = InvoiceBuilder::new(Currency::Bitcoin)
.payment_hash(sha256::Hash::from_slice(&[0; 32][..]).unwrap())
.duration_since_epoch(Duration::from_secs(1234567))
.min_final_cltv_expiry_delta(144);
let too_long_string = String::from_iter((0..1024).map(|_| '?'));
let long_desc_res = builder.clone().description(too_long_string).build_raw();
assert_eq!(long_desc_res, Err(CreationError::DescriptionTooLong));
let route_hop = RouteHintHop {
src_node_id: PublicKey::from_slice(
&[
0x03, 0x9e, 0x03, 0xa9, 0x01, 0xb8, 0x55, 0x34, 0xff, 0x1e, 0x92, 0xc4, 0x3c,
0x74, 0x43, 0x1f, 0x7c, 0xe7, 0x20, 0x46, 0x06, 0x0f, 0xcf, 0x7a, 0x95, 0xc3,
0x7e, 0x14, 0x8f, 0x78, 0xc7, 0x72, 0x55,
][..],
)
.unwrap(),
short_channel_id: 0,
fees: RoutingFees { base_msat: 0, proportional_millionths: 0 },
cltv_expiry_delta: 0,
htlc_minimum_msat: None,
htlc_maximum_msat: None,
};
let too_long_route = RouteHint(vec![route_hop; 13]);
let long_route_res =
builder.clone().description("Test".into()).private_route(too_long_route).build_raw();
assert_eq!(long_route_res, Err(CreationError::RouteTooLong));
let sign_error_res = builder
.description("Test".into())
.payment_secret(PaymentSecret([0; 32]))
.try_build_signed(|_| Err("ImaginaryError"));
assert_eq!(sign_error_res, Err(SignOrCreationError::SignError("ImaginaryError")));
}
#[test]
fn test_builder_ok() {
use crate::*;
use bitcoin::secp256k1::Secp256k1;
use bitcoin::secp256k1::{PublicKey, SecretKey};
use lightning_types::routing::RouteHintHop;
use std::time::Duration;
let secp_ctx = Secp256k1::new();
let private_key = SecretKey::from_slice(
&[
0xe1, 0x26, 0xf6, 0x8f, 0x7e, 0xaf, 0xcc, 0x8b, 0x74, 0xf5, 0x4d, 0x26, 0x9f, 0xe2,
0x06, 0xbe, 0x71, 0x50, 0x00, 0xf9, 0x4d, 0xac, 0x06, 0x7d, 0x1c, 0x04, 0xa8, 0xca,
0x3b, 0x2d, 0xb7, 0x34,
][..],
)
.unwrap();
let public_key = PublicKey::from_secret_key(&secp_ctx, &private_key);
let route_1 = RouteHint(vec![
RouteHintHop {
src_node_id: public_key,
short_channel_id: u64::from_be_bytes([123; 8]),
fees: RoutingFees { base_msat: 2, proportional_millionths: 1 },
cltv_expiry_delta: 145,
htlc_minimum_msat: None,
htlc_maximum_msat: None,
},
RouteHintHop {
src_node_id: public_key,
short_channel_id: u64::from_be_bytes([42; 8]),
fees: RoutingFees { base_msat: 3, proportional_millionths: 2 },
cltv_expiry_delta: 146,
htlc_minimum_msat: None,
htlc_maximum_msat: None,
},
]);
let route_2 = RouteHint(vec![
RouteHintHop {
src_node_id: public_key,
short_channel_id: 0,
fees: RoutingFees { base_msat: 4, proportional_millionths: 3 },
cltv_expiry_delta: 147,
htlc_minimum_msat: None,
htlc_maximum_msat: None,
},
RouteHintHop {
src_node_id: public_key,
short_channel_id: u64::from_be_bytes([1; 8]),
fees: RoutingFees { base_msat: 5, proportional_millionths: 4 },
cltv_expiry_delta: 148,
htlc_minimum_msat: None,
htlc_maximum_msat: None,
},
]);
let builder = InvoiceBuilder::new(Currency::BitcoinTestnet)
.amount_milli_satoshis(123)
.duration_since_epoch(Duration::from_secs(1234567))
.payee_pub_key(public_key)
.expiry_time(Duration::from_secs(54321))
.min_final_cltv_expiry_delta(144)
.fallback(Fallback::PubKeyHash(PubkeyHash::from_slice(&[0; 20]).unwrap()))
.private_route(route_1.clone())
.private_route(route_2.clone())
.description_hash(sha256::Hash::from_slice(&[3; 32][..]).unwrap())
.payment_hash(sha256::Hash::from_slice(&[21; 32][..]).unwrap())
.payment_secret(PaymentSecret([42; 32]))
.basic_mpp();
let invoice = builder
.clone()
.build_signed(|hash| secp_ctx.sign_ecdsa_recoverable(hash, &private_key))
.unwrap();
assert!(invoice.check_signature().is_ok());
assert_eq!(invoice.tagged_fields().count(), 10);
assert_eq!(invoice.amount_milli_satoshis(), Some(123));
assert_eq!(invoice.amount_pico_btc(), Some(1230));
assert_eq!(invoice.currency(), Currency::BitcoinTestnet);
#[cfg(feature = "std")]
assert_eq!(
invoice.timestamp().duration_since(SystemTime::UNIX_EPOCH).unwrap().as_secs(),
1234567
);
assert_eq!(invoice.payee_pub_key(), Some(&public_key));
assert_eq!(invoice.expiry_time(), Duration::from_secs(54321));
assert_eq!(invoice.min_final_cltv_expiry_delta(), 144);
assert_eq!(
invoice.fallbacks(),
vec![&Fallback::PubKeyHash(PubkeyHash::from_slice(&[0; 20]).unwrap())]
);
let address = Address::from_script(
&ScriptBuf::new_p2pkh(&PubkeyHash::from_slice(&[0; 20]).unwrap()),
Network::Testnet,
)
.unwrap();
assert_eq!(invoice.fallback_addresses(), vec![address]);
assert_eq!(invoice.private_routes(), vec![&PrivateRoute(route_1), &PrivateRoute(route_2)]);
assert_eq!(
invoice.description(),
Bolt11InvoiceDescriptionRef::Hash(&Sha256(
sha256::Hash::from_slice(&[3; 32][..]).unwrap()
))
);
assert_eq!(invoice.payment_hash(), &sha256::Hash::from_slice(&[21; 32][..]).unwrap());
assert_eq!(invoice.payment_secret(), &PaymentSecret([42; 32]));
let mut expected_features = Bolt11InvoiceFeatures::empty();
expected_features.set_variable_length_onion_required();
expected_features.set_payment_secret_required();
expected_features.set_basic_mpp_optional();
assert_eq!(invoice.features(), Some(&expected_features));
let raw_invoice = builder.build_raw().unwrap();
assert_eq!(raw_invoice, *invoice.into_signed_raw().raw_invoice())
}
#[test]
fn test_default_values() {
use crate::*;
use bitcoin::secp256k1::Secp256k1;
use bitcoin::secp256k1::SecretKey;
let signed_invoice = InvoiceBuilder::new(Currency::Bitcoin)
.description("Test".into())
.payment_hash(sha256::Hash::from_slice(&[0; 32][..]).unwrap())
.payment_secret(PaymentSecret([0; 32]))
.duration_since_epoch(Duration::from_secs(1234567))
.build_raw()
.unwrap()
.sign::<_, ()>(|hash| {
let privkey = SecretKey::from_slice(&[41; 32]).unwrap();
let secp_ctx = Secp256k1::new();
Ok(secp_ctx.sign_ecdsa_recoverable(hash, &privkey))
})
.unwrap();
let invoice = Bolt11Invoice::from_signed(signed_invoice).unwrap();
assert_eq!(invoice.min_final_cltv_expiry_delta(), DEFAULT_MIN_FINAL_CLTV_EXPIRY_DELTA);
assert_eq!(invoice.expiry_time(), Duration::from_secs(DEFAULT_EXPIRY_TIME));
assert!(!invoice.would_expire(Duration::from_secs(1234568)));
}
#[test]
fn test_expiration() {
use crate::*;
use bitcoin::secp256k1::Secp256k1;
use bitcoin::secp256k1::SecretKey;
let signed_invoice = InvoiceBuilder::new(Currency::Bitcoin)
.description("Test".into())
.payment_hash(sha256::Hash::from_slice(&[0; 32][..]).unwrap())
.payment_secret(PaymentSecret([0; 32]))
.duration_since_epoch(Duration::from_secs(1234567))
.build_raw()
.unwrap()
.sign::<_, ()>(|hash| {
let privkey = SecretKey::from_slice(&[41; 32]).unwrap();
let secp_ctx = Secp256k1::new();
Ok(secp_ctx.sign_ecdsa_recoverable(hash, &privkey))
})
.unwrap();
let invoice = Bolt11Invoice::from_signed(signed_invoice).unwrap();
assert!(invoice.would_expire(Duration::from_secs(1234567 + DEFAULT_EXPIRY_TIME + 1)));
}
#[cfg(feature = "serde")]
#[test]
fn test_serde() {
let invoice_str = "lnbc100p1psj9jhxdqud3jxktt5w46x7unfv9kz6mn0v3jsnp4q0d3p2sfluzdx45tqcs\
h2pu5qc7lgq0xs578ngs6s0s68ua4h7cvspp5q6rmq35js88zp5dvwrv9m459tnk2zunwj5jalqtyxqulh0l\
5gflssp5nf55ny5gcrfl30xuhzj3nphgj27rstekmr9fw3ny5989s300gyus9qyysgqcqpcrzjqw2sxwe993\
h5pcm4dxzpvttgza8zhkqxpgffcrf5v25nwpr3cmfg7z54kuqq8rgqqqqqqqq2qqqqq9qq9qrzjqd0ylaqcl\
j9424x9m8h2vcukcgnm6s56xfgu3j78zyqzhgs4hlpzvznlugqq9vsqqqqqqqlgqqqqqeqq9qrzjqwldmj9d\
ha74df76zhx6l9we0vjdquygcdt3kssupehe64g6yyp5yz5rhuqqwccqqyqqqqlgqqqqjcqq9qrzjqf9e58a\
guqr0rcun0ajlvmzq3ek63cw2w282gv3z5uupmuwvgjtq2z55qsqqg6qqqyqqqrtnqqqzq3cqygrzjqvphms\
ywntrrhqjcraumvc4y6r8v4z5v593trte429v4hredj7ms5z52usqq9ngqqqqqqqlgqqqqqqgq9qrzjq2v0v\
p62g49p7569ev48cmulecsxe59lvaw3wlxm7r982zxa9zzj7z5l0cqqxusqqyqqqqlgqqqqqzsqygarl9fh3\
8s0gyuxjjgux34w75dnc6xp2l35j7es3jd4ugt3lu0xzre26yg5m7ke54n2d5sym4xcmxtl8238xxvw5h5h5\
j5r6drg6k6zcqj0fcwg";
let invoice = invoice_str.parse::<super::Bolt11Invoice>().unwrap();
let serialized_invoice = serde_json::to_string(&invoice).unwrap();
let deserialized_invoice: super::Bolt11Invoice =
serde_json::from_str(serialized_invoice.as_str()).unwrap();
assert_eq!(invoice, deserialized_invoice);
assert_eq!(invoice_str, deserialized_invoice.to_string().as_str());
assert_eq!(invoice_str, serialized_invoice.as_str().trim_matches('\"'));
}
#[test]
fn raw_tagged_field_ordering() {
use crate::{
sha256, Description, Fe32, RawTaggedField, Sha256, TaggedField, UntrustedString,
};
let field10 = RawTaggedField::KnownSemantics(TaggedField::PaymentHash(Sha256(
sha256::Hash::from_str(
"0001020304050607080900010203040506070809000102030405060708090102",
)
.unwrap(),
)));
let field11 = RawTaggedField::KnownSemantics(TaggedField::Description(Description(
UntrustedString("Description".to_string()),
)));
let field20 = RawTaggedField::UnknownSemantics(vec![Fe32::Q]);
let field21 = RawTaggedField::UnknownSemantics(vec![Fe32::R]);
assert!(field10 < field20);
assert!(field20 > field10);
assert_eq!(field10.cmp(&field20), std::cmp::Ordering::Less);
assert_eq!(field20.cmp(&field10), std::cmp::Ordering::Greater);
assert_eq!(field10.cmp(&field10), std::cmp::Ordering::Equal);
assert_eq!(field20.cmp(&field20), std::cmp::Ordering::Equal);
assert_eq!(field10.partial_cmp(&field20).unwrap(), std::cmp::Ordering::Less);
assert_eq!(field20.partial_cmp(&field10).unwrap(), std::cmp::Ordering::Greater);
assert_eq!(field10.partial_cmp(&field11).unwrap(), std::cmp::Ordering::Less);
assert_eq!(field20.partial_cmp(&field21).unwrap(), std::cmp::Ordering::Less);
}
}