fix: [#1502] import torrents' download counters from DB

when the tracker starts.

In the current implementation all torrents that have benn downloaded at
least once have to be in memory initializting the counter. Otherwise,
the global counter for downloads for all torrents only includes
downloads for the torrents being currently tracker by the tracker.

Author: josecelano

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

@@ -60,7 +60,7 @@ impl TorrentsManager {
         }
     }
 
-    /// Loads torrents from the persistent database into the in-memory repository.
+    /// Loads torrents from the database into the in-memory repository.
     ///
     /// This function retrieves the list of persistent torrent entries (which
     /// include only the aggregate metrics, not the detailed peer lists) from
@@ -70,8 +70,7 @@ impl TorrentsManager {
     ///
     /// Returns a `databases::error::Error` if unable to load the persistent
     /// torrent data.
-    #[allow(dead_code)]
-    pub(crate) fn load_torrents_from_database(&self) -> Result<(), databases::error::Error> {
+    pub fn load_torrents_from_database(&self) -> Result<(), databases::error::Error> {
         let persistent_torrents = self.db_torrent_repository.load_all()?;
 
         self.in_memory_torrent_repository.import_persistent(&persistent_torrents);

src/app.rs

@@ -61,6 +61,7 @@ pub async fn start(config: &Configuration, app_container: &Arc<AppContainer>) ->
 async fn load_data_from_database(config: &Configuration, app_container: &Arc<AppContainer>) {
     load_peer_keys(config, app_container).await;
     load_whitelisted_torrents(config, app_container).await;
+    load_torrents_from_database(config, app_container);
 }
 
 async fn start_jobs(config: &Configuration, app_container: &Arc<AppContainer>) -> JobManager {
@@ -109,6 +110,16 @@ async fn load_whitelisted_torrents(config: &Configuration, app_container: &Arc<A
     }
 }
 
+fn load_torrents_from_database(config: &Configuration, app_container: &Arc<AppContainer>) {
+    if config.core.tracker_policy.persistent_torrent_completed_stat {
+        app_container
+            .tracker_core_container
+            .torrents_manager
+            .load_torrents_from_database()
+            .expect("Could not load torrents from database.");
+    }
+}
+
 fn start_http_core_event_listener(config: &Configuration, app_container: &Arc<AppContainer>, job_manager: &mut JobManager) {
     let opt_handle = jobs::http_tracker_core::start_event_listener(config, app_container);