Comfort to MQTT - Printable Version

Code:
!/usr/bin/perl



use Net::MQTT::Simple;

use Win32::SerialPort;

use strict;

use warnings;



#hello

print STDERR \"\

\".localtime().\"\

Opening Comfort Communications... \

\";



#Set up &amp; open  port

my $port = Win32::SerialPort-&gt;new(\"COM5\") or die \"Failed to open port: $!\

\";

print STDERR \"Port established: $port \

\";



$port-&gt;baudrate(9600);

$port-&gt;databits(8);

$port-&gt;parity(\"none\");

$port-&gt;stopbits(1);

$port-&gt;handshake(\"xoff\");

$port-&gt;write_settings;





#set up mqtt &amp; polling for inbound messages

my $mqtt_hostname = \'192.168.1.199\';

my $mqtt_to_comfort = \"comfort/to\";

my $mqtt_from_comfort = \"comfort/from\";



my $mqtt = Net::MQTT::Simple-&gt;new($mqtt_hostname);

$mqtt-&gt;subscribe($mqtt_to_comfort,&amp;callback);



#additional control vars

my $serial_stream = \"\"; #container for serial input from comfort

my $ts = time(); #current time

my $defaultreadspeed = 1; #port read interval

my $trace = 1; #enable debug output to console



#setup complete

print STDERR \"Starting to listen...\

\";



while (1) { #main loop



if ( time() - $ts &gt;  $defaultreadspeed ) { #use $defaultreadspeed to throttle



$ts = time(); #set target time for next loop

$serial_stream = $port-&gt;read(200);  #read up to 200 bytes from Comfort



if ($serial_stream) { #check if there\'s data read



doTrace (\"received from Comfort: $serial_stream\");

#split the data into an array based on STX or EOL

#remove those extraneous characters from the resulting array elements

my @reports = split /(?:\\x03|\\x0D|\\x0A)/, $serial_stream;



for my $rep (@reports) { #loop through each of the returned strings

if (length($rep)){ #only process non-empty strings

doTrace (\"sending report to MQTT: $rep\");

$mqtt-&gt;publish($mqtt_from_comfort =&gt; $rep); #send to MQTT

}else{

doTrace(\"empty string, not sending to MQTT\");

}

}



$port-&gt;lookclear; #needed to prevent blocking (?)

} #end check if data read



$mqtt-&gt;tick(1); #force query MQTT input with 1 second timeout



} #time check

}#while loop







################

##SUBROUTINES##

##############



sub callback { #process inputs from MQTT and send to Comfort

my ($topic, $message) = @_;

doTrace (\"got message from MQTT:  $message\");



$port-&gt;lookclear; #needed to prevent blocking (?)

my $str = chr(0x03).$message.\"\\

\"; #prepend STX char and add CR

$port-&gt;write($str); #send to Comfort



doTrace (\"sent to Comfort: $str\");

}



sub doTrace { #write trace logs to console

my ($traceString) = @_;



if ($trace){ #only implement if enabled

my $timestamp = getLoggingTime(); #get timestamp

print STDERR \"$timestamp $traceString \

\"; #print to console

}

}



sub getLoggingTime { #compose a decent looking timestamp



my ($sec,$min,$hour,$mday,$mon,$year,$wday,$yday,$isdst)=localtime(time);

my $nice_timestamp = sprintf ( \"%04d%02d%02d %02d:%02d:%02d\",

$year+1900,$mon+1,$mday,$hour,$min,$sec);

return $nice_timestamp;

}