fix: add checks if min met

Author: fbwoolf

beacon_node/beacon_chain/src/data_availability_checker/overflow_lru_cache.rs

@@ -367,14 +367,13 @@ impl<E: EthSpec> PendingComponents<E> {
             }
 
             // Log when minimum proofs requirement is met
-            let proof_ids: Vec<_> = self.verified_execution_proofs
+            let proof_ids: Vec<_> = self
+                .verified_execution_proofs
                 .iter()
                 .map(|p| p.proof_id.as_u8().to_string())
                 .collect();
 
-            let slot = self.verified_execution_proofs
-                .first()
-                .map(|p| p.slot);
+            let slot = self.verified_execution_proofs.first().map(|p| p.slot);
 
             self.span.in_scope(|| {
                 if let Some(slot) = slot {
@@ -420,9 +419,15 @@ impl<E: EthSpec> PendingComponents<E> {
             if proof_count > 0 {
                 let slot = self.block.as_ref().map(|b| b.as_block().slot());
                 if let Some(slot) = slot {
-                    info!("[Ethproofs] Block ready for validation with {} execution proofs slot={}", proof_count, slot);
+                    info!(
+                        "[Ethproofs] Block ready for validation with {} execution proofs slot={}",
+                        proof_count, slot
+                    );
                 } else {
-                    info!("[Ethproofs] Block ready for validation with {} execution proofs", proof_count);
+                    info!(
+                        "[Ethproofs] Block ready for validation with {} execution proofs",
+                        proof_count
+                    );
                 }
             }
             debug!("Block and all data components are available");
@@ -706,6 +711,18 @@ impl<T: BeaconChainTypes> DataAvailabilityCheckerInner<T> {
             return Ok(Availability::MissingComponents(block_root));
         }
 
+        // TODO(ethproofs): Added for demo.
+        // Check if we already have the minimum required proofs
+        // If so, don't add more to avoid unnecessary processing
+        if let Some(min_proofs) = self.spec.zkvm_min_proofs_required() {
+            if let Some(pending) = self.critical.read().peek(&block_root) {
+                if pending.execution_proof_subnet_count() >= min_proofs {
+                    // Already have minimum required proofs, skip adding more
+                    return Ok(Availability::MissingComponents(block_root));
+                }
+            }
+        }
+
         // Try to get epoch from existing pending components (if block already arrived)
         // Otherwise use Epoch::new(0) as placeholder (will be corrected when block arrives)
         // Also the component cannot be marked as available, if the block is missing

beacon_node/network/src/network_beacon_processor/gossip_methods.rs

@@ -792,6 +792,29 @@ impl<T: BeaconChainTypes> NetworkBeaconProcessor<T> {
             "Received execution proof via gossip"
         );
 
+        // TODO(ethproofs): Added for demo.
+        // Check if we already have the minimum required proofs for this block
+        // If so, skip verification to avoid unnecessary processing
+        if let Some(min_proofs) = self.chain.min_execution_proofs_required() {
+            if let Some(cached_proof_ids) = self
+                .chain
+                .data_availability_checker
+                .cached_execution_proof_subnet_ids(&block_root)
+            {
+                if cached_proof_ids.len() >= min_proofs {
+                    // Already have minimum required proofs, ignore this one
+                    debug!(
+                        %block_root,
+                        %proof_id,
+                        cached_count = cached_proof_ids.len(),
+                        min_required = min_proofs,
+                        "Ignoring execution proof, minimum proofs already cached"
+                    );
+                    return;
+                }
+            }
+        }
+
         // Verify the execution proof for gossip
         match self
             .chain