using System; using System.Collections.Generic; using System.IO; using System.Linq; using NLog; using NzbDrone.Common.Disk; using NzbDrone.Common.Extensions; using NzbDrone.Common.Instrumentation.Extensions; using NzbDrone.Core.MediaFiles.Commands; using NzbDrone.Core.MediaFiles.Events; using NzbDrone.Core.Messaging.Commands; using NzbDrone.Core.Messaging.Events; using NzbDrone.Core.Organizer; using NzbDrone.Core.Music; namespace NzbDrone.Core.MediaFiles { public interface IRenameTrackFileService { List GetRenamePreviews(int artistId); List GetRenamePreviews(int artistId, int albumId); } public class RenameTrackFileService : IRenameTrackFileService, IExecute, IExecute { private readonly IArtistService _artistService; private readonly IAlbumService _albumService; private readonly IMediaFileService _mediaFileService; private readonly IMoveTrackFiles _trackFileMover; private readonly IEventAggregator _eventAggregator; private readonly ITrackService _trackService; private readonly IBuildFileNames _filenameBuilder; private readonly IDiskProvider _diskProvider; private readonly Logger _logger; public RenameTrackFileService(IArtistService artistService, IAlbumService albumService, IMediaFileService mediaFileService, IMoveTrackFiles trackFileMover, IEventAggregator eventAggregator, ITrackService trackService, IBuildFileNames filenameBuilder, IDiskProvider diskProvider, Logger logger) { _artistService = artistService; _albumService = albumService; _mediaFileService = mediaFileService; _trackFileMover = trackFileMover; _eventAggregator = eventAggregator; _trackService = trackService; _filenameBuilder = filenameBuilder; _diskProvider = diskProvider; _logger = logger; } public List GetRenamePreviews(int artistId) { var artist = _artistService.GetArtist(artistId); var tracks = _trackService.GetTracksByArtist(artistId); var files = _mediaFileService.GetFilesByArtist(artistId); return GetPreviews(artist, tracks, files) .OrderByDescending(e => e.AlbumId) .ThenByDescending(e => e.TrackNumbers.First()) .ToList(); } public List GetRenamePreviews(int artistId, int albumId) { var artist = _artistService.GetArtist(artistId); var tracks = _trackService.GetTracksByAlbum(albumId); var files = _mediaFileService.GetFilesByAlbum(artistId, albumId); return GetPreviews(artist, tracks, files) .OrderByDescending(e => e.TrackNumbers.First()).ToList(); } private IEnumerable GetPreviews(Artist artist, List tracks, List files) { foreach (var f in files) { var file = f; var tracksInFile = tracks.Where(e => e.TrackFileId == file.Id).ToList(); var trackFilePath = Path.Combine(artist.Path, file.RelativePath); if (!tracksInFile.Any()) { _logger.Warn("File ({0}) is not linked to any tracks", trackFilePath); continue; } var album = _albumService.GetAlbum(tracksInFile.First().AlbumId); var newName = _filenameBuilder.BuildTrackFileName(tracksInFile, artist, album, file); var newPath = _filenameBuilder.BuildTrackFilePath(artist, album, newName, Path.GetExtension(trackFilePath)); if (!trackFilePath.PathEquals(newPath, StringComparison.Ordinal)) { yield return new RenameTrackFilePreview { ArtistId = artist.Id, AlbumId = album.Id, TrackNumbers = tracksInFile.Select(e => e.AbsoluteTrackNumber).ToList(), TrackFileId = file.Id, ExistingPath = file.RelativePath, NewPath = artist.Path.GetRelativePath(newPath) }; } } } private void RenameFiles(List trackFiles, Artist artist) { var renamed = new List(); foreach (var trackFile in trackFiles) { var trackFilePath = Path.Combine(artist.Path, trackFile.RelativePath); try { _logger.Debug("Renaming track file: {0}", trackFile); _trackFileMover.MoveTrackFile(trackFile, artist); _mediaFileService.Update(trackFile); renamed.Add(trackFile); _logger.Debug("Renamed track file: {0}", trackFile); _eventAggregator.PublishEvent(new TrackFileRenamedEvent(artist, trackFile, trackFilePath)); } catch (SameFilenameException ex) { _logger.Debug("File not renamed, source and destination are the same: {0}", ex.Filename); } catch (Exception ex) { _logger.Error(ex, "Failed to rename file {0}", trackFilePath); } } if (renamed.Any()) { _diskProvider.RemoveEmptySubfolders(artist.Path); _eventAggregator.PublishEvent(new ArtistRenamedEvent(artist)); } } public void Execute(RenameFilesCommand message) { var artist = _artistService.GetArtist(message.ArtistId); var trackFiles = _mediaFileService.Get(message.Files); _logger.ProgressInfo("Renaming {0} files for {1}", trackFiles.Count, artist.Name); RenameFiles(trackFiles, artist); _logger.ProgressInfo("Selected track files renamed for {0}", artist.Name); } public void Execute(RenameArtistCommand message) { _logger.Debug("Renaming all files for selected artist"); var artistToRename = _artistService.GetArtists(message.ArtistIds); foreach (var artist in artistToRename) { var trackFiles = _mediaFileService.GetFilesByArtist(artist.Id); _logger.ProgressInfo("Renaming all files in artist: {0}", artist.Name); RenameFiles(trackFiles, artist); _logger.ProgressInfo("All track files renamed for {0}", artist.Name); } } } }