Best Cerberus-source code snippet using org.cerberus.event.impl.EventService.processEvent_CAMPAIGN_END
Source:EventService.java
...148 // We load the invariant lists that will be used when converting execution to JSON. This is also done only once per event triggered.149// prioritiesList = invariantService.readByIdName("PRIORITY");150// countriesList = invariantService.readByIdName("COUNTRY");151// environmentsList = invariantService.readByIdName("ENVIRONMENT");152 processEvent_CAMPAIGN_END(eventHook, tag2, ceberusEventMessage, prioritiesList, countriesList, environmentsList);153 }154 break;155 case EventHook.EVENTREFERENCE_TESTCASE_CREATE:156 case EventHook.EVENTREFERENCE_TESTCASE_DELETE:157 case EventHook.EVENTREFERENCE_TESTCASE_UPDATE:158 TestCase testCase1 = (TestCase) object1;159 String originalTest = (String) object2;160 String originalTestcase = (String) object3;161 if (eval_NoFilter(eventHook.getObjectKey1(), eventHook.getObjectKey2())162 || eval_TestFolder_Filter(eventHook.getObjectKey1(), eventHook.getObjectKey2(), testCase1.getTest())163 || eval_Testcase_Filter(eventHook.getObjectKey1(), eventHook.getObjectKey2(), testCase1.getTest(), testCase1.getTestcase())) {164 processEvent_TESTCASE(eventHook, testCase1, originalTest, originalTestcase, ceberusEventMessage);165 }166 break;167 }168 }169 }170 } catch (CerberusException | JSONException | ParseException ex) {171 LOG.error(ex, ex);172 }173 return new MessageEvent(MessageEventEnum.GENERIC_OK);174 }175 private boolean eval_NoFilter(String obj1, String obj2) {176 if (StringUtil.isNullOrEmpty(obj2) && StringUtil.isNullOrEmpty(obj1)) {177 return true;178 }179 return false;180 }181 private boolean eval_TestFolder_Filter(String obj1, String obj2, String testFolder) {182 if (!StringUtil.isNullOrEmpty(obj2)) {183 return false;184 }185 if (!StringUtil.isNullOrEmpty(obj1) && obj1.equals(testFolder)) {186 return true;187 }188 return false;189 }190 private boolean eval_Testcase_Filter(String obj1, String obj2, String testFolder, String testcase) {191 if (StringUtil.isNullOrEmpty(obj1) || StringUtil.isNullOrEmpty(obj2)) {192 return false;193 }194 if (obj1.equals(testFolder) && obj2.equals(testcase)) {195 return true;196 }197 return false;198 }199 private boolean eval_Campaign_Filter(String obj1, String obj2, String campaign) {200 if (!StringUtil.isNullOrEmpty(obj2)) {201 return false;202 }203 if (!StringUtil.isNullOrEmpty(obj1) && obj1.equals(campaign)) {204 return true;205 }206 return false;207 }208 private void processEvent_CAMPAIGN_START(EventHook eventHook, Tag tag, JSONObject ceberusEventMessage) {209 LOG.debug("EventHook Processing '" + eventHook.getEventReference() + "' with connector '" + eventHook.getHookConnector() + "' to '" + eventHook.getHookRecipient() + "'");210 switch (eventHook.getHookConnector()) {211 case EventHook.HOOKCONNECTOR_EMAIL:212 if (!StringUtil.isNullOrEmpty(eventHook.getHookRecipient())) {213 LOG.debug("Generating and Sending an EMail Notification to : " + eventHook.getHookRecipient());214 Email email = null;215 try {216 email = emailGenerationService.generateNotifyStartTagExecution(tag, eventHook.getHookRecipient());217 emailService.sendHtmlMail(email);218 } catch (Exception ex) {219 LOG.warn("Exception generating email for '" + eventHook.getEventReference() + "'", ex);220 }221 }222 break;223 case EventHook.HOOKCONNECTOR_SLACK:224 if (!StringUtil.isNullOrEmpty(eventHook.getHookRecipient())) {225 LOG.debug("Generating and Sending a Slack Notification to : '" + eventHook.getHookRecipient() + "'");226 try {227 JSONObject slackMessage = slackGenerationService.generateNotifyStartTagExecution(tag, eventHook.getHookChannel());228 slackService.sendSlackMessage(slackMessage, eventHook.getHookRecipient());229 } catch (Exception ex) {230 LOG.warn("Exception generating slack notification for '" + eventHook.getEventReference() + "'", ex);231 }232 }233 break;234 case EventHook.HOOKCONNECTOR_GENERIC:235 if (!StringUtil.isNullOrEmpty(eventHook.getHookRecipient())) {236 LOG.debug("Generating and Sending a Generic Notification to : '" + eventHook.getHookRecipient() + "'");237 try {238 JSONObject message = webCallGenerationService.generateNotifyStartTagExecution(tag, ceberusEventMessage);239 webcallService.sendWebcallMessage(message, eventHook.getHookRecipient());240 } catch (Exception ex) {241 LOG.warn("Exception Generic notification for '" + eventHook.getEventReference() + "'", ex);242 }243 }244 break;245 case EventHook.HOOKCONNECTOR_TEAMS:246 if (!StringUtil.isNullOrEmpty(eventHook.getHookRecipient())) {247 LOG.debug("Generating and Sending a Teams Notification to : '" + eventHook.getHookRecipient() + "'");248 try {249 JSONObject message = teamsGenerationService.generateNotifyStartTagExecution(tag);250 teamsService.sendTeamsMessage(message, eventHook.getHookRecipient());251 } catch (Exception ex) {252 LOG.warn("Exception generating slack notification for '" + eventHook.getEventReference() + "'", ex);253 }254 }255 break;256 case EventHook.HOOKCONNECTOR_GOOGLECHAT:257 if (!StringUtil.isNullOrEmpty(eventHook.getHookRecipient())) {258 LOG.debug("Generating and Sending a Google Chat Notification to : '" + eventHook.getHookRecipient() + "'");259 try {260 JSONObject message = chatGenerationService.generateNotifyStartTagExecution(tag);261 chatService.sendGoogleChatMessage(message, eventHook.getHookRecipient(), tag.getTag());262 } catch (Exception ex) {263 LOG.warn("Exception generating Google Chat notification for '" + eventHook.getEventReference() + "'", ex);264 }265 }266 break;267 default:268 LOG.warn("Event Hook Connector '" + eventHook.getHookConnector() + "' Not implemented for Event '" + eventHook.getEventReference() + "'");269 break;270 }271 }272 private void processEvent_CAMPAIGN_END(EventHook eventHook, Tag tag, JSONObject ceberusEventMessage, List<Invariant> prioritiesList, List<Invariant> countriesList, List<Invariant> environmentsList) {273 LOG.debug("EventHook Processing '" + eventHook.getEventReference() + "' with connector '" + eventHook.getHookConnector() + "' to '" + eventHook.getHookRecipient() + "'");274 switch (eventHook.getHookConnector()) {275 case EventHook.HOOKCONNECTOR_EMAIL:276 if (!StringUtil.isNullOrEmpty(eventHook.getHookRecipient())) {277 LOG.debug("Generating and Sending an EMail Notification to : " + eventHook.getHookRecipient());278 Email email = null;279 try {280 email = emailGenerationService.generateNotifyEndTagExecution(tag, eventHook.getHookRecipient());281 emailService.sendHtmlMail(email);282 } catch (Exception ex) {283 LOG.warn("Exception generating email for '" + eventHook.getEventReference() + "'", ex);284 }285 }286 break;...
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.
You could also refer to video tutorials over LambdaTest YouTube channel to get step by step demonstration from industry experts.
Get 100 minutes of automation test minutes FREE!!