KaneAI - World’s First E2E Software Testing Agent.Book a Demo Join TestMu Conference

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

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

Source:TestSuiteService.java

...74    testSuite = this.repository.save(testSuite);75    testSuite.setTestCaseIds(testCaseIds);76    tagService.updateTags(testSuite.getTags(), TagType.TEST_SUITE, testSuite.getId());77    this.handleTestCaseMappings(testSuite);78    publishEvent(testSuite, EventType.CREATE);79    return testSuite;80  }81  public TestSuite update(TestSuite testSuite) throws TestsigmaException {82    List<Long> testCaseIds = testSuite.getTestCaseIds();83    List<String> tagNames = testSuite.getTags();84    List<Long> prereq = new ArrayList<>();85    prereq.add(testSuite.getId());86    validatePreRequisiteIsValid(testSuite, prereq);87    testSuite = this.repository.save(testSuite);88    testSuite.setTestCaseIds(testCaseIds);89    testSuite.setTags(tagNames);90    if (testSuite.getTags() != null)91      tagService.updateTags(testSuite.getTags(), TagType.TEST_SUITE, testSuite.getId());92    this.handleTestCaseMappings(testSuite);93    publishEvent(testSuite, EventType.UPDATE);94    return testSuite;95  }96  public void handlePrequisiteChange(TestSuite testSuite){97    this.suiteMappingService.handlePreRequisiteChange(testSuite);98  }99  private void validatePreRequisiteIsValid(TestSuite testSuite, List<Long> preReqList) throws TestsigmaException {100    Long preRequsiteId = testSuite.getPreRequisite();101    if (preRequsiteId != null) {102      if (preReqList.size() > 5) {103        log.debug("Testsuite Prerequisite hierarchy is more than 5,Prerequisite IDs:" + preReqList);104        throw new TestsigmaException("Prerequisite hierarchy crossed the allowed limit of 5");105      } else if (preReqList.contains(testSuite.getPreRequisite())) {106        log.debug("Cyclic dependency for Testsuite prerequisites found for Testsuite:" + testSuite);107        throw new TestsigmaException("Prerequisite to the Testsuite is not valid. This prerequisite causes cyclic dependencies for Testsuites.");108      }109      preReqList.add(preRequsiteId);110      TestSuite preReqTestSuite = find(preRequsiteId);111      if (preReqTestSuite.getPreRequisite() != null) {112        validatePreRequisiteIsValid(preReqTestSuite, preReqList);113      }114    } else {115      return;116    }117  }118  public TestSuite updateSuite(TestSuite testSuite) {119    testSuite = this.repository.save(testSuite);120    publishEvent(testSuite, EventType.UPDATE);121    return testSuite;122  }123  public void destroy(Long id) throws ResourceNotFoundException {124    TestSuite testSuite = this.find(id);125    publishEvent(testSuite, EventType.DELETE);126    this.repository.deleteById(id);127  }128  public void handleTestCaseMappings(TestSuite testSuite) {129    int position = 0;130    List<SuiteTestCaseMapping> newMappings = new ArrayList<>();131    List<SuiteTestCaseMapping> updatedMappings = new ArrayList<>();132    this.cleanupOrphanCaseMappings(testSuite);133    List<SuiteTestCaseMapping> mappings = this.suiteTestCaseMappingRepository.findBySuiteIdAndTestCaseIds(testSuite.getId(), testSuite.getTestCaseIds());134    for (Long testCaseId : testSuite.getTestCaseIds()) {135      SuiteTestCaseMapping suiteTestCaseMapping = new SuiteTestCaseMapping();136      Optional<SuiteTestCaseMapping> existing = mappings.stream().filter(mapping -> mapping.getTestCaseId().equals(testCaseId)).findFirst();137      position++;138      if (existing.isPresent()) {139        suiteTestCaseMapping = existing.get();140        if (!suiteTestCaseMapping.getPosition().equals(position)) {141          suiteTestCaseMapping.setPosition(position);142          suiteTestCaseMapping = this.suiteTestCaseMappingService.update(suiteTestCaseMapping);143          updatedMappings.add(suiteTestCaseMapping);144        }145      } else {146        suiteTestCaseMapping.setSuiteId(testSuite.getId());147        suiteTestCaseMapping.setTestCaseId(testCaseId);148        suiteTestCaseMapping.setPosition(position);149        suiteTestCaseMapping = this.suiteTestCaseMappingService.add(suiteTestCaseMapping);150        newMappings.add(suiteTestCaseMapping);151      }152    }153    testSuite.setUpdatedTestCases(updatedMappings);154    testSuite.setAddedTestCases(newMappings);155  }156  private void cleanupOrphanCaseMappings(TestSuite testSuite) {157    List<SuiteTestCaseMapping> suiteTestCaseMappings = this.suiteTestCaseMappingService.findAllBySuiteId(testSuite.getId());158    List<Long> existingCaseIds = suiteTestCaseMappings.stream().map(SuiteTestCaseMapping::getTestCaseId).collect(Collectors.toList());159    existingCaseIds.removeAll(testSuite.getTestCaseIds());160    if (existingCaseIds.size() > 0) {161      this.deleteAllBySuiteIdAndCaseIds(testSuite, existingCaseIds);162      List<Long> testCaseIds = testSuite.getTestCaseIds();163      testCaseIds.removeAll(existingCaseIds);164      testSuite.setTestCaseIds(testCaseIds);165    }166  }167  private void deleteAllBySuiteIdAndCaseIds(TestSuite suite, List<Long> existingCaseIds) {168    List<SuiteTestCaseMapping> mappings = this.suiteTestCaseMappingRepository.findBySuiteIdAndTestCaseIds(suite.getId(), existingCaseIds);169    suite.setRemovedTestCases(mappings);170    this.suiteTestCaseMappingService.deleteAll(mappings);171  }172  public void bulkDelete(Long[] ids) throws Exception {173    Boolean allIdsDeleted = true;174    TestPlanSpecificationsBuilder builder = new TestPlanSpecificationsBuilder();175    for (Long id : ids) {176      List<SearchCriteria> params = new ArrayList<>();177      params.add(new SearchCriteria("suiteId", SearchOperation.EQUALITY, id));178      builder.setParams(params);179      Specification<TestPlan> spec = builder.build();180      Page<TestPlan> linkedTestPlans = testPlanService.findAll(spec, PageRequest.of(0, 1));181      if (linkedTestPlans.getTotalElements() == 0) {182        this.destroy(id);183      } else {184        allIdsDeleted = false;185      }186    }187    if (!allIdsDeleted) {188      throw new DataIntegrityViolationException("dataIntegrityViolationException");189    }190  }191  public void publishEvent(TestSuite testSuite, EventType eventType) {192    TestSuiteEvent<TestSuite> event = createEvent(testSuite, eventType);193    log.info("Publishing event - " + event.toString());194    applicationEventPublisher.publishEvent(event);195  }196  public TestSuiteEvent<TestSuite> createEvent(TestSuite testSuite, EventType eventType) {197    TestSuiteEvent<TestSuite> event = new TestSuiteEvent<>();198    event.setEventData(testSuite);199    event.setEventType(eventType);200    return event;201  }202  public void export(BackupDTO backupDTO) throws IOException, ResourceNotFoundException {203    if (!backupDTO.getIsSuitesEnabled()) return;204    writeXML("test_suites", backupDTO, PageRequest.of(0, 25));205  }206  public Specification<TestSuite> getExportXmlSpecification(BackupDTO backupDTO) {207    SearchCriteria criteria = new SearchCriteria("workspaceVersionId", SearchOperation.EQUALITY, backupDTO.getWorkspaceVersionId());208    List<SearchCriteria> params = new ArrayList<>();...

Source:AgentService.java

...87    return agentRepository.findAll(specification, pageable);88  }89  public void destroy(@NonNull Agent agent) {90    List<AgentDevice> agentDevices = agentDeviceService.findAllByAgent(agent.getId());91    agentDevices.forEach(agentDevice -> agentDeviceService.publishEvent(agentDevice, EventType.DELETE));92    agentRepository.delete(agent);93    publishEvent(agent, EventType.DELETE);94  }95  public boolean isAgentActive(Long agentId) throws ResourceNotFoundException {96    Agent agent = find(agentId);97    long lastUpdatedTime = agent.getUpdatedDate().getTime();98    long currentTime = java.lang.System.currentTimeMillis();99    return currentTime - lastUpdatedTime <= 10 * 60 * 1000;100  }101  public Agent findByUniqueId(@NonNull String uniqueId) throws ResourceNotFoundException {102    Agent agent = null;103    try {104      agent = agentRepository.findByUniqueId(uniqueId);105    } catch (Exception e) {106      log.error(e.getMessage(), e);107    }108    if (agent == null) {109      throw new ResourceNotFoundException("Agent is not found");110    }111    return agent;112  }113  public Agent update(@NonNull AgentRequest agentRequest, String uniqueId) throws ResourceNotFoundException {114    boolean isRegistered = false;115    Agent db = findByUniqueId(uniqueId);116    if (db.getOsType() != null) {117      isRegistered = true;118    }119    mapper.map(agentRequest, db);120    db.setUpdatedDate(new Timestamp(java.lang.System.currentTimeMillis()));121    db = agentRepository.save(db);122    if (!isRegistered && db.getOsType() != null) {123      publishEvent(db, EventType.CREATE);124    }125    return db;126  }127  public void publishEvent(Agent agent, EventType eventType) {128    AgentEvent<Agent> event = createEvent(agent, eventType);129    log.info("Publishing event - " + event.toString());130    applicationEventPublisher.publishEvent(event);131  }132  public AgentEvent<Agent> createEvent(Agent agent, EventType eventType) {133    AgentEvent<Agent> event = new AgentEvent<>();134    event.setEventData(agent);135    event.setEventType(eventType);136    return event;137  }138  public void export(BackupDTO backupDTO) throws IOException, ResourceNotFoundException {139    if (!backupDTO.getIsAgentEnabled()) return;140    log.debug("backup process for agent initiated");141    writeXML("agent", backupDTO, PageRequest.of(0, 25));142    log.debug("backup process for agent completed");143  }144  @Override...

