FhemSwitch.js

// Description: Acceccory Shim to use with homebridge https://github.com/nfarina/homebridge
// Copy this file into the folder: homebridge/accessories

/* config.json Example:
{   
    "global": {
        "url": "127.0.0.1",
        "port": "8083",
        "auth": {"user": "username", "password": "password"}
    },
        
    "bridge": {
        "name": "Homebridge",
        "username": "CC:22:3D:E3:CE:27",
        "port": 51826,
        "pin": "031-45-154"
    },

    "platforms": [],                        
                          
    "accessories": [
        {
            "accessory": "FhemSwitch",
            "name": "flex_lamp"
        },
        {
            "accessory": "FhemSwitch",
            "name": "dining_floorlamp"
        }
    ]                      
}
*/

var Service = require("hap-nodejs").Service;
var Characteristic = require("hap-nodejs").Characteristic;
var request = require("request");

var fs = require('fs');
var path = require('path');

module.exports = {
  accessory: FhemSwitch
}

'use strict';

/**
* Load url
*/
  
var configPath = path.join(__dirname, "../config.json");
var config = JSON.parse(fs.readFileSync(configPath));
var url = config.global.url;
var port = config.global.port;
var base_url = 'http://' + url + ':' + port;
// console.log("base_url " + base_url);
var auth = config.global.auth;
// console.log("user " + auth.user + " password " +  auth.password);


function FhemSwitch(log, config) {
  this.log = this.mylog;
  this.name = config["name"];
  this.base_url = base_url;
  
  if (auth) {
    if( auth.sendImmediately == undefined )
      auth.sendImmediately = false;

    this.request = request.defaults( { 'auth': auth, 'rejectUnauthorized': false } );
  }
  
  this.Characteristic = {};
  this.currentValue = {};
  
  this.longpoll_running = false;
  this.startLongpoll();
}


