Use Vertx generated stubs instead of gRPC.io

Closes #1

Author: tsegismont

pom.xml

@@ -38,10 +38,6 @@
       <groupId>io.vertx</groupId>
       <artifactId>vertx-grpc-server</artifactId>
     </dependency>
-    <dependency>
-      <groupId>io.vertx</groupId>
-      <artifactId>vertx-grpcio-server</artifactId>
-    </dependency>
     <dependency>
       <groupId>com.google.protobuf</groupId>
       <artifactId>protobuf-java</artifactId>
@@ -85,16 +81,7 @@
         </configuration>
         <executions>
           <execution>
-            <id>compile</id>
-            <configuration>
-              <outputDirectory>${project.basedir}/src/main/java</outputDirectory>
-            </configuration>
-            <goals>
-              <goal>compile</goal>
-            </goals>
-          </execution>
-          <execution>
-            <id>compile-grpc-java</id>
+            <id>compile-java</id>
             <configuration>
               <pluginId>grpc-java</pluginId>
               <pluginArtifact>io.grpc:protoc-gen-grpc-java:${grpc.version}:exe:${os.detected.classifier}
@@ -112,6 +99,7 @@
               <outputDirectory>${project.basedir}/src/main/java</outputDirectory>
             </configuration>
             <goals>
+              <goal>compile</goal>
               <goal>compile-custom</goal>
             </goals>
           </execution>

src/main/java/io/vertx/howtos/grpcweb/ServerVerticle.java

@@ -1,30 +1,26 @@
 package io.vertx.howtos.grpcweb;
 
-import io.grpc.stub.StreamObserver;
 import io.vertx.core.Future;
 import io.vertx.core.VerticleBase;
 import io.vertx.core.Vertx;
 import io.vertx.ext.web.Router;
 import io.vertx.ext.web.handler.StaticHandler;
-import io.vertx.grpcio.server.GrpcIoServer;
-import io.vertx.grpcio.server.GrpcIoServiceBridge;
+import io.vertx.grpc.server.GrpcServer;
 
 public class ServerVerticle extends VerticleBase {
 
   @Override
   public Future<?> start() {
     // tag::grpcServer[]
-    GreeterGrpc.GreeterImplBase service = new GreeterGrpc.GreeterImplBase() {
+    VertxGreeterGrpcServer.GreeterApi stub = new VertxGreeterGrpcServer.GreeterApi() {
       @Override
-      public void sayHello(HelloRequest request, StreamObserver<HelloReply> responseObserver) {
-        responseObserver.onNext(HelloReply.newBuilder().setMessage("Hello " + request.getName()).build());
-        responseObserver.onCompleted();
+      public Future<HelloReply> sayHello(HelloRequest request) {
+        return Future.succeededFuture(HelloReply.newBuilder().setMessage("Hello " + request.getName()).build());
       }
     };
 
-    GrpcIoServer grpcServer = GrpcIoServer.server(vertx);
-    GrpcIoServiceBridge serverStub = GrpcIoServiceBridge.bridge(service);
-    serverStub.bind(grpcServer);
+    GrpcServer grpcServer = GrpcServer.server(vertx);
+    stub.bindAll(grpcServer);
     // end::grpcServer[]
 
     // tag::routerAndServer[]

src/main/java/io/vertx/howtos/grpcweb/VertxGreeterGrpcServer.java

@@ -0,0 +1,88 @@
+package io.vertx.howtos.grpcweb;
+
+import io.vertx.core.Future;
+import io.vertx.core.Promise;
+import io.vertx.core.Handler;
+import io.vertx.core.http.HttpServerRequest;
+import io.vertx.core.streams.ReadStream;
+import io.vertx.core.streams.WriteStream;
+import io.vertx.grpc.common.GrpcStatus;
+import io.vertx.grpc.common.ServiceName;
+import io.vertx.grpc.common.ServiceMethod;
+import io.vertx.grpc.common.GrpcReadStream;
+import io.vertx.grpc.common.GrpcWriteStream;
+import io.vertx.grpc.common.GrpcMessageDecoder;
+import io.vertx.grpc.common.GrpcMessageEncoder;
+import io.vertx.grpc.server.GrpcServerResponse;
+import io.vertx.grpc.server.GrpcServer;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class VertxGreeterGrpcServer  {
+
+  public static final ServiceMethod<io.vertx.howtos.grpcweb.HelloRequest, io.vertx.howtos.grpcweb.HelloReply> SayHello = ServiceMethod.server(
+    ServiceName.create("helloworld", "Greeter"),
+    "SayHello",
+    GrpcMessageEncoder.encoder(),
+    GrpcMessageDecoder.decoder(io.vertx.howtos.grpcweb.HelloRequest.parser()));
+  public static final ServiceMethod<io.vertx.howtos.grpcweb.HelloRequest, io.vertx.howtos.grpcweb.HelloReply> SayHello_JSON = ServiceMethod.server(
+    ServiceName.create("helloworld", "Greeter"),
+    "SayHello",
+    GrpcMessageEncoder.json(),
+    GrpcMessageDecoder.json(() -> io.vertx.howtos.grpcweb.HelloRequest.newBuilder()));
+
+  public static class GreeterApi {
+
+    public Future<io.vertx.howtos.grpcweb.HelloReply> sayHello(io.vertx.howtos.grpcweb.HelloRequest request) {
+      throw new UnsupportedOperationException("Not implemented");
+    }
+    public void sayHello(io.vertx.howtos.grpcweb.HelloRequest request, Promise<io.vertx.howtos.grpcweb.HelloReply> response) {
+      sayHello(request)
+        .onSuccess(msg -> response.complete(msg))
+        .onFailure(error -> response.fail(error));
+    }
+
+    public final void handle_sayHello(io.vertx.grpc.server.GrpcServerRequest<io.vertx.howtos.grpcweb.HelloRequest, io.vertx.howtos.grpcweb.HelloReply> request) {
+      Promise<io.vertx.howtos.grpcweb.HelloReply> promise = Promise.promise();
+      request.handler(msg -> {
+        try {
+          sayHello(msg, promise);
+        } catch (RuntimeException err) {
+          promise.tryFail(err);
+        }
+      });
+      promise.future()
+        .onFailure(err -> request.response().status(GrpcStatus.INTERNAL).end())
+        .onSuccess(resp -> request.response().end(resp));
+    }
+    public GreeterApi bind_sayHello(GrpcServer server) {
+      return bind_sayHello(server, io.vertx.grpc.common.WireFormat.PROTOBUF);
+    }
+    public GreeterApi bind_sayHello(GrpcServer server, io.vertx.grpc.common.WireFormat format) {
+      ServiceMethod<io.vertx.howtos.grpcweb.HelloRequest,io.vertx.howtos.grpcweb.HelloReply> serviceMethod;
+      switch(format) {
+        case PROTOBUF:
+          serviceMethod = SayHello;
+          break;
+        case JSON:
+          serviceMethod = SayHello_JSON;
+          break;
+        default:
+          throw new AssertionError();
+      }
+      server.callHandler(serviceMethod, this::handle_sayHello);
+      return this;
+    }
+
+    public final GreeterApi bindAll(GrpcServer server) {
+      bind_sayHello(server);
+      return this;
+    }
+
+    public final GreeterApi bindAll(GrpcServer server, io.vertx.grpc.common.WireFormat format) {
+      bind_sayHello(server, format);
+      return this;
+    }
+  }
+}