mirror of
https://github.com/node-red/node-red-nodes.git
synced 2025-03-01 10:37:43 +00:00
29b2ee9362
A payload format change is necessary for the node to function with emoncms v8.0 (current version). The latest version of emoncms introduces a 'key' to identify inputs within each emoncms node group, and is automatically assigned by emoncms, but for this to occur, it is necessary to change the format of the payload. The changes have also been tested with multiple inputs in the same node, ie inject a comma-separated payload such as 100,98,365 and emoncms will automatically parse the values, and result in 3 inputs within the same emoncms node. These changes are also backwards-compatible with previous emoncms versions.
111 lines
3.4 KiB
JavaScript
111 lines
3.4 KiB
JavaScript
/**
|
|
* Copyright 2013 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.
|
|
*/
|
|
|
|
var RED = require(process.env.NODE_RED_HOME+"/red/red");
|
|
//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;
|
|
var credentials = RED.nodes.getCredentials(n.id);
|
|
if (credentials) {
|
|
this.apikey = credentials.apikey;
|
|
}
|
|
|
|
}
|
|
RED.nodes.registerType("emoncms-server",EmoncmsServerNode);
|
|
|
|
var querystring = require('querystring');
|
|
|
|
RED.httpAdmin.get('/emoncms-server/:id',function(req,res) {
|
|
var credentials = RED.nodes.getCredentials(req.params.id);
|
|
if (credentials) {
|
|
res.send(JSON.stringify({apikey:credentials.apikey}));
|
|
} else {
|
|
res.send(JSON.stringify({}));
|
|
}
|
|
});
|
|
|
|
RED.httpAdmin.delete('/emoncms-server/:id',function(req,res) {
|
|
RED.nodes.deleteCredentials(req.params.id);
|
|
res.send(200);
|
|
});
|
|
|
|
RED.httpAdmin.post('/emoncms-server/:id',function(req,res) {
|
|
|
|
var body = "";
|
|
req.on('data', function(chunk) {
|
|
body+=chunk;
|
|
});
|
|
req.on('end', function(){
|
|
var newCreds = querystring.parse(body);
|
|
var credentials = RED.nodes.getCredentials(req.params.id)||{};
|
|
if (newCreds.apikey == null || newCreds.apikey == "") {
|
|
delete credentials.apikey;
|
|
} else {
|
|
credentials.apikey = newCreds.apikey;
|
|
}
|
|
RED.nodes.addCredentials(req.params.id,credentials);
|
|
res.send(200);
|
|
});
|
|
});
|
|
|
|
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.apikey;
|
|
|
|
this.topic = n.topic ||"";
|
|
this.nodegroup = n.nodegroup || "";
|
|
var node = this;
|
|
if (this.baseurl.substring(0,5) === "https") { var http = require("https"); }
|
|
else { var http = require("http"); }
|
|
this.on("input", function(msg) {
|
|
|
|
var topic = this.topic || msg.topic;
|
|
var nodegroup = this.nodegroup || msg.nodegroup;
|
|
if(nodegroup != ""){
|
|
this.url = this.baseurl + '/input/post.json?node=' + nodegroup + '&csv=' + msg.payload+'&apikey='+this.apikey;
|
|
}
|
|
node.log("[emoncms] "+this.url);
|
|
http.get(this.url, function(res) {
|
|
node.log("Http response: " + res.statusCode);
|
|
msg.rc = res.statusCode;
|
|
msg.payload = "";
|
|
if ((msg.rc != 200) && (msg.rc != 404)) {
|
|
node.send(msg);
|
|
}
|
|
res.setEncoding('utf8');
|
|
res.on('data', function(chunk) {
|
|
msg.payload += chunk;
|
|
});
|
|
res.on('end', function() {
|
|
node.send(msg);
|
|
});
|
|
}).on('error', function(e) {
|
|
// node.error(e);
|
|
msg.rc = 503;
|
|
msg.payload = e;
|
|
node.send(msg);
|
|
});
|
|
});
|
|
}
|
|
|
|
RED.nodes.registerType("emoncms",Emoncms);
|