@@ -542,6 +542,33 @@ macro_rules! expect_pending_htlcs_forwardable {
542
542
} }
543
543
}
544
544
545
+ macro_rules! expect_payment_received {
546
+ ( $node: expr, $expected_payment_hash: expr, $expected_recv_value: expr) => {
547
+ let events = $node. node. get_and_clear_pending_events( ) ;
548
+ assert_eq!( events. len( ) , 1 ) ;
549
+ match events[ 0 ] {
550
+ Event :: PaymentReceived { ref payment_hash, amt } => {
551
+ assert_eq!( $expected_payment_hash, * payment_hash) ;
552
+ assert_eq!( $expected_recv_value, amt) ;
553
+ } ,
554
+ _ => panic!( "Unexpected event" ) ,
555
+ }
556
+ }
557
+ }
558
+
559
+ macro_rules! expect_payment_sent {
560
+ ( $node: expr, $expected_payment_preimage: expr) => {
561
+ let events = $node. node. get_and_clear_pending_events( ) ;
562
+ assert_eq!( events. len( ) , 1 ) ;
563
+ match events[ 0 ] {
564
+ Event :: PaymentSent { ref payment_preimage } => {
565
+ assert_eq!( $expected_payment_preimage, * payment_preimage) ;
566
+ } ,
567
+ _ => panic!( "Unexpected event" ) ,
568
+ }
569
+ }
570
+ }
571
+
545
572
pub fn send_along_route_with_hash ( origin_node : & Node , route : Route , expected_route : & [ & Node ] , recv_value : u64 , our_payment_hash : PaymentHash ) {
546
573
let mut payment_event = {
547
574
origin_node. node . send_payment ( route, our_payment_hash) . unwrap ( ) ;
@@ -664,14 +691,7 @@ pub fn claim_payment_along_route(origin_node: &Node, expected_route: &[&Node], s
664
691
665
692
if !skip_last {
666
693
last_update_fulfill_dance ! ( origin_node, expected_route. first( ) . unwrap( ) ) ;
667
- let events = origin_node. node . get_and_clear_pending_events ( ) ;
668
- assert_eq ! ( events. len( ) , 1 ) ;
669
- match events[ 0 ] {
670
- Event :: PaymentSent { payment_preimage } => {
671
- assert_eq ! ( payment_preimage, our_payment_preimage) ;
672
- } ,
673
- _ => panic ! ( "Unexpected event" ) ,
674
- }
694
+ expect_payment_sent ! ( origin_node, our_payment_preimage) ;
675
695
}
676
696
}
677
697
@@ -935,20 +955,6 @@ pub fn get_announce_close_broadcast_events(nodes: &Vec<Node>, a: usize, b: usize
935
955
}
936
956
}
937
957
938
- macro_rules! expect_payment_received {
939
- ( $node: expr, $expected_payment_hash: expr, $expected_recv_value: expr) => {
940
- let events = $node. node. get_and_clear_pending_events( ) ;
941
- assert_eq!( events. len( ) , 1 ) ;
942
- match events[ 0 ] {
943
- Event :: PaymentReceived { ref payment_hash, amt } => {
944
- assert_eq!( $expected_payment_hash, * payment_hash) ;
945
- assert_eq!( $expected_recv_value, amt) ;
946
- } ,
947
- _ => panic!( "Unexpected event" ) ,
948
- }
949
- }
950
- }
951
-
952
958
macro_rules! get_channel_value_stat {
953
959
( $node: expr, $channel_id: expr) => { {
954
960
let chan_lock = $node. node. channel_state. lock( ) . unwrap( ) ;
0 commit comments