using System; using System.Collections.Generic; using System.IO; using System.Linq; using System.Threading; using System.Threading.Tasks; using MediaBrowser.Common.Configuration; using MediaBrowser.Model.IO; using MediaBrowser.Model.Tasks; using Microsoft.Extensions.Logging; namespace Emby.Server.Implementations.ScheduledTasks.Tasks { /// /// Deletes all transcoding temp files /// public class DeleteTranscodeFileTask : IScheduledTask, IConfigurableScheduledTask { private readonly ILogger _logger; private readonly IConfigurationManager _configurationManager; private readonly IFileSystem _fileSystem; /// /// Initializes a new instance of the class. /// public DeleteTranscodeFileTask(ILogger logger, IFileSystem fileSystem, IConfigurationManager configurationManager) { _logger = logger; _fileSystem = fileSystem; _configurationManager = configurationManager; } /// /// Creates the triggers that define when the task will run /// /// IEnumerable{BaseTaskTrigger}. public IEnumerable GetDefaultTriggers() => new List(); /// /// Returns the task to be executed /// /// The cancellation token. /// The progress. /// Task. public Task Execute(CancellationToken cancellationToken, IProgress progress) { var minDateModified = DateTime.UtcNow.AddDays(-1); progress.Report(50); DeleteTempFilesFromDirectory(cancellationToken, _configurationManager.GetTranscodePath(), minDateModified, progress); return Task.CompletedTask; } /// /// Deletes the transcoded temp files from directory with a last write time less than a given date /// /// The task cancellation token. /// The directory. /// The min date modified. /// The progress. private void DeleteTempFilesFromDirectory(CancellationToken cancellationToken, string directory, DateTime minDateModified, IProgress progress) { var filesToDelete = _fileSystem.GetFiles(directory, true) .Where(f => _fileSystem.GetLastWriteTimeUtc(f) < minDateModified) .ToList(); var index = 0; foreach (var file in filesToDelete) { double percent = index; percent /= filesToDelete.Count; progress.Report(100 * percent); cancellationToken.ThrowIfCancellationRequested(); DeleteFile(file.FullName); index++; } DeleteEmptyFolders(directory); progress.Report(100); } private void DeleteEmptyFolders(string parent) { foreach (var directory in _fileSystem.GetDirectoryPaths(parent)) { DeleteEmptyFolders(directory); if (!_fileSystem.GetFileSystemEntryPaths(directory).Any()) { try { Directory.Delete(directory, false); } catch (UnauthorizedAccessException ex) { _logger.LogError(ex, "Error deleting directory {path}", directory); } catch (IOException ex) { _logger.LogError(ex, "Error deleting directory {path}", directory); } } } } private void DeleteFile(string path) { try { _fileSystem.DeleteFile(path); } catch (UnauthorizedAccessException ex) { _logger.LogError(ex, "Error deleting file {path}", path); } catch (IOException ex) { _logger.LogError(ex, "Error deleting file {path}", path); } } public string Name => "Transcode file cleanup"; public string Description => "Deletes transcode files more than 24 hours old."; public string Category => "Maintenance"; public string Key => "DeleteTranscodeFiles"; public bool IsHidden => false; public bool IsEnabled => false; public bool IsLogged => true; } }