first steps towards simplified exception handling (server-side)

Author: mgravell

src/protobuf-net.Grpc/Internal/Reshape.cs

@@ -2,7 +2,9 @@
 using System;
 using System.Collections.Generic;
 using System.ComponentModel;
+using System.IO;
 using System.Runtime.CompilerServices;
+using System.Security;
 using System.Threading;
 using System.Threading.Tasks;
 namespace ProtoBuf.Grpc.Internal
@@ -136,6 +138,68 @@ public static async Task WriteTo<T>(this IAsyncEnumerable<T> reader, IServerStre
             }
         }
 
+        /// <summary>
+        /// Consumes the provided task raising exceptions as <see cref="RpcException"/>
+        /// </summary>
+        [Obsolete(WarningMessage, false)]
+        [Browsable(false), EditorBrowsable(EditorBrowsableState.Never)]
+        public static Task WithSimpleExceptionHandling(Task task)
+        {
+            return task.RanToCompletion() ? Task.CompletedTask : Awaited(task);
+
+            static async Task Awaited(Task task)
+            {
+                try
+                {
+                    await task.ConfigureAwait(false);
+                }
+                catch (Exception ex) when (!(ex is RpcException))
+                {
+                    Rethrow(ex);
+                }
+            }
+        }
+
+        /// <summary>
+        /// Consumes the provided task raising exceptions as <see cref="RpcException"/>
+        /// </summary>
+        [Obsolete(WarningMessage, false)]
+        [Browsable(false), EditorBrowsable(EditorBrowsableState.Never)]
+        public static Task<T> WithSimpleExceptionHandling<T>(Task<T> task)
+        {
+            return task.RanToCompletion() ? task : Awaited(task);
+
+            static async Task<T> Awaited(Task<T> task)
+            {
+                try
+                {
+                    return await task.ConfigureAwait(false);
+                }
+                catch (Exception ex) when (!(ex is RpcException))
+                {
+                    Rethrow(ex);
+                    return default!; // never reached
+                }
+            }
+        }
+
+        private static void Rethrow(Exception ex)
+        {
+            var code = ex switch
+            {
+                OperationCanceledException => StatusCode.Cancelled,
+                ArgumentException => StatusCode.InvalidArgument,
+                NotImplementedException => StatusCode.Unimplemented,
+                SecurityException => StatusCode.PermissionDenied,
+                EndOfStreamException => StatusCode.OutOfRange,
+                FileNotFoundException => StatusCode.NotFound,
+                DirectoryNotFoundException => StatusCode.NotFound,
+                TimeoutException => StatusCode.DeadlineExceeded,
+                _ => StatusCode.Unknown,
+            };
+            throw new RpcException(new Status(code, ex.Message), ex.Message);
+        }
+
         /// <summary>
         /// Performs a gRPC blocking unary call
         /// </summary>

tests/protobuf-net.Grpc.Test.IntegrationUpLevel/protobuf-net.Grpc.Test.IntegrationUpLevel.csproj

@@ -11,7 +11,7 @@
 
 	<ItemGroup>
 		<PackageReference Include="Microsoft.NET.Test.Sdk" Version="16.6.1" />
-		<PackageReference Include="protobuf-net" Version="3.0.1" />
+		<PackageReference Include="protobuf-net" Version="3.0.2" />
 		<PackageReference Include="System.Collections.Immutable" Version="1.7.1" />
 		<PackageReference Include="xunit" Version="2.4.1" />
 		<PackageReference Include="xunit.runner.visualstudio" Version="2.4.2">