feat: GrpcExtensions

src/Itmo.Dev.Platform.Testing.Behavioural/Extensions/GrpcCallResult.cs

@@ -0,0 +1,17 @@
+using Grpc.Core;
+
+namespace Itmo.Dev.Platform.Testing.Behavioural.Extensions;
+
+public abstract record GrpcCallResult<T>
+{
+    private GrpcCallResult() { }
+
+    public sealed record Success(T Value) : GrpcCallResult<T>;
+
+    public sealed record Failure(RpcException Exception) : GrpcCallResult<T>
+    {
+        public StatusCode StatusCode => Exception.StatusCode;
+
+        public string Detail => Exception.Status.Detail;
+    }
+}

src/Itmo.Dev.Platform.Testing.Behavioural/Extensions/GrpcExtensions.cs

@@ -0,0 +1,20 @@
+using Grpc.Core;
+
+namespace Itmo.Dev.Platform.Testing.Behavioural.Extensions;
+
+public static class GrpcExtensions
+{
+    public static async Task<GrpcCallResult<T>> AsResultAsync<T>(this AsyncUnaryCall<T> call)
+    {
+        try
+        {
+            T value = await call;
+
+            return new GrpcCallResult<T>.Success(value);
+        }
+        catch (RpcException e)
+        {
+            return new GrpcCallResult<T>.Failure(e);
+        }
+    }
+}

src/Itmo.Dev.Platform.Testing.Behavioural/Itmo.Dev.Platform.Testing.Behavioural.csproj

@@ -20,6 +20,7 @@
 
     <ItemGroup>
         <PackageReference Include="Google.Protobuf" />
+        <PackageReference Include="Grpc.Core.Api" />
         <PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions"/>
         <PackageReference Include="Newtonsoft.Json" />
         <PackageReference Include="Serilog.Sinks.XUnit"/>

tests/Itmo.Dev.Platform.Kafka.Tests.Startup/Program.cs

@@ -1,7 +1,5 @@
 using Itmo.Dev.Platform.Common.Extensions;
 using Itmo.Dev.Platform.Observability;
-using Microsoft.Extensions.Options;
-using Newtonsoft.Json;
 using OpenTelemetry.Trace;
 using Serilog;