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

perf(cache): Remove aggressive cache invalidation and optimize queries

Browse source
This commit is contained in:
destrodxbad 2025-11-18 02:04:51 +01:00
parent 47355030b5
commit 15af54ed24
2 changed files with 1 additions and 26 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
server/RdtClient.Data/Data/DownloadData.cs
View file

@ -47,8 +47,6 @@ public class DownloadData(DataContext dataContext)
await dataContext.SaveChangesAsync(); await dataContext.SaveChangesAsync();
await TorrentData.VoidCache();
return download; return download;
} }
@ -65,8 +63,6 @@ public class DownloadData(DataContext dataContext)
dbDownload.Link = unrestrictedLink; dbDownload.Link = unrestrictedLink;
await dataContext.SaveChangesAsync(); await dataContext.SaveChangesAsync();
await TorrentData.VoidCache();
} }
public async Task UpdateFileName(Guid downloadId, String fileName) public async Task UpdateFileName(Guid downloadId, String fileName)
@ -82,8 +78,6 @@ public class DownloadData(DataContext dataContext)
dbDownload.FileName = fileName; dbDownload.FileName = fileName;
await dataContext.SaveChangesAsync(); await dataContext.SaveChangesAsync();
await TorrentData.VoidCache();
} }
public async Task UpdateDownloadStarted(Guid downloadId, DateTimeOffset? dateTime) public async Task UpdateDownloadStarted(Guid downloadId, DateTimeOffset? dateTime)
@ -99,8 +93,6 @@ public class DownloadData(DataContext dataContext)
dbDownload.DownloadStarted = dateTime; dbDownload.DownloadStarted = dateTime;
await dataContext.SaveChangesAsync(); await dataContext.SaveChangesAsync();
await TorrentData.VoidCache();
} }
public async Task UpdateDownloadFinished(Guid downloadId, DateTimeOffset? dateTime) public async Task UpdateDownloadFinished(Guid downloadId, DateTimeOffset? dateTime)
@ -116,8 +108,6 @@ public class DownloadData(DataContext dataContext)
dbDownload.DownloadFinished = dateTime; dbDownload.DownloadFinished = dateTime;
await dataContext.SaveChangesAsync(); await dataContext.SaveChangesAsync();
await TorrentData.VoidCache();
} }
public async Task UpdateUnpackingQueued(Guid downloadId, DateTimeOffset? dateTime) public async Task UpdateUnpackingQueued(Guid downloadId, DateTimeOffset? dateTime)
@ -133,8 +123,6 @@ public class DownloadData(DataContext dataContext)
dbDownload.UnpackingQueued = dateTime; dbDownload.UnpackingQueued = dateTime;
await dataContext.SaveChangesAsync(); await dataContext.SaveChangesAsync();
await TorrentData.VoidCache();
} }
public async Task UpdateUnpackingStarted(Guid downloadId, DateTimeOffset? dateTime) public async Task UpdateUnpackingStarted(Guid downloadId, DateTimeOffset? dateTime)
@ -150,8 +138,6 @@ public class DownloadData(DataContext dataContext)
dbDownload.UnpackingStarted = dateTime; dbDownload.UnpackingStarted = dateTime;
await dataContext.SaveChangesAsync(); await dataContext.SaveChangesAsync();
await TorrentData.VoidCache();
} }
public async Task UpdateUnpackingFinished(Guid downloadId, DateTimeOffset? dateTime) public async Task UpdateUnpackingFinished(Guid downloadId, DateTimeOffset? dateTime)
@ -167,8 +153,6 @@ public class DownloadData(DataContext dataContext)
dbDownload.UnpackingFinished = dateTime; dbDownload.UnpackingFinished = dateTime;
await dataContext.SaveChangesAsync(); await dataContext.SaveChangesAsync();
await TorrentData.VoidCache();
} }
public async Task UpdateCompleted(Guid downloadId, DateTimeOffset? dateTime) public async Task UpdateCompleted(Guid downloadId, DateTimeOffset? dateTime)
@ -184,8 +168,6 @@ public class DownloadData(DataContext dataContext)
dbDownload.Completed = dateTime; dbDownload.Completed = dateTime;
await dataContext.SaveChangesAsync(); await dataContext.SaveChangesAsync();
await TorrentData.VoidCache();
} }
public async Task UpdateError(Guid downloadId, String? error) public async Task UpdateError(Guid downloadId, String? error)
@ -201,8 +183,6 @@ public class DownloadData(DataContext dataContext)
dbDownload.Error = error; dbDownload.Error = error;
await dataContext.SaveChangesAsync(); await dataContext.SaveChangesAsync();
await TorrentData.VoidCache();
} }
public async Task UpdateRetryCount(Guid downloadId, Int32 retryCount) public async Task UpdateRetryCount(Guid downloadId, Int32 retryCount)
@ -218,8 +198,6 @@ public class DownloadData(DataContext dataContext)
dbDownload.RetryCount = retryCount; dbDownload.RetryCount = retryCount;
await dataContext.SaveChangesAsync(); await dataContext.SaveChangesAsync();
await TorrentData.VoidCache();
} }
public async Task UpdateRemoteId(Guid downloadId, String remoteId) public async Task UpdateRemoteId(Guid downloadId, String remoteId)
@ -246,8 +224,6 @@ public class DownloadData(DataContext dataContext)
dataContext.Downloads.RemoveRange(downloads); dataContext.Downloads.RemoveRange(downloads);
await dataContext.SaveChangesAsync(); await dataContext.SaveChangesAsync();
await TorrentData.VoidCache();
} }
public async Task Reset(Guid downloadId) public async Task Reset(Guid downloadId)
@ -269,7 +245,5 @@ public class DownloadData(DataContext dataContext)
dbDownload.Error = null; dbDownload.Error = null;
await dataContext.SaveChangesAsync(); await dataContext.SaveChangesAsync();
await TorrentData.VoidCache();
} }
} }

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

@ -18,6 +18,7 @@ public class TorrentData(DataContext dataContext) : ITorrentData
{ {
_torrentCache ??= await dataContext.Torrents _torrentCache ??= await dataContext.Torrents
.AsNoTracking() .AsNoTracking()
.AsSplitQuery()
.Include(m => m.Downloads) .Include(m => m.Downloads)
.ToListAsync(); .ToListAsync();