Skip to content

Commit 6354d8b

Browse files
committed
Add timeout retry strategy to outbound payment
rename InvoicePayment to InvoicePaymentUsingTime with Time trait to allow manual time advance in test. impl Display for PaymentAttempts
1 parent f1550bb commit 6354d8b

File tree

4 files changed

+235
-95
lines changed

4 files changed

+235
-95
lines changed

lightning-background-processor/src/lib.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -365,7 +365,7 @@ mod tests {
365365
use lightning::util::logger::Logger;
366366
use lightning::util::ser::Writeable;
367367
use lightning::util::test_utils;
368-
use lightning_invoice::payment::{InvoicePayer, RetryAttempts};
368+
use lightning_invoice::payment::{InvoicePayer, Retry};
369369
use lightning_invoice::utils::DefaultRouter;
370370
use lightning_persister::FilesystemPersister;
371371
use std::fs;
@@ -755,7 +755,7 @@ mod tests {
755755
let persister = Persister::new(data_dir);
756756
let scorer = Arc::new(Mutex::new(test_utils::TestScorer::with_penalty(0)));
757757
let router = DefaultRouter::new(Arc::clone(&nodes[0].network_graph), Arc::clone(&nodes[0].logger), random_seed_bytes);
758-
let invoice_payer = Arc::new(InvoicePayer::new(Arc::clone(&nodes[0].node), router, scorer, Arc::clone(&nodes[0].logger), |_: &_| {}, RetryAttempts(2)));
758+
let invoice_payer = Arc::new(InvoicePayer::new(Arc::clone(&nodes[0].node), router, scorer, Arc::clone(&nodes[0].logger), |_: &_| {}, Retry::Attempts(2)));
759759
let event_handler = Arc::clone(&invoice_payer);
760760
let bg_processor = BackgroundProcessor::start(persister, event_handler, nodes[0].chain_monitor.clone(), nodes[0].node.clone(), nodes[0].net_graph_msg_handler.clone(), nodes[0].peer_manager.clone(), nodes[0].logger.clone());
761761
assert!(bg_processor.stop().is_ok());

0 commit comments

Comments
 (0)