From 254448caed0c5708ffd414a2b418983792a75a3c Mon Sep 17 00:00:00 2001 From: Matt Corallo Date: Wed, 23 Mar 2022 03:08:51 +0000 Subject: [PATCH] [Java] Use ProbabilisticScorer in HumanObjectPeerTest --- src/test/java/org/ldk/HumanObjectPeerTest.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/src/test/java/org/ldk/HumanObjectPeerTest.java b/src/test/java/org/ldk/HumanObjectPeerTest.java index 64ec2162..3297d8b8 100644 --- a/src/test/java/org/ldk/HumanObjectPeerTest.java +++ b/src/test/java/org/ldk/HumanObjectPeerTest.java @@ -357,9 +357,12 @@ class HumanObjectPeerTestInstance { this.constructor = new ChannelManagerConstructor(Network.LDKNetwork_Bitcoin, UserConfig.with_default(), new byte[32], 0, this.keys_interface, this.fee_estimator, this.chain_monitor, this.router, this.tx_broadcaster, this.logger); } - Result_ScorerDecodeErrorZ score_res = Scorer.read(Scorer.with_default().write()); + ProbabilisticScoringParameters params = ProbabilisticScoringParameters.with_default(); + ProbabilisticScorer default_scorer = ProbabilisticScorer.of(params, this.router); + Result_ProbabilisticScorerDecodeErrorZ score_res = ProbabilisticScorer.read(default_scorer.write(), + TwoTuple_ProbabilisticScoringParametersNetworkGraphZ.of(params, this.router)); assert score_res.is_ok(); - Score score = ((Result_ScorerDecodeErrorZ.Result_ScorerDecodeErrorZ_OK) score_res).res.as_Score(); + Score score = ((Result_ProbabilisticScorerDecodeErrorZ.Result_ProbabilisticScorerDecodeErrorZ_OK) score_res).res.as_Score(); MultiThreadedLockableScore scorer = null; if (use_invoice_payer) { scorer = MultiThreadedLockableScore.of(score); } constructor.chain_sync_completed(new ChannelManagerConstructor.EventHandler() { @@ -442,7 +445,7 @@ class HumanObjectPeerTestInstance { } catch (ChannelManagerConstructor.InvalidSerializedDataException e) {} } MultiThreadedLockableScore scorer = null; - if (use_invoice_payer) { scorer = MultiThreadedLockableScore.of(Scorer.with_default().as_Score()); } + if (use_invoice_payer) { scorer = MultiThreadedLockableScore.of(ProbabilisticScorer.of(ProbabilisticScoringParameters.with_default(), this.router).as_Score()); } constructor.chain_sync_completed(new ChannelManagerConstructor.EventHandler() { @Override public void handle_event(Event event) { synchronized (pending_manager_events) { -- 2.30.2