From fbe2078324cd9e5dd1a338a7c455d53aae81aaaf Mon Sep 17 00:00:00 2001
From: Brian Orpin <brian.orpin@gmail.com>
Date: Sun, 7 Feb 2021 22:32:58 +0000
Subject: [PATCH] Return all feed data (#743)

---
 io/emoncms/88-emoncms.html | 4 +++-
 io/emoncms/88-emoncms.js   | 9 ++++++---
 2 files changed, 9 insertions(+), 4 deletions(-)

diff --git a/io/emoncms/88-emoncms.html b/io/emoncms/88-emoncms.html
index 65789671..7fd323d7 100644
--- a/io/emoncms/88-emoncms.html
+++ b/io/emoncms/88-emoncms.html
@@ -83,7 +83,9 @@
 
 <script type="text/x-red" data-help-name="emoncms in">
     <p>Fetches data from emoncms.</p>
-    <p>The <code>msg.payload</code> contains last emoncms feed value
+    <p>The <code>msg.topic</code> contains the name of the Feed</p>
+    <p>The <code>msg.payload</code> contains last emoncms feed value</p>
+    <p>The <code>msg.feed_data</code> contains all the feed data</p>
 </script>
 
 <script type="text/javascript">
diff --git a/io/emoncms/88-emoncms.js b/io/emoncms/88-emoncms.js
index 0a2814ea..e8e14b5f 100644
--- a/io/emoncms/88-emoncms.js
+++ b/io/emoncms/88-emoncms.js
@@ -160,7 +160,7 @@ module.exports = function(RED) {
         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 = this.baseurl + '/feed/aget.json';
             this.url += '&apikey='+this.apikey;
             var feedid = this.feedid || msg.feedid;
             if (feedid !== "") {
@@ -169,14 +169,17 @@ module.exports = function(RED) {
             http.get(this.url, function(res) {
                 msg.rc = res.statusCode;
                 msg.payload = "";
+                msg.feed_data = "";
                 res.setEncoding('utf8');
                 res.on('data', function(chunk) {
-                    msg.payload += chunk;
+                    msg.feed_data += chunk;
                 });
                 res.on('end', function() {
                     if (msg.rc === 200) {
                         try {
-                            msg.payload = JSON.parse(msg.payload);
+                            msg.feed_data = JSON.parse(msg.feed_data);
+                            msg.topic = msg.feed_data.name;
+                            msg.payload = msg.feed_data.value;
                         }
                         catch(err) {
                             // Failed to parse, pass it on