From ed76709b7ffdd4e6a9605481d98c6797cdb9eb1a Mon Sep 17 00:00:00 2001 From: Qstick Date: Sun, 16 Aug 2020 01:09:33 -0400 Subject: [PATCH] Simplify FindDownloadId to remove inaccessable code paths --- src/NzbDrone.Core/History/HistoryService.cs | 70 +++++++++------------ 1 file changed, 28 insertions(+), 42 deletions(-) diff --git a/src/NzbDrone.Core/History/HistoryService.cs b/src/NzbDrone.Core/History/HistoryService.cs index 2b5181c6e..055472db1 100644 --- a/src/NzbDrone.Core/History/HistoryService.cs +++ b/src/NzbDrone.Core/History/HistoryService.cs @@ -97,6 +97,34 @@ public void UpdateMany(List toUpdate) _historyRepository.UpdateMany(toUpdate); } + public string FindDownloadId(MovieImportedEvent trackedDownload) + { + _logger.Debug("Trying to find downloadId for {0} from history", trackedDownload.ImportedMovie.Path); + + var movieId = trackedDownload.MovieInfo.Movie.Id; + var movieHistory = _historyRepository.FindDownloadHistory(movieId, trackedDownload.ImportedMovie.Quality); + + var processedDownloadId = movieHistory + .Where(c => c.EventType != MovieHistoryEventType.Grabbed && c.DownloadId != null) + .Select(c => c.DownloadId); + + var stillDownloading = movieHistory.Where(c => c.EventType == MovieHistoryEventType.Grabbed && !processedDownloadId.Contains(c.DownloadId)).ToList(); + + string downloadId = null; + + if (stillDownloading.Any()) + { + if (stillDownloading.Count != 1) + { + return null; + } + + downloadId = stillDownloading.Single().DownloadId; + } + + return downloadId; + } + public void Handle(MovieGrabbedEvent message) { var history = new MovieHistory @@ -252,48 +280,6 @@ public void Handle(MoviesDeletedEvent message) _historyRepository.DeleteForMovies(message.Movies.Select(m => m.Id).ToList()); } - public string FindDownloadId(MovieImportedEvent trackedDownload) - { - _logger.Debug("Trying to find downloadId for {0} from history", trackedDownload.ImportedMovie.Path); - - var movieId = trackedDownload.MovieInfo.Movie.Id; - var movieHistory = _historyRepository.FindDownloadHistory(movieId, trackedDownload.ImportedMovie.Quality); - - var processedDownloadId = movieHistory - .Where(c => c.EventType != MovieHistoryEventType.Grabbed && c.DownloadId != null) - .Select(c => c.DownloadId); - - var stillDownloading = movieHistory.Where(c => c.EventType == MovieHistoryEventType.Grabbed && !processedDownloadId.Contains(c.DownloadId)).ToList(); - - string downloadId = null; - - if (stillDownloading.Any()) - { - //foreach (var matchingHistory in trackedDownload.EpisodeInfo.Episodes.Select(e => stillDownloading.Where(c => c.MovieId == e.Id).ToList())) - //foreach (var matchingHistory in stillDownloading.Where(c => c.MovieId == e.Id).ToList()) - //{ - if (stillDownloading.Count != 1) - { - return null; - } - - var newDownloadId = stillDownloading.Single().DownloadId; - - if (downloadId == null || downloadId == newDownloadId) - { - downloadId = newDownloadId; - } - else - { - return null; - } - - //} - } - - return downloadId; - } - public void Handle(DownloadFailedEvent message) { var history = new MovieHistory