feat(starknet_mempool_types): add GetMempoolContent requence/responce

Author: lev-starkware

crates/starknet_mempool/src/communication.rs

@@ -123,6 +123,11 @@ impl ComponentRequestHandler<MempoolRequest, MempoolResponse> for MempoolCommuni
             MempoolRequest::UpdateGasPrice(gas_price) => {
                 MempoolResponse::UpdateGasPrice(self.update_gas_price(gas_price))
             }
+            MempoolRequest::GetMempoolSnapshot() => {
+                unimplemented!(
+                    "GetMempoolSnapshot is not yet implemented in MempoolCommunicationWrapper"
+                );
+            }
         }
     }
 }

crates/starknet_mempool_types/src/communication.rs

@@ -21,7 +21,7 @@ use starknet_sequencer_infra::component_definitions::{
 use thiserror::Error;
 
 use crate::errors::MempoolError;
-use crate::mempool_types::{AddTransactionArgs, CommitBlockArgs};
+use crate::mempool_types::{AddTransactionArgs, CommitBlockArgs, MempoolSnapshot};
 
 pub type LocalMempoolClient = LocalComponentClient<MempoolRequest, MempoolResponse>;
 pub type RemoteMempoolClient = RemoteComponentClient<MempoolRequest, MempoolResponse>;
@@ -61,6 +61,7 @@ pub enum MempoolRequest {
     GetTransactions(usize),
     AccountTxInPoolOrRecentBlock(ContractAddress),
     UpdateGasPrice(NonzeroGasPrice),
+    GetMempoolSnapshot(),
 }
 
 #[derive(Clone, Debug, Serialize, Deserialize)]
@@ -70,6 +71,7 @@ pub enum MempoolResponse {
     GetTransactions(MempoolResult<Vec<InternalRpcTransaction>>),
     AccountTxInPoolOrRecentBlock(MempoolResult<bool>),
     UpdateGasPrice(MempoolResult<()>),
+    GetMempoolSnapshot(MempoolResult<MempoolSnapshot>),
 }
 
 #[derive(Clone, Debug, Error)]

crates/starknet_mempool_types/src/mempool_types.rs

@@ -34,3 +34,8 @@ pub struct CommitBlockArgs {
 }
 
 pub type MempoolResult<T> = Result<T, MempoolError>;
+
+#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
+pub struct MempoolSnapshot {
+    pub transactions: Vec<TransactionHash>,
+}