Merge pull request #108 from lakindu95/v1

Initial Mocha tests

Author: rehrumesh

.travis.yml

@@ -4,8 +4,43 @@ node_js:
 
 sudo: false
 
+before_install:
+  - cd test
+  - mkdir sample-template
+  - cd sample-template
+  - npm init --yes
+
 install:
+  - npm install --save-dev serverless-offline 
+  - npm install -g [email protected]
+  - npm install aws-sdk
+  - npm install --save dynamodb-doc-client-wrapper
+  - serverless create --template aws-nodejs
+  - cd ..
+  - cd ..
+  - npm link
+  - cd test/sample-template/node_modules
+  - npm link serverless-dynamodb-local
+  - cd ..
+  - sed -i '18 a plugins:' serverless.yml
+  - sed -i '19 a - serverless-offline' serverless.yml
+  - sed -i '20 a - serverless-dynamodb-local' serverless.yml
+  - cd ..
+  - cd ..
+  - npm install --save-dev mocha
+  - npm install --save-dev should
+  - npm install --save expect
+  - npm install --save request
+  - npm install --save chai
   - travis_retry npm install
+  - cd test/sample-template
 
+before_script:
+  - sls dynamodb install
+  - sls dynamodb start -p 3000 & 
+  - cd .. 
+  - cd ..
+  - npm run test
+  
 script:
-  - npm test
+  - npm test

package.json

