From 18bb4282755eaabdeb3e07ea4014735ddce4c4f5 Mon Sep 17 00:00:00 2001
From: SeanOMik <seanomik@gmail.com>
Date: Sun, 19 Jun 2022 14:09:59 -0400
Subject: [PATCH] Implement deleting torrents

---
 src/client.rs | 42 +++++++++++++++++++++++++++++++++++++++++-
 1 file changed, 41 insertions(+), 1 deletion(-)

diff --git a/src/client.rs b/src/client.rs
index 542073a..e0db177 100644
--- a/src/client.rs
+++ b/src/client.rs
@@ -100,7 +100,7 @@ impl QBittorrentClient {
     pub async fn add_torrent(&self, upload: &TorrentUpload) -> ClientResult<()> {
         if let (Some(auth_string), Some(conn)) = (self.auth_string.as_ref(), self.connection_info.as_ref()) {
             // Construct and send request to qbittorrent
-            let resp = self.client.post(format!("{}/api/v2/torrents/add", conn.url.clone()))
+            let _resp = self.client.post(format!("{}/api/v2/torrents/add", conn.url.clone()))
                 .header(reqwest::header::COOKIE, auth_string.clone())
                 .multipart(upload.to_multipart_form())
                 .send().await?.error_for_status()?;
@@ -110,4 +110,44 @@ impl QBittorrentClient {
             Err(ClientError::Authorization)
         }
     }
+
+    /// Remove a torrent from the client.
+    pub async fn remove_torrent(&self, torrent: &TorrentInfo, delete_files: bool) -> ClientResult<()> {
+        if let (Some(auth_string), Some(conn)) = (self.auth_string.as_ref(), self.connection_info.as_ref()) {
+            // Construct and send request to qbittorrent
+            let _resp = self.client.post(format!("{}/api/v2/torrents/delete", conn.url.clone()))
+                .header(reqwest::header::COOKIE, auth_string.clone())
+                .form(&[
+                    ("hashes", torrent.hash.clone()),
+                    ("deleteFiles", delete_files.to_string()),
+                ]).send().await?.error_for_status()?;
+
+
+            Ok(())
+        } else {
+            Err(ClientError::Authorization)
+        }
+    }
+
+    /// Remove multiple torrents at once. `delete_files` applies to *all* torrents.
+    pub async fn remove_torrents(&self, torrents: Vec<&TorrentInfo>, delete_files: bool ) -> ClientResult<()> {
+        if let (Some(auth_string), Some(conn)) = (self.auth_string.as_ref(), self.connection_info.as_ref()) {
+            // Convert the hashes into a string concatenated with `|`
+            let hashes = torrents.iter()
+                .map(|t| t.hash.clone())
+                .collect::<Vec<_>>()
+                .join("|");
+
+            // Construct and send request to qbittorrent
+            let _resp = self.client.post(format!("{}/api/v2/torrents/delete", conn.url.clone()))
+                .header(reqwest::header::COOKIE, auth_string.clone())
+                .form(&[
+                    ("hashes", hashes),
+                    ("deleteFiles", delete_files.to_string()),
+                ]).send().await?.error_for_status()?;
+            Ok(())
+        } else {
+            Err(ClientError::Authorization)
+        }
+    }
 }
\ No newline at end of file