FFMpegCore.Test/FFProbeTests.cs

@@ -1,6 +1,4 @@
-using FFMpegCore.Exceptions;
+using FFMpegCore.Test.Resources;
-using FFMpegCore.Helpers;
-using FFMpegCore.Test.Resources;
 
 namespace FFMpegCore.Test;
 
@@ -287,68 +285,4 @@ public class FFProbeTests
         var info = FFProbe.Analyse(TestResources.Mp4Video, customArguments: "-headers \"Hello: World\"");
         Assert.AreEqual(3, info.Duration.Seconds);
     }
-
-    [TestMethod]
-    [Timeout(10000, CooperativeCancellation = true)]
-    public async Task Parallel_FFProbe_Cancellation_Should_Throw_Only_OperationCanceledException()
-    {
-        // Warm up FFMpegCore environment
-        FFProbeHelper.VerifyFFProbeExists(GlobalFFOptions.Current);
-
-        var mp4 = TestResources.Mp4Video;
-        if (!File.Exists(mp4))
-        {
-            Assert.Inconclusive($"Test video not found: {mp4}");
-            return;
-        }
-
-        using var cts = CancellationTokenSource.CreateLinkedTokenSource(TestContext.CancellationToken);
-        using var semaphore = new SemaphoreSlim(Environment.ProcessorCount, Environment.ProcessorCount);
-        var tasks = Enumerable.Range(0, 50).Select(x => Task.Run(async () =>
-        {
-            await semaphore.WaitAsync(cts.Token);
-            try
-            {
-                var analysis = await FFProbe.AnalyseAsync(mp4, cancellationToken: cts.Token);
-                return analysis;
-            }
-            finally
-            {
-                semaphore.Release();
-            }
-        }, cts.Token)).ToList();
-
-        // Wait for 2 tasks to finish, then cancel all
-        await Task.WhenAny(tasks);
-        await Task.WhenAny(tasks);
-        await cts.CancelAsync();
-
-        var exceptions = new List<Exception>();
-        foreach (var task in tasks)
-        {
-            try
-            {
-                await task;
-            }
-            catch (Exception e)
-            {
-                exceptions.Add(e);
-            }
-        }
-
-        Assert.IsNotEmpty(exceptions, "No exceptions were thrown on cancellation. Test was useless. " +
-                                      ".Try adjust cancellation timings to make cancellation at the moment, when ffprobe is still running.");
-
-        // Check that all exceptions are OperationCanceledException
-        CollectionAssert.AllItemsAreInstancesOfType(exceptions, typeof(OperationCanceledException));
-    }
-
-    [TestMethod]
-    [Timeout(10000, CooperativeCancellation = true)]
-    public async Task FFProbe_Should_Throw_FFMpegException_When_Exits_With_Non_Zero_Code()
-    {
-        var input = TestResources.SrtSubtitle; //non media file
-        await Assert.ThrowsAsync<FFMpegException>(async () => await FFProbe.AnalyseAsync(input,
-            cancellationToken: TestContext.CancellationToken, customArguments: "--some-invalid-argument"));
-    }
 }

FFMpegCore.Test/VideoTest.cs

@@ -82,40 +82,6 @@ public class VideoTest
         Assert.IsTrue(success);
     }
 
-    [TestMethod]
-    [Timeout(BaseTimeoutMilliseconds, CooperativeCancellation = true)]
-    public async Task Video_MetadataBuilder()
-    {
-        using var outputFile = new TemporaryFile($"out{VideoType.Mp4.Extension}");
-
-        await FFMpegArguments
-            .FromFileInput(TestResources.WebmVideo)
-            .AddMetaData(FFMetadataBuilder.Empty()
-                .WithTag("title", "noname")
-                .WithTag("artist", "unknown")
-                .WithChapter("Chapter 1", 1.1)
-                .WithChapter("Chapter 2", 1.23))
-            .OutputToFile(outputFile, false, opt => opt
-                .WithVideoCodec(VideoCodec.LibX264))
-            .CancellableThrough(TestContext.CancellationToken)
-            .ProcessAsynchronously();
-
-        var analysis = await FFProbe.AnalyseAsync(outputFile, cancellationToken: TestContext.CancellationToken);
-        Assert.IsTrue(analysis.Format.Tags!.TryGetValue("title", out var title));
-        Assert.IsTrue(analysis.Format.Tags!.TryGetValue("artist", out var artist));
-        Assert.AreEqual("noname", title);
-        Assert.AreEqual("unknown", artist);
-
-        Assert.HasCount(2, analysis.Chapters);
-        Assert.AreEqual("Chapter 1", analysis.Chapters.First().Title);
-        Assert.AreEqual(1.1, analysis.Chapters.First().Duration.TotalSeconds);
-        Assert.AreEqual(1.1, analysis.Chapters.First().End.TotalSeconds);
-
-        Assert.AreEqual("Chapter 2", analysis.Chapters.Last().Title);
-        Assert.AreEqual(1.23, analysis.Chapters.Last().Duration.TotalSeconds);
-        Assert.AreEqual(1.1 + 1.23, analysis.Chapters.Last().End.TotalSeconds);
-    }
-
     [TestMethod]
     [Timeout(BaseTimeoutMilliseconds, CooperativeCancellation = true)]
     public void Video_ToH265_MKV_Args()
