Restore broken behavior: after uploading a new torrent its tracker stats must be updated

src/databases/mysql.rs

@@ -344,7 +344,7 @@ impl Database for MysqlDatabase {
             INNER JOIN torrust_torrent_info ti ON tt.torrent_id = ti.torrent_id
             LEFT JOIN torrust_torrent_tracker_stats ts ON tt.torrent_id = ts.torrent_id
             WHERE title LIKE ?
-            GROUP BY torrent_id",
+            GROUP BY tt.torrent_id",
             category_filter_query
         );
 

src/databases/sqlite.rs

@@ -339,7 +339,7 @@ impl Database for SqliteDatabase {
             INNER JOIN torrust_torrent_info ti ON tt.torrent_id = ti.torrent_id
             LEFT JOIN torrust_torrent_tracker_stats ts ON tt.torrent_id = ts.torrent_id
             WHERE title LIKE ?
-            GROUP BY ts.torrent_id",
+            GROUP BY tt.torrent_id",
             category_filter_query
         );
 

src/routes/torrent.rs

@@ -96,6 +96,12 @@ pub async fn upload_torrent(req: HttpRequest, payload: Multipart, app_data: WebA
         )
         .await?;
 
+    // update torrent tracker stats
+    let _ = app_data
+        .tracker
+        .update_torrent_tracker_stats(torrent_id, &torrent_request.torrent.info_hash())
+        .await;
+
     // whitelist info hash on tracker
     if let Err(e) = app_data
         .tracker

src/tracker.rs

@@ -179,13 +179,19 @@ impl TrackerService {
     }
 
     pub async fn update_torrents(&self) -> Result<(), ServiceError> {
-        println!("Updating torrents..");
+        println!("Updating torrents ...");
         let torrents = self.database.get_all_torrents_compact().await?;
 
         for torrent in torrents {
-            let _ = self.get_torrent_info(torrent.torrent_id, &torrent.info_hash).await;
+            let _ = self
+                .update_torrent_tracker_stats(torrent.torrent_id, &torrent.info_hash)
+                .await;
         }
 
         Ok(())
     }
+
+    pub async fn update_torrent_tracker_stats(&self, torrent_id: i64, info_hash: &str) -> Result<TorrentInfo, ServiceError> {
+        self.get_torrent_info(torrent_id, info_hash).await
+    }
 }