refactor: [#1541] rename type alias PersistentTorrents to NumberOfDownloadsBTreeMap

josecelano · josecelano · commit bcf2338b04b5 · 2025-05-27T15:12:26.000+01:00
diff --git a/packages/primitives/src/lib.rs b/packages/primitives/src/lib.rs
@@ -19,4 +19,4 @@ use bittorrent_primitives::info_hash::InfoHash;
 pub type DurationSinceUnixEpoch = Duration;
 
 pub type NumberOfDownloads = u32;
-pub type PersistentTorrents = BTreeMap<InfoHash, NumberOfDownloads>;
+pub type NumberOfDownloadsBTreeMap = BTreeMap<InfoHash, NumberOfDownloads>;
diff --git a/packages/torrent-repository-benchmarking/src/repository/dash_map_mutex_std.rs b/packages/torrent-repository-benchmarking/src/repository/dash_map_mutex_std.rs
@@ -5,7 +5,7 @@ use dashmap::DashMap;
 use torrust_tracker_configuration::TrackerPolicy;
 use torrust_tracker_primitives::pagination::Pagination;
 use torrust_tracker_primitives::swarm_metadata::{AggregateSwarmMetadata, SwarmMetadata};
-use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, PersistentTorrents};
+use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, NumberOfDownloadsBTreeMap};
 
 use super::Repository;
 use crate::entry::peer_list::PeerList;
@@ -77,7 +77,7 @@ where
         }
     }
 
-    fn import_persistent(&self, persistent_torrents: &PersistentTorrents) {
+    fn import_persistent(&self, persistent_torrents: &NumberOfDownloadsBTreeMap) {
         for (info_hash, completed) in persistent_torrents {
             if self.torrents.contains_key(info_hash) {
                 continue;
diff --git a/packages/torrent-repository-benchmarking/src/repository/mod.rs b/packages/torrent-repository-benchmarking/src/repository/mod.rs
@@ -2,7 +2,7 @@ use bittorrent_primitives::info_hash::InfoHash;
 use torrust_tracker_configuration::TrackerPolicy;
 use torrust_tracker_primitives::pagination::Pagination;
 use torrust_tracker_primitives::swarm_metadata::{AggregateSwarmMetadata, SwarmMetadata};
-use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, PersistentTorrents};
+use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, NumberOfDownloadsBTreeMap};
 
 pub mod dash_map_mutex_std;
 pub mod rw_lock_std;
@@ -19,7 +19,7 @@ pub trait Repository<T>: Debug + Default + Sized + 'static {
     fn get(&self, key: &InfoHash) -> Option<T>;
     fn get_metrics(&self) -> AggregateSwarmMetadata;
     fn get_paginated(&self, pagination: Option<&Pagination>) -> Vec<(InfoHash, T)>;
-    fn import_persistent(&self, persistent_torrents: &PersistentTorrents);
+    fn import_persistent(&self, persistent_torrents: &NumberOfDownloadsBTreeMap);
     fn remove(&self, key: &InfoHash) -> Option<T>;
     fn remove_inactive_peers(&self, current_cutoff: DurationSinceUnixEpoch);
     fn remove_peerless_torrents(&self, policy: &TrackerPolicy);
@@ -32,7 +32,7 @@ pub trait RepositoryAsync<T>: Debug + Default + Sized + 'static {
     fn get(&self, key: &InfoHash) -> impl std::future::Future<Output = Option<T>> + Send;
     fn get_metrics(&self) -> impl std::future::Future<Output = AggregateSwarmMetadata> + Send;
     fn get_paginated(&self, pagination: Option<&Pagination>) -> impl std::future::Future<Output = Vec<(InfoHash, T)>> + Send;
-    fn import_persistent(&self, persistent_torrents: &PersistentTorrents) -> impl std::future::Future<Output = ()> + Send;
+    fn import_persistent(&self, persistent_torrents: &NumberOfDownloadsBTreeMap) -> impl std::future::Future<Output = ()> + Send;
     fn remove(&self, key: &InfoHash) -> impl std::future::Future<Output = Option<T>> + Send;
     fn remove_inactive_peers(&self, current_cutoff: DurationSinceUnixEpoch) -> impl std::future::Future<Output = ()> + Send;
     fn remove_peerless_torrents(&self, policy: &TrackerPolicy) -> impl std::future::Future<Output = ()> + Send;
diff --git a/packages/torrent-repository-benchmarking/src/repository/rw_lock_std.rs b/packages/torrent-repository-benchmarking/src/repository/rw_lock_std.rs
@@ -2,7 +2,7 @@ use bittorrent_primitives::info_hash::InfoHash;
 use torrust_tracker_configuration::TrackerPolicy;
 use torrust_tracker_primitives::pagination::Pagination;
 use torrust_tracker_primitives::swarm_metadata::{AggregateSwarmMetadata, SwarmMetadata};
-use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, PersistentTorrents};
+use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, NumberOfDownloadsBTreeMap};
 
 use super::Repository;
 use crate::entry::peer_list::PeerList;
