diff --git a/src/upgrades/from_v1_0_0_to_v2_0_0/databases/sqlite_v2_0_0.rs b/src/upgrades/from_v1_0_0_to_v2_0_0/databases/sqlite_v2_0_0.rs index 8ce447b2..3f1b3ade 100644 --- a/src/upgrades/from_v1_0_0_to_v2_0_0/databases/sqlite_v2_0_0.rs +++ b/src/upgrades/from_v1_0_0_to_v2_0_0/databases/sqlite_v2_0_0.rs @@ -218,6 +218,19 @@ impl SqliteDatabaseV2_0_0 { .map(|v| v.last_insert_rowid()) } + pub async fn insert_torrent_info(&self, torrent: &Torrent) -> Result { + query( + "INSERT INTO torrust_torrent_info (torrent_id, title, description) + VALUES (?, ?, ?)", + ) + .bind(torrent.torrent_id) + .bind(torrent.title.clone()) + .bind(torrent.description.clone()) + .execute(&self.pool) + .await + .map(|v| v.last_insert_rowid()) + } + pub async fn delete_all_database_rows(&self) -> Result<(), DatabaseError> { query("DELETE FROM torrust_categories;") .execute(&self.pool) diff --git a/src/upgrades/from_v1_0_0_to_v2_0_0/upgrader.rs b/src/upgrades/from_v1_0_0_to_v2_0_0/upgrader.rs index 71fa762b..45f681db 100644 --- a/src/upgrades/from_v1_0_0_to_v2_0_0/upgrader.rs +++ b/src/upgrades/from_v1_0_0_to_v2_0_0/upgrader.rs @@ -377,7 +377,19 @@ async fn transfer_torrents( // [v2] table torrust_torrent_info - // TODO + println!( + "[v2][torrust_torrent_info] adding the torrent info for torrent {:?} ...", + &torrent.torrent_id + ); + + let id = dest_database.insert_torrent_info(torrent).await; + + println!( + "[v2][torrust_torrents] torrent info insert result: {:?}.", + &id + ); + + println!("Torrents transferred"); } }