chore(mempool_node): change consensus_manager server type

commit-id:7923c2da

crates/consensus_manager/src/communication.rs

@@ -1,23 +1,19 @@
 use async_trait::async_trait;
 use starknet_consensus_manager_types::communication::{
     ConsensusManagerRequest,
-    ConsensusManagerRequestAndResponseSender,
     ConsensusManagerResponse,
 };
 use starknet_mempool_infra::component_definitions::ComponentRequestHandler;
-use starknet_mempool_infra::component_server::LocalActiveComponentServer;
-use tokio::sync::mpsc::Receiver;
+use starknet_mempool_infra::component_server::EmptyServer;
 
 use crate::consensus_manager::ConsensusManager;
 
-pub type LocalConsensusManagerServer =
-    LocalActiveComponentServer<ConsensusManager, ConsensusManagerRequest, ConsensusManagerResponse>;
+pub type ConsensusManagerServer = EmptyServer<ConsensusManager>;
 
-pub fn create_local_consensus_manager_server(
+pub fn create_consensus_manager_server(
     consensus_manager: ConsensusManager,
-    rx_consensus_manager: Receiver<ConsensusManagerRequestAndResponseSender>,
-) -> LocalConsensusManagerServer {
-    LocalActiveComponentServer::new(consensus_manager, rx_consensus_manager)
+) -> ConsensusManagerServer {
+    EmptyServer::new(consensus_manager)
 }
 
 #[async_trait]

crates/mempool_node/src/servers.rs

@@ -4,7 +4,7 @@ use std::pin::Pin;
 use futures::{Future, FutureExt};
 use starknet_batcher::communication::{create_local_batcher_server, LocalBatcherServer};
 use starknet_consensus_manager::communication::{
-    create_local_consensus_manager_server,
+    create_consensus_manager_server,
     LocalConsensusManagerServer,
 };
 use starknet_gateway::communication::{create_gateway_server, GatewayServer};
@@ -40,7 +40,7 @@ pub fn create_servers(
         None
     };
     let consensus_manager_server = if config.components.consensus_manager.execute {
-        Some(Box::new(create_local_consensus_manager_server(
+        Some(Box::new(create_consensus_manager_server(
             components.consensus_manager.expect("Consensus Manager is not initialized."),
             communication.take_consensus_manager_rx(),
         )))