< Summary - Jellyfin

Information
Class: Emby.Server.Implementations.Data.CleanDatabaseScheduledTask
Assembly: Emby.Server.Implementations
File(s): /srv/git/jellyfin/Emby.Server.Implementations/Data/CleanDatabaseScheduledTask.cs
Line coverage
100%
Covered lines: 5
Uncovered lines: 0
Coverable lines: 5
Total lines: 119
Line coverage: 100%
Branch coverage
N/A
Covered branches: 0
Total branches: 0
Branch coverage: N/A
Method coverage

Feature is only available for sponsors

Upgrade to PRO version

Coverage history

Coverage history 0 25 50 75 100

Metrics

MethodBranch coverage Crap Score Cyclomatic complexity Line coverage
.ctor(...)100%11100%

File(s)

/srv/git/jellyfin/Emby.Server.Implementations/Data/CleanDatabaseScheduledTask.cs

#LineLine coverage
 1#pragma warning disable CS1591
 2
 3using System;
 4using System.IO;
 5using System.Linq;
 6using System.Threading;
 7using System.Threading.Tasks;
 8using Jellyfin.Database.Implementations;
 9using MediaBrowser.Controller.Entities;
 10using MediaBrowser.Controller.IO;
 11using MediaBrowser.Controller.Library;
 12using Microsoft.EntityFrameworkCore;
 13using Microsoft.Extensions.Logging;
 14
 15namespace Emby.Server.Implementations.Data;
 16
 17public class CleanDatabaseScheduledTask : ILibraryPostScanTask
 18{
 19    private readonly ILibraryManager _libraryManager;
 20    private readonly ILogger<CleanDatabaseScheduledTask> _logger;
 21    private readonly IDbContextFactory<JellyfinDbContext> _dbProvider;
 22    private readonly IPathManager _pathManager;
 23
 24    public CleanDatabaseScheduledTask(
 25        ILibraryManager libraryManager,
 26        ILogger<CleanDatabaseScheduledTask> logger,
 27        IDbContextFactory<JellyfinDbContext> dbProvider,
 28        IPathManager pathManager)
 29    {
 2130        _libraryManager = libraryManager;
 2131        _logger = logger;
 2132        _dbProvider = dbProvider;
 2133        _pathManager = pathManager;
 2134    }
 35
 36    public async Task Run(IProgress<double> progress, CancellationToken cancellationToken)
 37    {
 38        await CleanDeadItems(cancellationToken, progress).ConfigureAwait(false);
 39    }
 40
 41    private async Task CleanDeadItems(CancellationToken cancellationToken, IProgress<double> progress)
 42    {
 43        var itemIds = _libraryManager.GetItemIds(new InternalItemsQuery
 44        {
 45            HasDeadParentId = true
 46        });
 47
 48        var numComplete = 0;
 49        var numItems = itemIds.Count + 1;
 50
 51        _logger.LogDebug("Cleaning {Number} items with dead parents", numItems);
 52
 53        IProgress<double> subProgress = new Progress<double>((val) => progress.Report(val / 2));
 54
 55        foreach (var itemId in itemIds)
 56        {
 57            cancellationToken.ThrowIfCancellationRequested();
 58
 59            var item = _libraryManager.GetItemById(itemId);
 60            if (item is not null)
 61            {
 62                _logger.LogInformation("Cleaning item {Item} type: {Type} path: {Path}", item.Name, item.GetType().Name,
 63
 64                foreach (var mediaSource in item.GetMediaSources(false))
 65                {
 66                    // Delete extracted data
 67                    var mediaSourceItem = _libraryManager.GetItemById(mediaSource.Id);
 68                    if (mediaSourceItem is null)
 69                    {
 70                        continue;
 71                    }
 72
 73                    var extractedDataFolders = _pathManager.GetExtractedDataPaths(mediaSourceItem);
 74                    foreach (var folder in extractedDataFolders)
 75                    {
 76                        if (Directory.Exists(folder))
 77                        {
 78                            try
 79                            {
 80                                Directory.Delete(folder, true);
 81                            }
 82                            catch (Exception e)
 83                            {
 84                                _logger.LogWarning("Failed to remove {Folder}: {Exception}", folder, e.Message);
 85                            }
 86                        }
 87                    }
 88                }
 89
 90                // Delete item
 91                _libraryManager.DeleteItem(item, new DeleteOptions
 92                {
 93                    DeleteFileLocation = false
 94                });
 95            }
 96
 97            numComplete++;
 98            double percent = numComplete;
 99            percent /= numItems;
 100            subProgress.Report(percent * 100);
 101        }
 102
 103        subProgress = new Progress<double>((val) => progress.Report((val / 2) + 50));
 104        var context = await _dbProvider.CreateDbContextAsync(cancellationToken).ConfigureAwait(false);
 105        await using (context.ConfigureAwait(false))
 106        {
 107            var transaction = await context.Database.BeginTransactionAsync(cancellationToken).ConfigureAwait(false);
 108            await using (transaction.ConfigureAwait(false))
 109            {
 110                await context.ItemValues.Where(e => e.BaseItemsMap!.Count == 0).ExecuteDeleteAsync(cancellationToken).Co
 111                subProgress.Report(50);
 112                await transaction.CommitAsync(cancellationToken).ConfigureAwait(false);
 113                subProgress.Report(100);
 114            }
 115        }
 116
 117        progress.Report(100);
 118    }
 119}