Archive-Team
/
sonarr-repo-only
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

New: Rescan series if destination file already exists during import 

Closes #5401
This commit is contained in:
Mark McDowall 2023-03-15 23:44:09 -07:00
parent 978618f041
commit bd228e88c3
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/NzbDrone.Core/MediaFiles/EpisodeImport/ImportApprovedEpisodes.cs
View File

@ -8,7 +8,9 @@ using NzbDrone.Common.Extensions;
using NzbDrone.Core.Download; using NzbDrone.Core.Download;
using NzbDrone.Core.Extras; using NzbDrone.Core.Extras;
using NzbDrone.Core.Languages; using NzbDrone.Core.Languages;
using NzbDrone.Core.MediaFiles.Commands;
using NzbDrone.Core.MediaFiles.Events; using NzbDrone.Core.MediaFiles.Events;
using NzbDrone.Core.Messaging.Commands;
using NzbDrone.Core.Messaging.Events; using NzbDrone.Core.Messaging.Events;
using NzbDrone.Core.Parser.Model; using NzbDrone.Core.Parser.Model;
using NzbDrone.Core.Qualities; using NzbDrone.Core.Qualities;
@ -27,6 +29,7 @@ namespace NzbDrone.Core.MediaFiles.EpisodeImport
private readonly IExtraService _extraService; private readonly IExtraService _extraService;
private readonly IDiskProvider _diskProvider; private readonly IDiskProvider _diskProvider;
private readonly IEventAggregator _eventAggregator; private readonly IEventAggregator _eventAggregator;
private readonly IManageCommandQueue _commandQueueManager;
private readonly Logger _logger; private readonly Logger _logger;
public ImportApprovedEpisodes(IUpgradeMediaFiles episodeFileUpgrader, public ImportApprovedEpisodes(IUpgradeMediaFiles episodeFileUpgrader,
@ -34,6 +37,7 @@ namespace NzbDrone.Core.MediaFiles.EpisodeImport
IExtraService extraService, IExtraService extraService,
IDiskProvider diskProvider, IDiskProvider diskProvider,
IEventAggregator eventAggregator, IEventAggregator eventAggregator,
IManageCommandQueue commandQueueManager,
Logger logger) Logger logger)
{ {
_episodeFileUpgrader = episodeFileUpgrader; _episodeFileUpgrader = episodeFileUpgrader;
@ -41,6 +45,7 @@ namespace NzbDrone.Core.MediaFiles.EpisodeImport
_extraService = extraService; _extraService = extraService;
_diskProvider = diskProvider; _diskProvider = diskProvider;
_eventAggregator = eventAggregator; _eventAggregator = eventAggregator;
_commandQueueManager = commandQueueManager;
_logger = logger; _logger = logger;
} }
@ -142,6 +147,8 @@ namespace NzbDrone.Core.MediaFiles.EpisodeImport
{ {
_logger.Warn(e, "Couldn't import episode " + localEpisode); _logger.Warn(e, "Couldn't import episode " + localEpisode);
importResults.Add(new ImportResult(importDecision, "Failed to import episode, Destination already exists.")); importResults.Add(new ImportResult(importDecision, "Failed to import episode, Destination already exists."));
_commandQueueManager.Push(new RescanSeriesCommand(localEpisode.Series.Id));
} }
catch (Exception e) catch (Exception e)
{ {