2 Commits

10 changed files with 216 additions and 115 deletions

View File

@@ -1,22 +1,32 @@
using Jellyfin.Plugin.MediaCleaner.Data; using Jellyfin.Plugin.MediaCleaner.Data;
using Jellyfin.Plugin.MediaCleaner;
using Jellyfin.Plugin.MediaCleaner.Models; using Jellyfin.Plugin.MediaCleaner.Models;
using Microsoft.AspNetCore.Mvc; using Microsoft.AspNetCore.Mvc;
using Jellyfin.Plugin.MediaCleaner.Configuration;
namespace Jellyfin.Plugin.MediaCleaner.Controllers; namespace Jellyfin.Plugin.MediaCleaner.Controllers;
[Route("mediacleaner/state")] [Route("mediacleaner/state")]
public class StateController : Controller public class StateController(MediaCleanerState state) : Controller
{ {
private readonly PluginState _state; private readonly MediaCleanerState _state = state;
public StateController(PluginState state) => _state = state; private static PluginConfiguration Configuration =>
Plugin.Instance!.Configuration;
[HttpGet] [HttpGet("getSeriesInfo")]
public IActionResult Get() => Ok(_state.GetSeriesInfo()); public IActionResult GetSeriesInfo() => Ok(_state.GetSeriesInfo());
[HttpPost("add")] [HttpGet("getMovieInfo")]
public IActionResult AddSeriesInfo([FromBody] SeriesInfo seriesInfo) public IActionResult GetMovieInfo() => Ok(_state.GetMovieInfo());
{
_state.AddSeriesInfo(seriesInfo); [HttpGet("updateState")]
return Ok(); public IActionResult GetUpdateState() => Ok(_state.UpdateState());
}
[HttpGet("getMoviesTitle")]
public IActionResult GetMoviesTitle() =>
Ok($"Stale Movies (Unwatched for and created over {Configuration.StaleMediaCutoff} Days ago.)");
[HttpGet("getSeriesTitle")]
public IActionResult GetSeriesTitle() =>
Ok($"Stale Series (Unwatched for and created over {Configuration.StaleMediaCutoff} Days ago.)");
} }

View File

@@ -0,0 +1,42 @@
using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using Jellyfin.Database.Implementations.ModelConfiguration;
using Jellyfin.Plugin.MediaCleaner;
using Jellyfin.Plugin.MediaCleaner.Models;
using Jellyfin.Plugin.MediaCleaner.ScheduledTasks;
using MediaBrowser.Controller.Library;
using Microsoft.Extensions.Logging;
namespace Jellyfin.Plugin.MediaCleaner.Data;
public class MediaCleanerState(ILogger<StaleMediaScanner> logger, ILibraryManager libraryManager)
{
private readonly Lock _lock = new();
private IEnumerable<MediaInfo> _mediaInfo = [];
private readonly StaleMediaScanner _staleMediaScanner = new(logger, libraryManager);
public async Task UpdateState()
{
_mediaInfo = await _staleMediaScanner.ScanStaleMedia().ConfigureAwait(false);
}
public IEnumerable<SeriesInfo> GetSeriesInfo()
{
lock (_lock)
{
return _mediaInfo.OfType<SeriesInfo>();
}
}
public IEnumerable<MovieInfo> GetMovieInfo()
{
lock (_lock)
{
return _mediaInfo.OfType<MovieInfo>();
}
}
}

View File

@@ -1,29 +0,0 @@
using System.Collections.Generic;
using Jellyfin.Plugin.MediaCleaner.Models;
namespace Jellyfin.Plugin.MediaCleaner.Data;
public class PluginState
{
private readonly object _lock = new();
private List<SeriesInfo> _seriesInfo = new List<SeriesInfo>
{
new SeriesInfo { SeriesName = "TestName", Id = System.Guid.NewGuid() }
};
public void AddSeriesInfo(SeriesInfo seriesInfo)
{
lock (_lock)
{
_seriesInfo.Add(seriesInfo);
}
}
public IEnumerable<SeriesInfo> GetSeriesInfo()
{
lock (_lock)
{
return _seriesInfo;
}
}
}

View File

@@ -0,0 +1,9 @@
using System;
namespace Jellyfin.Plugin.MediaCleaner.Models;
public abstract class MediaInfo
{
public required Guid Id { get; set; }
public required string Name { get; set; }
}

View File

@@ -0,0 +1,14 @@
using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using Jellyfin.Plugin.MediaCleaner;
namespace Jellyfin.Plugin.MediaCleaner.Models;
/// <summary>
/// Contains Movie information.
/// </summary>
public class MovieInfo : MediaInfo
{
}

