diff --git a/Jellyfin.Plugin.MediaCleaner/Configuration/PluginConfiguration.cs b/Jellyfin.Plugin.MediaCleaner/Configuration/PluginConfiguration.cs index 1a38a02..6265d21 100644 --- a/Jellyfin.Plugin.MediaCleaner/Configuration/PluginConfiguration.cs +++ b/Jellyfin.Plugin.MediaCleaner/Configuration/PluginConfiguration.cs @@ -1,3 +1,6 @@ +using System.Collections.Generic; +using System.Collections.ObjectModel; +using MediaBrowser.Controller.Entities; using MediaBrowser.Model.Plugins; namespace Jellyfin.Plugin.MediaCleaner.Configuration; @@ -27,5 +30,5 @@ public class PluginConfiguration : BasePluginConfiguration /// /// Gets or sets the cut off days before deleting unwatched files. /// - public int DaysUnwatched { get; set; } = 90; + public int StaleMediaCutoff { get; set; } = 90; } diff --git a/Jellyfin.Plugin.MediaCleaner/ScheduledTasks/StaleMediaTask.cs b/Jellyfin.Plugin.MediaCleaner/ScheduledTasks/StaleMediaTask.cs index 8f187c9..6c9771b 100644 --- a/Jellyfin.Plugin.MediaCleaner/ScheduledTasks/StaleMediaTask.cs +++ b/Jellyfin.Plugin.MediaCleaner/ScheduledTasks/StaleMediaTask.cs @@ -1,11 +1,15 @@ using System; using System.Collections.Generic; +using System.Collections.ObjectModel; using System.Diagnostics; using System.Linq; +using System.Reflection.Metadata.Ecma335; using System.Threading; using System.Threading.Tasks; using Jellyfin.Data.Enums; using Jellyfin.Database.Implementations.Entities; +using Jellyfin.Database.Implementations.Entities.Libraries; +using Jellyfin.Plugin.MediaCleaner.Configuration; using MediaBrowser.Controller.Entities; using MediaBrowser.Controller.Library; using MediaBrowser.Model.Tasks; @@ -35,6 +39,9 @@ public sealed class StaleMediaTask : IScheduledTask _libraryManager = libraryManager; } + private static PluginConfiguration Configuration => + Plugin.Instance!.Configuration; + string IScheduledTask.Name => "Scan Stale Media"; string IScheduledTask.Key => "Stale Media"; @@ -47,26 +54,85 @@ public sealed class StaleMediaTask : IScheduledTask { var query = new InternalItemsQuery { - IncludeItemTypes = new[] { BaseItemKind.Movie, BaseItemKind.Series }, + IncludeItemTypes = [BaseItemKind.Movie, BaseItemKind.Series], Recursive = true }; - var allItems = _libraryManager.GetItemsResult(query).Items; + List allItems = [.. _libraryManager.GetItemsResult(query).Items]; _logger.LogInformation("Total items found: {AllItems}", allItems); - foreach (BaseItem item in allItems) + List shows = [.. allItems.Where(item => item.GetBaseItemKind() == BaseItemKind.Series)]; + List movies = [.. allItems.Where(item => item.GetBaseItemKind() == BaseItemKind.Movie && item.UserData.Count > 0)]; + + List staleEpisodes = [.. shows.SelectMany(GetStaleEpisodes)]; + List staleMovies = [.. GetStaleMovies(movies)]; + + _logger.LogInformation("Stale Movies found: {StaleMovies}", staleMovies.Count); + _logger.LogInformation("Stale Series found: {StaleShows}", staleEpisodes.Count); + + return Task.CompletedTask; + } + + private List GetStaleMovies(List movies) + { + List staleMovies = []; + foreach (var movie in movies) { - var userData = item.UserData.ToList(); - var mostRecentUserData = userData.OrderByDescending(data => data.LastPlayedDate).First(); - if (mostRecentUserData.LastPlayedDate < DateTime.Now.AddDays(1)) + var mostRecentUserData = movie.UserData.OrderByDescending(data => data.LastPlayedDate).First(); + if (mostRecentUserData.LastPlayedDate < DateTime.Now.AddDays(-Configuration.StaleMediaCutoff)) { - // Stale data + staleMovies.Add(movie); } } - Debugger.Break(); + return staleMovies; + } - return Task.CompletedTask; + private List GetStaleEpisodes(BaseItem item) + { + List staleEpisodes = []; + + // Gets each season in a show + var seasons = _libraryManager.GetItemList(new InternalItemsQuery + { + ParentId = item.Id, + Recursive = false + }); + + foreach (var season in seasons) + { + // Gets each episode, to access user data. + var episodes = _libraryManager.GetItemList(new InternalItemsQuery + { + ParentId = season.Id, + Recursive = false + }); + + bool seasonHasUserData = episodes.Any(episode => episode.UserData.Count > 0); + + if (seasonHasUserData) + { + var episodesWithUserData = episodes.Where(episode => episode.UserData.Count > 0).ToList(); + foreach (var episode in episodesWithUserData) + { + bool stale = false; + var mostRecentUserData = episode.UserData.OrderByDescending(data => data.LastPlayedDate).First(); + if (mostRecentUserData.LastPlayedDate < DateTime.Now.AddDays(-Configuration.StaleMediaCutoff)) + { + staleEpisodes.AddRange(episodes); + stale = true; + break; + } + + if (stale) + { + break; + } + } + } + } + + return staleEpisodes; } IEnumerable IScheduledTask.GetDefaultTriggers()