danvics/rdt-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fixed premiumize nested folders.

Browse source
This commit is contained in:
Roger Versluis 2023-09-02 15:53:52 -06:00
parent cb291ad3b0
commit db0880b843
1 changed files with 55 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

71
server/RdtClient.Service/Services/TorrentClients/PremiumizeTorrentClient.cs
View file

@ -238,33 +238,34 @@ public class PremiumizeTorrentClient : ITorrentClient
throw new Exception($"Transfer {torrent.RdId} not found!"); throw new Exception($"Transfer {torrent.RdId} not found!");
} }
List<String> downloadLinks; Log($"Found transfer {transfer.Name} ({transfer.Id})", torrent);
if (!String.IsNullOrWhiteSpace(transfer.FolderId))
{
var files = await GetClient().Folder.ListAsync(transfer.FolderId);
downloadLinks = files.Content.Where(m => !String.IsNullOrWhiteSpace(m.Link)).Select(m => m.Link).ToList();
Log($"Found {downloadLinks.Count} links in folder {transfer.FolderId}", torrent); var downloadLinks = await GetAllDownloadLinks(torrent, transfer.FolderId);
}
else if (!String.IsNullOrWhiteSpace(transfer.FileId)) if (!String.IsNullOrWhiteSpace(transfer.FileId))
{ {
var file = await GetClient().Items.DetailsAsync(transfer.FileId); var file = await GetClient().Items.DetailsAsync(transfer.FileId);
downloadLinks = new List<String>
{
file.Link
};
Log($"Found {transfer.FileId}", torrent); Log($"Found {transfer.FileId}", torrent);
if (String.IsNullOrWhiteSpace(file.Link))
{
Log($"File {file.Name} ({file.Id}) does not contain a link", torrent);
}
downloadLinks.Add(file.Link);
} }
else
if (downloadLinks.Count == 0)
{ {
throw new Exception($"Transfer {torrent.RdId} has no folderId or fileId!"); Log($"No download links found for transfer {transfer.Name} ({transfer.Id})", torrent);
return null;
} }
foreach (var link in downloadLinks) foreach (var link in downloadLinks)
{ {
Log($"{link}", torrent); Log($"Found {link}", torrent);
} }
return downloadLinks; return downloadLinks;
@ -283,6 +284,44 @@ public class PremiumizeTorrentClient : ITorrentClient
return Map(result); return Map(result);
} }
private async Task<List<String>> GetAllDownloadLinks(Torrent torrent, String folderId)
{
var downloadLinks = new List<String>();
if (String.IsNullOrWhiteSpace(folderId))
{
return downloadLinks;
}
var folder = await GetClient().Folder.ListAsync(folderId);
if (folder.Content == null)
{
Log($"Found no items in folder {folder.Name} ({folderId})", torrent);
return downloadLinks;
}
Log($"Found {folder.Content.Count} items in folder {folder.Name} ({folderId})", torrent);
foreach (var item in folder.Content)
{
if (!String.IsNullOrWhiteSpace(item.Link))
{
Log($"Found item {item.Name} in folder {folder.Name} ({folderId}) with link {item.Link}", torrent);
downloadLinks.Add(item.Link);
}
else
{
Log($"Found item {item.Name} in folder {folder.Name} ({folderId}), but has no link", torrent);
}
var subDownloadLinks = await GetAllDownloadLinks(torrent, item.FolderId);
downloadLinks.AddRange(subDownloadLinks);
}
return downloadLinks;
}
private void Log(String message, Torrent? torrent = null) private void Log(String message, Torrent? torrent = null)
{ {
if (torrent != null) if (torrent != null)