Add Amazon S3 query node.

Author: hindessm

aws/s3.html

@@ -14,6 +14,49 @@
   limitations under the License.
 -->
 
+<script type="text/x-red" data-template-name="amazon s3">
+    <div class="form-row">
+        <label for="node-input-aws"><i class="fa fa-user"></i> AWS</label>
+        <input type="text" id="node-input-aws">
+    </div>
+    <div class="form-row">
+        <label for="node-input-bucket"><i class="fa fa-folder"></i> Bucket</label>
+        <input type="text" id="node-input-bucket" placeholder="bucket name">
+    </div>
+    <div class="form-row node-input-filename">
+         <label for="node-input-filename"><i class="fa fa-file"></i> Filename</label>
+         <input type="text" id="node-input-filename" placeholder="Filename">
+    </div>
+    <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>
+</script>
+
+<script type="text/x-red" data-help-name="amazon s3">
+    <p>Amazon S3 input node. Downloads content from an Amazon S3 bucket. The bucket name can be specified in the node <b>bucket</b> property or in the <b>msg.bucket</b> property. The name of the file to download is taken from the node <b>filename</b> property or the <b>msg.filename</b> property. The downloaded content is sent as <b>msg.payload</b> property. If the download fails <b>msg.error</b> will contain an error object.</p>
+</script>
+
+<script type="text/javascript">
+    RED.nodes.registerType('amazon s3',{
+        category: 'storage-output',
+        color:"#C0DEED",
+        defaults: {
+            aws: {type:"aws-config",required:true},
+            bucket: {required:true},
+            filename: {value:""},
+            name: {value:""},
+        },
+        inputs:1,
+        outputs:1,
+        icon: "amazon.png",
+        align: "right",
+        label: function() {
+            return this.bucket ? "s3 "+this.bucket : "s3";
+        }
+    });
+</script>
+
 <script type="text/x-red" data-template-name="amazon s3 out">
     <div class="form-row">
         <label for="node-input-aws"><i class="fa fa-user"></i> AWS</label>
@@ -50,6 +93,7 @@
             bucket: {required:true},
             filename: {value:""},
             localFilename: {value:""},
+            name: {value:""},
         },
         inputs:1,
         outputs:0,

aws/s3.js

@@ -18,6 +18,52 @@ module.exports = function(RED) {
     "use strict";
     var fs = require('fs');
 
+    function AmazonS3QueryNode(n) {
+        RED.nodes.createNode(this,n);
+        this.awsConfig = RED.nodes.getNode(n.aws);
+        this.region = n.region;
+        this.bucket = n.bucket;
+        this.filename = n.filename || "";
+        var node = this;
+        var AWS = this.awsConfig ? this.awsConfig.AWS : null;
+        if (!AWS) {
+            node.warn("Missing AWS credentials");
+            return;
+        }
+        var s3 = new AWS.S3();
+        node.on("input", function(msg) {
+            msg.filename = filename;
+            var bucket = node.bucket || msg.bucket;
+            if (bucket === "") {
+                node.warn("No bucket specified");
+                return;
+            }
+            var filename = node.filename || msg.filename;
+            if (filename === "") {
+                node.warn("No filename specified");
+                return;
+            }
+            msg.filename = filename;
+            node.status({fill:"blue",shape:"dot",text:"downloading"});
+            s3.getObject({
+                Bucket: bucket,
+                Key: filename,
+            }, function(err, data) {
+                if (err) {
+                    node.warn("download failed " + err.toString());
+                    delete msg.payload;
+                    msg.error = err;
+                } else {
+                    msg.payload = data.Body;
+                    delete msg.error;
+                }
+                node.status({});
+                node.send(msg);
+            });
+        });
+    }
+    RED.nodes.registerType("amazon s3", AmazonS3QueryNode);
+
     function AmazonS3OutNode(n) {
         RED.nodes.createNode(this,n);
         this.awsConfig = RED.nodes.getNode(n.aws);
@@ -34,25 +80,25 @@ module.exports = function(RED) {
         if (AWS) {
             var s3 = new AWS.S3();
             node.status({fill:"blue",shape:"dot",text:"checking credentials"});
-            s3.listObjects({ Bucket: this.bucket }, function(err) {
+            s3.listObjects({ Bucket: node.bucket }, function(err) {
                 if (err) {
                     node.error("AWS S3 error: " + err);
                     node.status({fill:"red",shape:"ring",text:"error"});
                     return;
                 }
                 node.status({});
                 node.on("input", function(msg) {
-                    var bucket = this.bucket || msg.bucket;
+                    var bucket = node.bucket || msg.bucket;
                     if (bucket === "") {
                         node.warn("No bucket specified");
                         return;
                     }
-                    var filename = this.filename || msg.filename;
+                    var filename = node.filename || msg.filename;
                     if (filename === "") {
                         node.warn("No filename specified");
                         return;
                     }
-                    var localFilename = this.localFilename || msg.localFilename;
+                    var localFilename = node.localFilename || msg.localFilename;
                     if (localFilename) {
                         // TODO: use chunked upload for large files
                         node.status({fill:"blue",shape:"dot",text:"uploading"});