using System.Globalization; using MediaBrowser.Common.Extensions; using MediaBrowser.Common.IO; using MediaBrowser.Common.MediaInfo; using MediaBrowser.Controller.Entities; using MediaBrowser.Controller.Persistence; using MediaBrowser.Model.Entities; using MediaBrowser.Model.Logging; using System; using System.Collections.Generic; using System.IO; using System.Linq; using System.Threading; using System.Threading.Tasks; namespace MediaBrowser.Controller.MediaInfo { /// /// Class FFMpegManager /// public class FFMpegManager { private readonly IServerApplicationPaths _appPaths; private readonly IMediaEncoder _encoder; private readonly ILogger _logger; private readonly IItemRepository _itemRepo; private readonly IFileSystem _fileSystem; /// /// Initializes a new instance of the class. /// /// The app paths. /// The encoder. /// The logger. /// The item repo. /// zipClient public FFMpegManager(IServerApplicationPaths appPaths, IMediaEncoder encoder, ILogger logger, IItemRepository itemRepo, IFileSystem fileSystem) { _appPaths = appPaths; _encoder = encoder; _logger = logger; _itemRepo = itemRepo; _fileSystem = fileSystem; } /// /// Gets the chapter images data path. /// /// The chapter images data path. public string ChapterImagesPath { get { return Path.Combine(_appPaths.DataPath, "chapter-images"); } } /// /// Gets the subtitle cache path. /// /// The subtitle cache path. private string SubtitleCachePath { get { return Path.Combine(_appPaths.CachePath, "subtitles"); } } /// /// The first chapter ticks /// private static readonly long FirstChapterTicks = TimeSpan.FromSeconds(15).Ticks; /// /// Extracts the chapter images. /// /// The video. /// The chapters. /// if set to true [extract images]. /// if set to true [save chapters]. /// The cancellation token. /// Task. /// public async Task PopulateChapterImages(Video video, List chapters, bool extractImages, bool saveChapters, CancellationToken cancellationToken) { // Can't extract images if there are no video streams if (!video.DefaultVideoStreamIndex.HasValue) { return true; } var success = true; var changesMade = false; var runtimeTicks = video.RunTimeTicks ?? 0; var currentImages = GetSavedChapterImages(video); foreach (var chapter in chapters) { if (chapter.StartPositionTicks >= runtimeTicks) { _logger.Info("Stopping chapter extraction for {0} because a chapter was found with a position greater than the runtime.", video.Name); break; } var path = GetChapterImagePath(video, chapter.StartPositionTicks); if (!currentImages.Contains(path, StringComparer.OrdinalIgnoreCase)) { if (extractImages) { if (video.VideoType == VideoType.HdDvd || video.VideoType == VideoType.Iso) { continue; } if (video.VideoType == VideoType.BluRay) { // Can only extract reliably on single file blurays if (video.PlayableStreamFileNames == null || video.PlayableStreamFileNames.Count != 1) { continue; } } // Add some time for the first chapter to make sure we don't end up with a black image var time = chapter.StartPositionTicks == 0 ? TimeSpan.FromTicks(Math.Min(FirstChapterTicks, video.RunTimeTicks ?? 0)) : TimeSpan.FromTicks(chapter.StartPositionTicks); InputType type; var inputPath = MediaEncoderHelpers.GetInputArgument(video, null, out type); try { var parentPath = Path.GetDirectoryName(path); Directory.CreateDirectory(parentPath); await _encoder.ExtractImage(inputPath, type, video.Video3DFormat, time, path, cancellationToken).ConfigureAwait(false); chapter.ImagePath = path; changesMade = true; } catch { success = false; break; } } } else if (!string.Equals(path, chapter.ImagePath, StringComparison.OrdinalIgnoreCase)) { chapter.ImagePath = path; changesMade = true; } } if (saveChapters && changesMade) { await _itemRepo.SaveChapters(video.Id, chapters, cancellationToken).ConfigureAwait(false); } DeleteDeadImages(currentImages, chapters); return success; } private void DeleteDeadImages(IEnumerable images, IEnumerable chapters) { var deadImages = images .Except(chapters.Select(i => i.ImagePath), StringComparer.OrdinalIgnoreCase) .Where(i => BaseItem.SupportedImageExtensions.Contains(Path.GetExtension(i), StringComparer.OrdinalIgnoreCase)) .ToList(); foreach (var image in deadImages) { _logger.Debug("Deleting dead chapter image {0}", image); try { File.Delete(image); } catch (IOException ex) { _logger.ErrorException("Error deleting {0}.", ex, image); } } } private readonly CultureInfo UsCulture = new CultureInfo("en-US"); /// /// Gets the subtitle cache path. /// /// The input. /// Index of the subtitle stream. /// The offset. /// The output extension. /// System.String. public string GetSubtitleCachePath(Video input, int subtitleStreamIndex, TimeSpan? offset, string outputExtension) { var ticksParam = offset.HasValue ? "_" + offset.Value.Ticks : ""; var stream = _itemRepo.GetMediaStreams(new MediaStreamQuery { ItemId = input.Id, Index = subtitleStreamIndex }).FirstOrDefault(); if (stream == null) { return null; } if (stream.IsExternal) { ticksParam += _fileSystem.GetLastWriteTimeUtc(stream.Path).Ticks; } var filename = (input.Id + "_" + subtitleStreamIndex.ToString(UsCulture) + "_" + input.DateModified.Ticks.ToString(UsCulture) + ticksParam).GetMD5() + outputExtension; var prefix = filename.Substring(0, 1); return Path.Combine(SubtitleCachePath, prefix, filename); } public string GetChapterImagePath(Video video, long chapterPositionTicks) { var filename = video.DateModified.Ticks.ToString(UsCulture) + "_" + chapterPositionTicks.ToString(UsCulture) + ".jpg"; var videoId = video.Id.ToString(); var prefix = videoId.Substring(0, 1); return Path.Combine(ChapterImagesPath, prefix, videoId, filename); } public List GetSavedChapterImages(Video video) { var videoId = video.Id.ToString(); var prefix = videoId.Substring(0, 1); var path = Path.Combine(ChapterImagesPath, prefix, videoId); try { return Directory.EnumerateFiles(path) .ToList(); } catch (DirectoryNotFoundException) { return new List(); } } } }