// <copyright file="FfProbeKeyframeExtractor.cs" company="PlaceholderCompany">
// Copyright (c) PlaceholderCompany. All rights reserved.
// </copyright>

namespace Jellyfin.MediaEncoding.Keyframes.FfProbe;

using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Globalization;
using System.IO;

/// <summary>
/// FfProbe based keyframe extractor.
/// </summary>
public static class FfProbeKeyframeExtractor
{
    /// <summary>
    /// Extracts the keyframes using the ffprobe executable at the specified path.
    /// </summary>
    /// <param name="ffProbePath">The path to the ffprobe executable.</param>
    /// <param name="filePath">The file path.</param>
    /// <returns>An instance of <see cref="KeyframeData"/>.</returns>
    public static KeyframeData GetKeyframeData(string ffProbePath, string filePath)
    {
        using var process = new Process
        {
            StartInfo = new ProcessStartInfo
            {
                FileName = ffProbePath,
                Arguments = string.Format(
                    CultureInfo.InvariantCulture,
                    "-fflags +genpts -v error -skip_frame nokey -show_entries format=duration -show_entries stream=duration -show_entries packet=pts_time,flags -select_streams v -of csv \"{0}\"",
                    filePath),

                CreateNoWindow = true,
                UseShellExecute = false,
                RedirectStandardOutput = true,

                WindowStyle = ProcessWindowStyle.Hidden,
                ErrorDialog = false,
            },
            EnableRaisingEvents = true,
        };

        try
        {
            process.Start();
            try
            {
                process.PriorityClass = ProcessPriorityClass.BelowNormal;
            }
            catch (InvalidOperationException)
            {
                // Process may have already exited - ignore
            }
            catch (System.ComponentModel.Win32Exception)
            {
                // Priority setting may not be supported on this platform - ignore
            }

            return ParseStream(process.StandardOutput);
        }
        catch (Exception)
        {
            try
            {
                if (!process.HasExited)
                {
                    process.Kill();
                }
            }
            catch (InvalidOperationException)
            {
                // Process may have already exited - ignore
            }
            catch (System.ComponentModel.Win32Exception)
            {
                // Process termination may fail - ignore
            }

            throw;
        }
    }

    /// <summary>
    /// Parses the keyframe data from the FFProbe stream.
    /// </summary>
    /// <param name="reader">The stream reader containing FFProbe output.</param>
    /// <returns>The parsed keyframe data.</returns>
    internal static KeyframeData ParseStream(StreamReader reader)
    {
        var keyframes = new List<long>();
        double streamDuration = 0;
        double formatDuration = 0;

        while (!reader.EndOfStream)
        {
            var line = reader.ReadLine().AsSpan();
            if (line.IsEmpty)
            {
                continue;
            }

            var firstComma = line.IndexOf(',');
            var lineType = line[..firstComma];
            var rest = line[(firstComma + 1)..];
            if (lineType.Equals("packet", StringComparison.OrdinalIgnoreCase))
            {
                // Split time and flags from the packet line. Example line: packet,7169.079000,K_
                var secondComma = rest.IndexOf(',');
                var ptsTime = rest[..secondComma];
                var flags = rest[(secondComma + 1)..];
                if (flags.StartsWith("K_"))
                {
                    if (double.TryParse(ptsTime, NumberStyles.AllowDecimalPoint, CultureInfo.InvariantCulture, out var keyframe))
                    {
                        // Have to manually convert to ticks to avoid rounding errors as TimeSpan is only precise down to 1 ms when converting double.
                        keyframes.Add(Convert.ToInt64(keyframe * TimeSpan.TicksPerSecond));
                    }
                }
            }
            else if (lineType.Equals("stream", StringComparison.OrdinalIgnoreCase))
            {
                if (double.TryParse(rest, NumberStyles.AllowDecimalPoint, CultureInfo.InvariantCulture, out var streamDurationResult))
                {
                    streamDuration = streamDurationResult;
                }
            }
            else if (lineType.Equals("format", StringComparison.OrdinalIgnoreCase))
            {
                if (double.TryParse(rest, NumberStyles.AllowDecimalPoint, CultureInfo.InvariantCulture, out var formatDurationResult))
                {
                    formatDuration = formatDurationResult;
                }
            }
        }

        // Prefer the stream duration as it should be more accurate
        var duration = streamDuration > 0 ? streamDuration : formatDuration;

        return new KeyframeData(TimeSpan.FromSeconds(duration).Ticks, keyframes);
    }
}
