fix test

core/src/config.rs

@@ -179,8 +179,8 @@ impl Default for BridgeConfig {
 
             num_operators: 3,
             num_watchtowers: 4,
-            num_sequential_collateral_txs: 1,
-            num_kickoffs_per_sequential_collateral_tx: 1, // TODO: increase after implementing stream for watchtower params
+            num_sequential_collateral_txs: 2,
+            num_kickoffs_per_sequential_collateral_tx: 2,
             operators_xonly_pks: vec![
                 XOnlyPublicKey::from_str(
                     "4f355bdcb7cc0af728ef3cceb9615d90684bb5b2ca5f859ab0f0b704075871aa",

core/src/rpc/aggregator.rs

@@ -604,9 +604,9 @@ impl ClementineAggregator for Aggregator {
         ));
 
         // Create channels for pipeline communication
-        let (agg_nonce_sender, agg_nonce_receiver) = channel(32);
-        let (partial_sig_sender, partial_sig_receiver) = channel(32);
-        let (final_sig_sender, final_sig_receiver) = channel(32);
+        let (agg_nonce_sender, agg_nonce_receiver) = channel(3200);
+        let (partial_sig_sender, partial_sig_receiver) = channel(3200);
+        let (final_sig_sender, final_sig_receiver) = channel(3200);
 
         // Start the nonce aggregation pipe.
         let nonce_agg_handle = tokio::spawn(nonce_aggregator(

core/src/rpc/verifier.rs

@@ -262,7 +262,10 @@ impl ClementineVerifier for Verifier {
         let watchtower_id = parser::watchtower::parse_id(&mut in_stream).await?;
 
         let mut watchtower_winternitz_public_keys = Vec::new();
-        for _ in 0..self.config.num_operators {
+        for _ in 0..self.config.num_operators
+            * self.config.num_sequential_collateral_txs
+            * self.config.num_kickoffs_per_sequential_collateral_tx
+        {
             watchtower_winternitz_public_keys
                 .push(parser::watchtower::parse_winternitz_public_key(&mut in_stream).await?);
         }
@@ -484,11 +487,11 @@ impl ClementineVerifier for Verifier {
                 })?;
 
                 nonce_idx += 1;
+                tracing::info!("Verifier {} signed sighash {} of {}", verifier.idx, nonce_idx, num_required_sigs);
                 if nonce_idx == num_required_sigs {
                     break;
                 }
             }
-
             // Drop all the nonces except the last one, to avoid reusing the nonces.
             let last_nonce = session
                 .nonces