feat(builder): remove offending UOs after onchain revert

alchemyplatform · Feb 14, 2025 · acf478f · acf478f
1 parent 3f0edb3
commit acf478f
Show file tree

Hide file tree

Showing 14 changed files with 383 additions and 199 deletions.
diff --git a/bin/rundler/src/cli/proxy.rs b/bin/rundler/src/cli/proxy.rs
@@ -34,8 +34,8 @@ impl SubmissionProxy for PassThroughProxy {
 
     async fn process_revert(
         &self,
-        _revert_data: Bytes,
-        _ops: Vec<UserOpsPerAggregator<UserOperationVariant>>,
+        _revert_data: &Bytes,
+        _ops: &[UserOpsPerAggregator<UserOperationVariant>],
     ) -> Vec<B256> {
         vec![]
     }

diff --git a/crates/aggregators/pbh/src/proxy.rs b/crates/aggregators/pbh/src/proxy.rs
@@ -28,8 +28,8 @@ impl SubmissionProxy for PbhSubmissionProxy {
 
     async fn process_revert(
         &self,
-        revert_data: Bytes,
-        _ops: Vec<UserOpsPerAggregator<UserOperationVariant>>,
+        revert_data: &Bytes,
+        _ops: &[UserOpsPerAggregator<UserOperationVariant>],
     ) -> Vec<B256> {
         tracing::info!(
             "PBH submission proxy received revert data, processing unimplemented: {revert_data:?}"

diff --git a/crates/builder/src/bundle_proposer.rs b/crates/builder/src/bundle_proposer.rs
@@ -896,8 +896,8 @@ where
                         .to_ops_per_aggregator()
                         .into_iter()
                         .map(|uo| uo.into_uo_variants())
-                        .collect();
-                    let to_remove = proxy.process_revert(revert_data.clone(), ops).await;
+                        .collect::<Vec<_>>();
+                    let to_remove = proxy.process_revert(&revert_data, &ops).await;
                     let mut removed = false;
                     for hash in to_remove {
                         removed |= self.reject_hash(context, hash).await;