@@ -92,7 +92,7 @@ where
         }
     }
 
-    fn import_persistent(&self, persistent_torrents: &PersistentTorrents) {
+    fn import_persistent(&self, persistent_torrents: &NumberOfDownloadsBTreeMap) {
         let mut torrents = self.get_torrents_mut();
 
         for (info_hash, downloaded) in persistent_torrents {
diff --git a/packages/torrent-repository-benchmarking/src/repository/rw_lock_std_mutex_std.rs b/packages/torrent-repository-benchmarking/src/repository/rw_lock_std_mutex_std.rs
@@ -4,7 +4,7 @@ use bittorrent_primitives::info_hash::InfoHash;
 use torrust_tracker_configuration::TrackerPolicy;
 use torrust_tracker_primitives::pagination::Pagination;
 use torrust_tracker_primitives::swarm_metadata::{AggregateSwarmMetadata, SwarmMetadata};
-use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, PersistentTorrents};
+use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, NumberOfDownloadsBTreeMap};
 
 use super::Repository;
 use crate::entry::peer_list::PeerList;
@@ -87,7 +87,7 @@ where
         }
     }
 
-    fn import_persistent(&self, persistent_torrents: &PersistentTorrents) {
+    fn import_persistent(&self, persistent_torrents: &NumberOfDownloadsBTreeMap) {
         let mut torrents = self.get_torrents_mut();
 
         for (info_hash, completed) in persistent_torrents {
diff --git a/packages/torrent-repository-benchmarking/src/repository/rw_lock_std_mutex_tokio.rs b/packages/torrent-repository-benchmarking/src/repository/rw_lock_std_mutex_tokio.rs
@@ -8,7 +8,7 @@ use futures::{Future, FutureExt};
 use torrust_tracker_configuration::TrackerPolicy;
 use torrust_tracker_primitives::pagination::Pagination;
 use torrust_tracker_primitives::swarm_metadata::{AggregateSwarmMetadata, SwarmMetadata};
-use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, PersistentTorrents};
+use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, NumberOfDownloadsBTreeMap};
 
 use super::RepositoryAsync;
 use crate::entry::peer_list::PeerList;
@@ -101,7 +101,7 @@ where
         metrics
     }
 
-    async fn import_persistent(&self, persistent_torrents: &PersistentTorrents) {
+    async fn import_persistent(&self, persistent_torrents: &NumberOfDownloadsBTreeMap) {
         let mut db = self.get_torrents_mut();
 
         for (info_hash, completed) in persistent_torrents {
diff --git a/packages/torrent-repository-benchmarking/src/repository/rw_lock_tokio.rs b/packages/torrent-repository-benchmarking/src/repository/rw_lock_tokio.rs
@@ -2,7 +2,7 @@ use bittorrent_primitives::info_hash::InfoHash;
 use torrust_tracker_configuration::TrackerPolicy;
 use torrust_tracker_primitives::pagination::Pagination;
 use torrust_tracker_primitives::swarm_metadata::{AggregateSwarmMetadata, SwarmMetadata};
-use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, PersistentTorrents};
+use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, NumberOfDownloadsBTreeMap};
 
 use super::RepositoryAsync;
 use crate::entry::peer_list::PeerList;
@@ -98,7 +98,7 @@ where
         metrics
     }
 
