| | | 1 | | using System; |
| | | 2 | | using System.Diagnostics.CodeAnalysis; |
| | | 3 | | using System.Globalization; |
| | | 4 | | using System.IO; |
| | | 5 | | using System.Text.Json; |
| | | 6 | | using Jellyfin.Extensions.Json; |
| | | 7 | | using Jellyfin.MediaEncoding.Hls.Extractors; |
| | | 8 | | using Jellyfin.MediaEncoding.Keyframes; |
| | | 9 | | using MediaBrowser.Common.Configuration; |
| | | 10 | | using MediaBrowser.Common.Extensions; |
| | | 11 | | using Microsoft.Extensions.Logging; |
| | | 12 | | |
| | | 13 | | namespace Jellyfin.MediaEncoding.Hls.Cache; |
| | | 14 | | |
| | | 15 | | /// <inheritdoc /> |
| | | 16 | | public class CacheDecorator : IKeyframeExtractor |
| | | 17 | | { |
| | | 18 | | private readonly IKeyframeExtractor _keyframeExtractor; |
| | | 19 | | private readonly ILogger<CacheDecorator> _logger; |
| | | 20 | | private readonly string _keyframeExtractorName; |
| | 0 | 21 | | private static readonly JsonSerializerOptions _jsonOptions = JsonDefaults.Options; |
| | | 22 | | private readonly string _keyframeCachePath; |
| | | 23 | | |
| | | 24 | | /// <summary> |
| | | 25 | | /// Initializes a new instance of the <see cref="CacheDecorator"/> class. |
| | | 26 | | /// </summary> |
| | | 27 | | /// <param name="applicationPaths">An instance of the <see cref="IApplicationPaths"/> interface.</param> |
| | | 28 | | /// <param name="keyframeExtractor">An instance of the <see cref="IKeyframeExtractor"/> interface.</param> |
| | | 29 | | /// <param name="logger">An instance of the <see cref="ILogger{CacheDecorator}"/> interface.</param> |
| | | 30 | | public CacheDecorator(IApplicationPaths applicationPaths, IKeyframeExtractor keyframeExtractor, ILogger<CacheDecorat |
| | 42 | 31 | | { |
| | 42 | 32 | | ArgumentNullException.ThrowIfNull(applicationPaths); |
| | 42 | 33 | | ArgumentNullException.ThrowIfNull(keyframeExtractor); |
| | | 34 | | |
| | 42 | 35 | | _keyframeExtractor = keyframeExtractor; |
| | 42 | 36 | | _logger = logger; |
| | 42 | 37 | | _keyframeExtractorName = keyframeExtractor.GetType().Name; |
| | | 38 | | // TODO make the dir configurable |
| | 42 | 39 | | _keyframeCachePath = Path.Combine(applicationPaths.DataPath, "keyframes"); |
| | 42 | 40 | | } |
| | | 41 | | |
| | | 42 | | /// <inheritdoc /> |
| | 42 | 43 | | public bool IsMetadataBased => _keyframeExtractor.IsMetadataBased; |
| | | 44 | | |
| | | 45 | | /// <inheritdoc /> |
| | | 46 | | public bool TryExtractKeyframes(string filePath, [NotNullWhen(true)] out KeyframeData? keyframeData) |
| | 0 | 47 | | { |
| | 0 | 48 | | keyframeData = null; |
| | 0 | 49 | | var cachePath = GetCachePath(_keyframeCachePath, filePath); |
| | 0 | 50 | | if (TryReadFromCache(cachePath, out var cachedResult)) |
| | 0 | 51 | | { |
| | 0 | 52 | | keyframeData = cachedResult; |
| | 0 | 53 | | return true; |
| | | 54 | | } |
| | | 55 | | |
| | 0 | 56 | | if (!_keyframeExtractor.TryExtractKeyframes(filePath, out var result)) |
| | 0 | 57 | | { |
| | 0 | 58 | | _logger.LogDebug("Failed to extract keyframes using {ExtractorName}", _keyframeExtractorName); |
| | 0 | 59 | | return false; |
| | | 60 | | } |
| | | 61 | | |
| | 0 | 62 | | _logger.LogDebug("Successfully extracted keyframes using {ExtractorName}", _keyframeExtractorName); |
| | 0 | 63 | | keyframeData = result; |
| | 0 | 64 | | SaveToCache(cachePath, keyframeData); |
| | 0 | 65 | | return true; |
| | 0 | 66 | | } |
| | | 67 | | |
| | | 68 | | private static void SaveToCache(string cachePath, KeyframeData keyframeData) |
| | 0 | 69 | | { |
| | 0 | 70 | | var json = JsonSerializer.Serialize(keyframeData, _jsonOptions); |
| | 0 | 71 | | Directory.CreateDirectory(Path.GetDirectoryName(cachePath) ?? throw new ArgumentException($"Provided path ({cach |
| | 0 | 72 | | File.WriteAllText(cachePath, json); |
| | 0 | 73 | | } |
| | | 74 | | |
| | | 75 | | private static string GetCachePath(string keyframeCachePath, string filePath) |
| | 0 | 76 | | { |
| | 0 | 77 | | var lastWriteTimeUtc = File.GetLastWriteTimeUtc(filePath); |
| | 0 | 78 | | ReadOnlySpan<char> filename = (filePath + "_" + lastWriteTimeUtc.Ticks.ToString(CultureInfo.InvariantCulture)).G |
| | 0 | 79 | | var prefix = filename[..1]; |
| | | 80 | | |
| | 0 | 81 | | return Path.Join(keyframeCachePath, prefix, filename); |
| | 0 | 82 | | } |
| | | 83 | | |
| | | 84 | | private static bool TryReadFromCache(string cachePath, [NotNullWhen(true)] out KeyframeData? cachedResult) |
| | 0 | 85 | | { |
| | 0 | 86 | | if (File.Exists(cachePath)) |
| | 0 | 87 | | { |
| | 0 | 88 | | var bytes = File.ReadAllBytes(cachePath); |
| | 0 | 89 | | cachedResult = JsonSerializer.Deserialize<KeyframeData>(bytes, _jsonOptions); |
| | 0 | 90 | | return cachedResult is not null; |
| | | 91 | | } |
| | | 92 | | |
| | 0 | 93 | | cachedResult = null; |
| | 0 | 94 | | return false; |
| | 0 | 95 | | } |
| | | 96 | | } |