use std::{cmp, fmt};
use std::marker::PhantomData;
use ln::msgs::DecodeError;
use util::ser::{Readable, Writeable, Writer};
mod sealed {
pub trait Context {
const KNOWN_FEATURE_FLAGS: &'static [u8];
const KNOWN_FEATURE_MASK: &'static [u8];
}
macro_rules! define_context {
($context: ident {
required_features: [$( $( $required_feature: ident )|*, )*],
optional_features: [$( $( $optional_feature: ident )|*, )*],
}) => {
pub struct $context {}
impl Context for $context {
const KNOWN_FEATURE_FLAGS: &'static [u8] = &[
$(
0b00_00_00_00 $(|
<Self as $required_feature>::REQUIRED_MASK)*
$(|
<Self as $optional_feature>::OPTIONAL_MASK)*,
)*
];
const KNOWN_FEATURE_MASK: &'static [u8] = &[
$(
0b00_00_00_00 $(|
<Self as $required_feature>::REQUIRED_MASK |
<Self as $required_feature>::OPTIONAL_MASK)*
$(|
<Self as $optional_feature>::REQUIRED_MASK |
<Self as $optional_feature>::OPTIONAL_MASK)*,
)*
];
}
};
}
define_context!(InitContext {
required_features: [
,
StaticRemoteKey,
,
,
],
optional_features: [
DataLossProtect | InitialRoutingSync | UpfrontShutdownScript | GossipQueries,
VariableLengthOnion | PaymentSecret,
BasicMPP,
ShutdownAnySegwit,
],
});
define_context!(NodeContext {
required_features: [
,
StaticRemoteKey,
,
,
],
optional_features: [
DataLossProtect | UpfrontShutdownScript | GossipQueries,
VariableLengthOnion | PaymentSecret,
BasicMPP,
ShutdownAnySegwit,
],
});
define_context!(ChannelContext {
required_features: [],
optional_features: [],
});
define_context!(InvoiceContext {
required_features: [,,,],
optional_features: [
,
VariableLengthOnion | PaymentSecret,
BasicMPP,
],
});
macro_rules! define_feature {
($odd_bit: expr, $feature: ident, [$($context: ty),+], $doc: expr) => {
#[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;
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;
}
#[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 $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;
}
)*
}
}
define_feature!(1, DataLossProtect, [InitContext, NodeContext],
"Feature flags for `option_data_loss_protect`.");
define_feature!(3, InitialRoutingSync, [InitContext],
"Feature flags for `initial_routing_sync`.");
define_feature!(5, UpfrontShutdownScript, [InitContext, NodeContext],
"Feature flags for `option_upfront_shutdown_script`.");
define_feature!(7, GossipQueries, [InitContext, NodeContext],
"Feature flags for `gossip_queries`.");
define_feature!(9, VariableLengthOnion, [InitContext, NodeContext, InvoiceContext],
"Feature flags for `var_onion_optin`.");
define_feature!(13, StaticRemoteKey, [InitContext, NodeContext],
"Feature flags for `option_static_remotekey`.");
define_feature!(15, PaymentSecret, [InitContext, NodeContext, InvoiceContext],
"Feature flags for `payment_secret`.");
define_feature!(17, BasicMPP, [InitContext, NodeContext, InvoiceContext],
"Feature flags for `basic_mpp`.");
define_feature!(27, ShutdownAnySegwit, [InitContext, NodeContext],
"Feature flags for `opt_shutdown_anysegwit`.");
#[cfg(test)]
define_context!(TestingContext {
required_features: [
,
,
UnknownFeature,
],
optional_features: [
,
,
,
],
});
#[cfg(test)]
define_feature!(23, UnknownFeature, [TestingContext],
"Feature flags for an unknown feature used in testing.");
}
pub struct Features<T: sealed::Context> {
flags: Vec<u8>,
mark: PhantomData<T>,
}
impl<T: sealed::Context> Clone for Features<T> {
fn clone(&self) -> Self {
Self {
flags: self.flags.clone(),
mark: PhantomData,
}
}
}
impl<T: sealed::Context> PartialEq for Features<T> {
fn eq(&self, o: &Self) -> bool {
self.flags.eq(&o.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 InvoiceFeatures = Features<sealed::InvoiceContext>;
impl InitFeatures {
pub(crate) fn write_up_to_13<W: Writer>(&self, w: &mut W) -> Result<(), ::std::io::Error> {
let len = cmp::min(2, self.flags.len());
w.size_hint(len + 2);
(len as u16).write(w)?;
for i in (0..len).rev() {
if i == 0 {
self.flags[i].write(w)?;
} else {
(self.flags[i] & 0b00_11_11_11).write(w)?;
}
}
Ok(())
}
pub(crate) fn or(mut self, o: InitFeatures) -> InitFeatures {
let total_feature_len = cmp::max(self.flags.len(), o.flags.len());
self.flags.resize(total_feature_len, 0u8);
for (byte, o_byte) in self.flags.iter_mut().zip(o.flags.iter()) {
*byte |= *o_byte;
}
self
}
pub(crate) fn to_context<C: sealed::Context>(&self) -> Features<C> {
self.to_context_internal()
}
}
impl InvoiceFeatures {
pub(crate) fn to_context<C: sealed::Context>(&self) -> Features<C> {
self.to_context_internal()
}
}
impl<T: sealed::Context> Features<T> {
pub fn empty() -> Self {
Features {
flags: Vec::new(),
mark: PhantomData,
}
}
pub fn known() -> Self {
Self {
flags: T::KNOWN_FEATURE_FLAGS.to_vec(),
mark: PhantomData,
}
}
fn to_context_internal<C: sealed::Context>(&self) -> Features<C> {
let byte_count = C::KNOWN_FEATURE_MASK.len();
let mut flags = Vec::new();
for (i, byte) in self.flags.iter().enumerate() {
if i < byte_count {
let known_source_features = T::KNOWN_FEATURE_MASK[i];
let known_target_features = C::KNOWN_FEATURE_MASK[i];
flags.push(byte & known_source_features & known_target_features);
}
}
Features::<C> { flags, mark: PhantomData, }
}
#[cfg(test)]
pub fn from_le_bytes(flags: Vec<u8>) -> Features<T> {
Features {
flags,
mark: PhantomData,
}
}
#[cfg(test)]
pub fn le_flags(&self) -> &Vec<u8> {
&self.flags
}
pub(crate) fn requires_unknown_bits(&self) -> bool {
let byte_count = T::KNOWN_FEATURE_MASK.len();
self.flags.iter().enumerate().any(|(i, &byte)| {
let required_features = 0b01_01_01_01;
let unknown_features = if i < byte_count {
!T::KNOWN_FEATURE_MASK[i]
} else {
0b11_11_11_11
};
(byte & (required_features & unknown_features)) != 0
})
}
pub(crate) 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(crate) fn byte_count(&self) -> usize {
self.flags.len()
}
#[cfg(test)]
pub(crate) fn set_required_unknown_bits(&mut self) {
<sealed::TestingContext as sealed::UnknownFeature>::set_required_bit(&mut self.flags);
}
#[cfg(test)]
pub(crate) fn set_optional_unknown_bits(&mut self) {
<sealed::TestingContext as sealed::UnknownFeature>::set_optional_bit(&mut self.flags);
}
#[cfg(test)]
pub(crate) fn clear_unknown_bits(&mut self) {
<sealed::TestingContext as sealed::UnknownFeature>::clear_bits(&mut self.flags);
}
}
impl<T: sealed::DataLossProtect> Features<T> {
#[cfg(test)]
pub(crate) fn requires_data_loss_protect(&self) -> bool {
<T as sealed::DataLossProtect>::requires_feature(&self.flags)
}
pub(crate) fn supports_data_loss_protect(&self) -> bool {
<T as sealed::DataLossProtect>::supports_feature(&self.flags)
}
}
impl<T: sealed::UpfrontShutdownScript> Features<T> {
#[cfg(test)]
pub(crate) fn requires_upfront_shutdown_script(&self) -> bool {
<T as sealed::UpfrontShutdownScript>::requires_feature(&self.flags)
}
pub(crate) fn supports_upfront_shutdown_script(&self) -> bool {
<T as sealed::UpfrontShutdownScript>::supports_feature(&self.flags)
}
#[cfg(test)]
pub(crate) fn clear_upfront_shutdown_script(mut self) -> Self {
<T as sealed::UpfrontShutdownScript>::clear_bits(&mut self.flags);
self
}
}
impl<T: sealed::GossipQueries> Features<T> {
#[cfg(test)]
pub(crate) fn requires_gossip_queries(&self) -> bool {
<T as sealed::GossipQueries>::requires_feature(&self.flags)
}
pub(crate) fn supports_gossip_queries(&self) -> bool {
<T as sealed::GossipQueries>::supports_feature(&self.flags)
}
#[cfg(test)]
pub(crate) fn clear_gossip_queries(mut self) -> Self {
<T as sealed::GossipQueries>::clear_bits(&mut self.flags);
self
}
}
impl<T: sealed::VariableLengthOnion> Features<T> {
#[cfg(test)]
pub(crate) fn requires_variable_length_onion(&self) -> bool {
<T as sealed::VariableLengthOnion>::requires_feature(&self.flags)
}
pub(crate) fn supports_variable_length_onion(&self) -> bool {
<T as sealed::VariableLengthOnion>::supports_feature(&self.flags)
}
}
impl<T: sealed::StaticRemoteKey> Features<T> {
pub(crate) fn supports_static_remote_key(&self) -> bool {
<T as sealed::StaticRemoteKey>::supports_feature(&self.flags)
}
#[cfg(test)]
pub(crate) fn requires_static_remote_key(&self) -> bool {
<T as sealed::StaticRemoteKey>::requires_feature(&self.flags)
}
}
impl<T: sealed::InitialRoutingSync> Features<T> {
pub(crate) fn initial_routing_sync(&self) -> bool {
<T as sealed::InitialRoutingSync>::supports_feature(&self.flags)
}
#[cfg(test)]
pub(crate) fn clear_initial_routing_sync(&mut self) {
<T as sealed::InitialRoutingSync>::clear_bits(&mut self.flags)
}
}
impl<T: sealed::PaymentSecret> Features<T> {
#[cfg(test)]
pub(crate) fn requires_payment_secret(&self) -> bool {
<T as sealed::PaymentSecret>::requires_feature(&self.flags)
}
#[allow(dead_code)]
pub(crate) fn supports_payment_secret(&self) -> bool {
<T as sealed::PaymentSecret>::supports_feature(&self.flags)
}
}
impl<T: sealed::BasicMPP> Features<T> {
#[cfg(test)]
pub(crate) fn requires_basic_mpp(&self) -> bool {
<T as sealed::BasicMPP>::requires_feature(&self.flags)
}
pub(crate) fn supports_basic_mpp(&self) -> bool {
<T as sealed::BasicMPP>::supports_feature(&self.flags)
}
}
impl<T: sealed::ShutdownAnySegwit> Features<T> {
pub(crate) fn supports_shutdown_anysegwit(&self) -> bool {
<T as sealed::ShutdownAnySegwit>::supports_feature(&self.flags)
}
#[cfg(test)]
pub(crate) fn clear_shutdown_anysegwit(mut self) -> Self {
<T as sealed::ShutdownAnySegwit>::clear_bits(&mut self.flags);
self
}
}
impl<T: sealed::Context> Writeable for Features<T> {
fn write<W: Writer>(&self, w: &mut W) -> Result<(), ::std::io::Error> {
w.size_hint(self.flags.len() + 2);
(self.flags.len() as u16).write(w)?;
for f in self.flags.iter().rev() { f.write(w)?;
}
Ok(())
}
}
impl<T: sealed::Context> Readable for Features<T> {
fn read<R: ::std::io::Read>(r: &mut R) -> Result<Self, DecodeError> {
let mut flags: Vec<u8> = Readable::read(r)?;
flags.reverse(); Ok(Self {
flags,
mark: PhantomData,
})
}
}
#[cfg(test)]
mod tests {
use super::{ChannelFeatures, InitFeatures, NodeFeatures};
#[test]
fn sanity_test_known_features() {
assert!(!ChannelFeatures::known().requires_unknown_bits());
assert!(!ChannelFeatures::known().supports_unknown_bits());
assert!(!InitFeatures::known().requires_unknown_bits());
assert!(!InitFeatures::known().supports_unknown_bits());
assert!(!NodeFeatures::known().requires_unknown_bits());
assert!(!NodeFeatures::known().supports_unknown_bits());
assert!(InitFeatures::known().supports_upfront_shutdown_script());
assert!(NodeFeatures::known().supports_upfront_shutdown_script());
assert!(!InitFeatures::known().requires_upfront_shutdown_script());
assert!(!NodeFeatures::known().requires_upfront_shutdown_script());
assert!(InitFeatures::known().supports_gossip_queries());
assert!(NodeFeatures::known().supports_gossip_queries());
assert!(!InitFeatures::known().requires_gossip_queries());
assert!(!NodeFeatures::known().requires_gossip_queries());
assert!(InitFeatures::known().supports_data_loss_protect());
assert!(NodeFeatures::known().supports_data_loss_protect());
assert!(!InitFeatures::known().requires_data_loss_protect());
assert!(!NodeFeatures::known().requires_data_loss_protect());
assert!(InitFeatures::known().supports_variable_length_onion());
assert!(NodeFeatures::known().supports_variable_length_onion());
assert!(!InitFeatures::known().requires_variable_length_onion());
assert!(!NodeFeatures::known().requires_variable_length_onion());
assert!(InitFeatures::known().supports_static_remote_key());
assert!(NodeFeatures::known().supports_static_remote_key());
assert!(InitFeatures::known().requires_static_remote_key());
assert!(NodeFeatures::known().requires_static_remote_key());
assert!(InitFeatures::known().supports_payment_secret());
assert!(NodeFeatures::known().supports_payment_secret());
assert!(!InitFeatures::known().requires_payment_secret());
assert!(!NodeFeatures::known().requires_payment_secret());
assert!(InitFeatures::known().supports_basic_mpp());
assert!(NodeFeatures::known().supports_basic_mpp());
assert!(!InitFeatures::known().requires_basic_mpp());
assert!(!NodeFeatures::known().requires_basic_mpp());
assert!(InitFeatures::known().supports_shutdown_anysegwit());
assert!(NodeFeatures::known().supports_shutdown_anysegwit());
let mut init_features = InitFeatures::known();
assert!(init_features.initial_routing_sync());
init_features.clear_initial_routing_sync();
assert!(!init_features.initial_routing_sync());
}
#[test]
fn sanity_test_unknown_bits() {
let mut features = ChannelFeatures::empty();
assert!(!features.requires_unknown_bits());
assert!(!features.supports_unknown_bits());
features.set_required_unknown_bits();
assert!(features.requires_unknown_bits());
assert!(features.supports_unknown_bits());
features.clear_unknown_bits();
assert!(!features.requires_unknown_bits());
assert!(!features.supports_unknown_bits());
features.set_optional_unknown_bits();
assert!(!features.requires_unknown_bits());
assert!(features.supports_unknown_bits());
}
#[test]
fn convert_to_context_with_relevant_flags() {
let init_features = InitFeatures::known().clear_upfront_shutdown_script().clear_gossip_queries();
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(), 4);
assert_eq!(node_features.flags[0], 0b00000010);
assert_eq!(node_features.flags[1], 0b10010010);
assert_eq!(node_features.flags[2], 0b00000010);
assert_eq!(node_features.flags[3], 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());
}
}