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

Fixed issue with torrent data caching.

Browse source
This commit is contained in:
Roger Far 2021-06-05 14:21:29 -06:00
parent f151312d47
commit 71c9eb17fb
5 changed files with 12 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
server/RdtClient.Data/Data/TorrentData.cs
View file

@ -46,14 +46,6 @@ namespace RdtClient.Data.Data
.ToListAsync();
}
foreach (var torrent in _torrentCache)
{
foreach (var download in torrent.Downloads)
{
download.Torrent = null;
}
}
return _torrentCache.OrderByDescending(m => m.Added).ToList();
}
finally

4
server/RdtClient.Service/Services/DownloadClient.cs
View file

@ -21,11 +21,11 @@ namespace RdtClient.Service.Services
private DownloadService _downloader;
private SimpleDownloader _simpleDownloader;
public DownloadClient(Download download, String destinationPath)
public DownloadClient(Download download, Torrent torrent, String destinationPath)
{
_download = download;
_torrent = torrent;
_destinationPath = destinationPath;
_torrent = download.Torrent;
}
public Boolean Finished { get; private set; }

2
server/RdtClient.Service/Services/Settings.cs
View file

@ -109,7 +109,7 @@ namespace RdtClient.Service.Services
}
};
var downloadClient = new DownloadClient(download, downloadPath);
var downloadClient = new DownloadClient(download, download.Torrent, downloadPath);
await downloadClient.Start(settings);

2
server/RdtClient.Service/Services/TorrentRunner.cs
View file

@ -253,7 +253,7 @@ namespace RdtClient.Service.Services
Log.Debug($"Setting download path for {download.DownloadId} to {downloadPath}");
// Start the download process
var downloadClient = new DownloadClient(download, downloadPath);
var downloadClient = new DownloadClient(download, torrentDownload, downloadPath);
if (TorrentRunner.ActiveDownloadClients.TryAdd(download.DownloadId, downloadClient))
{

10
server/RdtClient.Service/Services/Torrents.cs
View file

@ -440,7 +440,10 @@ namespace RdtClient.Service.Services
private async Task Update(Torrent torrent)
{
var originalTorrent = JsonConvert.SerializeObject(torrent);
var originalTorrent = JsonConvert.SerializeObject(torrent, new JsonSerializerSettings
{
ReferenceLoopHandling = ReferenceLoopHandling.Ignore
});
var rdTorrent = await GetRdNetClient().GetTorrentInfoAsync(torrent.RdId);
@ -493,7 +496,10 @@ namespace RdtClient.Service.Services
_ => RealDebridStatus.Error
};
var newTorrent = JsonConvert.SerializeObject(torrent);
var newTorrent = JsonConvert.SerializeObject(torrent, new JsonSerializerSettings
{
ReferenceLoopHandling = ReferenceLoopHandling.Ignore
});
if (originalTorrent != newTorrent)
{