new test class ShellExecutor created

src/test/java/io/github/astrapi69/net/ShellExecutor.java

@@ -0,0 +1,42 @@
+package io.github.astrapi69.net;
+
+import java.io.BufferedReader;
+import java.io.File;
+import java.io.IOException;
+import java.io.InputStreamReader;
+
+public class ShellExecutor
+{
+
+	public static String execute(String shellPath, String executionPath, String command)
+		throws IOException, InterruptedException
+	{
+		if(executionPath.contains("~")){
+			executionPath = executionPath.replace("~", System.getProperty("user.home"));
+		}
+		File executionDirectory = new File(executionPath);
+		if (!executionDirectory.exists())
+		{
+			throw new IllegalArgumentException("Execution directory does not exist");
+		}
+		String cdToExecutionPath = "cd " + executionPath;
+		String commands = cdToExecutionPath + " && " + command;
+		ProcessBuilder processBuilder = new ProcessBuilder();
+		processBuilder.command(shellPath, "-c", commands);
+
+		Process process = processBuilder.start();
+		StringBuilder stringBuilder = new StringBuilder();
+		BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream()));
+
+		String line;
+		while ((line = reader.readLine()) != null)
+		{
+			stringBuilder.append(line + "\n");
+		}
+		int waitFor = process.waitFor();
+
+		if (waitFor != 0)
+			stringBuilder.append("Exit code: ").append(waitFor).append("\n");
+		return stringBuilder.toString();
+	}
+}

src/test/java/io/github/astrapi69/net/ShellExecutorTest.java

@@ -0,0 +1,20 @@
+package io.github.astrapi69.net;
+
+import org.testng.annotations.Test;
+
+import java.io.IOException;
+
+public class ShellExecutorTest {
+
+    @Test
+    public void testExecute() throws IOException, InterruptedException {
+
+        String shellPath = "/usr/bin/zsh";
+        String executionPath = "~/dev/tmp";
+        String command = "touch foo.txt";
+
+        String shellOutput = ShellExecutor.execute(shellPath, executionPath, command);
+        System.out.println(shellOutput);
+
+    }
+}

src/test/java/io/github/astrapi69/net/SshConnector.java

@@ -78,7 +78,7 @@ public static void main(final String[] args) throws Exception
 		try
 		{
 
-			session = getSshSession("root", "admin", "192.168.0.1", 22);
+			session = getSshSession("root", "admin", "192.168.178.1", 22);
 			channel = (ChannelShell)session.openChannel("shell");
 
 			final PipedOutputStream reply = new PipedOutputStream();