Added MassTorrentAdd project

2024-10-06 17:07:50 -04:00
parent 09f65f9a31
commit 5a0ffdad1e
6 changed files with 182 additions and 1 deletions
--- a/MassTorrentAdd/Program.cs
+++ b/MassTorrentAdd/Program.cs
@@ -0,0 +1,100 @@
+using Microsoft.Extensions.Configuration;
+using System.Xml.Linq;
+using Transmission.API.RPC;
+
+namespace MassTorrentAdd
+{
+    internal class Program
+    {
+        static String watchFolder, transmissionHost, transmissionUsername, transmissionPassword, transmissionDownloadFolder, destinationFolder;
+        static Transmission.API.RPC.Client transmissionClient;
+
+        static void Main(string[] args)
+        {
+            if(args.Length == 0)
+            {
+                Console.WriteLine("Please provide the nyaa URL to target for download.");
+                return;
+            }
+            String url = args[0];
+            if (!url.Contains("rss"))
+                url = url + "&page=rss";
+
+            var builder = new ConfigurationBuilder()
+        .SetBasePath(Directory.GetCurrentDirectory())
+        .AddJsonFile("appsettings.json", optional: false, reloadOnChange: true);
+
+            IConfigurationRoot configuration = builder.Build();
+            transmissionHost = configuration.GetValue<String>("transmissionURI");
+            transmissionUsername = configuration.GetValue<String>("transmissionUsername");
+            transmissionPassword = configuration.GetValue<String>("transmissionPassword");
+            destinationFolder = configuration.GetValue<String>("destinationFolder");
+
+            Console.WriteLine($"Using transmission server {transmissionHost}");
+            transmissionClient = new Transmission.API.RPC.Client(transmissionHost, null, transmissionUsername, transmissionPassword);
+            var sessionInformation = transmissionClient.GetSessionInformation();
+            if (sessionInformation == null || String.IsNullOrEmpty(sessionInformation.Version))
+            {
+                Console.WriteLine("An error occurred while receiving session information from the rpc server");
+                return;
+            }
+
+
+            HttpClient httpClient = new HttpClient();
+            var response = httpClient.GetStringAsync(url).Result;
+            if(response == null)
+            {
+                Console.WriteLine("An error occurred while contacting Nyaa for a response");
+                return;
+            }
+            XDocument doc = XDocument.Parse(response);
+            XNamespace nyaaNS = doc.Root.GetNamespaceOfPrefix("nyaa");
+            var items = from item in doc.Descendants("channel").Elements("item")
+                        select new
+                        {
+                            Title = item.Element("title").Value,
+                            Published = item.Element("pubDate").Value,
+                            Category = item.Element(nyaaNS + "category").Value,
+                            CategoryID = item.Element(nyaaNS + "categoryId").Value,
+                            Size = item.Element(nyaaNS + "size").Value,
+                            Link = item.Element("link").Value,
+                            Description = item.Element("description").Value,
+                            PostID = item.Element("guid").Value,
+                        };
+            Console.WriteLine("Downloading ..");
+            foreach ( var item in items )
+            {
+                Console.WriteLine($"{item.Title}");
+            }
+            String transmissionDirectoryName = items.First().Title.Trim();
+            transmissionDirectoryName = System.Text.RegularExpressions.Regex.Replace(transmissionDirectoryName, @"E\d{2,3}.*?(\d{3,4}p)", " $1");
+            transmissionDirectoryName = destinationFolder + (destinationFolder.EndsWith("/") ? String.Empty : "/") + transmissionDirectoryName;
+            Console.WriteLine("to " + transmissionDirectoryName);
+
+            Console.WriteLine("Continue?");
+            if(Console.ReadKey().KeyChar != 'y')
+            {
+                Console.WriteLine("Exiting");
+                return;
+            }
+            foreach (var item in items)
+            {
+                var torrentData = httpClient.GetByteArrayAsync(item.Link).Result;
+                AddNewTorrentFileToServer(torrentData, transmissionDirectoryName);
+            }
+            Console.WriteLine("Completed");
+        }
+        private static void AddNewTorrentFileToServer(byte[] torrentFileData, String saveLocation)
+        {
+            Transmission.API.RPC.Entity.NewTorrent newTorrent = new()
+            {
+                DownloadDirectory = saveLocation,
+                Paused = true,
+                Metainfo = Convert.ToBase64String(torrentFileData)
+            };
+            var torrentInfo = transmissionClient.TorrentAdd(newTorrent);
+            transmissionClient.TorrentVerify(new object[] { torrentInfo.ID });
+
+        }
+    }
+}