adjust test timoeut

nomos-core/src/wire.rs

@@ -24,7 +24,7 @@ type BincodeOptions = WithOtherTrailing<
     RejectTrailing,
 >;
 
-const DATA_LIMIT: u64 = 2048; // Do not serialize/deserialize more than 2Kb
+const DATA_LIMIT: u64 = 1 << 19; // Do not serialize/deserialize more than 16Kb
 static OPTIONS: Lazy<BincodeOptions> = Lazy::new(|| {
     bincode::DefaultOptions::new()
         .with_little_endian()

nomos-libp2p/src/lib.rs

@@ -43,6 +43,7 @@ impl Behaviour {
             gossipsub::ConfigBuilder::from(gossipsub_config)
                 .validation_mode(gossipsub::ValidationMode::None)
                 .message_id_fn(compute_message_id)
+                .max_transmit_size(1 << 19)
                 .build()?,
         )?;
         Ok(Self {

nomos-services/cryptarchia-consensus/src/leadership.rs

@@ -38,7 +38,7 @@ impl Leader {
         }
     }
 
-    pub fn build_proof_for(
+    pub async fn build_proof_for(
         &self,
         note_tree: &NoteTree,
         epoch_state: &EpochState,
@@ -47,9 +47,19 @@ impl Leader {
     ) -> Option<Risc0LeaderProof> {
         let notes = self.notes.get(&parent)?;
         for note in notes {
-            let cm_root = [0; 32];
+            let Some(index) = note_tree
+                .commitments()
+                .iter()
+                .position(|cm| cm == &note.note_commitment())
+            else {
+                continue;
+            };
+
+            let input_cm_path = note_tree
+                .witness(index)
+                .expect("Note was found in the tree");
             let public_inputs = LeaderPublic::new(
-                cm_root,
+                note_tree.root(),
                 *epoch_state.nonce(),
                 slot.into(),
                 self.config.consensus_config.active_slot_coeff,
@@ -64,20 +74,20 @@ impl Leader {
                     note.note.value,
                     epoch_state.total_stake()
                 );
-                let index = note_tree
+                let input = *note;
-                    .commitments()
+                return Some(
-                    .iter()
+                    tokio::task::spawn_blocking(move || {
-                    .position(|cm| cm == &note.note_commitment())?;
+                        Risc0LeaderProof::build(
-                let input_cm_path = note_tree
+                            public_inputs,
-                    .witness(index)
+                            LeaderPrivate {
-                    .expect("Note was found in the tree");
+                                input,
-                return Some(Risc0LeaderProof::build(
+                                input_cm_path,
-                    public_inputs,
+                            },
-                    LeaderPrivate {
+                        )
-                        input: *note,
+                    })
-                        input_cm_path,
+                    .await
-                    },
+                    .ok()?,
-                ));
+                );
             }
         }
 

nomos-services/cryptarchia-consensus/src/lib.rs

@@ -344,7 +344,7 @@ where
                             tracing::error!("trying to propose a block for slot {} but epoch state is not available", u64::from(slot));
                             continue;
                         };
-                        if let Some(proof) = leader.build_proof_for(note_tree, epoch_state, slot, parent) {
+                        if let Some(proof) = leader.build_proof_for(note_tree, epoch_state, slot, parent).await {
                             tracing::debug!("proposing block...");
                             // TODO: spawn as a separate task?
                             let block = Self::propose_block(

tests/src/nodes/nomos.rs

@@ -258,7 +258,7 @@ impl Node for NomosNode {
             },
         };
         let time_config = TimeConfig {
-            slot_duration: Duration::from_secs(1),
+            slot_duration: Duration::from_secs(30),
             chain_start_time: OffsetDateTime::now_utc(),
         };