update plex paths when they are changed (#394)

CHANGELOG.md

@@ -10,6 +10,7 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/).
 ### Fixed
 - Include Specials/Season 0 `episode-num` entry in XMLTV
 - Fix some transcoding edge cases with VAAPI and pixel formats `yuv420p10le`, `yuv444p10le` and `yuv444p`
+- Update Plex movie and episode paths when they are changed within Plex
 
 ## [0.0.61-alpha] - 2021-09-30
 ### Fixed

ErsatzTV.Core.Tests/Fakes/FakeTelevisionRepository.cs

@@ -97,5 +97,6 @@ namespace ErsatzTV.Core.Tests.Fakes
         public Task<bool> AddDirector(EpisodeMetadata metadata, Director director) => throw new NotSupportedException();
 
         public Task<bool> AddWriter(EpisodeMetadata metadata, Writer writer) => throw new NotSupportedException();
+        public Task<Unit> UpdatePath(int mediaFileId, string path) => throw new NotSupportedException();
     }
 }

ErsatzTV.Core/Interfaces/Repositories/IMovieRepository.cs

@@ -33,5 +33,6 @@ namespace ErsatzTV.Core.Interfaces.Repositories
         Task<Option<EmbyMovie>> UpdateEmby(EmbyMovie movie);
         Task<bool> AddDirector(MovieMetadata metadata, Director director);
         Task<bool> AddWriter(MovieMetadata metadata, Writer writer);
+        Task<Unit> UpdatePath(int mediaFileId, string path);
     }
 }

ErsatzTV.Core/Interfaces/Repositories/ITelevisionRepository.cs

@@ -51,5 +51,6 @@ namespace ErsatzTV.Core.Interfaces.Repositories
         Task<Unit> RemoveMetadata(Episode episode, EpisodeMetadata metadata);
         Task<bool> AddDirector(EpisodeMetadata metadata, Director director);
         Task<bool> AddWriter(EpisodeMetadata metadata, Writer writer);
+        Task<Unit> UpdatePath(int mediaFileId, string path);
     }
 }

ErsatzTV.Core/Plex/PlexMovieLibraryScanner.cs

@@ -156,6 +156,24 @@ namespace ErsatzTV.Core.Plex
             MediaVersion existingVersion = existing.MediaVersions.Head();
             MediaVersion incomingVersion = incoming.MediaVersions.Head();
 
+            foreach (MediaFile incomingFile in incomingVersion.MediaFiles.HeadOrNone())
+            {
+                foreach (MediaFile existingFile in existingVersion.MediaFiles.HeadOrNone())
+                {
+                    if (incomingFile.Path != existingFile.Path)
+                    {
+                        _logger.LogDebug(
+                            "Plex movie has moved from {OldPath} to {NewPath}",
+                            existingFile.Path,
+                            incomingFile.Path);
+
+                        existingFile.Path = incomingFile.Path;
+
+                        await _movieRepository.UpdatePath(existingFile.Id, incomingFile.Path);
+                    }
+                }
+            }
+
             if (incomingVersion.DateUpdated > existingVersion.DateUpdated || !existingVersion.Streams.Any())
             {
                 string localPath = _plexPathReplacementService.GetReplacementPlexPath(

ErsatzTV.Core/Plex/PlexTelevisionLibraryScanner.cs

@@ -514,6 +514,24 @@ namespace ErsatzTV.Core.Plex
         {
             MediaVersion existingVersion = existing.MediaVersions.Head();
             MediaVersion incomingVersion = incoming.MediaVersions.Head();
+            
+            foreach (MediaFile incomingFile in incomingVersion.MediaFiles.HeadOrNone())
+            {
+                foreach (MediaFile existingFile in existingVersion.MediaFiles.HeadOrNone())
+                {
+                    if (incomingFile.Path != existingFile.Path)
+                    {
+                        _logger.LogDebug(
+                            "Plex episode has moved from {OldPath} to {NewPath}",
+                            existingFile.Path,
+                            incomingFile.Path);
+
+                        existingFile.Path = incomingFile.Path;
+
+                        await _televisionRepository.UpdatePath(existingFile.Id, incomingFile.Path);
+                    }
+                }
+            }
 
             if (incomingVersion.DateUpdated > existingVersion.DateUpdated || !existingVersion.Streams.Any())
             {

ErsatzTV.Infrastructure/Data/Repositories/MovieRepository.cs

@@ -774,6 +774,11 @@ namespace ErsatzTV.Infrastructure.Data.Repositories
                 "INSERT INTO Writer (Name, MovieMetadataId) VALUES (@Name, @MetadataId)",
                 new { writer.Name, MetadataId = metadata.Id }).Map(result => result > 0);
 
+        public Task<Unit> UpdatePath(int mediaFileId, string path) =>
+            _dbConnection.ExecuteAsync(
+                "UPDATE MediaFile SET Path = @Path WHERE Id = @MediaFileId",
+                new { Path = path, MediaFileId = mediaFileId }).Map(_ => Unit.Default);
+
         private static async Task<Either<BaseError, MediaItemScanResult<Movie>>> AddMovie(
             TvContext dbContext,
             int libraryPathId,

ErsatzTV.Infrastructure/Data/Repositories/TelevisionRepository.cs

@@ -568,6 +568,11 @@ namespace ErsatzTV.Infrastructure.Data.Repositories
                 "INSERT INTO Writer (Name, EpisodeMetadataId) VALUES (@Name, @MetadataId)",
                 new { writer.Name, MetadataId = metadata.Id }).Map(result => result > 0);
 
+        public Task<Unit> UpdatePath(int mediaFileId, string path) =>
+            _dbConnection.ExecuteAsync(
+                "UPDATE MediaFile SET Path = @Path WHERE Id = @MediaFileId",
+                new { Path = path, MediaFileId = mediaFileId }).Map(_ => Unit.Default);
+
         public async Task<List<Episode>> GetShowItems(int showId)
         {
             IEnumerable<int> ids = await _dbConnection.QueryAsync<int>(