Quantum Frame Work - ExtentHtmlReporter - issue with parallel execution

[rmnelapatla]

I had Extent Report helper class as below.

package com.quantum.java.pages;

import com.aventstack.extentreports.ExtentReports;
import com.aventstack.extentreports.ExtentTest;
import com.aventstack.extentreports.MediaEntityBuilder;
import com.aventstack.extentreports.reporter.ExtentHtmlReporter;
import com.aventstack.extentreports.reporter.KlovReporter;

import java.io.File;
import java.io.IOException;
import java.util.Date;

public class ExtentReportHelper {

private static ExtentHtmlReporter htmlReporter;
private static ExtentReports extent;
private static ExtentTest test;
static File ExtentFailStepScreenPath;


private static ThreadLocal<ExtentTest> extentTest;
private static ExtentReports extentnew = ExtentManager.getInstance();



public ExtentReportHelper(String sExtentReportDbServer, String sExtentReportDbServerPort, String sHtmlReportName,
                          String sProjectName, String sExtentReportServer, String sExtentReportServerPort,
                          String sExtentAutomationUser) throws Exception {

    KlovReporter klov = new KlovReporter();
    // specify mongoDb connection
    klov.initMongoDbConnection(sExtentReportDbServer, Integer.parseInt(sExtentReportDbServerPort));
    // specify project
    // ! you must specify a project, other a "Default project will be used"
    klov.setProjectName(sProjectName);

    Date date = new Date();
    // you must specify a reportName otherwise a default timestamp will be used
    klov.setReportName(sProjectName + "_" +  date.toString());

    // URL of the KLOV server
    // you must specify the server URL to ensure all your runtime media is uploaded
    // to the server
    klov.setKlovUrl("http://" + sExtentReportServer + ":" + sExtentReportServerPort);

    // initialize ExtentReports and attach the HtmlReporter
    extent = new ExtentReports();
    extentnew = new ExtentReports();

    // initialize the HtmlReporter
    htmlReporter = new ExtentHtmlReporter(sHtmlReportName + ".html");
    // htmlReporter.loadXMLConfig("extent-config.xml"); //you can
    // attach only HtmlReporter

// //extent.attachReporter(htmlReporter);
// extent.attachReporter(htmlReporter);
//
// // attach all reporters
// extent.attachReporter(htmlReporter, klov);
//
// extent.setSystemInfo("User", sExtentAutomationUser);

    // new report steps add
     extentnew= ExtentManager.createInstance(sHtmlReportName + ".html");
    //extentnew.attachReporter(htmlReporter);
    extentnew.attachReporter(htmlReporter,klov);
    extentnew.setSystemInfo("User", sExtentAutomationUser);


}

public void CreateTest(String TestCaseName, String Description) {
    if (extent != null) {

       // test = extent.createTest(TestCaseName, Description);
      test=  ExtentTestManager.createTest(TestCaseName, Description);
    }

}

public void StepPass(String Description) {
    if (test != null)
        test.pass("Pass - " + Description);


}

public void StepFail(String Description) throws IOException {

    if (ExtentFailStepScreenPath != null) {

        if (test != null)
            test.fail("Fail - " + Description, MediaEntityBuilder
                    .createScreenCaptureFromPath(ExtentFailStepScreenPath.getAbsolutePath()).build());
    } else if (test != null)
        test.fail("Fail - " + Description);

}

public void FlushReport() {
   // if (extent != null)
    //    extent.flush();
   ExtentManager.getInstance().flush();

}

public void AssignCategory(String category) {
    if (test != null)
        test.assignCategory(category);
}

public void AssignAuthor(String author) {
    if (test != null)
        test.assignAuthor(author);
}

}
QuantumReportlistner.java

//
// Source code recreated from a .class file by IntelliJ IDEA
// (powered by Fernflower decompiler)
//

package com.quantum.java.pages;

