DXP-2486 Add streamx run, stream and batch commands for StreamX 2.0 (and remove streamx publish/unpublish/cloud/dev/init commands for now)

e2e-tests/src/main/java/dev/streamx/cli/StreamxTerminalCommandProducer.java

@@ -1,6 +1,7 @@
 package dev.streamx.cli;
 
 import java.io.File;
+import java.nio.file.Path;
 import java.util.regex.Pattern;
 import java.util.stream.Stream;
 
@@ -39,7 +40,10 @@ private String findStreamxJar() {
         .filter(File::exists)
         .map(File::listFiles)
         .flatMap(Stream::of)
-        .map(File::getAbsolutePath)
+        .map(File::toPath)
+        .map(Path::toAbsolutePath)
+        .map(Path::normalize)
+        .map(Path::toString)
         .filter(p -> pattern.matcher(p.replace("\\", "/")).matches())
         .findFirst()
         .orElseThrow(() -> new RuntimeException("Could not find streamx Jar"));

e2e-tests/src/main/java/dev/streamx/cli/test/tools/terminal/OsTerminalCommandRunner.java

@@ -25,14 +25,14 @@ public OsTerminalCommandRunner() {
   }
 
   public ShellProcess run(String command) {
-    logger.info("Running terminal command: " + command);
     ProcessBuilder processBuilder = osCommand.create(command);
     try {
       ShellProcess shellProcess = ShellProcess.run(processBuilder);
       logger.info("Terminal command: '" + command + "' started");
       processes.add(shellProcess);
       return shellProcess;
     } catch (IOException e) {
+      logger.info("Error running terminal command: " + command);
       throw new RuntimeException(e);
     }
   }

e2e-tests/src/test/java/dev/streamx/cli/StreamxCliPublicationIT.java

@@ -14,7 +14,6 @@
 import java.nio.file.Path;
 import java.time.Duration;
 import org.eclipse.microprofile.config.inject.ConfigProperty;
-import org.jetbrains.annotations.NotNull;
 import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.TestInstance;