Comfort to MQTT - Printable Version

Code:

#!/usr/bin/perl



use Net::MQTT::Simple;

use IO::Select;

use Time::HiRes qw(time);

use strict;



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

###&nbsp;&nbsp;&nbsp; &nbsp; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; by:APR ###

###&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ###

### Perform the following system commands:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ###

### lsusb&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ###

### lsusb -d 0403:6001 -v | grep iSerial&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ###

### nano /etc/udev/rules.d/99-usb-serial.rules&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ###

### SUBSYSTEM==\"tty\", ATTRS{idVendor}==\"0403\", ATTRS{idProduct}==\"6001\", ATTRS{serial}==\"A7007iyv\", SYMLINK+=\"comfort\"

###&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ###

### Change the following lines to suit your configuration ###

###&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ###

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



my $comfort_port = \'/dev/comfort\';

my $mqtt_hostname = \'localhost\';

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

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



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



my $serial_location = \"off\";

my $serie =&nbsp; IO::Select-&gt;new();



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

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



my $ts = time();



while(1) {



&nbsp; if ( time() - $ts &gt; 10 ) { # every 10 secs

&nbsp;&nbsp;&nbsp; $ts = time();

&nbsp;&nbsp;&nbsp; my $SL = `ls -al /dev/comfort 2&gt;&amp;1`;

&nbsp;&nbsp;&nbsp; if( $SL =~ /(comfort -&gt; .+)/ ) { # isconnected

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; $SL = $1;

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if ( $serial_location eq \"off\" ) { # was plugged

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; print localtime(time) . \" $SL\

\";

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; $serial_location = $SL;

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; open(SERIAL,&nbsp; \"+&lt;$comfort_port\") or die \"Can\'t open serial port: $!\

\";

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; $serie-&gt;add(\\*SERIAL);

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; elsif ( $SL ne $serial_location) { # was restarted

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; print localtime(time) . \" $SL\

\";

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; $serial_location = $SL;

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; $serie-&gt;remove(\\*SERIAL);

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; close(SERIAL);



&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; open(SERIAL,&nbsp; \"+&lt;$comfort_port\") or die \"Can\'t open serial port: $!\

\";

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; $serie-&gt;add(\\*SERIAL);

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }

&nbsp;&nbsp;&nbsp; }

&nbsp;&nbsp;&nbsp; else {&nbsp; # is disconnected

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if($serial_location ne \"off\") { # was removed

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; print localtime(time) . \"UCM disconnected\

\";

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; $serial_location = \"off\";

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; $serie-&gt;remove(\\*SERIAL);

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; close(SERIAL);

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }

&nbsp;&nbsp;&nbsp; }

&nbsp; }

&nbsp; $mqtt-&gt;tick(0.1);

&nbsp; if($serial_location ne \"off\") {

&nbsp;&nbsp;&nbsp; if ($serie-&gt;can_read(.01)) {

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; my $recv = &lt;SERIAL&gt;;

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; $recv =~ tr/\\x03\\x0D\\x0A//d;

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; $mqtt-&gt;publish($mqtt_from_comfort =&gt; $recv);

&nbsp;&nbsp;&nbsp; }

&nbsp; }

}



sub callback {

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

&nbsp; if($serial_location&nbsp; ne \"off\") { print SERIAL chr(0x03) . \"$message\\

\"; }

&nbsp; else { $mqtt-&gt;publish($mqtt_from_comfort =&gt; \"OFFLINE\"); }

}

Code:

var string = msg.payload;

var re = /^s[r\\?](..)(..)(..)/; // regex to extract LSB, MSB

var sensor = msg.payload.replace(re, \"$1\"); //get sensor id

var hex = msg.payload.replace(re, \"$3$2\"); //Store MSB LSB

var dec = parseInt(hex,16); // convert to Decimal



if ((dec &amp; 0x8000) &gt; 0) { // handle negative numbers&nbsp; &nbsp;

&nbsp; dec = dec - 0x10000;

}

switch(sensor) {&nbsp; &nbsp; 

&nbsp; case \"00\":&nbsp; &nbsp; &nbsp; &nbsp; 

&nbsp; &nbsp; msg.topic = \"house/floor2/livingroom/temperature\";&nbsp; &nbsp; &nbsp; &nbsp; 

&nbsp; &nbsp; break;&nbsp; &nbsp; 

&nbsp; case \"09\":&nbsp; &nbsp; &nbsp; &nbsp; 

&nbsp; &nbsp; msg.topic = \"house/floor2/bedroom/temperature\";&nbsp; &nbsp; &nbsp; &nbsp; 

&nbsp; &nbsp; break;&nbsp; &nbsp; 

&nbsp; default:&nbsp; &nbsp; &nbsp; &nbsp; 

&nbsp; &nbsp; msg.topic = \"unspecified\";

}



msg.payload = dec;return msg;