import com.perfecto.reportium.WebDriverProvider;
import com.perfecto.reportium.exception.ReportiumException;
import com.perfecto.reportium.testng.ReportiumTestNgListener;
import com.perfecto.reportium.client.ReportiumClient;
import com.perfecto.reportium.client.ReportiumClientFactory;
import com.perfecto.reportium.model.Job;
import com.perfecto.reportium.model.PerfectoExecutionContext;
import com.perfecto.reportium.model.Project;
import com.perfecto.reportium.model.PerfectoExecutionContext.PerfectoExecutionContextBuilder;
import com.perfecto.reportium.test.TestContext;
import com.perfecto.reportium.test.result.TestResultFactory;
import com.qmetry.qaf.automation.core.CheckpointResultBean;
import com.qmetry.qaf.automation.core.ConfigurationManager;
import com.qmetry.qaf.automation.core.MessageTypes;
import com.qmetry.qaf.automation.core.QAFTestBase;
import com.qmetry.qaf.automation.core.TestBaseProvider;
import com.qmetry.qaf.automation.keys.ApplicationProperties;
import com.qmetry.qaf.automation.step.QAFTestStepListener;
import com.qmetry.qaf.automation.step.StepExecutionTracker;
import com.qmetry.qaf.automation.step.client.TestNGScenario;
import com.qmetry.qaf.automation.ui.WebDriverTestCase;
import com.quantum.listeners.PerfectoDriverListener;
import com.quantum.utils.ConsoleUtils;
import cucumber.runtime.RuntimeOptions;
import cucumber.runtime.RuntimeOptionsFactory;

import java.io.FileInputStream;
import java.io.IOException;
import java.util.Iterator;
import java.util.List;
import java.util.Objects;
import java.util.Properties;
import java.util.function.Function;
import java.util.stream.Collectors;
import org.apache.commons.lang3.ArrayUtils;
import org.openqa.selenium.WebDriver;
import org.testng.IInvokedMethod;
import org.testng.ITestContext;
import org.testng.ITestListener;
import org.testng.ITestResult;

