using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.ComponentModel;
using System.Data.Common;
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 Jellyfin.Plugin.MediaCleaner.Models;
using MediaBrowser.Controller.Entities;
using MediaBrowser.Controller.Library;
using MediaBrowser.Model.Tasks;
using Microsoft.Extensions.Logging;

namespace Jellyfin.Plugin.MediaCleaner.ScheduledTasks;

/// <summary>
/// A task to scan media for stale files.
/// </summary>
public sealed class StaleMediaTask : IScheduledTask
{
    private readonly ILogger _logger;
    private readonly IUserManager _userManager;
    private readonly ILibraryManager _libraryManager;

    /// <summary>
    /// Initializes a new instance of the <see cref="StaleMediaTask"/> class.
    /// </summary>
    /// <param name="logger">Logger.</param>
    /// <param name="userManager">User manager.</param>
    /// <param name="libraryManager">.</param>
    public StaleMediaTask(ILogger<StaleMediaTask> logger, IUserManager userManager, ILibraryManager libraryManager)
    {
        _logger = logger;
        _userManager = userManager;
        _libraryManager = libraryManager;
    }

    private static PluginConfiguration Configuration =>
            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)
    {
        if (Configuration.DebugMode)
        {
            _logger.LogInformation("--DEBUG MODE ACTIVE--");
        }

        _logger.LogInformation("-------------------------------------------------");
        _logger.LogInformation("Starting stale media scan...");

        var query = new InternalItemsQuery
        {
            IncludeItemTypes = [BaseItemKind.Movie, BaseItemKind.Series],
            Recursive = true
        };

        List<BaseItem> allItems = [.. _libraryManager.GetItemsResult(query).Items];

        _logger.LogInformation("Total stale items: {ItemCount}", allItems.Count);
        _logger.LogInformation("Stale items found: {AllItems}", allItems);

        List<BaseItem> series = [.. allItems.Where(item => item.GetBaseItemKind() == BaseItemKind.Series)];
        List<BaseItem> movies = [.. allItems.Where(item => item.GetBaseItemKind() == BaseItemKind.Movie)];

        List<BaseItem> staleEpisodes = [.. series.SelectMany(GetStaleEpisodes)];
        List<BaseItem> staleMovies = [.. GetStaleMovies(movies)];

        _logger.LogInformation("-------------------------------------------------");
        _logger.LogInformation("Stale Movies found: {StaleMovies}", staleMovies.Count);

        if (staleMovies.Count > 0 && Configuration.DebugMode)
        {
            foreach (var movieInfo in staleMovies)
            {
                _logger.LogInformation("Movie Info: ID: {Id} | Movie Name: {MovieName}", [movieInfo.Id, movieInfo.Name]);
            }
        }

        _logger.LogInformation("-------------------------------------------------");
        _logger.LogInformation("Stale Episodes found: {StaleEpisodes}", staleEpisodes.Count);

        if (staleEpisodes.Count > 0 && Configuration.DebugMode)
        {
            // Firstly figure out the seasons, and then the Series to find the name.
            List<SeriesInfo> seriesInfoList = FindSeriesInfoFromEpisodes(staleEpisodes);

            foreach (var seriesInfo in seriesInfoList)
            {
                _logger.LogInformation("Series Info: ID: {Id} | Series Name: {SeriesName} | Stale Seasons: {Seasons}", [seriesInfo.Id, seriesInfo.SeriesName, string.Join(", ", seriesInfo.Seasons)]);
            }
        }

        _logger.LogInformation("-------------------------------------------------");

        return Task.CompletedTask;
    }

    private List<BaseItem> GetStaleMovies(List<BaseItem> movies)
    {
        List<BaseItem> staleMovies = [];

        foreach (var movie in movies)
        {
            bool movieIsStale = movie.DateCreated < DateTime.Now.AddDays(-Configuration.StaleMediaCutoff);
            bool movieHasUserData = movie.UserData.Where(data => data.LastPlayedDate != null).ToList().Count > 0;
            if (movieHasUserData)
            {
                if (Configuration.DebugMode){
                    _logger.LogInformation("Movie has user data: {Movie}", movie);
                    _logger.LogInformation("-------------------------------------------------");
                }

                var mostRecentUserData = movie.UserData.OrderByDescending(data => data.LastPlayedDate).Where(data => data.LastPlayedDate != null).First();

                if (Configuration.DebugMode){
                    _logger.LogInformation("Most recent user data: {Movie}", movie);

                    foreach (var property in typeof(UserData).GetProperties())
                    {
                        _logger.LogInformation("{PropertyName}: {PropertyValue}", property.Name, property.GetValue(mostRecentUserData));
                    }
                    _logger.LogInformation("-------------------------------------------------");
                }

                if (mostRecentUserData.LastPlayedDate < DateTime.Now.AddDays(-Configuration.StaleMediaCutoff))
                {
                    if (Configuration.DebugMode)
                    {
                        _logger.LogInformation("Most recent user data last played date is outside of cutoff. Adding {Movie} to stale movies.", movie);
                    }
                    staleMovies.Add(movie);
                }
            }
            else if (movieIsStale)
            {
                if (Configuration.DebugMode)
                {
                    _logger.LogInformation("Movie has no user data and was created outside of cutoff: {DateCreated}", movie.DateCreated);
                }
                staleMovies.Add(movie);
            }
        }

        return staleMovies;
    }

    private List<SeriesInfo> FindSeriesInfoFromEpisodes(List<BaseItem> episodes)
    {
        Guid[] seasonIds = [.. episodes.Select(episode => episode.ParentId).Distinct()];

        var seasons = _libraryManager.GetItemList(new InternalItemsQuery
        {
            ItemIds = seasonIds
        });

        Guid[] seriesIds = [.. seasons.Select(season => season.ParentId).Distinct()];

        var series = _libraryManager.GetItemList(new InternalItemsQuery
        {
            ItemIds = seriesIds
        }).ToList();

        // Series Id, Series Name and Stale Seasons
        List<string> seriesNames = [.. series.Select(series => series.Name).Distinct()];

        List<SeriesInfo> seriesInfoList = [];

        series.ForEach(series =>
        {
            seriesInfoList.Add(new SeriesInfo
            {
                Id = series.Id,
                SeriesName = series.Name,
                Seasons = [.. seasons.Where(season => season.ParentId == series.Id).Select(season => season.Name)]
            });
        });

        return seriesInfoList;
    }

    private List<BaseItem> GetStaleEpisodes(BaseItem item)
    {
        List<BaseItem> staleEpisodes = [];

        // Gets each season in a show
        var seasons = _libraryManager.GetItemList(new InternalItemsQuery
        {
            ParentId = item.Id,
            Recursive = false
        });
        if (Configuration.DebugMode)
        {
            _logger.LogInformation("-------------------------------------------------");
            _logger.LogInformation("Debug data for {SeriesName}", item.Name);
            _logger.LogInformation("-------------------------------------------------");
        }

        int seasonNumber = 1;

        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 && Configuration.DebugMode)
            {
                _logger.LogInformation("Season {SeasonNumber} has user data.", [seasonNumber]);
                _logger.LogInformation("-------------------------------------------------");
            }

            bool seasonCanBeStale = episodes.All(episode => episode.DateCreated < DateTime.Now.AddDays(-Configuration.StaleMediaCutoff));
            if (seasonCanBeStale && Configuration.DebugMode)
            {
                _logger.LogInformation("All episodes were created outside of media cutoff, all episodes are eligible to be stale.");
            }

            if (seasonHasUserData)
            {
                var episodesWithUserData = episodes.Where(episode => episode.UserData.Where(data => data.LastPlayedDate != null).ToList().Count > 0).ToList();

                if(Configuration.DebugMode){
                    _logger.LogInformation("Episodes with user data: {EpisodesWithUserData}", episodesWithUserData);
                    _logger.LogInformation("-------------------------------------------------");
                }

                foreach (var episode in episodesWithUserData)
                {
                    var mostRecentUserData = episode.UserData.OrderByDescending(data => data.LastPlayedDate).Where(data => data.LastPlayedDate != null).First();
                    if(Configuration.DebugMode){
                        foreach (var property in typeof(UserData).GetProperties())
                        {
                            _logger.LogInformation("{PropertyName}: {PropertyValue}", property.Name, property.GetValue(mostRecentUserData));
                        }
                        _logger.LogInformation("-------------------------------------------------");
                    }
                    if (mostRecentUserData.LastPlayedDate < DateTime.Now.AddDays(-Configuration.StaleMediaCutoff))
                    {
                        if(Configuration.DebugMode){
                            _logger.LogInformation("Most recent user data has a last played date of: {LastPlayedDate}. Therefore all episodes are stale. Adding season to stale list.", mostRecentUserData.LastPlayedDate);
                            _logger.LogInformation("-------------------------------------------------");
                        }

                        staleEpisodes.AddRange(episodes);
                        break;
                    }
                }
            }
            // Check for episodes that have gone unwatched for stale media cutoff
            else if (seasonCanBeStale)
            {
                if(Configuration.DebugMode){
                    _logger.LogInformation("No user data, and creation date is outside of media cutoff, season is stale.");
                    _logger.LogInformation("-------------------------------------------------");
                }
                staleEpisodes.AddRange(episodes);
            }
            seasonNumber++;
        }

        return staleEpisodes;
    }

    IEnumerable<TaskTriggerInfo> IScheduledTask.GetDefaultTriggers()
    {
        // Run this task every 24 hours
        yield return new TaskTriggerInfo
        {
            Type = TaskTriggerInfoType.IntervalTrigger,
            IntervalTicks = TimeSpan.FromHours(24).Ticks
        };
    }
}