using System.Collections.Concurrent;

namespace Flaro.Api;

/// <summary>Was gerade läuft, je Gerät.</summary>
///
/// <remarks>
/// <para>
/// <b>Im Arbeitsspeicher, nicht in der Datenbank.</b> „Wer schaut gerade
/// was" ist eine Frage über den Augenblick; sie zu speichern hiesse, nach
/// einem Neustart Wiedergaben anzuzeigen, die es nicht mehr gibt. Fällt der
/// Container aus, ist die Antwort ohnehin „niemand".
/// </para>
/// <para>
/// <b>Abgeleitet aus den Fortschrittsmeldungen, nicht aus einer eigenen
/// Anmeldung am Spieler.</b> Jeder Client meldet beim Abspielen ohnehin alle
/// paar Sekunden, wo er steht — wer das als Lebenszeichen liest, braucht
/// kein zweites Verfahren, das ein Client vergessen könnte. Bleibt die
/// Meldung aus, läuft der Eintrag von selbst ab.
/// </para>
/// </remarks>
public sealed class PlaybackSessions(TimeProvider clock)
{
    /// <summary>Wie lange eine Wiedergabe ohne Meldung als laufend gilt.</summary>
    ///
    /// <remarks>
    /// Die Clients melden alle zehn Sekunden. Eine Minute lässt Raum für
    /// einen Aussetzer, ohne dass eine längst beendete Wiedergabe noch
    /// minutenlang im Dashboard steht.
    /// </remarks>
    public static readonly TimeSpan Lebensdauer = TimeSpan.FromMinutes(1);

    private readonly ConcurrentDictionary<string, Wiedergabe> _laufend = new();

    public sealed record Wiedergabe(
        string DeviceKey,
        Guid UserId,
        string UserName,
        Guid ItemId,
        string Title,
        string? SubTitle,
        string? PosterImage,
        TimeSpan Position,
        TimeSpan? Runtime,
        string DeviceName,
        DateTimeOffset LastSeenAt);

    /// <summary>Hält fest, dass dieses Gerät gerade etwas abspielt.</summary>
    public void Melden(Wiedergabe wiedergabe) =>
        _laufend[wiedergabe.DeviceKey] = wiedergabe;

    /// <summary>Nimmt eine Wiedergabe heraus — beim Beenden.</summary>
    public void Beenden(string deviceKey) => _laufend.TryRemove(deviceKey, out _);

    /// <summary>Was gerade läuft. Abgelaufenes fällt dabei heraus.</summary>
    public IReadOnlyList<Wiedergabe> Laufende()
    {
        var grenze = clock.GetUtcNow() - Lebensdauer;

        // Beiläufig aufräumen. Ein eigener Hintergrunddienst für eine
        // Handvoll Einträge wäre Aufwand ohne Gegenwert.
        foreach (var (schluessel, eintrag) in _laufend)
        {
            if (eintrag.LastSeenAt < grenze) _laufend.TryRemove(schluessel, out _);
        }

        return _laufend.Values.OrderBy(w => w.UserName).ThenBy(w => w.Title).ToList();
    }
}