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; using MediaBrowser.Model.Globalization; namespace Emby.Server.Implementations.ScheduledTasks.Tasks { /// /// Deletes old cache files /// public class DeleteCacheFileTask : IScheduledTask, IConfigurableScheduledTask { /// /// Gets or sets the application paths. /// /// The application paths. private IApplicationPaths ApplicationPaths { get; set; } private readonly ILogger _logger; private readonly IFileSystem _fileSystem; private readonly ILocalizationManager _localization; /// /// Initializes a new instance of the class. /// public DeleteCacheFileTask( IApplicationPaths appPaths, ILogger logger, IFileSystem fileSystem, ILocalizationManager localization) { ApplicationPaths = appPaths; _logger = logger; _fileSystem = fileSystem; _localization = localization; } /// /// Creates the triggers that define when the task will run /// /// IEnumerable{BaseTaskTrigger}. public IEnumerable GetDefaultTriggers() { return new[] { // Every so often new TaskTriggerInfo { Type = TaskTriggerInfo.TriggerInterval, IntervalTicks = TimeSpan.FromHours(24).Ticks} }; } /// /// Returns the task to be executed /// /// The cancellation token. /// The progress. /// Task. public Task Execute(CancellationToken cancellationToken, IProgress progress) { var minDateModified = DateTime.UtcNow.AddDays(-30); try { DeleteCacheFilesFromDirectory(cancellationToken, ApplicationPaths.CachePath, minDateModified, progress); } catch (DirectoryNotFoundException) { // No biggie here. Nothing to delete } progress.Report(90); minDateModified = DateTime.UtcNow.AddDays(-1); try { DeleteCacheFilesFromDirectory(cancellationToken, ApplicationPaths.TempDirectory, minDateModified, progress); } catch (DirectoryNotFoundException) { // No biggie here. Nothing to delete } return Task.CompletedTask; } /// /// Deletes the cache 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 DeleteCacheFilesFromDirectory(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 => _localization.GetLocalizedString("TaskCleanCache"); public string Description => _localization.GetLocalizedString("TaskCleanCacheDescription"); public string Category => _localization.GetLocalizedString("TasksCategoryMaintenance"); public string Key => "DeleteCacheFiles"; public bool IsHidden => false; public bool IsEnabled => true; public bool IsLogged => true; } }