Get remote ZFS server implemented (#104)

RedpointGames · Dec 23, 2024 · 76be3c1 · 76be3c1
1 parent 5ca6fea
commit 76be3c1
Show file tree

Hide file tree

Showing 12 changed files with 310 additions and 206 deletions.
diff --git a/UET/Redpoint.GrpcPipes.Transport.Tcp/Impl/TcpGrpcServerCall.cs b/UET/Redpoint.GrpcPipes.Transport.Tcp/Impl/TcpGrpcServerCall.cs
@@ -65,6 +65,12 @@ await _incoming.Connection.WriteAsync(new TcpGrpcResponseComplete
                     _incoming.LogTrace($"Wrote status ({statusCode}, '{details}') to client.");
                 }
             }
+            catch (RpcException ex) when (ex.StatusCode == StatusCode.Unavailable)
+            {
+                // We can't send any content to the client, because the client has already disconnected.
+                _incoming.LogTrace($"Unable to send ({statusCode}, '{details}') to client because the client has already disconnected.");
+                return;
+            }
             catch (OperationCanceledException) when (_serverCallContext.DeadlineCancellationToken.IsCancellationRequested)
             {
                 // We can't send any content to the client, because we have exceeded our extended deadline cancellation.

diff --git a/UET/Redpoint.Uet.Workspace/RemoteZfs/RemoteZfsProtocol.proto b/UET/Redpoint.Uet.Workspace/RemoteZfs/RemoteZfsProtocol.proto
@@ -2,13 +2,15 @@ syntax = 'proto3';
 
 package Redpoint.Uet.Workspace.RemoteZfs;
 
-message EmptyRequest {
+message AcquireWorkspaceRequest {
+	string templateId = 1;
+	repeated string disambiguators = 2;
 }
 
-message AcquireResponse {
-	string windowsSharePath = 1;
+message AcquireWorkspaceResponse {
+	string windowsShareRemotePath = 1;
 }
 
 service RemoteZfs {
-	rpc Acquire(stream EmptyRequest) returns (stream AcquireResponse) {}
+	rpc AcquireWorkspace(AcquireWorkspaceRequest) returns (stream AcquireWorkspaceResponse) {}
 }
diff --git a/UET/Redpoint.Uet.Workspace/RemoteZfs/RemoteZfsServer.cs b/UET/Redpoint.Uet.Workspace/RemoteZfs/RemoteZfsServer.cs
diff --git a/UET/uet/Commands/Internal/RemoteZfsServer/RemoteZfsSerializerContext.cs b/UET/uet/Commands/Internal/RemoteZfsServer/RemoteZfsSerializerContext.cs
@@ -0,0 +1,14 @@
+namespace UET.Commands.Internal.RemoteZfsServer
+{
+    using System.Text.Json.Serialization;
+
+    [JsonSerializable(typeof(TrueNasQueryOptions))]
+    [JsonSerializable(typeof(TrueNasQuery))]
+    [JsonSerializable(typeof(TrueNasSnapshot[]))]
+    [JsonSerializable(typeof(TrueNasSnapshotClone))]
+    [JsonSerializable(typeof(RemoteZfsServerConfig))]
+    [JsonSerializable(typeof(RemoteZfsServerConfigTemplate))]
+    internal partial class RemoteZfsSerializerContext : JsonSerializerContext
+    {
+    }
+}