mirror of
https://github.com/librenms/librenms.git
synced 2024-10-07 16:52:45 +00:00
Added notifications poller,page,schema,display
This commit is contained in:
Daniel Preussker
@ -103,3 +103,7 @@ if ($options['f'] === 'device_perf') {
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
if ($options['f'] === 'notifications') {
|
||||
include_once 'notifications.php';
|
||||
}
|
||||
|
||||
1
daily.sh
1
daily.sh
@ -16,3 +16,4 @@ php daily.php -f authlog
|
||||
php daily.php -f perf_times
|
||||
php daily.php -f callback
|
||||
php daily.php -f device_perf
|
||||
php daily.php -f notifications
|
||||
|
||||
56
html/includes/forms/notifications.inc.php
Normal file
56
html/includes/forms/notifications.inc.php
Normal file
@ -0,0 +1,56 @@
|
||||
<?php
|
||||
/* Copyright (C) 2015 Daniel Preussker, QuxLabs UG <preussker@quxlabs.com>
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>. */
|
||||
|
||||
/**
|
||||
* Notification Page
|
||||
* @author Daniel Preussker
|
||||
* @copyright 2015 Daniel Preussker, QuxLabs UG
|
||||
* @license GPL
|
||||
* @package LibreNMS
|
||||
* @subpackage Notifications
|
||||
*/
|
||||
|
||||
$status = 'error';
|
||||
$message = 'unknown error';
|
||||
if (isset($_REQUEST['notification_id']) && isset($_REQUEST['action'])) {
|
||||
if ($_REQUEST['action'] == 'read' && dbInsert(array('notifications_id'=>$_REQUEST['notification_id'],'user_id'=>$_SESSION['user_id'],'key'=>'read','value'=>1),'notifications_attribs')) {
|
||||
$status = 'ok';
|
||||
$message = 'Set as Read';
|
||||
}
|
||||
elseif ($_SESSION['userlevel'] == 10 && $_REQUEST['action'] == 'stick' && dbInsert(array('notifications_id'=>$_REQUEST['notification_id'],'user_id'=>$_SESSION['user_id'],'key'=>'sticky','value'=>1),'notifications_attribs')) {
|
||||
$status = 'ok';
|
||||
$message = 'Set as Sticky';
|
||||
}
|
||||
elseif ($_SESSION['userlevel'] == 10 && $_REQUEST['action'] == 'unstick' && dbUpdate(array('key'=>'sticky','value'=>0),'notifications_attribs','notifications_id = ? && user_id = ?',array($_REQUEST['notification_id'],$_SESSION['user_id']))) {
|
||||
$status = 'ok';
|
||||
$message = 'Removed Sticky';
|
||||
}
|
||||
}
|
||||
elseif ($_REQUEST['action'] == 'create' && $_SESSION['userlevel'] == 10 && (isset($_REQUEST['title']) && isset($_REQUEST['body']))) {
|
||||
if (dbInsert(array('title'=>$_REQUEST['title'],'body'=>$_REQUEST['body'],'checksum'=>hash('sha512',$_SESSION['user_id'].'.LOCAL.'.$_REQUEST['title']),'source'=>$_SESSION['user_id']),'notifications')) {
|
||||
$status = 'ok';
|
||||
$message = 'Created';
|
||||
}
|
||||
}
|
||||
else {
|
||||
$status = 'error';
|
||||
$message = 'ERROR: Missing Params';
|
||||
}
|
||||
|
||||
die(json_encode(array(
|
||||
'status' => $status,
|
||||
'message' => $message,
|
||||
)));
|
||||
|
||||
@ -488,6 +488,12 @@ if(is_file("includes/print-menubar-custom.inc.php")) {
|
||||
</div>
|
||||
</form>
|
||||
<ul class="nav navbar-nav navbar-right">
|
||||
<?php
|
||||
$notifications = new ObjCache('notifications');
|
||||
if (($notifications['sticky_count']+$notifications['count']) != 0) {
|
||||
echo ' <li><a href="notifications/"><span class="badge count-notif">'.($notifications['sticky_count']+$notifications['count']).'</span></a></li>';
|
||||
}
|
||||
?>
|
||||
<li class="dropdown">
|
||||
<a href="#" class="dropdown-toggle" data-hover="dropdown" data-toggle="dropdown"><i class="fa fa-cog fa-fw fa-lg fa-nav-icons"></i></a>
|
||||
<ul class="dropdown-menu">
|
||||
|
||||
238
html/pages/notifications.inc.php
Normal file
238
html/pages/notifications.inc.php
Normal file
@ -0,0 +1,238 @@
|
||||
<?php
|
||||
/* Copyright (C) 2015 Daniel Preussker, QuxLabs UG <preussker@quxlabs.com>
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>. */
|
||||
|
||||
/**
|
||||
* Notification Page
|
||||
* @author Daniel Preussker
|
||||
* @copyright 2015 Daniel Preussker, QuxLabs UG
|
||||
* @license GPL
|
||||
* @package LibreNMS
|
||||
* @subpackage Notifications
|
||||
*/
|
||||
|
||||
$notifications = new ObjCache('notifications');
|
||||
?>
|
||||
<div class="container">
|
||||
<div class="row">
|
||||
<div class="col-md-12">
|
||||
<h1><a href="/notifications">Notifications</a></h1>
|
||||
<h4><strong class="count-notif"><?php echo $notifications['count']; ?></strong> Unread Notifications <?php echo ($_SESSION['userlevel'] == 10 ? '<button class="btn btn-success pull-right new-notif" style="margin-top:-10px;">New</button>' : ''); ?></h4>
|
||||
<hr/>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
<div class="container new-notif-collapse">
|
||||
<div class="row">
|
||||
<div class="col-md-12">
|
||||
<form class="form-horizontal new-notif-form">
|
||||
<div class="form-group">
|
||||
<label for="notif_title" class="col-sm-2 control-label">Title</label>
|
||||
<div class="col-sm-10">
|
||||
<input type="text" class="form-control" id="notif_title" name="notif_title" placeholder="">
|
||||
</div>
|
||||
</div>
|
||||
<div class="form-group">
|
||||
<label for="notif_body" class="col-sm-2 control-label">Message</label>
|
||||
<div class="col-sm-10">
|
||||
<textarea class="form-control" id="notif_body" name="notif_body"></textarea>
|
||||
</div>
|
||||
</div>
|
||||
<div class="form-group">
|
||||
<div class="col-sm-offset-2 col-sm-10">
|
||||
<button type="submit" class="btn btn-success">Add Notification</button>
|
||||
</div>
|
||||
</div>
|
||||
</form>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
<?php if (!isset($vars['archive'])) { ?>
|
||||
<div class="container">
|
||||
<?php
|
||||
foreach ($notifications['sticky'] as $notif) {
|
||||
if (is_numeric($notif['source'])) {
|
||||
$notif['source'] = dbFetchCell('select username from users where user_id =?',array($notif['source']));
|
||||
} ?>
|
||||
<div class="well">
|
||||
<div class="row">
|
||||
<div class="col-md-12">
|
||||
<h4 class="text-warning" id="<?php echo $notif['notifications_id']; ?>"><strong><i class="fa fa-bell-o"></i> <?php echo $notif['title']; ?></strong> <span class="pull-right"><?php echo ($notif['user_id'] != $_SESSION['user_id'] ? '<code>Sticky by '.dbFetchCell('select username from users where user_id = ?',array($notif['user_id'])).'</code>' : '<button class="btn btn-primary fa fa-bell-slash-o unstick-notif" style="margin-top:-10px;"></button>'); ?></span></h4>
|
||||
</div>
|
||||
</div>
|
||||
<div class="row">
|
||||
<div class="col-md-12">
|
||||
<blockquote>
|
||||
<p><?php echo $notif['body']; ?></p>
|
||||
<footer>Source: <code><?php echo $notif['source']; ?></code></footer>
|
||||
</blockquote>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
<?php } ?>
|
||||
<?php if ($notifications['sticky_count'] != 0) { ?>
|
||||
<hr/>
|
||||
<?php } ?>
|
||||
<?php
|
||||
foreach ($notifications['unread'] as $notif) {
|
||||
if (is_numeric($notif['source'])) {
|
||||
$notif['source'] = dbFetchCell('select username from users where user_id =?',array($notif['source']));
|
||||
} ?>
|
||||
<div class="well">
|
||||
<div class="row">
|
||||
<div class="col-md-12">
|
||||
<h4 class="text-success" id="<?php echo $notif['notifications_id']; ?>"><strong><?php echo $notif['title']; ?></strong><span class="pull-right">
|
||||
<?php echo ($_SESSION['userlevel'] == 10 ? '<button class="btn btn-primary fa fa-bell-o stick-notif" style="margin-top:-10px;"></button>' : ''); ?>
|
||||
|
||||
<button class="btn btn-primary fa fa-eye read-notif" style="margin-top:-10px;"></button>
|
||||
</span>
|
||||
</h4>
|
||||
</div>
|
||||
</div>
|
||||
<div class="row">
|
||||
<div class="col-md-12">
|
||||
<blockquote>
|
||||
<p><?php echo $notif['body']; ?></p>
|
||||
<footer>Source: <code><?php echo $notif['source']; ?></code></footer>
|
||||
</blockquote>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
<?php } ?>
|
||||
<div class="row">
|
||||
<div class="col-md-12">
|
||||
<h3><a class="btn btn-default" href="/notifications/archive">Show Archive</a></h3>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
<?php } else if (isset($vars['archive'])) { ?>
|
||||
<div class="container">
|
||||
<div class="row">
|
||||
<div class="col-md-12">
|
||||
<h2>Archive</h2>
|
||||
</div>
|
||||
</div>
|
||||
<?php foreach (array_reverse($notifications['read']) as $notif) { ?>
|
||||
<div class="well">
|
||||
<div class="row">
|
||||
<div class="col-md-12">
|
||||
<h4 id="<?php echo $notif['notifications_id']; ?>"><?php echo $notif['title']; ?><button class="btn btn-primary fa fa-bell-o pull-right stick-notif" style="margin-top:-10px;"></button></h4>
|
||||
</div>
|
||||
</div>
|
||||
<div class="row">
|
||||
<div class="col-md-12">
|
||||
<blockquote>
|
||||
<p><?php echo $notif['body']; ?></p>
|
||||
<footer>Source: <code><?php echo $notif['source']; ?></code></footer>
|
||||
</blockquote>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
<?php } ?>
|
||||
</div>
|
||||
<?php } ?>
|
||||
<script>
|
||||
$(function() {
|
||||
|
||||
$('.new-notif-collapse').fadeOut(0);
|
||||
$(document).on( "click", ".new-notif", function() {
|
||||
$('.new-notif-collapse').fadeToggle();
|
||||
});
|
||||
|
||||
$(document).on( "submit", ".new-notif-form", function() {
|
||||
var notif = {};
|
||||
data = $(this).serializeArray();
|
||||
for( var field in data ) {
|
||||
notif[data[field].name] = data[field].value;
|
||||
}
|
||||
$.ajax({
|
||||
type: 'POST',
|
||||
url: 'ajax_form.php',
|
||||
data: {type: 'notifications', title: notif.notif_title, body: notif.notif_body, action: 'create'},
|
||||
dataType: "json",
|
||||
success: function (data) {
|
||||
if( data.status == "ok" ) {
|
||||
$("#message").html('<div class="alert alert-info">' + data.message + '</div>');
|
||||
window.location.href="/notifications";
|
||||
}
|
||||
else {
|
||||
$("#message").html('<div class="alert alert-info">' + data.message + '</div>');
|
||||
}
|
||||
}
|
||||
});
|
||||
return false;
|
||||
});
|
||||
|
||||
$(document).on( "click", ".read-notif", function() {
|
||||
var notif = $(this).parent().parent().attr('id');
|
||||
$.ajax({
|
||||
type: 'POST',
|
||||
url: 'ajax_form.php',
|
||||
data: {type: 'notifications', notification_id: notif, action: 'read'},
|
||||
dataType: "json",
|
||||
success: function (data) {
|
||||
if( data.status == "ok" ) {
|
||||
$("#message").html('<div class="alert alert-info">' + data.message + '</div>');
|
||||
$("#"+notif).parent().parent().parent().fadeOut();
|
||||
$(".count-notif").each(function(){
|
||||
this.innerHTML = this.innerHTML-1;
|
||||
});
|
||||
}
|
||||
else {
|
||||
$("#message").html('<div class="alert alert-info">' + data.message + '</div>');
|
||||
}
|
||||
}
|
||||
});
|
||||
});
|
||||
|
||||
$(document).on( "click", ".stick-notif", function() {
|
||||
var notif = $(this).parent().parent().attr('id');
|
||||
$.ajax({
|
||||
type: 'POST',
|
||||
url: 'ajax_form.php',
|
||||
data: {type: 'notifications', notification_id: notif, action: 'stick'},
|
||||
dataType: "json",
|
||||
success: function (data) {
|
||||
if( data.status == "ok" ) {
|
||||
$("#message").html('<div class="alert alert-info">' + data.message + '</div>');
|
||||
window.location.href="/notifications";
|
||||
}
|
||||
else {
|
||||
$("#message").html('<div class="alert alert-info">' + data.message + '</div>');
|
||||
}
|
||||
}
|
||||
});
|
||||
});
|
||||
|
||||
$(document).on( "click", ".unstick-notif", function() {
|
||||
var notif = $(this).parent().parent().attr('id');
|
||||
$.ajax({
|
||||
type: 'POST',
|
||||
url: 'ajax_form.php',
|
||||
data: {type: 'notifications', notification_id: notif, action: 'unstick'},
|
||||
dataType: "json",
|
||||
success: function (data) {
|
||||
if( data.status == "ok" ) {
|
||||
$("#message").html('<div class="alert alert-info">' + data.message + '</div>');
|
||||
window.location.href="/notifications";
|
||||
}
|
||||
else {
|
||||
$("#message").html('<div class="alert alert-info">' + data.message + '</div>');
|
||||
}
|
||||
}
|
||||
});
|
||||
});
|
||||
|
||||
});
|
||||
</script>
|
||||
47
includes/caches/notifications.inc.php
Normal file
47
includes/caches/notifications.inc.php
Normal file
@ -0,0 +1,47 @@
|
||||
<?php
|
||||
/* Copyright (C) 2015 Daniel Preussker, QuxLabs UG <preussker@quxlabs.com>
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>. */
|
||||
|
||||
/**
|
||||
* Notification Cache
|
||||
* @author Daniel Preussker
|
||||
* @copyright 2015 Daniel Preussker, QuxLabs UG
|
||||
* @license GPL
|
||||
* @package LibreNMS
|
||||
* @subpackage Notifications
|
||||
*/
|
||||
|
||||
$data['count'] = array(
|
||||
'query' => 'select count(notifications.notifications_id) from notifications where not exists( select 1 from notifications_attribs where notifications.notifications_id = notifications_attribs.notifications_id and notifications_attribs.user_id = ?)',
|
||||
'params' => array( $_SESSION['user_id'] )
|
||||
);
|
||||
|
||||
$data['unread'] = array(
|
||||
'query' => 'select notifications.* from notifications where not exists( select 1 from notifications_attribs where notifications.notifications_id = notifications_attribs.notifications_id and notifications_attribs.user_id = ?) order by notifications.notifications_id desc',
|
||||
'params' => array( $_SESSION['user_id'] )
|
||||
);
|
||||
|
||||
$data['sticky'] = array(
|
||||
'query' => 'select notifications.*,notifications_attribs.user_id from notifications inner join notifications_attribs on notifications.notifications_id = notifications_attribs.notifications_id where notifications_attribs.key = "sticky" && notifications_attribs.value = 1 order by notifications_attribs.attrib_id desc',
|
||||
);
|
||||
|
||||
$data['sticky_count'] = array(
|
||||
'query' => 'select count(notifications.notifications_id) from notifications inner join notifications_attribs on notifications.notifications_id = notifications_attribs.notifications_id where notifications_attribs.key = "sticky" && notifications_attribs.value = 1',
|
||||
);
|
||||
|
||||
$data['read'] = array(
|
||||
'query' => 'select notifications.* from notifications inner join notifications_attribs on notifications.notifications_id = notifications_attribs.notifications_id where notifications_attribs.user_id = ? && ( notifications_attribs.key = "read" && notifications_attribs.value = 1) && not exists( select 1 from notifications_attribs where notifications.notifications_id = notifications_attribs.notifications_id and notifications_attribs.key = "sticky" && notifications_attribs.value = "1") order by notifications_attribs.attrib_id desc',
|
||||
'params' => array( $_SESSION['user_id'] )
|
||||
);
|
||||
|
||||
94
notifications.php
Normal file
94
notifications.php
Normal file
@ -0,0 +1,94 @@
|
||||
<?php
|
||||
/* Copyright (C) 2015 Daniel Preussker, QuxLabs UG <preussker@quxlabs.com>
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>. */
|
||||
|
||||
/**
|
||||
* Notification Poller
|
||||
* @author Daniel Preussker
|
||||
* @copyright 2015 Daniel Preussker, QuxLabs UG
|
||||
* @license GPL
|
||||
* @package LibreNMS
|
||||
* @subpackage Notifications
|
||||
*/
|
||||
|
||||
require_once 'includes/defaults.inc.php';
|
||||
require_once 'config.php';
|
||||
require_once $config['install_dir'].'/includes/definitions.inc.php';
|
||||
require_once $config['install_dir'].'/includes/functions.php';
|
||||
|
||||
/**
|
||||
* Pull notifications from remotes
|
||||
* @return array Notifications
|
||||
*/
|
||||
function get_notifications() {
|
||||
global $config;
|
||||
$obj = array();
|
||||
foreach ($config['notifications'] as $name=>$url) {
|
||||
echo '[ '.date('r').' ] '.$url.' ';
|
||||
$feed = json_decode(json_encode(simplexml_load_string(file_get_contents($url))),true);
|
||||
if (isset($feed['channel'])) {
|
||||
$feed = parse_rss($feed);
|
||||
} else {
|
||||
$feed = parse_atom($feed);
|
||||
}
|
||||
array_walk($feed,function(&$items,$key,$url) { $items['source'] = $url; },$url);
|
||||
$obj = array_reverse(array_merge($obj,$feed));
|
||||
echo '('.sizeof($obj).')'.PHP_EOL;
|
||||
}
|
||||
return $obj;
|
||||
}
|
||||
|
||||
/**
|
||||
* Post notifications to users
|
||||
* @return null
|
||||
*/
|
||||
function post_notifications() {
|
||||
$notifs = get_notifications();
|
||||
echo '[ '.date('r').' ] Updating DB ';
|
||||
foreach ($notifs as $notif) {
|
||||
if (dbFetchCell('select 1 from notifications where checksum = ?',array($notif['checksum'])) != 1 && dbInsert('notifications',$notif) > 0) {
|
||||
echo '.';
|
||||
}
|
||||
}
|
||||
echo ' Done';
|
||||
echo PHP_EOL;
|
||||
}
|
||||
|
||||
/**
|
||||
* Parse RSS
|
||||
* @param array $feed RSS Object
|
||||
* @return array Parsed Object
|
||||
*/
|
||||
function parse_rss($feed) {
|
||||
$obj = array();
|
||||
foreach ($feed['channel']['item'] as $item) {
|
||||
$obj[] = array('title'=>$item['title'],'body'=>$item['description'],'checksum'=>hash('sha512',$item['title'].$item['description']));
|
||||
}
|
||||
return $obj;
|
||||
}
|
||||
|
||||
/**
|
||||
* Parse Atom
|
||||
* @param array $feed Atom Object
|
||||
* @return array Parsed Object
|
||||
*/
|
||||
function parse_atom($feed) {
|
||||
$obj = array();
|
||||
foreach ($feed['entry'] as $item) {
|
||||
$obj[] = array('title'=>$item['title'],'body'=>$item['content'],'checksum'=>hash('sha512',$item['title'].$item['content']));
|
||||
}
|
||||
return $obj;
|
||||
}
|
||||
|
||||
post_notifications();
|
||||
2
sql-schema/com.quxlabs.notifications/001.sql
Normal file
2
sql-schema/com.quxlabs.notifications/001.sql
Normal file
@ -0,0 +1,2 @@
|
||||
CREATE TABLE `notifications` ( `notifications_id` int(11) NOT NULL AUTO_INCREMENT, `title` varchar(255) NOT NULL DEFAULT '', `body` text NOT NULL, `source` varchar(255) NOT NULL DEFAULT '', `checksum` varchar(128) NOT NULL, PRIMARY KEY (`notifications_id`), UNIQUE KEY `checksum` (`checksum`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;
|
||||
CREATE TABLE `notifications_attribs` ( `attrib_id` int(11) NOT NULL AUTO_INCREMENT, `notifications_id` int(11) NOT NULL, `user_id` int(11) NOT NULL, `key` varchar(255) NOT NULL DEFAULT '', `value` varchar(255) NOT NULL DEFAULT '', PRIMARY KEY (`attrib_id`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;
|
||||
Reference in New Issue
Block a user