mirror of
https://github.com/librenms/librenms.git
synced 2024-09-24 11:58:54 +00:00
Neil Lathwood
commit
836a91457c
197
alerts.php
197
alerts.php
@ -23,8 +23,8 @@
|
||||
* @subpackage Alerts
|
||||
*/
|
||||
|
||||
include("includes/defaults.inc.php");
|
||||
include("config.php");
|
||||
include_once("includes/defaults.inc.php");
|
||||
include_once("config.php");
|
||||
|
||||
$lock = false;
|
||||
if( file_exists($config['install_dir']."/.alerts.lock") ) {
|
||||
@ -36,33 +36,76 @@ if( file_exists($config['install_dir']."/.alerts.lock") ) {
|
||||
}
|
||||
|
||||
if( $lock === true ) {
|
||||
exit('Alreading running with PID '.$lpid."\r\n");
|
||||
exit(1);
|
||||
} else {
|
||||
file_put_contents($config['install_dir']."/.alerts.lock", getmypid());
|
||||
}
|
||||
|
||||
include("includes/definitions.inc.php");
|
||||
include("includes/functions.php");
|
||||
include_once($config['install_dir']."/includes/definitions.inc.php");
|
||||
include_once($config['install_dir']."/includes/functions.php");
|
||||
include_once($config['install_dir']."/includes/alerts.inc.php");
|
||||
|
||||
RunAlerts();
|
||||
if( !defined("TEST") ) {
|
||||
echo "Start: ".date('r')."\r\n";
|
||||
echo "RunFollowUp():\r\n";
|
||||
RunFollowUp();
|
||||
echo "RunAlerts():\r\n";
|
||||
RunAlerts();
|
||||
echo "End : ".date('r')."\r\n";
|
||||
}
|
||||
|
||||
unlink($config['install_dir']."/.alerts.lock");
|
||||
|
||||
/**
|
||||
* Run Follow-Up alerts
|
||||
* @return void
|
||||
*/
|
||||
function RunFollowUp() {
|
||||
global $config;
|
||||
foreach( dbFetchRows("SELECT alerts.device_id, alerts.rule_id, alerts.state FROM alerts WHERE alerts.state != 2 && alerts.open = 0") as $alert ) {
|
||||
$alert = dbFetchRow("SELECT alert_log.id,alert_log.rule_id,alert_log.device_id,alert_log.state,alert_log.details,alert_log.time_logged,alert_rules.rule,alert_rules.severity,alert_rules.extra,alert_rules.name FROM alert_log,alert_rules WHERE alert_log.rule_id = alert_rules.id && alert_log.device_id = ? && alert_log.rule_id = ? ORDER BY alert_log.id DESC LIMIT 1",array($alert['device_id'],$alert['rule_id']));
|
||||
$alert['details'] = json_decode(gzuncompress($alert['details']),true);
|
||||
$rextra = json_decode($alert['extra'],true);
|
||||
if( $rextra['invert'] ) {
|
||||
continue;
|
||||
}
|
||||
$chk = dbFetchRows(GenSQL($alert['rule']),array($alert['device_id']));
|
||||
$o = sizeof($alert['details']['rule']);
|
||||
$n = sizeof($chk);
|
||||
$ret = "Alert #".$alert['id'];
|
||||
$state = 0;
|
||||
if( $n > $o ) {
|
||||
$ret .= " Worsens";
|
||||
$state = 3;
|
||||
} elseif( $n < $o ) {
|
||||
$ret .= " Betters";
|
||||
$state = 4;
|
||||
}
|
||||
if( $state > 0 ) {
|
||||
$alert['details']['rule'] = $chk;
|
||||
if( dbInsert(array('state' => $state, 'device_id' => $alert['device_id'], 'rule_id' => $alert['rule_id'], 'details' => gzcompress(json_encode($alert['details']),9)), 'alert_log') ) {
|
||||
dbUpdate(array('state' => $state, 'open' => 1, 'alerted' => 1),'alerts','rule_id = ? && device_id = ?', array($alert['rule_id'], $alert['device_id']));
|
||||
}
|
||||
echo $ret." (".$o."/".$n.")\r\n";
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Run all alerts
|
||||
* @return void
|
||||
*/
|
||||
function RunAlerts() {
|
||||
global $config;
|
||||
$default_tpl = "%title\r\nSeverity: %severity\r\n{if %state == 0}Time elapsed: %elapsed\r\n{/if}Timestamp: %timestamp\r\nUnique-ID: %uid\r\nRule: %rule\r\n{if %faults}Faults:\r\n{foreach %faults} #%key: %value\r\n{/foreach}{/if}Alert sent to: {foreach %contacts}%value <%key> {/foreach}"; //FIXME: Put somewhere else?
|
||||
$default_tpl = "%title\r\nSeverity: %severity\r\n{if %state == 0}Time elapsed: %elapsed\r\n{/if}Timestamp: %timestamp\r\nUnique-ID: %uid\r\nRule: {if %name}%name{else}%rule{/if}\r\n{if %faults}Faults:\r\n{foreach %faults} #%key: %value.string\r\n{/foreach}{/if}Alert sent to: {foreach %contacts}%value <%key> {/foreach}"; //FIXME: Put somewhere else?
|
||||
foreach( dbFetchRows("SELECT alerts.device_id, alerts.rule_id, alerts.state FROM alerts WHERE alerts.state != 2 && alerts.open = 1") as $alert ) {
|
||||
$alert = dbFetchRow("SELECT alert_log.id,alert_log.rule_id,alert_log.device_id,alert_log.state,alert_log.details,alert_log.time_logged,alert_rules.rule,alert_rules.severity,alert_rules.extra FROM alert_log,alert_rules WHERE alert_log.rule_id = alert_rules.id && alert_log.device_id = ? && alert_log.rule_id = ? ORDER BY alert_log.id DESC LIMIT 1",array($alert['device_id'],$alert['rule_id']));
|
||||
$alert = dbFetchRow("SELECT alert_log.id,alert_log.rule_id,alert_log.device_id,alert_log.state,alert_log.details,alert_log.time_logged,alert_rules.rule,alert_rules.severity,alert_rules.extra,alert_rules.name FROM alert_log,alert_rules WHERE alert_log.rule_id = alert_rules.id && alert_log.device_id = ? && alert_log.rule_id = ? ORDER BY alert_log.id DESC LIMIT 1",array($alert['device_id'],$alert['rule_id']));
|
||||
$alert['details'] = json_decode(gzuncompress($alert['details']),true);
|
||||
$noiss = false;
|
||||
$noacc = false;
|
||||
$updet = false;
|
||||
$rextra = json_decode($alert['extra'],true);
|
||||
$chk = dbFetchRow('SELECT alerted FROM alerts WHERE device_id = ? && rule_id = ?',array($alert['device_id'],$alert['rule_id']));
|
||||
$chk = dbFetchRow('SELECT alerts.alerted,devices.ignore,devices.disabled FROM alerts,devices WHERE alerts.device_id = ? && devices.device_id = alerts.device_id && alerts.rule_id = ?',array($alert['device_id'],$alert['rule_id']));
|
||||
if( $chk['alerted'] == $alert['state'] ) {
|
||||
$noiss = true;
|
||||
}
|
||||
@ -81,6 +124,11 @@ function RunAlerts() {
|
||||
$updet = true;
|
||||
$noiss = false;
|
||||
}
|
||||
if( $chk['ignore'] == 1 || $chk['disabled'] == 1 ) {
|
||||
$noiss = true;
|
||||
$updet = false;
|
||||
$noacc = false;
|
||||
}
|
||||
if( $updet ) {
|
||||
dbUpdate(array('details' => gzcompress(json_encode($alert['details']),9)),'alert_log','id = ?',array($alert['id']));
|
||||
}
|
||||
@ -138,39 +186,50 @@ function ExtTransports($obj) {
|
||||
* @return string
|
||||
*/
|
||||
function FormatAlertTpl($tpl,$obj) {
|
||||
$tpl = addslashes($tpl);
|
||||
|
||||
/**
|
||||
* {if ..}..{else}..{/if}
|
||||
*/
|
||||
preg_match_all('/\\{if (.+)\\}(.+)\\{\\/if\\}/Uims',$tpl,$m);
|
||||
foreach( $m[1] as $k=>$if ) {
|
||||
$if = preg_replace('/%(\w+)/i','\$obj["$1"]', $if);
|
||||
$ret = "";
|
||||
$cond = "if( $if ) {\r\n".'$ret = "'.str_replace("{else}",'";'."\r\n} else {\r\n".'$ret = "',$m[2][$k]).'";'."\r\n}\r\n";
|
||||
eval($cond); //FIXME: Eval is Evil
|
||||
$tpl = str_replace($m[0][$k],$ret,$tpl);
|
||||
$msg = '$ret .= "'.str_replace(array("{else}","{/if}","{/foreach}"),array('"; } else { $ret .= "','"; } $ret .= "','"; } $ret .= "'),addslashes($tpl)).'";';
|
||||
$parsed = $msg;
|
||||
$s = strlen($msg);
|
||||
$x = $pos = -1;
|
||||
$buff = "";
|
||||
$if = $for = false;
|
||||
while( ++$x < $s ) {
|
||||
if( $msg[$x] == "{" && $buff == "" ) {
|
||||
$buff .= $msg[$x];
|
||||
} elseif( $buff == "{ " ) {
|
||||
$buff = "";
|
||||
} elseif( $buff != "" ) {
|
||||
$buff .= $msg[$x];
|
||||
}
|
||||
if( $buff == "{if" ) {
|
||||
$pos = $x;
|
||||
$if = true;
|
||||
} elseif( $buff == "{foreach" ) {
|
||||
$pos = $x;
|
||||
$for = true;
|
||||
}
|
||||
if( $pos != -1 && $msg[$x] == "}" ) {
|
||||
$orig = $buff;
|
||||
$buff = "";
|
||||
$pos = -1;
|
||||
if( $if ) {
|
||||
$if = false;
|
||||
$o = 3;
|
||||
$native = array('"; if( ',' ) { $ret .= "');
|
||||
} elseif( $for ) {
|
||||
$for = false;
|
||||
$o = 8;
|
||||
$native = array('"; foreach( ',' as $key=>$value) { $ret .= "');
|
||||
} else {
|
||||
continue;
|
||||
}
|
||||
$cond = trim(populate(substr($orig,$o,-1),false));
|
||||
$native = $native[0].$cond.$native[1];
|
||||
$parsed = str_replace($orig,$native,$parsed);
|
||||
unset($cond, $o, $orig, $native);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* {foreach %var}..{/foreach}
|
||||
*/
|
||||
preg_match_all('/\\{foreach (.+)\\}(.+)\\{\\/foreach\\}/Uims',$tpl,$m);
|
||||
foreach( $m[1] as $k=>$for ) {
|
||||
$for = preg_replace('/%(\w+)/i','\$obj["$1"]', $for);
|
||||
$ret = "";
|
||||
$loop = 'foreach( '.$for.' as $key=>$value ) { $ret .= "'.str_replace(array("%key","%value"),array('$key','$value'),$m[2][$k]).'"; }';
|
||||
eval($loop); //FIXME: Eval is Evil
|
||||
$tpl = str_replace($m[0][$k],$ret,$tpl);
|
||||
}
|
||||
|
||||
/**
|
||||
* Populate variables with data
|
||||
*/
|
||||
foreach( $obj as $k=>$v ) {
|
||||
$tpl = str_replace("%".$k, $v, $tpl);
|
||||
}
|
||||
return $tpl;
|
||||
$parsed = populate($parsed);
|
||||
return RunJail($parsed,$obj);
|
||||
}
|
||||
|
||||
/**
|
||||
@ -184,18 +243,24 @@ function DescribeAlert($alert) {
|
||||
$device = dbFetchRow("SELECT hostname FROM devices WHERE device_id = ?",array($alert['device_id']));
|
||||
$obj['hostname'] = $device['hostname'];
|
||||
$extra = $alert['details'];
|
||||
if( $alert['state'] == 1 ) {
|
||||
if( $alert['state'] >= 1 ) {
|
||||
$obj['title'] = 'Alert for device '.$device['hostname'].' Alert-ID #'.$alert['id'];
|
||||
if( $alert['state'] == 3 ) {
|
||||
$obj['title'] .= " got worse";
|
||||
} elseif( $alert['state'] == 4 ) {
|
||||
$obj['title'] .= " got better";
|
||||
}
|
||||
foreach( $extra['rule'] as $incident ) {
|
||||
$i++;
|
||||
$obj['faults'][$i] = $incident;
|
||||
foreach( $incident as $k=>$v ) {
|
||||
if( !empty($v) && $k != 'device_id' && (stristr($k,'id') || stristr($k,'desc')) && substr_count($k,'_') <= 1 ) {
|
||||
$obj['faults'][$i] .= $k.' => '.$v."; ";
|
||||
$obj['faults'][$i]['string'] .= $k.' => '.$v."; ";
|
||||
}
|
||||
}
|
||||
}
|
||||
} elseif( $alert['state'] == 0 ) {
|
||||
$id = dbFetchRow("SELECT alert_log.id,alert_log.time_logged,alert_log.details FROM alert_log WHERE alert_log.state = 1 && alert_log.rule_id = ? && alert_log.device_id = ? && alert_log.id < ? ORDER BY id DESC LIMIT 1", array($alert['rule_id'],$alert['device_id'],$alert['id']));
|
||||
$id = dbFetchRow("SELECT alert_log.id,alert_log.time_logged,alert_log.details FROM alert_log WHERE alert_log.state != 2 && alert_log.state != 0 && alert_log.rule_id = ? && alert_log.device_id = ? && alert_log.id < ? ORDER BY id DESC LIMIT 1", array($alert['rule_id'],$alert['device_id'],$alert['id']));
|
||||
if( empty($id['id']) ) {
|
||||
return false;
|
||||
}
|
||||
@ -210,6 +275,7 @@ function DescribeAlert($alert) {
|
||||
$obj['uid'] = $alert['id'];
|
||||
$obj['severity'] = $alert['severity'];
|
||||
$obj['rule'] = $alert['rule'];
|
||||
$obj['name'] = $alert['name'];
|
||||
$obj['timestamp'] = $alert['time_logged'];
|
||||
$obj['contacts'] = $extra['contacts'];
|
||||
$obj['state'] = $alert['state'];
|
||||
@ -241,4 +307,47 @@ function TimeFormat($secs){
|
||||
}
|
||||
return join(' ', $ret);
|
||||
}
|
||||
|
||||
/**
|
||||
* "Safely" run eval
|
||||
* @param string $code Code to run
|
||||
* @param array $obj Object with variables
|
||||
* @return string|mixed
|
||||
*/
|
||||
function RunJail($code,$obj) {
|
||||
$ret = "";
|
||||
eval($code);
|
||||
return $ret;
|
||||
}
|
||||
|
||||
/**
|
||||
* Populate variables
|
||||
* @param string $txt Text with variables
|
||||
* @param bool $wrap Wrap variable for text-usage (default: true)
|
||||
* @return string
|
||||
*/
|
||||
function populate($txt,$wrap=true) {
|
||||
preg_match_all('/%([\w\.]+)/', $txt, $m);
|
||||
foreach( $m[1] as $tmp ) {
|
||||
$orig = $tmp;
|
||||
$rep = false;
|
||||
if( $tmp == "key" || $tmp == "value" ) {
|
||||
$rep = '$'.$tmp;
|
||||
} else {
|
||||
if( strstr($tmp,'.') ) {
|
||||
$tmp = explode('.',$tmp,2);
|
||||
$pre = '$'.$tmp[0];
|
||||
$tmp = $tmp[1];
|
||||
} else {
|
||||
$pre = '$obj';
|
||||
}
|
||||
$rep = $pre."['".str_replace('.',"']['",$tmp)."']";
|
||||
if( $wrap ) {
|
||||
$rep = "{".$rep."}";
|
||||
}
|
||||
}
|
||||
$txt = str_replace("%".$orig,$rep,$txt);
|
||||
}
|
||||
return $txt;
|
||||
}
|
||||
?>
|
||||
|
||||
@ -66,13 +66,29 @@ function RunRules($device) {
|
||||
}
|
||||
foreach( dbFetchRows("SELECT * FROM alert_rules WHERE alert_rules.disabled = 0 && ( alert_rules.device_id = -1 || alert_rules.device_id = ? ) ORDER BY device_id,id",array($device)) as $rule ) {
|
||||
echo " #".$rule['id'].":";
|
||||
$inv = json_decode($rule['extra'],true);
|
||||
if( isset($inv['invert']) ) {
|
||||
$inv = (bool) $inv['invert'];
|
||||
} else {
|
||||
$inv = false;
|
||||
}
|
||||
$chk = dbFetchRow("SELECT state FROM alerts WHERE rule_id = ? && device_id = ? ORDER BY id DESC LIMIT 1", array($rule['id'], $device));
|
||||
$sql = GenSQL($rule['rule']);
|
||||
$qry = dbFetchRows($sql,array($device));
|
||||
if( sizeof($qry) > 0 ) {
|
||||
$s = sizeof($qry);
|
||||
if( $s == 0 && $inv === false ) {
|
||||
$doalert = false;
|
||||
} elseif( $s > 0 && $inv === false ) {
|
||||
$doalert = true;
|
||||
} elseif( $s == 0 && $inv === true ) {
|
||||
$doalert = true;
|
||||
} else { //( $s > 0 && $inv == false ) {
|
||||
$doalert = false;
|
||||
}
|
||||
if( $doalert ) {
|
||||
if( $chk['state'] === "2" ) {
|
||||
echo " SKIP ";
|
||||
} elseif( $chk['state'] === "1" ) {
|
||||
} elseif( $chk['state'] >= "1" ) {
|
||||
echo " NOCHG ";
|
||||
} else {
|
||||
$extra = gzcompress(json_encode(array('contacts' => GetContacts($qry), 'rule'=>$qry)),9);
|
||||
|
||||
Loading…
Reference in New Issue
Block a user