@@ -136,8 +136,9 @@ public ChannelManagerConstructor(byte[] channel_manager_serialized, byte[][] cha
136136 EntropySource entropy_source , NodeSigner node_signer , SignerProvider signer_provider ,
137137 FeeEstimator fee_estimator , ChainMonitor chain_monitor ,
138138 @ Nullable Filter filter , byte [] net_graph_serialized ,
139- ProbabilisticScoringParameters scoring_params , byte [] probabilistic_scorer_bytes ,
140- @ Nullable RouterWrapper router_wrapper ,
139+ ProbabilisticScoringDecayParameters scoring_decay_params ,
140+ ProbabilisticScoringFeeParameters scoring_fee_params ,
141+ byte [] probabilistic_scorer_bytes , @ Nullable RouterWrapper router_wrapper ,
141142 BroadcasterInterface tx_broadcaster , Logger logger ) throws InvalidSerializedDataException {
142143 this .entropy_source = entropy_source ;
143144 this .node_signer = node_signer ;
@@ -147,16 +148,17 @@ public ChannelManagerConstructor(byte[] channel_manager_serialized, byte[][] cha
147148 throw new InvalidSerializedDataException ("Serialized Network Graph was corrupt" );
148149 }
149150 this .net_graph = ((Result_NetworkGraphDecodeErrorZ .Result_NetworkGraphDecodeErrorZ_OK )graph_res ).res ;
150- assert (scoring_params != null );
151+ assert (scoring_decay_params != null );
151152 assert (probabilistic_scorer_bytes != null );
152- Result_ProbabilisticScorerDecodeErrorZ scorer_res = ProbabilisticScorer .read (probabilistic_scorer_bytes , scoring_params , net_graph , logger );
153+ Result_ProbabilisticScorerDecodeErrorZ scorer_res = ProbabilisticScorer .read (probabilistic_scorer_bytes , scoring_decay_params , net_graph , logger );
153154 if (!scorer_res .is_ok ()) {
154155 throw new InvalidSerializedDataException ("Serialized ProbabilisticScorer was corrupt" );
155156 }
156157 this .prob_scorer = ((Result_ProbabilisticScorerDecodeErrorZ .Result_ProbabilisticScorerDecodeErrorZ_OK )scorer_res ).res ;
157158 this .scorer = MultiThreadedLockableScore .of (this .prob_scorer .as_Score ());
158159
159- DefaultRouter default_router = DefaultRouter .of (this .net_graph , logger , entropy_source .get_secure_random_bytes (), scorer .as_LockableScore ());
160+ assert (scoring_fee_params != null );
161+ DefaultRouter default_router = DefaultRouter .of (this .net_graph , logger , entropy_source .get_secure_random_bytes (), scorer .as_LockableScore (), scoring_fee_params );
160162 Router router ;
161163 if (router_wrapper != null ) {
162164 router = Router .new_impl (new Router .RouterInterface () {
@@ -211,17 +213,19 @@ public ChannelManagerConstructor(byte[] channel_manager_serialized, byte[][] cha
211213 public ChannelManagerConstructor (Network network , UserConfig config , byte [] current_blockchain_tip_hash , int current_blockchain_tip_height ,
212214 EntropySource entropy_source , NodeSigner node_signer , SignerProvider signer_provider ,
213215 FeeEstimator fee_estimator , ChainMonitor chain_monitor ,
214- NetworkGraph net_graph , ProbabilisticScoringParameters scoring_params ,
216+ NetworkGraph net_graph , ProbabilisticScoringDecayParameters scoring_decay_params ,
217+ ProbabilisticScoringFeeParameters scoring_fee_params ,
215218 @ Nullable RouterWrapper router_wrapper ,
216219 BroadcasterInterface tx_broadcaster , Logger logger ) {
217220 this .entropy_source = entropy_source ;
218221 this .node_signer = node_signer ;
219222 this .net_graph = net_graph ;
220- assert (scoring_params != null );
221- this .prob_scorer = ProbabilisticScorer .of (scoring_params , net_graph , logger );
223+ assert (scoring_decay_params != null );
224+ this .prob_scorer = ProbabilisticScorer .of (scoring_decay_params , net_graph , logger );
222225 this .scorer = MultiThreadedLockableScore .of (this .prob_scorer .as_Score ());
223226
224- DefaultRouter default_router = DefaultRouter .of (this .net_graph , logger , entropy_source .get_secure_random_bytes (), scorer .as_LockableScore ());
227+ assert (scoring_fee_params != null );
228+ DefaultRouter default_router = DefaultRouter .of (this .net_graph , logger , entropy_source .get_secure_random_bytes (), scorer .as_LockableScore (), scoring_fee_params );
225229 Router router ;
226230 if (router_wrapper != null ) {
227231 router = Router .new_impl (new Router .RouterInterface () {
@@ -241,7 +245,7 @@ public ChannelManagerConstructor(Network network, UserConfig config, byte[] curr
241245 BestBlock block = BestBlock .of (current_blockchain_tip_hash , current_blockchain_tip_height );
242246 ChainParameters params = ChainParameters .of (network , block );
243247 channel_manager = ChannelManager .of (fee_estimator , chain_monitor .as_Watch (), tx_broadcaster , router , logger ,
244- entropy_source , node_signer , signer_provider , config , params );
248+ entropy_source , node_signer , signer_provider , config , params , ( int ) ( System . currentTimeMillis () / 1000 ) );
245249 this .logger = logger ;
246250 }
247251
@@ -286,8 +290,8 @@ public void chain_sync_completed(EventHandler event_handler, boolean use_p2p_gra
286290 routing_msg_handler = ignoring_handler .as_RoutingMessageHandler ();
287291 this .peer_manager = PeerManager .of (channel_manager .as_ChannelMessageHandler (),
288292 routing_msg_handler , ignoring_handler .as_OnionMessageHandler (),
289- ( int )(System .currentTimeMillis () / 1000 ), this . entropy_source . get_secure_random_bytes ( ),
290- logger , ignoring_handler . as_CustomMessageHandler () , this .node_signer );
293+ ignoring_handler . as_CustomMessageHandler (), ( int )(System .currentTimeMillis () / 1000 ),
294+ this . entropy_source . get_secure_random_bytes (), logger , this .node_signer );
291295
292296 try {
293297 this .nio_peer_handler = new NioPeerHandler (peer_manager );
0 commit comments