const axios = require('axios'); const EventEmitter = require('events'); const _ = require('lodash'); API_APP_ID = 'zHtVqXt8k4yFyk2QGmgp48D9xZr2G94xWYnF4dak'; API_BASE_URL = 'https://cloud.plejd.com/parse/'; API_LOGIN_URL = 'login'; API_SITES_URL = 'functions/getSites'; // #region logging let debug = ''; const getLogger = () => { const consoleLogger = msg => console.log('plejd-api', msg); if (debug === 'console') { return consoleLogger; } return _.noop; }; const logger = getLogger(); // #endregion class PlejdApi extends EventEmitter { constructor(siteName, username, password, includeRoomsAsLights) { super(); this.includeRoomsAsLights = includeRoomsAsLights; this.siteName = siteName; this.username = username; this.password = password; this.sessionToken = ''; this.site = null; } updateSettings(settings) { if (settings.debug) { debug = 'console'; } else { debug = ''; } } login() { console.log('plejd-api: login()'); console.log('logging into ' + this.siteName); const self = this; const instance = axios.create({ baseURL: API_BASE_URL, headers: { 'X-Parse-Application-Id': API_APP_ID, 'Content-Type': 'application/json' } }); logger('sending POST to ' + API_BASE_URL + API_LOGIN_URL); instance.post( API_LOGIN_URL, { 'username': this.username, 'password': this.password }) .then((response) => { console.log('plejd-api: got session token response'); self.sessionToken = response.data.sessionToken; self.emit('loggedIn'); }) .catch((error) => { if (error.response.status === 400) { console.log('error: server returned status 400. probably invalid credentials, please verify.'); } else { console.log('error: unable to retrieve session token response: ' + error); } }); } getCryptoKey(callback) { console.log('plejd-api: getCryptoKey()'); const self = this; const instance = axios.create({ baseURL: API_BASE_URL, headers: { 'X-Parse-Application-Id': API_APP_ID, 'X-Parse-Session-Token': this.sessionToken, 'Content-Type': 'application/json' } }); logger('sending POST to ' + API_BASE_URL + API_SITES_URL); instance.post(API_SITES_URL) .then((response) => { console.log('plejd-api: got sites response'); self.site = response.data.result.find(x => x.site.title == self.siteName); self.cryptoKey = self.site.plejdMesh.cryptoKey; callback(self.cryptoKey); }) .catch((error) => { console.log('error: unable to retrieve the crypto key. error: ' + error + ' (code: ' + error.response.status + ')'); return Promise.reject('unable to retrieve the crypto key. error: ' + error); }); } getDevices() { let devices = []; // Just log the devices if debug logging enabled if (debug) { logger(JSON.stringify(this.site)); } const roomDevices = {}; for (let i = 0; i < this.site.devices.length; i++) { const device = this.site.devices[i]; const deviceId = device.deviceId; const settings = this.site.outputSettings.find(x => x.deviceParseId == device.objectId); let deviceNum = this.site.deviceAddress[deviceId]; if (settings) { const outputs = this.site.outputAddress[deviceId]; deviceNum = outputs[settings.output]; } // check if device is dimmable const plejdDevice = this.site.plejdDevices.find(x => x.deviceId == deviceId); let { name, type, dimmable } = this._getDeviceType(plejdDevice.hardwareId); if (settings) { dimmable = settings.dimCurve != 'NonDimmable'; } const newDevice = { id: deviceNum, name: device.title, type: type, typeName: name, dimmable: dimmable }; logger(JSON.stringify(newDevice)); if (roomDevices[device.roomId]) { roomDevices[device.roomId].push(newDevice); } else { roomDevices[device.roomId] = [newDevice]; } devices.push(newDevice); } if (this.includeRoomsAsLights) { logger('includeRoomsAsLights is set to true, adding rooms too.'); for (let i = 0; i < this.site.rooms.length; i++) { const room = this.site.rooms[i]; const roomId = room.roomId; const roomAddress = this.site.roomAddress[roomId]; const newDevice = { id: roomAddress, name: room.title, type: 'light', typeName: 'Room', dimmable: roomDevices[roomId].find(x => x.dimmable).length > 0 }; logger(JSON.stringify(newDevice)); devices.push(newDevice); } } return devices; } _getDeviceType(hardwareId) { switch (parseInt(hardwareId)) { case 1: case 11: return { name: "DIM-01", type: 'light', dimmable: true }; case 2: return { name: "DIM-02", type: 'light', dimmable: true }; case 3: return { name: "CTR-01", type: 'light', dimmable: false }; case 4: return { name: "GWY-01", type: 'sensor', dimmable: false }; case 5: return { name: "LED-10", type: 'light', dimmable: true }; case 6: return { name: "WPH-01", type: 'switch', dimmable: false }; case 7: return { name: "REL-01", type: 'switch', dimmable: false }; case 8: case 9: // Unknown return { name: "-unknown-", type: 'light', dimmable: false }; case 10: return { name: "-unknown-", type: 'light', dimmable: false }; case 12: // Unknown return { name: "-unknown-", type: 'light', dimmable: false }; case 13: return { name: "Generic", type: 'light', dimmable: false }; case 14: case 15: case 16: // Unknown return { name: "-unknown-", type: 'light', dimmable: false }; case 17: return { name: "REL-01", type: 'switch', dimmable: false }; case 18: return { name: "REL-02", type: 'switch', dimmable: false }; case 19: // Unknown return { name: "-unknown-", type: 'light', dimmable: false }; case 20: return { name: "SPR-01", type: 'switch', dimmable: false }; } } } module.exports = { PlejdApi };