1
0
mirror of https://github.com/node-red/node-red-nodes.git synced 2023-10-10 13:36:58 +02:00
node-red-nodes/io/emoncms/88-emoncms.js

122 lines
4.1 KiB
JavaScript
Raw Normal View History

/**
2015-11-03 12:03:02 +01:00
* Copyright 2013, 2015 Henrik Olsson henols@gmail.com
*
* 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.
*/
module.exports = function(RED) {
"use strict";
//The Server Definition - this opens (and closes) the connection
function EmoncmsServerNode(n) {
RED.nodes.createNode(this,n);
this.server = n.server;
this.name = n.name;
2014-02-10 15:54:36 +01:00
}
RED.nodes.registerType("emoncms-server",EmoncmsServerNode,{
credentials: {
apikey: {type:"text"}
}
});
2014-02-10 15:54:36 +01:00
function Emoncms(n) {
RED.nodes.createNode(this,n);
this.emonServer = n.emonServer;
var sc = RED.nodes.getNode(this.emonServer);
this.baseurl = sc.server;
this.apikey = sc.credentials.apikey;
this.nodegroup = n.nodegroup || "";
var node = this;
var http;
if (this.baseurl.substring(0,5) === "https") { http = require("https"); }
else { http = require("http"); }
this.on("input", function(msg) {
this.url = this.baseurl + '/input/post.json?';
if (msg.payload.indexOf(':') > -1) {
this.url += 'json={' + msg.payload + '}';
} else {
this.url += 'csv='+msg.payload;
}
this.url += '&apikey='+this.apikey;
var nodegroup = this.nodegroup || msg.nodegroup;
if (nodegroup !== "") {
this.url += '&node=' + nodegroup;
}
if (typeof msg.time !== 'undefined') {
this.url += '&time=' + msg.time;
}
http.get(this.url, function(res) {
msg.rc = res.statusCode;
msg.payload = "";
res.setEncoding('utf8');
res.on('data', function(chunk) {
msg.payload += chunk;
});
res.on('end', function() {
2015-11-03 12:03:02 +01:00
if (msg.rc === 200) {
node.send(msg);
}
});
}).on('error', function(e) {
2015-11-03 12:03:02 +01:00
node.error(e,msg);
});
});
}
RED.nodes.registerType("emoncms",Emoncms);
2015-11-03 12:03:02 +01:00
function Emoncmsin(n) {
RED.nodes.createNode(this,n);
this.emonServer = n.emonServer;
var sc = RED.nodes.getNode(this.emonServer);
this.baseurl = sc.server;
this.apikey = sc.credentials.apikey;
this.feedid = n.feedid
var node = this;
var http;
if (this.baseurl.substring(0,5) === "https") { http = require("https"); }
else { http = require("http"); }
this.on("input", function(msg) {
this.url = this.baseurl + '/feed/value.json';
this.url += '&apikey='+this.apikey;
var feedid = this.feedid || msg.feedid;
if (feedid !== "") {
this.url += '&id=' + feedid;
}
http.get(this.url, function(res) {
msg.rc = res.statusCode;
msg.payload = "";
res.setEncoding('utf8');
res.on('data', function(chunk) {
msg.payload += chunk;
});
res.on('end', function() {
2015-11-03 12:03:02 +01:00
if (msg.rc === 200) {
try {
msg.payload = JSON.parse(msg.payload);
} catch(err) {
// Failed to parse, pass it on
}
node.send(msg);
}
});
}).on('error', function(e) {
2015-11-03 12:03:02 +01:00
node.error(e,msg);
});
});
}
RED.nodes.registerType("emoncms in",Emoncmsin);
}