node: remove TxFilter

node/src/lib.rs

@@ -133,16 +133,6 @@ pub trait LongLivedService<N: Network, DB: database::DB, VM: vm::VMExecution>:
         Ok(())
     }
 
-    async fn add_filter(
-        &self,
-        topic: u8,
-        filter_fn: BoxedFilter,
-        network: &Arc<RwLock<N>>,
-    ) -> anyhow::Result<()> {
-        network.write().await.add_filter(topic, filter_fn).await?;
-        Ok(())
-    }
-
     /// Returns service name.
     fn name(&self) -> &'static str;
 }

node/src/mempool.rs

@@ -48,16 +48,6 @@ impl Default for MempoolSrv {
     }
 }
 
-pub struct TxFilter {}
-impl crate::Filter for TxFilter {
-    fn filter(&mut self, _msg: &Message) -> anyhow::Result<()> {
-        // TODO: Ensure transaction does not exist in the mempool state
-        // TODO: Ensure transaction does not exist in blockchain
-        // TODO: Check  Nullifier
-        Ok(())
-    }
-}
-
 #[async_trait]
 impl<N: Network, DB: database::DB, VM: vm::VMExecution>
     LongLivedService<N, DB, VM> for MempoolSrv
@@ -85,16 +75,6 @@ impl<N: Network, DB: database::DB, VM: vm::VMExecution>
         )
         .await?;
 
-        // Add a filter that will discard any transactions invalid to the actual
-        // mempool, blockchain state.
-        LongLivedService::<N, DB, VM>::add_filter(
-            self,
-            Topics::Tx.into(),
-            Box::new(TxFilter {}),
-            &network,
-        )
-        .await?;
-
         loop {
             if let Ok(msg) = self.inbound.recv().await {
                 match &msg.payload {