rulesChecker.js 3.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081
  1. var Q = require('q');
  2. var debug = require('debug')('ylt:ruleschecker');
  3. var RulesChecker = function() {
  4. 'use strict';
  5. this.check = function(data, policies) {
  6. var results = {};
  7. debug('Starting checking rules');
  8. for (var metricName in policies) {
  9. var policy = policies[metricName];
  10. var rule;
  11. if (policy.tool &&
  12. data.toolsResults[policy.tool] &&
  13. data.toolsResults[policy.tool].metrics &&
  14. (data.toolsResults[policy.tool].metrics[metricName] || data.toolsResults[policy.tool].metrics[metricName] === 0)) {
  15. rule = {
  16. value: data.toolsResults[policy.tool].metrics[metricName],
  17. policy: policy
  18. };
  19. if (data.toolsResults[policy.tool].offenders &&
  20. data.toolsResults[policy.tool].offenders[metricName] &&
  21. data.toolsResults[policy.tool].offenders[metricName].length > 0) {
  22. rule.offenders = data.toolsResults[policy.tool].offenders[metricName];
  23. }
  24. rule.bad = rule.value > policy.isOkThreshold;
  25. rule.abnormal = policy.isAbnormalThreshold && rule.value >= policy.isAbnormalThreshold;
  26. // A value between 0 (bad) and 100 (very good).
  27. var score = (policy.isBadThreshold - rule.value) * 100 / (policy.isBadThreshold - policy.isOkThreshold);
  28. rule.score = Math.min(Math.max(Math.round(score), 0), 100);
  29. // A value between 0 (abnormal) and negative-infinity (your website is a blackhole)
  30. var abnormalityScore = (policy.isAbnormalThreshold - rule.value) * 100 / (policy.isAbnormalThreshold - policy.isOkThreshold);
  31. rule.abnormalityScore = Math.min(Math.round(abnormalityScore), 0);
  32. results[metricName] = rule;
  33. debug('Metric %s calculated. Score: %d', metricName, rule.score);
  34. } else if (policy.scoreFn) {
  35. debug('Custom score function for %s', metricName);
  36. // Custom score function
  37. rule = policy.scoreFn(data);
  38. // Check returned values (if the result is null, just don't save)
  39. if (rule) {
  40. rule.policy = {
  41. label: policy.label,
  42. message: policy.message
  43. };
  44. results[metricName] = rule;
  45. debug('Metric %s calculated. Score: %d', metricName, rule.score);
  46. } else {
  47. debug('Metric %s is null. Ignored.', metricName);
  48. }
  49. } else {
  50. debug('Metric %s not found for tool %s', metricName, policy.tool);
  51. }
  52. }
  53. debug('Rules checking finished');
  54. return results;
  55. };
  56. };
  57. module.exports = new RulesChecker();