Add verification to non-payers

Author: Mechanix97

batcher/aligned-batcher/src/lib.rs

@@ -823,7 +823,7 @@ impl Batcher {
                     .await;
                 } else {
                     // Can't add new entry with less priority to the batch queue
-                    info!("Can't add new entry, the batcher queue is full");
+                    error!("Can't add new entry, the batcher queue is full");
                     send_message(
                         ws_conn_sink.clone(),
                         SubmitProofResponseMessage::BatchQueueLimitExceededError,
@@ -1767,6 +1767,16 @@ impl Batcher {
 
         let batch_state_lock = self.batch_state.lock().await;
 
+        if batch_state_lock.batch_queue.len() == self.max_queue_size {
+            error!("Can't add new entry, the batcher queue is full");
+            send_message(
+                ws_sink.clone(),
+                SubmitProofResponseMessage::BatchQueueLimitExceededError,
+            )
+            .await;
+            return Ok(());
+        }
+
         let nonced_verification_data = NoncedVerificationData::new(
             client_msg.verification_data.verification_data.clone(),
             client_msg.verification_data.nonce,

config-files/config-batcher-docker.yaml

@@ -24,6 +24,7 @@ batcher:
   max_proof_size: 67108864 # 64 MiB
   max_batch_byte_size: 268435456 # 256 MiB
   max_batch_proof_qty: 3000 # 3000 proofs in a batch
+  max_queue_size: 10000
   pre_verification_is_enabled: true
   metrics_port: 9093
   telemetry_ip_port_address: localhost:4001

config-files/config-batcher-ethereum-package.yaml

@@ -22,6 +22,7 @@ batcher:
   max_proof_size: 67108864 # 64 MiB
   max_batch_byte_size: 268435456 # 256 MiB
   max_batch_proof_qty: 3000 # 3000 proofs in a batch
+  max_queue_size: 10000
   pre_verification_is_enabled: true
   metrics_port: 9093
   telemetry_ip_port_address: localhost:4001