refactor: [#1519] rename Swarms to Registry

Author: josecelano

packages/swarm-coordination-registry/src/container.rs

@@ -6,10 +6,10 @@ use crate::event::bus::EventBus;
 use crate::event::sender::Broadcaster;
 use crate::event::{self};
 use crate::statistics::repository::Repository;
-use crate::{statistics, Swarms};
+use crate::{statistics, Registry};
 
 pub struct TorrentRepositoryContainer {
-    pub swarms: Arc<Swarms>,
+    pub swarms: Arc<Registry>,
     pub event_bus: Arc<event::bus::EventBus>,
     pub stats_event_sender: event::sender::Sender,
     pub stats_repository: Arc<statistics::repository::Repository>,
@@ -26,7 +26,7 @@ impl TorrentRepositoryContainer {
 
         let stats_event_sender = event_bus.sender();
 
-        let swarms = Arc::new(Swarms::new(stats_event_sender.clone()));
+        let swarms = Arc::new(Registry::new(stats_event_sender.clone()));
 
         Self {
             swarms,

packages/swarm-coordination-registry/src/lib.rs

@@ -8,7 +8,7 @@ use std::sync::Arc;
 use tokio::sync::Mutex;
 use torrust_tracker_clock::clock;
 
-pub type Swarms = swarm::registry::Registry;
+pub type Registry = swarm::registry::Registry;
 pub type SwarmHandle = Arc<Mutex<Coordinator>>;
 pub type Coordinator = swarm::coordinator::Coordinator;
 

packages/swarm-coordination-registry/src/statistics/activity_metrics_updater.rs

@@ -11,12 +11,12 @@ use tracing::instrument;
 
 use super::repository::Repository;
 use crate::statistics::{TORRENT_REPOSITORY_PEERS_INACTIVE_TOTAL, TORRENT_REPOSITORY_TORRENTS_INACTIVE_TOTAL};
-use crate::{CurrentClock, Swarms};
+use crate::{CurrentClock, Registry};
 
 #[must_use]
 #[instrument(skip(swarms, stats_repository))]
 pub fn start_job(
-    swarms: &Arc<Swarms>,
+    swarms: &Arc<Registry>,
     stats_repository: &Arc<Repository>,
     inactivity_cutoff: DurationSinceUnixEpoch,
 ) -> JoinHandle<()> {
@@ -51,7 +51,7 @@ pub fn start_job(
 
 async fn update_activity_metrics(
     interval_in_secs: u64,
-    swarms: &Arc<Swarms>,
+    swarms: &Arc<Registry>,
     stats_repository: &Arc<Repository>,
     inactivity_cutoff: DurationSinceUnixEpoch,
 ) {

packages/tracker-core/src/torrent/manager.rs

@@ -148,7 +148,7 @@ mod tests {
     use std::sync::Arc;
 
     use torrust_tracker_configuration::Core;
-    use torrust_tracker_swarm_coordination_registry::Swarms;
+    use torrust_tracker_swarm_coordination_registry::Registry;
 
     use super::{DatabaseDownloadsMetricRepository, TorrentsManager};
     use crate::databases::setup::initialize_database;
@@ -167,7 +167,7 @@ mod tests {
     }
 
     fn initialize_torrents_manager_with(config: Core) -> (Arc<TorrentsManager>, Arc<TorrentsManagerDeps>) {
-        let swarms = Arc::new(Swarms::default());
+        let swarms = Arc::new(Registry::default());
         let in_memory_torrent_repository = Arc::new(InMemoryTorrentRepository::new(swarms));
         let database = initialize_database(&config);
         let database_persistent_torrent_repository = Arc::new(DatabaseDownloadsMetricRepository::new(&database));

packages/tracker-core/src/torrent/repository/in_memory.rs

@@ -7,7 +7,7 @@ use torrust_tracker_configuration::{TrackerPolicy, TORRENT_PEERS_LIMIT};
 use torrust_tracker_primitives::pagination::Pagination;
 use torrust_tracker_primitives::swarm_metadata::{AggregateActiveSwarmMetadata, SwarmMetadata};
 use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, NumberOfDownloadsBTreeMap};
-use torrust_tracker_swarm_coordination_registry::{SwarmHandle, Swarms};
+use torrust_tracker_swarm_coordination_registry::{Registry, SwarmHandle};
 
 /// In-memory repository for torrent entries.
 ///
@@ -21,12 +21,12 @@ use torrust_tracker_swarm_coordination_registry::{SwarmHandle, Swarms};
 #[derive(Default)]
 pub struct InMemoryTorrentRepository {
     /// The underlying in-memory data structure that stores swarms data.
-    swarms: Arc<Swarms>,
+    swarms: Arc<Registry>,
 }
 
 impl InMemoryTorrentRepository {
     #[must_use]
-    pub fn new(swarms: Arc<Swarms>) -> Self {
+    pub fn new(swarms: Arc<Registry>) -> Self {
         Self { swarms }
     }