// Licensed to the .NET Foundation under one or more agreements.
// The .NET Foundation licenses this file to you under the MIT license.
 
using Aspire.Hosting.Dcp.Process;
 
namespace Aspire.Hosting.Tests.Pipelines;
 
internal sealed class PipelineOutputTestProcessRunner(Func<IReadOnlyList<string>, ProcessCaptureResult> capture) : IProcessRunner
{
    internal List<IReadOnlyList<string>> Calls { get; } = [];
    internal List<byte[]> Inputs { get; } = [];
 
    public (Task<ProcessResult>, IAsyncDisposable) Run(ProcessSpec processSpec) => throw new NotSupportedException();
 
    public Task<ProcessCaptureResult> RunAndCaptureTextAsync(string executablePath, IReadOnlyList<string> arguments,
        string workingDirectory, IReadOnlyDictionary<string, string>? environmentVariables = null,
        ReadOnlyMemory<byte> standardInput = default, CancellationToken cancellationToken = default)
    {
        cancellationToken.ThrowIfCancellationRequested();
        Calls.Add(arguments.ToArray());
        Inputs.Add(standardInput.ToArray());
        Assert.Equal("0", environmentVariables!["GIT_OPTIONAL_LOCKS"]);
        return Task.FromResult(capture(arguments));
    }
}