FhemSwitch.prototype = {

  /**
  * FHEM mylog
  */
  
  mylog: function mylog(msg) {
    var now = new Date().toLocaleString();
    var logmsg = now + " [" + this.name + "] " + msg;
    console.log(logmsg);
  },
  
  /**
  * FHEM Longpoll
  */
  
  startLongpoll: function() {
  
    if( this.longpoll_running )
      return;
    
    this.longpoll_running = true;

    var since = "null";
    var query = "/fhem.pl?XHR=1&inform=type=status;filter=" + this.name + ";since=" + since + 
    ";fmt=JSON&timestamp=" + Date.now();
    var url = encodeURI( this.base_url + query );
    //this.log( 'starting longpoll: ' + url );

    var offset = 0;
    var datastr = "";

    this.request.get( { url: url } ).on( 'data', function(data) {    
      //this.log( 'data: >'+ data + '<');
      if( !data ) 
        return;

      datastr += data;

      for(;;) {
      
        var nIndex = datastr.indexOf("\n", offset);
        if(nIndex < 0) 
          break; // exit for-loop
         
        var dataset = datastr.substr(offset, nIndex-offset);
        
        offset = nIndex + 1;
        if(!dataset.length)
          continue;
        
        var dataobj = JSON.parse(dataset);
        
        //this.log("dataset: " + dataset);
        //this.log('dataobj: ' + dataobj[0] + ', ' + dataobj[1]);
        
        var fhemvalue;
        if (dataobj[0] == this.name) {
          switch (dataobj[1]) {
            case 'on':  fhemvalue = true; break;
            case 'off': fhemvalue = false; break;
          }
          
          if(fhemvalue != this.currentValue.On) {
            //this.log( 'fhemvalue: ' + fhemvalue);
            this.currentValue.On = fhemvalue;        
            this.Characteristic.On.setValue(fhemvalue);
          }
        }
      }
      
      datastr = datastr.substr(offset);
      offset = 0;

    }.bind(this) ).on( 'end', function() {
      this.log( "longpoll ended" );

      this.longpoll_running = false;
      setTimeout( function(){this.startLongpoll()}.bind(this), 2000 );

    }.bind(this) ).on( 'error', function(err) {
      this.log( "longpoll error: " + err );

      this.longpoll_running = false;
      setTimeout( function(){this.startLongpoll()}.bind(this), 5000 );
    }.bind(this) );
  },
      
  /**
  * Characteristic.On
  */
  
  getPowerState: function(callback) {
    
    //this.log("Getting current state...");
    var cmd = '{ReadingsVal("' + this.name + '","state","")}';
    var fhem_url = this.base_url + '/fhem?cmd=' + cmd + '&XHR=1';

    this.request.get({url: fhem_url}, function(err, response, body) {
      //this.log('body: ' + body);
      if (!err && response.statusCode == 200) {
        var state = body.trim();
        if (state.match(/^[A-D]./))  // EnOcean
          state = state.slice(1,2);
        
        //this.log('getPowerState: >' + state + '<');
                
        switch (state) {
          case  '0':
          case  'off':   this.currentValue.On = false; break;
          case  'I':
          case  '1':
          case  'on':    this.currentValue.On = true; break;
          default:      // nothing
        }
        callback(null, this.currentValue.On);
      } 
      else {
        callback(err);
        this.log(err);
        if(response)
          this.log("statusCode: " + response.statusCode + " Message: " + response.statusMessage );
      }
    }.bind(this));
  },
  
  setPowerState: function(boolvalue, callback) {
    
    //this.log("setPowerState: " + boolvalue);
    if (boolvalue == this.currentValue.On) {
      callback();
      return;
    }
    
    var state = "";
    
    switch (boolvalue) {
      case 0:
      case false:       state = 'off'; break;
      case 1:
      case true:        state = 'on';  break; 
      default:          
        this.log("setPowerState: state undefined! boolvalue: >" + boolvalue + "<");
        callback();
        return;
    }
    
    var cmd = 'set ' + this.name + ' ' + state;
    //this.log("cmd: " + cmd);
    
    var fhem_url = this.base_url + '/fhem?cmd=' + cmd + '&XHR=1';    
    //this.log(fhem_url);
        
    this.request({url: fhem_url}, function(err, response, body) {

      if (!err && response.statusCode == 200) {
        this.currentValue.On = boolvalue;
        callback();
        //this.log("State change complete.");
      }
      else {
        callback(err)
        this.log(err);
        if(response)
          this.log("statusCode: " + response.statusCode + " Message: " + response.statusMessage );
      }
    }.bind(this));
  },
  
  /**
  * Accessory Information Identify 
  */
  
  identify: function(callback) {
    //this.log("Identify requested!");
    
    var cmd = 'set ' + this.name + ' ' + 'on-for-timer 2';
    //this.log("cmd: " + cmd);
    
    var fhem_url = this.base_url + '/fhem?cmd=' + cmd + '&XHR=1';    
    //this.log(fhem_url);
        
    this.request({url: fhem_url}, function(err, response, body) {

      if (!err && response.statusCode == 200) {
        callback();
        //this.log("State change complete.");
      } 
      else {
        this.log(err);
        callback(err)
        if(response)
          this.log("statusCode: " + response.statusCode + " Message: " + response.statusMessage );
      }
    }.bind(this));
  },
  
  /**
  * Services and Characteristics
  */
  
  getServices: function() {
    
    var informationService = new Service.AccessoryInformation();
    
    informationService
      .setCharacteristic(Characteristic.Manufacturer, "FHEM Manufacturer")
      .setCharacteristic(Characteristic.Model, "FHEM Model")
      .setCharacteristic(Characteristic.SerialNumber, "FHEM Serial Number")
      .setCharacteristic(Characteristic.Name, this.name);
        
    var FhemSwitchService = new Service.Switch();
    
    this.Characteristic.On = FhemSwitchService
      .getCharacteristic(Characteristic.On)
      .on('get', this.getPowerState.bind(this))
      .on('set', this.setPowerState.bind(this));
    this.currentValue.On = false;
    
    return [informationService, FhemSwitchService];
  }
};