Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

How to use publishEvent method of com.testsigma.service.TestPlanResultService class

Best Testsigma code snippet using com.testsigma.service.TestPlanResultService.publishEvent

Source:TestPlanResultService.java

...49    return this.testPlanResultRepository.findByTestPlanIdAndStatusIsNot(testPlanId, status);50  }51  public TestPlanResult create(TestPlanResult testPlanResult) {52    testPlanResult = this.testPlanResultRepository.save(testPlanResult);53    publishEvent(testPlanResult, EventType.CREATE);54    return testPlanResult;55  }56  public TestPlanResult update(TestPlanResult testPlanResult) {57    testPlanResult = this.testPlanResultRepository.save(testPlanResult);58    publishEvent(testPlanResult, EventType.UPDATE);59    return testPlanResult;60  }61  public TestPlanResult updateExecutionResult(ResultConstant maxResult, TestPlanResult testPlanResult) {62    String message = ResultConstant.SUCCESS.equals(maxResult) ? AutomatorMessages.MSG_EXECUTION_COMPLETED :63      (ResultConstant.STOPPED.equals(maxResult)) ? AutomatorMessages.MSG_TEST_PLAN_STOPPED :64        AutomatorMessages.MSG_EXECUTION_FAILURE;65    Timestamp currentTime = new Timestamp(System.currentTimeMillis());66    testPlanResult.setResult(maxResult);67    testPlanResult.setStatus(StatusConstant.STATUS_COMPLETED);68    testPlanResult.setMessage(message);69    testPlanResult.setStartTime(ObjectUtils.defaultIfNull(testPlanResult.getStartTime(), currentTime));70    testPlanResult.setEndTime(currentTime);71    testPlanResult.setDuration(testPlanResult.getEndTime().getTime() - testPlanResult.getStartTime().getTime());72    testPlanResult = update(testPlanResult);73    updateResultCounts(testPlanResult);74    publishNotificationEvent(testPlanResult, EventType.UPDATE);75    return testPlanResult;76  }77  public void rerun(AbstractTestPlan testPlan, TestPlanResult testPlanResult) throws Exception {78    //Check if eligible for rerun. If its already a rerun(Manual or automatic) then rerun parentId will be referring to an existing run.79    if (isReRunEligible(testPlan, testPlanResult)) {80      log.info(String.format("Re-run Test Plan :- Execution - %s, ExecutionResult - %s,  ReRunType - %s",81        testPlan.getId(), testPlanResult.getId(), testPlan.getReRunType()));82      AgentExecutionService agentExecutionService = agentExecutionServiceObjectFactory.getObject();83      agentExecutionService.setTestPlan(testPlan);84      agentExecutionService.setIsReRun(Boolean.TRUE);85      agentExecutionService.setReRunType(testPlan.getReRunType());86      agentExecutionService.setParentTestPlanResultId(testPlanResult.getId());87      agentExecutionService.start();88    } else {89      log.info(String.format("Test Plan not eligible for re-run :- Execution - %s, ExecutionResult - %s,  ReRunType - %s",90        testPlan.getId(), testPlanResult.getId(), testPlan.getReRunType()));91    }92  }93  private boolean isReRunEligible(AbstractTestPlan testPlan, TestPlanResult testPlanResult) {94    return (testPlanResult.getStatus() == StatusConstant.STATUS_COMPLETED95      && testPlan.getReRunType() != ReRunType.NONE96      && testPlan.getReRunType() != null97      && testPlanResult.getReRunParentId() == null98      && testPlanResult.getResult() != ResultConstant.STOPPED99      && testPlanResult.getResult() != ResultConstant.SUCCESS);100  }101  public void updateResultCounts(TestPlanResult testPlanResult) {102    this.testPlanResultRepository.updateTotalTestCaseResultsCount(testPlanResult.getId());103    this.testPlanResultRepository.updatePassedTestCaseResultsCount(testPlanResult.getId());104    this.testPlanResultRepository.updateFailedTestCaseResultsCount(testPlanResult.getId());105    this.testPlanResultRepository.updateAbortedTestCaseResultsCount(testPlanResult.getId());106    this.testPlanResultRepository.updateNotExecutedTestCaseResultsCount(testPlanResult.getId());107    this.testPlanResultRepository.updateQueuedTestCaseResultsCount(testPlanResult.getId());108    this.testPlanResultRepository.updateStoppedTestCaseResultsCount(testPlanResult.getId());109  }110  public Page<TestPlanResult> findAll(Specification<TestPlanResult> spec, Pageable pageable) {111    return this.testPlanResultRepository.findAll(spec, pageable);112  }113  public void updateVisualResult(TestPlanResult testPlanResult, boolean visualResult) {114    this.testPlanResultRepository.updateVisualResult(testPlanResult.getId(), visualResult);115  }116  public List<TestPlanResult> countOngoingEnvironmentResultsGroupByExecutionResult() {117    return this.testPlanResultRepository.countOngoingEnvironmentResultsGroupByTestPlanResult(118      Arrays.asList(StatusConstant.STATUS_IN_PROGRESS, StatusConstant.STATUS_PRE_FLIGHT, StatusConstant.STATUS_QUEUED));119  }120  public void destroy(Long id) throws ResourceNotFoundException {121    TestPlanResult result = this.find(id);122    this.testPlanResultRepository.delete(result);123  }124  public void markTestPlanResultstatus(TestPlanResult testPlanResult, StatusConstant status, String message) {125    testPlanResult.setStatus(status);126    testPlanResult.setMessage(message);127    update(testPlanResult);128  }129  public void publishEvent(TestPlanResult testPlanResult, EventType eventType) {130    TestPlanResultEvent<TestPlanResult> event = createEvent(testPlanResult, eventType);131    log.info("Publishing event - " + event.toString());132    applicationEventPublisher.publishEvent(event);133  }134  public void publishNotificationEvent(TestPlanResult testPlanResult, EventType eventType) {135    TestPlanResultNotificationEvent<TestPlanResult> event = createNotificationEvent(testPlanResult, eventType);136    log.info("Publishing event - " + event.toString());137    applicationEventPublisher.publishEvent(event);138  }139  public TestPlanResultEvent<TestPlanResult> createEvent(TestPlanResult testPlanResult, EventType eventType) {140    TestPlanResultEvent<TestPlanResult> event = new TestPlanResultEvent<>();141    event.setEventData(testPlanResult);142    event.setEventType(eventType);143    return event;144  }145  public TestPlanResultNotificationEvent<TestPlanResult> createNotificationEvent(TestPlanResult testPlanResult,146                                                                                 EventType eventType) {147    TestPlanResultNotificationEvent<TestPlanResult> event = new TestPlanResultNotificationEvent<>();148    event.setEventData(testPlanResult);149    event.setEventType(eventType);150    return event;151  }...

publishEvent

Using AI Code Generation

1import com.testsigma.service.TestPlanResultService;2import com.testsigma.service.TestPlanResultServiceFactory;3import com.testsigma.service.model.TestPlanResultEvent;4import com.testsigma.service.model.TestPlanResultEventBuilder;5import com.testsigma.service.model.TestPlanResultStatus;6TestPlanResultService testPlanResultService = TestPlanResultServiceFactory.getTestPlanResultService();7TestPlanResultEvent testPlanResultEvent = new TestPlanResultEventBuilder()8        .withTestPlanResultStatus(TestPlanResultStatus.SUCCESS)9        .withTestPlanId("testPlanId")10        .withTestPlanName("testPlanName")11        .withTestPlanVersion("testPlanVersion")12        .withTestPlanRunId("testPlanRunId")13        .withTestPlanRunName("testPlanRunName")14        .withTestPlanRunUrl("testPlanRunUrl")15        .withTestPlanRunStatusUrl("testPlanRunStatusUrl")16        .withTestPlanRunResultUrl("testPlanRunResultUrl")17        .withTestPlanRunStartTime(System.currentTimeMillis())18        .withTestPlanRunEndTime(System.currentTimeMillis())19        .withTestPlanRunDuration(1000L)20        .withTestPlanRunProperties("testPlanRunProperties")21        .withTestPlanRunTags("testPlanRunTags")22        .withTestPlanRunEnvironment("testPlanRunEnvironment")23        .build();24testPlanResultService.publishEvent(testPlanResultEvent);25import com.testsigma.service.TestSuiteResultService;26import com.testsigma.service.TestSuiteResultServiceFactory;27import com.testsigma.service.model.TestSuiteResultEvent;28import com.testsigma.service.model.TestSuiteResultEventBuilder;29import com.testsigma.service.model.TestSuiteResultStatus;30TestSuiteResultService testSuiteResultService = TestSuiteResultServiceFactory.getTestSuiteResultService();31TestSuiteResultEvent testSuiteResultEvent = new TestSuiteResultEventBuilder()32        .withTestSuiteResultStatus(TestSuiteResultStatus.SUCCESS)33        .withTestSuiteId("testSuiteId")34        .withTestSuiteName("testSuiteName")35        .withTestSuiteVersion("testSuiteVersion")36        .withTestSuiteRunId("testSuiteRunId")37        .withTestSuiteRunName("testSuiteRunName")

publishEvent

Using AI Code Generation

1def testPlanResult = new TestPlanResult()2testPlanResult.setTestPlanId(1)3testPlanResult.setTestPlanName("test plan name")4testPlanResult.setTestPlanDescription("test plan description")5testPlanResult.setTestPlanStatus("test plan status")6testPlanResult.setTestPlanStartTime("test plan start time")7testPlanResult.setTestPlanEndTime("test plan end time")8testPlanResult.setTestPlanDuration(1)9testPlanResult.setTestPlanTotalTests(1)10testPlanResult.setTestPlanTotalPassedTests(1)11testPlanResult.setTestPlanTotalFailedTests(1)12testPlanResult.setTestPlanTotalSkippedTests(1)13testPlanResult.setTestPlanTotalBlockedTests(1)14testPlanResult.setTestPlanTotalNotExecutedTests(1)15testPlanResult.setTestPlanTotalInProgressTests(1)16testPlanResult.setTestPlanTotalUnknownTests(1)17testPlanResult.setTestPlanTotalTests(1)18testPlanResult.setTestPlanTotalPassedTests(1)19testPlanResult.setTestPlanTotalFailedTests(1)20testPlanResult.setTestPlanTotalSkippedTests(1)21testPlanResult.setTestPlanTotalBlockedTests(1)22testPlanResult.setTestPlanTotalNotExecutedTests(1)23testPlanResult.setTestPlanTotalInProgressTests(1)24testPlanResult.setTestPlanTotalUnknownTests(1)25testPlanResult.setTestPlanTotalPassedSteps(1)26testPlanResult.setTestPlanTotalFailedSteps(1)27testPlanResult.setTestPlanTotalSkippedSteps(1)28testPlanResult.setTestPlanTotalBlockedSteps(1)29testPlanResult.setTestPlanTotalNotExecutedSteps(1)30testPlanResult.setTestPlanTotalInProgressSteps(1)31testPlanResult.setTestPlanTotalUnknownSteps(1)32testPlanResult.setTestPlanTotalPassedSteps(1)33testPlanResult.setTestPlanTotalFailedSteps(1)34testPlanResult.setTestPlanTotalSkippedSteps(1)35testPlanResult.setTestPlanTotalBlockedSteps(1)36testPlanResult.setTestPlanTotalNotExecutedSteps(1)37testPlanResult.setTestPlanTotalInProgressSteps(1)38testPlanResult.setTestPlanTotalUnknownSteps(1)39testPlanResult.setTestPlanTotalPassedSteps(1)40testPlanResult.setTestPlanTotalFailedSteps(1

publishEvent

Using AI Code Generation

1def testPlanResultService = new com.testsigma.service.TestPlanResultService()2def testPlanResult = new com.testsigma.service.TestPlanResult()3testPlanResult.setTestPlanId("TestPlanId")4testPlanResult.setTestPlanName("TestPlanName")5testPlanResult.setTestPlanResultStatus("Passed")6testPlanResult.setTestPlanResultMessage("Test Plan Passed")7testPlanResultService.publishEvent(testPlanResult)8def testSuiteResultService = new com.testsigma.service.TestSuiteResultService()9def testSuiteResult = new com.testsigma.service.TestSuiteResult()10testSuiteResult.setTestSuiteId("TestSuiteId")11testSuiteResult.setTestSuiteName("TestSuiteName")12testSuiteResult.setTestSuiteResultStatus("Passed")13testSuiteResult.setTestSuiteResultMessage("Test Suite Passed")14testSuiteResultService.publishEvent(testSuiteResult)15def testCaseResultService = new com.testsigma.service.TestCaseResultService()16def testCaseResult = new com.testsigma.service.TestCaseResult()17testCaseResult.setTestCaseId("TestCaseId")

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.