publishEvent

Using AI Code Generation

1package com.testsigma.service;2import org.apache.commons.logging.Log;3import org.apache.commons.logging.LogFactory;4import org.springframework.context.ApplicationEvent;5import org.springframework.context.ApplicationEventPublisher;6import org.springframework.context.ApplicationEventPublisherAware;7import org.springframework.stereotype.Component;8public class TestPlanService implements ApplicationEventPublisherAware {9private static final Log log = LogFactory.getLog(TestPlanService.class);10private ApplicationEventPublisher publisher;11public void setApplicationEventPublisher(ApplicationEventPublisher publisher) {12this.publisher = publisher;13}14public void publishEvent(ApplicationEvent event) {15log.info("Publishing event: " + event);16publisher.publishEvent(event);17}18}19package com.testsigma.service;20import org.springframework.beans.factory.annotation.Autowired;21import org.springframework.context.ApplicationEvent;22import org.springframework.stereotype.Component;23public class TestPlanPublisher {24private TestPlanService service;25public void publishEvent(ApplicationEvent event) {26service.publishEvent(event);27}28}29package com.testsigma.service;30import org.springframework.beans.factory.annotation.Autowired;31import org.springframework.stereotype.Component;32public class TestPlanEventPublisher {33private TestPlanPublisher publisher;34public void publishEvent() {35publisher.publishEvent(new TestPlanEvent(this, "Test Plan Event"));36}37}38package com.testsigma.service;39import org.springframework.beans.factory.annotation.Autowired;40import org.springframework.stereotype.Component;41public class TestPlanEventPublisherClient {42private TestPlanEventPublisher publisher;43public void publishEvent() {44publisher.publishEvent();45}46}47package com.testsigma.service;48import org.springframework.beans.factory.annotation.Autowired;49import org.springframework.stereotype.Component;50public class TestPlanEventPublisherClient {51private TestPlanEventPublisher publisher;52public void publishEvent() {53publisher.publishEvent();54}55}56package com.testsigma.service;57import org.springframework.beans.factory.annotation.Autowired;58import org.springframework.stereotype.Component;59public class TestPlanEventPublisherClient {60private TestPlanEventPublisher publisher;61public void publishEvent()

publishEvent

Using AI Code Generation

1import com.testsigma.service.TestPlanService;2import com.testsigma.service.TestPlanServiceFactory;3import com.testsigma.service.TestPlanServiceFactoryImpl;4import com.testsigma.service.TestPlanServiceException;5public class 2 {6    public static void main(String[] args) {7        TestPlanServiceFactory testPlanServiceFactory = new TestPlanServiceFactoryImpl();8        TestPlanService testPlanService = testPlanServiceFactory.getTestPlanService();9        try {10            testPlanService.publishEvent("TestPlan", "TestPlanEvent", "TestPlanEventData");11        } catch (TestPlanServiceException e) {12            e.printStackTrace();13        }14    }15}

publishEvent

Using AI Code Generation

1TestPlanService testPlanService = new TestPlanService();2testPlanService.publishEvent("TestPlan", "testPlanId", "eventName", "eventData");3TestPlanService testPlanService = new TestPlanService();4testPlanService.publishEvent("TestPlan", "testPlanId", "eventName", "eventData");5TestPlanService testPlanService = new TestPlanService();6testPlanService.publishEvent("TestPlan", "testPlanId", "eventName", "eventData");7TestPlanService testPlanService = new TestPlanService();8testPlanService.publishEvent("TestPlan", "testPlanId", "eventName", "eventData");9TestPlanService testPlanService = new TestPlanService();10testPlanService.publishEvent("TestPlan", "testPlanId", "eventName", "eventData");11TestPlanService testPlanService = new TestPlanService();12testPlanService.publishEvent("TestPlan", "testPlanId", "eventName", "eventData");13TestPlanService testPlanService = new TestPlanService();14testPlanService.publishEvent("TestPlan", "testPlanId", "eventName", "eventData");15TestPlanService testPlanService = new TestPlanService();16testPlanService.publishEvent("TestPlan", "testPlanId", "eventName", "eventData");17TestPlanService testPlanService = new TestPlanService();18testPlanService.publishEvent("TestPlan", "testPlanId", "eventName", "eventData");

publishEvent

Using AI Code Generation

1package com.testsigma.service;2public class TestPlanService {3  public void publishEvent(String event) {4  }5}6package com.testsigma.service;7public class TestPlanService {8  public void publishEvent(String event) {9  }10}11package com.testsigma.service;12public class TestPlanService {13  public void publishEvent(String event) {14  }15}16package com.testsigma.service;17public class TestPlanService {18  public void publishEvent(String event) {19  }20}21package com.testsigma.service;22public class TestPlanService {23  public void publishEvent(String event) {24  }25}26package com.testsigma.service;27public class TestPlanService {28  public void publishEvent(String event) {29  }30}31package com.testsigma.service;32public class TestPlanService {33  public void publishEvent(String event) {34  }35}36package com.testsigma.service;37public class TestPlanService {38  public void publishEvent(String event) {39  }40}41package com.testsigma.service;42public class TestPlanService {43  public void publishEvent(String event)

publishEvent

Using AI Code Generation

1package com.testsigma.service;2import com.testsigma.service.TestPlanService;3import com.testsigma.service.TestPlanServiceService;4import com.testsigma.service.TestPlanEvent;5import com.testsigma.service.TestPlanEventResult;6public class TestPlanServicePublishEvent {7    public static void main(String[] args) {8        TestPlanServiceService service = new TestPlanServiceService();9        TestPlanService port = service.getTestPlanServicePort();10        TestPlanEvent event = new TestPlanEvent();11        event.setTestPlanId("testPlanId");12        event.setTestPlanName("testPlanName");13        event.setTestPlanVersion("testPlanVersion");14        event.setTestPlanType("testPlanType");15        event.setStartTime("2014-10-10T10:10:10.100");16        event.setEndTime("2014-10-10T10:10:10.100");17        event.setTestPlanStatus("testPlanStatus");18        event.setTestPlanResult("testPlanResult");19        event.setTestPlanResultDetails("testPlanResultDetails");20        event.setTestPlanResultLink("testPlanResultLink");21        event.setTestPlanResultAttachment("testPlanResultAttachment");22        event.setTestPlanResultAttachmentLink("testPlanResultAttachmentLink");23        event.setTestPlanResultAttachmentName("testPlanResultAttachmentName");24        event.setTestPlanResultAttachmentType("testPlanResultAttachmentType");25        event.setTestPlanResultAttachmentSize("testPlanResultAttachmentSize");26        event.setTestPlanResultAttachmentDescription("testPlanResultAttachmentDescription");27        event.setTestPlanResultAttachmentThumbnail("testPlanResultAttachmentThumbnail");28        event.setTestPlanResultAttachmentThumbnailLink("testPlanResultAttachmentThumbnailLink");29        event.setTestPlanResultAttachmentThumbnailName("testPlanResultAttachmentThumbnailName");30        event.setTestPlanResultAttachmentThumbnailType("testPlanResultAttachmentThumbnailType");31        event.setTestPlanResultAttachmentThumbnailSize("testPlanResultAttachmentThumbnailSize");32        event.setTestPlanResultAttachmentThumbnailDescription("testPlanResultAttachmentThumbnailDescription");33        event.setTestPlanResultAttachmentThumbnailThumbnail("testPlanResultAttachmentThumbnailThumbnail");34        event.setTestPlanResultAttachmentThumbnailThumbnailLink("testPlanResultAttachmentThumbnailThumbnailLink");35        event.setTestPlanResultAttachmentThumbnailThumbnailName("testPlanResultAttachmentThumbnailThumbnailName");

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.