"use strict"; var inherits = require('util').inherits, debug = require('debug')('homebridge-neato'), botvac = require('node-botvac'), Service, Characteristic; module.exports = function (homebridge) { Service = homebridge.hap.Service; Characteristic = homebridge.hap.Characteristic; homebridge.registerPlatform("homebridge-neato", "NeatoVacuumRobot", NeatoVacuumRobotPlatform); }; function NeatoVacuumRobotPlatform(log, config) { this.log = log; this.serial = "1-3-3-7"; this.email = config['email']; this.password = config['password']; this.hiddenServices = ('disabled' in config ? config['disabled'] : ''); if ('refresh' in config && config['refresh'] !== 'auto') { // parse config parameter this.refresh = parseInt(config['refresh']); // must be integer and positive this.refresh = (typeof this.refresh !== 'number' || (this.refresh % 1) !== 0 || this.refresh < 0) ? 60 : this.refresh; // minimum 60s to save some load on the neato servers this.refresh = (this.refresh > 0 && this.refresh < 60) ? 60 : this.refresh; } // default auto else { this.refresh = 'auto'; } debug("Refresh is set to: " + this.refresh); } NeatoVacuumRobotPlatform.prototype = { accessories: function (callback) { let accessories = []; let platform = this; platform.boundaryNames = []; this.getRobots(function () { if (platform.robots) { platform.robots.forEach((robot, i) => { platform.log("Found robot #" + (i + 1) + " named \"" + robot.name + "\" with serial \"" + robot._serial + "\""); let NeatoVacuumRobotAccessory = require('./accessories/neatVacuumRobot')(Service, Characteristic); let robotAccessory = new NeatoVacuumRobotAccessory(robot, platform); accessories.push(robotAccessory); if (robot.maps) { robot.maps.forEach((map) => { if (map.boundaries) { map.boundaries.forEach((boundary) => { if (boundary.type === "polygon") { accessories.push(new NeatoVacuumRobotAccessory(robot, platform, boundary)) } }) } }) } }) } callback(accessories); }); }, getRobots: function (callback) { debug("Loading your robots"); let client = new botvac.Client(); let that = this; client.authorize(this.email, this.password, false, (error) => { if (error) { that.log(error); that.log.error("Can't log on to neato cloud. Please check your internet connection and your credentials. Try again later if the neato servers have issues."); callback(); } else { client.getRobots((error, robots) => { if (error) { that.log(error); that.log.error("Successful login but can't connect to your neato robot."); callback(); } else { if (robots.length === 0) { that.log.error("Successful login but no robots associated with your account."); that.robots = []; callback(); } else { debug("Found " + robots.length + " robots"); let updatedRobotCount = 0; that.robots = robots; that.robots.forEach((robot) => { robot.getPersistentMaps((error, result) => { if (error) { that.log("Error updating persistent maps: " + error + ": " + result); callback(); return; } robot.maps = result; let processedMapCount = 0; if (robot.maps.length === 0) { callback(); } robot.maps.forEach((map) => { robot.getMapBoundaries(map.id, (error, result) => { if (error) { this.log("error getting boundaries: " + error + ": " + result) } else { map.boundaries = result.boundaries; } processedMapCount++; if (processedMapCount == robot.maps.length) { updatedRobotCount++; if (updatedRobotCount === that.robots.length) { callback(); } } }) }) }) }) } } }); } }); } };