Bug fixes and version update

Reviewed-on: #15

Directory.Build.props

@@ -1,5 +1,5 @@
 <Project>
   <PropertyGroup>
-    <AssemblyVersion>0.0.0.12</AssemblyVersion>
+    <AssemblyVersion>0.1.1.1</AssemblyVersion>
   </PropertyGroup>
 </Project>

Jellyfin.Plugin.MediaCleaner/Configuration.cs

@@ -30,6 +30,16 @@ public class Configuration : BasePluginConfiguration
     /// </summary>
     public string SonarrAPIKey { get; set; } = string.Empty;
 
+    /// <summary>
+    /// Gets or sets the http and port address for your Sonarr instance.
+    /// </summary>
+    public string SonarrAnimeAddress { get; set; } = string.Empty;
+
+    /// <summary>
+    /// Gets or sets the api for your Sonarr instance.
+    /// </summary>
+    public string SonarrAnimeAPIKey { get; set; } = string.Empty;
+
     /// <summary>
     /// Gets or sets the cut off days before deleting unwatched files.
     /// </summary>

Jellyfin.Plugin.MediaCleaner/Controllers/RadarrController.cs

@@ -0,0 +1,104 @@
+using Jellyfin.Plugin.MediaCleaner.Helpers;
+using Jellyfin.Plugin.MediaCleaner.Models;
+using Microsoft.AspNetCore.Mvc;
+using System;
+using System.Collections.Generic;
+using System.Net.Http;
+using System.Text.Json;
+using System.Text.Json.Serialization;
+using System.Threading.Tasks;
+using Jellyfin.Plugin.MediaCleaner.Enums;
+using Microsoft.AspNetCore.Http;
+using System.Linq;
+
+namespace Jellyfin.Plugin.MediaCleaner.Controllers;
+
+[Route("radarr")]
+public class RadarrController : Controller
+{
+    private async Task<ObjectResult> GetRadarrMovieInfo(MovieInfo movieInfo)
+    {
+        HttpHelper httpHelper = new(ServerType.Radarr);
+        var responseBody = await httpHelper.SendHttpRequestAsync(
+            HttpMethod.Get,
+            $"/api/v3/movie?tmdbId={Uri.EscapeDataString(movieInfo.TmdbId ?? string.Empty)}&excludeLocalCovers=false"
+        ).ConfigureAwait(false);
+
+        var movies = JsonSerializer.Deserialize<List<RadarrMovie>>(responseBody.GetRawText());
+        var movie = movies?.FirstOrDefault();
+
+        if (movie == null)
+        {
+            return NotFound("Movie not found in Radarr library.");
+        }
+
+        return Ok(movie);
+    }
+
+    [HttpPost("deleteMovieFromRadarr")]
+    public async Task<IActionResult> DeleteMovieFromRadarr([FromBody] MovieInfo movieInfo){
+
+        if (movieInfo == null || string.IsNullOrEmpty(movieInfo.TmdbId))
+        {
+            return BadRequest("Invalid movie information provided.");
+        }
+
+        try
+        {
+            var radarrMovieInfoResult = await GetRadarrMovieInfo(movieInfo).ConfigureAwait(false);
+
+            if(radarrMovieInfoResult.StatusCode != StatusCodes.Status200OK || radarrMovieInfoResult.Value is not RadarrMovie){
+                return radarrMovieInfoResult;
+            }
+
+            RadarrMovie movie = (RadarrMovie)radarrMovieInfoResult.Value;
+
+            HttpHelper httpHelper = new(ServerType.Radarr);
+            var responseBody = await httpHelper.SendHttpRequestAsync(
+                HttpMethod.Delete,
+                $"/api/v3/movie/{movie.Id}?deleteFiles=true&addImportExclusion=true"
+            ).ConfigureAwait(false);
+
+            // Radarr typically returns an empty body on successful delete.
+            return Ok(responseBody);
+        }
+        catch (HttpRequestException e)
+        {
+            return StatusCode(StatusCodes.Status500InternalServerError, $"An unexpected error occurred. {e.Message}");
+        }
+    }
+
+    [HttpPost("testConnection")]
+    public async Task<IActionResult> TestConnection([FromBody] ConnectionTestRequest request)
+    {
+        if (request == null || string.IsNullOrWhiteSpace(request.Address) || string.IsNullOrWhiteSpace(request.ApiKey))
+        {
+            return BadRequest("Address and ApiKey are required.");
+        }
+
+        var address = request.Address.Trim();
+        if (!address.StartsWith("http://", StringComparison.OrdinalIgnoreCase) &&
+            !address.StartsWith("https://", StringComparison.OrdinalIgnoreCase))
+        {
+            address = "http://" + address;
+        }
+
+        try
+        {
+            using var testHttpClient = new HttpClient();
+            using var httpRequest = new HttpRequestMessage(HttpMethod.Get, address);
+            httpRequest.Headers.Add("X-Api-Key", request.ApiKey);
+
+            var response = await testHttpClient.SendAsync(httpRequest).ConfigureAwait(false);
+            return Ok(new { success = response.IsSuccessStatusCode });
+        }
+        catch (HttpRequestException e)
+        {
+            return StatusCode(StatusCodes.Status502BadGateway, e.Message);
+        }
+        catch (Exception e)
+        {
+            return StatusCode(StatusCodes.Status500InternalServerError, e.Message);
+        }
+    }
+}

Jellyfin.Plugin.MediaCleaner/Controllers/SonarrController.cs