@@ -1052,7 +1018,7 @@ public class VideoTest
     {
         using var outputFile = new TemporaryFile("out.mp4");
 
-        using var cts = CancellationTokenSource.CreateLinkedTokenSource(TestContext.CancellationToken);
+        var cts = new CancellationTokenSource();
 
         var task = FFMpegArguments
             .FromFileInput("testsrc2=size=320x240[out0]; sine[out1]", false, args => args
@@ -1063,6 +1029,7 @@ public class VideoTest
                 .WithVideoCodec(VideoCodec.LibX264)
                 .WithSpeedPreset(Speed.VeryFast))
             .CancellableThrough(cts.Token)
+            .CancellableThrough(TestContext.CancellationToken)
             .ProcessAsynchronously(false);
 
         cts.CancelAfter(300);
@@ -1078,7 +1045,7 @@ public class VideoTest
     {
         using var outputFile = new TemporaryFile("out.mp4");
 
-        using var cts = CancellationTokenSource.CreateLinkedTokenSource(TestContext.CancellationToken);
+        var cts = new CancellationTokenSource();
 
         var task = FFMpegArguments
             .FromFileInput("testsrc2=size=320x240[out0]; sine[out1]", false, args => args
@@ -1089,6 +1056,7 @@ public class VideoTest
                 .WithVideoCodec(VideoCodec.LibX264)
                 .WithSpeedPreset(Speed.VeryFast))
             .CancellableThrough(cts.Token)
+            .CancellableThrough(TestContext.CancellationToken)
             .ProcessAsynchronously();
 
         cts.CancelAfter(300);
@@ -1102,7 +1070,7 @@ public class VideoTest
     {
         using var outputFile = new TemporaryFile("out.mp4");
 
-        using var cts = CancellationTokenSource.CreateLinkedTokenSource(TestContext.CancellationToken);
+        var cts = new CancellationTokenSource();
 
         var task = FFMpegArguments
             .FromFileInput("testsrc2=size=320x240[out0]; sine[out1]", false, args => args
@@ -1126,7 +1094,7 @@ public class VideoTest
     {
         using var outputFile = new TemporaryFile("out.mp4");
 
-        using var cts = CancellationTokenSource.CreateLinkedTokenSource(TestContext.CancellationToken);
+        var cts = new CancellationTokenSource();
 
         cts.Cancel();
         var task = FFMpegArguments
@@ -1149,7 +1117,7 @@ public class VideoTest
     {
         using var outputFile = new TemporaryFile("out.mp4");
 
-        using var cts = CancellationTokenSource.CreateLinkedTokenSource(TestContext.CancellationToken);
+        var cts = new CancellationTokenSource();
 
         var task = FFMpegArguments
             .FromFileInput("testsrc2=size=320x240[out0]; sine[out1]", false, args => args

FFMpegCore/FFMetadataInputArgument.cs

@@ -1,62 +0,0 @@
-using System.Text;
-
-namespace FFMpegCore;
-
-public class FFMetadataBuilder
-{
-    private Dictionary<string, string> Tags { get; } = new();
-    private List<FFMetadataChapter> Chapters { get; } = [];
-
-    public static FFMetadataBuilder Empty()
-    {
-        return new FFMetadataBuilder();
-    }
-
-    public FFMetadataBuilder WithTag(string key, string value)
-    {
-        Tags.Add(key, value);
-        return this;
-    }
-
-    public FFMetadataBuilder WithChapter(string title, long durationMs)
-    {
-        Chapters.Add(new FFMetadataChapter(title, durationMs));
-        return this;
-    }
-
-    public FFMetadataBuilder WithChapter(string title, double durationSeconds)
-    {
-        Chapters.Add(new FFMetadataChapter(title, Convert.ToInt64(durationSeconds * 1000)));
-        return this;
-    }
-
-    public string GetMetadataFileContent()
-    {
-        var sb = new StringBuilder();
-        sb.AppendLine(";FFMETADATA1");
-
-        foreach (var tag in Tags)
-        {
-            sb.AppendLine($"{tag.Key}={tag.Value}");
-        }
-
-        long totalDurationMs = 0;
-        foreach (var chapter in Chapters)
-        {
-            sb.AppendLine("[CHAPTER]");
-            sb.AppendLine("TIMEBASE=1/1000");
-            sb.AppendLine($"START={totalDurationMs}");
-            sb.AppendLine($"END={totalDurationMs + chapter.DurationMs}");
-            sb.AppendLine($"title={chapter.Title}");
-            totalDurationMs += chapter.DurationMs;
-        }
-
-        return sb.ToString();
-    }
-
-    private class FFMetadataChapter(string title, long durationMs)
-    {
-        public string Title { get; } = title;
-        public long DurationMs { get; } = durationMs;
-    }
-}

FFMpegCore/FFMpeg/FFMpegArguments.cs

@@ -109,11 +109,6 @@ public sealed class FFMpegArguments : FFMpegArgumentsBase
         return WithInput(new MetaDataArgument(content), addArguments);
     }
 
-    public FFMpegArguments AddMetaData(FFMetadataBuilder metaDataBuilder, Action<FFMpegArgumentOptions>? addArguments = null)
-    {
-        return WithInput(new MetaDataArgument(metaDataBuilder.GetMetadataFileContent()), addArguments);
-    }
-
     public FFMpegArguments AddMetaData(IReadOnlyMetaData metaData, Action<FFMpegArgumentOptions>? addArguments = null)
     {
         return WithInput(new MetaDataArgument(MetaDataSerializer.Instance.Serialize(metaData)), addArguments);

FFMpegCore/FFMpegCore.csproj

@@ -3,14 +3,13 @@
   <PropertyGroup>
     <IsPackable>true</IsPackable>
     <Description>A .NET Standard FFMpeg/FFProbe wrapper for easily integrating media analysis and conversion into your .NET applications</Description>
-    <PackageVersion>5.4.0</PackageVersion>
+    <PackageVersion>5.3.0</PackageVersion>
     <PackageOutputPath>../nupkg</PackageOutputPath>
     <PackageReleaseNotes>
-      - Fixed exception thrown on cancelling ffprobe analysis - by snechaev
+      - **Fixed race condition on Named pipe dispose/disconnect** by techtel-pstevens
-      - Added FFMetadataBuilder - by rosenbjerg
+      - **More extensions for snapshot function(jpg, bmp, webp)** by GorobVictor
-      - Fix JoinImageSequence by passing framerate argument to input as well as output - by rosenbjerg
+      - **Include more GUID characters in pipe path** by reima, rosenbjerg
-      - Change fps input from int to double - by rosenbjerg
+      - **Updated dependencies and minor cleanup**: by rosenbjerg
-      - Fix GetCreationTime method on ITagsContainer - by rosenbjerg
     </PackageReleaseNotes>
     <PackageTags>ffmpeg ffprobe convert video audio mediafile resize analyze muxing</PackageTags>
     <Authors>Malte Rosenbjerg, Vlad Jerca, Max Bagryantsev</Authors>

FFMpegCore/FFProbe/FFProbe.cs

@@ -84,7 +84,6 @@ public static class FFProbe
 
         var instance = PrepareStreamAnalysisInstance(filePath, ffOptions ?? GlobalFFOptions.Current, customArguments);
         var result = await instance.StartAndWaitForExitAsync(cancellationToken).ConfigureAwait(false);
-        cancellationToken.ThrowIfCancellationRequested();
         ThrowIfExitCodeNotZero(result);
 
         return ParseOutput(result);
@@ -124,7 +123,6 @@ public static class FFProbe
     {
         var instance = PrepareStreamAnalysisInstance(uri.AbsoluteUri, ffOptions ?? GlobalFFOptions.Current, customArguments);
         var result = await instance.StartAndWaitForExitAsync(cancellationToken).ConfigureAwait(false);
-        cancellationToken.ThrowIfCancellationRequested();
         ThrowIfExitCodeNotZero(result);
 
         return ParseOutput(result);
@@ -152,7 +150,6 @@ public static class FFProbe
         }
 
         var result = await task.ConfigureAwait(false);
-        cancellationToken.ThrowIfCancellationRequested();
         ThrowIfExitCodeNotZero(result);
 
         pipeArgument.Post();

FFMpegCore/FFProbe/ProcessArgumentsExtensions.cs

@@ -13,6 +13,6 @@ public static class ProcessArgumentsExtensions
     public static async Task<IProcessResult> StartAndWaitForExitAsync(this ProcessArguments processArguments, CancellationToken cancellationToken = default)
     {
         using var instance = processArguments.Start();
-        return await instance.WaitForExitAsync(cancellationToken).ConfigureAwait(false);
+        return await instance.WaitForExitAsync(cancellationToken);
     }
 }