feat(mempool): implement commit-block first part that removes txs fro…

…m queue

crates/mempool/src/mempool.rs

@@ -70,8 +70,20 @@ impl Mempool {
     // push back.
     pub fn commit_block(
         &mut self,
-        _state_changes: HashMap<ContractAddress, AccountState>,
+        state_changes: HashMap<ContractAddress, AccountState>,
     ) -> MempoolResult<()> {
+        for (address, AccountState { nonce }) in state_changes {
+            // Dequeue transactions from the queue in the following cases:
+            // 1. Remove a transaction from queue with nonce lower than those committed to the
+            //    block, applicable when the block is from the same leader.
+            // 2. Remove a transaction from queue with nonce greater than those committed to the
+            //    block, applicable when the block is from a different leader.
+            if self.tx_queue.get_nonce(address).is_some_and(|queued_nonce| queued_nonce != nonce) {
+                self.tx_queue.remove(address);
+            }
+            // TODO: remove the transactions from the tx_pool.
+        }
+        // TODO: update the tx_queue with the new state changes.
         todo!()
     }
 

crates/mempool/src/transaction_queue.rs

@@ -52,13 +52,13 @@ impl TransactionQueue {
         self.queue.iter().rev().map(|tx| &tx.0)
     }
 
-    pub fn _get_nonce(&self, address: ContractAddress) -> Option<Nonce> {
+    pub fn get_nonce(&self, address: ContractAddress) -> Option<Nonce> {
         self.address_to_tx.get(&address).map(|tx| tx.nonce)
     }
 
     /// Removes the transaction of the given account address from the queue.
     /// This is well-defined, since there is at most one transaction per address in the queue.
-    pub fn _remove(&mut self, address: ContractAddress) -> bool {
+    pub fn remove(&mut self, address: ContractAddress) -> bool {
         if let Some(tx) = self.address_to_tx.remove(&address) {
             return self.queue.remove(&tx.into());
         }