feat: add support to run keploy v2 with unit tests #154

gouravkrosx · 2023-08-19T12:25:01Z

Related Issue

[feature]: add functionality to run keploy test with junit tests in java-sdk keploy#713

Describe the changes you've made

Added KeployCLI class which contains global functions to run keploy tests along with junit tests.
To run keploy tests along with exisiting junit tests, you just have to add this Test function in your test file.

 @Test
    @Order(Integer.MAX_VALUE)
    public void TestKeploy() throws InterruptedException {
        System.out.println("Running keploy tests along with unit tests");
        long pid = ProcessHandle.current().pid();
        System.out.println("Sending app pid to keploy:" + pid);

        Boolean testResult = true;
        try {
            // Start your keploy server
            Thread keployThread = new Thread(() -> {
                try {
                    System.out.println("Starting keploy server");
                    RunKeployServer(pid, 20, "./", 0);
                } catch (Exception e) {
                    throw new RuntimeException(e);
                }
            });

            keployThread.setDaemon(true);
            keployThread.start();
            // wait for the keploy to load hooks
            Thread.sleep(10000);

            System.out.println("Trying to fetch test sets");
            String[] testSets = FetchTestSets();
            if (testSets == null) {
                return;
            }

            System.out.println("TestSets: " + Arrays.asList(testSets));

            System.out.println("starting user application");

            boolean result = true;
            for (String testset : testSets) {

               String testRunId = RunTestSet(testset);

                // Start User application
                ExecutorService executor = Executors.newFixedThreadPool(1);

                // Submit tasks to the executor
                executor.submit(() -> {
                    try {
                        System.out.println("now starting");
                        SamplesJavaApplication.main(new String[]{""});
                    } catch (Exception e) {
                        System.out.println("got error while starting user application");
                        throw new RuntimeException(e);
                    }
                });

                KeployCLI.TestRunStatus testRunStatus;

               while (true) {

                   // check status every 2 sec
                   Thread.sleep(2000);
                   testRunStatus = FetchTestSetStatus(testRunId);
                   if (testRunStatus == TestRunStatus.RUNNING) {
                       System.out.println("testRun still in progress");
                       continue;
                   }
                   break;
               }

                
                // Shutdown the executor
                executor.shutdown();
                try {
                    if (!executor.awaitTermination(5, TimeUnit.SECONDS)) {
                        executor.shutdownNow();
                    }
                } catch (InterruptedException e) {
                    executor.shutdownNow();
                }
                Thread.sleep(5);
                // Stop User Application
                StopApplication();

                if (testRunStatus == TestRunStatus.FAILED) {
                    System.out.println("testrun failed");
                    result = false;
                } else if (testRunStatus == TestRunStatus.PASSED) {
                    System.out.println("testrun passed");
                    result = true;
                }

                System.out.println("TestResult of [" + testset + "]:" + result);
                testResult = testResult && result;

            }
        } catch (Exception e) {
            System.err.println("failed to execute keploy tests:" + e);
        } finally {
            System.out.println("Testing done with status:" + testResult);
        }

        System.out.println("Asserting on testResult:" + testResult);

        Thread stopKeploy = new Thread(() -> {
            System.out.println("Stopping keploy server");
            StopKeployServer();
        });
        stopKeploy.start();
        stopKeploy.join();
        assertTrue(testResult, "Keploy Test Result");
    }

Type of change

Bug fix (non-breaking change which fixes an issue)
New feature (non-breaking change which adds functionality)
Code style update (formatting, local variables)
Breaking change (fix or feature that would cause existing functionality to not work as expected)
This change requires a documentation update

Please describe the tests(if any). Provide instructions how its affecting the coverage.

Describe if there is any unusual behaviour of your code(Write `NA` if there isn't)

NA

Checklist:

My code follows the style guidelines of this project.
I have performed a self-review of my own code.
I have commented my code, particularly in hard-to-understand areas and used java doc.
I have made corresponding changes to the documentation.
My changes generate no new warnings.
I have added tests that prove my fix is effective or that my feature works.
New and existing unit tests pass locally with my changes.

Screenshots (if any)

Original	Updated
original screenshot	updated screenshot

Signed-off-by: gouravkrosx <gouravgreatkr@gmail.com>

github-actions

Remaining comments which cannot be posted as a review comment to avoid GitHub Rate Limit

checkstyle

v2/pom.xml