-    async fn import_persistent(&self, persistent_torrents: &PersistentTorrents) {
+    async fn import_persistent(&self, persistent_torrents: &NumberOfDownloadsBTreeMap) {
         let mut torrents = self.get_torrents_mut().await;
 
         for (info_hash, completed) in persistent_torrents {
diff --git a/packages/torrent-repository-benchmarking/src/repository/rw_lock_tokio_mutex_std.rs b/packages/torrent-repository-benchmarking/src/repository/rw_lock_tokio_mutex_std.rs
@@ -4,7 +4,7 @@ use bittorrent_primitives::info_hash::InfoHash;
 use torrust_tracker_configuration::TrackerPolicy;
 use torrust_tracker_primitives::pagination::Pagination;
 use torrust_tracker_primitives::swarm_metadata::{AggregateSwarmMetadata, SwarmMetadata};
-use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, PersistentTorrents};
+use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, NumberOfDownloadsBTreeMap};
 
 use super::RepositoryAsync;
 use crate::entry::peer_list::PeerList;
@@ -92,7 +92,7 @@ where
         metrics
     }
 
-    async fn import_persistent(&self, persistent_torrents: &PersistentTorrents) {
+    async fn import_persistent(&self, persistent_torrents: &NumberOfDownloadsBTreeMap) {
         let mut torrents = self.get_torrents_mut().await;
 
         for (info_hash, completed) in persistent_torrents {
diff --git a/packages/torrent-repository-benchmarking/src/repository/rw_lock_tokio_mutex_tokio.rs b/packages/torrent-repository-benchmarking/src/repository/rw_lock_tokio_mutex_tokio.rs
@@ -4,7 +4,7 @@ use bittorrent_primitives::info_hash::InfoHash;
 use torrust_tracker_configuration::TrackerPolicy;
 use torrust_tracker_primitives::pagination::Pagination;
 use torrust_tracker_primitives::swarm_metadata::{AggregateSwarmMetadata, SwarmMetadata};
-use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, PersistentTorrents};
+use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, NumberOfDownloadsBTreeMap};
 
 use super::RepositoryAsync;
 use crate::entry::peer_list::PeerList;
@@ -95,7 +95,7 @@ where
         metrics
     }
 
-    async fn import_persistent(&self, persistent_torrents: &PersistentTorrents) {
+    async fn import_persistent(&self, persistent_torrents: &NumberOfDownloadsBTreeMap) {
         let mut db = self.get_torrents_mut().await;
 
         for (info_hash, completed) in persistent_torrents {
diff --git a/packages/torrent-repository-benchmarking/src/repository/skip_map_mutex_std.rs b/packages/torrent-repository-benchmarking/src/repository/skip_map_mutex_std.rs
@@ -5,7 +5,7 @@ use crossbeam_skiplist::SkipMap;
 use torrust_tracker_configuration::TrackerPolicy;
 use torrust_tracker_primitives::pagination::Pagination;
 use torrust_tracker_primitives::swarm_metadata::{AggregateSwarmMetadata, SwarmMetadata};
-use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, PersistentTorrents};
+use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, NumberOfDownloadsBTreeMap};
 
 use super::Repository;
 use crate::entry::peer_list::PeerList;
@@ -100,7 +100,7 @@ where
         }
     }
 
