Land verified RPC stack

crates/mempool/src/admission.rs

@@ -2421,17 +2421,14 @@ mod tests {
     {
         struct Observer(AtomicUsize);
         impl crate::MempoolObserver for Observer {
-            fn wants_accepted_transactions(&self) -> bool {
-                false
-            }
             fn on_mutation(&self, _: &crate::MutationEnvelope) {
                 self.0.fetch_add(1, Ordering::SeqCst);
             }
         }
         let observer = Arc::new(Observer(AtomicUsize::new(0)));
         let preview_gateway = Arc::new(MempoolGateway::new(
             Arc::new(RwLock::new(Mempool::new(crate::MempoolLimits::default()))),
-            Some(observer.clone()),
+            Some((observer.clone(), crate::BodyInterest::Metadata)),
             ValidationEngine::Native,
             None,
         ));
@@ -2997,9 +2994,6 @@ mod tests {
     struct ReorgRecording(Mutex<Vec<(Txid, AdmissionOrigin)>>);
 
     impl crate::MempoolObserver for ReorgRecording {
-        fn wants_accepted_transactions(&self) -> bool {
-            false
-        }
         fn on_mutation(&self, envelope: &crate::MutationEnvelope) {
             let mut seen = self.0.lock();
             for change in &envelope.result.changes {
@@ -3018,9 +3012,6 @@ mod tests {
     struct ReorgBatchLog(Mutex<Vec<ReorgBatch>>);
 
     impl crate::MempoolObserver for ReorgBatchLog {
-        fn wants_accepted_transactions(&self) -> bool {
-            false
-        }
         fn on_mutation(&self, envelope: &crate::MutationEnvelope) {
             let mut seen = self.0.lock();
             seen.push((
@@ -3039,7 +3030,7 @@ mod tests {
         let leg: Arc<dyn crate::MempoolObserver> = observer.clone();
         Arc::new(MempoolGateway::new(
             Arc::new(RwLock::new(Mempool::new(crate::MempoolLimits::default()))),
-            Some(leg),
+            Some((leg, crate::BodyInterest::Metadata)),
             ValidationEngine::Native,
             None,
         ))
@@ -3255,7 +3246,7 @@ mod tests {
         let leg: Arc<dyn crate::MempoolObserver> = log.clone();
         let gateway = Arc::new(MempoolGateway::new(
             Arc::new(RwLock::new(Mempool::new(limits))),
-            Some(leg),
+            Some((leg, crate::BodyInterest::Metadata)),
             ValidationEngine::Native,
             None,
         ));
@@ -3641,7 +3632,7 @@ mod tests {
         let leg: Arc<dyn crate::MempoolObserver> = log.clone();
         let gateway = Arc::new(MempoolGateway::new(
             Arc::new(RwLock::new(Mempool::new(crate::MempoolLimits::default()))),
-            Some(leg),
+            Some((leg, crate::BodyInterest::Metadata)),
             ValidationEngine::Native,
             None,
         ));
@@ -3667,7 +3658,7 @@ mod tests {
                             max_total_bytes: 100,
                             ..crate::MempoolLimits::default()
                         }))),
-                        Some(observer),
+                        Some((observer, crate::BodyInterest::Metadata)),
                         ValidationEngine::Native,
                         None,
                     );
@@ -3793,7 +3784,7 @@ mod tests {
                     max_total_bytes: 100,
                     ..crate::MempoolLimits::default()
                 }))),
-                Some(observer),
+                Some((observer, crate::BodyInterest::Metadata)),
                 ValidationEngine::Native,
                 None,
             ));