@@ -143,7 +143,7 @@ use lightning::ln::{PaymentHash, PaymentPreimage, PaymentSecret};
143
143
use lightning:: ln:: channelmanager:: { ChannelDetails , PaymentId , PaymentSendFailure } ;
144
144
use lightning:: ln:: msgs:: LightningError ;
145
145
use lightning:: routing:: scoring:: { LockableScore , Score } ;
146
- use lightning:: routing:: router:: { Payee , Route , RouteParameters } ;
146
+ use lightning:: routing:: router:: { PaymentParameters , Route , RouteParameters } ;
147
147
use lightning:: util:: events:: { Event , EventHandler } ;
148
148
use lightning:: util:: logger:: Logger ;
149
149
use crate :: sync:: Mutex ;
@@ -206,7 +206,7 @@ pub trait Payer {
206
206
pub trait Router < S : Score > {
207
207
/// Finds a [`Route`] between `payer` and `payee` for a payment with the given values.
208
208
fn find_route (
209
- & self , payer : & PublicKey , params : & RouteParameters , payment_hash : & PaymentHash ,
209
+ & self , payer : & PublicKey , route_params : & RouteParameters , payment_hash : & PaymentHash ,
210
210
first_hops : Option < & [ & ChannelDetails ] > , scorer : & S
211
211
) -> Result < Route , LightningError > ;
212
212
}
@@ -296,22 +296,22 @@ where
296
296
} ;
297
297
298
298
let payment_secret = Some ( invoice. payment_secret ( ) . clone ( ) ) ;
299
- let mut payee = Payee :: from_node_id ( invoice. recover_payee_pub_key ( ) )
299
+ let mut payment_params = PaymentParameters :: from_node_id ( invoice. recover_payee_pub_key ( ) )
300
300
. with_expiry_time ( expiry_time_from_unix_epoch ( & invoice) . as_secs ( ) )
301
301
. with_route_hints ( invoice. route_hints ( ) ) ;
302
302
if let Some ( features) = invoice. features ( ) {
303
- payee = payee . with_features ( features. clone ( ) ) ;
303
+ payment_params = payment_params . with_features ( features. clone ( ) ) ;
304
304
}
305
- let params = RouteParameters {
306
- payee ,
305
+ let route_params = RouteParameters {
306
+ payment_params ,
307
307
final_value_msat : invoice. amount_milli_satoshis ( ) . or ( amount_msats) . unwrap ( ) ,
308
308
final_cltv_expiry_delta : invoice. min_final_cltv_expiry ( ) as u32 ,
309
309
} ;
310
310
311
311
let send_payment = |route : & Route | {
312
312
self . payer . send_payment ( route, payment_hash, & payment_secret)
313
313
} ;
314
- self . pay_internal ( & params , payment_hash, send_payment)
314
+ self . pay_internal ( & route_params , payment_hash, send_payment)
315
315
. map_err ( |e| { self . payment_cache . lock ( ) . unwrap ( ) . remove ( & payment_hash) ; e } )
316
316
}
317
317
@@ -330,16 +330,16 @@ where
330
330
hash_map:: Entry :: Vacant ( entry) => entry. insert ( 0 ) ,
331
331
} ;
332
332
333
- let params = RouteParameters {
334
- payee : Payee :: for_keysend ( pubkey) ,
333
+ let route_params = RouteParameters {
334
+ payment_params : PaymentParameters :: for_keysend ( pubkey) ,
335
335
final_value_msat : amount_msats,
336
336
final_cltv_expiry_delta,
337
337
} ;
338
338
339
339
let send_payment = |route : & Route | {
340
340
self . payer . send_spontaneous_payment ( route, payment_preimage)
341
341
} ;
342
- self . pay_internal ( & params , payment_hash, send_payment)
342
+ self . pay_internal ( & route_params , payment_hash, send_payment)
343
343
. map_err ( |e| { self . payment_cache . lock ( ) . unwrap ( ) . remove ( & payment_hash) ; e } )
344
344
}
345
345
@@ -462,8 +462,8 @@ fn expiry_time_from_unix_epoch(invoice: &Invoice) -> Duration {
462
462
}
463
463
464
464
#[ cfg( feature = "std" ) ]
465
- fn has_expired ( params : & RouteParameters ) -> bool {
466
- if let Some ( expiry_time) = params . payee . expiry_time {
465
+ fn has_expired ( route_params : & RouteParameters ) -> bool {
466
+ if let Some ( expiry_time) = route_params . payment_params . expiry_time {
467
467
Invoice :: is_expired_from_epoch ( & SystemTime :: UNIX_EPOCH , Duration :: from_secs ( expiry_time) )
468
468
} else { false }
469
469
}
@@ -533,7 +533,7 @@ mod tests {
533
533
use lightning:: ln:: functional_test_utils:: * ;
534
534
use lightning:: ln:: msgs:: { ChannelMessageHandler , ErrorAction , LightningError } ;
535
535
use lightning:: routing:: network_graph:: NodeId ;
536
- use lightning:: routing:: router:: { Payee , Route , RouteHop } ;
536
+ use lightning:: routing:: router:: { PaymentParameters , Route , RouteHop } ;
537
537
use lightning:: util:: test_utils:: TestLogger ;
538
538
use lightning:: util:: errors:: APIError ;
539
539
use lightning:: util:: events:: { Event , EventsProvider , MessageSendEvent , MessageSendEventsProvider } ;
@@ -882,7 +882,7 @@ mod tests {
882
882
assert_eq ! ( * payer. attempts. borrow( ) , 1 ) ;
883
883
884
884
let mut retry_data = TestRouter :: retry_for_invoice ( & invoice) ;
885
- retry_data. payee . expiry_time = Some ( SystemTime :: now ( )
885
+ retry_data. payment_params . expiry_time = Some ( SystemTime :: now ( )
886
886
. checked_sub ( Duration :: from_secs ( 2 ) ) . unwrap ( )
887
887
. duration_since ( SystemTime :: UNIX_EPOCH ) . unwrap ( ) . as_secs ( ) ) ;
888
888
let event = Event :: PaymentPathFailed {
@@ -1136,7 +1136,7 @@ mod tests {
1136
1136
assert_eq ! ( * payer. attempts. borrow( ) , 1 ) ;
1137
1137
1138
1138
let retry = RouteParameters {
1139
- payee : Payee :: for_keysend ( pubkey) ,
1139
+ payment_params : PaymentParameters :: for_keysend ( pubkey) ,
1140
1140
final_value_msat,
1141
1141
final_cltv_expiry_delta,
1142
1142
} ;
@@ -1251,7 +1251,7 @@ mod tests {
1251
1251
short_channel_id: 1 , fee_msat: final_value_msat / 2 , cltv_expiry_delta: 144
1252
1252
} ] ,
1253
1253
] ,
1254
- payee : None ,
1254
+ payment_params : None ,
1255
1255
}
1256
1256
}
1257
1257
@@ -1260,15 +1260,15 @@ mod tests {
1260
1260
}
1261
1261
1262
1262
fn retry_for_invoice ( invoice : & Invoice ) -> RouteParameters {
1263
- let mut payee = Payee :: from_node_id ( invoice. recover_payee_pub_key ( ) )
1263
+ let mut payment_params = PaymentParameters :: from_node_id ( invoice. recover_payee_pub_key ( ) )
1264
1264
. with_expiry_time ( expiry_time_from_unix_epoch ( invoice) . as_secs ( ) )
1265
1265
. with_route_hints ( invoice. route_hints ( ) ) ;
1266
1266
if let Some ( features) = invoice. features ( ) {
1267
- payee = payee . with_features ( features. clone ( ) ) ;
1267
+ payment_params = payment_params . with_features ( features. clone ( ) ) ;
1268
1268
}
1269
1269
let final_value_msat = invoice. amount_milli_satoshis ( ) . unwrap ( ) / 2 ;
1270
1270
RouteParameters {
1271
- payee ,
1271
+ payment_params ,
1272
1272
final_value_msat,
1273
1273
final_cltv_expiry_delta : invoice. min_final_cltv_expiry ( ) as u32 ,
1274
1274
}
@@ -1277,11 +1277,11 @@ mod tests {
1277
1277
1278
1278
impl < S : Score > Router < S > for TestRouter {
1279
1279
fn find_route (
1280
- & self , _payer : & PublicKey , params : & RouteParameters , _payment_hash : & PaymentHash ,
1280
+ & self , _payer : & PublicKey , route_params : & RouteParameters , _payment_hash : & PaymentHash ,
1281
1281
_first_hops : Option < & [ & ChannelDetails ] > , _scorer : & S
1282
1282
) -> Result < Route , LightningError > {
1283
1283
Ok ( Route {
1284
- payee : Some ( params . payee . clone ( ) ) , ..Self :: route_for_value ( params . final_value_msat )
1284
+ payment_params : Some ( route_params . payment_params . clone ( ) ) , ..Self :: route_for_value ( route_params . final_value_msat )
1285
1285
} )
1286
1286
}
1287
1287
}
@@ -1543,7 +1543,7 @@ mod tests {
1543
1543
cltv_expiry_delta: 100 ,
1544
1544
} ] ,
1545
1545
] ,
1546
- payee : Some ( Payee :: from_node_id ( nodes[ 1 ] . node . get_our_node_id ( ) ) ) ,
1546
+ payment_params : Some ( PaymentParameters :: from_node_id ( nodes[ 1 ] . node . get_our_node_id ( ) ) ) ,
1547
1547
} ;
1548
1548
let router = ManualRouter ( RefCell :: new ( VecDeque :: new ( ) ) ) ;
1549
1549
router. expect_find_route ( Ok ( route. clone ( ) ) ) ;
@@ -1587,7 +1587,7 @@ mod tests {
1587
1587
cltv_expiry_delta: 100 ,
1588
1588
} ] ,
1589
1589
] ,
1590
- payee : Some ( Payee :: from_node_id ( nodes[ 1 ] . node . get_our_node_id ( ) ) ) ,
1590
+ payment_params : Some ( PaymentParameters :: from_node_id ( nodes[ 1 ] . node . get_our_node_id ( ) ) ) ,
1591
1591
} ;
1592
1592
let router = ManualRouter ( RefCell :: new ( VecDeque :: new ( ) ) ) ;
1593
1593
router. expect_find_route ( Ok ( route. clone ( ) ) ) ;
@@ -1668,7 +1668,7 @@ mod tests {
1668
1668
cltv_expiry_delta: 100 ,
1669
1669
} ]
1670
1670
] ,
1671
- payee : Some ( Payee :: from_node_id ( nodes[ 2 ] . node . get_our_node_id ( ) ) ) ,
1671
+ payment_params : Some ( PaymentParameters :: from_node_id ( nodes[ 2 ] . node . get_our_node_id ( ) ) ) ,
1672
1672
} ;
1673
1673
let router = ManualRouter ( RefCell :: new ( VecDeque :: new ( ) ) ) ;
1674
1674
router. expect_find_route ( Ok ( route. clone ( ) ) ) ;
0 commit comments