@ -8,9 +8,10 @@ using NzbDrone.Common.Extensions;
using NzbDrone.Core.Download ;
using NzbDrone.Core.Extras ;
using NzbDrone.Core.History ;
using NzbDrone.Core.MediaFiles.Commands ;
using NzbDrone.Core.MediaFiles.Events ;
using NzbDrone.Core.Messaging.Commands ;
using NzbDrone.Core.Messaging.Events ;
using NzbDrone.Core.Parser ;
using NzbDrone.Core.Parser.Model ;
using NzbDrone.Core.Qualities ;
@ -29,6 +30,7 @@ namespace NzbDrone.Core.MediaFiles.MovieImport
private readonly IDiskProvider _diskProvider ;
private readonly IHistoryService _historyService ;
private readonly IEventAggregator _eventAggregator ;
private readonly IManageCommandQueue _commandQueueManager ;
private readonly Logger _logger ;
public ImportApprovedMovie ( IUpgradeMediaFiles movieFileUpgrader ,
@ -37,6 +39,7 @@ namespace NzbDrone.Core.MediaFiles.MovieImport
IDiskProvider diskProvider ,
IHistoryService historyService ,
IEventAggregator eventAggregator ,
IManageCommandQueue commandQueueManager ,
Logger logger )
{
_movieFileUpgrader = movieFileUpgrader ;
@ -45,6 +48,7 @@ namespace NzbDrone.Core.MediaFiles.MovieImport
_diskProvider = diskProvider ;
_historyService = historyService ;
_eventAggregator = eventAggregator ;
_commandQueueManager = commandQueueManager ;
_logger = logger ;
}
@ -157,6 +161,8 @@ namespace NzbDrone.Core.MediaFiles.MovieImport
{
_logger . Warn ( e , "Couldn't import movie " + localMovie ) ;
importResults . Add ( new ImportResult ( importDecision , "Failed to import movie, Destination already exists." ) ) ;
_commandQueueManager . Push ( new RescanMovieCommand ( localMovie . Movie . Id ) ) ;
}
catch ( Exception e )
{