current.php

#!/usr/bin/php
<?php

$time = time();
$time -= $time%300;

chdir(dirname(__FILE__));
$config_file = 'config.properties';

require_once('common.php');

$query = 'SELECT id, short, decimals FROM sensor_values';
$values = db_query($query);

$query = 'SELECT id FROM sensors';
$sensors = db_query($query);

chdir($config['munin_data_directory']);

$query1 = 'SELECT COUNT(*) value_count FROM sensor_cache WHERE sensor = ? AND what = ?';
$query2 = 'SELECT UNIX_TIMESTAMP(timestamp) timestamp, value FROM sensor_cache FORCE INDEX (sensor_cache_sensor_what_timestamp_idx) WHERE sensor = ? AND what = ? AND DATE_SUB(NOW(), INTERVAL 1 DAY) < timestamp ORDER BY timestamp DESC LIMIT 0, 1';
foreach($sensors as $sensor) {
	foreach($values as $value) {
#		$result = db_query($query1, array($sensor['id'], $value['id']));
#		if($result[0]['value_count'] == 0) {
#			// there is no data for this combination of 'sensor' and 'what' in sensor_cache,
#			// so there won't be any data in sensor_data either
#			continue;
#		}
#
		$data = db_query($query2, array($sensor['id'], $value['id']));
		if(count($data) > 0) {
			$timestamp = intval($data[0]['timestamp']);
			$measurement = floatval($data[0]['value']);

			if(time()-$timestamp < $config['value_outdated_period']) {
				$measurement = round($measurement, $value['decimals']);
				$pattern = "{$config['munin_prefix']}-sensor*{$value['short']}*sensor{$sensor['id']}-g.rrd";
				foreach(glob($pattern) as $filename) {
					echo "rrdtool update $filename $time:$measurement\n";
					system("rrdtool update $filename $time:$measurement\n");
				}	
			}
		}
	}
}