Merge pull request #11 from osos/publicdata

added get public data - node

Author: ssadams11

netatmoNodes.html

@@ -258,6 +258,74 @@
 
 <!-- *************************************************************  -->
 
+<script type="text/javascript">
+    console.log("registering netatmo get public data");
+    RED.nodes.registerType('get public data',{
+        category: 'Netatmo',
+        color: '#669966',
+        defaults: {
+            name: {value:""},
+            lat_ne: {value: '15'},
+            lon_ne: {value: '20'},
+            lat_sw: {value: '-15'},
+            lon_sw: {value: '-20'},
+            required_data: {value:'rain,humidity'},
+            filter: {value:"false"},
+            creds: {value:"",type:"configNode"}
+        },
+        inputs:1,
+        outputs:1,
+        icon: "feed.png",
+        label: function() {
+            return "get public data";
+        }
+    });
+</script>
+
+<script type="text/x-red" data-template-name="get public data">
+    <div class="form-row">
+        <label for="node-input-client_id"><i class="icon-tag"></i> Creds</label>
+        <input type="text" id="node-input-creds" placeholder="Add netatmo creds">
+    </div>
+    <div class="form-row">
+        <label for="node-input-lat_ne"><i class="icon-tag"></i> Latitude noth-east corner</label>
+        <input type="text" id="node-input-lat_ne" value="15">
+    </div>
+    <div class="form-row">
+        <label for="node-input-lon_ne"><i class="icon-tag"></i> Longitude noth-east corner</label>
+        <input type="text" id="node-input-lon_ne" value="20">
+    </div>
+    <div class="form-row">
+        <label for="node-input-lat_sw"><i class="icon-tag"></i> Latitude south-west corner</label>
+        <input type="text" id="node-input-lat_sw" value="-15">
+    </div>
+    <div class="form-row">
+        <label for="node-input-lon_sw"><i class="icon-tag"></i> Longitude south-west corner</label>
+        <input type="text" id="node-input-lon_sw" value="-20">
+    </div>
+    <div class="form-row">
+        <label for="node-input-required_data" title="any mix of Temperature,CO2,Rain,Humidity,Pressure,Noise"><i class="icon-tag"></i> Required data</label>
+        <input type="text" id="node-input-required_data" value="rain,humidity">
+    </div>
+    <div class="form-row">
+        <label for="node-input-filter"><i class="icon-tag"></i> Filter</label>
+        <input type="text" id="node-input-filter" value="false">
+    </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="Name">
+    </div>
+</script>
+
+<script type="text/x-red" data-help-name="get public data">
+   <p>This node returns public data from netatmo with this username and credentials.</p>
+   <p>Outputs an object called <b>msg</b> containing <b>msg.topic</b> and
+   <b>msg.payload</b>. msg.payload is JSON.</p>
+   <p>See <a href="https://dev.netatmo.com/resources/technical/reference/weatherapi/getpublicdata" target=_blank>https://dev.netatmo.com/resources/technical/reference/weatherapi/getpublicdata</a> for details on format</p>
+</script>
+
+<!-- *************************************************************  -->
+
 <script type="text/javascript">
     console.log("registering netatmo config node");
         RED.nodes.registerType('configNode',{
@@ -297,3 +365,4 @@
         <label for="node-input-device_id"><i class="icon-tag"></i> Device ID</label>
         <input type="text" id="node-config-input-device_id" placeholder="70:ee:.....">
     </div>
+</script>

netatmoNodes.js

@@ -168,13 +168,13 @@ module.exports = function(RED) {
                 type: this.types
             };
             if ((this.beginDate !== '')&&(this.beginDate !== null)){
-                options.date_begin = JSON.parse(this.beginDate)
+                options.date_begin = JSON.parse(this.beginDate);
             }
             if ((this.endDate !== '')&&(this.endDate !== null)){
-                options.date_end = (this.endDate === 'last' ? 'last' : JSON.parse(this.endDate))
+                options.date_end = (this.endDate === 'last' ? 'last' : JSON.parse(this.endDate));
             }
             if ((this.limit !== '')&&(this.limit !== null)){
-                options.limit = JSON.parse(this.limit)
+                options.limit = JSON.parse(this.limit);
             }
 
                api.getMeasure(options,function(err, measure) {
@@ -219,6 +219,59 @@ module.exports = function(RED) {
     }
     RED.nodes.registerType("get stations data",NetatmoGetStationsData);
     /***************************************************************/
+    function NetatmoGetPublicData(config) {
+        RED.nodes.createNode(this,config);
+        this.creds = RED.nodes.getNode(config.creds);
+        var node = this;
+        this.on('input', function(msg) {
+            config.lat_ne = config.lat_ne || '15';
+            config.lon_ne = config.lon_ne || '20';
+            config.lat_sw = config.lat_sw || '-15';
+            config.lon_sw = config.lon_sw || '-20';
+            config.required_data = config.required_data || 'rain,humidity';
+            config.filter = config.filter || false;
+            this.lat_ne = mustache.render(config.lat_ne, msg);
+            this.lon_ne = mustache.render(config.lon_ne, msg);
+            this.lat_sw = mustache.render(config.lat_sw, msg);
+            this.lon_sw = mustache.render(config.lon_sw, msg);
+            this.required_data = mustache.render(config.required_data, msg);
+            this.filter = mustache.render(config.filter, msg);
+            var netatmo = require('netatmo');
+
+            var auth = {
+                "client_id": this.creds.client_id,
+                "client_secret": this.creds.client_secret,
+                "username": this.creds.username,
+                "password": this.creds.password 
+            };
+            var api = new netatmo(auth);
+            
+            api.on("error", function(error) {
+                node.error(error);
+            });
+
+            api.on("warning", function(error) {
+                node.warn(error);
+            });                 
+            
+            var options = {
+                lat_ne: config.lat_ne,
+                lon_ne: config.lon_ne,
+                lat_sw: config.lat_sw,
+                lon_sw: config.lon_sw,
+                required_data: config.required_data,
+                filter: config.filter,
+            };
+
+               api.getPublicData(options,function(err, data) {
+                msg.payload = data;
+                node.send(msg);
+            });
+        });
+
+    }
+    RED.nodes.registerType("get public data",NetatmoGetPublicData);
+    /***************************************************************/
     function NetatmoConfigNode(n) {
         RED.nodes.createNode(this,n);
         this.client_id = n.client_id;

package.json

@@ -10,7 +10,7 @@
     "url": "git+https://github.com/ssadams11/node-red-contrib-netatmo.git"
   },
   "dependencies": {
-    "netatmo": "2.0.0",
+    "netatmo": "2.2.0",
     "mustache": "2.2.1"
   },
   "version": "0.1.5",
@@ -37,4 +37,4 @@
       "email": "[email protected]"
     }
   ]
-}
+}