VE-Tools/VE.Direct-notify
1
0
Fork 0
Code Issues 2 Pull Requests Actions Packages Projects Releases Wiki Activity

completed monitor queries and added option for test messages

Browse Source
This commit is contained in:
Aaska Black Wolf
2026-06-03 20:14:56 +02:00
parent e3424352d9
commit 7da503ce68
1 changed files with 104 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files
worker.php
+102 -25
View File
@@ -8,38 +8,52 @@
* You should have received a copy of the license with this software
*/
// read configuration
$config = readConfig();
if( !isset($config) )
exit("Error reading configuration! Exit!\r\n");
// check whether test message shall be delivered to notification service
if( $argc >= 3 && $argv[1] == "test" && isset($argv[2]) ) {
sendMessage($argv[2] . ": Testmessage");
exit();
}
queryMonitors();
function readConfig() {
return json_decode( file_get_contents('config.json') );
}
function sendMessage($message) {
global $config;
$authorization = "";
if( defined($config->service->username) && defined($config->service->password) )
$authorization = 'Basic ' + base64_encode($config->service->username + ':' + $config->service->password);
elseif( defined($config->service->token) )
$authorization = 'Bearer ' + $config->service->token;
$result = file_get_contents( $config->service->url + '/' + $config->service->topic, false, stream_context_create([
'http' => [
'method' => 'POST',
'header' =>
'Content-Type: text/plain\r\n' .
'Authorization: ' + $authorization,
'content' => $message
]
]));
return true;
function checkCondition($value, $condition) {
switch($condition[0]) {
case "e": // equal
if($value == $condition[1])
return ' equals ' . $condition[1];
break;
case "gt": // greater than
if( floatval($value) > floatval($condition[1]) )
return ' = ' . $value . ' and greater than ' . $condition[1];
break;
case "gte": // greater than or equal
if( floatval($value) >= floatval($condition[1]) )
return ' = ' . $value . ' and greater than or equal ' . $condition[1];
break;
case "lt": // lower than
if( floatval($value) < floatval($condition[1]) )
return ' = ' . $value . ' and lower than ' . $condition[1];
break;
case "lte": // lower than or equal
if( floatval($value) <= floatval($condition[1]) )
return ' = ' . $value . ' and lower than or equal ' . $condition[1];
break;
case "ne": // not equal
if($value != $condition[1])
return ' = ' . $value . ' and not equal to ' . $condition[1];
break;
}
return false;
}
function queryMonitors() {
global $config;
// establish database connection
$dbPath = (str_starts_with($config->database, '/')) ? $config->database : dirname(__FILE__) . '/' . $config->database;
try {
@@ -49,6 +63,7 @@ function queryMonitors() {
print ('error detected: ' . $e->getMessage() . "\r\n");
return false;
}
// query devices from database
$sql = "SELECT name FROM sqlite_schema WHERE name NOT LIKE 'sqlite_%' AND name <> 'meta' ORDER BY name ASC;";
$data = $db->query($sql);
@@ -59,12 +74,74 @@ function queryMonitors() {
$sql = "SELECT * FROM '" . $device['name'] . "' ORDER BY date DESC, time DESC LIMIT 1;";
$res = $db->query($sql)->fetchArray(SQLITE3_NUM);
$dataset = json_decode($res[2]);
print_r($dataset);
// read last status of warnings and errors for comparison to avoid double sending of notifications
$statusFile = __DIR__ . '/status/' . $device['name'];
$lastStatus = [];
if( is_file($statusFile) )
$lastStatus = json_decode( file_get_contents( $statusFile ), true );
// process configured monitors
foreach($config->monitors as $monitor) {
if( !empty($monitor->warning) ) {
if( !isset( $lastStatus[$monitor->parameter]['warning'] ) )
$lastStatus[$monitor->parameter]['warning'] = 0;
$status = checkCondition($dataset->{$monitor->parameter}, $monitor->warning);
if( $status && $lastStatus[$monitor->parameter]['warning'] == 0 ) { // new warning
sendMessage('Warning from ' . $device['name'] . ': ' . $monitor->parameter . $status);
$lastStatus[$monitor->parameter]['warning'] = 1;
}
else if( !$status && $lastStatus[$monitor->parameter]['warning'] == 1) { // warning cleared
sendMessage( 'Warning cleared on ' . $device['name'] . '. ' . $monitor->parameter . ' = ' . $dataset->{$monitor->parameter} . ' and back to normal.');
$lastStatus[$monitor->parameter]['warning'] = 0;
}
}
if( !empty($monitor->error) ) {
if( !isset( $lastStatus[$monitor->parameter]['error'] ) )
$lastStatus[$monitor->parameter]['error'] = 0;
$status = checkCondition($dataset->{$monitor->parameter}, $monitor->error);
if( $status && $lastStatus[$monitor->parameter]['error'] == 0 ) { // new error!
sendMessage('Error from ' . $device['name'] . ': ' . $monitor->parameter . $status);
$lastStatus[$monitor->parameter]['error'] = 1;
}
else if( !$status && $lastStatus[$monitor->parameter]['error'] == 1 ) { // error cleared
sendMessage('Error cleared on ' . $device['name'] . '. ' . $monitor->parameter . ' = ' . $dataset->{$monitor->parameter} . ' and out of critical range.');
$lastStatus[$monitor->parameter]['error'] = 0;
}
}
}
file_put_contents( $statusFile, json_encode($lastStatus) );
}
}
function readConfig() {
return json_decode( file_get_contents(__DIR__ . '/config.json') );
}
function sendMessage($message) {
global $config;
$authorization = "Authorization: ";
if( !empty($config->service->username) && !empty($config->service->password) )
$authorization .= 'Basic ' . base64_encode($config->service->username . ':' . $config->service->password);
elseif( !empty($config->service->auth_token) )
$authorization .= 'Bearer ' . $config->service->auth_token;
else
$authorization = '';
$result = file_get_contents( $config->service->url . '/' . $config->service->topic, false, stream_context_create([
'http' => [
'method' => 'POST',
'header' =>
"Content-Type: text/plain\r\n" .
$authorization,
'content' => $message
]
]));
return true;
}
?>