use core::borrow::Borrow;
use core::hash::{Hash, Hasher};
use core::marker::PhantomData;
use core::{cmp, fmt};
use alloc::vec;
use alloc::vec::Vec;
use bech32::{u5, Base32Len, FromBase32, ToBase32, WriteBase32};
mod sealed {
use super::Features;
use alloc::vec::Vec;
pub trait Context {
const KNOWN_FEATURE_MASK: &'static [u8];
}
macro_rules! define_context {
($context: ident, [$( $( $known_feature: ident )|*, )*]) => {
#[derive(Eq, PartialEq)]
pub struct $context {}
impl Context for $context {
const KNOWN_FEATURE_MASK: &'static [u8] = &[
$(
0b00_00_00_00 $(|
<Self as $known_feature>::REQUIRED_MASK |
<Self as $known_feature>::OPTIONAL_MASK)*,
)*
];
}
impl alloc::fmt::Display for Features<$context> {
fn fmt(&self, fmt: &mut alloc::fmt::Formatter) -> Result<(), alloc::fmt::Error> {
$(
$(
fmt.write_fmt(format_args!("{}: {}, ", stringify!($known_feature),
if <$context as $known_feature>::requires_feature(&self.flags) { "required" }
else if <$context as $known_feature>::supports_feature(&self.flags) { "supported" }
else { "not supported" }))?;
)*
{} )*
fmt.write_fmt(format_args!("unknown flags: {}",
if self.requires_unknown_bits() { "required" }
else if self.supports_unknown_bits() { "supported" } else { "none" }))
}
}
};
}
define_context!(
InitContext,
[
DataLossProtect | InitialRoutingSync | UpfrontShutdownScript | GossipQueries,
VariableLengthOnion | StaticRemoteKey | PaymentSecret,
BasicMPP | Wumbo | AnchorsNonzeroFeeHtlcTx | AnchorsZeroFeeHtlcTx,
RouteBlinding | ShutdownAnySegwit | Taproot,
OnionMessages,
ChannelType | SCIDPrivacy,
ZeroConf,
Trampoline,
]
);
define_context!(
NodeContext,
[
DataLossProtect | UpfrontShutdownScript | GossipQueries,
VariableLengthOnion | StaticRemoteKey | PaymentSecret,
BasicMPP | Wumbo | AnchorsNonzeroFeeHtlcTx | AnchorsZeroFeeHtlcTx,
RouteBlinding | ShutdownAnySegwit | Taproot,
OnionMessages,
ChannelType | SCIDPrivacy,
ZeroConf | Keysend,
Trampoline,
]
);
define_context!(ChannelContext, []);
define_context!(Bolt11InvoiceContext, [
,
VariableLengthOnion | PaymentSecret,
BasicMPP,
,
,
,
PaymentMetadata,
Trampoline,
]);
define_context!(OfferContext, []);
define_context!(InvoiceRequestContext, []);
define_context!(Bolt12InvoiceContext, [
,
,
BasicMPP,
]);
define_context!(BlindedHopContext, []);
define_context!(ChannelTypeContext, [
,
StaticRemoteKey,
AnchorsNonzeroFeeHtlcTx | AnchorsZeroFeeHtlcTx,
Taproot,
,
SCIDPrivacy,
ZeroConf,
]);
macro_rules! define_feature {
($odd_bit: expr, $feature: ident, [$($context: ty),+], $doc: expr, $optional_setter: ident,
$required_setter: ident, $supported_getter: ident) => {
#[doc = $doc]
pub trait $feature: Context {
const EVEN_BIT: usize = $odd_bit - 1;
const ODD_BIT: usize = $odd_bit;
const ASSERT_EVEN_BIT_PARITY: usize;
const ASSERT_ODD_BIT_PARITY: usize;
#[cfg(not(any(test, feature = "_test_utils")))] const ASSERT_BITS_IN_MASK: u8;
const BYTE_OFFSET: usize = Self::EVEN_BIT / 8;
const REQUIRED_MASK: u8 = 1 << (Self::EVEN_BIT - 8 * Self::BYTE_OFFSET);
const OPTIONAL_MASK: u8 = 1 << (Self::ODD_BIT - 8 * Self::BYTE_OFFSET);
#[inline]
fn requires_feature(flags: &Vec<u8>) -> bool {
flags.len() > Self::BYTE_OFFSET &&
(flags[Self::BYTE_OFFSET] & Self::REQUIRED_MASK) != 0
}
#[inline]
fn supports_feature(flags: &Vec<u8>) -> bool {
flags.len() > Self::BYTE_OFFSET &&
(flags[Self::BYTE_OFFSET] & (Self::REQUIRED_MASK | Self::OPTIONAL_MASK)) != 0
}
#[inline]
fn set_required_bit(flags: &mut Vec<u8>) {
if flags.len() <= Self::BYTE_OFFSET {
flags.resize(Self::BYTE_OFFSET + 1, 0u8);
}
flags[Self::BYTE_OFFSET] |= Self::REQUIRED_MASK;
flags[Self::BYTE_OFFSET] &= !Self::OPTIONAL_MASK;
}
#[inline]
fn set_optional_bit(flags: &mut Vec<u8>) {
if flags.len() <= Self::BYTE_OFFSET {
flags.resize(Self::BYTE_OFFSET + 1, 0u8);
}
flags[Self::BYTE_OFFSET] |= Self::OPTIONAL_MASK;
}
#[inline]
fn clear_bits(flags: &mut Vec<u8>) {
if flags.len() > Self::BYTE_OFFSET {
flags[Self::BYTE_OFFSET] &= !Self::REQUIRED_MASK;
flags[Self::BYTE_OFFSET] &= !Self::OPTIONAL_MASK;
}
let last_non_zero_byte = flags.iter().rposition(|&byte| byte != 0);
let size = if let Some(offset) = last_non_zero_byte { offset + 1 } else { 0 };
flags.resize(size, 0u8);
}
}
impl <T: $feature> Features<T> {
pub fn $optional_setter(&mut self) {
<T as $feature>::set_optional_bit(&mut self.flags);
}
pub fn $required_setter(&mut self) {
<T as $feature>::set_required_bit(&mut self.flags);
}
pub fn $supported_getter(&self) -> bool {
<T as $feature>::supports_feature(&self.flags)
}
}
$(
impl $feature for $context {
const ASSERT_EVEN_BIT_PARITY: usize = 0 - (<Self as $feature>::EVEN_BIT % 2);
const ASSERT_ODD_BIT_PARITY: usize = (<Self as $feature>::ODD_BIT % 2) - 1;
#[cfg(not(any(test, feature = "_test_utils")))] const ASSERT_BITS_IN_MASK: u8 =
((<$context>::KNOWN_FEATURE_MASK[<Self as $feature>::BYTE_OFFSET] & (<Self as $feature>::REQUIRED_MASK | <Self as $feature>::OPTIONAL_MASK))
>> (<Self as $feature>::EVEN_BIT % 8)) - 3;
}
)*
};
($odd_bit: expr, $feature: ident, [$($context: ty),+], $doc: expr, $optional_setter: ident,
$required_setter: ident, $supported_getter: ident, $required_getter: ident) => {
define_feature!($odd_bit, $feature, [$($context),+], $doc, $optional_setter, $required_setter, $supported_getter);
impl <T: $feature> Features<T> {
pub fn $required_getter(&self) -> bool {
<T as $feature>::requires_feature(&self.flags)
}
}
}
}
define_feature!(
1,
DataLossProtect,
[InitContext, NodeContext],
"Feature flags for `option_data_loss_protect`.",
set_data_loss_protect_optional,
set_data_loss_protect_required,
supports_data_loss_protect,
requires_data_loss_protect
);
define_feature!(
3,
InitialRoutingSync,
[InitContext],
"Feature flags for `initial_routing_sync`.",
set_initial_routing_sync_optional,
set_initial_routing_sync_required,
initial_routing_sync
);
define_feature!(
5,
UpfrontShutdownScript,
[InitContext, NodeContext],
"Feature flags for `option_upfront_shutdown_script`.",
set_upfront_shutdown_script_optional,
set_upfront_shutdown_script_required,
supports_upfront_shutdown_script,
requires_upfront_shutdown_script
);
define_feature!(
7,
GossipQueries,
[InitContext, NodeContext],
"Feature flags for `gossip_queries`.",
set_gossip_queries_optional,
set_gossip_queries_required,
supports_gossip_queries,
requires_gossip_queries
);
define_feature!(
9,
VariableLengthOnion,
[InitContext, NodeContext, Bolt11InvoiceContext],
"Feature flags for `var_onion_optin`.",
set_variable_length_onion_optional,
set_variable_length_onion_required,
supports_variable_length_onion,
requires_variable_length_onion
);
define_feature!(
13,
StaticRemoteKey,
[InitContext, NodeContext, ChannelTypeContext],
"Feature flags for `option_static_remotekey`.",
set_static_remote_key_optional,
set_static_remote_key_required,
supports_static_remote_key,
requires_static_remote_key
);
define_feature!(
15,
PaymentSecret,
[InitContext, NodeContext, Bolt11InvoiceContext],
"Feature flags for `payment_secret`.",
set_payment_secret_optional,
set_payment_secret_required,
supports_payment_secret,
requires_payment_secret
);
define_feature!(
17,
BasicMPP,
[InitContext, NodeContext, Bolt11InvoiceContext, Bolt12InvoiceContext],
"Feature flags for `basic_mpp`.",
set_basic_mpp_optional,
set_basic_mpp_required,
supports_basic_mpp,
requires_basic_mpp
);
define_feature!(
19,
Wumbo,
[InitContext, NodeContext],
"Feature flags for `option_support_large_channel` (aka wumbo channels).",
set_wumbo_optional,
set_wumbo_required,
supports_wumbo,
requires_wumbo
);
define_feature!(
21,
AnchorsNonzeroFeeHtlcTx,
[InitContext, NodeContext, ChannelTypeContext],
"Feature flags for `option_anchors_nonzero_fee_htlc_tx`.",
set_anchors_nonzero_fee_htlc_tx_optional,
set_anchors_nonzero_fee_htlc_tx_required,
supports_anchors_nonzero_fee_htlc_tx,
requires_anchors_nonzero_fee_htlc_tx
);
define_feature!(
23,
AnchorsZeroFeeHtlcTx,
[InitContext, NodeContext, ChannelTypeContext],
"Feature flags for `option_anchors_zero_fee_htlc_tx`.",
set_anchors_zero_fee_htlc_tx_optional,
set_anchors_zero_fee_htlc_tx_required,
supports_anchors_zero_fee_htlc_tx,
requires_anchors_zero_fee_htlc_tx
);
define_feature!(
25,
RouteBlinding,
[InitContext, NodeContext],
"Feature flags for `option_route_blinding`.",
set_route_blinding_optional,
set_route_blinding_required,
supports_route_blinding,
requires_route_blinding
);
define_feature!(
27,
ShutdownAnySegwit,
[InitContext, NodeContext],
"Feature flags for `opt_shutdown_anysegwit`.",
set_shutdown_any_segwit_optional,
set_shutdown_any_segwit_required,
supports_shutdown_anysegwit,
requires_shutdown_anysegwit
);
define_feature!(
31,
Taproot,
[InitContext, NodeContext, ChannelTypeContext],
"Feature flags for `option_taproot`.",
set_taproot_optional,
set_taproot_required,
supports_taproot,
requires_taproot
);
define_feature!(
39,
OnionMessages,
[InitContext, NodeContext],
"Feature flags for `option_onion_messages`.",
set_onion_messages_optional,
set_onion_messages_required,
supports_onion_messages,
requires_onion_messages
);
define_feature!(
45,
ChannelType,
[InitContext, NodeContext],
"Feature flags for `option_channel_type`.",
set_channel_type_optional,
set_channel_type_required,
supports_channel_type,
requires_channel_type
);
define_feature!(47, SCIDPrivacy, [InitContext, NodeContext, ChannelTypeContext],
"Feature flags for only forwarding with SCID aliasing. Called `option_scid_alias` in the BOLTs",
set_scid_privacy_optional, set_scid_privacy_required, supports_scid_privacy, requires_scid_privacy);
define_feature!(
49,
PaymentMetadata,
[Bolt11InvoiceContext],
"Feature flags for payment metadata in invoices.",
set_payment_metadata_optional,
set_payment_metadata_required,
supports_payment_metadata,
requires_payment_metadata
);
define_feature!(51, ZeroConf, [InitContext, NodeContext, ChannelTypeContext],
"Feature flags for accepting channels with zero confirmations. Called `option_zeroconf` in the BOLTs",
set_zero_conf_optional, set_zero_conf_required, supports_zero_conf, requires_zero_conf);
define_feature!(
55,
Keysend,
[NodeContext],
"Feature flags for keysend payments.",
set_keysend_optional,
set_keysend_required,
supports_keysend,
requires_keysend
);
define_feature!(
57,
Trampoline,
[InitContext, NodeContext, Bolt11InvoiceContext],
"Feature flags for Trampoline routing.",
set_trampoline_routing_optional,
set_trampoline_routing_required,
supports_trampoline_routing,
requires_trampoline_routing
);
#[cfg(any(test, feature = "_test_utils"))]
define_feature!(
12345,
UnknownFeature,
[
NodeContext,
ChannelContext,
Bolt11InvoiceContext,
OfferContext,
InvoiceRequestContext,
Bolt12InvoiceContext,
BlindedHopContext
],
"Feature flags for an unknown feature used in testing.",
set_unknown_feature_optional,
set_unknown_feature_required,
supports_unknown_test_feature,
requires_unknown_test_feature
);
}
const ANY_REQUIRED_FEATURES_MASK: u8 = 0b01_01_01_01;
const ANY_OPTIONAL_FEATURES_MASK: u8 = 0b10_10_10_10;
#[derive(Eq)]
pub struct Features<T: sealed::Context> {
flags: Vec<u8>,
mark: PhantomData<T>,
}
impl<T: sealed::Context, Rhs: Borrow<Self>> core::ops::BitOrAssign<Rhs> for Features<T> {
fn bitor_assign(&mut self, rhs: Rhs) {
let total_feature_len = cmp::max(self.flags.len(), rhs.borrow().flags.len());
self.flags.resize(total_feature_len, 0u8);
for (byte, rhs_byte) in self.flags.iter_mut().zip(rhs.borrow().flags.iter()) {
*byte |= *rhs_byte;
}
}
}
impl<T: sealed::Context> core::ops::BitOr for Features<T> {
type Output = Self;
fn bitor(mut self, o: Self) -> Self {
self |= o;
self
}
}
impl<T: sealed::Context> Clone for Features<T> {
fn clone(&self) -> Self {
Self { flags: self.flags.clone(), mark: PhantomData }
}
}
impl<T: sealed::Context> Hash for Features<T> {
fn hash<H: Hasher>(&self, hasher: &mut H) {
let mut nonzero_flags = &self.flags[..];
while nonzero_flags.last() == Some(&0) {
nonzero_flags = &nonzero_flags[..nonzero_flags.len() - 1];
}
nonzero_flags.hash(hasher);
}
}
impl<T: sealed::Context> PartialEq for Features<T> {
fn eq(&self, o: &Self) -> bool {
let mut o_iter = o.flags.iter();
let mut self_iter = self.flags.iter();
loop {
match (o_iter.next(), self_iter.next()) {
(Some(o), Some(us)) => {
if o != us {
return false;
}
},
(Some(b), None) | (None, Some(b)) => {
if *b != 0 {
return false;
}
},
(None, None) => return true,
}
}
}
}
impl<T: sealed::Context> PartialOrd for Features<T> {
fn partial_cmp(&self, other: &Self) -> Option<cmp::Ordering> {
self.flags.partial_cmp(&other.flags)
}
}
impl<T: sealed::Context + Eq> Ord for Features<T> {
fn cmp(&self, other: &Self) -> cmp::Ordering {
self.flags.cmp(&other.flags)
}
}
impl<T: sealed::Context> fmt::Debug for Features<T> {
fn fmt(&self, fmt: &mut fmt::Formatter) -> Result<(), fmt::Error> {
self.flags.fmt(fmt)
}
}
pub type InitFeatures = Features<sealed::InitContext>;
pub type NodeFeatures = Features<sealed::NodeContext>;
pub type ChannelFeatures = Features<sealed::ChannelContext>;
pub type Bolt11InvoiceFeatures = Features<sealed::Bolt11InvoiceContext>;
pub type OfferFeatures = Features<sealed::OfferContext>;
pub type InvoiceRequestFeatures = Features<sealed::InvoiceRequestContext>;
pub type Bolt12InvoiceFeatures = Features<sealed::Bolt12InvoiceContext>;
pub type BlindedHopFeatures = Features<sealed::BlindedHopContext>;
pub type ChannelTypeFeatures = Features<sealed::ChannelTypeContext>;
impl InitFeatures {
#[doc(hidden)]
pub fn to_context<C: sealed::Context>(&self) -> Features<C> {
self.to_context_internal()
}
}
impl Bolt11InvoiceFeatures {
#[doc(hidden)]
pub fn to_context<C: sealed::Context>(&self) -> Features<C> {
self.to_context_internal()
}
pub fn for_keysend(allow_mpp: bool) -> Bolt11InvoiceFeatures {
let mut res = Bolt11InvoiceFeatures::empty();
res.set_variable_length_onion_optional();
if allow_mpp {
res.set_basic_mpp_optional();
}
res
}
}
impl Bolt12InvoiceFeatures {
#[doc(hidden)]
pub fn to_context<C: sealed::Context>(&self) -> Features<C> {
self.to_context_internal()
}
}
impl ChannelTypeFeatures {
#[doc(hidden)]
pub fn from_init(init: &InitFeatures) -> Self {
let mut ret = init.to_context_internal();
for byte in ret.flags.iter_mut() {
*byte |= (*byte & ANY_OPTIONAL_FEATURES_MASK) >> 1;
*byte &= ANY_REQUIRED_FEATURES_MASK;
}
ret
}
pub fn only_static_remote_key() -> Self {
let mut ret = Self::empty();
<sealed::ChannelTypeContext as sealed::StaticRemoteKey>::set_required_bit(&mut ret.flags);
ret
}
pub fn anchors_zero_htlc_fee_and_dependencies() -> Self {
let mut ret = Self::empty();
<sealed::ChannelTypeContext as sealed::StaticRemoteKey>::set_required_bit(&mut ret.flags);
<sealed::ChannelTypeContext as sealed::AnchorsZeroFeeHtlcTx>::set_required_bit(
&mut ret.flags,
);
ret
}
}
impl ToBase32 for Bolt11InvoiceFeatures {
fn write_base32<W: WriteBase32>(&self, writer: &mut W) -> Result<(), <W as WriteBase32>::Err> {
let length_u5s = (self.flags.len() * 8 + 4) / 5 as usize;
let mut res_u5s: Vec<u5> = vec![u5::try_from_u8(0).unwrap(); length_u5s];
for (byte_idx, byte) in self.flags.iter().enumerate() {
let bit_pos_from_left_0_indexed = byte_idx * 8;
let new_u5_idx = length_u5s - (bit_pos_from_left_0_indexed / 5) as usize - 1;
let new_bit_pos = bit_pos_from_left_0_indexed % 5;
let shifted_chunk_u16 = (*byte as u16) << new_bit_pos;
let curr_u5_as_u8 = res_u5s[new_u5_idx].to_u8();
res_u5s[new_u5_idx] =
u5::try_from_u8(curr_u5_as_u8 | ((shifted_chunk_u16 & 0x001f) as u8)).unwrap();
if new_u5_idx > 0 {
let curr_u5_as_u8 = res_u5s[new_u5_idx - 1].to_u8();
res_u5s[new_u5_idx - 1] =
u5::try_from_u8(curr_u5_as_u8 | (((shifted_chunk_u16 >> 5) & 0x001f) as u8))
.unwrap();
}
if new_u5_idx > 1 {
let curr_u5_as_u8 = res_u5s[new_u5_idx - 2].to_u8();
res_u5s[new_u5_idx - 2] =
u5::try_from_u8(curr_u5_as_u8 | (((shifted_chunk_u16 >> 10) & 0x001f) as u8))
.unwrap();
}
}
while !res_u5s.is_empty() && res_u5s[0] == u5::try_from_u8(0).unwrap() {
res_u5s.remove(0);
}
writer.write(&res_u5s)
}
}
impl Base32Len for Bolt11InvoiceFeatures {
fn base32_len(&self) -> usize {
self.to_base32().len()
}
}
impl FromBase32 for Bolt11InvoiceFeatures {
type Err = bech32::Error;
fn from_base32(field_data: &[u5]) -> Result<Bolt11InvoiceFeatures, bech32::Error> {
let length_bytes = (field_data.len() * 5 + 7) / 8 as usize;
let mut res_bytes: Vec<u8> = vec![0; length_bytes];
for (u5_idx, chunk) in field_data.iter().enumerate() {
let bit_pos_from_right_0_indexed = (field_data.len() - u5_idx - 1) * 5;
let new_byte_idx = (bit_pos_from_right_0_indexed / 8) as usize;
let new_bit_pos = bit_pos_from_right_0_indexed % 8;
let chunk_u16 = chunk.to_u8() as u16;
res_bytes[new_byte_idx] |= ((chunk_u16 << new_bit_pos) & 0xff) as u8;
if new_byte_idx != length_bytes - 1 {
res_bytes[new_byte_idx + 1] |= ((chunk_u16 >> (8 - new_bit_pos)) & 0xff) as u8;
}
}
while !res_bytes.is_empty() && res_bytes[res_bytes.len() - 1] == 0 {
res_bytes.pop();
}
Ok(Bolt11InvoiceFeatures::from_le_bytes(res_bytes))
}
}
impl<T: sealed::Context> Features<T> {
pub fn empty() -> Self {
Features { flags: Vec::new(), mark: PhantomData }
}
fn to_context_internal<C: sealed::Context>(&self) -> Features<C> {
let from_byte_count = T::KNOWN_FEATURE_MASK.len();
let to_byte_count = C::KNOWN_FEATURE_MASK.len();
let mut flags = Vec::new();
for (i, byte) in self.flags.iter().enumerate() {
if i < from_byte_count && i < to_byte_count {
let from_known_features = T::KNOWN_FEATURE_MASK[i];
let to_known_features = C::KNOWN_FEATURE_MASK[i];
flags.push(byte & from_known_features & to_known_features);
}
}
Features::<C> { flags, mark: PhantomData }
}
pub fn from_le_bytes(flags: Vec<u8>) -> Features<T> {
Features { flags, mark: PhantomData }
}
pub fn le_flags(&self) -> &[u8] {
&self.flags
}
pub fn from_be_bytes(mut flags: Vec<u8>) -> Features<T> {
flags.reverse(); Self { flags, mark: PhantomData }
}
pub fn supports_any_optional_bits(&self) -> bool {
self.flags.iter().any(|&byte| (byte & ANY_OPTIONAL_FEATURES_MASK) != 0)
}
pub fn requires_unknown_bits_from(&self, other: &Self) -> bool {
self.flags.iter().enumerate().any(|(i, &byte)| {
let unknown_features = unset_features_mask_at_position(other, i);
(byte & (ANY_REQUIRED_FEATURES_MASK & unknown_features)) != 0
})
}
pub fn required_unknown_bits_from(&self, other: &Self) -> Vec<u64> {
let mut unknown_bits = Vec::new();
self.flags.iter().enumerate().for_each(|(i, &byte)| {
let unknown_features = unset_features_mask_at_position(other, i);
if byte & unknown_features != 0 {
for bit in (0..8).step_by(2) {
if ((byte & unknown_features) >> bit) & 1 == 1 {
unknown_bits.push((i as u64) * 8 + bit);
}
}
}
});
unknown_bits
}
pub fn requires_unknown_bits(&self) -> bool {
let mut known_chunks = T::KNOWN_FEATURE_MASK.chunks(8);
for chunk in self.flags.chunks(8) {
let mut flag_bytes = [0; 8];
flag_bytes[..chunk.len()].copy_from_slice(&chunk);
let flag_int = u64::from_le_bytes(flag_bytes);
let known_chunk = known_chunks.next().unwrap_or(&[0; 0]);
let mut known_bytes = [0; 8];
known_bytes[..known_chunk.len()].copy_from_slice(&known_chunk);
let known_int = u64::from_le_bytes(known_bytes);
const REQ_MASK: u64 = u64::from_le_bytes([ANY_REQUIRED_FEATURES_MASK; 8]);
if flag_int & (REQ_MASK & !known_int) != 0 {
return true;
}
}
false
}
pub fn supports_unknown_bits(&self) -> bool {
let byte_count = T::KNOWN_FEATURE_MASK.len();
self.flags.iter().enumerate().any(|(i, &byte)| {
let unknown_features =
if i < byte_count { !T::KNOWN_FEATURE_MASK[i] } else { 0b11_11_11_11 };
(byte & unknown_features) != 0
})
}
pub fn set_required_feature_bit(&mut self, bit: usize) -> Result<(), ()> {
self.set_feature_bit(bit - (bit % 2))
}
pub fn set_optional_feature_bit(&mut self, bit: usize) -> Result<(), ()> {
self.set_feature_bit(bit + (1 - (bit % 2)))
}
fn set_feature_bit(&mut self, bit: usize) -> Result<(), ()> {
if bit > 255 {
return Err(());
}
self.set_bit(bit, false)
}
pub fn set_required_custom_bit(&mut self, bit: usize) -> Result<(), ()> {
self.set_custom_bit(bit - (bit % 2))
}
pub fn set_optional_custom_bit(&mut self, bit: usize) -> Result<(), ()> {
self.set_custom_bit(bit + (1 - (bit % 2)))
}
fn set_custom_bit(&mut self, bit: usize) -> Result<(), ()> {
if bit < 256 {
return Err(());
}
self.set_bit(bit, true)
}
fn set_bit(&mut self, bit: usize, custom: bool) -> Result<(), ()> {
let byte_offset = bit / 8;
let mask = 1 << (bit - 8 * byte_offset);
if byte_offset < T::KNOWN_FEATURE_MASK.len() && custom {
if (T::KNOWN_FEATURE_MASK[byte_offset] & mask) != 0 {
return Err(());
}
}
if self.flags.len() <= byte_offset {
self.flags.resize(byte_offset + 1, 0u8);
}
self.flags[byte_offset] |= mask;
Ok(())
}
}
impl<T: sealed::UpfrontShutdownScript> Features<T> {
pub fn clear_upfront_shutdown_script(mut self) -> Self {
<T as sealed::UpfrontShutdownScript>::clear_bits(&mut self.flags);
self
}
}
impl<T: sealed::ShutdownAnySegwit> Features<T> {
pub fn clear_shutdown_anysegwit(mut self) -> Self {
<T as sealed::ShutdownAnySegwit>::clear_bits(&mut self.flags);
self
}
}
impl<T: sealed::Wumbo> Features<T> {
pub fn clear_wumbo(mut self) -> Self {
<T as sealed::Wumbo>::clear_bits(&mut self.flags);
self
}
}
impl<T: sealed::SCIDPrivacy> Features<T> {
pub fn clear_scid_privacy(&mut self) {
<T as sealed::SCIDPrivacy>::clear_bits(&mut self.flags);
}
}
impl<T: sealed::AnchorsZeroFeeHtlcTx> Features<T> {
pub fn clear_anchors_zero_fee_htlc_tx(&mut self) {
<T as sealed::AnchorsZeroFeeHtlcTx>::clear_bits(&mut self.flags);
}
}
impl<T: sealed::RouteBlinding> Features<T> {
pub fn clear_route_blinding(&mut self) {
<T as sealed::RouteBlinding>::clear_bits(&mut self.flags);
}
}
#[cfg(any(test, feature = "_test_utils"))]
impl<T: sealed::UnknownFeature> Features<T> {
pub fn unknown() -> Self {
let mut features = Self::empty();
features.set_unknown_feature_required();
features
}
}
pub(crate) fn unset_features_mask_at_position<T: sealed::Context>(
other: &Features<T>, index: usize,
) -> u8 {
if index < other.flags.len() {
!(other.flags[index]
| ((other.flags[index] >> 1) & ANY_REQUIRED_FEATURES_MASK)
| ((other.flags[index] << 1) & ANY_OPTIONAL_FEATURES_MASK))
} else {
0b11_11_11_11
}
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn sanity_test_unknown_bits() {
let features = ChannelFeatures::empty();
assert!(!features.requires_unknown_bits());
assert!(!features.supports_unknown_bits());
let mut features = ChannelFeatures::empty();
features.set_unknown_feature_required();
assert!(features.requires_unknown_bits());
assert!(features.supports_unknown_bits());
assert_eq!(features.required_unknown_bits_from(&ChannelFeatures::empty()), vec![12344]);
let mut features = ChannelFeatures::empty();
features.set_unknown_feature_optional();
assert!(!features.requires_unknown_bits());
assert!(features.supports_unknown_bits());
assert_eq!(features.required_unknown_bits_from(&ChannelFeatures::empty()), vec![]);
let mut features = ChannelFeatures::empty();
features.set_unknown_feature_required();
features.set_custom_bit(12346).unwrap();
assert!(features.requires_unknown_bits());
assert!(features.supports_unknown_bits());
assert_eq!(
features.required_unknown_bits_from(&ChannelFeatures::empty()),
vec![12344, 12346]
);
let mut limiter = ChannelFeatures::empty();
limiter.set_unknown_feature_optional();
assert_eq!(features.required_unknown_bits_from(&limiter), vec![12346]);
}
#[test]
fn requires_unknown_bits_from() {
let mut features1 = InitFeatures::empty();
let mut features2 = InitFeatures::empty();
assert!(!features1.requires_unknown_bits_from(&features2));
assert!(!features2.requires_unknown_bits_from(&features1));
features1.set_data_loss_protect_required();
assert!(features1.requires_unknown_bits_from(&features2));
assert!(!features2.requires_unknown_bits_from(&features1));
features2.set_data_loss_protect_optional();
assert!(!features1.requires_unknown_bits_from(&features2));
assert!(!features2.requires_unknown_bits_from(&features1));
features2.set_gossip_queries_required();
assert!(!features1.requires_unknown_bits_from(&features2));
assert!(features2.requires_unknown_bits_from(&features1));
features1.set_gossip_queries_optional();
assert!(!features1.requires_unknown_bits_from(&features2));
assert!(!features2.requires_unknown_bits_from(&features1));
features1.set_variable_length_onion_required();
assert!(features1.requires_unknown_bits_from(&features2));
assert!(!features2.requires_unknown_bits_from(&features1));
features2.set_variable_length_onion_optional();
assert!(!features1.requires_unknown_bits_from(&features2));
assert!(!features2.requires_unknown_bits_from(&features1));
features1.set_basic_mpp_required();
features2.set_wumbo_required();
assert!(features1.requires_unknown_bits_from(&features2));
assert!(features2.requires_unknown_bits_from(&features1));
}
#[test]
fn convert_to_context_with_relevant_flags() {
let mut init_features = InitFeatures::empty();
init_features.set_initial_routing_sync_required();
init_features.set_data_loss_protect_required();
init_features.set_variable_length_onion_required();
init_features.set_static_remote_key_required();
init_features.set_payment_secret_required();
init_features.set_basic_mpp_optional();
init_features.set_wumbo_optional();
init_features.set_anchors_zero_fee_htlc_tx_optional();
init_features.set_route_blinding_optional();
init_features.set_shutdown_any_segwit_optional();
init_features.set_onion_messages_optional();
init_features.set_channel_type_optional();
init_features.set_scid_privacy_optional();
init_features.set_zero_conf_optional();
assert!(init_features.initial_routing_sync());
assert!(!init_features.supports_upfront_shutdown_script());
assert!(!init_features.supports_gossip_queries());
let node_features: NodeFeatures = init_features.to_context();
{
assert_eq!(node_features.flags.len(), 7);
assert_eq!(node_features.flags[0], 0b00000001);
assert_eq!(node_features.flags[1], 0b01010001);
assert_eq!(node_features.flags[2], 0b10001010);
assert_eq!(node_features.flags[3], 0b00001010);
assert_eq!(node_features.flags[4], 0b10000000);
assert_eq!(node_features.flags[5], 0b10100000);
assert_eq!(node_features.flags[6], 0b00001000);
}
let features: InitFeatures = node_features.to_context_internal();
assert!(!features.initial_routing_sync());
assert!(!features.supports_upfront_shutdown_script());
assert!(!init_features.supports_gossip_queries());
}
#[test]
fn convert_to_context_with_unknown_flags() {
assert!(
<sealed::ChannelContext as sealed::Context>::KNOWN_FEATURE_MASK.len()
< <sealed::Bolt11InvoiceContext as sealed::Context>::KNOWN_FEATURE_MASK.len()
);
let mut channel_features = ChannelFeatures::empty();
channel_features.set_unknown_feature_optional();
assert!(channel_features.supports_unknown_bits());
let invoice_features: Bolt11InvoiceFeatures = channel_features.to_context_internal();
assert!(!invoice_features.supports_unknown_bits());
}
#[test]
fn set_feature_bits() {
let mut features = Bolt11InvoiceFeatures::empty();
features.set_basic_mpp_optional();
features.set_payment_secret_required();
assert!(features.supports_basic_mpp());
assert!(!features.requires_basic_mpp());
assert!(features.requires_payment_secret());
assert!(features.supports_payment_secret());
let mut features = NodeFeatures::empty();
assert!(features.set_optional_feature_bit(55).is_ok());
assert!(features.supports_keysend());
assert!(features.set_optional_feature_bit(255).is_ok());
assert!(features.set_required_feature_bit(256).is_err());
}
#[test]
fn set_custom_bits() {
let mut features = Bolt11InvoiceFeatures::empty();
features.set_variable_length_onion_optional();
assert_eq!(features.flags[1], 0b00000010);
assert!(features.set_optional_custom_bit(255).is_err());
assert!(features.set_required_custom_bit(256).is_ok());
assert!(features.set_required_custom_bit(258).is_ok());
assert_eq!(features.flags[31], 0b00000000);
assert_eq!(features.flags[32], 0b00000101);
let known_bit = <sealed::Bolt11InvoiceContext as sealed::PaymentSecret>::EVEN_BIT;
let byte_offset = <sealed::Bolt11InvoiceContext as sealed::PaymentSecret>::BYTE_OFFSET;
assert_eq!(byte_offset, 1);
assert_eq!(features.flags[byte_offset], 0b00000010);
assert!(features.set_required_custom_bit(known_bit).is_err());
assert_eq!(features.flags[byte_offset], 0b00000010);
let mut features = Bolt11InvoiceFeatures::empty();
assert!(features.set_optional_custom_bit(256).is_ok());
assert!(features.set_optional_custom_bit(259).is_ok());
assert_eq!(features.flags[32], 0b00001010);
let mut features = Bolt11InvoiceFeatures::empty();
assert!(features.set_required_custom_bit(257).is_ok());
assert!(features.set_required_custom_bit(258).is_ok());
assert_eq!(features.flags[32], 0b00000101);
}
#[test]
fn invoice_features_encoding() {
let features_as_u5s = vec![
u5::try_from_u8(6).unwrap(),
u5::try_from_u8(10).unwrap(),
u5::try_from_u8(25).unwrap(),
u5::try_from_u8(1).unwrap(),
u5::try_from_u8(10).unwrap(),
u5::try_from_u8(0).unwrap(),
u5::try_from_u8(20).unwrap(),
u5::try_from_u8(2).unwrap(),
u5::try_from_u8(0).unwrap(),
u5::try_from_u8(6).unwrap(),
u5::try_from_u8(0).unwrap(),
u5::try_from_u8(16).unwrap(),
u5::try_from_u8(1).unwrap(),
];
let features = Bolt11InvoiceFeatures::from_le_bytes(vec![1, 2, 3, 4, 5, 42, 100, 101]);
assert_eq!(features.base32_len(), 13);
let features_serialized = features.to_base32();
assert_eq!(features_as_u5s, features_serialized);
let features_deserialized = Bolt11InvoiceFeatures::from_base32(&features_as_u5s).unwrap();
assert_eq!(features, features_deserialized);
}
#[test]
fn test_channel_type_mapping() {
let mut init_features = InitFeatures::empty();
init_features.set_static_remote_key_optional();
let converted_features = ChannelTypeFeatures::from_init(&init_features);
assert_eq!(converted_features, ChannelTypeFeatures::only_static_remote_key());
assert!(!converted_features.supports_any_optional_bits());
assert!(converted_features.requires_static_remote_key());
}
#[test]
fn test_excess_zero_bytes_ignored() {
use std::collections::hash_map::DefaultHasher;
use std::hash::{Hash, Hasher};
let mut zerod_features = InitFeatures::empty();
zerod_features.flags = vec![0];
let empty_features = InitFeatures::empty();
assert!(empty_features.flags.is_empty());
assert_eq!(zerod_features, empty_features);
let mut zerod_hash = DefaultHasher::new();
zerod_features.hash(&mut zerod_hash);
let mut empty_hash = DefaultHasher::new();
empty_features.hash(&mut empty_hash);
assert_eq!(zerod_hash.finish(), empty_hash.finish());
}
}