index.js

'use strict';
var homebridge;
var NetatmoWeatherStationAccessory, NetatmoThermostatAccessory;
var async = require('async');

// TODO: user info auswerten (metrisch /imperial ...)

module.exports = function (pHomebridge) {
  homebridge = pHomebridge;
  homebridge.registerPlatform("homebridge-netatmo", "netatmo", NetatmoPlatform);
};

var netatmo = require("netatmo");
var inherits = require('util').inherits;

class NetatmoPlatform {
  constructor(log, config) {
    this.log = log;
    this.config = config || {};
    this.foundAccessories = [];

    // If this log message is not seen, most likely the config.js is not found.
    this.log.debug('Creating NetatmoPlatform');

    if (config.mockapi) {
      this.log.warn('CAUTION! USING FAKE NETATMO API: ' + config.mockapi);
      this.api = require("./lib/netatmo-api-mock")(config.mockapi);
    } else {
      this.api = new netatmo(config.auth);
    }
    this.api.on("error", function (error) {
      this.log.error('ERROR - Netatmo: ' + error);
    }.bind(this));
    this.api.on("warning", function (error) {
      this.log.warn('WARN - Netatmo: ' + error);
    }.bind(this));
  }

  accessories(callback) {
    this.log.debug("Loading accessories");

    var calls = this.loadDevices();
  
    async.parallel(calls, function(err, result) {
      if (err) {
        this.log("Error: " + err);
      } else {
        for (var i = 0; i < result.length; i++) {
          for (var j = 0; j < result[i].length; j++) {
            this.foundAccessories.push(result[i][j]);
          }
        }
      }
      callback(this.foundAccessories);    
    }.bind(this));
  }

  loadDevices() {
    var deviceTypes = this.config.deviceTypes || [ "weatherstation", "thermostat", "camera" ];

    var calls = [];

    deviceTypes.forEach(function(deviceType) {
      try {
        calls.push(function(callback) {
          var DeviceType = require('./device/' + deviceType + '-device.js')(homebridge);
          var devType = new DeviceType(this.log, this.api, this.config);
          devType.buildAccessoriesForDevices(function(err, deviceAccessories) {
            callback(err, deviceAccessories);
          });
        }.bind(this));
      } catch (err) {
        this.log("Could not process device " + deviceType);
        this.log(err);
        this.log(err.stack); 
      }
    }.bind(this));

    return calls;
  }
}