Initial import

FileParser.php

@@ -0,0 +1,44 @@
+<?PHP
+
+ abstract class FileParser {
+
+  protected abstract function parse_line($line);
+
+  protected function parse_blockname($block) { return $block; }
+  protected function analyse() {}
+
+  public function __construct($file) {
+   $contents = file($file);
+
+   $block = '';
+   $lines = array();
+   foreach ($contents as $line) {
+    $tline = trim($line);
+
+    // Comments and empty lines
+    if (empty($tline) || $tline[0] == '#') {
+     continue;
+    }
+
+    // Close braces
+    if ($tline[0] == '}') {
+     call_user_func(array(&$this, 'parse_' . $block), $lines);
+     continue;
+    }
+
+    // Open braces
+    if (substr($tline, -1) == '{') {
+     $block = $this->parse_blockname(trim(substr($tline, 0, -1)));
+     $lines = array();
+     continue;
+    }
+
+    // Other lines
+    $lines = array_merge($lines, $this->parse_line($tline));
+   }
+
+   $this->analyse();
+  }
+ } 
+
+?>

Formats.php

@@ -0,0 +1,40 @@
+<?PHP
+
+ function translateStatus($status) {
+  switch ($status) {
+   case  0: return 'OK';
+   case  1: return 'Warning';
+   case  2: return 'Critical';
+   default: return 'Unknown';
+  }
+ }
+
+ function formatDate($date, $scheduled = false, $id) {
+  if ($date == 0) {
+   return '<td class="date never update" id="' . $id . '">Never</td>';
+  } else if ($date < strtotime('-30 seconds') && $scheduled) {
+   return '<td class="date overdue update" id="' . $id . '">' . date('d/m/Y H:i', $date) . '</td>';
+  } else {
+   return '<td class="date update" id="' . $id . '">' . date('d/m/Y H:i', $date) . '</td>';
+  }
+ }
+
+ function trunc($string) {
+  if (strlen($string) > 60) {
+   $string = substr($string, 0, 59).'…';
+  }
+  return $string;
+ }
+
+ function knatsort(&$karr){
+   $kkeyarr = array_keys($karr);
+   natsort($kkeyarr);
+   $ksortedarr = array();
+   foreach($kkeyarr as $kcurrkey){
+    $ksortedarr[$kcurrkey] = $karr[$kcurrkey];
+   }
+   $karr = $ksortedarr;
+   return true;
+ }
+
+?>

ObjectFileParser.php

@@ -0,0 +1,45 @@
+<?PHP
+
+ require_once(dirname(__FILE__) . '/FileParser.php');
+
+ class ObjectFileParser extends FileParser {
+
+  private $hosts = array();
+  private $services = array();
+
+  protected function parse_line($line) {
+   $index = strpos($line, "\t");
+   return array(substr($line, 0, $index) => substr($line, 1 + $index));
+  }
+
+  protected function parse_blockname($name) {
+   return substr($name, 7);
+  }
+
+  protected function parse_command($data) {}
+  protected function parse_service($data) { $this->services[$data['host_name']][$data['service_description']] = $data; }
+  protected function parse_servicegroup($data) {}
+  protected function parse_host($data) { $this->hosts[$data['host_name']] = $data; }
+  protected function parse_hostextinfo($data) {}
+  protected function parse_hostgroup($data) {}
+  protected function parse_contact($data) {}
+  protected function parse_contactgroup($data) {} 
+  protected function parse_timeperiod($data) {}
+
+  protected function analyse() {
+   foreach ($this->hosts as $hostname => $data) {
+    $this->hosts[$hostname]['services'] = $this->services[$hostname];
+   }
+
+   unset($this->services);
+  }
+
+  public function getHosts() { return $this->hosts; }
+
+  public function __construct($file = '/var/cache/nagios3/objects.cache') {
+   parent::__construct($file);
+  }
+
+ } 
+
+?>

StatusFileParser.php

@@ -0,0 +1,38 @@
+<?PHP
+
+ require_once(dirname(__FILE__) . '/FileParser.php');
+
+ class StatusFileParser extends FileParser {
+
+  private $hosts = array();
+  private $services = array();
+
+  protected function parse_line($line) {
+   $index = strpos($line, '=');
+   return array(substr($line, 0, $index) => substr($line, 1 + $index));
+  }
+
+  protected function parse_servicestatus($data) { $this->services[$data['host_name']][$data['service_description']] = $data; }
+  protected function parse_hoststatus($data) { $this->hosts[$data['host_name']] = $data; }
+  protected function parse_info($data) {}
+  protected function parse_programstatus($data) { }
+  protected function parse_contactstatus($data) { }
+  protected function parse_servicecomment($data) { }
+
+  protected function analyse() {
+   foreach ($this->hosts as $hostname => $data) {
+    $this->hosts[$hostname]['services'] = $this->services[$hostname];
+   }
+
+   unset($this->services);
+  }
+
+  public function getHosts() { return $this->hosts; }
+
+  public function __construct($file = '/var/cache/nagios3/status.dat') {
+   parent::__construct($file);
+  }
+
+ } 
+
+?>

