finish mempool side

base_layer/core/src/mempool/mempool.rs

@@ -102,8 +102,8 @@ impl Mempool {
     }
 
     /// After a sync event, we can move all orphan transactions to the unconfirmed pool after validation
-    pub async fn process_sync(&self, blocks_added: u64) -> Result<(), MempoolError> {
-        self.with_write_access(move |storage| storage.process_sync(blocks_added))
+    pub async fn process_sync(&self) -> Result<(), MempoolError> {
+        self.with_write_access(move |storage| storage.process_sync())
             .await
     }
 

base_layer/core/src/mempool/mempool_storage.rs

@@ -203,7 +203,7 @@ impl MempoolStorage {
     }
 
     /// After a sync event, we need to try to add in all the transaction form the reorg pool.
-    pub fn process_sync(&mut self, blocks_added: u64) -> Result<(), MempoolError> {
+    pub fn process_sync(&mut self) -> Result<(), MempoolError> {
         debug!(target: LOG_TARGET, "Mempool processing sync finished");
         // lets remove and revalidate all transactions from the mempool. All we know is that the state has changed, but
         // we dont have the data to know what.

base_layer/core/src/mempool/service/inbound_handlers.rs

@@ -174,9 +174,8 @@ impl MempoolInboundHandlers {
             },
             ValidBlockAdded(_, _) => {},
             BlockSyncRewind(_) => {},
-            BlockSyncComplete(tip_block, starting_sync_height) => {
-                let height_diff = tip_block.height() - starting_sync_height;
-                self.mempool.process_sync(height_diff).await?;
+            BlockSyncComplete(_,_) => {
+                self.mempool.process_sync().await?;
             },
             AddBlockValidationFailed {
                 block: failed_block,