11use crate :: connection:: send_message;
2+ use crate :: gnark:: verify_gnark;
23use crate :: risc_zero:: verify_risc_zero_proof;
34use crate :: sp1:: verify_sp1_proof;
45use crate :: types:: batch_queue:: BatchQueue ;
5- use crate :: { gnark:: verify_gnark, types:: batch_queue:: BatchQueueEntry } ;
66use aligned_sdk:: core:: types:: {
77 ProofInvalidReason , ProvingSystemId , ValidityResponseMessage , VerificationData ,
88} ;
@@ -84,7 +84,7 @@ pub(crate) async fn filter_disabled_verifiers(
8484 batch_queue : BatchQueue ,
8585 disabled_verifiers : MutexGuard < ' _ , U256 > ,
8686) -> BatchQueue {
87- let mut removed_entries = Vec :: new ( ) ;
87+ let mut removed_senders = Vec :: new ( ) ;
8888 let mut filtered_batch_queue = BatchQueue :: new ( ) ;
8989 for ( entry, entry_priority) in batch_queue. iter ( ) {
9090 let verification_data = & entry. nonced_verification_data . verification_data ;
@@ -106,12 +106,9 @@ pub(crate) async fn filter_disabled_verifiers(
106106 )
107107 . await ;
108108 }
109- removed_entries . push ( entry. clone ( ) ) ;
109+ removed_senders . push ( entry. sender ) ;
110110 continue ;
111- } else if removed_entries
112- . iter ( )
113- . any ( |e : & BatchQueueEntry | e. sender == entry. sender )
114- {
111+ } else if removed_senders. contains ( & entry. sender ) {
115112 let ws_sink = entry. messaging_sink . as_ref ( ) ;
116113 if let Some ( ws_sink) = ws_sink {
117114 send_message (
0 commit comments