index.php

@@ -0,0 +1,3 @@
+<?php
+	header('Location: status.php');
+?>

script.js

@@ -0,0 +1,34 @@
+function update() {
+ new Ajax.Request(document.location.href, {method: 'get', parameters: {xml: 'true', rand: Math.random() * 1000}, onSuccess: updateResult});
+}
+
+function updateResult(transport) {
+ var xml = transport.responseXML;
+ var updated = false;
+
+ $$('.update').each(function(el) {
+  try {
+   var updatable = xml.getElementById(el.id);
+
+   if (el.innerHTML != updatable.innerHTML || el.className != updatable.className) {
+    el.innerHTML = updatable.innerHTML;
+    el.className = updatable.className + ' updated';
+    updated = true;
+   }
+  } catch (e) {
+   //alert('Something broke: ' + e);
+  }
+ });
+
+ if (updated) {
+  setTimeout(updateCancel, 3000);
+ }
+}
+
+function updateCancel() {
+ $$('.updated').each(function(el) {
+  el.removeClassName('updated');
+ });
+}
+
+new PeriodicalExecuter(update, 10);

status.php

@@ -0,0 +1,63 @@
+<?PHP
+
+if (isset($_GET['xml'])) {
+ header('Content-type: text/xml');
+} else {
+ header('Content-type: application/xhtml+xml');
+}
+
+echo '<?xml version="1.0" encoding="UTF-8"?>', "\n";
+
+?>
+<html xmlns="http://www.w3.org/1999/xhtml">
+ <head>
+  <title>Nagios status</title>
+  <link rel="stylesheet" href="style.css" type="text/css"/>
+  <script src="http://ajax.googleapis.com/ajax/libs/prototype/1.6/prototype.js" type="text/javascript"></script>
+ </head>
+ <body>
+<?PHP
+
+ require_once(dirname(__FILE__) . '/Formats.php');
+ require_once(dirname(__FILE__) . '/ObjectFileParser.php');
+ require_once(dirname(__FILE__) . '/StatusFileParser.php');
+
+ $op = new ObjectFileParser();
+ $sp = new StatusFileParser();
+ $sh = $sp->getHosts();
+
+ echo '<table class="status">';
+ echo '<tr><th>Host</th><th>Service</th><th>Status</th><th>Last check</th><th>Next check</th><th>Comment</th></tr>';
+
+ $hosts = $op->getHosts();
+ knatsort($hosts);
+
+ foreach ($hosts as $hn => $host) {
+  echo '<tr><td rowspan="', count($host['services']), '">', $host['alias'], '</td>';
+  $first = true; 
+
+  foreach ($host['services'] as $sn => $service) {
+   if ($first) {
+    $first = false;
+   } else {
+    echo '<tr>';
+   }
+
+   $services = $sh[$hn]['services'][$sn];
+   $status = translateStatus($services['current_state']);
+   $prefix = $host['host_name'] . '_' . str_replace(' ', '_', $service['service_description']) . '_';
+   echo '<td>', $service['service_description'], '</td>';
+   echo '<td class="update status ', $status, '" id="', $prefix, '_status">', $status, '</td>';
+   echo formatDate($services['last_check'], false, $prefix . 'last');
+   echo formatDate($services['next_check'],  true, $prefix . 'next');
+   echo '<td class="update output" id="', $prefix, '_output">', trunc($services['plugin_output']), '</td>';
+   echo '</tr>';
+  }
+ }
+
+ echo '</table>';
+
+?>
+  <script src="script.js" type="text/javascript"></script>
+ </body>
+</html>

style.css

@@ -0,0 +1,48 @@
+body {
+}
+
+td, th {
+ border: 1px solid black;
+ padding: 2px 3px;
+}
+
+table {
+ border-collapse: collapse;
+}
+
+td.status, td.date {
+ text-align: center;
+}
+
+td.status {
+ width: 100px;
+}
+
+td.status.OK {
+ background-color: green;
+ color: white;
+}
+
+td.status.Unknown {
+ background-color: yellow;
+ color: black;
+}
+
+td.status.Warning, td.date.overdue {
+ background-color: orange;
+ color: black;
+}
+
+td.status.Critical, td.date.never {
+ background-color: red;
+ color: white;
+}
+
+.updated {
+ text-decoration: blink; 
+}
+
+td.output {
+ font-family: monospace;
+ font-style: italic;
+}