chore: add MutagenSdk project (#48)

Contains a gRPC client for mutagen's synchronization API.

All required .proto files are vendored using a new script
`Update-Proto.ps1`, which finds all required files by scanning `import`
directives.

The vendored files are modified to add `csharp_namespace` and a MIT
license header from mutagen.

Example usage:
```cs
using var client = new MutagenClient(@"C:\Users\dean\.mutagen");
var res = await client.Synchronization.ListAsync(new ListRequest
{
    Selection = new Selection
    {
        All = true,
    },
});

foreach (var state in res.SessionStates)
    Console.WriteLine(state);
```

Closes coder/internal#378

Author: deansheather

.gitattributes

@@ -0,0 +1 @@
+MutagenSdk/Proto/**/*.proto linguist-generated=true

Coder.Desktop.sln

@@ -23,6 +23,8 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Vpn.DebugClient", "Vpn.Debu
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Installer", "Installer\Installer.csproj", "{39F5B55A-09D8-477D-A3FA-ADAC29C52605}"
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "MutagenSdk", "MutagenSdk\MutagenSdk.csproj", "{E2477ADC-03DA-490D-9369-79A4CC4A58D2}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -203,6 +205,22 @@ Global
 		{39F5B55A-09D8-477D-A3FA-ADAC29C52605}.Release|x64.Build.0 = Release|Any CPU
 		{39F5B55A-09D8-477D-A3FA-ADAC29C52605}.Release|x86.ActiveCfg = Release|Any CPU
 		{39F5B55A-09D8-477D-A3FA-ADAC29C52605}.Release|x86.Build.0 = Release|Any CPU
+		{E2477ADC-03DA-490D-9369-79A4CC4A58D2}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{E2477ADC-03DA-490D-9369-79A4CC4A58D2}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{E2477ADC-03DA-490D-9369-79A4CC4A58D2}.Debug|ARM64.ActiveCfg = Debug|Any CPU
+		{E2477ADC-03DA-490D-9369-79A4CC4A58D2}.Debug|ARM64.Build.0 = Debug|Any CPU
+		{E2477ADC-03DA-490D-9369-79A4CC4A58D2}.Debug|x64.ActiveCfg = Debug|Any CPU
+		{E2477ADC-03DA-490D-9369-79A4CC4A58D2}.Debug|x64.Build.0 = Debug|Any CPU
+		{E2477ADC-03DA-490D-9369-79A4CC4A58D2}.Debug|x86.ActiveCfg = Debug|Any CPU
+		{E2477ADC-03DA-490D-9369-79A4CC4A58D2}.Debug|x86.Build.0 = Debug|Any CPU
+		{E2477ADC-03DA-490D-9369-79A4CC4A58D2}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{E2477ADC-03DA-490D-9369-79A4CC4A58D2}.Release|Any CPU.Build.0 = Release|Any CPU
+		{E2477ADC-03DA-490D-9369-79A4CC4A58D2}.Release|ARM64.ActiveCfg = Release|Any CPU
+		{E2477ADC-03DA-490D-9369-79A4CC4A58D2}.Release|ARM64.Build.0 = Release|Any CPU
+		{E2477ADC-03DA-490D-9369-79A4CC4A58D2}.Release|x64.ActiveCfg = Release|Any CPU
+		{E2477ADC-03DA-490D-9369-79A4CC4A58D2}.Release|x64.Build.0 = Release|Any CPU
+		{E2477ADC-03DA-490D-9369-79A4CC4A58D2}.Release|x86.ActiveCfg = Release|Any CPU
+		{E2477ADC-03DA-490D-9369-79A4CC4A58D2}.Release|x86.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE

MutagenSdk/MutagenClient.cs

@@ -0,0 +1,55 @@
+using Coder.Desktop.MutagenSdk.Proto.Service.Synchronization;
+using Grpc.Core;
+using Grpc.Net.Client;
+
+namespace Coder.Desktop.MutagenSdk;
+
+public class MutagenClient : IDisposable
+{
+    private readonly GrpcChannel _channel;
+
+    public readonly Synchronization.SynchronizationClient Synchronization;
+
+    public MutagenClient(string dataDir)
+    {
+        // Check for the lock file first, since it should exist if it's running.
+        var daemonLockFile = Path.Combine(dataDir, "daemon", "daemon.lock");
+        if (!File.Exists(daemonLockFile))
+            throw new FileNotFoundException(
+                "Mutagen daemon lock file not found, did the mutagen daemon start successfully?", daemonLockFile);
+
+        // Read the IPC named pipe address from the sock file.
+        var daemonSockFile = Path.Combine(dataDir, "daemon", "daemon.sock");
+        if (!File.Exists(daemonSockFile))
+            throw new FileNotFoundException(
+                "Mutagen daemon socket file not found, did the mutagen daemon start successfully?", daemonSockFile);
+        var daemonSockAddress = File.ReadAllText(daemonSockFile).Trim();
+        if (string.IsNullOrWhiteSpace(daemonSockAddress))
+            throw new InvalidOperationException(
+                "Mutagen daemon socket address is empty, did the mutagen daemon start successfully?");
+
+        const string namedPipePrefix = @"\\.\pipe\";
+        if (!daemonSockAddress.StartsWith(namedPipePrefix))
+            throw new InvalidOperationException("Mutagen daemon socket address is not a named pipe address");
+        var pipeName = daemonSockAddress[namedPipePrefix.Length..];
+
+        var connectionFactory = new NamedPipesConnectionFactory(pipeName);
+        var socketsHttpHandler = new SocketsHttpHandler
+        {
+            ConnectCallback = connectionFactory.ConnectAsync,
+        };
+
+        _channel = GrpcChannel.ForAddress("http://localhost", new GrpcChannelOptions
+        {
+            Credentials = ChannelCredentials.Insecure,
+            HttpHandler = socketsHttpHandler,
+        });
+        Synchronization = new Synchronization.SynchronizationClient(_channel);
+    }
+
+    public void Dispose()
+    {
+        _channel.Dispose();
+        GC.SuppressFinalize(this);
+    }
+}

MutagenSdk/MutagenSdk.csproj

@@ -0,0 +1,25 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+    <PropertyGroup>
+        <AssemblyName>Coder.Desktop.MutagenSdk</AssemblyName>
+        <RootNamespace>Coder.Desktop.MutagenSdk</RootNamespace>
+        <TargetFramework>net8.0</TargetFramework>
+        <ImplicitUsings>enable</ImplicitUsings>
+        <Nullable>enable</Nullable>
+        <RestorePackagesWithLockFile>true</RestorePackagesWithLockFile>
+    </PropertyGroup>
+
+    <ItemGroup>
+        <Protobuf Include="Proto\**\*.proto" ProtoRoot="Proto" GrpcServices="Client" />
+    </ItemGroup>
+
+    <ItemGroup>
+        <PackageReference Include="Google.Protobuf" Version="3.29.3" />
+        <PackageReference Include="Grpc.Net.Client" Version="2.67.0" />
+        <PackageReference Include="Grpc.Tools" Version="2.69.0">
+            <PrivateAssets>all</PrivateAssets>
+            <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
+        </PackageReference>
+    </ItemGroup>
+
+</Project>

MutagenSdk/NamedPipesConnectionFactory.cs

@@ -0,0 +1,36 @@
+using System.IO.Pipes;
+using System.Security.Principal;
+
+namespace Coder.Desktop.MutagenSdk;
+
+public class NamedPipesConnectionFactory
+{
+    private readonly string _pipeName;
+
+    public NamedPipesConnectionFactory(string pipeName)
+    {
+        _pipeName = pipeName;
+    }
+
+    public async ValueTask<Stream> ConnectAsync(SocketsHttpConnectionContext _,
+        CancellationToken cancellationToken = default)
+    {
+        var client = new NamedPipeClientStream(
+            ".",
+            _pipeName,
+            PipeDirection.InOut,
+            PipeOptions.WriteThrough | PipeOptions.Asynchronous,
+            TokenImpersonationLevel.Anonymous);
+
+        try
+        {
+            await client.ConnectAsync(cancellationToken);
+            return client;
+        }
+        catch
+        {
+            await client.DisposeAsync();
+            throw;
+        }
+    }
+}

MutagenSdk/Proto/filesystem/behavior/probe_mode.proto

@@ -0,0 +1,140 @@
+# Usage: Update-Proto.ps1 -mutagenTag <version>
+param (
+    [Parameter(Mandatory = $true)]
+    [string] $mutagenTag
+)
+
+$ErrorActionPreference = "Stop"
+
+$repo = "mutagen-io/mutagen"
+$protoPrefix = "pkg"
+$entryFile = "service\synchronization\synchronization.proto"
+
+$outputNamespace = "Coder.Desktop.MutagenSdk.Proto"
+$outputDir = "MutagenSdk\Proto"
+
+$cloneDir = Join-Path $env:TEMP "coder-desktop-mutagen-proto"
+if (Test-Path $cloneDir) {
+    Write-Host "Found existing mutagen repo at $cloneDir, checking out $mutagenTag..."
+    # Checkout tag and clean
+    Push-Location $cloneDir
+    try {
+        & git.exe clean -fdx
+        if ($LASTEXITCODE -ne 0) { throw "Failed to clean $mutagenTag" }
+        # If we're already on the tag, we don't need to fetch or checkout.
+        if ((& git.exe name-rev --name-only HEAD) -eq "tags/$mutagenTag") {
+            Write-Host "Already on $mutagenTag"
+        }
+        else {
+            & git.exe fetch --all
+            if ($LASTEXITCODE -ne 0) { throw "Failed to fetch all tags" }
+            & git.exe checkout $mutagenTag
+            if ($LASTEXITCODE -ne 0) { throw "Failed to checkout $mutagenTag" }
+        }
+    }
+    finally {
+        Pop-Location
+    }
+}
+else {
+    New-Item -ItemType Directory -Path $cloneDir -Force
+
+    Write-Host "Cloning mutagen repo to $cloneDir..."
+    & git.exe clone `
+        --depth 1 `
+        --branch $mutagenTag `
+        "https://github.com/$repo.git" `
+        $cloneDir
+}
+
+# Read and format the license header for the copied files.
+$licenseContent = Get-Content (Join-Path $cloneDir "LICENSE")
+# Find the index where MIT License starts so we don't include the preamble.
+$mitStartIndex = $licenseContent.IndexOf("MIT License")
+$licenseHeader = ($licenseContent[$mitStartIndex..($licenseContent.Length - 1)] | ForEach-Object { (" * " + $_).TrimEnd() }) -join "`n"
+
+$entryFilePath = Join-Path $cloneDir (Join-Path $protoPrefix $entryFile)
+if (-not (Test-Path $entryFilePath)) {
+    throw "Failed to find $entryFilePath in mutagen repo"
+}
+
+# Map of src (in the mutagen repo) to dst (within the $outputDir).
+$filesToCopy = @{
+    $entryFilePath = $entryFile
+}
+
+function Add-ImportedFiles([string] $path) {
+    $content = Get-Content $path
+    foreach ($line in $content) {
+        if ($line -match '^import "(.+)"') {
+            $importPath = $matches[1]
+
+            # If the import path starts with google, it doesn't exist in the
+            # mutagen repo, so we need to skip it.
+            if ($importPath -match '^google/') {
+                Write-Host "Skipping $importPath"
+                continue
+            }
+
+            # Mutagen generates from within the pkg directory, so we need to add
+            # the prefix.
+            $filePath = Join-Path $cloneDir (Join-Path $protoPrefix $importPath)
+            if (-not $filesToCopy.ContainsKey($filePath)) {
+                Write-Host "Adding $filePath $importPath"
+                $filesToCopy[$filePath] = $importPath
+                Add-ImportedFiles $filePath
+            }
+        }
+    }
+}
+
+Add-ImportedFiles $entryFilePath
+
+$repoRoot = Resolve-Path (Join-Path $PSScriptRoot "..")
+Push-Location $repoRoot
+if (Test-Path $outputDir) {
+    Remove-Item -Recurse -Force $outputDir
+}
+New-Item -ItemType Directory -Path $outputDir -Force
+
+try {
+    foreach ($filePath in $filesToCopy.Keys) {
+        $protoPath = $filesToCopy[$filePath]
+        $dstPath = Join-Path $outputDir $protoPath
+        $destDir = Split-Path -Path $dstPath -Parent
+        if (-not (Test-Path $destDir)) {
+            New-Item -ItemType Directory -Path $destDir -Force
+        }
+        Copy-Item -Force $filePath $dstPath
+
+        # Determine the license header.
+        $fileHeader = "/*`n" +
+        " * This file was taken from`n" +
+        " * https://github.com/$repo/tree/$mutagenTag/$protoPrefix/$protoPath`n" +
+        " *`n" +
+        $licenseHeader +
+        "`n */`n`n"
+
+        # Determine the csharp_namespace for the file.
+        # Remove the filename and capitalize the first letter of each component
+        # of the path, then join with dots.
+        $protoDir = Split-Path -Path $protoPath -Parent
+        $csharpNamespaceSuffix = ($protoDir -split '[/\\]' | ForEach-Object { $_.Substring(0, 1).ToUpper() + $_.Substring(1) }) -join '.'
+        $csharpNamespace = "$outputNamespace"
+        if ($csharpNamespaceSuffix) {
+            $csharpNamespace += ".$csharpNamespaceSuffix"
+        }
+
+        # Add the csharp_namespace declaration.
+        $content = Get-Content $dstPath -Raw
+        $content = $fileHeader + $content
+        $content = $content -replace '(?m)^(package .*?;)', "`$1`noption csharp_namespace = `"$csharpNamespace`";"
+
+        # Replace all LF with CRLF to avoid spurious diffs in git.
+        $content = $content -replace "(?<!`r)`n", "`r`n"
+        Set-Content -Path $dstPath -Value $content -Encoding UTF8
+    }
+}
+finally {
+    Pop-Location
+}

MutagenSdk/Proto/selection/selection.proto

@@ -0,0 +1,47 @@
+{
+  "version": 1,
+  "dependencies": {
+    "net8.0": {
+      "Google.Protobuf": {
+        "type": "Direct",
+        "requested": "[3.29.3, )",
+        "resolved": "3.29.3",
+        "contentHash": "t7nZFFUFwigCwZ+nIXHDLweXvwIpsOXi+P7J7smPT/QjI3EKxnCzTQOhBqyEh6XEzc/pNH+bCFOOSjatrPt6Tw=="
+      },
+      "Grpc.Net.Client": {
+        "type": "Direct",
+        "requested": "[2.67.0, )",
+        "resolved": "2.67.0",
+        "contentHash": "ofTjJQfegWkVlk5R4k/LlwpcucpsBzntygd4iAeuKd/eLMkmBWoXN+xcjYJ5IibAahRpIJU461jABZvT6E9dwA==",
+        "dependencies": {
+          "Grpc.Net.Common": "2.67.0",
+          "Microsoft.Extensions.Logging.Abstractions": "6.0.0"
+        }
+      },
+      "Grpc.Tools": {
+        "type": "Direct",
+        "requested": "[2.69.0, )",
+        "resolved": "2.69.0",
+        "contentHash": "W5hW4R1h19FCzKb8ToqIJMI5YxnQqGmREEpV8E5XkfCtLPIK5MSHztwQ8gZUfG8qu9fg5MhItjzyPRqQBjnrbA=="
+      },
+      "Grpc.Core.Api": {
+        "type": "Transitive",
+        "resolved": "2.67.0",
+        "contentHash": "cL1/2f8kc8lsAGNdfCU25deedXVehhLA6GXKLLN4hAWx16XN7BmjYn3gFU+FBpir5yJynvDTHEypr3Tl0j7x/Q=="
+      },
+      "Grpc.Net.Common": {
+        "type": "Transitive",
+        "resolved": "2.67.0",
+        "contentHash": "gazn1cD2Eol0/W5ZJRV4PYbNrxJ9oMs8pGYux5S9E4MymClvl7aqYSmpqgmWAUWvziRqK9K+yt3cjCMfQ3x/5A==",
+        "dependencies": {
+          "Grpc.Core.Api": "2.67.0"
+        }
+      },
+      "Microsoft.Extensions.Logging.Abstractions": {
+        "type": "Transitive",
+        "resolved": "6.0.0",
+        "contentHash": "/HggWBbTwy8TgebGSX5DBZ24ndhzi93sHUBDvP1IxbZD7FDokYzdAr6+vbWGjw2XAfR2EJ1sfKUotpjHnFWPxA=="
+      }
+    }
+  }
+}