92 lines
2.6 KiB
JavaScript
92 lines
2.6 KiB
JavaScript
var Tinkerforge = require('../Tinkerforge')
|
|
, Conf = require('./config.json')
|
|
, Helper = require('../Adawim/helper')
|
|
, Log = require('../Adawim/logging')
|
|
, http = require('http');
|
|
|
|
|
|
Helper.each(Conf.items, function(item) {
|
|
var HOST = item.host;
|
|
var PORT = item.port;
|
|
var UID = item.uid;
|
|
|
|
Log.log('Init ' + UID);
|
|
|
|
var ipcon = new Tinkerforge.IPConnection(); // Create IP connection
|
|
var dus = new Tinkerforge.BrickletDistanceUS(UID, ipcon); // Create device object
|
|
|
|
var counter = 0;
|
|
var readyForNextNotification = true;
|
|
|
|
ipcon.connect(HOST, PORT,
|
|
function (error) {
|
|
Log.log('Error: ' + error);
|
|
}
|
|
); // Connect to brickd
|
|
// Don't use device before ipcon is connected
|
|
|
|
ipcon.on(Tinkerforge.IPConnection.CALLBACK_CONNECTED,
|
|
function (connectReason) {
|
|
// Set period for distance value callback to 0.2s (200ms)
|
|
// Note: The distance value callback is only called every 0.2 seconds
|
|
// if the distance value has changed since the last call!
|
|
dus.setDistanceCallbackPeriod(200);
|
|
}
|
|
);
|
|
|
|
// Register distance value callback
|
|
dus.on(Tinkerforge.BrickletDistanceUS.CALLBACK_DISTANCE,
|
|
// Callback function for distance value callback
|
|
function (distance) {
|
|
//Log.log('Distance Value: ' + distance);
|
|
|
|
if(readyForNextNotification) {
|
|
if((item.mode === '<' && distance < item.value) || (item.mode === '>' && distance > item.value)) {
|
|
counter++;
|
|
readyForNextNotification = false;
|
|
|
|
var url2callObj = (counter % 2 == 0 ? item.on.action.on : item.on.action.off);
|
|
|
|
Log.log('Distance Value: ' + distance + ', URL to call: ' + url2callObj.host + ':' + url2callObj.port + url2callObj.path);
|
|
doHoBuDoorBellCall(url2callObj);
|
|
|
|
setTimeout(function() { readyForNextNotification = true; }, item.on.action.timeout);
|
|
}
|
|
}
|
|
}
|
|
);
|
|
|
|
process.on( 'SIGINT', function() {
|
|
Log.log( "Gracefully disconnect " + HOST );
|
|
ipcon.disconnect();
|
|
process.exit( );
|
|
});
|
|
});
|
|
|
|
|
|
/* private */
|
|
function doHoBuDoorBellCall(options) {
|
|
callback = function(response) {
|
|
var str = '';
|
|
|
|
//another chunk of data has been recieved, so append it to `str`
|
|
response.on('data', function (chunk) {
|
|
str += chunk;
|
|
});
|
|
|
|
//the whole response has been recieved, so we just print it out here
|
|
response.on('end', function () {
|
|
Log.log(str);
|
|
});
|
|
}
|
|
|
|
var req = http.request(options, function(res) {
|
|
//Log.inspect('Result', res);
|
|
});
|
|
|
|
req.on('error', function(err) {
|
|
Log.error(err);
|
|
});
|
|
|
|
req.end();
|
|
} |