Skip to content

Commit d9a9e18

Browse files
committed
f Account for scoring params given seperately
1 parent 9d0ab0b commit d9a9e18

File tree

3 files changed

+16
-7
lines changed

3 files changed

+16
-7
lines changed

src/io/utils.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ use crate::{Error, EventQueue, PaymentDetails};
77

88
use lightning::chain::channelmonitor::ChannelMonitor;
99
use lightning::routing::gossip::NetworkGraph;
10-
use lightning::routing::scoring::{ProbabilisticScorer, ProbabilisticScoringParameters};
10+
use lightning::routing::scoring::{ProbabilisticScorer, ProbabilisticScoringDecayParameters};
1111
use lightning::sign::{EntropySource, SignerProvider};
1212
use lightning::util::logger::Logger;
1313
use lightning::util::ser::{Readable, ReadableArgs, Writeable};
@@ -115,7 +115,7 @@ where
115115
K::Target: KVStore,
116116
L::Target: Logger,
117117
{
118-
let params = ProbabilisticScoringParameters::default();
118+
let params = ProbabilisticScoringDecayParameters::default();
119119
let mut reader = kv_store.read(SCORER_PERSISTENCE_NAMESPACE, SCORER_PERSISTENCE_KEY)?;
120120
let args = (params, network_graph, logger);
121121
let scorer = ProbabilisticScorer::read(&mut reader, args).map_err(|_| {

src/lib.rs

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,9 @@ use lightning::ln::channelmanager::{
119119
};
120120
use lightning::ln::peer_handler::{IgnoringMessageHandler, MessageHandler};
121121
use lightning::ln::{PaymentHash, PaymentPreimage, PaymentSecret};
122-
use lightning::routing::scoring::{ProbabilisticScorer, ProbabilisticScoringParameters};
122+
use lightning::routing::scoring::{
123+
ProbabilisticScorer, ProbabilisticScoringDecayParameters, ProbabilisticScoringFeeParameters,
124+
};
123125
use lightning::sign::EntropySource;
124126

125127
use lightning::util::config::{ChannelHandshakeConfig, ChannelHandshakeLimits, UserConfig};
@@ -429,7 +431,7 @@ impl Builder {
429431
Ok(scorer) => Arc::new(Mutex::new(scorer)),
430432
Err(e) => {
431433
if e.kind() == std::io::ErrorKind::NotFound {
432-
let params = ProbabilisticScoringParameters::default();
434+
let params = ProbabilisticScoringDecayParameters::default();
433435
Arc::new(Mutex::new(ProbabilisticScorer::new(
434436
params,
435437
Arc::clone(&network_graph),
@@ -442,11 +444,13 @@ impl Builder {
442444
}
443445
};
444446

447+
let scoring_fee_params = ProbabilisticScoringFeeParameters::default();
445448
let router = Arc::new(DefaultRouter::new(
446449
Arc::clone(&network_graph),
447450
Arc::clone(&logger),
448451
keys_manager.get_secure_random_bytes(),
449452
Arc::clone(&scorer),
453+
scoring_fee_params,
450454
));
451455

452456
// Read ChannelMonitor state from store

src/types.rs

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ use lightning::ln::peer_handler::IgnoringMessageHandler;
1212
use lightning::ln::{PaymentHash, PaymentPreimage, PaymentSecret};
1313
use lightning::routing::gossip;
1414
use lightning::routing::router::DefaultRouter;
15-
use lightning::routing::scoring::ProbabilisticScorer;
15+
use lightning::routing::scoring::{ProbabilisticScorer, ProbabilisticScoringFeeParameters};
1616
use lightning::sign::InMemorySigner;
1717
use lightning::util::ser::{Readable, Writeable, Writer};
1818
use lightning_invoice::{Invoice, SignedRawInvoice};
@@ -61,8 +61,13 @@ pub(crate) type ChannelManager = lightning::ln::channelmanager::ChannelManager<
6161

6262
pub(crate) type KeysManager = WalletKeysManager<bdk::database::SqliteDatabase>;
6363

64-
pub(crate) type Router =
65-
DefaultRouter<Arc<NetworkGraph>, Arc<FilesystemLogger>, Arc<Mutex<Scorer>>>;
64+
pub(crate) type Router = DefaultRouter<
65+
Arc<NetworkGraph>,
66+
Arc<FilesystemLogger>,
67+
Arc<Mutex<Scorer>>,
68+
ProbabilisticScoringFeeParameters,
69+
Scorer,
70+
>;
6671
pub(crate) type Scorer = ProbabilisticScorer<Arc<NetworkGraph>, Arc<FilesystemLogger>>;
6772

6873
pub(crate) type NetworkGraph = gossip::NetworkGraph<Arc<FilesystemLogger>>;

0 commit comments

Comments
 (0)