< 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 parent links", numItems);
 52
 53        foreach (var itemId in itemIds)
 54        {
 55            cancellationToken.ThrowIfCancellationRequested();
 56
 57            var item = _libraryManager.GetItemById(itemId);
 58            if (item is not null)
 59            {
 60                _logger.LogInformation("Cleaning item {Item} type: {Type} path: {Path}", item.Name, item.GetType().Name,
 61
 62                foreach (var mediaSource in item.GetMediaSources(false))
 63                {
 64                    // Delete extracted subtitles
 65                    try
 66                    {
 67                        var subtitleFolder = _pathManager.GetSubtitleFolderPath(mediaSource.Id);
 68                        if (Directory.Exists(subtitleFolder))
 69                        {
 70                            Directory.Delete(subtitleFolder, true);
 71                        }
 72                    }
 73                    catch (Exception e)
 74                    {
 75                        _logger.LogWarning("Failed to remove subtitle cache folder for {Item}: {Exception}", item.Id, e.
 76                    }
 77
 78                    // Delete extracted attachments
 79                    try
 80                    {
 81                        var attachmentFolder = _pathManager.GetAttachmentFolderPath(mediaSource.Id);
 82                        if (Directory.Exists(attachmentFolder))
 83                        {
 84                            Directory.Delete(attachmentFolder, true);
 85                        }
 86                    }
 87                    catch (Exception e)
 88                    {
 89                        _logger.LogWarning("Failed to remove attachment cache folder for {Item}: {Exception}", item.Id, 
 90                    }
 91                }
 92
 93                // Delete item
 94                _libraryManager.DeleteItem(item, new DeleteOptions
 95                {
 96                    DeleteFileLocation = false
 97                });
 98            }
 99
 100            numComplete++;
 101            double percent = numComplete;
 102            percent /= numItems;
 103            progress.Report(percent * 100);
 104        }
 105
 106        var context = await _dbProvider.CreateDbContextAsync(cancellationToken).ConfigureAwait(false);
 107        await using (context.ConfigureAwait(false))
 108        {
 109            var transaction = await context.Database.BeginTransactionAsync(cancellationToken).ConfigureAwait(false);
 110            await using (transaction.ConfigureAwait(false))
 111            {
 112                await context.ItemValues.Where(e => e.BaseItemsMap!.Count == 0).ExecuteDeleteAsync(cancellationToken).Co
 113                await transaction.CommitAsync(cancellationToken).ConfigureAwait(false);
 114            }
 115        }
 116
 117        progress.Report(100);
 118    }
 119}