@@ -17,7 +17,8 @@ use lightning::chain::chaininterface::{BroadcasterInterface, ConfirmationTarget,
17
17
use lightning:: chain:: keysinterface:: KeysManager ;
18
18
use lightning:: ln:: PaymentHash ;
19
19
use lightning:: routing:: gossip:: NodeId ;
20
- use lightning:: util:: events as ldk_events;
20
+ use lightning:: util:: events:: Event as LdkEvent ;
21
+ use lightning:: util:: events:: EventHandler as LdkEventHandler ;
21
22
use lightning:: util:: persist:: KVStorePersister ;
22
23
use lightning:: util:: ser:: { Readable , ReadableArgs , Writeable , Writer } ;
23
24
@@ -322,10 +323,10 @@ impl LdkLiteEventHandler {
322
323
}
323
324
}
324
325
325
- impl ldk_events :: EventHandler for LdkLiteEventHandler {
326
- fn handle_event ( & self , event : & ldk_events :: Event ) {
326
+ impl LdkEventHandler for LdkLiteEventHandler {
327
+ fn handle_event ( & self , event : & LdkEvent ) {
327
328
match event {
328
- ldk_events :: Event :: FundingGenerationReady {
329
+ LdkEvent :: FundingGenerationReady {
329
330
temporary_channel_id,
330
331
counterparty_node_id,
331
332
channel_value_satoshis,
@@ -361,7 +362,7 @@ impl ldk_events::EventHandler for LdkLiteEventHandler {
361
362
}
362
363
}
363
364
}
364
- ldk_events :: Event :: PaymentReceived { payment_hash, purpose, amount_msat } => {
365
+ LdkEvent :: PaymentReceived { payment_hash, purpose, amount_msat } => {
365
366
log_info ! (
366
367
self . logger,
367
368
"Received payment from payment hash {} of {} millisatoshis" ,
@@ -382,7 +383,7 @@ impl ldk_events::EventHandler for LdkLiteEventHandler {
382
383
} ) )
383
384
. unwrap ( ) ;
384
385
}
385
- ldk_events :: Event :: PaymentClaimed { payment_hash, purpose, amount_msat } => {
386
+ LdkEvent :: PaymentClaimed { payment_hash, purpose, amount_msat } => {
386
387
log_info ! (
387
388
self . logger,
388
389
"Claimed payment from payment hash {} of {} millisatoshis" ,
@@ -417,7 +418,7 @@ impl ldk_events::EventHandler for LdkLiteEventHandler {
417
418
}
418
419
}
419
420
}
420
- ldk_events :: Event :: PaymentSent {
421
+ LdkEvent :: PaymentSent {
421
422
payment_preimage,
422
423
payment_hash,
423
424
fee_paid_msat,
@@ -449,7 +450,7 @@ impl ldk_events::EventHandler for LdkLiteEventHandler {
449
450
} ) )
450
451
. unwrap ( ) ;
451
452
}
452
- ldk_events :: Event :: PaymentFailed { payment_hash, .. } => {
453
+ LdkEvent :: PaymentFailed { payment_hash, .. } => {
453
454
log_info ! (
454
455
self . logger,
455
456
"Failed to send payment to payment hash {:?}: exhausted payment retry attempts" ,
@@ -468,12 +469,12 @@ impl ldk_events::EventHandler for LdkLiteEventHandler {
468
469
. unwrap ( ) ;
469
470
}
470
471
471
- ldk_events :: Event :: PaymentPathSuccessful { .. } => { }
472
- ldk_events :: Event :: PaymentPathFailed { .. } => { }
473
- ldk_events :: Event :: ProbeSuccessful { .. } => { }
474
- ldk_events :: Event :: ProbeFailed { .. } => { }
475
- ldk_events :: Event :: HTLCHandlingFailed { .. } => { }
476
- ldk_events :: Event :: PendingHTLCsForwardable { time_forwardable } => {
472
+ LdkEvent :: PaymentPathSuccessful { .. } => { }
473
+ LdkEvent :: PaymentPathFailed { .. } => { }
474
+ LdkEvent :: ProbeSuccessful { .. } => { }
475
+ LdkEvent :: ProbeFailed { .. } => { }
476
+ LdkEvent :: HTLCHandlingFailed { .. } => { }
477
+ LdkEvent :: PendingHTLCsForwardable { time_forwardable } => {
477
478
let forwarding_channel_manager = self . channel_manager . clone ( ) ;
478
479
let min = time_forwardable. as_millis ( ) as u64 ;
479
480
@@ -485,7 +486,7 @@ impl ldk_events::EventHandler for LdkLiteEventHandler {
485
486
forwarding_channel_manager. process_pending_htlc_forwards ( ) ;
486
487
} ) ;
487
488
}
488
- ldk_events :: Event :: SpendableOutputs { outputs } => {
489
+ LdkEvent :: SpendableOutputs { outputs } => {
489
490
let destination_address = self . chain_access . get_new_address ( ) . unwrap ( ) ;
490
491
let output_descriptors = & outputs. iter ( ) . map ( |a| a) . collect :: < Vec < _ > > ( ) ;
491
492
let tx_feerate =
@@ -502,8 +503,8 @@ impl ldk_events::EventHandler for LdkLiteEventHandler {
502
503
. unwrap ( ) ;
503
504
self . chain_access . broadcast_transaction ( & spending_tx) ;
504
505
}
505
- ldk_events :: Event :: OpenChannelRequest { .. } => { }
506
- ldk_events :: Event :: PaymentForwarded {
506
+ LdkEvent :: OpenChannelRequest { .. } => { }
507
+ LdkEvent :: PaymentForwarded {
507
508
prev_channel_id,
508
509
next_channel_id,
509
510
fee_earned_msat,
@@ -568,7 +569,7 @@ impl ldk_events::EventHandler for LdkLiteEventHandler {
568
569
}
569
570
}
570
571
571
- ldk_events :: Event :: ChannelClosed { channel_id, reason, user_channel_id : _ } => {
572
+ LdkEvent :: ChannelClosed { channel_id, reason, user_channel_id : _ } => {
572
573
log_info ! (
573
574
self . logger,
574
575
"Channel {} closed due to: {:?}" ,
@@ -581,7 +582,7 @@ impl ldk_events::EventHandler for LdkLiteEventHandler {
581
582
} ) )
582
583
. unwrap ( ) ;
583
584
}
584
- ldk_events :: Event :: DiscardFunding { .. } => { }
585
+ LdkEvent :: DiscardFunding { .. } => { }
585
586
}
586
587
}
587
588
}
0 commit comments