Fixed: Hookup BulkMovieMovieCommand

src/NzbDrone.Core.Test/MovieTests/MoveMovieServiceFixture.cs

@@ -1,4 +1,6 @@
+using System.Collections.Generic;
 using System.IO;
+using System.Linq;
 using FizzWare.NBuilder;
 using Moq;
 using NUnit.Framework;
@@ -16,6 +18,7 @@ namespace NzbDrone.Core.Test.MovieTests
     {
         private Movie _movie;
         private MoveMovieCommand _command;
+        private BulkMoveMovieCommand _bulkCommand;
 
         [SetUp]
         public void Setup()
@@ -25,15 +28,32 @@ namespace NzbDrone.Core.Test.MovieTests
                 .Build();
 
             _command = new MoveMovieCommand
-                       {
-                           MovieId = 1,
-                           SourcePath = @"C:\Test\Movies\Movie".AsOsAgnostic(),
-                           DestinationPath = @"C:\Test\Movies2\Movie".AsOsAgnostic()
-                       };
+            {
+                MovieId = 1,
+                SourcePath = @"C:\Test\Movies\Movie".AsOsAgnostic(),
+                DestinationPath = @"C:\Test\Movies2\Movie".AsOsAgnostic()
+            };
+
+            _bulkCommand = new BulkMoveMovieCommand
+            {
+                Movies = new List<BulkMoveMovie>
+                                    {
+                                        new BulkMoveMovie
+                                        {
+                                            MovieId = 1,
+                                            SourcePath = @"C:\Test\Movies\Movie".AsOsAgnostic()
+                                        }
+                                    },
+                DestinationRootFolder = @"C:\Test\Movies2".AsOsAgnostic()
+            };
 
             Mocker.GetMock<IMovieService>()
                   .Setup(s => s.GetMovie(It.IsAny<int>()))
                   .Returns(_movie);
+
+            Mocker.GetMock<IDiskProvider>()
+                  .Setup(s => s.FolderExists(It.IsAny<string>()))
+                  .Returns(true);
         }
 
         private void GivenFailedMove()
@@ -48,52 +68,67 @@ namespace NzbDrone.Core.Test.MovieTests
         {
             GivenFailedMove();
 
-            Assert.Throws<IOException>(() => Subject.Execute(_command));
+            Subject.Execute(_command);
 
             ExceptionVerification.ExpectedErrors(1);
         }
 
         [Test]
-        public void should_no_update_movie_path_on_error()
+        public void should_revert_movie_path_on_error()
         {
             GivenFailedMove();
 
-            Assert.Throws<IOException>(() => Subject.Execute(_command));
+            Subject.Execute(_command);
 
             ExceptionVerification.ExpectedErrors(1);
 
             Mocker.GetMock<IMovieService>()
-                  .Verify(v => v.UpdateMovie(It.IsAny<Movie>()), Times.Never());
+                  .Verify(v => v.UpdateMovie(It.IsAny<Movie>()), Times.Once());
         }
 
         [Test]
-        public void should_build_new_path_when_root_folder_is_provided()
+        public void should_use_destination_path()
         {
-            _command.DestinationPath = null;
-            _command.DestinationRootFolder = @"C:\Test\Movie3".AsOsAgnostic();
+            Subject.Execute(_command);
 
-            var expectedPath = @"C:\Test\Movie3\Movie".AsOsAgnostic();
+            Mocker.GetMock<IDiskTransferService>()
+                  .Verify(v => v.TransferFolder(_command.SourcePath, _command.DestinationPath, TransferMode.Move, It.IsAny<bool>()), Times.Once());
 
             Mocker.GetMock<IBuildFileNames>()
-                  .Setup(s => s.GetMovieFolder(It.IsAny<Movie>(), null))
-                  .Returns("Movie");
+                  .Verify(v => v.GetMovieFolder(It.IsAny<Movie>(), null), Times.Never());
+        }
 
-            Subject.Execute(_command);
+        [Test]
+        public void should_build_new_path_when_root_folder_is_provided()
+        {
+            var movieFolder = "Movie";
+            var expectedPath = Path.Combine(_bulkCommand.DestinationRootFolder, movieFolder);
 
-            Mocker.GetMock<IMovieService>()
-                  .Verify(v => v.UpdateMovie(It.Is<Movie>(s => s.Path == expectedPath)), Times.Once());
+            Mocker.GetMock<IBuildFileNames>()
+                    .Setup(s => s.GetMovieFolder(It.IsAny<Movie>(), null))
+                    .Returns(movieFolder);
+
+            Subject.Execute(_bulkCommand);
+
+            Mocker.GetMock<IDiskTransferService>()
+                  .Verify(v => v.TransferFolder(_bulkCommand.Movies.First().SourcePath, expectedPath, TransferMode.Move, It.IsAny<bool>()), Times.Once());
         }
 
         [Test]
-        public void should_use_destination_path_if_destination_root_folder_is_blank()
+        public void should_skip_movie_folder_if_it_does_not_exist()
         {
+            Mocker.GetMock<IDiskProvider>()
+                  .Setup(s => s.FolderExists(It.IsAny<string>()))
+                  .Returns(false);
+
+
             Subject.Execute(_command);
 
-            Mocker.GetMock<IMovieService>()
-                  .Verify(v => v.UpdateMovie(It.Is<Movie>(s => s.Path == _command.DestinationPath)), Times.Once());
+            Mocker.GetMock<IDiskTransferService>()
+                  .Verify(v => v.TransferFolder(_command.SourcePath, _command.DestinationPath, TransferMode.Move, It.IsAny<bool>()), Times.Never());
 
             Mocker.GetMock<IBuildFileNames>()
                   .Verify(v => v.GetMovieFolder(It.IsAny<Movie>(), null), Times.Never());
         }
     }