@@ -0,0 +1,290 @@
+using Jellyfin.Plugin.MediaCleaner.Models;
+using Microsoft.AspNetCore.Mvc;
+using System.Net.Http;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore.Http;
+using System.Net.Http.Headers;
+using System;
+using System.Text.Json;
+using System.Collections.Generic;
+using System.Linq;
+using System.Globalization;
+using Jellyfin.Plugin.MediaCleaner.Enums;
+using Jellyfin.Plugin.MediaCleaner.Helpers;
+
+namespace Jellyfin.Plugin.MediaCleaner.Controllers;
+
+[Route("sonarr")]
+public class SonarrController : Controller
+{
+    private readonly HttpClient _httpClient;
+
+    public SonarrController(HttpClient httpClient)
+    {
+        _httpClient = httpClient;
+
+        // Set the default request headers
+        _httpClient.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
+    }
+
+    private async Task<ObjectResult> GetSeriesInfo(SeriesInfo seriesInfo, ServerType serverType){
+        HttpHelper httpHelper = new(serverType);
+        var responseBody = await httpHelper.SendHttpRequestAsync(
+            HttpMethod.Get,
+            $"/api/v3/series?tvdbId={Uri.EscapeDataString(seriesInfo.TvdbId ?? string.Empty)}"
+        ).ConfigureAwait(false);
+
+        var seriesResponseObj = JsonSerializer.Deserialize<List<SonarrSeries>>(responseBody.GetRawText());
+        var series = seriesResponseObj?.FirstOrDefault();
+
+        if (series == null)
+        {
+            return NotFound("Series not found in Sonarr library.");
+        }
+
+        return Ok(series);
+    }
+
+    private async Task<ObjectResult> GetEpisodeInfo(SonarrSeries sonarrSeries, ServerType serverType){
+        HttpHelper httpHelper = new(serverType);
+        var responseBody = await httpHelper.SendHttpRequestAsync(
+            HttpMethod.Get,
+            $"/api/v3/episode?seriesId={sonarrSeries.Id.ToString(CultureInfo.InvariantCulture)}"
+        ).ConfigureAwait(false);
+
+        var episodesResponseObj = JsonSerializer.Deserialize<List<EpisodeDeletionDetails>>(responseBody.GetRawText());
+
+        if(episodesResponseObj == null){
+            return NotFound("No episodes in response object.");
+        }
+
+        var seasonNumbers = new HashSet<int>(sonarrSeries.Seasons
+            .Select(s => s.SeasonNumber));
+
+        var staleEpisodesResponseObj = episodesResponseObj
+            .Where(episodeDeletionDetail => seasonNumbers.Contains(episodeDeletionDetail.SeasonNumber))
+            .ToList();
+
+        var episodeIds = staleEpisodesResponseObj
+            .Where(episodeDeletionDetail => episodeDeletionDetail.HasFile)
+            .Select(episodeDeletionDetail => episodeDeletionDetail.EpisodeId)
+            .ToList();
+
+        var episodeFileIds = staleEpisodesResponseObj
+            .Where(episodeDeletionDetail => episodeDeletionDetail.HasFile)
+            .Select(episodeDeletionDetail => episodeDeletionDetail.EpisodeFileId)
+            .ToList();
+
+        return Ok(new EpisodeIdLists(episodeIds, episodeFileIds));
+    }
+
+    [HttpPost("deleteSeriesFromAnimeSonarr")]
+    public async Task<IActionResult> DeleteSeriesFromAnimeSonarr([FromBody] SeriesInfo seriesInfo){
+
+        if (seriesInfo == null || string.IsNullOrEmpty(seriesInfo.TvdbId))
+        {
+            return BadRequest("Invalid series information provided.");
+        }
+
+        try
+        {
+            var sonarrSeriesInfoResult = await GetSeriesInfo(seriesInfo, ServerType.SonarrAnime).ConfigureAwait(false);
+
+            if(sonarrSeriesInfoResult.StatusCode != StatusCodes.Status200OK || sonarrSeriesInfoResult.Value is not SonarrSeries){
+                return sonarrSeriesInfoResult;
+            }
+
+            SonarrSeries retrievedSeries = (SonarrSeries)sonarrSeriesInfoResult.Value;
+            SonarrSeries staleSeries = new(
+                Id: retrievedSeries.Id,
+                Title: retrievedSeries.Title,
+                Seasons: [.. seriesInfo.Seasons.Select(season => new Season(SeasonNumber: int.Parse(season, CultureInfo.InvariantCulture)))],
+                Ended: retrievedSeries.Ended,
+                TvdbId: retrievedSeries.TvdbId
+            );
+
+            var episodesToPurgeResult = await GetEpisodeInfo(staleSeries, ServerType.SonarrAnime).ConfigureAwait(false);
+            if (episodesToPurgeResult.StatusCode != StatusCodes.Status200OK || episodesToPurgeResult.Value is not EpisodeIdLists)
+            {
+                return sonarrSeriesInfoResult;
+            }
+
+            EpisodeIdLists episodesToPurge = (EpisodeIdLists)episodesToPurgeResult.Value;
+
+            await UnmonitorSeasons(staleSeries, ServerType.SonarrAnime).ConfigureAwait(false);
+            await UnmonitorEpisodeIds(episodesToPurge.EpisodeIds, ServerType.SonarrAnime).ConfigureAwait(false);
+            await DeleteEpisodeFiles(episodesToPurge.EpisodeFileIds, ServerType.SonarrAnime).ConfigureAwait(false);
+
+            return Ok();
+        }
+        catch (HttpRequestException e)
+        {
+            return StatusCode(StatusCodes.Status500InternalServerError, $"An unexpected error occurred. {e.Message}");
+        }
+    }
+
+    [HttpPost("deleteSeriesFromSonarr")]
+    public async Task<IActionResult> DeleteSeriesFromSonarr([FromBody] SeriesInfo seriesInfo){
+
+        if (seriesInfo == null || string.IsNullOrEmpty(seriesInfo.TvdbId))
+        {
+            return BadRequest("Invalid series information provided.");
+        }
+
+        try
+        {
+            var sonarrSeriesInfoResult = await GetSeriesInfo(seriesInfo, ServerType.Sonarr).ConfigureAwait(false);
+
+            if(sonarrSeriesInfoResult.StatusCode != StatusCodes.Status200OK || sonarrSeriesInfoResult.Value is not SonarrSeries){
+                return sonarrSeriesInfoResult;
+            }
+
+            SonarrSeries retrievedSeries = (SonarrSeries)sonarrSeriesInfoResult.Value;
+            SonarrSeries staleSeries = new(
+                Id: retrievedSeries.Id,
+                Title: retrievedSeries.Title,
+                Seasons: [.. seriesInfo.Seasons.Select(season => new Season(SeasonNumber: int.Parse(season, CultureInfo.InvariantCulture)))],
+                Ended: retrievedSeries.Ended,
+                TvdbId: retrievedSeries.TvdbId
+            );
+
+            var episodesToPurgeResult = await GetEpisodeInfo(staleSeries, ServerType.Sonarr).ConfigureAwait(false);
+            if (episodesToPurgeResult.StatusCode != StatusCodes.Status200OK || episodesToPurgeResult.Value is not EpisodeIdLists)
+            {
+                return sonarrSeriesInfoResult;
+            }
+
+            EpisodeIdLists episodesToPurge = (EpisodeIdLists)episodesToPurgeResult.Value;
+
+            await UnmonitorSeasons(staleSeries, ServerType.Sonarr).ConfigureAwait(false);
+            await UnmonitorEpisodeIds(episodesToPurge.EpisodeIds, ServerType.Sonarr).ConfigureAwait(false);
+            await DeleteEpisodeFiles(episodesToPurge.EpisodeFileIds, ServerType.Sonarr).ConfigureAwait(false);
+
+            return Ok();
+        }
+        catch (HttpRequestException e)
+        {
+            return StatusCode(StatusCodes.Status500InternalServerError, $"An unexpected error occurred. {e.Message}");
+        }
+    }
+
+    private async Task<ObjectResult> UnmonitorSeasons(SonarrSeries staleSeries, ServerType serverType){
+        if (staleSeries == null)
+        {
+            return BadRequest("No stale series provided.");
+        }
+
+        HttpHelper httpHelper = new(serverType);
+        var series = await httpHelper.SendHttpRequestAsync(
+            HttpMethod.Get,
+            $"/api/v3/series/{staleSeries.Id}"
+        ).ConfigureAwait(false);
+
+        var seriesDict = JsonSerializer.Deserialize<Dictionary<string, object>>(series.GetRawText());
+        if (seriesDict == null)
+        {
+            throw new InvalidOperationException("Failed to deserialize season.");
+        }
+        var seasons = series.GetProperty("seasons").EnumerateArray().ToList();
+
+        var staleSeasonNumbers = staleSeries.Seasons
+            .Select(s => s.SeasonNumber)
+            .ToHashSet();
+
+        var updatedSeasons = seasons.Select(season =>
+        {
+            var seasonNumber = season.GetProperty("seasonNumber").GetInt32();
+
+            if (staleSeasonNumbers.Contains(seasonNumber))
+            {
+                var seasonDict = JsonSerializer.Deserialize<Dictionary<string, object>>(season.GetRawText());
+                if (seasonDict == null)
+                {
+                    throw new InvalidOperationException("Failed to deserialize season.");
+                }
+                seasonDict["monitored"] = false;
+                return seasonDict;
+            }
+
+            return JsonSerializer.Deserialize<Dictionary<string, object>>(season.GetRawText());
+        }).ToArray();
+
+        seriesDict["seasons"] = updatedSeasons;
+
+        var responseBody = await httpHelper.SendHttpRequestAsync(
+            HttpMethod.Put,
+            $"/api/v3/series/{staleSeries.Id}",
+            seriesDict
+        ).ConfigureAwait(false);
+
+        return Ok(responseBody);
+    }
+
+    private async Task<ObjectResult> DeleteEpisodeFiles(IReadOnlyList<int> episodeFileIds, ServerType serverType)
+    {
+        if (episodeFileIds == null || episodeFileIds.Count == 0)
+        {
+            return BadRequest("No episode file IDs provided.");
+        }
+
+        HttpHelper httpHelper = new(serverType);
+        var responseBody = await httpHelper.SendHttpRequestAsync(
+            HttpMethod.Delete,
+            "/api/v3/episodefile/bulk",
+            new { episodeFileIds }
+        ).ConfigureAwait(false);
+
+        return Ok(responseBody);
+    }
+
+    private async Task<ObjectResult> UnmonitorEpisodeIds(IReadOnlyList<int> episodeIds, ServerType serverType)
+    {
+        if (episodeIds == null || episodeIds.Count == 0)
+        {
+            return BadRequest("No episode IDs provided.");
+        }
+
+
+        HttpHelper httpHelper = new(serverType);
+        var responseBody = await httpHelper.SendHttpRequestAsync(
+            HttpMethod.Put,
+            "/api/v3/episode/monitor",
+            new { episodeIds, monitored = false }
+        ).ConfigureAwait(false);
+
+        return Ok(responseBody);
+    }
+
+    [HttpPost("testConnection")]
+    public async Task<IActionResult> TestConnection([FromBody] ConnectionTestRequest request)
+    {
+        if (request == null || string.IsNullOrWhiteSpace(request.Address) || string.IsNullOrWhiteSpace(request.ApiKey))
+        {
+            return BadRequest("Address and ApiKey are required.");
+        }
+
+        var address = request.Address.Trim();
+        if (!address.StartsWith("http://", StringComparison.OrdinalIgnoreCase) &&
+            !address.StartsWith("https://", StringComparison.OrdinalIgnoreCase))
+        {
+            address = "http://" + address;
+        }
+
+        try
+        {
+            using var httpRequest = new HttpRequestMessage(HttpMethod.Get, address);
+            httpRequest.Headers.Add("X-Api-Key", request.ApiKey);
+
+            var response = await _httpClient.SendAsync(httpRequest).ConfigureAwait(false);
+            return Ok(new { success = response.IsSuccessStatusCode });
+        }
+        catch (HttpRequestException e)
+        {
+            return StatusCode(StatusCodes.Status502BadGateway, e.Message);
+        }
+        catch (Exception e)
+        {
+            return StatusCode(StatusCodes.Status500InternalServerError, e.Message);
+        }
+    }
+}

