Check for duplicate services - mutiny and plain; from quarkusio#44326

extensions/grpc/deployment/src/main/java/io/quarkus/grpc/deployment/GrpcServerProcessor.java

@@ -148,17 +148,18 @@ void processGeneratedBeans(CombinedIndexBuildItem index, BuildProducer<Annotatio
                 continue;
             }
             DotName mutinyImplBase = generatedBean.superName();
+            // Should probably never be 0 ... ?
             if (index.getIndex().getAllKnownSubclasses(mutinyImplBase).size() != 1) {
-                // Some class extends the mutiny impl base
-                continue;
+                // Some other class also extends the mutiny impl base -- 1 is this generated gRPC "bean" class
+                throw new IllegalStateException("Duplicated gRPC service: " + mutinyImplBase);
             }
             String mutinyImplBaseName = mutinyImplBase.toString();
             // Now derive the original impl base
             // e.g. examples.MutinyGreeterGrpc.GreeterImplBase -> examples.GreeterGrpc.GreeterImplBase
             DotName implBase = DotName.createSimple(mutinyImplBaseName.replace(MutinyGrpcGenerator.CLASS_PREFIX, ""));
             if (!index.getIndex().getAllKnownSubclasses(implBase).isEmpty()) {
-                // Some class extends the impl base
-                continue;
+                // Some class already extends the impl base
+                throw new IllegalStateException("Duplicated gRPC service: " + implBase);
             }
             // Finally, exclude some packages
             boolean excluded = false;
