From 112a3abdc71e7873c37f6c0db39af61831ee7da1 Mon Sep 17 00:00:00 2001
From: henols <henols@gmail.com>
Date: Fri, 7 Feb 2014 12:08:16 +0100
Subject: [PATCH] Emoncms

A node that can publish to one or more Emoncms servers and acconts
---
 io/emoncms/88-emoncms.html        |  94 ++++++++++++++++++++++++++++++
 io/emoncms/88-emoncms.js          |  71 ++++++++++++++++++++++
 io/emoncms/icons/emoncms-logo.png | Bin 0 -> 1418 bytes
 3 files changed, 165 insertions(+)
 create mode 100644 io/emoncms/88-emoncms.html
 create mode 100644 io/emoncms/88-emoncms.js
 create mode 100644 io/emoncms/icons/emoncms-logo.png

diff --git a/io/emoncms/88-emoncms.html b/io/emoncms/88-emoncms.html
new file mode 100644
index 00000000..ff71828b
--- /dev/null
+++ b/io/emoncms/88-emoncms.html
@@ -0,0 +1,94 @@
+<!--
+  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.
+-->
+
+<script type="text/x-red" data-template-name="emoncms">
+    <div class="form-row">
+        <label for="node-input-emonServer"><i class="icon-globe"></i> Emoncms server</label>
+        <input type="text" id="node-input-emonServer">
+    </div>
+    <div class="form-row">
+        <label for="node-input-topic"><i class="icon-tasks"></i> Topic</label>
+        <input type="text" id="node-input-topic" placeholder="">
+    </div>
+    <div class="form-row">
+        <label for="node-input-name"><i class="icon-tag"></i> Name</label>
+        <input type="text" id="node-input-name" placeholder="Emoncms">
+    </div>
+    <div class="form-row">
+        <label for="node-input-nodegroup"><i class="icon-tag"></i> Node</label>
+        <input type="text" id="node-input-nodegroup" placeholder="">
+    </div>
+    <div class="form-tips">If Topic is left blank the output Topic is the same as the input Topic.</div>
+</script>
+
+<script type="text/x-red" data-help-name="emoncms">
+	<p>Performs post to Emoncms.</p>
+	<p>The Topic is not mandatory, if Topic is left blank <b>msg.topic</b> will used.</p>
+	<p>The Node is not mandatory, (numberic)</p>
+</script>
+
+<script type="text/javascript">
+    RED.nodes.registerType('emoncms',{
+        category: 'output',
+        color:"rgb(91, 192, 222)",
+         defaults: {
+            name: {value:"Emoncms"},
+            emonServer: {type:"emoncms-server", required:true},
+            topic: {value:""},
+            nodegroup: {value:""}
+        },
+        inputs:1,
+        outputs:0,
+        icon: "emoncms-logo.png",
+        align: "right",
+        label: function() {
+            return this.name||this.baseurl;
+        },
+        labelStyle: function() {
+            return this.name?"node_label_italic":"";
+        }
+    });
+</script>
+
+<script type="text/x-red" data-template-name="emoncms-server">
+    <div class="form-row">
+        <label for="node-config-input-server"><i class="icon-globe"></i> Base URL</label>
+        <input type="text" id="node-config-input-server">
+    </div>
+    <div class="form-row">
+        <label for="node-config-input-apikey"><i class="icon-tasks"></i> API key</label>
+        <input type="text" id="node-config-input-apikey">
+    </div>
+    <div class="form-row">
+        <label for="node-config-input-name"><i class="icon-tag"></i> Name</label>
+        <input type="text" id="node-config-input-name">
+    </div>
+<div class="form-tips">The <b>Base URL</b> is the URL to the Emoncms root directory.</div>
+</script>
+
+<script type="text/javascript">
+    RED.nodes.registerType('emoncms-server',{
+        category: 'config',
+        defaults: {
+            server: {value:"http://localhost",required:true},
+            apikey: {value:"",required:true},
+            name: {value:""}
+        },
+        label: function() {
+            return this.name||this.server;
+        }
+    });
+</script>
diff --git a/io/emoncms/88-emoncms.js b/io/emoncms/88-emoncms.js
new file mode 100644
index 00000000..a40ee9a5
--- /dev/null
+++ b/io/emoncms/88-emoncms.js
@@ -0,0 +1,71 @@
+/**
+ * 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.apikey = n.apikey;
+    this.name = n.name;
+}
+RED.nodes.registerType("emoncms-server",EmoncmsServerNode);
+
+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;
+		this.url = this.baseurl + '/input/post.json?json={' + topic + ':' + msg.payload+'}&apikey='+this.apikey;
+		if(this.nodegroup != ""){
+			this.url += '&node='+this.nodegroup;
+		}
+		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);
diff --git a/io/emoncms/icons/emoncms-logo.png b/io/emoncms/icons/emoncms-logo.png
new file mode 100644
index 0000000000000000000000000000000000000000..8cde78715855be139d55b070f2f3bd97fb28b410
GIT binary patch
literal 1418
zcmV;51$Fv~P)<h;3K|Lk000e1NJLTq000;O000;W1^@s6;CDUv00004b3#c}2nYxW
zd<bNS00009a7bBm000VM000VM0sPELB>(^b8FWQhbW?9;ba!ELWdL_~cP?peYja~^
zaAhuUa%Y?FJQ@H11qVq)K~zYIwU$e4RM#DczjN+$#$(SbeheOi85@%{kPzA;<4`M2
zLVyTxB1KLXRg>-#q;9fFltr3dqApr>m#S)|c2iYiL#%cMrFEJ(AvPG8$k>R7J=haG
zhVi@~_i?(gu^^&Rk;0LFyL-M*_kSM$Ba~7+%po5t{XqpIBO|S&qobh*nIpcdL`RMs
z=@vq~0X%CM=C(*AY%8V6=kqn!^)4&r|5FI@=drP|#RnD~K7908TU+b<0|VPT13??7
z=}@g!5mM3;45H~em2z3l&dx4ZtCbJN#>PJWzXT&ABb$8RKb}gZcE;oJ(Cpl0BH=LI
z$s~zH0;S;QH(72hE>bKM8Q4BRHk&Oi%wJDyn)b?x6DOAbr(kq+)T}oeGf(V%GF2!R
zP`+aDg`-^cqTKXas0)j~U4gjXU{|QZv(ekk{p%A<)4&b{RXTlPu3ReZIDPuGdxv??
zB9}^~-}I&Wx)+xg+5UsaNId^@PC0#Kv@YC06eG}ruv@q#Bb+RE@$S`rZa(!oTlxmL
zefyT!vZZ&kZQCE-&D;<iI&|pAkx2A4z)B{QEVd7FRdrz6K@2N^VFl2w0Ky0$&9!KD
zkbmSmI4%Z>#$p6)I}mJX`NhG52cNv(AN--St1F&cS)p(5K~_W*!?Mv$8_l$khKV#R
zl)e^WSV+S{nl{tb2+eKJkj-XECVS#asgLgw2qA=F7@hTco#CJC!)lH4;#Qqq?GmXQ
z2+aV^0IA~&9Zwqg(g4lm3F{W!xv%*9`6Y&)9>R4TG+pn$N3ehY{(fCIbkB9^O!hMM
z=}Ep>%Fq+Gc_}664-1r#ctX-t5*JCzEb`du8Pe%AOT{J&MHefYz;#_r!!!>ZIItB!
z2XGu`k71Z$$7v!$F#;{E{PoxG&>DS&y)TZk>!*i#Jg)KCP3Y2UY$>KWcQuQKLJA2&
zB7|h7AgI-9n5Gpj6jt{D*K`0W<)eThghT?54?Ra}=MOplyI-;V^#o(*|APp$k=oqD
z&=;R`#R;Rw_MoiR_07H(UkRiX0Jad?_Kgy`t~*hwlq<gP5!5`C@`-jNc=Mw_;@NHZ
zP7_%xGI#MDo7!XS+obc%${3ql1)xB!WoM!V-&a&B)dKimZU_v+n5xxlWlhtl7xO63
z!*t37Rxb0SN4KJUkA?Z`7`jFvU?YXXmhe{M2Ja1p>5J%?0@@7+UDv5Msud~a<i;AD
zI&~^PJUr~VuE)g-7uY)-<MLFR@$qqN+a?qWQE$xSc`iyR)-OEHPfz1{lN=iw!g_ie
zi<wzm*Tr?*=J@!(O8~kMLIRra`{ydvYF9daQ7$aZ(`Yn^$7AGjx%%APY{_w){H05?
zo8ynftx~b%Hk%Dquh(dAZ#SnVClO+bTCGN@Ty{OrodPr=gw)rHh{|L#zXb8w)>JCt
zc^;akF+Dw<TU}lK%goHoiF&<GEEenN?(TV^P{>a%FE7tktJRmY+3e5y`}^aXrlFK#
zCAYks&1T=e!xc&?gb*5F?%uuo)kq}z+qSkgb7duWZGL|KtxP791GM#s_4A_u5Ac%7
zWM^-0@9#T0I(qV}g?eE%f9&kpv!4J>rIdHiZ7PH?1_y`!<oj;!%$YMEt^@DDzuo=(
zJCaZ+q;~As@xBluI59Etrc%n;VBW9c2qDBeP`?W<zV(^9OX32)x)1C-TjuvM9{Q`|
YzxtOj(?|bkT>t<807*qoM6N<$f*O9OkpKVy

literal 0
HcmV?d00001