Up coverage

Author: tilfin

test/fixtures/data/invalid_json.txt

@@ -0,0 +1 @@
+{"Invalid":data}

test/fixtures/data/valid_json.txt

@@ -0,0 +1 @@
+{"foo":1,"bar":true,"baz":"Hi"}

test/fixtures/events/agg-data-invalid.json

@@ -0,0 +1,20 @@
+{
+    "Records": [
+        {
+            "kinesis": {
+                "kinesisSchemaVersion": "1.0",
+                "partitionKey": "a",
+                "sequenceNumber": "49565441425403787852263465772251211695429557620804943874",
+                "data": "84mawgogMWRiYjgxMGFhNjQwYTRjYzRkNDM3ZjFjOTk1ZDE5MDkKIDM4OGE1YjExYjFhNDA4ZTNiNWRmOGI4YTVhY2MzMGM5CiBlYzZmODc3MmNjYjQyMzM0NmFkYWJhNjE1ZTc4N2RmNwogODQzMDRjN2RhNjE5MmJmNDAxYmI0YTNkOTZkNGUyZGYKIDllYjUzNzljNGNjNjM4YmU5Nzc0NGEzYjhiZjUxOGI3GnsIABp3eyJuYW1lIjoiaW5mby1sb2ciLCJob3N0bmFtZSI6InRrMi0yMTgtMTg3OTYiLCJwaWQiOjI0MjY4LCJsZXZlbCI6MzAsImNvdW50ZXIiOjExLCJtc2ciOiJUaGlzIGlzIGEgaW5mbyBtZXNzYWdlIiwidiI6MH0aewgBGnd7Im5hbWUiOiJpbmZvLWxvZyIsImhvc3RuYW1lIjoidGsyLTIxOC0xODc5NiIsInBpZCI6MjQyNjgsImxldmVsIjozMCwiY291bnRlciI6MTEsIm1zZyI6IlRoaXMgaXMgYSBpbmZvIG1lc3NhZ2UiLCJ2IjowfRp9CAIaeXsibmFtZSI6ImVycm9yLWxvZyIsImhvc3RuYW1lIjoidGsyLTIxOC0xODc5NiIsInBpZCI6MjQyNjgsImxldmVsIjo1MCwiY291bnRlciI6MTIsIm1zZyI6IlRoaXMgaXMgYSBlcnJvciBtZXNzYWdlIiwidiI6MH0angEIAxqZAXsibmFtZSI6ImRlYnVnLWxvZyIsImhvc3RuYW1lIjoidGsyLTIxOC0xODc5NiIsInBpZCI6MjQyNjgsImxldmVsIjoyMCwiY291bnRlciI6MywiZGF0YSI6eyJmb28iOiJiaXoiLCJiYXIiOmZhbHNlfSwibXNnIjoiVGhpcyBpcyBhIGRlYnVnIG1lc3NhZ2UiLCJ2IjowfRqeAQgEGpkBeyJuYW1lIjoiZGVidWctbG9nIiwiaG9zdG5hbWUiOiJ0azItMjE4LTE4Nzk2IiwicGlkIjoyNDI2OCwibGV2ZWwiOjIwLCJjb3VudGVyIjoxLCJkYXRhIjp7ImZvbyI6ImJpeiIsImJhciI6ZmFsc2V9LCJtc2ciOiJUaGlzIGlzIGEgZGVidWcgbWVzc2FnZSIsInYiOjB99KaxOTkRznQJVnwdxryJ5$==",
+                "approximateArrivalTimestamp": 1473001463.638
+            },
+            "eventSource": "aws:kinesis",
+            "eventVersion": "1.0",
+            "eventID": "shardId-000000000000:49565441425403787852263465772251211695429557620804943874",
+            "eventName": "aws:kinesis:record",
+            "invokeIdentityArn": "arn:aws:iam::986450800000:role/lambda_basic_execution",
+            "awsRegion": "ap-northeast-1",
+            "eventSourceARN": "arn:aws:kinesis:ap-northeast-1:986450800000:stream/kpl-stream"
+        }
+    ]
+}

test/fixtures/events/data-0.json

@@ -0,0 +1,20 @@
+{
+    "Records": [
+        {
+            "kinesis": {
+                "kinesisSchemaVersion": "1.0",
+                "partitionKey": "485bd0f3c7f8b6ec3ddc6ada18abcf8d",
+                "sequenceNumber": "49565441425403787852263465772329791873704550161163747330",
+                "data": "ZGF0YQ==",
+                "approximateArrivalTimestamp": 1473002069.264
+            },
+            "eventSource": "aws:kinesis",
+            "eventVersion": "1.0",
+            "eventID": "shardId-000000000000:49565441425403787852263465772329791873704550161163747330",
+            "eventName": "aws:kinesis:record",
+            "invokeIdentityArn": "arn:aws:iam::986450800000:role/lambda_basic_execution",
+            "awsRegion": "ap-northeast-1",
+            "eventSourceARN": "arn:aws:kinesis:ap-northeast-1:986450800000:stream/kpl-stream"
+        }
+    ]
+}

test/json_stream.test.js

@@ -0,0 +1,44 @@
+'use strict';
+
+const fs = require('fs');
+const chai = require('chai');
+const assert = chai.assert;
+
+const JSONTransform = require('../lib/json_transform');
+
+
+describe('KinesisLambda.parseJSON', () => {
+  context('passed valid JSON', () => {
+    it('raises finish event', (done) => {
+      const readStream = fs.createReadStream(__dirname + '/fixtures/data/valid_json.txt');
+      const jsonStream = JSONTransform()
+        .on('finish', function() {
+          assert.isOk(true);
+          done();
+        })
+        .on('error', function(err) {
+          assert.ifError(err);
+          done();
+        });
+
+      readStream.pipe(jsonStream);
+    });
+  });
+
+  context('passed invalid JSON', () => {
+    it('raises error event', (done) => {
+      const readStream = fs.createReadStream(__dirname + '/fixtures/data/invalid_json.txt');
+      const jsonStream = JSONTransform()
+        .on('finish', function() {
+          assert.isOk(false);
+          done();
+        })
+        .on('error', function(err) {
+          assert.instanceOf(err, SyntaxError);
+          done();
+        });
+
+      readStream.pipe(jsonStream);
+    });
+  });
+});

test/read_stream.test.js

@@ -0,0 +1,42 @@
+'use strict';
+
+const es = require('event-stream');
+const chai = require('chai');
+const assert = chai.assert;
+
+const KLReader = require('../lib/read_stream');
+
+
+describe('KinesisLambda.reader', () => {
+  context('called function', () => {
+    it('OK', () => {
+      const event = require('./fixtures/events/data-0');
+      const readStream = KLReader(event);
+
+      readStream
+        .pipe(es.writeArray(function(err, array) {
+          assert.equal(array[0].toString(), 'data');
+        }))
+        .on('end', function() {
+          assert.isOk(true);
+          done();
+        });
+    });
+  });
+
+  context('aggregation mode', () => {
+    context('data is invalid base64', () => {
+      it('raises error event', (done) => {
+        const event = require('./fixtures/events/agg-data-invalid');
+        const readStream = KLReader(event, { isAgg: true });
+
+        readStream.on('error', function(err) {
+            assert.instanceOf(err, Error);
+            done();
+          });
+
+        readStream.pipe(process.stdout);
+      });
+    });
+  });
+});