88-emoncms.js

/**
 * 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.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) {
        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;
        }
        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);