#!/usr/bin/perl

package aquariumTemperatureController;

use DBI;

# To use along with collectd's DBI plugin
my $dsn = 'mysql:serial_devices;host=localhost';
my $user = 'serial_devices';
my $pwd = 'shjHtmrEPcTXZQ5y';

my $dbh = DBI->connect('dbi:'.$dsn, $user, $pwd);

sub terminate {
	$dbh->disconnect();
}

sub gotMessage {
	my $addr = shift;
	my @data = @_;
	
	my $type = chr(shift @data);
	
	if($type eq 'r') { # report
		my ($tank, $target, $power, $probe_0, $probe_1, $ambient) = @data;
		
		$dbh->do(
			'INSERT INTO aquarium_temperature_controller'.
			'(dt, tank, target, power, probe_0, probe_1, ambient)'.
			' VALUES(NOW(), ?, ?, ?, ?, ?, ?)',
			undef,
			$tank, $target, $power, $probe_0, $probe_1, $ambient
		) if($dbh);
	}
}

1;