try {
      // Read server's stdout to dynamically capture the allocated ephemeral ports
      java.io.BufferedReader reader =
          new java.io.BufferedReader(
              new java.io.InputStreamReader(
                  serverProcess.getInputStream(), java.nio.charset.StandardCharsets.UTF_8));

      String line;
      boolean grpcPqcFound = false;
      boolean grpcClassicalFound = false;

      // Wait for the server process to output its HTTP and gRPC ports
      long startTime = System.currentTimeMillis();
      while ((line = reader.readLine()) != null) {
        System.out.println("[SERVER-OUT] " + line);
        if (line.startsWith("GRPC_PQC_PORT: ")) {
          grpcPqcPort = Integer.parseInt(line.substring(15).trim());
          grpcPqcFound = true;
        } else if (line.startsWith("GRPC_CLASSICAL_PORT: ")) {
          grpcClassicalPort = Integer.parseInt(line.substring(21).trim());
          grpcClassicalFound = true;
        }

        if (grpcPqcFound && grpcClassicalFound) {
          break;
        }

        // Ephemeral port detection timeout (10 seconds) to fail-fast on server startup
        // errors
        if (System.currentTimeMillis() - startTime > 10000) {
          throw new RuntimeException(
              "Timeout waiting for PqcTestServer ephemeral ports to be printed!");
        }
      }

      if (!grpcPqcFound || !grpcClassicalFound) {
        throw new RuntimeException("PqcTestServer failed to initialize ephemeral ports!");
      }

      // Start a background thread to continuously drain the server's stdout
      Thread drainThread =
          new Thread(
              () -> {
                try {
                  String l;
                  while ((l = reader.readLine()) != null) {
                    System.out.println("[SERVER-OUT] " + l);
                  }
                } catch (java.io.IOException e) {
                  // Ignore stream closed
                }
              });
      drainThread.setDaemon(true);
      drainThread.start();
    } catch (Throwable t) {
      serverProcess.destroyForcibly();
      throw t;
    }

  public static void main(String[] args) throws Exception {
    PqcTestServer server = new PqcTestServer();
    try {
      server.start();

      System.out.println("HTTP_PQC_PORT: " + server.getHttpPqcPort());
      System.out.println("HTTP_CLASSICAL_PORT: " + server.getHttpClassicalPort());
      System.out.println("GRPC_PQC_PORT: " + server.getGrpcPqcPort());
      System.out.println("GRPC_CLASSICAL_PORT: " + server.getGrpcClassicalPort());
      System.out.flush();

      while (System.in.read() != -1) {
        Thread.sleep(1000);
      }
    } catch (InterruptedException e) {
      Thread.currentThread().interrupt();
      System.err.println("Server interrupted: " + e.getMessage());
    } catch (Exception e) {
      e.printStackTrace();
    } finally {
      server.stop();
    }
  }