(wip) Implement support for call credentials

jitpack.yml

@@ -0,0 +1,2 @@
+jdk:
+  - openjdk20

pom.xml

@@ -11,12 +11,12 @@
   <packaging>pom</packaging>
 
   <artifactId>vertx-grpc-aggregator</artifactId>
-  <version>5.0.0-SNAPSHOT</version>
+  <version>4.4.4</version>
 
   <properties>
-    <stack.version>5.0.0-SNAPSHOT</stack.version>
+    <stack.version>4.4.4</stack.version>
     <grpc.version>1.50.2</grpc.version>
-    <protoc.version>3.21.12</protoc.version>
+    <protoc.version>3.23.1</protoc.version>
     <doc.skip>true</doc.skip>
   </properties>
 
@@ -63,6 +63,7 @@
     <module>vertx-grpc-common</module>
     <module>vertx-grpc-server</module>
     <module>vertx-grpc-client</module>
+    <module>vertx-grpc-jwt-auth</module>
     <module>vertx-grpc-context-storage</module>
     <module>vertx-grpc-protoc-plugin2</module>
     <module>vertx-grpc-it</module>

vertx-grpc-client/pom.xml

@@ -21,7 +21,7 @@
   <parent>
     <groupId>io.vertx</groupId>
     <artifactId>vertx-grpc-aggregator</artifactId>
-    <version>5.0.0-SNAPSHOT</version>
+    <version>4.4.4</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

vertx-grpc-client/src/main/asciidoc/client.adoc

@@ -163,3 +163,12 @@ handle the message encoding:
 
 - when the message uses the response encoding, the message is sent as is
 - when the message uses a different encoding, it will be encoded, e.g. compressed or uncompressed
+
+=== Error Handling
+
+A `{@link io.vertx.grpc.common.GrpcException}` may be throw and accessed via a `onFailure` handler. It may grant access to the response and the gRPC status via `{@link io.vertx.grpc.common.GrpcStatus}`.
+
+[source,java]
+----
+{@link examples.GrpcClientExamples#errorHandling}
+----

vertx-grpc-client/src/main/java/examples/GrpcClientExamples.java

@@ -5,13 +5,16 @@
 import io.vertx.core.Future;
 import io.vertx.core.Vertx;
 import io.vertx.core.buffer.Buffer;
+import io.vertx.core.http.HttpClientResponse;
 import io.vertx.core.net.SocketAddress;
 import io.vertx.docgen.Source;
 import io.vertx.grpc.client.GrpcClient;
 import io.vertx.grpc.client.GrpcClientChannel;
 import io.vertx.grpc.client.GrpcClientRequest;
 import io.vertx.grpc.client.GrpcClientResponse;
+import io.vertx.grpc.common.GrpcException;
 import io.vertx.grpc.common.GrpcMessage;
+import io.vertx.grpc.common.GrpcStatus;
 import io.vertx.grpc.common.ServiceName;
 
 @Source
@@ -189,4 +192,18 @@ public void messageLevelAPI(GrpcClient client, Buffer protoHello, SocketAddress
       });
     });
   }
+
+  public void errorHandling(GrpcClientRequest<HelloRequest, HelloReply> request) {
+    request.response().onSuccess(response -> {
+      Future<HelloReply> fut = response.last();
+      fut.onFailure(error -> {
+        if (error instanceof GrpcException) {
+          GrpcException grpcError = (GrpcException) error;
+          GrpcStatus status = grpcError.status();
+          HttpClientResponse httpResponse = grpcError.response();
+        }
+      });
+    });
+  }
+
 }

vertx-grpc-client/src/main/java/io/vertx/grpc/client/GrpcClientChannel.java

@@ -12,13 +12,9 @@
 
 import io.grpc.CallOptions;
 import io.grpc.ClientCall;
-import io.grpc.Compressor;
-import io.grpc.CompressorRegistry;
 import io.grpc.MethodDescriptor;
 import io.vertx.core.net.SocketAddress;
 
-import java.util.concurrent.Executor;
-
 /**
  * Bridge a gRPC service with a {@link io.vertx.grpc.client.GrpcClient}.
  */
@@ -34,20 +30,7 @@ public GrpcClientChannel(GrpcClient client, SocketAddress server) {
 
   @Override
   public <RequestT, ResponseT> ClientCall<RequestT, ResponseT> newCall(MethodDescriptor<RequestT, ResponseT> methodDescriptor, CallOptions callOptions) {
-
-    String encoding = callOptions.getCompressor();
-
-    Compressor compressor;
-    if (encoding != null) {
-      compressor = CompressorRegistry.getDefaultInstance().lookupCompressor(encoding);
-    } else {
-      compressor = null;
-    }
-
-
-    Executor exec = callOptions.getExecutor();
-
-    return new VertxClientCall<>(client, server, exec, methodDescriptor, encoding, compressor);
+    return new VertxClientCall<>(client, server, methodDescriptor, callOptions, authority());
   }
 
   @Override