Working version

Services/ProcessRunner.cs

@@ -8,13 +8,16 @@ namespace AmigaDB.VideoRenderer.Services;
 
 public sealed partial class ProcessRunner
 {
+    public sealed record ProcessOutput(string Line, TimeSpan? Time, double? FramesPerSecond, double? Speed, int? Frame);
+
     public async Task<string> RunAsync(
         string executable,
         IEnumerable<string> arguments,
         Action<string>? log,
         Action<TimeSpan>? position,
         CancellationToken token,
-        bool allowFailure = false)
+        bool allowFailure = false,
+        Action<ProcessOutput>? outputHandler = null)
     {
         ProcessStartInfo start = new()
         {
@@ -33,8 +36,8 @@ public sealed partial class ProcessRunner
         StringBuilder output = new();
         process.Start();
 
-        Task stdout = PumpAsync(process.StandardOutput, output, log, position, token);
-        Task stderr = PumpAsync(process.StandardError, output, log, position, token);
+        Task stdout = PumpAsync(process.StandardOutput, output, log, position, token, outputHandler);
+        Task stderr = PumpAsync(process.StandardError, output, log, position, token, outputHandler);
         using CancellationTokenRegistration registration = token.Register(() =>
         {
             try { if (!process.HasExited) process.Kill(true); } catch { }
@@ -48,18 +51,97 @@ public sealed partial class ProcessRunner
 
     private static async Task PumpAsync(
         StreamReader reader, StringBuilder output, Action<string>? log,
-        Action<TimeSpan>? position, CancellationToken token)
+        Action<TimeSpan>? position, CancellationToken token, Action<ProcessOutput>? outputHandler)
     {
         while (await reader.ReadLineAsync(token) is { } line)
         {
             output.AppendLine(line);
-            log?.Invoke(line);
-            Match match = TimeRegex().Match(line);
-            if (match.Success && TimeSpan.TryParse(match.Groups[1].Value, CultureInfo.InvariantCulture, out TimeSpan time))
+            ProcessOutput parsed = ParseOutput(line);
+            if (!IsNoise(parsed))
+                log?.Invoke(line);
+            if (parsed.Time is { } time)
                 position?.Invoke(time);
+            outputHandler?.Invoke(parsed);
         }
     }
 
+    private static ProcessOutput ParseOutput(string line)
+    {
+        TimeSpan? time = null;
+        double? fps = null;
+        double? speed = null;
+        int? frame = null;
+
+        Match timeMatch = TimeRegex().Match(line);
+        if (timeMatch.Success && TimeSpan.TryParse(timeMatch.Groups[1].Value, CultureInfo.InvariantCulture, out TimeSpan parsedTime))
+            time = parsedTime;
+
+        Match frameMatch = FrameRegex().Match(line);
+        if (frameMatch.Success)
+        {
+            if (int.TryParse(frameMatch.Groups["frame"].Value, NumberStyles.Integer, CultureInfo.InvariantCulture, out int parsedFrame))
+                frame = parsedFrame;
+            if (double.TryParse(frameMatch.Groups["fps"].Value, NumberStyles.Float, CultureInfo.InvariantCulture, out double parsedFps))
+                fps = parsedFps;
+            if (double.TryParse(frameMatch.Groups["speed"].Value, NumberStyles.Float, CultureInfo.InvariantCulture, out double parsedSpeed))
+                speed = parsedSpeed;
+        }
+
+        return new ProcessOutput(line, time, fps, speed, frame);
+    }
+
+    private static bool IsNoise(ProcessOutput output)
+    {
+        if (output.Frame is not null || output.Time is not null)
+            return true;
+
+        string line = output.Line.TrimStart();
+        if (string.IsNullOrWhiteSpace(line))
+            return true;
+
+        if (line.StartsWith("ERROR:", StringComparison.OrdinalIgnoreCase)
+            || line.StartsWith("WARNING:", StringComparison.OrdinalIgnoreCase)
+            || line.Contains("selected.", StringComparison.OrdinalIgnoreCase)
+            || line.Contains("Falling back to FFmpeg from PATH", StringComparison.OrdinalIgnoreCase)
+            || line.Contains("skipped", StringComparison.OrdinalIgnoreCase)
+            || line.Contains("could not", StringComparison.OrdinalIgnoreCase)
+            || line.Contains("failed", StringComparison.OrdinalIgnoreCase)
+            || line.Contains("not found", StringComparison.OrdinalIgnoreCase)
+            || line.Contains("Output file is empty", StringComparison.OrdinalIgnoreCase))
+            return false;
+
+        return line.StartsWith("ffmpeg version ", StringComparison.OrdinalIgnoreCase)
+            || line.StartsWith("built with ", StringComparison.OrdinalIgnoreCase)
+            || line.StartsWith("configuration:", StringComparison.OrdinalIgnoreCase)
+            || line.StartsWith("libavutil", StringComparison.OrdinalIgnoreCase)
+            || line.StartsWith("libavcodec", StringComparison.OrdinalIgnoreCase)
+            || line.StartsWith("libavformat", StringComparison.OrdinalIgnoreCase)
+            || line.StartsWith("libavdevice", StringComparison.OrdinalIgnoreCase)
+            || line.StartsWith("libavfilter", StringComparison.OrdinalIgnoreCase)
+            || line.StartsWith("libswscale", StringComparison.OrdinalIgnoreCase)
+            || line.StartsWith("libswresample", StringComparison.OrdinalIgnoreCase)
+            || line.StartsWith("Input #", StringComparison.OrdinalIgnoreCase)
+            || line.StartsWith("Output #", StringComparison.OrdinalIgnoreCase)
+            || line.StartsWith("Stream mapping:", StringComparison.OrdinalIgnoreCase)
+            || line.StartsWith("Stream #", StringComparison.OrdinalIgnoreCase)
+            || line.StartsWith("Metadata:", StringComparison.OrdinalIgnoreCase)
+            || line.StartsWith("Side data:", StringComparison.OrdinalIgnoreCase)
+            || line.StartsWith("encoder         :", StringComparison.OrdinalIgnoreCase)
+            || line.StartsWith("title           :", StringComparison.OrdinalIgnoreCase)
+            || line.StartsWith("Press [q] to stop", StringComparison.OrdinalIgnoreCase)
+            || line.StartsWith("[", StringComparison.OrdinalIgnoreCase)
+            || line.StartsWith("Duration:", StringComparison.OrdinalIgnoreCase)
+            || line.StartsWith("video:", StringComparison.OrdinalIgnoreCase)
+            || line.StartsWith("audio:", StringComparison.OrdinalIgnoreCase)
+            || line.StartsWith("subtitle:", StringComparison.OrdinalIgnoreCase)
+            || line.StartsWith("other streams:", StringComparison.OrdinalIgnoreCase)
+            || line.StartsWith("global headers:", StringComparison.OrdinalIgnoreCase)
+            || line.StartsWith("muxing overhead:", StringComparison.OrdinalIgnoreCase);
+    }
+
     [GeneratedRegex(@"time=(\d{2}:\d{2}:\d{2}(?:\.\d+)?)", RegexOptions.CultureInvariant)]
     private static partial Regex TimeRegex();
+
+    [GeneratedRegex(@"frame=\s*(?<frame>\d+).*?fps=\s*(?<fps>\d+(?:\.\d+)?).*?speed=\s*(?<speed>\d+(?:\.\d+)?)x", RegexOptions.CultureInvariant)]
+    private static partial Regex FrameRegex();
 }