index.js

var exec = require("child_process").exec;
var locks = require('locks');
var request = require('request');

var Service, Characteristic;

module.exports = function(homebridge) {
  Service = homebridge.hap.Service;
  Characteristic = homebridge.hap.Characteristic;
  homebridge.registerAccessory('homebridge-rfremote-fan', 'RF-Remote Fan', FanAccessory);
};

function FanAccessory(log, config) {
  this.log = log;

  this.host = config.host;
  this.name = config.name;
  this.id = config.id;

  this.state = {
    power: false,
    speed: 25,
  };
  this.mutex = locks.createMutex()
}

FanAccessory.prototype.getRelays = function(value, callback) {
  request({
    url: 'http://' + this.host + '/rfremotefan/api/v1.0/status',
    method: 'GET',
    json: true,
    body: value,
  }, function(error, response, body) {
    if (error) {
      callback(error);
    } else if (response.statusCode == 200) {
      callback(null, body);
    } else {
      callback(new Error('HTTP response ' + response.statusCode + ': ' + JSON.stringify(body)));
    }
  });
};

FanAccessory.prototype.updateRelays = function(value, callback) {

  this.log('update relays: ' + value);
	
  request({
    url: 'http://' + this.host + '/rfremotefan/api/v1.0/update',
    method: 'POST',
    json: true,
    body: value,
  }, function(error, response, body) {
    if (error) {
      callback(error);
    } else if (response.statusCode == 200) {
      callback(null);
    } else {
      callback(new Error('HTTP response ' + response.statusCode + ': ' + JSON.stringify(body)));
    }
  });
};

FanAccessory.prototype.getFanState = function(callback) {
  info = {"id": this.id}
  this.getRelays(info, (error, data) => {
    if (error) {
      callback(error);
    } else {
      var state = {}
	  speed = data["speed"]
      if (speed == 3) {
        state.power = true;
        state.speed = 100;
      } else if (speed == 2) {
        state.power = true;
        state.speed = 50;
      } else if (speed == 1) {
        state.power = true;
        state.speed = 25;
      } else {
        state.power = false;
        state.speed = 25;
      }
      // state.temperature = data.temperature;
	  this.log("speed ---" + state.speed)
      this.state = state;
      callback(null, state);
    }
  });
};

FanAccessory.prototype.setFanState = function(state, callback) {
  var relay;
  if (state.power && state.speed > 50) {
    relay = 3;
  } else if (state.power && state.speed > 25) {
    relay = 2;
  } else if (state.power && state.speed > 0) {
    relay = 1;
  } else {
    relay = 0;
  }

  this.log('active relay ' + relay);

  var update1 = {
  };
  update1["id"] = this.id;
  update1["speed"] = relay;

  var update2 = {
    1: false,
    2: false,
    3: false,
  };
  if (relay) {
    delete update2[relay];
  }

  this.mutex.timedLock(5000, (error) => {
    if (error) {
      callback(error);
      return;
    }

    this.updateRelays(update1, (error) => {
      if (error) {
        this.mutex.unlock();
        callback(error);
        return;
      }

      this.updateRelays(update1, (error) => {
        this.mutex.unlock();
        callback(error);
        return;
      });
    });
  });
}

FanAccessory.prototype.identify = function(callback) {
  this.log("Identify requested!");
  this.updateRelays({4: true}, (error) => {
    if (error) {
      callback(error);
      return;
    }
    setTimeout(() => {
      this.updateRelays({4: false}, callback);
    }, 500);
  });
};

FanAccessory.prototype.getServices = function() {
  this.fanService = new Service.Fan();
  this.fanService.getCharacteristic(Characteristic.On)
    .on('get', this.getOn.bind(this))
    .on('set', this.setOn.bind(this));
  this.fanService.getCharacteristic(Characteristic.RotationSpeed)
    .setProps({
      minValue: 0,
      maxValue: 100,
      minStep: 25,
    })
    .on('get', this.getSpeed.bind(this))
    .on('set', this.setSpeed.bind(this));

  return [this.fanService];
};

FanAccessory.prototype.getOn = function(callback) {
  this.getFanState(function(error, state) {
    callback(null, state && state.power);
  });
};

FanAccessory.prototype.setOn = function(value, callback) {
  if (this.state.power != value) {
    this.log('setting power to ' + value);
    this.state.power = value;
    this.setFanState(this.state, callback);
  } else {
    callback(null);
  }
};

FanAccessory.prototype.getSpeed = function(callback) {
  this.log("get speed");
  this.getFanState(function(error, state) {
    callback(null, state && state.speed);
  });
};

FanAccessory.prototype.setSpeed = function(value, callback) {
  if (this.state.speed != value) {
    this.log('setting speed to ' + value);
    this.state.speed = value;
    this.setFanState(this.state, callback);
  } else {
    callback(null);
  }
};