Refactor gRPC test to use Jash for process execution

Signed-off-by: Daniel Fiala <danfiala23@gmail.com>

Author: zZHorizonZz

pom.xml

@@ -108,6 +108,12 @@
         <version>1.70</version>
         <scope>test</scope>
       </dependency>
+      <dependency>
+        <groupId>dev.jbang</groupId>
+        <artifactId>jash</artifactId>
+        <version>0.0.3</version>
+        <scope>test</scope>
+      </dependency>
       <dependency>
         <groupId>io.grpc</groupId>
         <artifactId>grpc-netty-shaded</artifactId>
@@ -274,4 +280,4 @@
     </plugins>
   </build>
 
-</project>
+</project>

vertx-grpc-it/pom.xml

@@ -79,6 +79,11 @@
       <artifactId>bcpkix-jdk15on</artifactId>
       <scope>test</scope>
     </dependency>
+    <dependency>
+      <groupId>dev.jbang</groupId>
+      <artifactId>jash</artifactId>
+      <scope>test</scope>
+    </dependency>
   </dependencies>
 
   <build>

vertx-grpc-it/src/test/java/io/vertx/grpc/it/ReflectionTest.java

@@ -10,6 +10,7 @@
  */
 package io.vertx.grpc.it;
 
+import dev.jbang.jash.Jash;
 import io.grpc.examples.helloworld.GreeterGrpcService;
 import io.grpc.examples.helloworld.HelloReply;
 import io.grpc.examples.helloworld.HelloWorldProto;
@@ -23,10 +24,11 @@
 import io.vertx.tests.common.GrpcTestBase;
 import org.junit.Test;
 
-import java.io.BufferedReader;
-import java.io.IOException;
-import java.io.InputStreamReader;
-import java.util.concurrent.TimeUnit;
+import java.time.Duration;
+import java.time.temporal.ChronoUnit;
+import java.util.stream.Collectors;
+
+import static dev.jbang.jash.Jash.$;
 
 /**
  * This test requires grpcurl to be installed on the system.
@@ -118,46 +120,13 @@ public void testReflectionDescribeMessage(TestContext should) {
   private Future<String> executeGrpcurl(String args) {
     return vertx.executeBlocking(() -> {
       try {
-        // Build the command - use an array to avoid shell escaping issues
-        String[] cmdArray = {
-          "sh", "-c", "grpcurl -plaintext localhost:" + port + " " + args
-        };
-
-        System.out.println("[grpcurl] Executing command: " + String.join(" ", cmdArray));
-
-        // Create the process
-        Process process = Runtime.getRuntime().exec(cmdArray);
-
-        // Read the output
-        StringBuilder output = new StringBuilder();
-        try (BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream()))) {
-          String line;
-          while ((line = reader.readLine()) != null) {
-            output.append(line).append("\n");
-          }
-        }
+        String command = "grpcurl -plaintext localhost:" + port + " " + args;
+        System.out.println("[grpcurl] Executing command: " + command);
 
-        // Wait for the process to complete
-        if (!process.waitFor(10, TimeUnit.SECONDS)) {
-          process.destroyForcibly();
-          throw new RuntimeException("grpcurl command timed out: " + String.join(" ", cmdArray));
+        try (Jash process = $(command).withTimeout(Duration.of(10, ChronoUnit.SECONDS))) {
+          return process.stream().collect(Collectors.joining("\n"));
         }
-
-        // Check the exit code
-        int exitCode = process.exitValue();
-        if (exitCode != 0) {
-          StringBuilder errorOutput = new StringBuilder();
-          try (BufferedReader reader = new BufferedReader(new InputStreamReader(process.getErrorStream()))) {
-            String line;
-            while ((line = reader.readLine()) != null) {
-              errorOutput.append(line).append("\n");
-            }
-          }
-          throw new RuntimeException("grpcurl command failed with exit code " + exitCode + ": " + errorOutput);
-        }
-
-        return output.toString();
-      } catch (IOException | InterruptedException e) {
+      } catch (Exception e) {
         throw new RuntimeException("Failed to execute grpcurl command", e);
       }
     });