View File

@@ -1,26 +1,14 @@
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Collections.ObjectModel; using System.Collections.ObjectModel;
using Jellyfin.Plugin.MediaCleaner;
namespace Jellyfin.Plugin.MediaCleaner.Models; namespace Jellyfin.Plugin.MediaCleaner.Models;
/// <summary> /// <summary>
/// Contains series information. /// Contains series information.
/// </summary> /// </summary>
public class SeriesInfo public class SeriesInfo : MediaInfo
{ {
/// <summary>
/// Gets or sets series identifier.
/// </summary>
public Guid Id { get; set; }
/// <summary>
/// Gets or sets series name.
/// </summary>
public string SeriesName { get; set; } = string.Empty;
/// <summary>
/// Gets or sets seasons.
/// </summary>
public IEnumerable<string> Seasons { get; set; } = []; public IEnumerable<string> Seasons { get; set; } = [];
} }

View File

@@ -3,18 +3,29 @@
<div data-role="content"> <div data-role="content">
<div class="content-primary"> <div class="content-primary">
<div> <div>
<a href="#configurationpage?name=Home">Home</a>
<a href="#configurationpage?name=Settings">Settings</a> <a href="#configurationpage?name=Settings">Settings</a>
</div> </div>
<h2>Media Cleaner</h2> <h2>Media Cleaner</h2>
<h3 id="moviesTitle"></h3>
<table id="moviesTable">
<thead>
<tr>
<th>Name</th>
</tr>
</thead>
</table>
<br>
<br>
<h3 id="seriesTitle"></h3>
<table id="seriesTable"> <table id="seriesTable">
<thead> <thead>
<tr> <tr>
<th>ID</th> <th>Name</th>
<th>Series Name</th> <th>Seasons</th>
</tr> </tr>
</thead> </thead>
<tbody></tbody>
</table> </table>
</div> </div>
</div> </div>

View File

