Fixed IAM roles

Author: bigsnarfdude

ProcessKinesisRecords.js

@@ -1,3 +1,16 @@
+/*
+ * Copyright (c) 2015 Snowplow Analytics Ltd. All rights reserved.
+ *
+ * This program is licensed to you under the Apache License Version 2.0,
+ * and you may not use this file except in compliance with the Apache License Version 2.0.
+ * You may obtain a copy of the Apache License Version 2.0 at http://www.apache.org/licenses/LICENSE-2.0.
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the Apache License Version 2.0 is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the Apache License Version 2.0 for the specific language governing permissions and limitations there under.
+ */
+
 console.log('Loading ProcessKinesisRecordsDynamoDB function');
 
 var aws = require('aws-sdk');
@@ -33,8 +46,8 @@ exports.kinesisHandler = function(records, context) {
         });
     });
 
-
     ///////////////////////////////helper functions ////////////////////////////////
+
     // update item to DynamoDB
     function updateDynamoDB (params, callback) {
         table.updateItem(params, function (err, data) {
@@ -44,7 +57,6 @@ exports.kinesisHandler = function(records, context) {
         });
     }
 
-
     // creating records objects to sort
     function aggregateData(payload) {
         var datum = JSON.parse(payload);
@@ -78,7 +90,6 @@ exports.kinesisHandler = function(records, context) {
         return params;
     }
 
-
     // manual check of UTC build zero adder
     function pad(number) {
         var r = String(number);
@@ -88,7 +99,6 @@ exports.kinesisHandler = function(records, context) {
         return r;
     }
 
-
     // downsample function for creating metadata
     function downsample(dateObject) {
         return dateObject.getUTCFullYear()
@@ -101,13 +111,10 @@ exports.kinesisHandler = function(records, context) {
     context.done();
 };
 
-
 // main function
 exports.handler = function(event, context) {
     var record = event.Records[0];
     if (record.kinesis) {
         exports.kinesisHandler(event.Records, context);
     }
 };
-
-

README.md

@@ -209,7 +209,7 @@ limitations under the License.
 [vagrant-install]: http://docs.vagrantup.com/v2/installation/index.html
 [virtualbox-install]: https://www.virtualbox.org/wiki/Downloads
 
-[blog-post]: http://snowplowanalytics.com/blog/2015/07/10/aws-lambda-nodejs-example-project-0.1.0-released/
+[blog-post]: http://snowplowanalytics.com/blog/2015/07/11/aws-lambda-nodejs-example-project-0.1.0-released/
 [020-milestone]: https://github.com/snowplow/aws-lambda-nodejs-example-project/milestones/Version%200.2.0
 [dynamodb-table-image]: /docs/dynamodb-table-image.png?raw=true
 

tasks/deployLambda.js

@@ -39,10 +39,19 @@ module.exports = function (grunt) {
                 if (err) { 
                     console.log(err, err.stack); 
                 } else { 
-                    DEFAULTS['arn'] = data.Roles[0].Arn;
-                    console.log(DEFAULTS.arn);
-                callback(err);
+                    DEFAULTS['arnRoles'] = data.Roles;
+                    for (var i = 0; i < DEFAULTS.arnRoles.length; i++) {
+                        var lambdaRole = data.Roles[i].Arn;
+                        if (lambdaRole.indexOf("LambdaExecRole") > 38 && lambdaRole.indexOf("LambdaExecRole") < 48) {
+                            DEFAULTS['arn'] = data.Roles[i].Arn;
+                            console.log("Found");
+                            console.log(DEFAULTS.arn);
+                        } else {
+                            console.log("Looking for ... kinesisDynamo-LambdaExecRole");
+                        }
+                    }
                 }
+                callback(err);
             });
         }
 

tasks/iam.js

@@ -37,7 +37,18 @@ module.exports = function (grunt) {
                 if (err) { 
                     console.log(err, err.stack); 
                 } else { 
-                    opts.params.RoleName = data.Roles[0].RoleName;
+                    opts.params['arnRoles'] = data.Roles;
+                    for (var i = 0; i < opts.params.arnRoles.length; i++) {
+                        //opts.params.RoleName = data.Roles[0].RoleName;
+                        var lambdaRole = data.Roles[i].RoleName;
+                        if (lambdaRole.indexOf("LambdaExecRole") > 0) {
+                            opts.params.RoleName = data.Roles[i].RoleName;
+                            console.log("Found");
+                            console.log(opts.params.RoleName);
+                        } else {
+                            console.log("Looking for ... kinesisDynamo-LambdaExecRole");
+                        }
+                    }
                 callback(err);
                 }
             });

tasks/packaging.js

@@ -24,7 +24,7 @@ module.exports = function (grunt) {
         var opts = this.options(DEFAULTS);
         var done = this.async();
         var pkg = grunt.file.readJSON(path.resolve(DEFAULTS.package_folder + '/package.json'));
-        var dir = { path: './temp/' } //new tmp.Dir();
+        var dir = { path: './dist/' };
         var now = new Date();
         var time_string = 'latest';
         var file_version = pkg.version.replace(/\./g, '-');