Merge pull request #2004 from QuxLabs/qux-issue-5

Added notification system

daily.php

@@ -96,3 +96,7 @@ if ($options['f'] === 'device_perf') {
         }
     }
 }
+
+if ($options['f'] === 'notifications') {
+    include_once 'notifications.php';
+}

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

html/includes/authentication/active_directory.inc.php

@@ -86,7 +86,16 @@ function auth_usermanagement() {
 function adduser($username) {
     // Check to see if user is already added in the database
     if (!user_exists_in_db($username)) {
-        return dbInsert(array('username' => $username, 'user_id' => get_userid($username), 'level' => "0", 'can_modify_passwd' => 0, 'twofactor' => 0), 'users');
+        $userid = dbInsert(array('username' => $username, 'user_id' => get_userid($username), 'level' => "0", 'can_modify_passwd' => 0, 'twofactor' => 0), 'users');
+        if ($userid == false) {
+            return false;
+        }
+        else {
+            foreach (dbFetchRows('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',array($userid)) as $notif) {
+                dbInsert(array('notifications_id'=>$notif['notifications_id'],'user_id'=>$userid,'key'=>'read','value'=>1),'notifications_attribs');
+            }
+        }
+        return $userid;
     }
     else {
         return false;

html/includes/authentication/http-auth.inc.php

@@ -44,11 +44,20 @@ function auth_usermanagement() {
 }
 
 
-function adduser($username, $password, $level, $email='', $realname='', $can_modify_passwd='1') {
+function adduser($username, $password, $level, $email='', $realname='', $can_modify_passwd=1, $description='', $twofactor=0) {
     if (!user_exists($username)) {
         $hasher    = new PasswordHash(8, false);
         $encrypted = $hasher->HashPassword($password);
-        return dbInsert(array('username' => $username, 'password' => $encrypted, 'level' => $level, 'email' => $email, 'realname' => $realname), 'users');
+        $userid    = dbInsert(array('username' => $username, 'password' => $encrypted, 'level' => $level, 'email' => $email, 'realname' => $realname, 'can_modify_passwd' => $can_modify_passwd, 'descr' => $description, 'twofactor' => $twofactor), 'users');
+        if ($userid == false) {
+            return false;
+        }
+        else {
+            foreach (dbFetchRows('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',array($userid)) as $notif) {
+                dbInsert(array('notifications_id'=>$notif['notifications_id'],'user_id'=>$userid,'key'=>'read','value'=>1),'notifications_attribs');
+            }
+        }
+        return $userid;
     }
     else {
         return false;

html/includes/authentication/mysql.inc.php

@@ -104,7 +104,16 @@ function adduser($username, $password, $level, $email='', $realname='', $can_mod
     if (!user_exists($username)) {
         $hasher    = new PasswordHash(8, false);
         $encrypted = $hasher->HashPassword($password);
-        return dbInsert(array('username' => $username, 'password' => $encrypted, 'level' => $level, 'email' => $email, 'realname' => $realname, 'can_modify_passwd' => $can_modify_passwd, 'descr' => $description, 'twofactor' => $twofactor), 'users');
+        $userid    = dbInsert(array('username' => $username, 'password' => $encrypted, 'level' => $level, 'email' => $email, 'realname' => $realname, 'can_modify_passwd' => $can_modify_passwd, 'descr' => $description, 'twofactor' => $twofactor), 'users');
+        if ($userid == false) {
+            return false;
+        }
+        else {
+            foreach (dbFetchRows('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',array($userid)) as $notif) {
+                dbInsert(array('notifications_id'=>$notif['notifications_id'],'user_id'=>$userid,'key'=>'read','value'=>1),'notifications_attribs');
+            }
+        }
+        return $userid;
     }
     else {
         return false;

html/includes/forms/notifications.inc.php

@@ -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,
+)));
+

html/includes/print-menubar.php

@@ -488,6 +488,10 @@ if(is_file("includes/print-menubar-custom.inc.php")) {
          </div>
      </form>
     <ul class="nav navbar-nav navbar-right">
+<?php
+$notifications = new ObjCache('notifications');
+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">

html/pages/notifications.inc.php

@@ -0,0 +1,240 @@
+<?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>&nbsp;&nbsp;&nbsp;<?php echo $notif['title']; ?></strong>&nbsp;<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" data-toggle="tooltip" data-placement="bottom" title="Remove Sticky" 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" data-toggle="tooltip" data-placement="bottom" title="Mark as Sticky" style="margin-top:-10px;"></button>' : ''); ?>
+&nbsp;
+<button class="btn btn-primary fa fa-eye read-notif" data-toggle="tooltip" data-placement="bottom" title="Mark as Read" 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']; echo ($_SESSION['userlevel'] == 10 ? '<span class="pull-right"><button class="btn btn-primary fa fa-bell-o stick-notif" data-toggle="tooltip" data-placement="bottom" title="Mark as Sticky" style="margin-top:-10px;"></button></span>' : ''); ?>
+      </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() {
+  $('[data-toggle="tooltip"]').tooltip();
+  $('.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() {
+    $(this).attr("disabled", true);
+    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 {
+          $(this).attr("disabled", false);
+          $("#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>

includes/caches/notifications.inc.php

@@ -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'] )
+);
+

includes/defaults.inc.php

@@ -825,3 +825,6 @@ $config['summary_errors']                               = 0;
 
 // Default width of the availability map's tiles
 $config['availability-map-width']                       = 25;
+
+// Default notifications Feed
+$config['notifications']['LibreNMS']                    = 'http://www.librenms.org/notifications.rss';

includes/object-cache.inc.php

@@ -95,7 +95,10 @@ class ObjCache implements ArrayAccess {
                 return $GLOBALS['_ObjCache'][$this->obj][$obj]['value'];
             }
             else {
-                $GLOBALS['_ObjCache'][$this->obj][$obj]['value'] = dbFetchCell($this->data[$obj]['query'], $this->data[$obj]['params']);
+                $GLOBALS['_ObjCache'][$this->obj][$obj]['value'] = dbFetchRows($this->data[$obj]['query'], $this->data[$obj]['params']);
+                if (sizeof($GLOBALS['_ObjCache'][$this->obj][$obj]['value']) == 1 && sizeof($GLOBALS['_ObjCache'][$this->obj][$obj]['value'][0]) == 1) {
+                    $GLOBALS['_ObjCache'][$this->obj][$obj]['value'] = current($GLOBALS['_ObjCache'][$this->obj][$obj]['value'][0]);
+                }
                 return $GLOBALS['_ObjCache'][$this->obj][$obj]['value'];
             }
         }

notifications.php

@@ -0,0 +1,100 @@
+<?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();
+    if( !array_key_exists('0',$feed['channel']['item']) ) {
+        $feed['channel']['item'] = array( $feed['channel']['item'] );
+    }
+    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();
+    if( !array_key_exists('0',$feed['entry']) ) {
+        $feed['entry'] = array( $feed['entry'] );
+    }
+    foreach ($feed['entry'] as $item) {
+        $obj[] = array('title'=>$item['title'],'body'=>$item['content'],'checksum'=>hash('sha512',$item['title'].$item['content']));
+    }
+    return $obj;
+}
+
+post_notifications();

sql-schema/077.sql

@@ -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;