@@ -29,7 +29,7 @@
     "main": "index.js",
     "bin": {},
     "scripts": {
-        "test": "echo \"Warning: no test specified\" && exit 0"
+        "test": "mocha ./test"
     },
     "dependencies": {
         "aws-sdk": "^2.7.0",

test/indexTest.js

@@ -1,24 +1,68 @@
-var should = require("should");
-var request = require("request");
-var expect = require("chai").expect;
-var util = require("util");
-
-var assert = require('chai').assert;
-var config = require('../index');
-
-describe('Unit Test', function () {
-    it('Check endpoint', function () {
-        before(function () {
-            config.listen(8989);
-        });
-        after(function () {
-            console.log('after');
-        });
+"use strict";
+//Define the modules required to mocha testing
+const assert = require("chai").assert;
+const http = require ("http");
+const expect = require("chai").expect;
+const should = require("should");
+const aws = require ("aws-sdk");
+const seeder = require("../src/seeder.js");
+const dataApp = require("../index.js");
+
+describe("Port function",function(){
+  it("Port should return number",function(){
+    let myport = dataApp.prototype.port;
+    assert(typeof myport, "number");
+  });
+
+  it("Port value should be >= 0 and < 65536",function () {
+  http.get(dataApp.prototype.port, function (response) {
+    assert.equal(response.statusCode, 200);
     });
+  });
+});
 
-    it('Check timeout test to 1000ms', () => {
-        this.timeout(1000);
-        assert.ok(true);
+describe("Check the dynamodb function",function(){
+  it("Endpoint should listen to the port",function () {
+     let server;
+     before(function () {
+      server = dynamodbOptions.listen(port);
+     });
+     after(function () {
+      assert.ok;
+     });
     });
+
+  it("Should be an object",function(){
+    let dynamoOptions = dataApp.prototype.dynamodbOptions;
+    let raw = new aws.DynamoDB(dynamoOptions);
+    raw.should.be.type("object");
+  });
+  
+  it("Should be an object",function(){
+    let dynamoOptions =  dataApp.prototype.dynamodbOptions;
+    let doc = new aws.DynamoDB(dynamoOptions);
+    doc.should.be.type("object");
+  });
 });
 
+describe ("Start handler function",function(){
+  it ("Should not  be null",function(){
+    let handler = dataApp.prototype.startHandler;
+    assert(handler =! null);
+  });
+});
+
+
+describe ("createTable functon",function(){
+  it ("Should check as a function",function(){
+    const tbl = dataApp.prototype.createTable;
+    assert.equal(typeof tbl, "function");
+  });
+}); 
+
+describe ("Check the Seeder file",function(){
+  it("Table name shoud be a string",function(){
+    let tblName = seeder.writeSeeds.name;
+    expect(tblName).to.be.a("string");
+  });
+});

test/testItems.js

@@ -0,0 +1,120 @@
+"use strict";
+const assert = require("chai").assert;
+const http = require ("http");
+const expect = require("chai").expect;
+const should = require("should");
+const aws = require ("aws-sdk");
+
+aws.config.update({ accessKeyId: "localAccessKey", secretAccessKey: "localSecretAccessKey", region: "localRegion"});
+var db = new aws.DynamoDB({ endpoint: "http://localhost:8000" });
+var dbClient = new aws.DynamoDB.DocumentClient({ endpoint: "http://localhost:8000"});
+
+describe("#Add Items", function() {
+  this.timeout(30000);
+  it("should add item to table", function(done) {
+    {
+      var params = {
+        TableName:"MyMovie",
+        Item:{
+            "year": 2017,
+            "title": "Big Movie",
+            "info":{
+                "plot": "Nothing happens at all.",
+                "rating": 0
+            }            
+        }
+      };
+      dbClient.put(params, function(err, data) {
+        if (err) {
+          should.not.exist(data); 
+        } else {
+          assert.isNotNull(data.Attributes);
+          assert.isOk(true, "This will pass");
+        }
+        done();
+      });
+    };
+  });
+});
+
+describe("#Update Items", function(){
+  this.timeout(30000);
+  it("should update the items", function(done){
+    var params = {
+      TableName:"MyMovie",
+      Key:{
+          "year": 2017,
+          "title": "Big Movie"
+      },
+      UpdateExpression: "set info.rating = :r, info.plot=:p, info.actors=:a",
+      ExpressionAttributeValues:{
+        ":r":5.4,
+        ":p":"Everything happens all at once.",
+        ":a":["Steve", "Jonson", "Cethie"]
+      },
+      ReturnValues:"UPDATED_NEW"
+    };
+    dbClient.update(params, function(err,data){
+      if(err){
+        should.exist(err);
+      } else {
+      assert.isNotNull(data.Attributes);
+      assert.isOk(true, "This will pass");
+      }
+      done();
+    });  
+  });
+});
+
+describe("#Delete Items", function(){
+  this.timeout(30000);
+  it("should delete the items", function(done){
+    var params = {
+      TableName:"Movies10",
+      Key:{
+        "year":2017,
+        "title":"Big Movie"
+      },
+      ConditionExpression:"info.rating <= :val",
+      ExpressionAttributeValues: {
+        ":val": 5.0
+      }
+    };
+    dbClient.delete(params, function(err, data) {
+      if (err) {
+        should.exist(err); 
+      } else {
+        should.not.exist(data); 
+      }
+      done();
+    });
+  });
+});
+
+describe("#Retrieving from database",function(){
+  this.timeout(30000);
+  var params = {
+    TableName : "Movies10",
+    KeyConditionExpression: "#yr = :yyyy",
+    ExpressionAttributeNames:{
+      "#yr": "year"
+    },
+    ExpressionAttributeValues: {
+      ":yyyy":2017
+    }
+  };
+  
+  it ("Getting data from the table", function(done){
+    this.timeout(30000);
+    dbClient.query(params, function(err, data) {
+      if (err) {
+        should.exist(err); 
+      } else {
+        data.Items.forEach(function(item) {
+          assert.equal(item.year + ": " + item.title, "2017: Big Movie", "==Matching the values.");
+        });
+      }
+      done();
+    });
+  });
+});

test/testTable.js

@@ -0,0 +1,118 @@
+"use strict";
+//Define the modules required to mocha testing
+const assert = require("chai").assert;
+const http = require ("http");
+const expect = require("chai").expect;
+const should = require("should");
+const aws = require ("aws-sdk");
+const dynamodbLocal = require("../index.js");
+
+aws.config.update({ accessKeyId: "localAccessKey", secretAccessKey: "localSecretAccessKey", region: "localRegion"});
+var db = new aws.DynamoDB({ endpoint: 'http://localhost:8000' });
+
+describe("Check Table operations", function() {
+  describe("#create table", function() {
+    this.timeout(50000);
+    it("should create a table if not existing", function(done) {
+      var params = {
+      TableName : "Movies",
+      KeySchema: [       
+          { AttributeName: "year", KeyType: "HASH"},  //Partition key
+          { AttributeName: "title", KeyType: "RANGE" }  //Sort key
+      ],
+      AttributeDefinitions: [       
+          { AttributeName: "year", AttributeType: "N" },
+          { AttributeName: "title", AttributeType: "S" },
+          { AttributeName: "info", AttributeType: "S"}
+      ],
+      ProvisionedThroughput: {       
+          ReadCapacityUnits: 1, 
+          WriteCapacityUnits: 1
+        }
+      };
+
+      var create = db.createTable(params, function(err, data) {
+        if (err) {
+           should.not.exist(err);
+        } else {
+           should.exist(data); 
+           data.TableDescription.should.have.property("TableName","Movies");
+           assert.isNumber(data.TableDescription.ProvisionedThroughput.WriteCapacityUnits);
+
+        }
+        done();
+        }); 
+    });
+  });
+
+  describe("#delete table", function(){
+    this.timeout(50000);
+    it("should delete the table", function(done){
+      var params = {"TableName":"Movies"};
+      
+      db.deleteTable(params,function(err,data){
+        if (err){
+          should.not.exist(err);
+          assert.isNull(data);
+        } else {
+          should.exist(data);
+        }
+        done();
+      });
+    });
+  });
+
+  describe("#update table", function(){
+    this.timeout(50000);
+    it("should update the table", function(done){
+      var params = {
+          "AttributeDefinitions": [ 
+              { 
+                "AttributeName": "batch",
+                "AttributeType": "N"
+              }
+          ],   
+          "ProvisionedThroughput": { 
+              "ReadCapacityUnits": 10,
+              "WriteCapacityUnits": 10
+          },
+          "TableName": "Movies"
+        }
+ 
+    db.updateTable(params,function(err,data){
+        if (err){
+            should.not.exist(data);
+        } else {
+            data.TableDescription.should.have.property("TableName","Movies");
+            should.exist(data);
+        }
+        done();
+      });
+    });
+  });
+  describe("queue-handler", function() {
+    this.timeout(50000);
+    it("should connect to dynamodb and list tables", function(done) {
+      db.listTables({}, function(err, data) {
+        if(err){
+            should.exist(err);
+        } else {
+            should.not.exist(data);
+        }
+        done();     
+        });
+    });
+  });
+
+  describe("#getItems", function() {
+    this.timeout(50000);
+    var tableDes = db.getItem({"TableName": "Movies"})
+    it("Retrieve hostname from created tables", function() {
+      assert.equal(tableDes.httpRequest.endpoint.hostname,"localhost");
+    });
+    
+    it("Retrieves the path of the table",function(){
+      assert.equal(tableDes.httpRequest.path, "/");
+    });
+  });
+});