mirror/Radarr
1
0
Fork 0
mirror of https://github.com/Radarr/Radarr synced 2025-02-22 14:21:14 +00:00
Code Issues Releases Wiki Activity

New: Refresh cache for tracked queue on movie add

Browse source
This commit is contained in:
Bogdan 2024-06-06 12:32:39 +03:00
parent c8b409ed0b
commit 8a5c0ffd18
1 changed files with 22 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
src/NzbDrone.Core/Download/TrackedDownloads/TrackedDownloadService.cs
View file

@ -28,6 +28,7 @@ public interface ITrackedDownloadService
} }
public class TrackedDownloadService : ITrackedDownloadService, public class TrackedDownloadService : ITrackedDownloadService,
IHandle<MovieAddedEvent>,
IHandle<MoviesDeletedEvent> IHandle<MoviesDeletedEvent>
{ {
private readonly IParsingService _parsingService; private readonly IParsingService _parsingService;
@ -250,12 +251,29 @@ private void LogItemChange(TrackedDownload trackedDownload, DownloadClientItem e
} }
} }
public void Handle(MovieAddedEvent message)
{
var cachedItems = _cache.Values
.Where(t =>
t.RemoteMovie?.Movie == null ||
message.Movie?.TmdbId == t.RemoteMovie.Movie.TmdbId)
.ToList();
if (cachedItems.Any())
{
cachedItems.ForEach(UpdateCachedItem);
_eventAggregator.PublishEvent(new TrackedDownloadRefreshedEvent(GetTrackedDownloads()));
}
}
public void Handle(MoviesDeletedEvent message) public void Handle(MoviesDeletedEvent message)
{ {
var cachedItems = _cache.Values.Where(t => var cachedItems = _cache.Values
t.RemoteMovie?.Movie != null && .Where(t =>
message.Movies.Any(m => m.Id == t.RemoteMovie.Movie.Id)) t.RemoteMovie?.Movie != null &&
.ToList(); message.Movies.Any(m => m.Id == t.RemoteMovie.Movie.Id || m.TmdbId == t.RemoteMovie.Movie.TmdbId))
.ToList();
if (cachedItems.Any()) if (cachedItems.Any())
{ {