-    fn import_persistent(&self, persistent_torrents: &PersistentTorrents) {
+    fn import_persistent(&self, persistent_torrents: &NumberOfDownloadsBTreeMap) {
         for (info_hash, completed) in persistent_torrents {
             if self.torrents.contains_key(info_hash) {
                 continue;
@@ -193,7 +193,7 @@ where
         }
     }
 
-    fn import_persistent(&self, persistent_torrents: &PersistentTorrents) {
+    fn import_persistent(&self, persistent_torrents: &NumberOfDownloadsBTreeMap) {
         for (info_hash, completed) in persistent_torrents {
             if self.torrents.contains_key(info_hash) {
                 continue;
@@ -286,7 +286,7 @@ where
         }
     }
 
-    fn import_persistent(&self, persistent_torrents: &PersistentTorrents) {
+    fn import_persistent(&self, persistent_torrents: &NumberOfDownloadsBTreeMap) {
         for (info_hash, completed) in persistent_torrents {
             if self.torrents.contains_key(info_hash) {
                 continue;
diff --git a/packages/torrent-repository-benchmarking/tests/common/repo.rs b/packages/torrent-repository-benchmarking/tests/common/repo.rs
@@ -2,7 +2,7 @@ use bittorrent_primitives::info_hash::InfoHash;
 use torrust_tracker_configuration::TrackerPolicy;
 use torrust_tracker_primitives::pagination::Pagination;
 use torrust_tracker_primitives::swarm_metadata::{AggregateSwarmMetadata, SwarmMetadata};
-use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, PersistentTorrents};
+use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, NumberOfDownloadsBTreeMap};
 use torrust_tracker_torrent_repository_benchmarking::repository::{Repository as _, RepositoryAsync as _};
 use torrust_tracker_torrent_repository_benchmarking::{
     EntrySingle, TorrentsDashMapMutexStd, TorrentsRwLockStd, TorrentsRwLockStdMutexStd, TorrentsRwLockStdMutexTokio,
@@ -144,7 +144,7 @@ impl Repo {
         }
     }
 
-    pub(crate) async fn import_persistent(&self, persistent_torrents: &PersistentTorrents) {
+    pub(crate) async fn import_persistent(&self, persistent_torrents: &NumberOfDownloadsBTreeMap) {
         match self {
             Repo::RwLockStd(repo) => repo.import_persistent(persistent_torrents),
             Repo::RwLockStdMutexStd(repo) => repo.import_persistent(persistent_torrents),
diff --git a/packages/torrent-repository-benchmarking/tests/repository/mod.rs b/packages/torrent-repository-benchmarking/tests/repository/mod.rs
@@ -7,7 +7,7 @@ use rstest::{fixture, rstest};
 use torrust_tracker_configuration::TrackerPolicy;
 use torrust_tracker_primitives::pagination::Pagination;
 use torrust_tracker_primitives::swarm_metadata::SwarmMetadata;
-use torrust_tracker_primitives::PersistentTorrents;
+use torrust_tracker_primitives::NumberOfDownloadsBTreeMap;
 use torrust_tracker_torrent_repository_benchmarking::entry::Entry as _;
 use torrust_tracker_torrent_repository_benchmarking::repository::dash_map_mutex_std::XacrimonDashMap;
 use torrust_tracker_torrent_repository_benchmarking::repository::rw_lock_std::RwLockStd;
@@ -167,12 +167,12 @@ fn many_hashed_in_order() -> Entries {
 }
 
 #[fixture]
-fn persistent_empty() -> PersistentTorrents {
-    PersistentTorrents::default()
+fn persistent_empty() -> NumberOfDownloadsBTreeMap {
+    NumberOfDownloadsBTreeMap::default()
 }
 
 #[fixture]
-fn persistent_single() -> PersistentTorrents {
+fn persistent_single() -> NumberOfDownloadsBTreeMap {
     let hash = &mut DefaultHasher::default();
 
     hash.write_u8(1);
@@ -182,7 +182,7 @@ fn persistent_single() -> PersistentTorrents {
 }
 
 #[fixture]
-fn persistent_three() -> PersistentTorrents {
+fn persistent_three() -> NumberOfDownloadsBTreeMap {
     let hash = &mut DefaultHasher::default();
 
     hash.write_u8(1);
@@ -445,7 +445,7 @@ async fn it_should_import_persistent_torrents(
     )]
     repo: Repo,
     #[case] entries: Entries,
-    #[values(persistent_empty(), persistent_single(), persistent_three())] persistent_torrents: PersistentTorrents,
+    #[values(persistent_empty(), persistent_single(), persistent_three())] persistent_torrents: NumberOfDownloadsBTreeMap,
 ) {
     make(&repo, &entries).await;
 
diff --git a/packages/torrent-repository/src/swarms.rs b/packages/torrent-repository/src/swarms.rs
@@ -7,7 +7,7 @@ use torrust_tracker_clock::conv::convert_from_timestamp_to_datetime_utc;
 use torrust_tracker_configuration::TrackerPolicy;
 use torrust_tracker_primitives::pagination::Pagination;
 use torrust_tracker_primitives::swarm_metadata::{AggregateSwarmMetadata, SwarmMetadata};
-use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, PersistentTorrents};
+use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, NumberOfDownloadsBTreeMap};
 
 use crate::event::sender::Sender;
 use crate::event::Event;
@@ -356,7 +356,7 @@ impl Swarms {
     /// This method takes a set of persisted torrent entries (e.g., from a
     /// database) and imports them into the in-memory repository for immediate
     /// access.
-    pub fn import_persistent(&self, persistent_torrents: &PersistentTorrents) -> u64 {
+    pub fn import_persistent(&self, persistent_torrents: &NumberOfDownloadsBTreeMap) -> u64 {
         tracing::info!("Importing persisted info about torrents ...");
 
         let mut torrents_imported = 0;
@@ -1271,7 +1271,7 @@ mod tests {
 
             use std::sync::Arc;
 
-            use torrust_tracker_primitives::PersistentTorrents;
+            use torrust_tracker_primitives::NumberOfDownloadsBTreeMap;
 
             use crate::swarms::Swarms;
             use crate::tests::{leecher, sample_info_hash};
@@ -1282,7 +1282,7 @@ mod tests {
 
                 let infohash = sample_info_hash();
 
-                let mut persistent_torrents = PersistentTorrents::default();
+                let mut persistent_torrents = NumberOfDownloadsBTreeMap::default();
 
                 persistent_torrents.insert(infohash, 1);
 
@@ -1302,7 +1302,7 @@ mod tests {
 
                 let infohash = sample_info_hash();
 
-                let mut persistent_torrents = PersistentTorrents::default();
+                let mut persistent_torrents = NumberOfDownloadsBTreeMap::default();
 
                 persistent_torrents.insert(infohash, 1);
                 persistent_torrents.insert(infohash, 2);
@@ -1327,7 +1327,7 @@ mod tests {
 
                 // Try to import the torrent entry
                 let new_number_of_downloads = initial_number_of_downloads + 1;
-                let mut persistent_torrents = PersistentTorrents::default();
+                let mut persistent_torrents = NumberOfDownloadsBTreeMap::default();
                 persistent_torrents.insert(infohash, new_number_of_downloads);
                 swarms.import_persistent(&persistent_torrents);
 
diff --git a/packages/tracker-core/src/databases/driver/mysql.rs b/packages/tracker-core/src/databases/driver/mysql.rs
@@ -13,7 +13,7 @@ use r2d2::Pool;
 use r2d2_mysql::mysql::prelude::Queryable;
 use r2d2_mysql::mysql::{params, Opts, OptsBuilder};
 use r2d2_mysql::MySqlConnectionManager;
-use torrust_tracker_primitives::{NumberOfDownloads, PersistentTorrents};
+use torrust_tracker_primitives::{NumberOfDownloads, NumberOfDownloadsBTreeMap};
 
 use super::{Database, Driver, Error, TORRENTS_DOWNLOADS_TOTAL};
 use crate::authentication::key::AUTH_KEY_LENGTH;
@@ -146,7 +146,7 @@ impl Database for Mysql {
     }
 
     /// Refer to [`databases::Database::load_persistent_torrents`](crate::core::databases::Database::load_persistent_torrents).
-    fn load_all_torrents_downloads(&self) -> Result<PersistentTorrents, Error> {
+    fn load_all_torrents_downloads(&self) -> Result<NumberOfDownloadsBTreeMap, Error> {
         let mut conn = self.pool.get().map_err(|e| (e, DRIVER))?;
 
         let torrents = conn.query_map(
diff --git a/packages/tracker-core/src/databases/driver/sqlite.rs b/packages/tracker-core/src/databases/driver/sqlite.rs
@@ -13,7 +13,7 @@ use r2d2::Pool;
 use r2d2_sqlite::rusqlite::params;
 use r2d2_sqlite::rusqlite::types::Null;
 use r2d2_sqlite::SqliteConnectionManager;
-use torrust_tracker_primitives::{DurationSinceUnixEpoch, NumberOfDownloads, PersistentTorrents};
+use torrust_tracker_primitives::{DurationSinceUnixEpoch, NumberOfDownloads, NumberOfDownloadsBTreeMap};
 
 use super::{Database, Driver, Error, TORRENTS_DOWNLOADS_TOTAL};
 use crate::authentication::{self, Key};
@@ -152,7 +152,7 @@ impl Database for Sqlite {
     }
 
     /// Refer to [`databases::Database::load_persistent_torrents`](crate::core::databases::Database::load_persistent_torrents).
-    fn load_all_torrents_downloads(&self) -> Result<PersistentTorrents, Error> {
+    fn load_all_torrents_downloads(&self) -> Result<NumberOfDownloadsBTreeMap, Error> {
         let conn = self.pool.get().map_err(|e| (e, DRIVER))?;
 
         let mut stmt = conn.prepare("SELECT info_hash, completed FROM torrents")?;
diff --git a/packages/tracker-core/src/databases/mod.rs b/packages/tracker-core/src/databases/mod.rs
@@ -52,7 +52,7 @@ pub mod setup;
 
 use bittorrent_primitives::info_hash::InfoHash;
 use mockall::automock;
-use torrust_tracker_primitives::{NumberOfDownloads, PersistentTorrents};
+use torrust_tracker_primitives::{NumberOfDownloads, NumberOfDownloadsBTreeMap};
 
 use self::error::Error;
 use crate::authentication::{self, Key};
@@ -101,7 +101,7 @@ pub trait Database: Sync + Send {
     /// # Errors
     ///
     /// Returns an [`Error`] if the metrics cannot be loaded.
-    fn load_all_torrents_downloads(&self) -> Result<PersistentTorrents, Error>;
+    fn load_all_torrents_downloads(&self) -> Result<NumberOfDownloadsBTreeMap, Error>;
 
     /// Loads torrent metrics data from the database for one torrent.
     ///
diff --git a/packages/tracker-core/src/statistics/persisted/downloads.rs b/packages/tracker-core/src/statistics/persisted/downloads.rs
@@ -2,7 +2,7 @@
 use std::sync::Arc;
 
 use bittorrent_primitives::info_hash::InfoHash;
-use torrust_tracker_primitives::{NumberOfDownloads, PersistentTorrents};
+use torrust_tracker_primitives::{NumberOfDownloads, NumberOfDownloadsBTreeMap};
 
 use crate::databases::error::Error;
 use crate::databases::Database;
@@ -77,7 +77,7 @@ impl DatabaseDownloadsMetricRepository {
     /// # Errors
     ///
     /// Returns an [`Error`] if the underlying database query fails.
-    pub(crate) fn load_all_torrents_downloads(&self) -> Result<PersistentTorrents, Error> {
+    pub(crate) fn load_all_torrents_downloads(&self) -> Result<NumberOfDownloadsBTreeMap, Error> {
         self.database.load_all_torrents_downloads()
     }
 
@@ -141,7 +141,7 @@ impl DatabaseDownloadsMetricRepository {
 #[cfg(test)]
 mod tests {
 
-    use torrust_tracker_primitives::PersistentTorrents;
+    use torrust_tracker_primitives::NumberOfDownloadsBTreeMap;
 
     use super::DatabaseDownloadsMetricRepository;
     use crate::databases::setup::initialize_database;
@@ -191,7 +191,7 @@ mod tests {
 
         let torrents = repository.load_all_torrents_downloads().unwrap();
 
-        let mut expected_torrents = PersistentTorrents::new();
+        let mut expected_torrents = NumberOfDownloadsBTreeMap::new();
         expected_torrents.insert(infohash_one, 1);
         expected_torrents.insert(infohash_two, 2);
 
diff --git a/packages/tracker-core/src/torrent/repository/in_memory.rs b/packages/tracker-core/src/torrent/repository/in_memory.rs

Original file line number	Diff line number	Diff line change
`@@ -2,7 +2,7 @@ use bittorrent_primitives::info_hash::InfoHash;`
`2`	`2`	`use torrust_tracker_configuration::TrackerPolicy;`
`3`	`3`	`use torrust_tracker_primitives::pagination::Pagination;`
`4`	`4`	`use torrust_tracker_primitives::swarm_metadata::{AggregateSwarmMetadata, SwarmMetadata};`
`5`		`-use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, PersistentTorrents};`
	`5`	`+use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, NumberOfDownloadsBTreeMap};`
`6`	`6`
`7`	`7`	`use super::Repository;`
`8`	`8`	`use crate::entry::peer_list::PeerList;`
`@@ -92,7 +92,7 @@ where`
`92`	`92`	`}`
`93`	`93`	`}`
`94`	`94`
`95`		`- fn import_persistent(&self, persistent_torrents: &PersistentTorrents) {`
	`95`	`+ fn import_persistent(&self, persistent_torrents: &NumberOfDownloadsBTreeMap) {`
`96`	`96`	`let mut torrents = self.get_torrents_mut();`
`97`	`97`
`98`	`98`	`for (info_hash, downloaded) in persistent_torrents {`
Original file line number	Diff line number	Diff line change
`@@ -4,7 +4,7 @@ use bittorrent_primitives::info_hash::InfoHash;`
`4`	`4`	`use torrust_tracker_configuration::TrackerPolicy;`
`5`	`5`	`use torrust_tracker_primitives::pagination::Pagination;`
`6`	`6`	`use torrust_tracker_primitives::swarm_metadata::{AggregateSwarmMetadata, SwarmMetadata};`
`7`		`-use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, PersistentTorrents};`
	`7`	`+use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, NumberOfDownloadsBTreeMap};`
`8`	`8`
`9`	`9`	`use super::Repository;`
`10`	`10`	`use crate::entry::peer_list::PeerList;`
`@@ -87,7 +87,7 @@ where`
`87`	`87`	`}`
`88`	`88`	`}`
`89`	`89`
`90`		`- fn import_persistent(&self, persistent_torrents: &PersistentTorrents) {`
	`90`	`+ fn import_persistent(&self, persistent_torrents: &NumberOfDownloadsBTreeMap) {`
`91`	`91`	`let mut torrents = self.get_torrents_mut();`
`92`	`92`
`93`	`93`	`for (info_hash, completed) in persistent_torrents {`
Original file line number	Diff line number	Diff line change
`@@ -5,7 +5,7 @@ use crossbeam_skiplist::SkipMap;`
`5`	`5`	`use torrust_tracker_configuration::TrackerPolicy;`
`6`	`6`	`use torrust_tracker_primitives::pagination::Pagination;`
`7`	`7`	`use torrust_tracker_primitives::swarm_metadata::{AggregateSwarmMetadata, SwarmMetadata};`
`8`		`-use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, PersistentTorrents};`
	`8`	`+use torrust_tracker_primitives::{peer, DurationSinceUnixEpoch, NumberOfDownloads, NumberOfDownloadsBTreeMap};`
`9`	`9`
`10`	`10`	`use super::Repository;`
`11`	`11`	`use crate::entry::peer_list::PeerList;`
`@@ -100,7 +100,7 @@ where`
`100`	`100`	`}`
`101`	`101`	`}`
`102`	`102`
`103`		`- fn import_persistent(&self, persistent_torrents: &PersistentTorrents) {`
	`103`	`+ fn import_persistent(&self, persistent_torrents: &NumberOfDownloadsBTreeMap) {`
`104`	`104`	`for (info_hash, completed) in persistent_torrents {`
`105`	`105`	`if self.torrents.contains_key(info_hash) {`
`106`	`106`	`continue;`
`@@ -193,7 +193,7 @@ where`
`193`	`193`	`}`
`194`	`194`	`}`
`195`	`195`
`196`		`- fn import_persistent(&self, persistent_torrents: &PersistentTorrents) {`
	`196`	`+ fn import_persistent(&self, persistent_torrents: &NumberOfDownloadsBTreeMap) {`
`197`	`197`	`for (info_hash, completed) in persistent_torrents {`
`198`	`198`	`if self.torrents.contains_key(info_hash) {`
`199`	`199`	`continue;`
`@@ -286,7 +286,7 @@ where`
`286`	`286`	`}`
`287`	`287`	`}`
`288`	`288`
`289`		`- fn import_persistent(&self, persistent_torrents: &PersistentTorrents) {`
	`289`	`+ fn import_persistent(&self, persistent_torrents: &NumberOfDownloadsBTreeMap) {`
`290`	`290`	`for (info_hash, completed) in persistent_torrents {`
`291`	`291`	`if self.torrents.contains_key(info_hash) {`
`292`	`292`	`continue;`