3 files changed, 246 insertions, 0 deletions

diff --git a/inc/collectd.inc.php b/inc/collectd.inc.php
new file mode 100644
index 0000000..2724c05
--- /dev/null
+++ b/inc/collectd.inc.php
@@ -0,0 +1,176 @@
+<?php
+
+require_once 'conf/common.inc.php';
+
+# returns an array of all collectd hosts
+function collectd_hosts() {
+        global $CONFIG;
+
+        if (!is_dir($CONFIG['datadir']))
+                return false;
+
+        $dir = scandir($CONFIG['datadir']);
+        foreach($dir as $k => $v) {
+                if(!is_dir($CONFIG['datadir'].'/'.$v) || $v == '.' || $v == '..')
+                        unset($dir[$k]);
+        }
+        return($dir);
+}
+
+# returns an array of plugins/pinstances/types/tinstances
+function collectd_plugindata($host) {
+        global $CONFIG;
+
+        if (!is_dir($CONFIG['datadir'].'/'.$host))
+                return false;
+
+        chdir($CONFIG['datadir'].'/'.$host);
+        $files = glob("*/*.rrd");
+        if (!$files)
+                return false;
+        
+        $data;
+        $i = 0;
+        foreach($files as $item) {
+                unset($part);
+
+                # split item by plugin/type
+                $part = explode('/', $item);
+                $part[1] = preg_replace('/\.rrd/', '', $part[1]);
+
+                # plugin
+                $data[$i]['p'] = preg_replace('/-.+/', '', $part[0]);
+
+                # plugin instance
+                if(preg_match('/-/', $part[0]))
+                        $data[$i]['pi'] = preg_replace('/^[a-z_]+\-/', '', $part[0]);
+                
+                # type
+                $data[$i]['t'] = preg_replace('/-.+/', '', $part[1]);
+
+                # type instance
+                if(preg_match('/-/', $part[1]))
+                        $data[$i]['ti'] = preg_replace('/^[a-z_]+\-/', '', $part[1]);
+
+                $i++;
+        }
+        return($data);
+}
+
+# returns an array of all plugins of a host
+function collectd_plugins($host) {
+        $plugindata = collectd_plugindata($host);
+
+        $plugins = array();
+        foreach ($plugindata as $item) {
+                if (!in_array($item['p'], $plugins))
+                        $plugins[] = $item['p'];
+        }
+        
+        return $plugins;
+}
+
+# returns an array of all pi/t/ti of an plugin
+function collectd_plugindetail($host, $plugin, $detail, $where=NULL) {
+        $details = array('pi', 't', 'ti');
+        if (!in_array($detail, $details))
+                return false;
+
+        $plugindata = collectd_plugindata($host);
+
+        $return = array();
+        foreach ($plugindata as $item) {
+                if ($item['p'] == $plugin && !in_array($item[$detail], $return) && isset($item[$detail])) {
+                        if ($where) {
+                                $add = true;
+                                # add detail to returnvalue if all where is true
+                                foreach($where as $key => $value) {
+                                        if ($item[$key] != $value)
+                                                $add = false;
+                                }
+                                if ($add)
+                                        $return[] = $item[$detail];
+                        } else {
+                                $return[] = $item[$detail];
+                        }
+                }
+        }
+
+        if (empty($return))
+                return false;
+        
+        return $return;
+}
+
+# generate graph url's for a plugin of a host
+function graphs_from_plugin($host, $plugin) {
+        global $CONFIG;
+
+        $pis = collectd_plugindetail($host, $plugin, 'pi');
+        $ts = collectd_plugindetail($host, $plugin, 't');
+        $tis = collectd_plugindetail($host, $plugin, 'ti');
+        if (!$pis) $pis = array('NULL');
+        if (!$tis) $tis = array('NULL');
+
+        foreach($pis as $pi) {
+                if ($CONFIG['groupby'][$plugin] == 'type') {
+                        foreach ($ts as $t) {
+                                $items = array(
+                                        'h' => $host,
+                                        'p' => $plugin,
+                                        'pi' => $pi,
+                                        't' => $t
+                                );
+                                printf('<a href="%s/%s"><img src="%s/%s"></a>'."\n",
+                                        $CONFIG['weburl'],
+                                        build_url('detail.php', $items).'&x=800&y=350',
+                                        $CONFIG['weburl'],
+                                        build_url('graph.php', $items)
+                                );
+                        }
+                } else {
+                        foreach ($tis as $ti) {
+                                foreach ($ts as $t) {
+                                        $items = array(
+                                                'h' => $host,
+                                                'p' => $plugin,
+                                                'pi' => $pi,
+                                                't' => $t,
+                                                'ti' => $ti
+                                        );
+                                        printf('<a href="%s/%s"><img src="%s/%s"></a>'."\n",
+                                                $CONFIG['weburl'],
+                                                build_url('detail.php', $items).'&x=800&y=350',
+                                                $CONFIG['weburl'],
+                                                build_url('graph.php', $items)
+                                        );
+                                }
+                        }
+                }
+        }
+}
+
+# generate an url with GET values from $items
+function build_url($base, $items, $s=86400) {
+        if (!is_array($items))
+                return false;
+        
+        if (!is_numeric($s))
+                return false;
+
+        $i=0;
+        foreach ($items as $key => $value) {
+                # don't include empty values
+                if ($value == 'NULL')
+                        continue;
+
+                $base .= sprintf('%s%s=%s', $i==0 ? '?' : '&', $key, $value);
+                $i++;
+        }
+        if (!isset($items['s']))
+                $base .= '&s='.$s;
+
+        return $base;
+}
+
+?>
diff --git a/inc/html.inc.php b/inc/html.inc.php
new file mode 100644
index 0000000..d1d2a65
--- /dev/null
+++ b/inc/html.inc.php
@@ -0,0 +1,45 @@
+<?php
+
+function html_start() {
+        echo <<<EOT
+<!DOCTYPE HTML>
+<html>
+<head>
+        <meta http-equiv="Content-Type" content="text/html; charset=utf-8">
+        <title>Collectd Graph Panel</title>
+        <link rel="stylesheet" href="layout/style.css" type="text/css">
+</head>
+<body>
+
+EOT;
+}
+
+function html_end() {
+        echo <<<EOT
+</body>
+</html>
+EOT;
+}
+
+require_once 'conf/common.inc.php';
+require_once 'inc/rrdtool.class.php';
+function host_summary($hosts) {
+        global $CONFIG;
+
+        $rrd = new RRDTool;
+
+        echo "<table class=\"summary\">\n";
+
+        foreach($hosts as $host) {
+                $rrd_info = $rrd->rrd_info($CONFIG['datadir'].'/'.$host.'/load/load.rrd');
+                if (!$rrd_info)
+                        continue;
+                printf('<tr><th><a href="%s/host.php?h=%s">%s</a></th><td>%.2f</td><td>%.2f</td><td>%.2f</td></tr>'."\n",
+                $CONFIG['weburl'],$host, $host,
+                $rrd_info["ds[shortterm].last_ds"], $rrd_info["ds[midterm].last_ds"], $rrd_info["ds[longterm].last_ds"]);
+        }
+
+        echo "</table>\n";
+}
+
+?>
diff --git a/inc/rrdtool.class.php b/inc/rrdtool.class.php
new file mode 100644
index 0000000..e1a7b4b
--- /dev/null
+++ b/inc/rrdtool.class.php
@@ -0,0 +1,25 @@
+<?php
+
+class RRDTool {
+        var $width = 175;
+        var $height = 125;
+
+        function rrd_info($rrdfile) {
+                if (file_exists($rrdfile)) {
+                        $raw_info = shell_exec('/usr/bin/rrdtool info '.$rrdfile);
+                        $raw_array = explode("\n", $raw_info);
+                        foreach ($raw_array as $key => $info) {
+                                if ($info != "") {
+                                        $item_info = explode(" = ", $info);
+                                        $item_info[1] = preg_replace('/"/', '', $item_info[1]);
+                                        $info_array[$item_info[0]] = $item_info[1];
+                                }
+                        }
+                        return($info_array);
+                } else {
+                        return false;
+                }
+        }
+}
+
+?>