More torrent and omdb

Aberwyn/Data/DelugeClient.cs

@@ -0,0 +1,70 @@
+using MySqlX.XDevAPI;
+using System.Text.Json;
+
+namespace Aberwyn.Data
+{
+    public class DelugeClient
+    {
+        private readonly HttpClient _http;
+        private readonly string _url;
+        private string _sessionId;
+
+        public DelugeClient(HttpClient httpClient, string baseUrl = "http://192.168.1.3:8112/json")
+        {
+            _http = httpClient;
+            _url = baseUrl;
+        }
+
+        public async Task<bool> LoginAsync(string password)
+        {
+            var payload = new
+            {
+                method = "auth.login",
+                @params = new object[] { password },
+                id = 1
+            };
+
+            var response = await _http.PostAsJsonAsync(_url, payload);
+            var json = await response.Content.ReadFromJsonAsync<JsonElement>();
+
+            // spara sessioncookie för framtida requests
+            if (response.Headers.TryGetValues("Set-Cookie", out var cookies))
+            {
+                _sessionId = cookies.FirstOrDefault()?.Split(';')[0];
+                if (!_http.DefaultRequestHeaders.Contains("Cookie"))
+                    _http.DefaultRequestHeaders.Add("Cookie", _sessionId);
+            }
+
+            return json.GetProperty("result").GetBoolean();
+        }
+
+        public async Task<bool> AddMagnetAsync(string magnetLink)
+        {
+            var payload = new
+            {
+                method = "core.add_torrent_url",
+                @params = new object[] { magnetLink, new { } },
+                id = 2
+            };
+
+            var response = await _http.PostAsJsonAsync(_url, payload);
+            var json = await response.Content.ReadFromJsonAsync<JsonElement>();
+            return json.GetProperty("result").ValueKind != JsonValueKind.Null;
+        }
+        public async Task<bool> AddTorrentUrlAsync(string torrentUrl)
+        {
+            var payload = new
+            {
+                method = "core.add_torrent_url",
+                @params = new object[] { torrentUrl, new { } },
+                id = 3
+            };
+
+            var response = await _http.PostAsJsonAsync(_url, payload);
+            var json = await response.Content.ReadFromJsonAsync<JsonElement>();
+
+            return json.GetProperty("result").ValueKind != JsonValueKind.Null;
+        }
+
+    }
+}