feat: add functionality to create all components

commit-id:bb128e01

crates/gateway/src/gateway.rs

@@ -14,8 +14,9 @@ use starknet_mempool_types::mempool_types::{Account, MempoolInput};
 use starknet_sierra_compile::compile::{compile_sierra_to_casm, CompilationUtilError};
 use starknet_sierra_compile::utils::into_contract_class_for_compilation;
 
-use crate::config::{GatewayConfig, GatewayNetworkConfig};
+use crate::config::{GatewayConfig, GatewayNetworkConfig, RpcStateReaderConfig};
 use crate::errors::{GatewayError, GatewayRunError};
+use crate::rpc_state_reader::RpcStateReaderFactory;
 use crate::starknet_api_test_utils::get_sender_address;
 use crate::state_reader::StateReaderFactory;
 use crate::stateful_transaction_validator::StatefulTransactionValidator;
@@ -167,3 +168,12 @@ fn compile_contract_class(declare_tx: &RPCDeclareTransaction) -> GatewayResult<C
     )?;
     Ok(class_info)
 }
+
+pub fn create_gateway(
+    config: GatewayConfig,
+    rpc_state_reader_config: RpcStateReaderConfig,
+    client: SharedMempoolClient,
+) -> Gateway {
+    let state_reader_factory = Arc::new(RpcStateReaderFactory { config: rpc_state_reader_config });
+    Gateway::new(config, state_reader_factory, client)
+}

crates/mempool_node/Cargo.toml

@@ -12,6 +12,8 @@ workspace = true
 clap.workspace = true
 const_format.workspace = true
 starknet_gateway = { path = "../gateway", version = "0.0" }
+starknet_mempool = { path = "../mempool", version = "0.0" }
+starknet_mempool_types = { path = "../mempool_types", version = "0.0" }
 serde.workspace = true
 papyrus_config.workspace = true
 tokio.workspace = true

crates/mempool_node/src/components.rs

@@ -0,0 +1,30 @@
+use starknet_gateway::gateway::{create_gateway, Gateway};
+use starknet_mempool::mempool::Mempool;
+
+use crate::communication::MempoolNodeClients;
+use crate::config::MempoolNodeConfig;
+
+pub struct Components {
+    pub gateway: Option<Gateway>,
+    pub mempool: Option<Mempool>,
+}
+
+pub fn create_components(config: &MempoolNodeConfig, clients: &MempoolNodeClients) -> Components {
+    let gateway_component = if config.components.gateway_component.execute {
+        let mempool_clent =
+            clients.get_mempool_client().expect("Mempool Client should be available");
+
+        Some(create_gateway(
+            config.gateway_config.clone(),
+            config.rpc_state_reader_config.clone(),
+            mempool_clent,
+        ))
+    } else {
+        None
+    };
+
+    let mempool_component =
+        if config.components.mempool_component.execute { Some(Mempool::empty()) } else { None };
+
+    Components { gateway: gateway_component, mempool: mempool_component }
+}

crates/mempool_node/src/lib.rs

@@ -1,2 +1,4 @@
+pub mod communication;
+pub mod components;
 pub mod config;
 pub mod version;