CleanDatabaseScheduledTask.cs 2.5 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677
  1. using MediaBrowser.Common.Progress;
  2. using MediaBrowser.Controller.Entities;
  3. using MediaBrowser.Controller.Library;
  4. using MediaBrowser.Controller.Persistence;
  5. using MediaBrowser.Model.Entities;
  6. using MediaBrowser.Model.Logging;
  7. using System;
  8. using System.Collections.Generic;
  9. using System.Linq;
  10. using System.Threading;
  11. using System.Threading.Tasks;
  12. using MediaBrowser.Common.Configuration;
  13. using MediaBrowser.Model.IO;
  14. namespace Emby.Server.Implementations.Data
  15. {
  16. public class CleanDatabaseScheduledTask : ILibraryPostScanTask
  17. {
  18. private readonly ILibraryManager _libraryManager;
  19. private readonly IItemRepository _itemRepo;
  20. private readonly ILogger _logger;
  21. private readonly IFileSystem _fileSystem;
  22. private readonly IApplicationPaths _appPaths;
  23. public CleanDatabaseScheduledTask(ILibraryManager libraryManager, IItemRepository itemRepo, ILogger logger, IFileSystem fileSystem, IApplicationPaths appPaths)
  24. {
  25. _libraryManager = libraryManager;
  26. _itemRepo = itemRepo;
  27. _logger = logger;
  28. _fileSystem = fileSystem;
  29. _appPaths = appPaths;
  30. }
  31. public Task Run(IProgress<double> progress, CancellationToken cancellationToken)
  32. {
  33. return CleanDeadItems(cancellationToken, progress);
  34. }
  35. private async Task CleanDeadItems(CancellationToken cancellationToken, IProgress<double> progress)
  36. {
  37. var itemIds = _libraryManager.GetItemIds(new InternalItemsQuery
  38. {
  39. HasDeadParentId = true
  40. });
  41. var numComplete = 0;
  42. var numItems = itemIds.Count;
  43. _logger.Debug("Cleaning {0} items with dead parent links", numItems);
  44. foreach (var itemId in itemIds)
  45. {
  46. cancellationToken.ThrowIfCancellationRequested();
  47. var item = _libraryManager.GetItemById(itemId);
  48. if (item != null)
  49. {
  50. _logger.Info("Cleaning item {0} type: {1} path: {2}", item.Name, item.GetType().Name, item.Path ?? string.Empty);
  51. await item.Delete(new DeleteOptions
  52. {
  53. DeleteFileLocation = false
  54. }).ConfigureAwait(false);
  55. }
  56. numComplete++;
  57. double percent = numComplete;
  58. percent /= numItems;
  59. progress.Report(percent * 100);
  60. }
  61. progress.Report(100);
  62. }
  63. }
  64. }