chris/AnimeAnnouncer
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Initial commit of auto-adding torrent system

Browse Source
This commit is contained in:
chris
2026-10-11 12:25:32 -04:00
parent 57b2d8835d
commit 32aca8b197
9 changed files with 159 additions and 65 deletions
Download Patch File Download Diff File Expand all files Collapse all files
MassTorrentAdd/MassTorrentAdd.csproj
+4 -1
View File
@@ -16,7 +16,6 @@
<PackageReference Include="Microsoft.Extensions.Configuration.Json" Version="8.0.0" />
<PackageReference Include="Microsoft.Extensions.Options.ConfigurationExtensions" Version="8.0.0" />
<PackageReference Include="Microsoft.VisualStudio.Azure.Containers.Tools.Targets" Version="1.21.0" />
<PackageReference Include="Transmission.API.RPC" Version="2.1.2" />
</ItemGroup>
<ItemGroup>
@@ -25,4 +24,8 @@
</None>
</ItemGroup>
<ItemGroup>
<ProjectReference Include="..\AnimeAnnouncer.Torrents\AnimeAnnouncer.Torrents.csproj" />
</ItemGroup>
</Project>
MassTorrentAdd/Program.cs
+32 -63
View File
@@ -1,15 +1,11 @@
using Microsoft.Extensions.Configuration;
using System.Xml.Linq;
using Transmission.API.RPC;
using AnimeAnnouncer.Torrents;
using Microsoft.Extensions.Configuration;
namespace MassTorrentAdd
{
internal class Program
{
static String watchFolder, transmissionHost, transmissionUsername, transmissionPassword, transmissionDownloadFolder, destinationFolder;
static Transmission.API.RPC.Client transmissionClient;
static void Main(string[] args)
static async Task Main(string[] args)
{
if(args.Length == 0)
{
@@ -17,60 +13,53 @@ namespace MassTorrentAdd
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");
String transmissionHost = configuration.GetValue<String>("transmissionURI")!;
String? transmissionUsername = configuration.GetValue<String>("transmissionUsername");
String? transmissionPassword = configuration.GetValue<String>("transmissionPassword");
String 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))
TransmissionService transmission;
try
{
Console.WriteLine("An error occurred while receiving session information from the rpc server");
transmission = await TransmissionService.ConnectAsync(transmissionHost, transmissionUsername, transmissionPassword);
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
return;
}
HttpClient httpClient = new HttpClient();
var response = httpClient.GetStringAsync(url).Result;
if(response == null)
var nyaa = new NyaaRssReader();
List<NyaaRssItem> items;
try
{
Console.WriteLine("An error occurred while contacting Nyaa for a response");
items = await nyaa.ReadAsync(url);
}
catch (Exception ex)
{
Console.WriteLine($"An error occurred while contacting Nyaa for a response: {ex.Message}");
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,
};
if (items.Count == 0)
{
Console.WriteLine("No items found in the feed");
return;
}
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 = System.Text.RegularExpressions.Regex.Replace(transmissionDirectoryName, @"\s\(.*?\)$", "");
transmissionDirectoryName = destinationFolder + (destinationFolder.EndsWith("/") ? String.Empty : "/") + transmissionDirectoryName.Replace(" ", ".");
Console.WriteLine($"{items.Count()} item(s) to {transmissionDirectoryName}");
String transmissionDirectoryName = TorrentDirectoryNamer.FromTitle(items.First().Title, destinationFolder);
Console.WriteLine($"{items.Count} item(s) to {transmissionDirectoryName}");
Console.WriteLine("Continue?");
if(Console.ReadKey().KeyChar != 'y')
@@ -80,30 +69,10 @@ namespace MassTorrentAdd
}
foreach (var item in items)
{
var torrentData = httpClient.GetByteArrayAsync(item.Link).Result;
AddNewTorrentFileToServer(torrentData, transmissionDirectoryName);
var torrentData = await nyaa.DownloadTorrentAsync(item);
await transmission.AddNewTorrentFileToServerAsync(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);
var seedSettings = new Transmission.API.RPC.Arguments.TorrentSettings()
{
SeedRatioLimit = 1.0,
SeedRatioMode = 1,
IDs = [torrentInfo.ID]
};
transmissionClient.TorrentSet(seedSettings);
//transmissionClient.TorrentVerify(new object[] { torrentInfo.ID });
}
}
}