-}
+}

src/NzbDrone.Core/Movies/MoveMovieService.cs

@@ -1,7 +1,6 @@
 using System.IO;
 using NLog;
 using NzbDrone.Common.Disk;
-using NzbDrone.Common.Extensions;
 using NzbDrone.Common.Instrumentation.Extensions;
 using NzbDrone.Core.Messaging.Commands;
 using NzbDrone.Core.Messaging.Events;
@@ -11,61 +10,94 @@ using NzbDrone.Core.Organizer;
 
 namespace NzbDrone.Core.Movies
 {
-    public class MoveMovieService : IExecute<MoveMovieCommand>
+    public class MoveMovieService : IExecute<MoveMovieCommand>, IExecute<BulkMoveMovieCommand>
     {
         private readonly IMovieService _movieService;
         private readonly IBuildFileNames _filenameBuilder;
+        private readonly IDiskProvider _diskProvider;
         private readonly IDiskTransferService _diskTransferService;
         private readonly IEventAggregator _eventAggregator;
         private readonly Logger _logger;
 
         public MoveMovieService(IMovieService movieService,
                                  IBuildFileNames filenameBuilder,
+                                 IDiskProvider diskProvider,
                                  IDiskTransferService diskTransferService,
                                  IEventAggregator eventAggregator,
                                  Logger logger)
         {
             _movieService = movieService;
             _filenameBuilder = filenameBuilder;
+            _diskProvider = diskProvider;
             _diskTransferService = diskTransferService;
             _eventAggregator = eventAggregator;
             _logger = logger;
         }
 
-        public void Execute(MoveMovieCommand message)
+        private void MoveSingleMovie(Movie movie, string sourcePath, string destinationPath, int? index = null, int? total = null)
         {
-            var movie = _movieService.GetMovie(message.MovieId);
-            var source = message.SourcePath;
-            var destination = message.DestinationPath;
-
-            if (!message.DestinationRootFolder.IsNullOrWhiteSpace())
+            if (!_diskProvider.FolderExists(sourcePath))
             {
-                _logger.Debug("Buiding destination path using root folder: {0} and the movie title", message.DestinationRootFolder);
-                destination = Path.Combine(message.DestinationRootFolder, _filenameBuilder.GetMovieFolder(movie));
+                _logger.Debug("Folder '{0}' for '{1}' does not exist, not moving.", sourcePath, movie.Title);
+                return;
             }
 
-            _logger.ProgressInfo("Moving {0} from '{1}' to '{2}'", movie.Title, source, destination);
+            if (index != null && total != null)
+            {
+                _logger.ProgressInfo("Moving {0} from '{1}' to '{2}' ({3}/{4})", movie.Title, sourcePath, destinationPath, index + 1, total);
+            }
+            else
+            {
+                _logger.ProgressInfo("Moving {0} from '{1}' to '{2}'", movie.Title, sourcePath, destinationPath);
+            }
 
-            //TODO: Move to transactional disk operations
             try
             {
-                _diskTransferService.TransferFolder(source, destination, TransferMode.Move);
+                _diskTransferService.TransferFolder(sourcePath, destinationPath, TransferMode.Move);
+
+                _logger.ProgressInfo("{0} moved successfully to {1}", movie.Title, movie.Path);
+
+                _eventAggregator.PublishEvent(new MovieMovedEvent(movie, sourcePath, destinationPath));
             }
             catch (IOException ex)
             {
-                var errorMessage = string.Format("Unable to move movie from '{0}' to '{1}'", source, destination);
+                _logger.Error(ex, "Unable to move movie from '{0}' to '{1}'. Try moving files manually", sourcePath, destinationPath);
 
-                _logger.Error(ex, errorMessage);
-                throw;
+                RevertPath(movie.Id, sourcePath);
             }
+        }
+
+        private void RevertPath(int movieId, string path)
+        {
+            var movie = _movieService.GetMovie(movieId);
 
-            _logger.ProgressInfo("{0} moved successfully to {1}", movie.Title, movie.Path);
+            movie.Path = path;
+            _movieService.UpdateMovie(movie);
+        }
+
+        public void Execute(MoveMovieCommand message)
+        {
+            var movie = _movieService.GetMovie(message.MovieId);
+            MoveSingleMovie(movie, message.SourcePath, message.DestinationPath);
+        }
 
-            //Update the movie path to the new path
-            movie.Path = destination;
-            movie = _movieService.UpdateMovie(movie);
+        public void Execute(BulkMoveMovieCommand message)
+        {
+            var moviesToMove = message.Movies;
+            var destinationRootFolder = message.DestinationRootFolder;
+
+            _logger.ProgressInfo("Moving {0} movies to '{1}'", moviesToMove.Count, destinationRootFolder);
+
+            for (var index = 0; index < moviesToMove.Count; index++)
+            {
+                var s = moviesToMove[index];
+                var movie = _movieService.GetMovie(s.MovieId);
+                var destinationPath = Path.Combine(destinationRootFolder, _filenameBuilder.GetMovieFolder(movie));
+
+                MoveSingleMovie(movie, s.SourcePath, destinationPath, index, moviesToMove.Count);
+            }
 
-            _eventAggregator.PublishEvent(new MovieMovedEvent(movie, source, destination));
+            _logger.ProgressInfo("Finished moving {0} movies to '{1}'", moviesToMove.Count, destinationRootFolder);
         }
     }
 }