@@ -230,11 +230,21 @@ fn test_v1_splice_in() {
230230 initiator_node. node. get_our_node_id( )
231231 ) ;
232232
233- // TODO(splicing) This is the last tx_complete, which triggers the commitment flow, which is not yet implemented
234- // let _res = initiator_node.node.handle_tx_complete(acceptor_node.node.get_our_node_id(), &tx_complete_msg);
233+ // TODO(splicing) This is the last tx_complete, which triggers the commitment flow, which is not yet fully implemented
234+ let _res = initiator_node. node . handle_tx_complete ( acceptor_node. node . get_our_node_id ( ) , & tx_complete_msg) ;
235+ let events = initiator_node. node . get_and_clear_pending_msg_events ( ) ;
236+ assert_eq ! ( events. len( ) , 2 ) ;
237+ match events[ 0 ] {
238+ MessageSendEvent :: SendTxComplete { .. } => { } ,
239+ _ => panic ! ( "Unexpected event {:?}" , events[ 0 ] ) ,
240+ }
241+ match events[ 1 ] {
242+ MessageSendEvent :: HandleError { .. } => { } ,
243+ _ => panic ! ( "Unexpected event {:?}" , events[ 1 ] ) ,
244+ }
235245
236246 // TODO(splicing): Continue with commitment flow, new tx confirmation
237-
247+ /*
238248 // === Close channel, cooperatively
239249 initiator_node.node.close_channel(&channel_id, &acceptor_node.node.get_our_node_id()).unwrap();
240250 let node0_shutdown_message = get_event_msg!(
@@ -256,6 +266,7 @@ fn test_v1_splice_in() {
256266 MessageSendEvent::SendClosingSigned,
257267 acceptor_node.node.get_our_node_id()
258268 );
269+ */
259270}
260271
261272#[ test]
0 commit comments