feat: implement Homebrew package manager and related process handling

Author: WolfBublitz

Directory.Packages.props

@@ -0,0 +1,19 @@
+<Project>
+  <PropertyGroup>
+    <ManagePackageVersionsCentrally>true</ManagePackageVersionsCentrally>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageVersion Include="Microsoft.Extensions.DependencyInjection" Version="10.0.0" />
+    <PackageVersion Include="ProcessX" Version="1.5.6" />
+    <PackageVersion Include="R3" Version="1.3.0" />
+    <PackageVersion Include="Spectre.Console" Version="0.54.0" />
+    <PackageVersion Include="System.CommandLine" Version="2.0.0" />
+    <PackageVersion Include="Tomlyn" Version="0.19.0" />
+
+    <PackageVersion Include="AwesomeAssertions" Version="9.3.0" />
+    <PackageVersion Include="AwesomeAssertions.Analyzers" Version="9.0.8" />
+    <PackageVersion Include="Microsoft.Testing.Platform" Version="2.0.2" />
+    <PackageVersion Include="Verify.MSTest" Version="31.7.1" />
+  </ItemGroup>
+</Project>

src/DevEnv.csproj

@@ -8,4 +8,8 @@
     <InvariantGlobalization>true</InvariantGlobalization>
   </PropertyGroup>
 
+  <ItemGroup>
+    <PackageReference Include="R3" />
+  </ItemGroup>
+
 </Project>

src/PackageManager/HomebrewPackageManager.cs

@@ -0,0 +1,37 @@
+using System;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace DevEnv;
+
+public sealed class HomebrewPackageManager : IPackageManager
+{
+    public string Name { get; } = "Homebrew";
+
+    public Task InstallPackageAsync(string packageName, CancellationToken cancellationToken)
+    {
+        Process process = new("brew", "install", packageName);
+
+        return process.ExecuteAsync(cancellationToken);
+    }
+
+    public Task UpdateAsync(CancellationToken cancellationToken)
+    {
+        Process process = new("brew", "update");
+
+        return process.ExecuteAsync(cancellationToken);
+    }
+    public async Task<bool> CheckIfPackageIsInstalledAsync(string packageName,CancellationToken cancellationToken)
+    {
+        Process processService = new("brew", "list", "--versions", packageName);
+
+        int exitCode = await processService.ExecuteAsync(cancellationToken).ConfigureAwait(false);
+    
+        return exitCode == 0;
+    }
+
+    public Task UpdatePackageAsync(string packageName, CancellationToken cancellationToken)
+    {
+        throw new NotImplementedException();
+    }
+}

src/PackageManager/IPackageManager.cs

@@ -0,0 +1,17 @@
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace DevEnv;
+
+public interface IPackageManager
+{
+    public string Name { get; }
+
+    public Task UpdateAsync(CancellationToken cancellationToken);
+
+    public Task UpdatePackageAsync(string packageName, CancellationToken cancellationToken);
+
+    public Task InstallPackageAsync(string packageName, CancellationToken cancellationToken);
+
+    public Task<bool> CheckIfPackageIsInstalledAsync(string packageName, CancellationToken cancellationToken);
+}

src/Process.cs

@@ -0,0 +1,64 @@
+using System.Diagnostics;
+using System.Threading;
+using System.Threading.Tasks;
+using R3;
+
+namespace DevEnv;
+
+public sealed class Process(string command, params string[] args)
+{
+    private readonly ReplaySubject<string> stdOut = new();
+
+    private readonly ReplaySubject<string> stdErr = new();
+
+    private readonly string command = command;
+
+    private readonly string[] args = args;
+
+    public Observable<string> StdOut => stdOut;
+
+    public Observable<string> StdErr => stdErr;
+
+    public async Task<int> ExecuteAsync(CancellationToken cancellationToken)
+    {
+        ProcessStartInfo processStartInfo = new()
+        {
+            FileName = command,
+            Arguments = string.Join(' ', args),
+            RedirectStandardOutput = true,
+            RedirectStandardError = true,
+            UseShellExecute = false,
+            CreateNoWindow = true,
+        };
+
+        using System.Diagnostics.Process process = new()
+        {
+            StartInfo = processStartInfo,
+        };
+
+        process.OutputDataReceived += (sender, e) =>
+        {
+            if (e.Data != null)
+            {
+                stdOut.OnNext(e.Data);
+            }
+        };
+
+        process.ErrorDataReceived += (sender, e) =>
+        {
+            if (e.Data != null)
+            {
+                stdErr.OnNext(e.Data);
+            }
+        };
+
+        process.Start();
+
+        process.BeginOutputReadLine();
+        process.BeginErrorReadLine();
+
+        await process.WaitForExitAsync(cancellationToken).ConfigureAwait(false);
+
+        return process.ExitCode;
+    }
+}