helpers.js

var Orvibo = require("node-orvibo");
var o = new Orvibo();

var devices = {};

var discoveryTimer = [];
var subscribeTimer = [];
var stateTimer = [];

o.listen(function () {
    discoveryTimer = setInterval(function () {
        o.discover();
    }, 1000);
});

o.on("deviceadded", function (device) {
    clearInterval(discoveryTimer);
    o.discover();
    if (typeof devices[device.macAddress] === 'undefined') {
        subscribeTimer[device.macAddress] = setInterval(function() {
            o.subscribe(device)
        }, 1000);
    } else {
        devices[device.macAddress].state = device.state;
    }
});

o.on('subscribed', function(device) {
    clearInterval(subscribeTimer[device.macAddress]);
    devices[device.macAddress] = device;
});

o.on('setstate', function(device, state) {
    devices[device.macAddress].state = device;
    clearInterval(stateTimer[device.macAddress]);
});

exports.changeState = function(params, callback) {
    if (typeof devices[params.mac] === 'defined') {
        var state = (params.state == 'on');
        stateTimer[params.mac] = setInterval(function() {
            o.setState({device: devices[params.mac], state: state});
        }, 1000);
    }
    callback();
};

exports.getDevices = function(callback) {
    callback(devices);
};

exports.queryDevice = function(params, callback) {
    var device = (typeof devices[params.mac] !== 'undefined') ? devices[params.mac] : false;
    callback(device);
};