feat: add functionality to create all servers

commit-id:0f64f96b

crates/mempool_node/Cargo.toml

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

crates/mempool_node/src/lib.rs

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

crates/mempool_node/src/servers.rs

@@ -0,0 +1,41 @@
+use starknet_gateway::communication::create_gateway_server;
+use starknet_mempool::communication::create_mempool_server;
+use starknet_mempool_infra::component_server::ComponentServerStarter;
+
+use crate::communication::MempoolNodeCommunication;
+use crate::components::Components;
+use crate::config::MempoolNodeConfig;
+
+pub struct Servers {
+    pub gateway: Option<Box<dyn ComponentServerStarter>>,
+    pub mempool: Option<Box<dyn ComponentServerStarter>>,
+}
+
+pub fn create_servers(
+    config: &MempoolNodeConfig,
+    mut communication: MempoolNodeCommunication,
+    components: Components,
+) -> Servers {
+    let gateway_server: Option<Box<dyn ComponentServerStarter>> =
+        if config.components.gateway_component.execute {
+            Some(Box::new(create_gateway_server(
+                components.gateway.expect("Gateway is not initialized."),
+            )))
+        } else {
+            None
+        };
+
+    let mempool_server: Option<Box<dyn ComponentServerStarter>> =
+        if config.components.mempool_component.execute {
+            Some(Box::new(create_mempool_server(
+                components.mempool.expect("Mempool is not initialized."),
+                communication.take_mempool_rx(),
+            )))
+        } else {
+            None
+        };
+
+    Servers { gateway: gateway_server, mempool: mempool_server }
+}
+
+// TODO (Lev): Implement the run server components function.