Jellyfin.Plugin.MediaCleaner/Controllers/StateController.cs

@@ -2,6 +2,8 @@ using Jellyfin.Plugin.MediaCleaner.Data;
 using Jellyfin.Plugin.MediaCleaner;
 using Jellyfin.Plugin.MediaCleaner.Models;
 using Microsoft.AspNetCore.Mvc;
+using System.Threading.Tasks;
+using System.Collections.Generic;
 
 namespace Jellyfin.Plugin.MediaCleaner.Controllers;
 
@@ -12,14 +14,29 @@ public class StateController(MediaCleanerState state) : Controller
     private static Configuration Configuration =>
             Plugin.Instance!.Configuration;
 
-    [HttpGet("getSeriesInfo")]
-    public IActionResult GetSeriesInfo() => Ok(_state.GetSeriesInfo());
+    [HttpGet("getTvSeriesInfo")]
+    public async Task<IActionResult> GetTvSeriesInfo()
+    {
+        var tvSeriesInfo = await _state.GetTvSeriesInfo().ConfigureAwait(false);
+        return Ok(tvSeriesInfo);
+    }
+
+    [HttpGet("getAnimeSeriesInfo")]
+    public async Task<IActionResult> GetAnimeSeriesInfo()
+    {
+        var animeSeriesInfo = await _state.GetAnimeSeriesInfo().ConfigureAwait(false);
+        return Ok(animeSeriesInfo);
+    }
 
     [HttpGet("getMovieInfo")]
     public IActionResult GetMovieInfo() => Ok(_state.GetMovieInfo());
 
     [HttpGet("updateState")]
-    public IActionResult GetUpdateState() => Ok(_state.UpdateState());
+    public async Task<IActionResult> GetUpdateState()
+    {
+        await _state.UpdateState().ConfigureAwait(false);
+        return Ok();
+    }
 
     [HttpGet("getMoviesTitle")]
     public IActionResult GetMoviesTitle() =>
@@ -27,5 +44,9 @@ public class StateController(MediaCleanerState state) : Controller
 
     [HttpGet("getSeriesTitle")]
     public IActionResult GetSeriesTitle() =>
-        Ok($"Stale Series (Unwatched for and created over {Configuration.StaleMediaCutoff} Days ago.)");
+        Ok($"Stale TV Series (Unwatched for and created over {Configuration.StaleMediaCutoff} Days ago.)");
+
+    [HttpGet("getAnimeSeriesTitle")]
+    public IActionResult GetAnimeSeriesTitle() =>
+        Ok($"Stale Anime Series (Unwatched for and created over {Configuration.StaleMediaCutoff} Days ago.)");
 }

Jellyfin.Plugin.MediaCleaner/Data/MediaCleanerState.cs

@@ -1,34 +1,105 @@
-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.Helpers;
 using Jellyfin.Plugin.MediaCleaner.Models;
-using Jellyfin.Plugin.MediaCleaner.ScheduledTasks;
 using MediaBrowser.Controller.Library;
 using Microsoft.Extensions.Logging;
+using Jellyfin.Plugin.MediaCleaner.Enums;
+using System.Net.Http;
+using System;
+using System.Text.Json;
+using System.Globalization;
+using MediaBrowser.Model.Tasks;
+using Microsoft.AspNetCore.Mvc;
 
 namespace Jellyfin.Plugin.MediaCleaner.Data;
 
