add device stream after refactor

device-stream.html

@@ -0,0 +1,46 @@
+<script type="text/javascript">
+    RED.nodes.registerType('device-stream', {
+        category: 'input',
+        color: '#74b9ff',
+        defaults: {
+            name: {value:""},
+            device: {value: "", required:true},
+            resource: {value: "", required:true},
+            interval: {value: "10", required:true},
+            server: {value:"", type:"thinger-server"}
+        },
+        icon:"thinger_logo_white.png",
+        inputs:0,
+        outputs:1,
+        label: function() {
+            return this.name || ((this.device && this.resource) ? (this.device + "/" + this.resource + " ("  + this.interval + "s)") : "Device Stream");
+        }
+    });
+</script>
+
+<script type="text/x-red" data-template-name="device-stream">
+    <div class="form-row">
+        <label for="node-input-name"><i class="fa fa-tag"></i> Name</label>
+        <input type="text" id="node-input-name" placeholder="Name">
+    </div>
+        <div class="form-row">
+        <label for="node-input-device"><i class="fa fa-rocket"></i> Device</label>
+        <input type="text" id="node-input-device" placeholder="Device Identifier">
+    </div>
+        <div class="form-row">
+        <label for="node-input-resource"><i class="fa fa-cog"></i> Resource</label>
+        <input type="text" id="node-input-resource" placeholder="Resource Name">
+    </div>
+    <div class="form-row">
+        <label for="node-input-interval"><i class="fa fa-clock-o"></i> Interval (s)</label>
+        <input type="text" id="node-input-interval" placeholder="Sampling Interval (s)">
+    </div>
+    <div class="form-row">
+        <label for="node-input-server"><i class="fa fa-server"></i> Server</label>
+        <input type="text" id="node-input-server" placeholder="Select Server">
+    </div>
+</script>
+
+<script type="text/x-red" data-help-name="device-stream">
+    <p>Node that reads information from a Thinger.io connected device</p>
+</script>

device-stream.js

@@ -0,0 +1,25 @@
+module.exports = function(RED) {
+
+    function DeviceStreamNode(config) {
+        RED.nodes.createNode(this, config);
+
+        // get node
+        var node = this;
+
+        // get server configuration
+        var server = RED.nodes.getNode(config.server);
+
+        // register listener on creation
+        server.registerDeviceResourceListener(config.device, config.resource, Number(config.interval), node);
+
+        // unregister listener on close
+        node.on('close', function(removed, done) {
+            if(removed){
+                server.unRegisterDeviceResourceListener(config.device, config.resource, node);
+            }
+            done();
+        });
+    }
+
+    RED.nodes.registerType("device-stream", DeviceStreamNode);
+};