revgraph.pl

#!/usr/bin/env perl

use strict;
use warnings;
use utf8;

use Net::MQTT::Simple;
use Net::Graphite;

# Setup mqtt connection
my $mqtt = Net::MQTT::Simple->new('revspace.nl');

# Setup mqtt connection
my $graphite = Net::Graphite->new(
     host                  => '127.0.0.1',
     port                  => 2003,
     trace                 => 0,                
     proto                 => 'tcp',
     timeout               => 1,
     fire_and_forget       => 1,
     return_connect_error  => 0
);

my %topics;

# "Connect" to graphite
$graphite->connect;


# subscribe to sensors with weird topics
$mqtt->subscribe(
	"revspace/sensors/+" => sub {
		my ($topic, $message) = @_;

		my $since = $topics{$topic} ? ( time() - $topics{$topic} ) : ( time() - 0 );

		my ($type) = $topic =~ /revspace\/sensors\/(.*)/;
		($message) = $message =~ m{(\d+(?:\.\d+)?)};

		my $graphite_path = "revgraph.sensor.$type.general.0";

		$graphite->send(
			path => $graphite_path,
			value => $message,
			time => time(),
		) unless $since > 1800;

		$topics{$topic} = time();
	}
);

$mqtt->subscribe(
	"revspace/sensors/co2/mhz19" => sub {
		my ($topic, $message) = @_;

		my $since = $topics{$topic} ? ( time() - $topics{$topic} ) : ( time() - 0 );

		($message) = $message =~ m{(\-?\d+(?:\.\d+)?)};

		$graphite->send(
			path => 'revgraph.sensor.co2.mhz19.0',
			value => $message,
			time => time(),
		) unless $since > 1800;

		$topics{$topic} = time();
	}
);

# subscribe to standard sensor topics
$mqtt->subscribe(
	"revspace/sensors/+/+/+" => sub {
		my ($topic, $message) = @_;

		my $since = $topics{$topic} ? ( time() - $topics{$topic} ) : ( time() - 0 );

		my ($type, $room, $id) = $topic =~ /revspace\/sensors\/([^\/]+)\/([^\/]+)\/([^\/]+)/;
		($message) = $message =~ m{(\-?\d+(?:\.\d+)?)};

		my $graphite_path = "revgraph.sensor.$type.$room.$id";

		$graphite->send(
			path => $graphite_path,
			value => $message,
			time => time(),
		) unless $since > 1800;

		$topics{$topic} = time();
	}
);

# subscribe to open/closed space
$mqtt->subscribe(
	"revspace/state" => sub {
		my ($topic, $message) = @_;

		$message = $message eq 'open' ? 1 : 0;

		$graphite->send(
			path => "revgraph.state",
			value => $message,
			time => time(),
		);
	}
);

# Run this thing
$mqtt->run;