@@ -1,9 +1,11 @@
var table = document.getElementById("seriesTable"); document.addEventListener('pageshow', async () => {
var moviesTitle = document.getElementById("moviesTitle");
var seriesTitle = document.getElementById("seriesTitle");
var moviesTable = document.getElementById("moviesTable");
var seriesTable = document.getElementById("seriesTable");
const getMediaCleanerSeriesInfo = async () => {
const response = await fetch("/mediacleaner/state/getSeriesInfo");
const getMediaCleanerState = async () => {
const response = await fetch('/mediacleaner/state');
if(!response.ok){ if(!response.ok){
throw new Error(`Response status: ${response.status}`) throw new Error(`Response status: ${response.status}`)
@@ -12,16 +14,78 @@ const getMediaCleanerState = async () => {
return response.json(); return response.json();
} }
var state = await getMediaCleanerState(); const getMediaCleanerMovieInfo = async () => {
const response = await fetch("/mediacleaner/state/getMovieInfo");
console.log("State: ", state); if(!response.ok){
throw new Error(`Response status: ${response.status}`)
}
for(let i = 0; i < state.length; i++){ return response.json();
var row = table.insertRow(-1); }
const updateMediaCleanerState = async () => {
const response = await fetch("/mediacleaner/state/updateState");
if(!response.ok){
throw new Error(`Response status: ${response.status}`)
}
return response.json();
}
const getMediaCleanerSeriesTitle = async () => {
const response = await fetch("/mediacleaner/state/getSeriesTitle");
if(!response.ok){
throw new Error(`Response status: ${response.status}`);
}
return response.json();
}
const getMediaCleanerMoviesTitle = async () => {
const response = await fetch("/mediacleaner/state/getMoviesTitle");
if(!response.ok){
throw new Error(`Response status: ${response.status}`);
}
return response.json();
}
const populateMoviesTable = () => {
moviesTable.innerHTML = '';
for(let i = 0; i < moviesInfo.length; i++){
var row = moviesTable.insertRow(-1);
var cell1 = row.insertCell(0);
var cell2 = row.insertCell(1);
cell1.innerHTML = moviesInfo[i].Name;
cell2.innerHTML = "<button>Delete</button>";
}
}
const populateSeriesTable = () => {
seriesTable.innerHTML = '';
for(let i = 0; i < seriesInfo.length; i++){
var row = seriesTable.insertRow(-1);
var cell1 = row.insertCell(0); var cell1 = row.insertCell(0);
var cell2 = row.insertCell(1); var cell2 = row.insertCell(1);
var cell3 = row.insertCell(2); var cell3 = row.insertCell(2);
cell1.innerHTML = state[i].Id; cell1.innerHTML = seriesInfo[i].Name;
cell2.innerHTML = state[i].SeriesName; cell2.innerHTML = seriesInfo[i].Seasons.map(season => season.replace("Season ", "")).join(", ");
cell3.innerHTML = state[i].Seasons.length; cell3.innerHTML = "<button>Delete</button>";
} }
}
moviesTitle.innerHTML = await getMediaCleanerMoviesTitle();
seriesTitle.innerHTML = await getMediaCleanerSeriesTitle();
await updateMediaCleanerState();
var moviesInfo = await getMediaCleanerMovieInfo();
var seriesInfo = await getMediaCleanerSeriesInfo();
populateMoviesTable();
populateSeriesTable();
});

View File

@@ -8,6 +8,6 @@ public class PluginServiceRegistrator : IPluginServiceRegistrator
{ {
public void RegisterServices(IServiceCollection serviceCollection, IServerApplicationHost applicationHost) public void RegisterServices(IServiceCollection serviceCollection, IServerApplicationHost applicationHost)
{ {
serviceCollection.AddSingleton<PluginState>(); serviceCollection.AddSingleton<MediaCleanerState>();
} }
} }

View File

@@ -14,18 +14,20 @@ using Jellyfin.Database.Implementations.Entities;
using Jellyfin.Database.Implementations.Entities.Libraries; using Jellyfin.Database.Implementations.Entities.Libraries;
using Jellyfin.Plugin.MediaCleaner.Configuration; using Jellyfin.Plugin.MediaCleaner.Configuration;
using Jellyfin.Plugin.MediaCleaner.Helpers; using Jellyfin.Plugin.MediaCleaner.Helpers;
using Jellyfin.Plugin.MediaCleaner;
using Jellyfin.Plugin.MediaCleaner.Models; using Jellyfin.Plugin.MediaCleaner.Models;
using MediaBrowser.Controller.Entities; using MediaBrowser.Controller.Entities;
using MediaBrowser.Controller.Library; using MediaBrowser.Controller.Library;
using MediaBrowser.Model.Tasks; using MediaBrowser.Model.Tasks;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Logging; using Microsoft.Extensions.Logging;
namespace Jellyfin.Plugin.MediaCleaner.ScheduledTasks; namespace Jellyfin.Plugin.MediaCleaner;
/// <summary> /// <summary>
/// A task to scan media for stale files. /// A task to scan media for stale files.
/// </summary> /// </summary>
public sealed class StaleMediaTask : IScheduledTask public sealed class StaleMediaScanner
{ {
private readonly ILogger _logger; private readonly ILogger _logger;
private readonly ILibraryManager _libraryManager; private readonly ILibraryManager _libraryManager;
@@ -38,7 +40,7 @@ public sealed class StaleMediaTask : IScheduledTask
/// </summary> /// </summary>
/// <param name="logger">Logger for StaleMediaTask.</param> /// <param name="logger">Logger for StaleMediaTask.</param>
/// <param name="libraryManager">Accesses jellyfin's library manager for media.</param> /// <param name="libraryManager">Accesses jellyfin's library manager for media.</param>
public StaleMediaTask(ILogger<StaleMediaTask> logger, ILibraryManager libraryManager) public StaleMediaScanner(ILogger<StaleMediaScanner> logger, ILibraryManager libraryManager)
{ {
_logger = logger; _logger = logger;
_libraryManager = libraryManager; _libraryManager = libraryManager;
@@ -47,18 +49,7 @@ public sealed class StaleMediaTask : IScheduledTask
_seriesHelper = new SeriesHelper(_logger); _seriesHelper = new SeriesHelper(_logger);
} }
private static PluginConfiguration Configuration => public async Task<IEnumerable<MediaInfo>> ScanStaleMedia()
Plugin.Instance!.Configuration;
string IScheduledTask.Name => "Scan Stale Media";
string IScheduledTask.Key => "Stale Media";
string IScheduledTask.Description => "Scan Stale Media";
string IScheduledTask.Category => "Media";
Task IScheduledTask.ExecuteAsync(IProgress<double> progress, CancellationToken cancellationToken)
{ {
_loggingHelper.LogDebugInformation("--DEBUG MODE ACTIVE--"); _loggingHelper.LogDebugInformation("--DEBUG MODE ACTIVE--");
_loggingHelper.LogInformation("-------------------------------------------------"); _loggingHelper.LogInformation("-------------------------------------------------");
@@ -98,13 +89,15 @@ public sealed class StaleMediaTask : IScheduledTask
_loggingHelper.LogInformation("-------------------------------------------------"); _loggingHelper.LogInformation("-------------------------------------------------");
_loggingHelper.LogInformation("Stale seasons found: {StaleSeasons}", staleSeasons.Count); _loggingHelper.LogInformation("Stale seasons found: {StaleSeasons}", staleSeasons.Count);
IEnumerable<MediaInfo> staleSeriesInfo = [];
if (staleSeasons.Count > 0) if (staleSeasons.Count > 0)
{ {
IEnumerable<SeriesInfo> staleSeriesInfo = FindSeriesInfo(staleSeasons); staleSeriesInfo = FindSeriesInfo(staleSeasons);
foreach (var seriesInfo in staleSeriesInfo) foreach (SeriesInfo seriesInfo in staleSeriesInfo.Cast<SeriesInfo>())
{ {
_loggingHelper.LogInformation("Series Info: ID: {Id} | Series Name: {SeriesName} | Stale Seasons: {Seasons}", [seriesInfo.Id, seriesInfo.SeriesName, string.Join(", ", seriesInfo.Seasons)]); _loggingHelper.LogInformation("Series Info: ID: {Id} | Series Name: {SeriesName} | Stale Seasons: {Seasons}", [seriesInfo.Id, seriesInfo.Name, string.Join(", ", seriesInfo.Seasons)]);
} }
} }
else else
@@ -115,9 +108,17 @@ public sealed class StaleMediaTask : IScheduledTask
_loggingHelper.LogInformation("-------------------------------------------------"); _loggingHelper.LogInformation("-------------------------------------------------");
_loggingHelper.LogInformation("Stale Movies found: {StaleMovies}", staleMovies.Count); _loggingHelper.LogInformation("Stale Movies found: {StaleMovies}", staleMovies.Count);
IEnumerable<MediaInfo> staleMoviesInfo = [];
if (staleMovies.Count > 0) if (staleMovies.Count > 0)
{ {
foreach (var movieInfo in staleMovies) staleMoviesInfo = staleMovies.Select(movie => new MovieInfo
{
Id = movie.Id,
Name = movie.Name
});
foreach (MovieInfo movieInfo in staleMoviesInfo.Cast<MovieInfo>())
{ {
_loggingHelper.LogInformation("Movie Info: ID: {Id} | Movie Name: {MovieName}", [movieInfo.Id, movieInfo.Name]); _loggingHelper.LogInformation("Movie Info: ID: {Id} | Movie Name: {MovieName}", [movieInfo.Id, movieInfo.Name]);
} }
@@ -131,7 +132,9 @@ public sealed class StaleMediaTask : IScheduledTask
_loggingHelper.LogInformation("Ending stale media scan..."); _loggingHelper.LogInformation("Ending stale media scan...");
_loggingHelper.LogInformation("-------------------------------------------------"); _loggingHelper.LogInformation("-------------------------------------------------");
return Task.CompletedTask; IEnumerable<MediaInfo> mediaInfo = staleSeriesInfo.Concat(staleMoviesInfo);
return mediaInfo;
} }
private List<BaseItem> GetStaleMovies(List<BaseItem> movies) private List<BaseItem> GetStaleMovies(List<BaseItem> movies)
@@ -198,7 +201,7 @@ public sealed class StaleMediaTask : IScheduledTask
return staleSeasons; return staleSeasons;
} }
private IEnumerable<SeriesInfo> FindSeriesInfo(IReadOnlyCollection<BaseItem> seasons) private IEnumerable<MediaInfo> FindSeriesInfo(IReadOnlyCollection<BaseItem> seasons)
{ {
Guid[] seriesIds = [.. seasons.Select(season => season.ParentId).Distinct()]; Guid[] seriesIds = [.. seasons.Select(season => season.ParentId).Distinct()];
@@ -212,22 +215,11 @@ public sealed class StaleMediaTask : IScheduledTask
return new SeriesInfo return new SeriesInfo
{ {
Id = series.Id, Id = series.Id,
SeriesName = series.Name, Name = series.Name,
Seasons = [.. seasons.Where(season => season.ParentId == series.Id).Select(season => season.Name)] Seasons = [.. seasons.Where(season => season.ParentId == series.Id).Select(season => season.Name)]
}; };
}); });
return seriesInfoList; return seriesInfoList;
} }
IEnumerable<TaskTriggerInfo> IScheduledTask.GetDefaultTriggers()
{
// Run this task every 24 hours
// Unnecessary, and will be removed once front end page is ready.
yield return new TaskTriggerInfo
{
Type = TaskTriggerInfoType.IntervalTrigger,
IntervalTicks = TimeSpan.FromHours(24).Ticks
};
}
} }