mirror of
https://github.com/node-red/node-red-nodes.git
synced 2023-10-10 13:36:58 +02:00
c4ec78e854
Squashed commits: [3079c2d] Added Heatmiser input and output nodes [62bd1f3] Added Heatmiser input and output nodes Fix input node bugs
92 lines
2.8 KiB
JavaScript
92 lines
2.8 KiB
JavaScript
/**
|
|
* Copyright 2014 Sean Bedford
|
|
*
|
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
* you may not use this file except in compliance with the License.
|
|
* You may obtain a copy of the License at
|
|
*
|
|
* http://www.apache.org/licenses/LICENSE-2.0
|
|
*
|
|
* Unless required by applicable law or agreed to in writing, software
|
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
* See the License for the specific language governing permissions and
|
|
* limitations under the License.
|
|
**/
|
|
|
|
var RED = require(process.env.NODE_RED_HOME+"/red/red");
|
|
|
|
var Heatmiser = require("heatmiser");
|
|
var util = require('util');
|
|
|
|
function HeatmiserOutputNode(n) {
|
|
// TODO - holiday and hot water cases when confirmed working
|
|
var DEBUG = false;
|
|
RED.nodes.createNode(this,n);
|
|
this.ip = n.ip || "192.168.0.1";
|
|
this.pin = n.pin || "1234";
|
|
this.pollTime = n.pollTime*60*1000 || 30*60*1000;
|
|
this.pollIntervalRef = undefined;
|
|
hmoutnode = this;
|
|
|
|
this.hm = new Heatmiser(this.ip, this.pin);
|
|
|
|
this.hm.on('success', function(data) {
|
|
if (DEBUG) {
|
|
util.log("[100-heatmiser-in.js] - Successfully wrote data. Response : " + JSON.stringify(data));
|
|
}
|
|
hmoutnode.send({topic: "", payload:JSON.stringify(data.dcb)});
|
|
});
|
|
this.hm.on('error', function(data) {
|
|
if (DEBUG) {
|
|
util.log("[100-heatmiser-in.js] - Error during data setting : " + JSON.stringify(data));
|
|
}
|
|
hmoutnode.send(data);
|
|
});
|
|
|
|
this.read = function() {
|
|
if (hmoutnode.hm) {
|
|
hmoutnode.hm.read_device();
|
|
}
|
|
};
|
|
|
|
if (!this.currentStatus) {
|
|
this.read();
|
|
this.pollIntervalRef = setInterval(this.read, this.pollTime);
|
|
}
|
|
|
|
this.on("close", function() {
|
|
if (this.pollIntervalRef) {
|
|
clearInterval(this.pollIntervalRef);
|
|
this.pollIntervalRef = undefined;
|
|
}
|
|
});
|
|
|
|
this.on("input", function(message) {
|
|
// Valid inputs are heating:{target:, hold:}, read:, runmode:frost/heating, holiday:{enabled:, time:}, hotwater:{'on':1/0 / 'boost':1/0}
|
|
if (message.payload == "undefined" || !message.payload) {
|
|
message.payload = {read : true};
|
|
}
|
|
if (typeof(message.payload) == "string") {
|
|
message.payload = JSON.parse(message.payload);
|
|
}
|
|
if (message.payload.read) {
|
|
hmoutnode.read();
|
|
}
|
|
else if (message.payload) {
|
|
// Compare message.payload data to confirm valid and send to thermostat
|
|
var validInputs = ["heating", "runmode"];
|
|
for (var key in message.payload) {
|
|
if (message.payload.hasOwnProperty(key)) {
|
|
if (validInputs.indexOf(key) < 0) {
|
|
util.log("[100-heatmiser.js] Warning: Unsupported key ("+key+") passed!");
|
|
return;
|
|
}
|
|
}
|
|
}
|
|
hmoutnode.validateAndWrite(message);
|
|
}
|
|
});
|
|
}
|
|
RED.nodes.registerType("heatmiser-out",HeatmiserOutputNode);
|