Add fixes for linters, add github workflows
This runs eslint --fix as well as manually fixing things that the automatic fixer couldn't handle.
This commit is contained in:
314
node_helper.js
314
node_helper.js
@ -1,210 +1,210 @@
|
||||
var NodeHelper = require('node_helper');
|
||||
|
||||
module.exports = NodeHelper.create({
|
||||
start: function() {
|
||||
this.setTimer(30 * 60 * 1000);
|
||||
},
|
||||
start: function() {
|
||||
this.setTimer(30 * 60 * 1000);
|
||||
},
|
||||
|
||||
doUpdate: function() {
|
||||
var self = this;
|
||||
getPoolData(this.config, function(poolData) {
|
||||
self.sendSocketNotification('SCREENLOGIC_RESULT', poolData);
|
||||
});
|
||||
},
|
||||
doUpdate: function() {
|
||||
var self = this;
|
||||
getPoolData(this.config, function(poolData) {
|
||||
self.sendSocketNotification('SCREENLOGIC_RESULT', poolData);
|
||||
});
|
||||
},
|
||||
|
||||
setCircuit: function(circuitState) {
|
||||
var self = this;
|
||||
setCircuitState(circuitState, function(poolStatus) {
|
||||
self.sendSocketNotification('SCREENLOGIC_CIRCUIT_DONE', {circuitState: circuitState, status: poolStatus});
|
||||
});
|
||||
},
|
||||
setCircuit: function(circuitState) {
|
||||
var self = this;
|
||||
setCircuitState(circuitState, function(poolStatus) {
|
||||
self.sendSocketNotification('SCREENLOGIC_CIRCUIT_DONE', {circuitState: circuitState, status: poolStatus});
|
||||
});
|
||||
},
|
||||
|
||||
setHeatpoint: function(heatpoint) {
|
||||
var self = this;
|
||||
setHeatpointState(heatpoint, function(poolStatus) {
|
||||
self.sendSocketNotification('SCREENLOGIC_HEATPOINT_DONE', {heatpoint: heatpoint, status: poolStatus});
|
||||
});
|
||||
},
|
||||
setHeatpoint: function(heatpoint) {
|
||||
var self = this;
|
||||
setHeatpointState(heatpoint, function(poolStatus) {
|
||||
self.sendSocketNotification('SCREENLOGIC_HEATPOINT_DONE', {heatpoint: heatpoint, status: poolStatus});
|
||||
});
|
||||
},
|
||||
|
||||
setHeatstate: function(heatstate) {
|
||||
var self = this;
|
||||
setHeatstateState(heatstate, function(poolStatus) {
|
||||
self.sendSocketNotification('SCREENLOGIC_HEATSTATE_DONE', {heatstate: heatstate, status: poolStatus});
|
||||
});
|
||||
},
|
||||
setHeatstate: function(heatstate) {
|
||||
var self = this;
|
||||
setHeatstateState(heatstate, function(poolStatus) {
|
||||
self.sendSocketNotification('SCREENLOGIC_HEATSTATE_DONE', {heatstate: heatstate, status: poolStatus});
|
||||
});
|
||||
},
|
||||
|
||||
setLightcmd: function(lightCmd) {
|
||||
var self = this;
|
||||
setLights(lightCmd, function(poolStatus) {
|
||||
self.sendSocketNotification('SCREENLOGIC_LIGHTCMD_DONE', {lightCmd: lightCmd, status: poolStatus});
|
||||
});
|
||||
},
|
||||
setLightcmd: function(lightCmd) {
|
||||
var self = this;
|
||||
setLights(lightCmd, function(poolStatus) {
|
||||
self.sendSocketNotification('SCREENLOGIC_LIGHTCMD_DONE', {lightCmd: lightCmd, status: poolStatus});
|
||||
});
|
||||
},
|
||||
|
||||
restartTimer: function() {
|
||||
var interval = this.updateInterval;
|
||||
this.updateInterval = undefined;
|
||||
this.setTimer(interval);
|
||||
},
|
||||
restartTimer: function() {
|
||||
var interval = this.updateInterval;
|
||||
this.updateInterval = undefined;
|
||||
this.setTimer(interval);
|
||||
},
|
||||
|
||||
setTimer: function(updateInterval) {
|
||||
var update = true;
|
||||
update = typeof this.updateInterval === 'undefined' || this.updateInterval != updateInterval;
|
||||
this.updateInterval = updateInterval;
|
||||
setTimer: function(updateInterval) {
|
||||
var update = true;
|
||||
update = typeof this.updateInterval === 'undefined' || this.updateInterval !== updateInterval;
|
||||
this.updateInterval = updateInterval;
|
||||
|
||||
if (update) {
|
||||
if (typeof this.timer !== 'undefined') {
|
||||
clearInterval(this.timer);
|
||||
}
|
||||
if (update) {
|
||||
if (typeof this.timer !== 'undefined') {
|
||||
clearInterval(this.timer);
|
||||
}
|
||||
|
||||
var self = this;
|
||||
self.timer = setInterval(function() {
|
||||
self.doUpdate()
|
||||
}, self.updateInterval);
|
||||
}
|
||||
},
|
||||
var self = this;
|
||||
self.timer = setInterval(function() {
|
||||
self.doUpdate()
|
||||
}, self.updateInterval);
|
||||
}
|
||||
},
|
||||
|
||||
socketNotificationReceived: function(notification, payload) {
|
||||
if (notification === 'SCREENLOGIC_CONFIG') {
|
||||
this.config = payload;
|
||||
this.setTimer(this.config.updateInterval);
|
||||
}
|
||||
if (notification === 'SCREENLOGIC_UPDATE') {
|
||||
this.doUpdate();
|
||||
}
|
||||
if (notification === 'SCREENLOGIC_CIRCUIT') {
|
||||
this.setCircuit(payload);
|
||||
}
|
||||
if (notification === 'SCREENLOGIC_HEATPOINT') {
|
||||
this.setHeatpoint(payload);
|
||||
}
|
||||
if (notification === 'SCREENLOGIC_HEATSTATE') {
|
||||
this.setHeatstate(payload);
|
||||
}
|
||||
if (notification === 'SCREENLOGIC_LIGHTCMD') {
|
||||
this.setLightcmd(payload);
|
||||
}
|
||||
}
|
||||
socketNotificationReceived: function(notification, payload) {
|
||||
if (notification === 'SCREENLOGIC_CONFIG') {
|
||||
this.config = payload;
|
||||
this.setTimer(this.config.updateInterval);
|
||||
}
|
||||
if (notification === 'SCREENLOGIC_UPDATE') {
|
||||
this.doUpdate();
|
||||
}
|
||||
if (notification === 'SCREENLOGIC_CIRCUIT') {
|
||||
this.setCircuit(payload);
|
||||
}
|
||||
if (notification === 'SCREENLOGIC_HEATPOINT') {
|
||||
this.setHeatpoint(payload);
|
||||
}
|
||||
if (notification === 'SCREENLOGIC_HEATSTATE') {
|
||||
this.setHeatstate(payload);
|
||||
}
|
||||
if (notification === 'SCREENLOGIC_LIGHTCMD') {
|
||||
this.setLightcmd(payload);
|
||||
}
|
||||
}
|
||||
});
|
||||
|
||||
const ScreenLogic = require('node-screenlogic');
|
||||
var foundUnit;
|
||||
|
||||
function getPoolData(config, cb) {
|
||||
if (!foundUnit && typeof config !== 'undefined' && config.serverAddress && config.serverPort) {
|
||||
foundUnit = new ScreenLogic.UnitConnection(config.serverPort, config.serverAddress);
|
||||
}
|
||||
if (!foundUnit && typeof config !== 'undefined' && config.serverAddress && config.serverPort) {
|
||||
foundUnit = new ScreenLogic.UnitConnection(config.serverPort, config.serverAddress);
|
||||
}
|
||||
|
||||
if (foundUnit) {
|
||||
populateSystemData(cb);
|
||||
} else {
|
||||
findServer(cb);
|
||||
}
|
||||
if (foundUnit) {
|
||||
populateSystemData(cb);
|
||||
} else {
|
||||
findServer(cb);
|
||||
}
|
||||
}
|
||||
|
||||
function findServer(cb) {
|
||||
var finder = new ScreenLogic.FindUnits();
|
||||
finder.on('serverFound', function(server) {
|
||||
finder.close();
|
||||
var finder = new ScreenLogic.FindUnits();
|
||||
finder.on('serverFound', function(server) {
|
||||
finder.close();
|
||||
|
||||
foundUnit = new ScreenLogic.UnitConnection(server);
|
||||
populateSystemData(cb);
|
||||
});
|
||||
foundUnit = new ScreenLogic.UnitConnection(server);
|
||||
populateSystemData(cb);
|
||||
});
|
||||
|
||||
finder.search();
|
||||
finder.search();
|
||||
}
|
||||
|
||||
function populateSystemData(cb) {
|
||||
var poolData = {};
|
||||
var poolData = {};
|
||||
|
||||
if (!foundUnit) {
|
||||
cb(poolData);
|
||||
return;
|
||||
}
|
||||
if (!foundUnit) {
|
||||
cb(poolData);
|
||||
return;
|
||||
}
|
||||
|
||||
foundUnit.once('loggedIn', function() {
|
||||
foundUnit.getControllerConfig();
|
||||
}).once('controllerConfig', function(config) {
|
||||
poolData.controllerConfig = config;
|
||||
poolData.degStr = config.degC ? 'C' : 'F';
|
||||
foundUnit.getPoolStatus();
|
||||
}).once('poolStatus', function(status) {
|
||||
poolData.status = status;
|
||||
foundUnit.once('loggedIn', function() {
|
||||
foundUnit.getControllerConfig();
|
||||
}).once('controllerConfig', function(config) {
|
||||
poolData.controllerConfig = config;
|
||||
poolData.degStr = config.degC ? 'C' : 'F';
|
||||
foundUnit.getPoolStatus();
|
||||
}).once('poolStatus', function(status) {
|
||||
poolData.status = status;
|
||||
|
||||
foundUnit.close();
|
||||
cb(poolData);
|
||||
});
|
||||
foundUnit.close();
|
||||
cb(poolData);
|
||||
});
|
||||
|
||||
foundUnit.connect();
|
||||
foundUnit.connect();
|
||||
}
|
||||
|
||||
function setCircuitState(circuitState, cb) {
|
||||
if (!foundUnit) {
|
||||
cb();
|
||||
return;
|
||||
}
|
||||
if (!foundUnit) {
|
||||
cb();
|
||||
return;
|
||||
}
|
||||
|
||||
foundUnit.once('loggedIn', function() {
|
||||
foundUnit.setCircuitState(0, circuitState.id, circuitState.state);
|
||||
}).once('circuitStateChanged', function() {
|
||||
foundUnit.getPoolStatus();
|
||||
}).once('poolStatus', function(status) {
|
||||
foundUnit.close();
|
||||
cb(status);
|
||||
});
|
||||
foundUnit.once('loggedIn', function() {
|
||||
foundUnit.setCircuitState(0, circuitState.id, circuitState.state);
|
||||
}).once('circuitStateChanged', function() {
|
||||
foundUnit.getPoolStatus();
|
||||
}).once('poolStatus', function(status) {
|
||||
foundUnit.close();
|
||||
cb(status);
|
||||
});
|
||||
|
||||
foundUnit.connect();
|
||||
foundUnit.connect();
|
||||
}
|
||||
|
||||
function setHeatpointState(heatpoint, cb) {
|
||||
if (!foundUnit) {
|
||||
cb();
|
||||
return;
|
||||
}
|
||||
if (!foundUnit) {
|
||||
cb();
|
||||
return;
|
||||
}
|
||||
|
||||
foundUnit.once('loggedIn', function() {
|
||||
foundUnit.setSetPoint(0, heatpoint.body, heatpoint.temperature);
|
||||
}).once('setPointChanged', function() {
|
||||
foundUnit.getPoolStatus();
|
||||
}).once('poolStatus', function(status) {
|
||||
foundUnit.close();
|
||||
cb(status);
|
||||
});
|
||||
foundUnit.once('loggedIn', function() {
|
||||
foundUnit.setSetPoint(0, heatpoint.body, heatpoint.temperature);
|
||||
}).once('setPointChanged', function() {
|
||||
foundUnit.getPoolStatus();
|
||||
}).once('poolStatus', function(status) {
|
||||
foundUnit.close();
|
||||
cb(status);
|
||||
});
|
||||
|
||||
foundUnit.connect();
|
||||
foundUnit.connect();
|
||||
}
|
||||
|
||||
function setHeatstateState(heatstate, cb) {
|
||||
if (!foundUnit) {
|
||||
cb();
|
||||
return;
|
||||
}
|
||||
if (!foundUnit) {
|
||||
cb();
|
||||
return;
|
||||
}
|
||||
|
||||
foundUnit.once('loggedIn', function() {
|
||||
foundUnit.setHeatMode(0, heatstate.body, heatstate.state);
|
||||
}).once('heatModeChanged', function() {
|
||||
foundUnit.getPoolStatus();
|
||||
}).once('poolStatus', function(status) {
|
||||
foundUnit.close();
|
||||
cb(status);
|
||||
});
|
||||
foundUnit.once('loggedIn', function() {
|
||||
foundUnit.setHeatMode(0, heatstate.body, heatstate.state);
|
||||
}).once('heatModeChanged', function() {
|
||||
foundUnit.getPoolStatus();
|
||||
}).once('poolStatus', function(status) {
|
||||
foundUnit.close();
|
||||
cb(status);
|
||||
});
|
||||
|
||||
foundUnit.connect();
|
||||
foundUnit.connect();
|
||||
}
|
||||
|
||||
function setLights(lightCmd, cb) {
|
||||
if (!foundUnit) {
|
||||
cb();
|
||||
return;
|
||||
}
|
||||
if (!foundUnit) {
|
||||
cb();
|
||||
return;
|
||||
}
|
||||
|
||||
foundUnit.once('loggedIn', function() {
|
||||
foundUnit.sendLightCommand(0, lightCmd);
|
||||
}).once('sentLightCommand', function() {
|
||||
foundUnit.getPoolStatus();
|
||||
}).once('poolStatus', function(status) {
|
||||
foundUnit.close();
|
||||
cb(status);
|
||||
});
|
||||
foundUnit.once('loggedIn', function() {
|
||||
foundUnit.sendLightCommand(0, lightCmd);
|
||||
}).once('sentLightCommand', function() {
|
||||
foundUnit.getPoolStatus();
|
||||
}).once('poolStatus', function(status) {
|
||||
foundUnit.close();
|
||||
cb(status);
|
||||
});
|
||||
|
||||
foundUnit.connect();
|
||||
foundUnit.connect();
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user