From e0ebe16f3e5eae36bf7595c4c166233b266a016d Mon Sep 17 00:00:00 2001
From: Jason Dove <1695733+jasongdove@users.noreply.github.com>
Date: Mon, 16 Feb 2026 12:37:23 -0600
Subject: [PATCH] pass cancellation token

---
 .../Metadata/LocalStatisticsProvider.cs       | 24 +++++++++++--------
 1 file changed, 14 insertions(+), 10 deletions(-)

diff --git a/ErsatzTV.Infrastructure/Metadata/LocalStatisticsProvider.cs b/ErsatzTV.Infrastructure/Metadata/LocalStatisticsProvider.cs
index 7b67de330..3ebbc2914 100644
--- a/ErsatzTV.Infrastructure/Metadata/LocalStatisticsProvider.cs
+++ b/ErsatzTV.Infrastructure/Metadata/LocalStatisticsProvider.cs
@@ -189,7 +189,7 @@ public partial class LocalStatisticsProvider : ILocalStatisticsProvider
         try
         {
             string filePath = await PathForMediaItem(mediaItem);
-            return await GetProfileCount(ffmpegPath, filePath);
+            return await GetProfileCount(ffmpegPath, filePath, cancellationToken);
         }
         catch (Exception ex)
         {
@@ -354,7 +354,10 @@ public partial class LocalStatisticsProvider : ILocalStatisticsProvider
         return stats;
     }
 
-    private async Task<Option<int>> GetProfileCount(string ffmpegPath, string filePath)
+    private async Task<Option<int>> GetProfileCount(
+        string ffmpegPath,
+        string filePath,
+        CancellationToken cancellationToken)
     {
         string[] arguments =
         [
@@ -370,15 +373,16 @@ public partial class LocalStatisticsProvider : ILocalStatisticsProvider
         CommandResult traceHeaders = await Cli.Wrap(ffmpegPath)
             .WithArguments(arguments)
             .WithValidation(CommandResultValidation.None)
-            .WithStandardErrorPipe(PipeTarget.ToDelegate(line =>
-            {
-                int idx = line.IndexOf("profile_idc", StringComparison.Ordinal);
-                if (idx >= 0)
+            .WithStandardErrorPipe(
+                PipeTarget.ToDelegate(line =>
                 {
-                    uniqueProfiles.Add(line[idx..]);
-                }
-            }))
-            .ExecuteAsync();
+                    int idx = line.IndexOf("profile_idc", StringComparison.Ordinal);
+                    if (idx >= 0)
+                    {
+                        uniqueProfiles.Add(line[idx..]);
+                    }
+                }))
+            .ExecuteAsync(cancellationToken);
 
         if (traceHeaders.ExitCode != 0)
         {