First public version

Author: 0xMartin

README.md

@@ -0,0 +1,5 @@
+log4j.rootLogger=info, console
+
+log4j.appender.console=org.apache.log4j.ConsoleAppender
+log4j.appender.console.layout=org.apache.log4j.PatternLayout
+log4j.appender.console.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss} %-5p %c{1} - %m%n

app/PID_LIST.txt

@@ -0,0 +1,55 @@
+/*
+ * This file was generated by the Gradle 'init' task.
+ *
+ * This generated file contains a sample Java application project to get you started.
+ * For more details on building Java & JVM projects, please refer to https://docs.gradle.org/8.7/userguide/building_java_projects.html in the Gradle documentation.
+ */
+
+plugins {
+    // Apply the application plugin to add support for building a CLI application in Java.
+    id 'application'
+    id 'com.github.johnrengelman.shadow' version '8.1.1'
+}
+
+repositories {
+    // Use Maven Central for resolving dependencies.
+    mavenCentral()
+}
+
+dependencies {
+    // Use JUnit test framework.
+    testImplementation libs.junit
+
+    // This dependency is used by the application.
+    implementation libs.guava
+
+    implementation 'commons-cli:commons-cli:1.4'
+    implementation 'com.aventstack:extentreports:5.0.5'
+    implementation 'org.yaml:snakeyaml:1.29'
+    implementation 'com.icegreen:greenmail:1.6.1'
+    implementation 'com.sun.mail:javax.mail:1.6.2'
+    implementation 'org.apache.httpcomponents:httpclient:4.5.13'
+    implementation 'org.jsoup:jsoup:1.14.3'
+    implementation 'org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.2.5'
+    implementation 'com.fasterxml.jackson.core:jackson-databind:2.13.1'
+    implementation 'com.fasterxml.jackson.dataformat:jackson-dataformat-xml:2.13.1'
+    implementation 'io.moquette:moquette-broker:0.15'
+}
+
+// Apply a specific Java toolchain to ease working on different environments.
+java {
+    toolchain {
+        languageVersion = JavaLanguageVersion.of(17)
+    }
+}
+
+application {
+    // Define the main class for the application.
+    mainClass = 'utb.fai.NetworkAppTestingTool'
+}
+
+jar {
+    manifest {
+        attributes 'Main-Class': 'utb.fai.NetworkAppTestingTool'
+    }
+}

app/bin/main/log4j.properties

