var cacheTTL = 300; // timeout in minutes for cache entries variables.oConfig = arguments.config; // global configuration variables.instanceName = arguments.instanceName; logMessage("Starting BugLogListener (#instanceName#) service..."); // load settings variables.maxLogSize = arguments.config.getSetting("service.maxLogSize"); // load DAO Factory variables.oDAOFactory = createObject("component","bugLog.components.DAOFactory").init( variables.oConfig ); // load the finder objects variables.oAppFinder = createObject("component","bugLog.components.appFinder").init( variables.oDAOFactory.getDAO("application") ); variables.oHostFinder = createObject("component","bugLog.components.hostFinder").init( variables.oDAOFactory.getDAO("host") ); variables.oSeverityFinder = createObject("component","bugLog.components.severityFinder").init( variables.oDAOFactory.getDAO("severity") ); variables.oSourceFinder = createObject("component","bugLog.components.sourceFinder").init( variables.oDAOFactory.getDAO("source") ); variables.oUserFinder = createObject("component","bugLog.components.userFinder").init( variables.oDAOFactory.getDAO("user") ); // load the rule processor variables.oRuleProcessor = createObject("component","bugLog.components.ruleProcessor").init(); // create cache instances variables.oAppCache = createObject("component","bugLog.components.lib.cache.cacheService").init(50, cacheTTL, false); variables.oHostCache = createObject("component","bugLog.components.lib.cache.cacheService").init(50, cacheTTL, false); variables.oSeverityCache = createObject("component","bugLog.components.lib.cache.cacheService").init(10, cacheTTL, false); variables.oSourceCache = createObject("component","bugLog.components.lib.cache.cacheService").init(5, cacheTTL, false); variables.oUserCache = createObject("component","bugLog.components.lib.cache.cacheService").init(50, cacheTTL, false); // load scheduler variables.scheduler = createObject("component","bugLog.components.schedulerService").init( variables.oConfig, variables.instanceName ); // load the mailer service variables.mailerService = createObject("component","bugLog.components.MailerService").init( variables.oConfig ); // load rules loadRules(); // configure history purging configureHistoryPurging(); // configure the digest sender configureDigest(); // record the date at which the service started variables.startedOn = Now(); logMessage("BugLogListener Service (#instanceName#) Started"); var bean = arguments.entryBean; var oEntry = 0; var oApp = 0; var oHost = 0; var oSeverity = 0; var oSource = 0; var oDF = variables.oDAOFactory; // get autocreate settings var autoCreateApp = allowAutoCreate("application"); var autoCreateHost = allowAutoCreate("host"); var autoCreateSeverity = allowAutoCreate("severity"); var autoCreateSource = allowAutoCreate("source"); // extract related objects from bean oApp = getApplicationFromBean( bean, autoCreateApp ); oHost = getHostFromBean( bean, autoCreateHost ); oSeverity = getSeverityFromBean( bean, autoCreateSeverity ); oSource = getSourceFromBean( bean, autoCreateSource ); // create entry oEntry = createObject("component","bugLog.components.entry").init( oDF.getDAO("entry") ); oEntry.setDateTime(bean.getdateTime()); oEntry.setMessage(bean.getmessage()); oEntry.setApplicationID(oApp.getApplicationID()); oEntry.setSourceID(oSource.getSourceID()); oEntry.setSeverityID(oSeverity.getSeverityID()); oEntry.setHostID(oHost.getHostID()); oEntry.setExceptionMessage(bean.getexceptionMessage()); oEntry.setExceptionDetails(bean.getexceptionDetails()); oEntry.setCFID(bean.getcfid()); oEntry.setCFTOKEN(bean.getcftoken()); oEntry.setUserAgent(bean.getuserAgent()); oEntry.setTemplatePath(bean.gettemplate_Path()); oEntry.setHTMLReport(bean.getHTMLReport()); oEntry.setCreatedOn(bean.getReceivedOn()); // save entry oEntry.save(); // process rules variables.oRuleProcessor.processRules(bean, oEntry); // validate API if(getConfig().getSetting("service.requireAPIKey",false)) { if(arguments.apiKey eq "") { throw(message="Invalid API Key",type="bugLog.invalidAPIKey"); } var masterKey = getConfig().getSetting("service.APIKey"); if(arguments.apiKey neq masterKey) { var user = getUserByAPIKey(arguments.apiKey); if(!user.getIsAdmin() and arrayLen(user.getAllowedApplications())) { // key is good, but since the user is a non-admin // we need to validate the user can post bugs to the requested // application. var app = getApplicationFromBean( entryBean, false ); if(!user.isApplicationAllowed(app)) { throw(message="Application not allowed",type="applicationNotAllowed"); } } } } // validate application if(!allowAutoCreate("application")) { getApplicationFromBean( entryBean, false ); } // validate host if(!allowAutoCreate("host")) { getHostFromBean( entryBean, false ); } // validte severity if(!allowAutoCreate("severity")) { getSeverityFromBean( entryBean, false ); } // validate source if(!allowAutoCreate("source")) { getSourceFromBean( entryBean, false ); } return true; var key = ""; var bean = arguments.entryBean; var oApp = 0; var oDF = variables.oDAOFactory; key = bean.getApplicationCode(); try { // first we try to get it from the cache oApp = variables.oAppCache.retrieve( key ); } catch(cacheService.itemNotFound e) { // entry not in cache, so we get it from DB try { oApp = variables.oAppFinder.findByCode( key ); } catch(appFinderException.ApplicationCodeNotFound e) { // code does not exist, so we need to create it (if autocreate enabled) if(!arguments.createIfNeeded) throw(message="Invalid Application",type="invalidApplication"); oApp = createObject("component","bugLog.components.app").init( oDF.getDAO("application") ); oApp.setCode( key ); oApp.setName( key ); oApp.save(); } // store entry in cache variables.oAppCache.store( key, oApp ); } var key = ""; var bean = arguments.entryBean; var oHost = 0; var oDF = variables.oDAOFactory; key = bean.getHostName(); try { // first we try to get it from the cache oHost = variables.oHostCache.retrieve( key ); } catch(cacheService.itemNotFound e) { // entry not in cache, so we get it from DB try { oHost = variables.oHostFinder.findByName( key ); } catch(hostFinderException.HostNameNotFound e) { // code does not exist, so we need to create it (if autocreate enabled) if(!arguments.createIfNeeded) throw(message="Invalid Host",type="invalidHost"); oHost = createObject("component","bugLog.components.host").init( oDF.getDAO("host") ); oHost.setHostName(key); oHost.save(); } // store entry in cache variables.oHostCache.store( key, oHost ); } var key = ""; var bean = arguments.entryBean; var oSeverity = 0; var oDF = variables.oDAOFactory; key = bean.getSeverityCode(); try { // first we try to get it from the cache oSeverity = variables.oSeverityCache.retrieve( key ); } catch(cacheService.itemNotFound e) { // entry not in cache, so we get it from DB try { oSeverity = variables.oSeverityFinder.findByCode( key ); } catch(severityFinderException.codeNotFound e) { // code does not exist, so we need to create it (if autocreate enabled) if(!arguments.createIfNeeded) throw(message="Invalid Severity",type="invalidSeverity"); oSeverity = createObject("component","bugLog.components.severity").init( oDF.getDAO("severity") ); oSeverity.setCode( key ); oSeverity.setName( key ); oSeverity.save(); } // store entry in cache variables.oSeverityCache.store( key, oSeverity ); } var oUser = 0; try { // first we try to get it from the cache oUser = variables.oUserCache.retrieve( apiKey ); } catch(cacheService.itemNotFound e) { // entry not in cache, so we get it from DB try { oUser = variables.oUserFinder.findByAPIKey( apiKey ); var qryUserApps = oDAOFactory.getDAO("userApplication").search(userID = oUser.getUserID()); var apps = oAppFinder.findByIDList(valueList(qryUserApps.applicationID)); oUser.setAllowedApplications(apps); } catch(sourceFinderException.usernameNotFound e) { // code does not exist, so we need to create it (if autocreate enabled) throw(message="Invalid API Key",type="bugLog.invalidAPIKey"); } // store entry in cache variables.oUserCache.store( key, oUser ); } return oUser; var key = ""; var bean = arguments.entryBean; var oSource = 0; var oDF = variables.oDAOFactory; key = bean.getSourceName(); try { // first we try to get it from the cache oSource = variables.oSourceCache.retrieve( key ); } catch(cacheService.itemNotFound e) { // entry not in cache, so we get it from DB try { oSource = variables.oSourceFinder.findByName( key ); } catch(sourceFinderException.codeNotFound e) { // code does not exist, so we need to create it (if autocreate enabled) if(!arguments.createIfNeeded) throw(message="Invalid Source",type="invalidSource"); oSource = createObject("component","bugLog.components.source").init( oDF.getDAO("source") ); oSource.setName( key ); oSource.save(); } // store entry in cache variables.oSourceCache.store( key, oSource ); } var oRule = 0; var oExtensionsService = 0; var aRules = arrayNew(1); var i = 0; var dao = 0; var thisRule = 0; // clear all existing rules variables.oRuleProcessor.flushRules(); // get the rule definitions from the extensions service dao = variables.oDAOFactory.getDAO("extension"); oExtensionsService = createObject("component","bugLog.components.extensionsService").init( dao ); aRules = oExtensionsService.getRules(); // create rule objects and load them into the rule processor for(i=1; i lte arrayLen(aRules);i=i+1) { thisRule = aRules[i]; if(thisRule.enabled) { oRule = thisRule.instance .setListener(this) .setDAOFactory( variables.oDAOFactory ) .setMailerService( variables.mailerService ); // add rule to processor variables.oRuleProcessor.addRule(oRule); } }