Use certificate-generator for gRPC integration tests

integration-tests/grpc/pom.xml

@@ -59,6 +59,11 @@
             <groupId>org.apache.camel.quarkus</groupId>
             <artifactId>camel-quarkus-integration-tests-support-grpc</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.apache.camel.quarkus</groupId>
+            <artifactId>camel-quarkus-integration-tests-support-certificate-generator</artifactId>
+            <scope>test</scope>
+        </dependency>
 
         <!-- test dependencies -->
         <dependency>

integration-tests/grpc/src/main/java/org/apache/camel/quarkus/component/grpc/it/GrpcRoute.java

@@ -45,7 +45,7 @@ public void configure() throws Exception {
 
         // Verifies that the serviceAccountResource can be loaded on startup
         from("direct:googleAuthenticationType")
-                .toF("grpc://localhost:{{camel.grpc.test.async.server.port}}/%s?method=pingAsyncAsync&negotiationType=TLS&keyResource=certs/server.key&authenticationType=GOOGLE&serviceAccountResource=keys/app.json&KeyCertChainResource=certs/server.pem",
+                .toF("grpc://localhost:{{camel.grpc.test.async.server.port}}/%s?method=pingAsyncAsync&negotiationType=TLS&keyResource=certs/grpc.key&authenticationType=GOOGLE&serviceAccountResource=keys/app.json&KeyCertChainResource=certs/grpc.pem",
                         PING_PONG_SERVICE);
 
         // Streaming producer strategy
@@ -111,8 +111,9 @@ public void configure() throws Exception {
         // TLS secured consumer
         fromF("grpc://localhost:{{camel.grpc.test.tls.server.port}}"
                 + "/%s?consumerStrategy=PROPAGATION&"
-                + "negotiationType=TLS&keyCertChainResource=certs/server.pem&"
-                + "keyResource=certs/server.key&trustCertCollectionResource=certs/ca.pem", PING_PONG_SERVICE)
+                + "negotiationType=TLS&keyCertChainResource=file:target/certs/grpc.crt&"
+                + "keyResource=file:target/certs/grpc.key&trustCertCollectionResource=file:target/certs/grpc-ca.crt",
+                PING_PONG_SERVICE)
                 .process("messageOriginProcessor")
                 .choice()
                 .when(simple("${header.origin} == 'producer'"))
@@ -126,8 +127,9 @@ public void configure() throws Exception {
         from("direct:sendTls")
                 .toF("grpc://localhost:{{camel.grpc.test.tls.server.port}}"
                         + "/%s?method=pingSyncSync&synchronous=true&"
-                        + "negotiationType=TLS&keyCertChainResource=certs/client.pem&"
-                        + "keyResource=certs/client.key&trustCertCollectionResource=certs/ca.pem", PING_PONG_SERVICE);
+                        + "negotiationType=TLS&keyCertChainResource=file:target/certs/grpc.crt&"
+                        + "keyResource=file:target/certs/grpc.key&trustCertCollectionResource=file:target/certs/grpc-ca.crt",
+                        PING_PONG_SERVICE);
 
         // JWT secured consumer
         fromF("grpc://localhost:{{camel.grpc.test.jwt.server.port}}"

integration-tests/grpc/src/test/java/org/apache/camel/quarkus/component/grpc/it/GrpcTest.java

@@ -16,6 +16,7 @@
  */
 package org.apache.camel.quarkus.component.grpc.it;
 
+import java.io.FileInputStream;
 import java.util.Iterator;
 import java.util.List;
 import java.util.concurrent.CountDownLatch;
@@ -32,6 +33,8 @@
 import io.quarkus.test.junit.QuarkusTest;
 import io.restassured.RestAssured;
 import io.restassured.path.json.JsonPath;
+import me.escoffier.certs.Format;
+import me.escoffier.certs.junit5.Certificate;
 import org.apache.camel.component.grpc.auth.jwt.JwtAlgorithm;
 import org.apache.camel.component.grpc.auth.jwt.JwtCallCredentials;
 import org.apache.camel.component.grpc.auth.jwt.JwtHelper;
@@ -40,6 +43,7 @@
 import org.apache.camel.quarkus.component.grpc.it.model.PingPongGrpc.PingPongStub;
 import org.apache.camel.quarkus.component.grpc.it.model.PingRequest;
 import org.apache.camel.quarkus.component.grpc.it.model.PongResponse;
+import org.apache.camel.quarkus.test.support.certificate.TestCertificates;
 import org.apache.camel.util.StringHelper;
 import org.awaitility.Awaitility;
 import org.eclipse.microprofile.config.Config;
@@ -66,6 +70,9 @@
 import static org.junit.jupiter.api.Assertions.assertTrue;
 import static org.junit.jupiter.api.Assertions.fail;
 
+@TestCertificates(certificates = {
+        @Certificate(name = "grpc", formats = { Format.PEM })
+}, baseDir = "target/certs")
 @QuarkusTest
 @QuarkusTestResource(GrpcServerTestResource.class)
 class GrpcTest {
@@ -256,15 +263,13 @@ public void tlsConsumer() throws Exception {
         Config config = ConfigProvider.getConfig();
         Integer port = config.getValue("camel.grpc.test.tls.server.port", Integer.class);
 
-        ClassLoader classLoader = Thread.currentThread().getContextClassLoader();
-
         ManagedChannel channel = null;
         try {
             channel = NettyChannelBuilder.forAddress("localhost", port)
                     .sslContext(GrpcSslContexts.forClient()
-                            .keyManager(classLoader.getResourceAsStream("certs/client.pem"),
-                                    classLoader.getResourceAsStream("certs/client.key"))
-                            .trustManager(classLoader.getResourceAsStream("certs/ca.pem"))
+                            .keyManager(new FileInputStream("target/certs/grpc.crt"),
+                                    new FileInputStream("target/certs/grpc.key"))
+                            .trustManager(new FileInputStream("target/certs/grpc-ca.crt"))
                             .build())
                     .build();