-public class MediaCleanerState(ILogger<StaleMediaScanner> logger, ILibraryManager libraryManager)
+public class MediaCleanerState(ILogger<StaleMediaScanner> logger, ILibraryManager libraryManager, ITaskManager taskManager)
 {
     private readonly Lock _lock = new();
     private IEnumerable<MediaInfo> _mediaInfo = [];
     private readonly StaleMediaScanner _staleMediaScanner = new(logger, libraryManager);
+    // private readonly ILibraryManager _libraryManager = libraryManager;
+    private readonly ITaskManager _taskManager = taskManager;
 
     public async Task UpdateState()
     {
-        _mediaInfo = await _staleMediaScanner.ScanStaleMedia().ConfigureAwait(false);
+        // First re-scan library and then scan for stale media.
+        IScheduledTaskWorker? refreshLibraryWorker = _taskManager.ScheduledTasks.FirstOrDefault(task => task.ScheduledTask.Key == "RefreshLibrary");
+
+        if(refreshLibraryWorker != null)
+        {
+            await _taskManager.Execute(refreshLibraryWorker, new TaskOptions()).ConfigureAwait(false);
         }
 
-    public IEnumerable<SeriesInfo> GetSeriesInfo()
+        _mediaInfo = await _staleMediaScanner.ScanStaleMedia().ConfigureAwait(false);
+
+        return;
+    }
+
+    public async Task<IEnumerable<SeriesInfo>> GetTvSeriesInfo()
     {
+        // Filter only TV
+        // Get all series on tv sonarr server
+        HttpHelper httpHelper = new HttpHelper(ServerType.Sonarr);
+        JsonElement tvSeriesResponse = new JsonElement();
+        try
+        {
+            tvSeriesResponse = await httpHelper.SendHttpRequestAsync(HttpMethod.Get,"/api/v3/series").ConfigureAwait(false);
+        }
+        catch
+        {
+            return [];
+        }
+
+        var tvSeries = JsonSerializer.Deserialize<IEnumerable<SonarrSeries>>(tvSeriesResponse.GetRawText());
+        if(tvSeries == null)
+        {
+            return [];
+        }
+
         lock (_lock)
         {
-            return _mediaInfo.OfType<SeriesInfo>();
+            var allSeries = _mediaInfo.OfType<SeriesInfo>();
+
+            var tvSeriesInfo = allSeries
+            .Where(series => tvSeries.Any(tv => tv.TvdbId == int.Parse(series.TvdbId, CultureInfo.InvariantCulture)));
+
+            return [.. tvSeriesInfo];
+        }
+    }
+
+    public async Task<IEnumerable<SeriesInfo>> GetAnimeSeriesInfo()
+    {
+        // Get all series on anime sonarr server
+        HttpHelper animeHttpHelper = new HttpHelper(ServerType.SonarrAnime);
+        JsonElement animeSeriesResponse = new JsonElement();
+        try
+        {
+            animeSeriesResponse = await animeHttpHelper.SendHttpRequestAsync(HttpMethod.Get,"/api/v3/series").ConfigureAwait(false);
+        }
+        catch
+        {
+            return [];
+        }
+
+        var animeSeries = JsonSerializer.Deserialize<List<SonarrSeries>>(animeSeriesResponse.GetRawText());
+
+        if(animeSeries == null)
+        {
+            return Enumerable.Empty<SeriesInfo>();
+        }
+
+        lock (_lock)
+        {
+            var allSeries = _mediaInfo.OfType<SeriesInfo>();
+
+            var animeSeriesInfo = allSeries
+            .Where(series => animeSeries.Any(anime => anime.TvdbId == int.Parse(series.TvdbId, CultureInfo.InvariantCulture)));
+
+            return animeSeriesInfo;
         }
     }
 

Jellyfin.Plugin.MediaCleaner/Enums/ServerType.cs

@@ -0,0 +1,8 @@
+namespace Jellyfin.Plugin.MediaCleaner.Enums;
+
+public enum ServerType
+{
+    Radarr,
+    Sonarr,
+    SonarrAnime
+}

Jellyfin.Plugin.MediaCleaner/Helpers/HttpHelper.cs

@@ -0,0 +1,74 @@
+using System;
+using System.Net.Http;
+using System.Net.Http.Headers;
+using System.Text.Json;
+using System.Threading.Tasks;
+using Jellyfin.Plugin.MediaCleaner.Enums;
+
+namespace Jellyfin.Plugin.MediaCleaner.Helpers;
+
+public class HttpHelper
+{
+    private string _baseAddress { get; }
+    private HttpClient _httpClient { get; }
+
+    private static Configuration Configuration =>
+            Plugin.Instance!.Configuration;
+
+    public HttpHelper(ServerType serverType)
+    {
+        _httpClient = new HttpClient();
+
+        // Set the default request headers
+        _httpClient.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
+        _httpClient.DefaultRequestHeaders.Add("X-Api-Key", RetrieveApiKey(serverType));
+
+        _baseAddress = RetrieveBaseAddress(serverType);
+    }
+
+    /// <summary>
+    /// Sends a JSON request and returns the raw JSON element response.
+    /// </summary>
+    /// <remarks>
+    /// Do NOT create a new HttpClient on every call; reuse one instance (DI or a singleton) to avoid socket exhaustion.
+    /// </remarks>
+    public async Task<JsonElement> SendHttpRequestAsync(HttpMethod method, string path, object? body = null)
+    {
+        var uri = new UriBuilder($"{_baseAddress}{path}").Uri;
+        using var request = new HttpRequestMessage(method, uri);
+
+        if (body != null)
+        {
+            var json = JsonSerializer.Serialize(body);
+            request.Content = new StringContent(json, System.Text.Encoding.UTF8, "application/json");
+        }
+
+        var response = await _httpClient.SendAsync(request).ConfigureAwait(false);
+        response.EnsureSuccessStatusCode();
+
+        var responseBody = await response.Content.ReadAsStringAsync().ConfigureAwait(false);
+        return JsonSerializer.Deserialize<JsonElement>(responseBody);
+    }
+
+    private string RetrieveApiKey(ServerType serverType)
+    {
+        return serverType switch
+        {
+            ServerType.Sonarr => Configuration.SonarrAPIKey,
+            ServerType.SonarrAnime => Configuration.SonarrAnimeAPIKey,
+            ServerType.Radarr => Configuration.RadarrAPIKey,
+            _ => string.Empty,
+        };
+    }
+
+    private string RetrieveBaseAddress(ServerType serverType)
+    {
+        return serverType switch
+        {
+            ServerType.Sonarr => Configuration.SonarrAddress,
+            ServerType.SonarrAnime => Configuration.SonarrAnimeAddress,
+            ServerType.Radarr => Configuration.RadarrAddress,
+            _ => string.Empty,
+        };
+    }
+}

Jellyfin.Plugin.MediaCleaner/Models/ConnectionTestRequest.cs

@@ -0,0 +1,3 @@
+namespace Jellyfin.Plugin.MediaCleaner.Models;
+
+public record ConnectionTestRequest(string Address, string ApiKey);

Jellyfin.Plugin.MediaCleaner/Models/EpisodeDeletionDetails.cs

@@ -0,0 +1,10 @@
+using System.Text.Json.Serialization;
+
+namespace Jellyfin.Plugin.MediaCleaner.Models;
+
+public record EpisodeDeletionDetails(
+    [property: JsonPropertyName("id")] int EpisodeId,
+    [property: JsonPropertyName("episodeFileId")] int EpisodeFileId,
+    [property: JsonPropertyName("seasonNumber")] int SeasonNumber,
+    [property: JsonPropertyName("hasFile")] bool HasFile
+);

Jellyfin.Plugin.MediaCleaner/Models/EpisodeIdLists.cs

@@ -0,0 +1,5 @@
+using System.Collections.Generic;
+
+namespace Jellyfin.Plugin.MediaCleaner.Models;
+
+public record EpisodeIdLists(IReadOnlyList<int> EpisodeIds, IReadOnlyList<int> EpisodeFileIds);

Jellyfin.Plugin.MediaCleaner/Models/MediaInfo.cs

@@ -4,6 +4,6 @@ namespace Jellyfin.Plugin.MediaCleaner.Models;
 
 public abstract class MediaInfo
 {
-    public required Guid Id { get; set; }
+    public required string TmdbId { get; set; }
     public required string Name { get; set; }
 }

Jellyfin.Plugin.MediaCleaner/Models/RadarrMovie.cs

@@ -0,0 +1,8 @@
+using System.Text.Json.Serialization;
+
+namespace Jellyfin.Plugin.MediaCleaner.Models;
+
+public record RadarrMovie(
+    [property: JsonPropertyName("id")] int? Id,
+    [property: JsonPropertyName("title")] string? Title
+);

Jellyfin.Plugin.MediaCleaner/Models/SeriesInfo.cs

@@ -10,5 +10,7 @@ namespace Jellyfin.Plugin.MediaCleaner.Models;
 /// </summary>
 public class SeriesInfo : MediaInfo
 {
+    public Guid SeriesId { get; set; }
     public IEnumerable<string> Seasons { get; set; } = [];
+    public required string TvdbId { get; set; }
 }

Jellyfin.Plugin.MediaCleaner/Models/SonarrSeries.cs

@@ -0,0 +1,18 @@
+using System.Collections.Generic;
+using System.Text.Json.Serialization;
+
+namespace Jellyfin.Plugin.MediaCleaner.Models;
+
+public record SonarrSeries(
+    [property: JsonPropertyName("id")] int Id,
+    [property: JsonPropertyName("title")] string? Title,
+    [property: JsonPropertyName("seasons")] IReadOnlyList<Season> Seasons,
+    [property: JsonPropertyName("ended")] bool Ended,
+    [property: JsonPropertyName("tvdbId")] int TvdbId
+    // [property: JsonPropertyName("tmdbId")] int TmdbId,
+    // [property: JsonPropertyName("imdbId")] int ImdbId
+);
+
+public record Season(
+    [property: JsonPropertyName("seasonNumber")] int SeasonNumber
+);

Jellyfin.Plugin.MediaCleaner/Pages/configuration.html

@@ -47,6 +47,26 @@
                     </div>
                 </div>
 
+                <div class="inlineContainer">
+                    <div class="inputContainer">
+                        <label class="inputLabel inputLabelUnfocused" for="SonarrAnimeAddress">Sonarr Anime Address (http:port)</label>
+                        <input id="SonarrAnimeAddress" name="SonarrAnimeAddress" type="text" is="emby-input" />
+                        <div class="fieldDescription">The address and port of your sonarr instance.</div>
+                    </div>
+                    <div class="inputContainer">
+                        <label class="inputLabel inputLabelUnfocused" for="SonarrAnimeAPIKey">Sonarr Anime API Key</label>
+                        <input id="SonarrAnimeAPIKey" name="SonarrAnimeAPIKey" type="text" is="emby-input" />
+                        <div class="fieldDescription">The api key used by your sonarr instance</div>
+                    </div>
+                    <div class="inputContainer">
+                        <button id="SonarrAnimeTestConnectionButton" is="emby-button" type="button" class="raised button-submit block emby-button">
+                            <span>Test</span>
+                        </button>
+                        <div class="validation" id="SonarrAnimeConnectionValidation" hidden>
+                        </div>
+                    </div>
+                </div>
+
                 <h3>General Settings</h3>
                 <div class="inlineContainer">
                     <div class="inputContainer">

Jellyfin.Plugin.MediaCleaner/Pages/configuration.js

@@ -3,46 +3,6 @@ var MediaCleanerConfig = {
     pluginUniqueId: 'fef007a8-3e8f-4aa8-a22e-486a387f4192'
 };
 
-// Handlers
-document.querySelector('#RadarrTestConnectionButton')
-    .addEventListener('click', testConnectionRadarr);
-
-document.querySelector('#SonarrTestConnectionButton')
-    .addEventListener('click', testConnectionSonarr);
-
-document.querySelector('#MediaCleanerConfigPage')
-    .addEventListener('pageshow', function() {
-        Dashboard.showLoadingMsg();
-        ApiClient.getPluginConfiguration(MediaCleanerConfig.pluginUniqueId).then(function (config) {
-            document.querySelector('#RadarrAPIKey').value = config.RadarrAPIKey;
-            document.querySelector('#RadarrAddress').value = config.RadarrAddress;
-            document.querySelector('#SonarrAPIKey').value = config.SonarrAPIKey;
-            document.querySelector('#SonarrAddress').value = config.SonarrAddress;
-            document.querySelector('#StaleMediaCutoff').value = config.StaleMediaCutoff;
-            document.querySelector('#DebugMode').checked = config.DebugMode;
-            Dashboard.hideLoadingMsg();
-        });
-    });
-
-document.querySelector('#MediaCleanerConfigForm')
-    .addEventListener('submit', function(e) {
-    Dashboard.showLoadingMsg();
-    ApiClient.getPluginConfiguration(MediaCleanerConfig.pluginUniqueId).then(function (config) {
-        config.RadarrAPIKey = document.querySelector('#RadarrAPIKey').value;
-        config.RadarrAddress = document.querySelector('#RadarrAddress').value;
-        config.SonarrAPIKey = document.querySelector('#SonarrAPIKey').value;
-        config.SonarrAddress = document.querySelector('#SonarrAddress').value;
-        config.StaleMediaCutoff = document.querySelector('#StaleMediaCutoff').value;
-        config.DebugMode = document.querySelector('#DebugMode').checked;
-        ApiClient.updatePluginConfiguration(MediaCleanerConfig.pluginUniqueId, config).then(function (result) {
-            Dashboard.processPluginConfigurationUpdateResult(result);
-        });
-    });
-
-    e.preventDefault();
-    return false;
-});
-
 // Fades
 const startFadeOut = (element, interval = 100) => {
   const timer = setInterval(() => {
@@ -72,12 +32,20 @@ const startFadeIn = (element, interval = 100) => {
 };
 
 // Connection Methods
+const testConnectionSonarrAnime = async () => {
+    var apiKeyElement = document.getElementById('SonarrAnimeAPIKey');
+    var addressElement = document.getElementById('SonarrAnimeAddress');
+    var validationElement = document.getElementById('SonarrAnimeConnectionValidation');
+
+    await validateConnection(apiKeyElement, addressElement, validationElement, "sonarr");
+}
+
 const testConnectionSonarr = async () => {
     var apiKeyElement = document.getElementById('SonarrAPIKey');
     var addressElement = document.getElementById('SonarrAddress');
     var validationElement = document.getElementById('SonarrConnectionValidation');
 
-    await validateConnection(apiKeyElement, addressElement, validationElement);
+    await validateConnection(apiKeyElement, addressElement, validationElement, "sonarr");
 }
 
 const testConnectionRadarr = async () => {
@@ -85,10 +53,9 @@ const testConnectionRadarr = async () => {
     var addressElement = document.getElementById('RadarrAddress');
     var validationElement = document.getElementById('RadarrConnectionValidation');
 
-    await validateConnection(apiKeyElement, addressElement, validationElement);
+    await validateConnection(apiKeyElement, addressElement, validationElement, "radarr");
 }
 
-
 // Validation and Normalization
 const normalizeUrl = (url) => {
     let normalizedUrl = url.trim();
@@ -98,7 +65,7 @@ const normalizeUrl = (url) => {
     return normalizedUrl;
 };
 
-const validateConnection = async (apiKeyElement, addressElement, validationElement) => {
+const validateConnection = async (apiKeyElement, addressElement, validationElement, controller) => {
     var httpAddress = addressElement.value;
     var apiKey = apiKeyElement.value;
 
@@ -118,13 +85,19 @@ const validateConnection = async (apiKeyElement, addressElement, validationEleme
         setAttemptingConnection(validationElement);
         try{
             const url = normalizeUrl(httpAddress);
-            const response = await fetch(url, {
-                method: "GET",
+            // Move endpoint to a constant?
+            const response = await fetch(`/${controller}/testConnection`, {
+                method: "POST",
                 headers: {
-                    "X-Api-Key": apiKey,
-                }
+                    "Content-Type": "application/json"
+                },
+                body: JSON.stringify({ address: url, apiKey })
             });
-            success = response.ok;
+
+            if (response.ok) {
+                const result = await response.json();
+                success = result?.success === true;
+            }
         }
         catch (error){
             console.error(`Error: ${error}`);
@@ -159,3 +132,49 @@ const processValidationElement = (validationElement, success) => {
     setTimeout(() => startFadeOut(validationElement, 50), 2000);
 }
 
+// Handlers
+document.querySelector('#RadarrTestConnectionButton')
+    .addEventListener('click', testConnectionRadarr);
+
+document.querySelector('#SonarrTestConnectionButton')
+    .addEventListener('click', testConnectionSonarr);
+
+document.querySelector('#SonarrAnimeTestConnectionButton')
+    .addEventListener('click', testConnectionSonarrAnime);
+
+document.querySelector('#MediaCleanerConfigPage')
+    .addEventListener('pageshow', function() {
+        Dashboard.showLoadingMsg();
+        ApiClient.getPluginConfiguration(MediaCleanerConfig.pluginUniqueId).then(function (config) {
+            document.querySelector('#RadarrAPIKey').value = config.RadarrAPIKey;
+            document.querySelector('#RadarrAddress').value = config.RadarrAddress;
+            document.querySelector('#SonarrAPIKey').value = config.SonarrAPIKey;
+            document.querySelector('#SonarrAddress').value = config.SonarrAddress;
+            document.querySelector('#SonarrAnimeAPIKey').value = config.SonarrAnimeAPIKey;
+            document.querySelector('#SonarrAnimeAddress').value = config.SonarrAnimeAddress;
+            document.querySelector('#StaleMediaCutoff').value = config.StaleMediaCutoff;
+            document.querySelector('#DebugMode').checked = config.DebugMode;
+            Dashboard.hideLoadingMsg();
+        });
+    });
+
+document.querySelector('#MediaCleanerConfigForm')
+    .addEventListener('submit', function(e) {
+    Dashboard.showLoadingMsg();
+    ApiClient.getPluginConfiguration(MediaCleanerConfig.pluginUniqueId).then(function (config) {
+        config.RadarrAPIKey = document.querySelector('#RadarrAPIKey').value;
+        config.RadarrAddress = document.querySelector('#RadarrAddress').value;
+        config.SonarrAPIKey = document.querySelector('#SonarrAPIKey').value;
+        config.SonarrAddress = document.querySelector('#SonarrAddress').value;
+        config.SonarrAnimeAPIKey = document.querySelector('#SonarrAnimeAPIKey').value;
+        config.SonarrAnimeAddress = document.querySelector('#SonarrAnimeAddress').value;
+        config.StaleMediaCutoff = document.querySelector('#StaleMediaCutoff').value;
+        config.DebugMode = document.querySelector('#DebugMode').checked;
+        ApiClient.updatePluginConfiguration(MediaCleanerConfig.pluginUniqueId, config).then(function (result) {
+            Dashboard.processPluginConfigurationUpdateResult(result);
+        });
+    });
+
+    e.preventDefault();
+    return false;
+});

Jellyfin.Plugin.MediaCleaner/Pages/home.html

@@ -3,7 +3,7 @@
 	<div data-role="content">
 		<div class="content-primary">
             <link rel="stylesheet" href="/web/configurationpage?name=global.css" />
-            <div id="loading">Loading...</div>
+            <div id="loading">Loading... This may take some time whilst we scan your library and retrieve data from Radarr and Sonarr to accurately fill tables.</div>
             <div id="homepage" style="visibility: hidden;">
                 <button class="links" data-target="configurationpage?name=Configuration">Configuration</button>
                 <h2>Media Cleaner</h2>
@@ -18,6 +18,7 @@
                     </thead>
                     <tbody></tbody>
                 </table>
+                <button id="moviesDeleteButton" class="delete-button raised button-submit emby-button" style="visibility: hidden;">Delete</button>
                 <br>
 
                 <h3 id="seriesTitle"></h3>
@@ -31,6 +32,21 @@
                     </thead>
                     <tbody></tbody>
                 </table>
+                <button id="seriesDeleteButton" class="delete-button raised button-submit emby-button" style="visibility: hidden;">Delete</button>
+                <br>
+
+                <h3 id="animeSeriesTitle"></h3>
+                <table id="animeSeriesTable">
+                    <thead>
+                        <tr>
+                            <th>Name</th>
+                            <th>Seasons</th>
+                            <th></th>
+                        </tr>
+                    </thead>
+                    <tbody></tbody>
+                </table>
+                <button id="animeSeriesDeleteButton" class="delete-button raised button-submit emby-button" style="visibility: hidden;">Delete</button>
             </div>
 		</div>
 	</div>

Jellyfin.Plugin.MediaCleaner/Pages/home.js

@@ -1,25 +1,43 @@
 document.addEventListener('pageshow', async () => {
+    await refreshFrontEnd();
+});
+
+const refreshFrontEnd = async () => {
+    startLoading();
     await updateMediaCleanerState();
 
     var moviesTitle = document.getElementById("moviesTitle");
     var seriesTitle = document.getElementById("seriesTitle");
+    var animeSeriesTitle = document.getElementById("animeSeriesTitle");
 
     moviesTitle.innerHTML = await getMediaCleanerMoviesTitle();
     seriesTitle.innerHTML = await getMediaCleanerSeriesTitle();
+    animeSeriesTitle.innerHTML = await getMediaCleanerAnimeSeriesTitle();
 
     await populateTables();
     addClickHandlersToLinks();
+    addClickHandlersToDeleteButtons();
     finishLoading();
-});
+}
 
-const getMediaCleanerSeriesInfo = async () => {
-    const response = await fetch("/mediacleaner/state/getSeriesInfo");
+const getMediaCleanerTvSeriesInfo = async () => {
+    const response = await fetch("/mediacleaner/state/getTvSeriesInfo");
 
     if(!response.ok){
         throw new Error(`Response status: ${response.status}`)
     }
 
-    return response.json();
+    return await response.json();
+};
+
+const getMediaCleanerAnimeSeriesInfo = async () => {
+    const response = await fetch("/mediacleaner/state/getAnimeSeriesInfo");
+
+    if(!response.ok){
+        throw new Error(`Response status: ${response.status}`)
+    }
+
+    return await response.json();
 };
 
 const getMediaCleanerMovieInfo = async () => {
@@ -29,7 +47,7 @@ const getMediaCleanerMovieInfo = async () => {
         throw new Error(`Response status: ${response.status}`)
     }
 
-    return response.json();
+    return await response.json();
 };
 
 const updateMediaCleanerState = async () => {
@@ -38,6 +56,14 @@ const updateMediaCleanerState = async () => {
     if(!response.ok){
         throw new Error(`Response status: ${response.status}`)
     }
+};
+
+const getMediaCleanerAnimeSeriesTitle = async () => {
+    const response = await fetch("/mediacleaner/state/getAnimeSeriesTitle");
+
+    if(!response.ok){
+        throw new Error(`Response status: ${response.status}`);
+    }
 
     return response.json();
 };
@@ -62,10 +88,96 @@ const getMediaCleanerMoviesTitle = async () => {
     return response.json();
 };
 
-const selectedMovies = new Set();
-const selectedTvShows = new Set();
 
-const createCheckbox = (mediaInfo = {}, state = []) => {
+const populateTables = async () => {
+    var moviesInfo = await getMediaCleanerMovieInfo();
+    var seriesInfo = await getMediaCleanerTvSeriesInfo();
+    var animeSeriesInfo = await getMediaCleanerAnimeSeriesInfo();
+
+    var seriesTable = document.getElementById("seriesTable");
+    var moviesTable = document.getElementById("moviesTable");
+    var animeSeriesTable = document.getElementById("animeSeriesTable");
+
+    var seriesTableBody = seriesTable.getElementsByTagName('tbody')[0];
+    seriesTableBody.replaceChildren();
+    var seriesDeleteButton = document.getElementById('seriesDeleteButton');
+
+    var moviesTableBody = moviesTable.getElementsByTagName('tbody')[0];
+    moviesTableBody.replaceChildren();
+    var moviesDeleteButton = document.getElementById('moviesDeleteButton');
+
+    var animeSeriesTableBody = animeSeriesTable.getElementsByTagName('tbody')[0];
+    animeSeriesTableBody.replaceChildren();
+    var animeSeriesDeleteButton = document.getElementById('animeSeriesDeleteButton');
+
+    if (moviesInfo.length > 0){
+        for(let i = 0; i < moviesInfo.length; i++){
+            var row = moviesTableBody.insertRow(-1);
+            var cell1 = row.insertCell(0);
+            var cell2 = row.insertCell(1);
+            cell1.innerHTML = moviesInfo[i].Name;
+            cell1.className = "table-text";
+            cell2.appendChild(createCheckbox(moviesInfo[i], moviesTable, moviesDeleteButton));
+            cell2.className = "table-checkbox"
+        }
+    }
+    else{
+        var columnCount = moviesTable.tHead.rows[0].cells.length;
+        var row = moviesTableBody.insertRow(-1);
+        var cell1 = row.insertCell(0);
+        cell1.colSpan = columnCount;
+        cell1.innerHTML = "No stale movies found.";
+        cell1.className = "table-text";
+    }
+
+    if(seriesInfo.length > 0){
+        for(let i = 0; i < seriesInfo.length; i++){
+            var row = seriesTableBody.insertRow(-1);
+            var cell1 = row.insertCell(0);
+            var cell2 = row.insertCell(1);
+            var cell3 = row.insertCell(2);
+            cell1.innerHTML = seriesInfo[i].Name;
+            cell1.className = "table-text";
+            cell2.innerHTML = seriesInfo[i].Seasons.map(season => season).join(", ");
+            cell2.className = "table-text";
+            cell3.appendChild(createCheckbox(seriesInfo[i], seriesTable, seriesDeleteButton));
+            cell3.className = "table-checkbox"
+        }
+    }
+    else{
+        var columnCount = seriesTable.tHead.rows[0].cells.length;
+        var row = seriesTableBody.insertRow(-1);
+        var cell1 = row.insertCell(0);
+        cell1.colSpan = columnCount;
+        cell1.innerHTML = "No stale tv series found.";
+        cell1.className = "table-text";
+    }
+
+    if(animeSeriesInfo.length > 0){
+        for(let i = 0; i < animeSeriesInfo.length; i++){
+            var row = animeSeriesTableBody.insertRow(-1);
+            var cell1 = row.insertCell(0);
+            var cell2 = row.insertCell(1);
+            var cell3 = row.insertCell(2);
+            cell1.innerHTML = animeSeriesInfo[i].Name;
+            cell1.className = "table-text";
+            cell2.innerHTML = animeSeriesInfo[i].Seasons.map(season => season).join(", ");
+            cell2.className = "table-text";
+            cell3.appendChild(createCheckbox(animeSeriesInfo[i], animeSeriesTable, animeSeriesDeleteButton));
+            cell3.className = "table-checkbox"
+        }
+    }
+    else{
+        var columnCount = animeSeriesTable.tHead.rows[0].cells.length;
+        var row = animeSeriesTableBody.insertRow(-1);
+        var cell1 = row.insertCell(0);
+        cell1.colSpan = columnCount;
+        cell1.innerHTML = "No stale anime series found.";
+        cell1.className = "table-text";
+    }
+};
+
+const createCheckbox = (mediaInfo = {}, table, deleteButton) => {
     const container = document.createElement('div');
     container.className = 'checkboxContainer';
     container.style.marginBottom = 0;
@@ -87,78 +199,27 @@ const createCheckbox = (mediaInfo = {}, state = []) => {
     label.appendChild(span);
     container.appendChild(label);
 
-    // Remove dependency on local state. Move to scanning for all checked checkboxes and create the array at that point.
     checkbox.addEventListener('change', (e) => {
-        const mediaInfo = checkbox.dataset.mediaInfo || '(no info)';
-        if (checkbox.checked) {
-            state.add(mediaInfo);
-        } else {
-            state.delete(mediaInfo);
+        if(isDeleteButtonVisible(table)){
+            deleteButton.style.visibility = 'visible';
+        }
+        else {
+            deleteButton.style.visibility = 'hidden';
         }
-        // Update UI or state — use console.log for debugging
-        console.log('selected:', Array.from(state));
     });
 
     return container;
 };
 
-const populateTables = async () => {
-    var moviesInfo = await getMediaCleanerMovieInfo();
-    var seriesInfo = await getMediaCleanerSeriesInfo();
-
-    var seriesTableBody = seriesTable.getElementsByTagName('tbody')[0];
-    seriesTableBody.replaceChildren();
-
-    var moviesTableBody = moviesTable.getElementsByTagName('tbody')[0];
-    moviesTableBody.replaceChildren();
-
-    if (moviesInfo.length > 0){
-        for(let i = 0; i < moviesInfo.length; i++){
-            var row = moviesTableBody.insertRow(-1);
-            var cell1 = row.insertCell(0);
-            var cell2 = row.insertCell(1);
-            cell1.innerHTML = moviesInfo[i].Name;
-            cell1.className = "table-text";
-            cell2.appendChild(createCheckbox(moviesInfo[i], selectedMovies));
-            cell2.className = "table-checkbox"
+const isDeleteButtonVisible = (table) => {
+    const checkboxes = table.getElementsByClassName('emby-checkbox');
+    const hasChecked = Array.from(checkboxes).some(checkbox => checkbox.checked);
+    return hasChecked;
 }
-    }
-    else{
-        var columnCount = moviesTable.tHead.rows[0].cells.length;
-        var row = moviesTableBody.insertRow(-1);
-        var cell1 = row.insertCell(0);
-        cell1.colSpan = columnCount;
-        cell1.innerHTML = "No stale movies found.";
-        cell1.className = "table-text";
-    }
-
-    if(seriesInfo.length > 0){
-        for(let i = 0; i < seriesInfo.length; i++){
-            var row = seriesTableBody.insertRow(-1);
-            var cell1 = row.insertCell(0);
-            var cell2 = row.insertCell(1);
-            var cell3 = row.insertCell(2);
-            cell1.innerHTML = seriesInfo[i].Name;
-            cell1.className = "table-text";
-            cell2.innerHTML = seriesInfo[i].Seasons.map(season => season.replace("Season ", "")).join(", ");
-            cell2.className = "table-text";
-            cell3.appendChild(createCheckbox(seriesInfo[i], selectedTvShows));
-            cell3.className = "table-checkbox"
-        }
-    }
-    else{
-        var columnCount = seriesTable.tHead.rows[0].cells.length;
-        var row = seriesTableBody.insertRow(-1);
-        var cell1 = row.insertCell(0);
-        cell1.colSpan = columnCount;
-        cell1.innerHTML = "No stale series found.";
-        cell1.className = "table-text";
-    }
-};
 
 const addClickHandlersToLinks = () => {
-    const linkbtns = document.querySelectorAll("button.links")
-    linkbtns.forEach(btn => {
+    const linkBtns = document.querySelectorAll("button.links");
+    linkBtns.forEach(btn => {
         btn.addEventListener("click", () => {
             const target = btn.dataset.target;
             if (!target) return;
@@ -167,13 +228,98 @@ const addClickHandlersToLinks = () => {
     })
 }
 
+const addClickHandlersToDeleteButtons = () => {
+    const deleteMoviesButtonElement = document.getElementById("moviesDeleteButton");
+    const deleteSeriesButtonElement = document.getElementById("seriesDeleteButton");
+    const deleteAnimeSeriesButtonElement = document.getElementById("animeSeriesDeleteButton");
+    deleteMoviesButtonElement.addEventListener("click", deleteFromRadarr);
+    deleteSeriesButtonElement.addEventListener("click", deleteFromSonarr);
+    deleteAnimeSeriesButtonElement.addEventListener("click", deleteFromAnimeSonarr);
+}
+
+const getCheckedMedia = (table) => {
+    const checkboxes = table.getElementsByClassName('emby-checkbox');
+    const selectedMediaCheckboxes = Array.from(checkboxes).filter(checkbox => checkbox.checked);
+    const selectedMedia = selectedMediaCheckboxes.map(selectedMediaCheckbox => JSON.parse(selectedMediaCheckbox.dataset.mediaInfo));
+    console.log("Selected media: ", selectedMedia);
+    return selectedMedia;
+}
+
+const deleteMovieFromRadarrApi = async (movie) => {
+    const response = await fetch("/radarr/deleteMovieFromRadarr", {
+        method: "POST",
+        headers: {
+            'Content-Type': 'application/json'
+        },
+        body: JSON.stringify(movie)
+    });
+
+    if(!response.ok){
+        throw new Error(`Response status: ${response.status}`)
+    }
+}
+
+const deleteSeriesFromSonarrApi = async (series) => {
+    const response = await fetch("/sonarr/deleteSeriesFromSonarr", {
+        method: "POST",
+        headers: {
+            'Content-Type': 'application/json'
+        },
+        body: JSON.stringify(series)
+    });
+
+    if(!response.ok){
+        throw new Error(`Response status: ${response.status}`)
+    }
+}
+
+const deleteSeriesFromAnimeSonarrApi = async (series) => {
+    const response = await fetch("/sonarr/deleteSeriesFromAnimeSonarr", {
+        method: "POST",
+        headers: {
+            'Content-Type': 'application/json'
+        },
+        body: JSON.stringify(series)
+    });
+
+    if(!response.ok){
+        throw new Error(`Response status: ${response.status}`)
+    }
+}
+
+const deleteFromRadarr = async () => {
+    const selectedMovies = getCheckedMedia(moviesTable);
+    selectedMovies.forEach(async movie => await deleteMovieFromRadarrApi(movie));
+    refreshFrontEnd();
+}
+
+const deleteFromSonarr = () => {
+    const selectedSeries = getCheckedMedia(seriesTable);
+    selectedSeries.forEach(async series => await deleteSeriesFromSonarrApi(series));
+    refreshFrontEnd();
+}
+
+const deleteFromAnimeSonarr = () => {
+    const selectedSeries = getCheckedMedia(animeSeriesTable);
+    selectedSeries.forEach(async series => await deleteSeriesFromAnimeSonarrApi(series));
+    refreshFrontEnd();
+}
+
 const finishLoading = () => {
     const loadingElement = document.getElementById("loading");
-
     const homepage = document.getElementById("homepage");
     loadingElement.style.visibility = "hidden";
     homepage.style.visibility = "visible";
-
-    console.log("Loading element: ", loadingElement);
-    console.log("Homepage element: ", homepage);
+}
+
+const startLoading = () => {
+    const loadingElement = document.getElementById("loading");
+    const homepage = document.getElementById("homepage");
+    const moviesDeleteButton = document.getElementById('moviesDeleteButton');
+    const seriesDeleteButton = document.getElementById('seriesDeleteButton');
+
+    loadingElement.style.visibility = "visible";
+    homepage.style.visibility = "hidden";
+    moviesDeleteButton.style.visibility = "hidden";
+    seriesDeleteButton.style.visibility = "hidden";
 }

Jellyfin.Plugin.MediaCleaner/StaleMediaScanner.cs

@@ -84,7 +84,7 @@ public sealed class StaleMediaScanner
 
             foreach (SeriesInfo seriesInfo in staleSeriesInfo.Cast<SeriesInfo>())
             {
-                _loggingHelper.LogInformation("Series Info: ID: {Id} | Series Name: {SeriesName} | Stale Seasons: {Seasons}", [seriesInfo.Id, seriesInfo.Name, string.Join(", ", seriesInfo.Seasons)]);
+                _loggingHelper.LogInformation("Series Info: TmbdID: {Id} | Series Name: {SeriesName} | Stale Seasons: {Seasons}", [seriesInfo.TmdbId, seriesInfo.Name, string.Join(", ", seriesInfo.Seasons)]);
             }
         }
         else
@@ -99,15 +99,18 @@ public sealed class StaleMediaScanner
 
         if (staleMovies.Count > 0)
         {
-            staleMoviesInfo = staleMovies.Select(movie => new MovieInfo
+            staleMoviesInfo = staleMovies.Select(movie => {
+                movie.ProviderIds.TryGetValue("Tmdb", out string? tmdbId);
+                return new MovieInfo
                 {
-                Id = movie.Id,
+                    TmdbId = tmdbId ?? string.Empty,
                     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: TmdbID: {Id} | Movie Name: {MovieName}", [movieInfo.TmdbId, movieInfo.Name]);
             }
         }
         else
@@ -186,34 +189,6 @@ public sealed class StaleMediaScanner
 
         List<BaseItem> staleSeasons = [.. GetStaleSeasonsWithShortCircuitOnNonStaleSeason(seasons)];
 
-        // [ ..seasons
-        // .Where(season => {
-        //     var episodes = _libraryManager.GetItemList(new InternalItemsQuery
-        //     {
-        //         ParentId = season.Id,
-        //         Recursive = false
-        //     });
-
-        //     _loggingHelper.LogDebugInformation("Season debug information for {SeasonNumber}:", season);
-
-        //     bool isSeasonDataStale = false;
-
-        //     try
-        //     {
-        //         isSeasonDataStale = _seriesHelper.IsSeasonDataStale(episodes);
-        //     }
-        //     catch (ArgumentNullException ex)
-        //     {
-        //         _loggingHelper.LogInformation("Arguement Null Exception in GetStaleSeasons!");
-        //         _loggingHelper.LogInformation(ex.Message);
-        //     }
-
-        //     _loggingHelper.LogDebugInformation("End of season debug information for {SeasonNumber}.", season);
-
-        //     return isSeasonDataStale;
-        // })];
-
-
         _loggingHelper.LogDebugInformation("-------------------------------------------------");
         _loggingHelper.LogDebugInformation("End of scanning for series: {Series}", item);
 
@@ -231,11 +206,16 @@ public sealed class StaleMediaScanner
 
         IEnumerable<SeriesInfo> seriesInfoList = series.Select(series =>
         {
+            series.ProviderIds.TryGetValue("Tvdb", out string? tvdbId);
+            series.ProviderIds.TryGetValue("Tmdb", out string? tmdbId);
+
             return new SeriesInfo
             {
-                Id = series.Id,
+                SeriesId = series.Id,
+                TmdbId = tmdbId ?? string.Empty,
+                TvdbId = tvdbId ?? string.Empty,
                 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.Replace("Season ", "", StringComparison.OrdinalIgnoreCase))]
             };
         });
 

README.md

@@ -4,8 +4,9 @@ At the time of writing, the plugin is only capable of logging movies and shows t
 
 Planned features:
 - Better logging to show more than just the count. ✅
-- A page that shows what media is currently flagged for removal. And a button to confirm removal.
-- Integration with sonarr and radarr apis to delete your media.
+- A page that shows what media is currently flagged for removal. ✅
+- Checkboxes to select media for removal within Jellyfin. ✅
+- Integration with sonarr and radarr apis to delete your media. ✅
 - Whitelist for shows to ignore. (Seasonal shows)
 
 Future features if I feel like it: