refactor(mempool_p2p): rename modules to propagator and runner (#1601)

crates/mempool_node/src/components.rs

@@ -5,7 +5,7 @@ use starknet_consensus_manager::consensus_manager::ConsensusManager;
 use starknet_gateway::gateway::{create_gateway, Gateway};
 use starknet_http_server::http_server::{create_http_server, HttpServer};
 use starknet_mempool::communication::{create_mempool, MempoolCommunicationWrapper};
-use starknet_mempool_p2p::sender::EmptyMempoolP2pPropagatorClient;
+use starknet_mempool_p2p::propagator::EmptyMempoolP2pPropagatorClient;
 use starknet_monitoring_endpoint::monitoring_endpoint::{
     create_monitoring_endpoint,
     MonitoringEndpoint,

crates/mempool_p2p/src/lib.rs

@@ -1,14 +1,14 @@
 pub mod config;
-pub mod receiver;
-pub mod sender;
+pub mod propagator;
+pub mod runner;
 
 use papyrus_network::gossipsub_impl::Topic;
 use papyrus_network::network_manager::{BroadcastTopicChannels, NetworkManager};
 use starknet_gateway_types::communication::SharedGatewayClient;
 
 use crate::config::MempoolP2pConfig;
-use crate::receiver::MempoolP2pRunner;
-use crate::sender::MempoolP2pPropagator;
+use crate::propagator::MempoolP2pPropagator;
+use crate::runner::MempoolP2pRunner;
 
 const MEMPOOL_TOPIC: &str = "starknet_mempool_transaction_propagation/0.1.0";
 

crates/mempool_p2p/src/sender/test.rs → crates/mempool_p2p/src/propagator/test.rs

@@ -13,7 +13,7 @@ use starknet_mempool_p2p_types::communication::MempoolP2pPropagatorRequest;
 use starknet_sequencer_infra::component_definitions::ComponentRequestHandler;
 use tokio::time::timeout;
 
-use crate::sender::MempoolP2pPropagator;
+use super::MempoolP2pPropagator;
 
 const TIMEOUT: std::time::Duration = std::time::Duration::from_secs(1);
 

crates/mempool_p2p/src/receiver/test.rs → crates/mempool_p2p/src/runner/test.rs

@@ -22,7 +22,7 @@ use starknet_gateway_types::gateway_types::GatewayInput;
 use starknet_sequencer_infra::component_definitions::ComponentStarter;
 use tokio::time::sleep;
 
-use crate::receiver::MempoolP2pRunner;
+use super::MempoolP2pRunner;
 
 // TODO(eitan): Make it an automock
 #[derive(Clone)]