public class QuantumReportListener extends ReportiumTestNgListener implements QAFTestStepListener, ITestListener {
public static final String PERFECTO_REPORT_CLIENT = "perfecto.report.client";

static ExtentReportHelper extentReportHelper;
static boolean isStepFailed= false;

public QuantumReportListener() throws Exception {
}

public static ReportiumClient getReportiumClientTest() {
    return (ReportiumClient)ConfigurationManager.getBundle().getObject("perfecto.report.client");
}

public void onStart(ITestContext context) {
    try {

	

        final Properties properties = new Properties();
        properties.load(new FileInputStream("resources/application.properties"));
        String dbserver = properties.getProperty("extentx.report.dbserver");
        String dbserverport = properties.getProperty("extentx.report.dbserverport");
        String reportname = properties.getProperty("extentx.report.reportname");
        String projectname = properties.getProperty("extentx.report.projectname");
        String reportserver = properties.getProperty("extentx.report.reportserver");
        String reportserverport = properties.getProperty("extentx.report.reportserverport");
        String user = properties.getProperty("extentx.report.user");


        extentReportHelper = new ExtentReportHelper(dbserver, dbserverport,
                reportname, projectname,
                reportserver, reportserverport, user);

    } catch (Exception e) {
        e.printStackTrace();
    }

    if(ConfigurationManager.getBundle().getString("remote.server", "").contains("perfecto")) {
        List<String> stepListeners = ConfigurationManager.getBundle().getList(ApplicationProperties.TESTSTEP_LISTENERS.key);
        if(!stepListeners.contains(this.getClass().getName())) {
            stepListeners.add(this.getClass().getName());
            ConfigurationManager.getBundle().setProperty(ApplicationProperties.TESTSTEP_LISTENERS.key, stepListeners);
        }

        if(ConfigurationManager.getBundle().getBoolean("perfecto.default.driver.listener", true)) {
            List<String> driverListeners = ConfigurationManager.getBundle().getList(ApplicationProperties.WEBDRIVER_COMMAND_LISTENERS.key);
            if(!driverListeners.contains(PerfectoDriverListener.class.getName())) {
                driverListeners.add(PerfectoDriverListener.class.getName());
                ConfigurationManager.getBundle().setProperty(ApplicationProperties.WEBDRIVER_COMMAND_LISTENERS.key, driverListeners);
            }
        }
    }

}

public void onTestStart(ITestResult testResult) {
    extentReportHelper.CreateTest(testResult.getTestName(), " Run TestCase " + testResult.getTestName() + " end to end .");

    if(ConfigurationManager.getBundle().getString("remote.server", "").contains("perfecto")) {
        this.createReportiumClient(testResult).testStart(testResult.getMethod().getMethodName(), new TestContext(testResult.getMethod().getGroups()));
    }

}

public void beforeInvocation(IInvokedMethod method, ITestResult testResult) {
    if(method.isTestMethod()) {
        ConsoleUtils.surroundWithSquare("TEST STARTED: " + this.getTestName(testResult) + (testResult.getParameters().length > 0?" [" + testResult.getParameters()[0] + "]":""));
    }

}

public void beforExecute(StepExecutionTracker stepExecutionTracker) {

    isStepFailed = false;
    String msg = "BEGIN STEP: " + stepExecutionTracker.getStep().getDescription();
    ConsoleUtils.logInfoBlocks(msg, ConsoleUtils.lower_block + " ", 10);
    logStepStart(stepExecutionTracker.getStep().getDescription());
}

public void afterExecute(StepExecutionTracker stepExecutionTracker) {


    logStepEnd();
    String msg = "END STEP: " + stepExecutionTracker.getStep().getDescription();
    ConsoleUtils.logInfoBlocks(msg, ConsoleUtils.upper_block + " ", 10);


    if (!isStepFailed)
        extentReportHelper.StepPass("Step " + stepExecutionTracker.getStep().getDescription() + " passed.");

}

public void onFailure(StepExecutionTracker stepExecutionTracker) {
    isStepFailed = true;

    try {
        extentReportHelper.StepFail("Step " + stepExecutionTracker.getStep().getDescription() + " failed.");
    } catch (IOException e) {
        e.printStackTrace();
    }
}

public void onTestSuccess(ITestResult testResult) {


    ReportiumClient client = getReportiumClientTest();
    if(null != client) {
        client.testStop(TestResultFactory.createSuccess());
        this.logTestEnd(testResult);
    }

}

public void onTestFailure(ITestResult testResult) {


    ReportiumClient client = getReportiumClientTest();
    if(null != client) {
        String failMsg = "";
        List<CheckpointResultBean> checkpointsList = ((QAFTestBase)TestBaseProvider.instance().get()).getCheckPointResults();
        Iterator var5 = checkpointsList.iterator();

        while(var5.hasNext()) {
            CheckpointResultBean result = (CheckpointResultBean)var5.next();
            if(result.getType().equals(MessageTypes.TestStepFail.toString())) {
                failMsg = failMsg + "Step:" + result.getMessage() + " failed\n";
            }
        }

        client.testStop(TestResultFactory.createFailure(failMsg.isEmpty()?"An error occurred":failMsg, testResult.getThrowable()));
        this.logTestEnd(testResult);
    }

}

public void onTestSkipped(ITestResult result) {
}

public void onTestFailedButWithinSuccessPercentage(ITestResult result) {
}

public void onFinish(ITestContext context) {

    extentReportHelper.FlushReport();


}

public static void logTestStep(String message) {
    System.out.println(".................stepExecutionTracker logstepstatus");
    try {
        getReportiumClientTest().testStep(message);
    } catch (Exception var2) {
        ;
    }

}

public static void logStepStart(String message) {

    try {
        getReportiumClientTest().stepStart(message);
    } catch (Exception var2) {
        ;
    }

}

public static void logStepEnd() {
    try {


        getReportiumClientTest().stepEnd();
    } catch (Exception var1) {
        ;
    }

}

private void logTestEnd(ITestResult testResult) {
    String endText = "TEST " + (testResult.isSuccess()?"PASSED":"FAILED") + ": ";
    this.addReportLink(testResult, getReportiumClientTest().getReportUrl());
    ConsoleUtils.logWarningBlocks("REPORTIUM URL: " + getReportiumClientTest().getReportUrl().replace("[", "%5B").replace("]", "%5D"));
    ConsoleUtils.surroundWithSquare(endText + this.getTestName(testResult) + (testResult.getParameters().length > 0?" [" + testResult.getParameters()[0] + "]":""));
}

protected String getTestName(ITestResult result) {
    return result.getTestName() == null?result.getMethod().getMethodName():result.getTestName();
}

protected ReportiumClient createReportiumClient(ITestResult testResult) {
    ReportiumClient reportiumClient = (new ReportiumClientFactory()).createLoggerClient();
    String suiteName = testResult.getTestContext().getSuite().getName();
    String prjName = ConfigurationManager.getBundle().getString("project.name", suiteName);
    String prjVer = ConfigurationManager.getBundle().getString("project.ver", "1.0");
    String xmlTestName = testResult.getTestContext().getName();
    Object testInstance = testResult.getInstance();
    WebDriver driver = null;
    if(testInstance instanceof WebDriverTestCase) {
        driver = (WebDriver)((WebDriverTestCase)testInstance).getDriver();
    } else if(testInstance instanceof WebDriverProvider) {
        driver = ((WebDriverProvider)testInstance).getWebDriver();
    }

    if(driver != null) {
        PerfectoExecutionContext perfectoExecutionContext = (new PerfectoExecutionContextBuilder()).withProject(new Project(prjName, prjVer)).withContextTags(new String[]{suiteName, xmlTestName}).withJob(new Job(ConfigurationManager.getBundle().getString("JOB_NAME"), ConfigurationManager.getBundle().getInt("BUILD_NUMBER", 0))).withWebDriver(driver).build();
        reportiumClient = (new ReportiumClientFactory()).createPerfectoReportiumClient(perfectoExecutionContext);
    }

    ConfigurationManager.getBundle().setProperty("perfecto.report.client", reportiumClient);
    return reportiumClient;
}

protected String[] getTags(ITestResult testResult) {
    RuntimeOptions cucumberOptions = this.getCucumberOptions(testResult);
    List<String> optionsList = (List)cucumberOptions.getFilters().stream().map((object) -> {
        return Objects.toString(object, (String)null);
    }).collect(Collectors.toList());
    optionsList.addAll(cucumberOptions.getFeaturePaths());
    optionsList.addAll(cucumberOptions.getGlue());
    return (String[])ArrayUtils.addAll(super.getTags(testResult), optionsList.toArray(new String[optionsList.size()]));
}

private RuntimeOptions getCucumberOptions(ITestResult testResult) {
    try {
        return (new RuntimeOptionsFactory(Class.forName(testResult.getTestClass().getName()))).create();
    } catch (ClassNotFoundException var3) {
        var3.printStackTrace();
        return null;
    }
}

private void addReportLink(ITestResult result, String url) {
    ((TestNGScenario)result.getMethod()).getMetaData().put("Perfecto-report", "<a href=\"" + url + "\" target=\"_blank\">view</a>");
}

private void reportTestEnd(ITestResult testResult) {
    int status = testResult.getStatus();
    ReportiumClient client = this.getReportiumClient();
    if (client != null) {
        switch(status) {
            case 1:
            case 4:
                client.testStop(TestResultFactory.createSuccess());
                break;
            case 2:
                client.testStop(TestResultFactory.createFailure(testResult.getThrowable()));
            case 3:
                break;
            case 16:
            default:
                throw new ReportiumException("Unexpected status " + status);
        }
    }

}

}
Testng xml

<test name="Demo Test" enabled="true">
    <parameter name="driver.name" value="chromedriver"></parameter>
    <parameter name= "webdriver.chrome.driver" value="E:/QuantumFrameWork_Examples/AllBrowsers/chromedriver.exe"></parameter>
    <!--<parameter name="driver.capabilities.platformName" value="Windows"></parameter> -->
    <groups>
        <run>
            <include name="@Version" />
        </run>
    </groups>
    <classes>
        <class
                name="com.qmetry.qaf.automation.step.client.gherkin.GherkinScenarioFactory" />
    </classes>
</test>


<test name="RamanaTest" enabled="true">
    <parameter name="driver.name" value="iExplorerDriver"></parameter>
    <parameter name="system.webdriver.ie.driver" value="E:/QuantumFrameWork_Examples/AllBrowsers/IEDriverServer2.53.exe"></parameter>
    <!--<parameter name="driver.capabilities.platformName" value="Windows"></paramete> -->
    <groups>
        <run>
            <include name="@MyWeb" />
        </run>
    </groups>
    <classes>
        <class
                name="com.qmetry.qaf.automation.step.client.gherkin.GherkinScenarioFactory" />
    </classes>
</test>

For Parallel Testing the report generate in wrong . All steps added to last scenario