X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=fuzz%2Fsrc%2Frouter.rs;h=fabad11ac75d974f9ca4c92b7b5cd5cb841dbcb9;hb=0882655680040a0226b1790b6558150324a288f4;hp=f9a263cc3254556036bc4640d07f40a9df6179d4;hpb=62f466a0a2370b9f9696e05d3ce651216d7410d9;p=rust-lightning diff --git a/fuzz/src/router.rs b/fuzz/src/router.rs index f9a263cc..fabad11a 100644 --- a/fuzz/src/router.rs +++ b/fuzz/src/router.rs @@ -16,7 +16,7 @@ use lightning::chain::transaction::OutPoint; use lightning::ln::channelmanager::ChannelDetails; use lightning::ln::features::InitFeatures; use lightning::ln::msgs; -use lightning::routing::router::{get_route, RouteHintHop}; +use lightning::routing::router::{get_route, RouteHint, RouteHintHop}; use lightning::util::logger::Logger; use lightning::util::ser::Readable; use lightning::routing::network_graph::{NetworkGraph, RoutingFees}; @@ -133,6 +133,7 @@ pub fn do_test(data: &[u8], out: Out) { msgs::DecodeError::BadLengthDescriptor => return, msgs::DecodeError::ShortRead => panic!("We picked the length..."), msgs::DecodeError::Io(e) => panic!("{:?}", e), + msgs::DecodeError::UnsupportedCompression => return, } } }} @@ -211,12 +212,13 @@ pub fn do_test(data: &[u8], out: Out) { remote_network_id: *rnid, counterparty_features: InitFeatures::known(), channel_value_satoshis: slice_to_be64(get_slice!(8)), - user_id: 0, - inbound_capacity_msat: 0, - is_outbound: true, - is_funding_locked: true, - is_usable: true, - is_public: true, + user_id: 0, inbound_capacity_msat: 0, + to_self_reserve_satoshis: None, + to_remote_reserve_satoshis: 0, + confirmations_required: None, + spend_csv_on_our_commitment_funds: None, + is_outbound: true, is_funding_locked: true, + is_usable: true, is_public: true, outbound_capacity_msat: 0, counterparty_forwarding_info: None, }); @@ -224,13 +226,13 @@ pub fn do_test(data: &[u8], out: Out) { Some(&first_hops_vec[..]) }, }; - let mut last_hops_vec = Vec::new(); + let mut last_hops = Vec::new(); { let count = get_slice!(1)[0]; for _ in 0..count { scid += 1; let rnid = node_pks.iter().skip(slice_to_be16(get_slice!(2))as usize % node_pks.len()).next().unwrap(); - last_hops_vec.push(RouteHintHop { + last_hops.push(RouteHint(vec![RouteHintHop { src_node_id: *rnid, short_channel_id: scid, fees: RoutingFees { @@ -240,10 +242,9 @@ pub fn do_test(data: &[u8], out: Out) { cltv_expiry_delta: slice_to_be16(get_slice!(2)), htlc_minimum_msat: Some(slice_to_be64(get_slice!(8))), htlc_maximum_msat: None, - }); + }])); } } - let last_hops = &last_hops_vec[..]; for target in node_pks.iter() { let _ = get_route(&our_pubkey, &net_graph, target, None, first_hops.map(|c| c.iter().collect::>()).as_ref().map(|a| a.as_slice()),