@@ -235,6 +236,7 @@ void discoverBindableServices(BuildProducer<BindableServiceBuildItem> bindables,
             if (Modifier.isAbstract(service.flags())) {
                 continue;
             }
+
             BindableServiceBuildItem item = new BindableServiceBuildItem(service.name());
             Set<String> blockingMethods = gatherBlockingOrVirtualMethodNames(service, index, false);
             Set<String> virtualMethods = gatherBlockingOrVirtualMethodNames(service, index, true);

extensions/grpc/deployment/src/test/java/io/quarkus/grpc/server/Duplicate2ServiceTest.java

@@ -0,0 +1,35 @@
+package io.quarkus.grpc.server;
+
+import static org.junit.jupiter.api.Assertions.fail;
+
+import org.jboss.shrinkwrap.api.ShrinkWrap;
+import org.jboss.shrinkwrap.api.spec.JavaArchive;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Disabled;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.RegisterExtension;
+
+import io.grpc.examples.dups.Poke;
+import io.quarkus.grpc.server.dups.Poke2Service;
+import io.quarkus.grpc.server.dups.PokeService;
+import io.quarkus.test.QuarkusUnitTest;
+
+// 2 same implBase services
+@Disabled("Currently not detected at build time")
+public class Duplicate2ServiceTest {
+
+    @RegisterExtension
+    static final QuarkusUnitTest unitTest = new QuarkusUnitTest()
+            .setArchiveProducer(() -> ShrinkWrap.create(JavaArchive.class)
+                    .addClasses(Poke2Service.class, PokeService.class)
+                    .addPackage(Poke.class.getPackage()))
+            .assertException(t -> {
+                Assertions.assertTrue(t.getMessage().contains("Duplicated gRPC service"));
+            });
+
+    @Test
+    void testDuplicateService() {
+        fail("Should not be called");
+    }
+
+}

extensions/grpc/deployment/src/test/java/io/quarkus/grpc/server/DuplicateBeansServiceTest.java

@@ -0,0 +1,34 @@
+package io.quarkus.grpc.server;
+
+import static org.junit.jupiter.api.Assertions.fail;
+
+import org.jboss.shrinkwrap.api.ShrinkWrap;
+import org.jboss.shrinkwrap.api.spec.JavaArchive;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.RegisterExtension;
+
+import io.grpc.examples.dups.Poke;
+import io.quarkus.grpc.server.dups.MutinyPoke2Service;
+import io.quarkus.grpc.server.dups.MutinyPokeService;
+import io.quarkus.test.QuarkusUnitTest;
+
+// 2 same beans services
+public class DuplicateBeansServiceTest {
+
+    @RegisterExtension
+    static final QuarkusUnitTest unitTest = new QuarkusUnitTest()
+            .setArchiveProducer(() -> ShrinkWrap.create(JavaArchive.class)
+                    .addClasses(MutinyPokeService.class, MutinyPoke2Service.class)
+                    .addPackage(Poke.class.getPackage()))
+            .assertException(t -> {
+                // fails with CDI / Arc
+                Assertions.assertTrue(t.getMessage().contains("Ambiguous dependencies"));
+            });
+
+    @Test
+    void testDuplicateService() {
+        fail("Should not be called");
+    }
+
+}

extensions/grpc/deployment/src/test/java/io/quarkus/grpc/server/DuplicateServiceTest.java

@@ -0,0 +1,33 @@
+package io.quarkus.grpc.server;
+
+import static org.junit.jupiter.api.Assertions.fail;
+
+import org.jboss.shrinkwrap.api.ShrinkWrap;
+import org.jboss.shrinkwrap.api.spec.JavaArchive;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.RegisterExtension;
+
+import io.grpc.examples.dups.Poke;
+import io.quarkus.grpc.server.dups.MutinyPokeService;
+import io.quarkus.grpc.server.dups.PokeService;
+import io.quarkus.test.QuarkusUnitTest;
+
+// 1 implBase + 1 bean
+public class DuplicateServiceTest {
+
+    @RegisterExtension
+    static final QuarkusUnitTest unitTest = new QuarkusUnitTest()
+            .setArchiveProducer(() -> ShrinkWrap.create(JavaArchive.class)
+                    .addClasses(MutinyPokeService.class, PokeService.class)
+                    .addPackage(Poke.class.getPackage()))
+            .assertException(t -> {
+                Assertions.assertTrue(t.getMessage().contains("Duplicated gRPC service"));
+            });
+
+    @Test
+    void testDuplicateService() {
+        fail("Should not be called");
+    }
+
+}

extensions/grpc/deployment/src/test/java/io/quarkus/grpc/server/MDuplicate2ServiceTest.java

@@ -0,0 +1,35 @@
+package io.quarkus.grpc.server;
+
+import static org.junit.jupiter.api.Assertions.fail;
+
+import org.jboss.shrinkwrap.api.ShrinkWrap;
+import org.jboss.shrinkwrap.api.spec.JavaArchive;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Disabled;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.RegisterExtension;
+
+import io.grpc.examples.dups.Poke;
+import io.quarkus.grpc.server.dups.MPoke2Service;
+import io.quarkus.grpc.server.dups.MPokeService;
+import io.quarkus.test.QuarkusUnitTest;
+
+// 2 same mutinyImplBase services
+@Disabled("Currently not detected at build time")
+public class MDuplicate2ServiceTest {
+
+    @RegisterExtension
+    static final QuarkusUnitTest unitTest = new QuarkusUnitTest()
+            .setArchiveProducer(() -> ShrinkWrap.create(JavaArchive.class)
+                    .addClasses(MPoke2Service.class, MPokeService.class)
+                    .addPackage(Poke.class.getPackage()))
+            .assertException(t -> {
+                Assertions.assertTrue(t.getMessage().contains("Duplicated gRPC service"));
+            });
+
+    @Test
+    void testDuplicateService() {
+        fail("Should not be called");
+    }
+
+}

extensions/grpc/deployment/src/test/java/io/quarkus/grpc/server/VertxDuplicateServiceTest.java

@@ -0,0 +1,34 @@
+package io.quarkus.grpc.server;
+
+import static org.junit.jupiter.api.Assertions.fail;
+
+import org.jboss.shrinkwrap.api.ShrinkWrap;
+import org.jboss.shrinkwrap.api.spec.JavaArchive;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.RegisterExtension;
+
+import io.grpc.examples.dups.Poke;
+import io.quarkus.grpc.server.dups.MutinyPokeService;
+import io.quarkus.grpc.server.dups.PokeService;
+import io.quarkus.test.QuarkusUnitTest;
+
+// 1 implBase + 1 bean -- with Vert.x based gRPC
+public class VertxDuplicateServiceTest {
+
+    @RegisterExtension
+    static final QuarkusUnitTest unitTest = new QuarkusUnitTest()
+            .setArchiveProducer(() -> ShrinkWrap.create(JavaArchive.class)
+                    .addClasses(MutinyPokeService.class, PokeService.class)
+                    .addPackage(Poke.class.getPackage()))
+            .overrideConfigKey("quarkus.grpc.server.use-separate-server", "false")
+            .assertException(t -> {
+                Assertions.assertTrue(t.getMessage().contains("Duplicated gRPC service"));
+            });
+
+    @Test
+    void testDuplicateService() {
+        fail("Should not be called");
+    }
+
+}

extensions/grpc/deployment/src/test/java/io/quarkus/grpc/server/dups/MPoke2Service.java

@@ -0,0 +1,15 @@
+package io.quarkus.grpc.server.dups;
+
+import io.grpc.examples.dups.MutinyPokeGrpc;
+import io.grpc.examples.dups.PokeReply;
+import io.grpc.examples.dups.PokeRequest;
+import io.quarkus.grpc.GrpcService;
+import io.smallrye.mutiny.Uni;
+
+@GrpcService
+public class MPoke2Service extends MutinyPokeGrpc.PokeImplBase {
+    @Override
+    public Uni<PokeReply> poke(PokeRequest request) {
+        return super.poke(request);
+    }
+}

extensions/grpc/deployment/src/test/java/io/quarkus/grpc/server/dups/MPokeService.java

@@ -0,0 +1,15 @@
+package io.quarkus.grpc.server.dups;
+
+import io.grpc.examples.dups.MutinyPokeGrpc;
+import io.grpc.examples.dups.PokeReply;
+import io.grpc.examples.dups.PokeRequest;
+import io.quarkus.grpc.GrpcService;
+import io.smallrye.mutiny.Uni;
+
+@GrpcService
+public class MPokeService extends MutinyPokeGrpc.PokeImplBase {
+    @Override
+    public Uni<PokeReply> poke(PokeRequest request) {
+        return super.poke(request);
+    }
+}

extensions/grpc/deployment/src/test/java/io/quarkus/grpc/server/dups/Mutiny2PokeService.java

@@ -0,0 +1,15 @@
+package io.quarkus.grpc.server.dups;
+
+import io.grpc.examples.dups.Poke;
+import io.grpc.examples.dups.PokeReply;
+import io.grpc.examples.dups.PokeRequest;
+import io.quarkus.grpc.GrpcService;
+import io.smallrye.mutiny.Uni;
+
+@GrpcService
+public class Mutiny2PokeService implements Poke {
+    @Override
+    public Uni<PokeReply> poke(PokeRequest request) {
+        return null;
+    }
+}

extensions/grpc/deployment/src/test/java/io/quarkus/grpc/server/dups/MutinyPoke2Service.java

@@ -0,0 +1,15 @@
+package io.quarkus.grpc.server.dups;
+
+import io.grpc.examples.dups.Poke;
+import io.grpc.examples.dups.PokeReply;
+import io.grpc.examples.dups.PokeRequest;
+import io.quarkus.grpc.GrpcService;
+import io.smallrye.mutiny.Uni;
+
+@GrpcService
+public class MutinyPoke2Service implements Poke {
+    @Override
+    public Uni<PokeReply> poke(PokeRequest request) {
+        return null;
+    }
+}

extensions/grpc/deployment/src/test/java/io/quarkus/grpc/server/dups/MutinyPokeService.java

@@ -0,0 +1,15 @@
+package io.quarkus.grpc.server.dups;
+
+import io.grpc.examples.dups.Poke;
+import io.grpc.examples.dups.PokeReply;
+import io.grpc.examples.dups.PokeRequest;
+import io.quarkus.grpc.GrpcService;
+import io.smallrye.mutiny.Uni;
+
+@GrpcService
+public class MutinyPokeService implements Poke {
+    @Override
+    public Uni<PokeReply> poke(PokeRequest request) {
+        return null;
+    }
+}

extensions/grpc/deployment/src/test/java/io/quarkus/grpc/server/dups/Poke2Service.java

@@ -0,0 +1,14 @@
+package io.quarkus.grpc.server.dups;
+
+import io.grpc.examples.dups.PokeGrpc;
+import io.grpc.examples.dups.PokeReply;
+import io.grpc.examples.dups.PokeRequest;
+import io.grpc.stub.StreamObserver;
+import io.quarkus.grpc.GrpcService;
+
+@GrpcService
+public class Poke2Service extends PokeGrpc.PokeImplBase {
+    @Override
+    public void poke(PokeRequest request, StreamObserver<PokeReply> responseObserver) {
+    }
+}

extensions/grpc/deployment/src/test/java/io/quarkus/grpc/server/dups/PokeService.java

@@ -0,0 +1,14 @@
+package io.quarkus.grpc.server.dups;
+
+import io.grpc.examples.dups.PokeGrpc;
+import io.grpc.examples.dups.PokeReply;
+import io.grpc.examples.dups.PokeRequest;
+import io.grpc.stub.StreamObserver;
+import io.quarkus.grpc.GrpcService;
+
+@GrpcService
+public class PokeService extends PokeGrpc.PokeImplBase {
+    @Override
+    public void poke(PokeRequest request, StreamObserver<PokeReply> responseObserver) {
+    }
+}

extensions/grpc/deployment/src/test/proto/dups.proto

@@ -0,0 +1,20 @@
+syntax = "proto3";
+
+option java_multiple_files = true;
+option java_package = "io.grpc.examples.dups";
+option java_outer_classname = "DupsFooProto";
+option objc_class_prefix = "DF";
+
+package dups;
+
+service Poke {
+    rpc poke (PokeRequest) returns (PokeReply) {}
+}
+
+message PokeRequest {
+    string name = 1;
+}
+
+message PokeReply {
+    string message = 1;
+}

extensions/grpc/reflection/src/main/java/io/quarkus/grpc/reflection/service/ReflectionServiceV1.java

@@ -28,8 +28,12 @@ public class ReflectionServiceV1 extends MutinyServerReflectionGrpc.ServerReflec
 
     private final GrpcServerIndex index;
 
+    public ReflectionServiceV1(GrpcServerIndex index) {
+        this.index = index;
+    }
+
     public ReflectionServiceV1(List<ServerServiceDefinition> definitions) {
-        index = new GrpcServerIndex(definitions);
+        this(new GrpcServerIndex(definitions));
     }
 
     @Override

extensions/grpc/reflection/src/main/java/io/quarkus/grpc/reflection/service/ReflectionServiceV1alpha.java

@@ -21,8 +21,12 @@ public class ReflectionServiceV1alpha extends MutinyServerReflectionGrpc.ServerR
 
     private final GrpcServerIndex index;
 
+    public ReflectionServiceV1alpha(GrpcServerIndex index) {
+        this.index = index;
+    }
+
     public ReflectionServiceV1alpha(List<ServerServiceDefinition> definitions) {
-        index = new GrpcServerIndex(definitions);
+        this(new GrpcServerIndex(definitions));
     }
 
     @Override