From: Martin Mares <mj@ucw.cz>
Date: Wed, 10 Jul 2019 08:17:57 +0000 (+0200)
Subject: Air tests: logger
X-Git-Url: http://mj.ucw.cz/gitweb/?a=commitdiff_plain;h=981e7a29ff18c9af865ba55ed28a75655a593dda;p=home-hw.git

Air tests: logger
---

diff --git a/test-opencm3/logger b/test-opencm3/logger
new file mode 100755
index 0000000..f117960
--- /dev/null
+++ b/test-opencm3/logger
@@ -0,0 +1,39 @@
+#!/usr/bin/perl
+use common::sense;
+use Device::SerialPort;
+use Data::Dumper;
+use Net::MQTT::Simple;
+
+my $port = Device::SerialPort->new('/dev/ttyUSB0', 0);
+$port->baudrate(115200);
+$port->parity('none');
+$port->databits(8);
+$port->stopbits(1);
+$port->handshake('none');
+$port->stty_icanon(1);
+$port->read_char_time(1);
+$port->purge_all;
+
+my $mqtt = Net::MQTT::Simple->new('micac.vojtech.kobylisy.czf') or die "Cannot connect to MQTT";
+
+my @desc = qw(outside-exhaust inside-exhaust outside-intake chilled inside-intake bypass fan-pwm);
+
+for (;;) {
+	my $line = $port->read(255);
+	chomp $line;
+	$line =~ s{\r}{}g;
+	next if $line eq "";
+	my @fields = split /\s+/, $line;
+	unless (@fields == @desc + 1 && $fields[0] eq '#') {
+		print STDERR "Malformed line: $line\n";
+		next;
+	}
+	# print join("|", @fields), "\n";
+
+	my $now = time;
+	for my $i (0..$#desc) {
+		$mqtt->retain('burrow/air/' . $desc[$i], join(" ", $fields[$i+1], $now));
+		print $desc[$i], '=', $fields[$i+1], " ";
+	}
+	print "\n";
+}