@@ -28,6 +28,8 @@ use crate::ln::types::ChannelId;
28
28
use crate :: prelude:: * ;
29
29
use crate :: sign:: { ChannelSigner as _, P2WPKH_WITNESS_WEIGHT } ;
30
30
use crate :: util:: ser:: TransactionU16LenLimited ;
31
+ #[ cfg( async_signing) ]
32
+ use crate :: util:: test_channel_signer:: SignerOp ;
31
33
use crate :: util:: test_utils;
32
34
33
35
// Dual-funding: V2 Channel Establishment Tests
@@ -129,9 +131,23 @@ fn do_test_v2_channel_establishment(
129
131
let _tx_complete_msg =
130
132
get_event_msg ! ( nodes[ 1 ] , MessageSendEvent :: SendTxComplete , nodes[ 0 ] . node. get_our_node_id( ) ) ;
131
133
132
- let tx_complete_msg = TxComplete { channel_id } ;
134
+ #[ cfg( async_signing) ] {
135
+ nodes[ 1 ] . disable_channel_signer_op (
136
+ & nodes[ 0 ] . node . get_our_node_id ( ) , & channel_id, SignerOp :: SignCounterpartyCommitment ,
137
+ ) ;
138
+ }
133
139
140
+ let tx_complete_msg = TxComplete { channel_id } ;
134
141
nodes[ 1 ] . node . handle_tx_complete ( nodes[ 0 ] . node . get_our_node_id ( ) , & tx_complete_msg) ;
142
+
143
+ #[ cfg( async_signing) ] {
144
+ assert ! ( nodes[ 1 ] . node. get_and_clear_pending_msg_events( ) . is_empty( ) ) ;
145
+ nodes[ 1 ] . enable_channel_signer_op (
146
+ & nodes[ 0 ] . node . get_our_node_id ( ) , & channel_id, SignerOp :: SignCounterpartyCommitment ,
147
+ ) ;
148
+ nodes[ 1 ] . node . signer_unblocked ( Some ( ( nodes[ 0 ] . node . get_our_node_id ( ) , channel_id) ) ) ;
149
+ }
150
+
135
151
let msg_events = nodes[ 1 ] . node . get_and_clear_pending_msg_events ( ) ;
136
152
assert_eq ! ( msg_events. len( ) , 1 ) ;
137
153
let _msg_commitment_signed_from_1 = match msg_events[ 0 ] {
0 commit comments