@@ -0,0 +1,273 @@
+package utb.fai.Core;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.io.OutputStream;
+import java.util.ArrayList;
+import java.util.List;
+
+import utb.fai.Exception.InternalErrorException;
+import utb.fai.Exception.NonUniqueModuleNamesException;
+import utb.fai.Exception.TestedAppFailedToRunException;
+
+/**
+ * Trida urcena pro spousteni externich aplikaci. Umoznuje spusteni, ukonceni,
+ * odeslani a prijimani zprav na standartni stream teto aplikace.
+ */
+@NATTAnnotation.Module("app.std.out")
+public class ExternalProgramRunner extends NATTModule {
+
+    public static final String NAME = "app-std-out";
+
+    private NATTLogger logger = new NATTLogger(ExternalProgramRunner.class);
+
+    private Process currentProcess;
+    private long currentPID;
+    private OutputStream outputStream;
+
+    public ExternalProgramRunner() throws NonUniqueModuleNamesException, InternalErrorException {
+        super(ExternalProgramRunner.NAME);
+        this.currentProcess = null;
+        super.setRunning(true);
+        String currentDirectory = System.getProperty("user.dir");
+        logger.info("External program runner init done. Working directory path: " + currentDirectory);
+    }
+
+    @Override
+    public void runModule() throws InternalErrorException {
+        // ignorovano ...
+    }
+
+    @Override
+    public boolean terminateModule() {
+        return false;
+    }
+
+    @Override
+    public boolean sendMessage(String message) throws InternalErrorException {
+        return this.sendMessageToExternalProgram(message, true);
+    }
+
+    /**
+     * Prevede prikaz zapsany v retezci na pole argumenut. Napriklad: "java -jar
+     * app.jar 11" rozzdeli na [java, jar, app.jar, 11]
+     * 
+     * @param commandString Prikaz zapsany v retezci
+     * @return Pole prikazu
+     */
+    public static String[] commandStringToCommandList(String commandString) {
+        if (commandString == null) {
+            String[] empty = new String[0];
+            return empty;
+        }
+        if (commandString.isEmpty()) {
+            String[] empty = new String[0];
+            return empty;
+        }
+
+        String[] parts = commandString.split("(?=(?:[^']*'[^']*')*[^']*$)\\s+");
+
+        List<String> commandList = new ArrayList<>();
+
+        for (String part : parts) {
+            if (part.startsWith("'") && part.endsWith("'")) {
+                part = part.substring(1, part.length() - 1);
+            }
+            commandList.add(part);
+        }
+
+        String[] command = commandList.toArray(new String[0]);
+        return command;
+    }
+
+    /**
+     * Spusti aplikace pro testovani
+     * 
+     * @param command Prikaz pro spusteni aplikace
+     */
+    public void runExternalProgram(String command) throws TestedAppFailedToRunException {
+        if (this.currentProcess != null) {
+            logger.warning("Failed to run. External application is currently running!");
+            return;
+        }
+
+        logger.info("Run external application with command: " + command);
+
+        try {
+            currentProcess = Runtime.getRuntime().exec(ExternalProgramRunner.commandStringToCommandList(command));
+            if (currentProcess == null) {
+                throw new TestedAppFailedToRunException(command);
+            }
+            this.outputStream = currentProcess.getOutputStream();
+            InputStream inputStream = currentProcess.getInputStream();
+
+            if (inputStream == null) {
+                currentProcess.destroy();
+                throw new TestedAppFailedToRunException(command);
+            }
+            if (this.outputStream == null) {
+                currentProcess.destroy();
+                throw new TestedAppFailedToRunException(command);
+            }
+
+            ProgramOutputHandler outputHandler = new ProgramOutputHandler(this.currentProcess, inputStream,
+                    this.getName());
+            outputHandler.start();
+
+            // prida pid procesu do souboru pro priadne pozdejsi ukonceni (pokud by doslo k
+            // necekanemu ukonceni nastroje)
+            try {
+                this.currentPID = currentProcess.pid();
+                ProcessManager.addPID(ProcessManager.DEFAULT_FILE, String.valueOf(this.currentPID));
+            } catch (Exception ex) {
+            }
+
+        } catch (IOException e) {
+            throw new TestedAppFailedToRunException(command);
+        }
+    }
+
+    /**
+     * Odesle zpravu na System.in spustene aplikace
+     * 
+     * @param message Obsah odesilane zpravy
+     * @param endLine Pokud je true bude za konec zpravy vlozen symbol ukonceni
+     *                radku
+     * 
+     * @return True v pripade uspesneho odeslani zpravy
+     */
+    public boolean sendMessageToExternalProgram(String message, boolean endLine) {
+        if (currentProcess != null) {
+            logger.info("Sending message to external application on System.in. Message content: " + message);
+            try {
+
+                outputStream.write(message.getBytes());
+                if (endLine) {
+                    outputStream.write('\n');
+                }
+                outputStream.flush();
+
+                return true;
+
+            } catch (IOException e) {
+                logger.warning("Failed to send data. Stream is closed!");
+            }
+        } else {
+            logger.warning("Failed to send data. External application is not running now!");
+        }
+
+        return false;
+    }
+
+    /**
+     * Overi zda je proces spusteny
+     * 
+     * @return True v pripade ze proces je stale sputeny
+     */
+    public boolean isProcessRunning() {
+        if (this.currentProcess == null) {
+            return false;
+        }
+        try {
+            this.currentProcess.exitValue();
+            return false; // Proces byl ukoncen
+        } catch (IllegalThreadStateException e) {
+            return true; // proces je stale aktivni
+        }
+    }
+
+    /**
+     * Ukonci aplikaci
+     */
+    public boolean stopExternalProgram() {
+        if (currentProcess != null) {
+            logger.info("Termiting external application");
+            currentProcess.destroy();
+            currentProcess = null;
+
+            try {
+                outputStream.close();
+            } catch (IOException e) {
+            }
+
+            try {
+                ProcessManager.removePID(ProcessManager.DEFAULT_FILE, String.valueOf(this.currentPID));
+            } catch (Exception ex) {
+            }
+
+            return true;
+        }
+
+        return false;
+    }
+
+    /**
+     * Trida pro zpracovani prichozich zprav od externe spustene aplikace. Zpravy
+     * jsou prijimany pres standartni stream.
+     */
+    private class ProgramOutputHandler extends Thread {
+
+        private Process targetProcess;
+
+        private BufferedReader reader;
+
+        private String msgBufferName;
+
+        public ProgramOutputHandler(Process targetProcess, InputStream inputStream, String msgBufferName) {
+            this.targetProcess = targetProcess;
+            this.reader = new BufferedReader(new InputStreamReader(inputStream));
+            this.msgBufferName = msgBufferName;
+        }
+
+        @Override
+        public void run() {
+            String line;
+            try {
+                while ((line = reader.readLine()) != null) {
+                    // prijatou zpravu vlozi na buffer a zalogguje
+                    NATTContext.instance().getMessageBuffer().addMessage(msgBufferName, "", line);
+                    notifyMessageListeners("", line);
+                }
+            } catch (IOException e) {
+                logger.info("External application termited");
+            }
+
+            // odstraneni PID z listu jelikoz aplikace jiz byla ukoncena
+            try {
+                ProcessManager.removePID(ProcessManager.DEFAULT_FILE, String.valueOf(currentPID));
+            } catch (Exception ex) {
+            }
+
+            // pokusi se ziskat exit kod aplikace a vypsat pripadne chyby
+            int exitCode = 0;
+            try {
+                exitCode = this.targetProcess.waitFor();
+                if (exitCode != 0) {
+                    logger.warning("External application ends with error: " + exitCode);
+                    BufferedReader errorReader = new BufferedReader(
+                            new InputStreamReader(targetProcess.getErrorStream()));
+                    String errorLine;
+                    StringBuilder errorMessage = new StringBuilder();
+                    try {
+                        while ((errorLine = errorReader.readLine()) != null) {
+                            errorMessage.append(errorLine).append("\n");
+                        }
+                    } catch (IOException e) {
+                    }
+                    if (!errorMessage.isEmpty()) {
+                        logger.warning("Error message from external application: " + errorMessage.toString());
+                    }
+                } else {
+                    logger.info("External application ends with exit code 0");
+                }
+            } catch (InterruptedException e) {
+                logger.warning("Failed to get exit code of external application. Message: " + e.getMessage());
+            }
+            currentProcess = null;
+        }
+
+    }
+
+}